xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

TD-2072

This commit is contained in:
Shengliang Guan 2020-11-12 06:03:14 +00:00
parent a31a6ed9a5
commit 9d8beb6598
2 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/inc/tsdb.h
View File

@ -324,7 +324,7 @@ void tsdbReportStat(void *repo, int64_t *totalPoints, int64_t *totalStorage, int
int tsdbInitCommitQueue(int nthreads); int tsdbInitCommitQueue(int nthreads);
void tsdbDestroyCommitQueue(); void tsdbDestroyCommitQueue();
int tsdbSyncCommit(TSDB_REPO_T *repo); int tsdbSyncCommit(TSDB_REPO_T *repo);
int tsdbIncCommitRef(int vgId); void tsdbIncCommitRef(int vgId);
void tsdbDecCommitRef(int vgId); void tsdbDecCommitRef(int vgId);
#ifdef __cplusplus #ifdef __cplusplus

6
src/tsdb/src/tsdbCommitQueue.c
View File

@ -148,12 +148,12 @@ _exit:
return NULL; return NULL;
} }
int tsdbIncCommitRef(int vgId) { void tsdbIncCommitRef(int vgId) {
int refCount = atomic_add_fetch_32(&tsCommitQueue.refCount, 1); 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) { void tsdbDecCommitRef(int vgId) {
int refCount = atomic_sub_fetch_32(&tsCommitQueue.refCount, 1); 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);
} }