diff options
| author | Garrett D'Amore <garrett@damore.org> | 2017-07-21 03:24:29 -0700 |
|---|---|---|
| committer | Garrett D'Amore <garrett@damore.org> | 2017-07-21 03:24:29 -0700 |
| commit | 0dfee5a37a0339a0cc2fad9998976f3b3d44f0a0 (patch) | |
| tree | f05724b80cdf64a52eafd0fc7e93a8de5fce1700 /src/core/taskq.c | |
| parent | 537e2eda8d9fda2001295c835a4720def6a237f1 (diff) | |
| download | nng-0dfee5a37a0339a0cc2fad9998976f3b3d44f0a0.tar.gz nng-0dfee5a37a0339a0cc2fad9998976f3b3d44f0a0.tar.bz2 nng-0dfee5a37a0339a0cc2fad9998976f3b3d44f0a0.zip | |
Eliminate the separate AIO wake callback, making nni_aio_wait
block for any AIO completion.
Diffstat (limited to 'src/core/taskq.c')
| -rw-r--r-- | src/core/taskq.c | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/src/core/taskq.c b/src/core/taskq.c index cf722596..33116ec9 100644 --- a/src/core/taskq.c +++ b/src/core/taskq.c @@ -145,6 +145,11 @@ nni_task_dispatch(nni_task *task) { nni_taskq *tq = task->task_tq; + // If there is no callback to perform, then do nothing! + // The user will be none the wiser. + if (task->task_cb == NULL) { + return; + } nni_mtx_lock(&tq->tq_mtx); // It might already be scheduled... if so don't redo it. if (!nni_list_active(&tq->tq_tasks, task)) { |