Move runner.End to end of SessionExpired

QuangTung97 · Apr 5, 2024 · 7a1ff0e · 7a1ff0e
1 parent a760efe
commit 7a1ff0e
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/curator/fake_client.go b/curator/fake_client.go
@@ -152,13 +152,13 @@ func (s *FakeZookeeper) SessionExpired(clientID FakeClientID) {
 	state.SessionID = 0
 	state.ConnErr = true
 
-	runner := s.Sessions[clientID]
-	runner.End()
-
 	s.runAllCallbacksWithConnectionError(clientID, false)
 
 	s.Zxid++
 	s.deleteNodesRecursiveForSessionID(s.Root, "", sessionID)
+
+	runner := s.Sessions[clientID]
+	runner.End()
 }
 
 func (s *FakeZookeeper) deleteNodesRecursiveForSessionID(parent *ZNode, path string, sessionID int64) {