rouggy/FlexDXCluster
1
1
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

up

Browse Source
This commit is contained in:
Gregory Salaun 2024-10-24 22:06:07 +07:00
parent 09e9c9ef80
commit ab7a2e487f
2 changed files with 9 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
TCPClient.go
View File

@ -150,10 +150,10 @@ func (c *TCPClient) ReadLine() {
c.Log.Info("Start receiving spots") c.Log.Info("Start receiving spots")
} }
start := time.Now() // start := time.Now()
ProcessTelnetSpot(spotRe, message, c.SpotChanToFlex, c.SpotChanToHTTPServer, c.Countries) go ProcessTelnetSpot(spotRe, message, c.SpotChanToFlex, c.SpotChanToHTTPServer, c.Countries)
elapsed := time.Since(start) // elapsed := time.Since(start)
Log.Infof("Total time for processing spot: %s", elapsed) // Log.Infof("Total time for processing spot: %s", elapsed)
// Send the spot message to TCP server // Send the spot message to TCP server
if len(c.TCPServer.Clients) > 0 { if len(c.TCPServer.Clients) > 0 {

5
spot.go
View File

@ -5,6 +5,7 @@ import (
"strconv" "strconv"
"strings" "strings"
"sync" "sync"
"time"
_ "github.com/mattn/go-sqlite3" _ "github.com/mattn/go-sqlite3"
) )
@ -58,6 +59,8 @@ func ProcessTelnetSpot(re *regexp.Regexp, spotRaw string, SpotChanToFlex chan Te
wg := new(sync.WaitGroup) wg := new(sync.WaitGroup)
wg.Add(4) wg.Add(4)
start := time.Now()
go contactRepo.ListByCountry(spot.DXCC, contactsChan, wg) go contactRepo.ListByCountry(spot.DXCC, contactsChan, wg)
contacts := <-contactsChan contacts := <-contactsChan
@ -71,6 +74,8 @@ func ProcessTelnetSpot(re *regexp.Regexp, spotRaw string, SpotChanToFlex chan Te
contactsCall := <-contactsCallChan contactsCall := <-contactsCallChan
wg.Wait() wg.Wait()
elapsed := time.Since(start)
Log.Infof("Checking Db took: %s", elapsed)
if len(contacts) == 0 { if len(contacts) == 0 {
spot.NewDXCC = true spot.NewDXCC = true