academy/mq-container
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Apply mirroring delay to last iteration

Browse Source
This commit is contained in:
Riccardo Biraghi
2018-04-09 15:50:12 +01:00
parent ab5d7ca1d1
commit 6f3672df4f
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
cmd/runmqserver/mirror.go
View File

@@ -171,8 +171,8 @@ func mirrorLog(ctx context.Context, wg *sync.WaitGroup, path string, fromStart b
// Don't seek this time, because we know it's a new file // Don't seek this time, because we know it's a new file
mirrorAvailableMessages(f, mf) mirrorAvailableMessages(f, mf)
} }
select {
case <-ctx.Done(): if <-ctx.Done() {
log.Debugf("Context cancelled for mirroring %v", path) log.Debugf("Context cancelled for mirroring %v", path)
if closing { if closing {
log.Debugf("Shutting down mirror for %v", path) log.Debugf("Shutting down mirror for %v", path)
@@ -180,9 +180,9 @@ func mirrorLog(ctx context.Context, wg *sync.WaitGroup, path string, fromStart b
} }
// Set a flag, to allow one more time through the loop // Set a flag, to allow one more time through the loop
closing = true closing = true
default:
time.Sleep(500 * time.Millisecond)
} }
time.Sleep(500 * time.Millisecond)
} }
}() }()
return errorChannel, nil return errorChannel, nil