From 1bd9db31bca41b0a5b1a3c3e0d5525cabcb634b7 Mon Sep 17 00:00:00 2001 From: Ethan Buchman Date: Wed, 22 Aug 2018 15:53:14 -0400 Subject: [PATCH] libs/autofile: bring back loops --- libs/autofile/autofile.go | 12 +++++++----- libs/autofile/group.go | 14 ++++++++------ 2 files changed, 15 insertions(+), 11 deletions(-) diff --git a/libs/autofile/autofile.go b/libs/autofile/autofile.go index 2f1bb4fd5..b00585285 100644 --- a/libs/autofile/autofile.go +++ b/libs/autofile/autofile.go @@ -67,11 +67,13 @@ func (af *AutoFile) Close() error { } func (af *AutoFile) processTicks() { - select { - case <-af.ticker.C: - af.closeFile() - case <-af.tickerStopped: - return + for { + select { + case <-af.ticker.C: + af.closeFile() + case <-af.tickerStopped: + return + } } } diff --git a/libs/autofile/group.go b/libs/autofile/group.go index e747f04dd..500bdbc7c 100644 --- a/libs/autofile/group.go +++ b/libs/autofile/group.go @@ -199,12 +199,14 @@ func (g *Group) Flush() error { } func (g *Group) processTicks() { - select { - case <-g.ticker.C: - g.checkHeadSizeLimit() - g.checkTotalSizeLimit() - case <-g.Quit(): - return + for { + select { + case <-g.ticker.C: + g.checkHeadSizeLimit() + g.checkTotalSizeLimit() + case <-g.Quit(): + return + } } }