From 9d8beb659836b1ba429a559f20855e05605790d3 Mon Sep 17 00:00:00 2001 From: Shengliang Guan Date: Thu, 12 Nov 2020 06:03:14 +0000 Subject: [PATCH] TD-2072 --- src/inc/tsdb.h | 2 +- src/tsdb/src/tsdbCommitQueue.c | 6 +++--- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/src/inc/tsdb.h b/src/inc/tsdb.h index 499aedfeed..0cdb24a4da 100644 --- a/src/inc/tsdb.h +++ b/src/inc/tsdb.h @@ -324,7 +324,7 @@ void tsdbReportStat(void *repo, int64_t *totalPoints, int64_t *totalStorage, int int tsdbInitCommitQueue(int nthreads); void tsdbDestroyCommitQueue(); int tsdbSyncCommit(TSDB_REPO_T *repo); -int tsdbIncCommitRef(int vgId); +void tsdbIncCommitRef(int vgId); void tsdbDecCommitRef(int vgId); #ifdef __cplusplus diff --git a/src/tsdb/src/tsdbCommitQueue.c b/src/tsdb/src/tsdbCommitQueue.c index ad4e433274..49d24f0538 100644 --- a/src/tsdb/src/tsdbCommitQueue.c +++ b/src/tsdb/src/tsdbCommitQueue.c @@ -148,12 +148,12 @@ _exit: return NULL; } -int tsdbIncCommitRef(int vgId) { +void tsdbIncCommitRef(int vgId) { int refCount = atomic_add_fetch_32(&tsCommitQueue.refCount, 1); - tsdbDebug("vgId:%d, inc commit queue ref to %d", refCount); + tsdbDebug("vgId:%d, inc commit queue ref to %d", vgId, refCount); } void tsdbDecCommitRef(int vgId) { int refCount = atomic_sub_fetch_32(&tsCommitQueue.refCount, 1); - tsdbDebug("vgId:%d, dec commit queue ref to %d", refCount); + tsdbDebug("vgId:%d, dec commit queue ref to %d", vgId, refCount); } \ No newline at end of file -- GitLab