diff --git a/src/client/src/tscServer.c b/src/client/src/tscServer.c index 11c458e9bcd4da9d27dd6429eee75d5210a0d13c..87289f77283517e4e580920bca1f8581deb88258 100644 --- a/src/client/src/tscServer.c +++ b/src/client/src/tscServer.c @@ -525,6 +525,7 @@ static void doProcessMsgFromServer(SSchedMsg* pSchedMsg) { } void tscProcessMsgFromServer(SRpcMsg *rpcMsg, SRpcEpSet *pEpSet) { + int64_t st = taosGetTimestampUs(); SSchedMsg schedMsg = {0}; schedMsg.fp = doProcessMsgFromServer; @@ -543,6 +544,11 @@ void tscProcessMsgFromServer(SRpcMsg *rpcMsg, SRpcEpSet *pEpSet) { schedMsg.msg = NULL; taosScheduleTask(tscQhandle, &schedMsg); + + int64_t et = taosGetTimestampUs(); + if (et - st > 100) { + tscDebug("add message to task queue, elapsed time:%"PRId64, et - st); + } } int doBuildAndSendMsg(SSqlObj *pSql) {