feature/qnode

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)

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);