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 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";