[core] Added debug info log for worker status reports

flomesh-io · Jan 3, 2025 · b28b492 · b28b492
1 parent 6ee6ddb
commit b28b492
Showing 1 changed file with 7 additions and 2 deletions.
diff --git a/src/main.cpp b/src/main.cpp
@@ -230,15 +230,20 @@ class StatusReporter : public PeriodicJob {
     static Data::Producer s_dp("Status Reports");
     if (s_has_shutdown) return;
     if (!m_fetch->busy()) {
+      Log::debug(Log::CODEBASE, "[codebase] Start collecting status");
+
       WorkerManager::get().status(
         [this](Status &status) {
           if (m_send_metrics) {
+            Log::debug(Log::CODEBASE, "[codebase] Start collecting metrics");
             WorkerManager::get().stats(
               [&](stats::MetricDataSum &metric_data_sum) {
+                Log::debug(Log::CODEBASE, "[codebase] Start sending status report");
                 send(status, &metric_data_sum);
               }
             );
           } else {
+            Log::debug(Log::CODEBASE, "[codebase] Start sending status report");
             send(status, nullptr);
           }
         }
@@ -283,8 +288,8 @@ class StatusReporter : public PeriodicJob {
 
         Log::debug(
           Log::CODEBASE,
-          "[codebase] Sent status report in %dms (size = %d)",
-          int(utils::now() - time), size
+          "[codebase] Sent status report in %dms (size = %d, response = %d)",
+          int(utils::now() - time), size, head->status
         );
       }
     );