fix: crash during migration when connection is closing (#2973)

dragonflydb · Apr 30, 2024 · c84b6fa · c84b6fa
1 parent fd5772a
commit c84b6fa
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/facade/dragonfly_connection.cc b/src/facade/dragonfly_connection.cc
@@ -1452,7 +1452,7 @@ bool Connection::Migrate(util::fb2::ProactorBase* dest) {
  CHECK(!cc_->async_dispatch);
  CHECK_EQ(cc_->subscriptions, 0); // are bound to thread local caches
  CHECK_EQ(self_.use_count(), 1u); // references cache our thread and backpressure
- if (dispatch_fb_.IsJoinable()) { // can't move once it started
+ if (dispatch_fb_.IsJoinable() || cc_->conn_closing) { // can't move once it started
  return false;
  }