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 b41a58645b
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
cmd/runmqserver/mirror.go
View File

@@ -171,6 +171,7 @@ 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 { select {
case <-ctx.Done(): case <-ctx.Done():
log.Debugf("Context cancelled for mirroring %v", path) log.Debugf("Context cancelled for mirroring %v", path)
@@ -180,9 +181,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