diff options
Diffstat (limited to 'queue_loop.c')
| -rw-r--r-- | queue_loop.c | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/queue_loop.c b/queue_loop.c index 019e30b..77c8620 100644 --- a/queue_loop.c +++ b/queue_loop.c @@ -46,8 +46,8 @@ void * mog_queue_loop(void *arg) struct mog_queue *q = arg; struct mog_fd *mfd = NULL; + mog_cancel_prepare(); pthread_cleanup_push(queue_loop_cleanup, NULL); - mog_cancel_disable(); syslog(LOG_DEBUG, "mog_queue_loop[%lx] thread ready", (unsigned long)pthread_self()); @@ -101,7 +101,7 @@ void mog_queue_quit_loop(struct mog_queue *queue) assert(mog_nr_active_at_quit <= (size_t)INT_MAX && "mog_nr_active_at_quit underflow"); - if ((mfd = mog_idleq_wait(queue, -1))) + if ((mfd = mog_idleq_wait_intr(queue, -1))) queue_quit_step(mfd); } } |