From 5b25f89d00433f1c11576d1ea19304797dc60d1b Mon Sep 17 00:00:00 2001 From: Dirk Engling Date: Sat, 31 Oct 2026 18:48:00 +0100 Subject: Refactor ot_workqueue out of ot_mutex, no behaviour change --- ot_sync.c | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) (limited to 'ot_sync.c') diff --git a/ot_sync.c b/ot_sync.c index 3668aa1..c19cf36 100644 --- a/ot_sync.c +++ b/ot_sync.c @@ -14,6 +14,7 @@ #include "ot_fmt.h" #include "ot_iovec.h" #include "ot_mutex.h" +#include "ot_workqueue.h" #include "ot_scan.h" #include "ot_stats.h" #include "ot_sync.h" @@ -139,10 +140,10 @@ static void *sync_worker(void *args) { while (1) { ot_tasktype tasktype = TASK_SYNC_OUT; - ot_taskid taskid = mutex_workqueue_poptask(&tasktype); + ot_taskid taskid = workqueue_poptask(&tasktype); sync_make(&iovec_entries, &iovector); stats_issue_event(ws, EVENT_SYNC_OUT, FLAG_TCP, iovec_length(&iovec_entries, &iovector)); - if (mutex_workqueue_pushresult(taskid, iovec_entries, iovector)) + if (workqueue_pushresult(taskid, iovec_entries, iovector)) iovec_free(&iovec_entries, &iovector); } return NULL; @@ -158,7 +159,7 @@ void sync_deinit( ) { } void sync_deliver( int64_t socket ) { - mutex_workqueue_pushtask( socket, TASK_SYNC_OUT ); + workqueue_pushtask( socket, TASK_SYNC_OUT ); } #endif -- cgit v1.3