TD-2072

5a417fdd · Shengliang Guan · f6ee376f · 5a417fdd
隐藏空白更改
内联并排

Showing with 1 addition and 0 deletion

src/tsdb/src/tsdbCommitQueue.c src/tsdb/src/tsdbCommitQueue.c +1 -0

未找到文件。
--- a/src/tsdb/src/tsdbCommitQueue.c
+++ b/src/tsdb/src/tsdbCommitQueue.c
@@ -155,5 +155,6 @@ void tsdbIncCommitRef(int vgId) {

 void tsdbDecCommitRef(int vgId) {
  int refCount = atomic_sub_fetch_32(&tsCommitQueue.refCount, 1);
+  pthread_cond_broadcast(&(tsCommitQueue.queueNotEmpty));
  tsdbDebug("vgId:%d, dec commit queue ref to %d", vgId, refCount);
 }
\ No newline at end of file