From bbe557ea744fdda4bf391f8ca6767a7060805133 Mon Sep 17 00:00:00 2001 From: wuxiaofeng1 Date: Wed, 8 Mar 2023 14:44:49 +0800 Subject: [PATCH] =?UTF-8?q?Adpater=E6=9C=AA=E8=BF=9E=E6=8E=A5=E6=97=B6?= =?UTF-8?q?=E8=AF=B7=E6=B1=82=E8=B6=85=E6=97=B6=E7=BB=9F=E8=AE=A1?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- servant/libservant/ObjectProxy.cpp | 5 +++++ servant/servant/AdapterProxy.h | 10 +++++----- 2 files changed, 10 insertions(+), 5 deletions(-) diff --git a/servant/libservant/ObjectProxy.cpp b/servant/libservant/ObjectProxy.cpp index 660710f..096380c 100755 --- a/servant/libservant/ObjectProxy.cpp +++ b/servant/libservant/ObjectProxy.cpp @@ -237,6 +237,11 @@ void ObjectProxy::doInvokeException(ReqMessage * msg) //标识请求异常 msg->eStatus = ReqMessage::REQ_EXC; + if (!msg->adapter) + { + msg->adapter->stat(msg); + } + if(msg->eType == ReqMessage::SYNC_CALL) { if(!msg->sched) diff --git a/servant/servant/AdapterProxy.h b/servant/servant/AdapterProxy.h index cde60ed..d6e4c64 100644 --- a/servant/servant/AdapterProxy.h +++ b/servant/servant/AdapterProxy.h @@ -221,6 +221,11 @@ public: */ TC_TimeoutQueueNew * getTimeoutQueue() { return _timeoutQueue.get(); } + /** + * 模块间调用信息的统计 + */ + void stat(ReqMessage * msg); + protected: //创建完网络句柄后的回调 @@ -268,11 +273,6 @@ private: */ void initStatHead(); - /** - * 模块间调用信息的统计 - */ - void stat(ReqMessage * msg); - /** * 模块间调用信息的合并 */