fix: fix query thread stop issue

08be4503 · dapan1121 · 94070d29 · 08be4503
隐藏空白更改
内联并排

Showing with 2 addition and 0 deletion

source/libs/qworker/src/qworker.c source/libs/qworker/src/qworker.c +2 -0

未找到文件。
--- a/source/libs/qworker/src/qworker.c
+++ b/source/libs/qworker/src/qworker.c
@@ -1191,6 +1191,8 @@ void qWorkerStopAllTasks(void *qWorkerMgmt) {
    
    if (QW_QUERY_RUNNING(ctx)) {
      qwKillTaskHandle(ctx);
+    } else if (!QW_EVENT_PROCESSED(ctx, QW_EVENT_DROP)) {
+      QW_SET_EVENT_RECEIVED(ctx, QW_EVENT_DROP);
    }

    QW_UNLOCK(QW_WRITE, &ctx->lock);