From b41a58645b5360a52050ae160104a1eb5d05daeb Mon Sep 17 00:00:00 2001 From: Riccardo Biraghi Date: Mon, 9 Apr 2018 15:50:12 +0100 Subject: [PATCH] Apply mirroring delay to last iteration --- cmd/runmqserver/mirror.go | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/cmd/runmqserver/mirror.go b/cmd/runmqserver/mirror.go index 170e608..75cda44 100644 --- a/cmd/runmqserver/mirror.go +++ b/cmd/runmqserver/mirror.go @@ -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 mirrorAvailableMessages(f, mf) } + select { case <-ctx.Done(): 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 closing = true - default: - time.Sleep(500 * time.Millisecond) } + + time.Sleep(500 * time.Millisecond) } }() return errorChannel, nil