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

Merge remote-tracking branch 'origin/3.0' into enh/opt-transport

This commit is contained in:
yihaoDeng 2024-10-12 16:45:55 +08:00
parent f8e955ca61
commit a0324f41a6
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
source/libs/executor/src/exchangeoperator.c
View File

@ -533,7 +533,11 @@ int32_t loadRemoteDataCallback(void* param, SDataBuf* pMsg, int32_t code) {
int64_t* pRpcHandle = taosArrayGet(pExchangeInfo->pFetchRpcHandles, index); int64_t* pRpcHandle = taosArrayGet(pExchangeInfo->pFetchRpcHandles, index);
if (pRpcHandle != NULL) { if (pRpcHandle != NULL) {
asyncFreeConnById(pExchangeInfo->pTransporter, *pRpcHandle); code = asyncFreeConnById(pExchangeInfo->pTransporter, *pRpcHandle);
if (code != 0) {
qError("failed to free rpc handle, code:%s, %p", tstrerror(code), pExchangeInfo);
code = 0;
}
*pRpcHandle = -1; *pRpcHandle = -1;
} }