From 7a1ff0e64956c024178bda0fd57baac52b987c14 Mon Sep 17 00:00:00 2001 From: "tung.tq" Date: Fri, 5 Apr 2024 13:51:55 +0700 Subject: [PATCH] Move runner.End to end of SessionExpired --- curator/fake_client.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/curator/fake_client.go b/curator/fake_client.go index 2f496ca..87b63ed 100644 --- 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) {