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

rapid decreasing of upload if necessary

Browse Source
This commit is contained in:
Giovanni Harting
2022-07-04 23:29:35 +02:00
parent 06d7d93c5d
commit eee1141dd3
1 changed files with 5 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
main.go
View File

@@ -121,9 +121,8 @@ func (m UploadManager) pingWorker() error {
return err return err
} }
if m.isBWInRange(up - conf.Bandwidth.Step) { log.Infof("Ping %s over threshold detected, starting extensive pinging...", stats.AvgRtt)
log.Infof("Ping over threshold (%s) detected, confirming...", stats.AvgRtt) for stats.AvgRtt.Milliseconds() >= conf.ThrottlePingThreshold && m.isBWInRange(up-conf.Bandwidth.Step) {
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)
@@ -132,16 +131,14 @@ func (m UploadManager) pingWorker() error {
} }
if stats.AvgRtt.Milliseconds() >= conf.ThrottlePingThreshold { if stats.AvgRtt.Milliseconds() >= conf.ThrottlePingThreshold {
log.Infof("Ping confirmed (%s), adjusting upload TC %d->%d", stats.AvgRtt, up, up-conf.Bandwidth.Step) log.Infof("extended ping %s, adjusting upload TC %d->%d", stats.AvgRtt, up, up-conf.Bandwidth.Step)
err = m.SetUpload(up - conf.Bandwidth.Step) err = m.SetUpload(up - conf.Bandwidth.Step)
if err != nil { if err != nil {
return err return err
} }
m.LastOver = time.Now() m.LastOver = time.Now()
} }
} else { time.Sleep(20 * time.Second)
log.Infof("Ping over threshold (%s) detected, but no bandwidth available", stats.AvgRtt)
m.LastOver = time.Now()
} }
} else if time.Since(m.LastOver) >= time.Duration(conf.TryRestoringAfter)*time.Minute { } else if time.Since(m.LastOver) >= time.Duration(conf.TryRestoringAfter)*time.Minute {
up, err := m.Upload() up, err := m.Upload()
@@ -149,7 +146,7 @@ func (m UploadManager) pingWorker() error {
return err return err
} }
if m.isBWInRange(up + conf.Bandwidth.Step) { if m.isBWInRange(up + conf.Bandwidth.Step) {
log.Infof("trying to increase upload TC %d->%d", up, up+conf.Bandwidth.Step) log.Infof("Short ping %s, trying to increase upload TC %d->%d", stats.AvgRtt, up, up+conf.Bandwidth.Step)
err = m.SetUpload(up + conf.Bandwidth.Step) err = m.SetUpload(up + conf.Bandwidth.Step)
if err != nil { if err != nil {
return err return err