This is an automated email from the ASF dual-hosted git repository. wwbmmm pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/brpc.git
The following commit(s) were added to refs/heads/master by this push: new aad1fc69 modify GetGlobalEventDispatcher for rdma (#2513) aad1fc69 is described below commit aad1fc6972b113e7177cd3bf847ed0226ff27589 Author: Yang,Liming <liming.y...@139.com> AuthorDate: Mon Jan 22 11:00:41 2024 +0800 modify GetGlobalEventDispatcher for rdma (#2513) --- src/brpc/rdma/rdma_endpoint.cpp | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/brpc/rdma/rdma_endpoint.cpp b/src/brpc/rdma/rdma_endpoint.cpp index 40b52a80..93faf4b6 100644 --- a/src/brpc/rdma/rdma_endpoint.cpp +++ b/src/brpc/rdma/rdma_endpoint.cpp @@ -1257,7 +1257,7 @@ void RdmaEndpoint::DeallocateResources() { if (_resource->comp_channel) { // destroy comp_channel will destroy this fd // so that we should remove it from epoll fd first - GetGlobalEventDispatcher(fd).RemoveConsumer(fd); + GetGlobalEventDispatcher(fd, _socket->_bthread_tag).RemoveConsumer(fd); fd = -1; if (IbvDestroyCompChannel(_resource->comp_channel) < 0) { PLOG(WARNING) << "Fail to destroy CQ channel"; @@ -1273,7 +1273,7 @@ void RdmaEndpoint::DeallocateResources() { if (Socket::Address(_cq_sid, &s) == 0) { s->_user = NULL; // do not release user (this RdmaEndpoint) if (fd >= 0) { - GetGlobalEventDispatcher(fd).RemoveConsumer(fd); + GetGlobalEventDispatcher(fd, _socket->_bthread_tag).RemoveConsumer(fd); } s->_fd = -1; // already remove fd from epoll fd s->SetFailed(); --------------------------------------------------------------------- To unsubscribe, e-mail: dev-unsubscr...@brpc.apache.org For additional commands, e-mail: dev-h...@brpc.apache.org