Cleanup in-memory events before stopping snapshotter

Signed-off-by: Swapnil Mhamane <[email protected]>
gardener · Aug 22, 2019 · fb0d8b2 · fb0d8b2
1 parent ebec08d
commit fb0d8b2
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
 		}
 	}