From bc874c142e86555926fe27847c968a91e76c095f Mon Sep 17 00:00:00 2001 From: xiehan <52160700+Barenboim@users.noreply.github.com> Date: Sun, 31 Mar 2024 01:04:54 +0800 Subject: [PATCH] Rename an internal function. (#1513) --- src/kernel/Communicator.cc | 6 +++--- src/kernel/Communicator.h | 3 +-- 2 files changed, 4 insertions(+), 5 deletions(-) diff --git a/src/kernel/Communicator.cc b/src/kernel/Communicator.cc index 50003267..41c72bb4 100644 --- a/src/kernel/Communicator.cc +++ b/src/kernel/Communicator.cc @@ -1887,7 +1887,7 @@ void Communicator::unbind(CommService *service) } } -int Communicator::reply_idle_conn(CommSession *session, CommTarget *target) +int Communicator::reply_reliable(CommSession *session, CommTarget *target) { struct CommConnEntry *entry; struct list_head *pos; @@ -1995,7 +1995,7 @@ int Communicator::reply(CommSession *session) session->passive = 2; target = (CommServiceTarget *)session->target; if (target->service->reliable) - ret = this->reply_idle_conn(session, target); + ret = this->reply_reliable(session, target); else ret = this->reply_unreliable(session, target); @@ -2006,7 +2006,7 @@ int Communicator::reply(CommSession *session) if (__sync_sub_and_fetch(&entry->ref, 1) == 0) { __release_conn(entry); - ((CommServiceTarget *)target)->decref(); + target->decref(); } } else if (ret < 0) diff --git a/src/kernel/Communicator.h b/src/kernel/Communicator.h index 05e1a662..dbbc2ba7 100644 --- a/src/kernel/Communicator.h +++ b/src/kernel/Communicator.h @@ -310,12 +310,11 @@ private: int send_message(struct CommConnEntry *entry); int request_new_conn(CommSession *session, CommTarget *target); - int request_idle_conn(CommSession *session, CommTarget *target); - int reply_idle_conn(CommSession *session, CommTarget *target); int reply_message_unreliable(struct CommConnEntry *entry); + int reply_reliable(CommSession *session, CommTarget *target); int reply_unreliable(CommSession *session, CommTarget *target); void handle_incoming_request(struct poller_result *res);