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

set pRpc

This commit is contained in:
Jeff Tao 2020-06-19 11:29:02 +00:00
parent 894fc1eddb
commit b531944f03
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/rpc/src/rpcMain.c
View File

@ -579,14 +579,15 @@ static void rpcReleaseConn(SRpcConn *pConn) {
rpcFreeMsg(pConn->pRspMsg); // it may have a response msg saved, but not request msg rpcFreeMsg(pConn->pRspMsg); // it may have a response msg saved, but not request msg
} }
tTrace("%s, rpc connection is released", pConn->info);
// lockedBy can not be reset, since it maybe hold by a thread // lockedBy can not be reset, since it maybe hold by a thread
int sid = pConn->sid; int sid = pConn->sid;
int64_t lockedBy = pConn->lockedBy; int64_t lockedBy = pConn->lockedBy;
memset(pConn, 0, sizeof(SRpcConn)); memset(pConn, 0, sizeof(SRpcConn));
pConn->lockedBy = lockedBy; pConn->lockedBy = lockedBy;
pConn->pRpc = pRpc;
taosFreeId(pRpc->idPool, sid); taosFreeId(pRpc->idPool, sid);
tTrace("%s, rpc connection is released", pConn->info);
} }
static void rpcCloseConn(void *thandle) { static void rpcCloseConn(void *thandle) {