bugfix

src/common/utils.hpp

@@ -54,11 +54,11 @@ public:
         double milliseconds = microseconds / 1000.0;
         double seconds = milliseconds / 1000.0;
 
-        printf("[%*s] Elapsed time: %*lld us | %*.3f ms | %*.6f s\n", 10,
-            m_name.c_str(),
-            6, static_cast<long long>(microseconds),
-            6, milliseconds,
-            6, seconds);
+        printf("%-*s Elapsed time: %-*lld us | %-*.3f ms | %-*.6f s\n",
+            18, m_name.c_str(),
+            10, static_cast<long long>(microseconds),
+            10, milliseconds,
+            10, seconds);
 
         m_stopped = true; // 标记为已停止并打印
     }

src/nodes/base/base.cpp

@@ -29,12 +29,10 @@ void BaseNode::stop()
     if (running_.exchange(false))
     {
         // 删除队列中全部元素
-        PLOGI.printf("Node : [%s] delete queue start", name_.c_str());
         std::for_each(input_buffers_.begin(), input_buffers_.end(),
                   [&](const auto &item) { item.second->clear(); });
         std::for_each(output_buffers_.begin(), output_buffers_.end(),
                     [&](const auto &item) { item.second->clear(); });
-        PLOGI.printf("Node : [%s] delete queue stop", name_.c_str());
         cond_var_->notify_all();
         if (worker_thread_.joinable())
         {
@@ -48,7 +46,6 @@ void BaseNode::work()
 {
     while (running_)
     {
-        Timer timer(name_);
         bool has_data = false;
         for (auto& input_buffer : input_buffers_)
         {
@@ -58,6 +55,7 @@ void BaseNode::work()
                 continue;
             }
             has_data = true;
+            Timer timer(name_);
             handle_data(meta_data);
             send_output_data(meta_data);          
         }