diff --git a/source/libs/transport/src/transCli.c b/source/libs/transport/src/transCli.c index dfeea77035..4ece709289 100644 --- a/source/libs/transport/src/transCli.c +++ b/source/libs/transport/src/transCli.c @@ -1145,6 +1145,9 @@ static void cliHandleBatch_shareConnExcept(SCliConn* conn) { transMsg.info.ahandle = pCtx->ahandle; int32_t ret = cliAppCb(conn, &transMsg, pMsg); + if (ret != 0) { + return; + } } // SCliConn* conn = req->data;