From c524647b969cdef2dfdd39a0ab0ab9332b4a2ae7 Mon Sep 17 00:00:00 2001 From: dapan1121 Date: Mon, 14 Feb 2022 09:39:16 +0800 Subject: [PATCH] feature/qnode --- source/libs/catalog/inc/catalogInt.h | 2 +- source/libs/catalog/src/catalog.c | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/source/libs/catalog/inc/catalogInt.h b/source/libs/catalog/inc/catalogInt.h index f427910758..76a0bad195 100644 --- a/source/libs/catalog/inc/catalogInt.h +++ b/source/libs/catalog/inc/catalogInt.h @@ -181,7 +181,7 @@ typedef struct SCtgAction { #define CTG_QUEUE_ADD() atomic_add_fetch_64(&gCtgMgmt.qRemainNum, 1) #define CTG_QUEUE_SUB() atomic_sub_fetch_64(&gCtgMgmt.qRemainNum, 1) -#define CTG_STAT_ADD(n) qError("done:%" PRId64, atomic_add_fetch_64(&(n), 1)) +#define CTG_STAT_ADD(n) atomic_add_fetch_64(&(n), 1) #define CTG_STAT_SUB(n) atomic_sub_fetch_64(&(n), 1) #define CTG_IS_META_NULL(type) ((type) == META_TYPE_NULL_TABLE) diff --git a/source/libs/catalog/src/catalog.c b/source/libs/catalog/src/catalog.c index 732d3ab111..34c5261c17 100644 --- a/source/libs/catalog/src/catalog.c +++ b/source/libs/catalog/src/catalog.c @@ -217,7 +217,7 @@ int32_t ctgPushAction(SCtgMetaAction *action) { CTG_UNLOCK(CTG_WRITE, &gCtgMgmt.qlock); CTG_QUEUE_ADD(); - //CTG_STAT_ADD(gCtgMgmt.stat.runtime.qNum); + CTG_STAT_ADD(gCtgMgmt.stat.runtime.qNum); tsem_post(&gCtgMgmt.sem); -- GitLab