From bd8b811b9dc5c602e6a3a2dd6ece68c8da709ea8 Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Fri, 21 Jul 2023 09:14:25 +0800 Subject: [PATCH] refactor: do some internal refactor. --- source/libs/stream/src/streamRecover.c | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/source/libs/stream/src/streamRecover.c b/source/libs/stream/src/streamRecover.c index 022ebd24c7..80b3c2a618 100644 --- a/source/libs/stream/src/streamRecover.c +++ b/source/libs/stream/src/streamRecover.c @@ -785,12 +785,13 @@ void streamTaskPause(SStreamTask* pTask) { // todo fix race condition void streamTaskDisablePause(SStreamTask* pTask) { // pre-condition check + const char* id = pTask->id.idStr; while (pTask->status.taskStatus == TASK_STATUS__PAUSE) { - taosMsleep(10); - qDebug("s-task:%s already in pause, wait for pause being cancelled, and then set pause disabled", pTask->id.idStr); + taosMsleep(100); + qDebug("s-task:%s already in pause, wait for pause being cancelled, and set pause disabled, check in 100ms", id); } - qDebug("s-task:%s disable task pause", pTask->id.idStr); + qDebug("s-task:%s disable task pause", id); pTask->status.pauseAllowed = 0; }