mirrors/TarsCloud_TarsCpp
1
0
Fork 0
mirror of https://gitee.com/TarsCloud/TarsCpp.git synced 2025-01-03 05:22:26 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

Adpater未连接时请求超时统计

Browse Source
This commit is contained in:
wuxiaofeng1 2023-03-08 14:44:49 +08:00 committed by ruanshudong
parent af41549b63
commit bbe557ea74
2 changed files with 10 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
servant/libservant/ObjectProxy.cpp
View File

@ -237,6 +237,11 @@ void ObjectProxy::doInvokeException(ReqMessage * msg)
//标识请求异常 //标识请求异常
msg->eStatus = ReqMessage::REQ_EXC; msg->eStatus = ReqMessage::REQ_EXC;
if (!msg->adapter)
{
msg->adapter->stat(msg);
}
if(msg->eType == ReqMessage::SYNC_CALL) if(msg->eType == ReqMessage::SYNC_CALL)
{ {
if(!msg->sched) if(!msg->sched)

10
servant/servant/AdapterProxy.h
View File

@ -221,6 +221,11 @@ public:
*/ */
TC_TimeoutQueueNew<ReqMessage*> * getTimeoutQueue() { return _timeoutQueue.get(); } TC_TimeoutQueueNew<ReqMessage*> * getTimeoutQueue() { return _timeoutQueue.get(); }
/**
* 模块间调用信息的统计
*/
void stat(ReqMessage * msg);
protected: protected:
//创建完网络句柄后的回调 //创建完网络句柄后的回调
@ -268,11 +273,6 @@ private:
*/ */
void initStatHead(); void initStatHead();
/**
* 模块间调用信息的统计
*/
void stat(ReqMessage * msg);
/** /**
* 模块间调用信息的合并 * 模块间调用信息的合并
*/ */