diff options
| -rw-r--r-- | lgc/upload.go | 9 |
1 files changed, 3 insertions, 6 deletions
diff --git a/lgc/upload.go b/lgc/upload.go index 2da1782..23eef21 100644 --- a/lgc/upload.go +++ b/lgc/upload.go @@ -54,7 +54,9 @@ type LoadGeneratingConnectionUpload struct { statusWaiter *sync.Cond } -func NewLoadGeneratingConnectionUpload(url string, keyLogger io.Writer, connectToAddr string, insecureSkipVerify bool, congestionControl *string) LoadGeneratingConnectionUpload { +func NewLoadGeneratingConnectionUpload(url string, keyLogger io.Writer, connectToAddr string, + insecureSkipVerify bool, congestionControl *string, +) LoadGeneratingConnectionUpload { lgu := LoadGeneratingConnectionUpload{ URL: url, KeyLogger: keyLogger, @@ -320,11 +322,6 @@ func (lgu *LoadGeneratingConnectionUpload) doUpload(ctx context.Context) error { lgu.uploadStartTime = time.Now() lgu.lastIntervalEnd = 0 - lgu.statusLock.Lock() - lgu.status = LGC_STATUS_RUNNING - lgu.statusWaiter.Broadcast() - lgu.statusLock.Unlock() - if resp, err = lgu.client.Do(request); err != nil { lgu.statusLock.Lock() lgu.status = LGC_STATUS_ERROR |