Handling invalid connections when deleting a database

This commit is contained in:
slguan 2019-07-11 19:02:45 +08:00
parent 4ee2f63374
commit fa719d5c99
1 changed files with 4 additions and 0 deletions

View File

@ -503,6 +503,10 @@ int taosGetRpcConn(int chann, int sid, char *meterId, STaosRpc *pServer, SRpcCon
}
pConn = pChann->connList + sid;
if (pChann == NULL || pChann->connList == NULL) {
tTrace("%s cid:%d sid:%d, connlist is null, received:%s", pServer->label, chann, sid, meterId);
return TSDB_CODE_MISMATCHED_METER_ID;
}
if (pConn->signature == NULL) {
memset(pConn, 0, sizeof(SRpcConn));