Skip to content

Commit

Permalink
more debug3 messages
Browse files Browse the repository at this point in the history
  • Loading branch information
alandekok committed Nov 29, 2017
1 parent d8688cd commit d7c78cb
Showing 1 changed file with 6 additions and 1 deletion.
7 changes: 6 additions & 1 deletion src/lib/io/worker.c
Expand Up @@ -764,6 +764,7 @@ static REQUEST *fr_worker_get_request(fr_worker_t *worker, fr_time_t now)
*/
request = fr_heap_pop(worker->runnable);
if (request) {
DEBUG3("Worker found runnable request.");
REQUEST_VERIFY(request);
rad_assert(request->runnable_id < 0);
fr_time_tracking_resume(&request->async->tracking, now);
Expand All @@ -779,8 +780,12 @@ static REQUEST *fr_worker_get_request(fr_worker_t *worker, fr_time_t now)
if (!cd) {
WORKER_HEAP_POP(to_decode, cd, request.list);
}
if (!cd) return NULL;
if (!cd) {
DEBUG3("Worker localized and decode lists are empty.");
return NULL;
}

DEBUG3("Worker found request to decode.");
worker->num_decoded++;
} while (!cd);

Expand Down

0 comments on commit d7c78cb

Please sign in to comment.