fix: close socket to prevent onCompletion call after the journal stre… (

#4270) fix: close socket to prevent onCompletion call after the journal streamer is destroyed
dragonflydb · Dec 8, 2024 · 32ad00b · 32ad00b
1 parent f9f93b1
commit 32ad00b
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/server/cluster/outgoing_slot_migration.cc b/src/server/cluster/outgoing_slot_migration.cc
@@ -81,7 +81,8 @@ class OutgoingMigration::SliceSlotMigration : private ProtocolClient {
   }
 
   void Cancel() {
-    cntx_.Cancel();
+    // Close socket for clean disconnect.
+    CloseSocket();
     streamer_.Cancel();
   }