From 32ad00b09a4cea9420f16d760697defa5547ca87 Mon Sep 17 00:00:00 2001
From: Borys <borys@dragonflydb.io>
Date: Sun, 8 Dec 2024 11:57:08 +0200
Subject: [PATCH] =?UTF-8?q?fix:=20close=20socket=20to=20prevent=20onComple?=
 =?UTF-8?q?tion=20call=20after=20the=20journal=20stre=E2=80=A6=20(#4270)?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

fix: close socket to prevent onCompletion call after the journal streamer is destroyed
---
 src/server/cluster/outgoing_slot_migration.cc | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/src/server/cluster/outgoing_slot_migration.cc b/src/server/cluster/outgoing_slot_migration.cc
index b0d0ce794..1704fbe12 100644
--- 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();
   }