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 <[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]
