bug: fix node shutdown

jamf · Jan 16, 2024 · f2c0922 · f2c0922
1 parent e9a43ae
commit f2c0922
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/storage/engine_events.go b/storage/engine_events.go
@@ -9,12 +9,12 @@ import (
 func (e *Engine) dispatchEvents() {
 	for {
 		select {
-		case <-e.stop:
-			return
 		case evt := <-e.eventsCh:
 			e.log.Infof("raft: %T %+v", evt, evt)
 			switch ev := evt.(type) {
-			case leaderUpdated, nodeUnloaded, membershipChanged, nodeHostShuttingDown:
+			case nodeHostShuttingDown:
+				return
+			case leaderUpdated, nodeUnloaded, membershipChanged:
 				e.Cluster.Notify()
 			case nodeReady:
 				if ev.ReplicaID == e.cfg.NodeID && e.LogCache != nil {