mirrors/dragonflydb-dragonfly
1
0
Fork 0
mirror of https://github.com/dragonflydb/dragonfly.git synced 2024-12-14 11:58:02 +00:00
Code Activity

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

Browse source 
fix: close socket to prevent onCompletion call after the journal streamer is destroyed
This commit is contained in:
Borys 2024-12-08 11:57:08 +02:00 committed by GitHub
parent f9f93b108c
commit 32ad00b09a
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 2 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
src/server/cluster/outgoing_slot_migration.cc
View file

@ -81,7 +81,8 @@ class OutgoingMigration::SliceSlotMigration : private ProtocolClient {
} }
void Cancel() { void Cancel() {
cntx_.Cancel(); // Close socket for clean disconnect.
CloseSocket();
streamer_.Cancel(); streamer_.Cancel();
} }