0
0
Fork 0

scorch zap mergerLoop missing fireAsyncError case

This commit is contained in:
Steve Yen 2018-01-24 08:39:50 -08:00
parent 37121c3b49
commit 603425c2c5
1 changed files with 1 additions and 1 deletions

View File

@ -54,7 +54,6 @@ OUTER:
lastEpochMergePlanned = ourSnapshot.epoch
s.fireEvent(EventKindMergerProgress, time.Since(startTime))
}
_ = ourSnapshot.DecRef()
@ -81,6 +80,7 @@ OUTER:
// lets get started
err := s.planMergeAtSnapshot(ourSnapshot)
if err != nil {
s.fireAsyncError(fmt.Errorf("merging err: %v", err))
_ = ourSnapshot.DecRef()
continue OUTER
}