anonfunc/upload-baker
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

fix for stats being checked after they are nil

Browse Source
This commit is contained in:
Giovanni Harting
2022-07-25 16:03:02 +02:00
parent 58f787e235
commit f29b90ff9c
1 changed files with 2 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
main.go
View File

@@ -125,6 +125,7 @@ func (m UploadManager) isBWInRange(bw float64) bool {
} }
func (m UploadManager) pingWorker() error { func (m UploadManager) pingWorker() error {
outerLoop:
for { for {
stats, err := doPing(conf.Host, conf.PPP, time.Second) stats, err := doPing(conf.Host, conf.PPP, time.Second)
if err != nil { if err != nil {
@@ -141,19 +142,13 @@ func (m UploadManager) pingWorker() error {
return err return err
} }
if stats == nil {
log.Warningf("ping to %s failed: %v", conf.Host, "no response")
time.Sleep(time.Duration(conf.Interval) * time.Minute)
continue
}
log.Infof("ping %s over threshold detected, starting extended pings...", stats.AvgRtt) log.Infof("ping %s over threshold detected, starting extended pings...", stats.AvgRtt)
for stats.AvgRtt.Milliseconds() >= conf.ThrottlePingThreshold { for stats.AvgRtt.Milliseconds() >= conf.ThrottlePingThreshold {
stats, err = doPing(conf.Host, conf.ConformationPPP, time.Second) stats, err = doPing(conf.Host, conf.ConformationPPP, time.Second)
if err != nil { if err != nil {
log.Warningf("ping to %s failed: %v", conf.Host, err) log.Warningf("ping to %s failed: %v", conf.Host, err)
time.Sleep(time.Duration(conf.Interval) * time.Minute) time.Sleep(time.Duration(conf.Interval) * time.Minute)
continue continue outerLoop
} }
if stats.AvgRtt.Milliseconds() >= conf.ThrottlePingThreshold { if stats.AvgRtt.Milliseconds() >= conf.ThrottlePingThreshold {