|
@ -146,7 +146,7 @@ func (g *Group) OnStart() error { |
|
|
func (g *Group) OnStop() { |
|
|
func (g *Group) OnStop() { |
|
|
g.ticker.Stop() |
|
|
g.ticker.Stop() |
|
|
if err := g.FlushAndSync(); err != nil { |
|
|
if err := g.FlushAndSync(); err != nil { |
|
|
g.Logger.Error("Error flushin to disk", "err", err) |
|
|
|
|
|
|
|
|
g.Logger.Error("Error flushing to disk", "err", err) |
|
|
} |
|
|
} |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
@ -160,7 +160,7 @@ func (g *Group) Wait() { |
|
|
// Close closes the head file. The group must be stopped by this moment.
|
|
|
// Close closes the head file. The group must be stopped by this moment.
|
|
|
func (g *Group) Close() { |
|
|
func (g *Group) Close() { |
|
|
if err := g.FlushAndSync(); err != nil { |
|
|
if err := g.FlushAndSync(); err != nil { |
|
|
g.Logger.Error("Error flushin to disk", "err", err) |
|
|
|
|
|
|
|
|
g.Logger.Error("Error flushing to disk", "err", err) |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
g.mtx.Lock() |
|
|
g.mtx.Lock() |
|
|