Clear the previous hashmap once new SS is downloaded.
diff --git a/listener.go b/listener.go
index 9c002f2..f770dba 100644
--- a/listener.go
+++ b/listener.go
@@ -25,8 +25,15 @@
)
func processSnapshot(snapshot *common.Snapshot) {
- log.Debugf("Snapshot received. Switching to DB version: %s", snapshot.SnapshotInfo)
+ if apidInfo.LastSnapshot != "" && apidInfo.LastSnapshot != snapshot.SnapshotInfo {
+ log.Debugf("Release snapshot for {%s}. Switching to version {%s}",
+ apidInfo.LastSnapshot , snapshot.SnapshotInfo)
+ dataService.ReleaseDB(apidInfo.LastSnapshot)
+ } else {
+ log.Debugf("Process snapshot for version {%s}",
+ snapshot.SnapshotInfo)
+ }
db, err := dataService.DBVersion(snapshot.SnapshotInfo)
if err != nil {
log.Panicf("Unable to access database: %v", err)
