Skip to content

Commit d78abf9

Browse files
frankistcodebot
authored andcommitted
du-high: make all du_cell queues synchronous in zmq mode
1 parent 238c7d3 commit d78abf9

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

apps/services/worker_manager.cpp

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -249,7 +249,8 @@ void worker_manager::create_du_executors(bool is_blocking_m
249249
for (unsigned cell_id = 0; cell_id != nof_cells; ++cell_id) {
250250
const std::string cell_id_str = std::to_string(cell_id);
251251

252-
slot_workers[cell_id].executors.emplace_back("cell_exec#" + cell_id_str, task_priority::max - 1);
252+
slot_workers[cell_id].executors.push_back(
253+
{"cell_exec#" + cell_id_str, task_priority::max - 1, {}, std::nullopt, is_blocking_mode_active});
253254
slot_workers[cell_id].executors.push_back(
254255
{"slot_exec#" + cell_id_str, task_priority::max, {}, std::nullopt, is_blocking_mode_active});
255256

0 commit comments

Comments
 (0)