diff --git a/core/predictor/framework/bsf-inl.h b/core/predictor/framework/bsf-inl.h old mode 100755 new mode 100644 index abdba1f2e5bc9710e19804fa3f4d4c0fbce50abd..fc468bfe9a3fd42c472ada774c6eb77b4de7dac7 --- a/core/predictor/framework/bsf-inl.h +++ b/core/predictor/framework/bsf-inl.h @@ -275,6 +275,7 @@ bool TaskExecutor::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::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::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;