From 6943a7beed9305eb28eed9bfe11792b646472f29 Mon Sep 17 00:00:00 2001 From: Yang Liming Date: Thu, 31 Jul 2025 09:26:16 +0800 Subject: [PATCH 1/2] when rdma event dispatcher unschedule is true, start ProcessEvent background --- src/brpc/socket.cpp | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/brpc/socket.cpp b/src/brpc/socket.cpp index 8ca217d3d9..91f9ca653a 100644 --- a/src/brpc/socket.cpp +++ b/src/brpc/socket.cpp @@ -2276,7 +2276,7 @@ int Socket::OnInputEvent(void* user_data, uint32_t events, if (FLAGS_usercode_in_coroutine) { ProcessEvent(p); #if BRPC_WITH_RDMA - } else if (rdma::FLAGS_rdma_edisp_unsched == false) { + } else if (rdma::FLAGS_rdma_edisp_unsched) { auto rc = bthread_start_background(&tid, &attr, ProcessEvent, p); if (rc != 0) { LOG(FATAL) << "Fail to start ProcessEvent"; From b4a68ec9d4027b48eb3290b6977f4a4bc8d32703 Mon Sep 17 00:00:00 2001 From: Yang Liming Date: Fri, 8 Aug 2025 10:22:04 +0800 Subject: [PATCH 2/2] add declare of brpc::rdma::GlobalRdmaInitializeOrDie without define BRPC_WITH_RDMA --- src/brpc/rdma/rdma_helper.h | 9 +++++++++ 1 file changed, 9 insertions(+) diff --git a/src/brpc/rdma/rdma_helper.h b/src/brpc/rdma/rdma_helper.h index a10c501aaf..052763325b 100644 --- a/src/brpc/rdma/rdma_helper.h +++ b/src/brpc/rdma/rdma_helper.h @@ -91,7 +91,16 @@ bool SupportedByRdma(std::string protocol); } // namespace rdma } // namespace brpc +#else +namespace brpc { +namespace rdma { + +// Initialize RDMA environment +// Exit if failed +void GlobalRdmaInitializeOrDie(); +} // namespace rdma +} // namespace brpc #endif // if BRPC_WITH_RDMA #endif // BRPC_RDMA_HELPER_H