Lines Matching refs:io_loop
173 event_base_loopbreak(pt_to_priv_event(pt)->io_loop);
187 w_read->watcher = event_new(ptpr->io_loop, wsi->desc.sockfd,
215 ptpr->io_loop = loop;
280 wpr->w_read.watcher = event_new(ptpr->io_loop, fd,
282 wpr->w_write.watcher = event_new(ptpr->io_loop, fd,
295 if (!ptpr->io_loop || wsi->a.context->being_destroyed ||
329 if (pt_to_priv_event(&context->pt[tsi])->io_loop)
331 pt_to_priv_event(&context->pt[tsi])->io_loop);
354 if (!ptpr->io_loop)
365 event_base_loopexit(ptpr->io_loop, NULL);
366 // event_base_free(pt->event.io_loop);
367 // pt->event.io_loop = NULL;
432 w->w_read.watcher = event_new(ptpr->io_loop, fd, (EV_READ | EV_PERSIST),
434 w->w_write.watcher = event_new(ptpr->io_loop, fd,
458 if (pt->event_loop_foreign || !ptpr->io_loop)
462 event_base_loopexit(ptpr->io_loop, NULL);
466 (m = event_base_loop(ptpr->io_loop, EVLOOP_NONBLOCK)))
471 event_base_free(ptpr->io_loop);
472 ptpr->io_loop = NULL;