diff --git a/src/rpc/src/trpc.c b/src/rpc/src/trpc.c index 4c16ada51c078e03996a0e6320733a8865f88954..31b6f8f94d52bb02b1005d314e487ad75945036a 100644 --- a/src/rpc/src/trpc.c +++ b/src/rpc/src/trpc.c @@ -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));