sender log

Signed-off-by: guo-shaoge <[email protected]>
pingcap · Oct 19, 2024 · 8faaf5a · 8faaf5a
1 parent dbd6afe
commit 8faaf5a
Show file tree

Hide file tree

Showing 2 changed files with 20 additions and 1 deletion.
diff --git a/dbms/src/Common/LooseBoundedMPMCQueue.h b/dbms/src/Common/LooseBoundedMPMCQueue.h
@@ -50,10 +50,20 @@ class LooseBoundedMPMCQueue
         , push_callback(std::move(push_callback_))
     {}
 
+    String getAddr() const
+    {
+        std::stringstream ss;
+        ss << this;
+        return ss.str();
+    }
+
     void registerPipeReadTask(TaskPtr && task)
     {
         {
+            const auto pipe_task_cnt = pipe_reader_cv.getTaskCnt();
             std::lock_guard lock(mu);
+            LOG_DEBUG(Logger::get(), "gjt debug registerPipeReadTask queue size: {}, status: {}, pipe_task_cnt: {}, workqueue: {}",
+                    queue.size(), status == MPMCQueueStatus::NORMAL, pipe_task_cnt, getAddr());
             if (queue.empty() && status == MPMCQueueStatus::NORMAL)
             {
                 pipe_reader_cv.registerTask(std::move(task));
@@ -66,7 +76,10 @@ class LooseBoundedMPMCQueue
     void registerPipeWriteTask(TaskPtr && task)
     {
         {
+            const auto pipe_task_cnt = pipe_writer_cv.getTaskCnt();
             std::lock_guard lock(mu);
+            LOG_DEBUG(Logger::get(), "gjt debug registerPipeWriteTask isFullWithoutLock: {}, status: {}, pipe_task_cnt: {}, workqueue: {}",
+                isFullWithoutLock(), status == MPMCQueueStatus::NORMAL, pipe_task_cnt, getAddr());
             if (isFullWithoutLock() && status == MPMCQueueStatus::NORMAL)
             {
                 pipe_writer_cv.registerTask(std::move(task));
@@ -259,18 +272,24 @@ class LooseBoundedMPMCQueue
 private:
     void notifyOneReader()
     {
+        LOG_DEBUG(Logger::get(), "gjt debug notifyOneReader: {}",
+                getAddr());
         reader_cv.notify_one();
         pipe_reader_cv.notifyOne();
     }
 
     void notifyOneWriter()
     {
+        LOG_DEBUG(Logger::get(), "gjt debug notifyOneWriter: {}",
+                getAddr());
         writer_cv.notify_one();
         pipe_writer_cv.notifyOne();
     }
 
     void notifyAll()
     {
+        LOG_DEBUG(Logger::get(), "gjt debug notifyAll: {}",
+                getAddr());
         reader_cv.notify_all();
         pipe_reader_cv.notifyAll();
 

diff --git a/dbms/src/Storages/DeltaMerge/ReadThread/SegmentReadTaskScheduler.cpp b/dbms/src/Storages/DeltaMerge/ReadThread/SegmentReadTaskScheduler.cpp
@@ -156,7 +156,7 @@ bool SegmentReadTaskScheduler::needScheduleToRead(const SegmentReadTaskPoolPtr &
 {
     if (pool->getFreeBlockSlots() <= 0)
     {
-        LOG_DEBUG(Logger::get(), "gjt debug needScheduleToRead failed: {}", pool->getFreeBlockSlotsInfo());
+        // LOG_DEBUG(Logger::get(), "gjt debug needScheduleToRead failed: {}", pool->getFreeBlockSlotsInfo());
         GET_METRIC(tiflash_storage_read_thread_counter, type_sche_no_slot).Increment();
         return false;
     }