Merge pull request #191 from swapnilgm/fix/cleanup

[hotfix] Cleanup in-memory events before stopping snapshotter
gardener · Aug 22, 2019 · 795902a · 795902a
2 parents ebec08d + fb0d8b2
commit 795902a
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/pkg/snapshot/snapshotter/snapshotter.go b/pkg/snapshot/snapshotter/snapshotter.go
@@ -377,6 +377,7 @@ func (ssr *Snapshotter) CollectEventsSincePrevSnapshot(stopCh <-chan struct{}) (
 				return false, nil
 			}
 		case <-stopCh:
+			ssr.cleanupInMemoryEvents()
 			return true, nil
 		}
 	}
@@ -441,6 +442,7 @@ func (ssr *Snapshotter) snapshotEventHandler(stopCh <-chan struct{}) error {
 				return err
 			}
 		case <-stopCh:
+			ssr.cleanupInMemoryEvents()
 			return nil
 		}
 	}