From d0e019f3b2fc94a3ff1fb40648982d74695e607a Mon Sep 17 00:00:00 2001
From: TeslaZhao <zhaolisoftware@163.com>
Date: Sun, 24 Apr 2022 15:47:23 +0800
Subject: [PATCH] Add auto-padding log

---
 core/predictor/framework/bsf-inl.h | 7 +++++++
 1 file changed, 7 insertions(+)
 mode change 100755 => 100644 core/predictor/framework/bsf-inl.h

diff --git a/core/predictor/framework/bsf-inl.h b/core/predictor/framework/bsf-inl.h
old mode 100755
new mode 100644
index abdba1f2..fc468bfe
--- a/core/predictor/framework/bsf-inl.h
+++ b/core/predictor/framework/bsf-inl.h
@@ -275,6 +275,7 @@ bool TaskExecutor<TaskT>::move_task_to_batch(
   }
 
   TaskT* previous_task = nullptr;
+  int padding_task_count = 0;
   while (!_task_queue.empty()) {
     TaskT* task = _task_queue.front();
 
@@ -327,6 +328,7 @@ bool TaskExecutor<TaskT>::move_task_to_batch(
     if (batchTask.padding(task) != 2) {
       break;
     }
+    ++padding_task_count;
     size_t rem = batchTask.append_task(task);
     previous_task = task;
     if (task->rem <= 0) {
@@ -334,6 +336,11 @@ bool TaskExecutor<TaskT>::move_task_to_batch(
     }
     if (rem <= 0) break;
   }
+
+  if (padding_task_count > 1) {
+    LOG(INFO) << "Hit auto padding, merge " << padding_task_count
+              << " tasks into 1 batch.";
+  }
   LOG(INFO) << "Number of tasks remaining in _task_queue is"
             << _task_queue.size();
   return true;
-- 
GitLab