xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

opt parameter

This commit is contained in:
yihaoDeng 2024-09-13 21:09:00 +08:00
parent aa094def92
commit 8031f196ad
2 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
include/libs/transport/trpc.h
View File

@ -66,6 +66,7 @@ typedef struct SRpcHandleInfo {
int32_t seqNum; // msg seq
int64_t qId; // queryId Get from client, other req's qId = -1;
int32_t refIdMgt;
int32_t msgType;
} SRpcHandleInfo;
typedef struct SRpcMsg {

6
source/libs/transport/src/transSvr.c
View File

@ -565,6 +565,7 @@ static bool uvHandleReq(SSvrConn* pConn) {
transMsg.info.noResp = pHead->noResp == 1 ? 1 : 0;
transMsg.info.seqNum = htonl(pHead->seqNum);
transMsg.info.qId = taosHton64(pHead->qid);
transMsg.info.msgType = pHead->msgType;
// uvMaySetConnAcquired(pConn, pHead);
@ -1807,6 +1808,9 @@ int32_t transSendResponse(const STransMsg* msg) {
STransMsg tmsg = *msg;
tmsg.info.refId = refId;
if (tmsg.info.qId == 0) {
tmsg.msgType = msg->info.msgType + 1;
}
SWorkThrd* pThrd = exh->pThrd;
ASYNC_ERR_JRET(pThrd);
@ -1816,8 +1820,8 @@ int32_t transSendResponse(const STransMsg* msg) {
code = TSDB_CODE_OUT_OF_MEMORY;
goto _return1;
}
m->msg = tmsg;
m->type = Normal;
STraceId* trace = (STraceId*)&msg->info.traceId;