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