1

cpp/dbpool.cc

@@ -118,6 +118,7 @@ namespace f8
             while (!terminated_) {
                 CheckDB();
                 ProcessMsg();
+                ++DBPool::Instance()->run_loop_num;
                 WaitLoopCond();
             }
 
@@ -167,6 +168,7 @@ namespace f8
                 AsyncQueryNode *pdelnode = work_node_;
                 work_node_ = work_node_->nextnode;
                 ProcAsyncQuery(pdelnode);
+                ++DBPool::Instance()->exec_query_num;
                 delete pdelnode;
             }
         }
@@ -431,6 +433,7 @@ namespace f8
                                                                                                  .SetParam1(AQE_CONN_ERROR));
                                                              },
                                                              &p->timer_attacher.timer_list_);
+            ++DBPool::Instance()->total_query_num;
         }
 
     private:

cpp/dbpool.h

@@ -1,5 +1,7 @@
 #pragma once
 
+#include <atomic>
+
 namespace f8
 {
     typedef std::vector<std::vector<std::string>> DataSet;
@@ -15,6 +17,9 @@ namespace f8
 
     public:
         AsyncDBOnErrorFunc on_dberror = nullptr;
+        std::atomic<long long> total_query_num = {0};
+        std::atomic<long long> exec_query_num = {0};
+        std::atomic<long long> run_loop_num = {0};
 
     public:
         void Init();