look at unlang action, instead of rcode

diff --git a/src/lib/io/worker.c b/src/lib/io/worker.c
index a20ad46fc1b18142263ac4124df615ee72ce7b80..0e4238dd7cc92eefab85646f62a1f9682cfb9099 100644 (file)
--- a/src/lib/io/worker.c
+++ b/src/lib/io/worker.c
@@ -886,6 +886,7 @@ static inline CC_HINT(always_inline) void worker_run_request(fr_worker_t *worker
         */
        while (((now - start) < (NSEC / 100000)) &&
               ((request = fr_heap_pop(worker->runnable)) != NULL)) {
+               unlang_action_t action;
 
                REQUEST_VERIFY(request);
                fr_assert(request->runnable_id < 0);
@@ -909,9 +910,9 @@ static inline CC_HINT(always_inline) void worker_run_request(fr_worker_t *worker
                /*
                 *      Everything else, run the request.
                 */
-               request->async->process(&final, &(module_ctx_t){ .instance = request->async->process_inst }, request);
+               action = request->async->process(&final, &(module_ctx_t){ .instance = request->async->process_inst }, request);
 
-               if (final == RLM_MODULE_YIELD) {
+               if (action == UNLANG_ACTION_YIELD) {
                        now = fr_time();
                        fr_time_tracking_yield(&request->async->tracking, now);