From b2085e53df2890b0ad60fc8a9619f42a32318b6b Mon Sep 17 00:00:00 2001 From: "litiantian.118" Date: Tue, 10 Mar 2026 16:29:26 +0800 Subject: [PATCH] add endpoint set false in endpoint_store.cpp --- .../src/transport/rdma_transport/endpoint_store.cpp | 2 ++ 1 file changed, 2 insertions(+) diff --git a/mooncake-transfer-engine/src/transport/rdma_transport/endpoint_store.cpp b/mooncake-transfer-engine/src/transport/rdma_transport/endpoint_store.cpp index f5210ce648..22bf8f9ded 100644 --- a/mooncake-transfer-engine/src/transport/rdma_transport/endpoint_store.cpp +++ b/mooncake-transfer-engine/src/transport/rdma_transport/endpoint_store.cpp @@ -71,6 +71,7 @@ int FIFOEndpointStore::deleteEndpoint(const std::string &peer_nic_path) { // in case it is setting up connection or submitting slice if (iter != endpoint_map_.end()) { waiting_list_.insert(iter->second); + iter->second->set_active(false); endpoint_map_.erase(iter); auto fifo_iter = fifo_map_[peer_nic_path]; fifo_list_.erase(fifo_iter); @@ -174,6 +175,7 @@ int SIEVEEndpointStore::deleteEndpoint(const std::string &peer_nic_path) { if (iter != endpoint_map_.end()) { waiting_list_len_++; waiting_list_.insert(iter->second.first); + iter->second.first->set_active(false); endpoint_map_.erase(iter); auto fifo_iter = fifo_map_[peer_nic_path]; if (hand_.has_value() && hand_.value() == fifo_iter) {