Minimize calls to deploymentsChanged
diff --git a/data.go b/data.go index ae8aafd..d36e745 100644 --- a/data.go +++ b/data.go
@@ -144,8 +144,6 @@ return err } - deploymentsChanged <- depID - log.Debugf("deleteDeployment %s succeeded", depID) return err }
diff --git a/listener.go b/listener.go index d895a31..43bab9a 100644 --- a/listener.go +++ b/listener.go
@@ -188,9 +188,15 @@ err = tx.Commit() if err != nil { - log.Panicf("Error committing Snapshot change: %v", err) + log.Panicf("Error processing ChangeList: %v", err) } + if len(deploymentsToDelete) > 0 { + deploymentsChanged <- deploymentsToDelete[0].ID // arbitrary, the ID doesn't matter + } + + log.Debug("ChangeList processed") + for _, dep := range deploymentsToInsert { queueDownloadRequest(dep) }