DeepSeek/3FS
1
0
Fork 0
mirror of https://github.com/deepseek-ai/3FS synced 2025-06-26 18:16:45 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

fix(chore): fix some uncorrect tcp socket use

Browse Source
This commit is contained in:
zhaohaiyuan
2025-03-03 17:39:40 +08:00
parent fa8fe320ff
commit f519e37091
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/common/net/Listener.cc
View File

@@ -119,7 +119,7 @@ Result<Void> Listener::start(ServiceGroup &group) {
} }
auto accept = [this](auto socket) { acceptRDMA(std::move(socket)); }; auto accept = [this](auto socket) { acceptRDMA(std::move(socket)); };
auto service = std::make_unique<IBConnectService>(ibconfig_, accept, config_.rdma_accept_timeout_getter()); auto service = std::make_unique<IBConnectService>(ibconfig_, accept, config_.rdma_accept_timeout_getter());
group.addSerdeService(std::move(service), Address::Type::TCP); group.addSerdeService(std::move(service), Address::RDMA);
} }
if (UNLIKELY(addressList_.empty())) { if (UNLIKELY(addressList_.empty())) {
@@ -222,7 +222,7 @@ CoTask<void> Listener::checkRDMA(std::weak_ptr<Transport> weak) {
} }
CoTask<void> Listener::release(folly::coro::ServerSocket /* socket */) { CoTask<void> Listener::release(folly::coro::ServerSocket /* socket */) {
XLOGF(DBG, "release a unused TCP server socket"); XLOGF(DBG, "release a unused server socket");
--running_; --running_;
co_return; co_return;
} }