Lines Matching refs:pt
34 struct lws_context_per_thread *pt = (struct lws_context_per_thread *)p;
35 struct lws_pt_eventlibs_libevent *ptpr = pt_to_priv_event(pt);
39 lws_pt_lock(pt, __func__);
40 us = __lws_sul_service_ripe(pt->pt_sul_owner, LWS_COUNT_PT_SUL_OWNERS,
52 lws_pt_unlock(pt);
58 struct lws_context_per_thread *pt = (struct lws_context_per_thread *)p;
59 struct lws_pt_eventlibs_libevent *ptpr = pt_to_priv_event(pt);
63 if (pt->is_destroyed)
66 lws_service_do_ripe_rxflow(pt);
71 if (!lws_service_adjust_timeout(pt->context, 1, pt->tid)) {
73 _lws_plat_service_forced_tsi(pt->context, pt->tid);
75 if (!lws_service_adjust_timeout(pt->context, 1, pt->tid)) {
88 lws_pt_lock(pt, __func__);
89 us = __lws_sul_service_ripe(pt->pt_sul_owner, LWS_COUNT_PT_SUL_OWNERS,
96 lws_pt_unlock(pt);
98 if (pt->destroy_self)
99 lws_context_destroy(pt->context);
108 struct lws_context_per_thread *pt;
141 pt = &context->pt[(int)wsi->tsi];
142 if (pt->is_destroyed)
147 if (pt->destroy_self) {
148 lwsl_cx_notice(context, "pt destroy self coming true");
149 lws_context_destroy(pt->context);
157 evtimer_add(pt_to_priv_event(pt)->idle_timer, &tv);
163 struct lws_context_per_thread *pt = ctx;
164 struct event *signal = pt_to_priv_event(pt)->w_sigint.watcher;
166 if (pt->context->eventlib_signal_cb) {
167 pt->context->eventlib_signal_cb((void *)(lws_intptr_t)sock_fd,
172 if (!pt->event_loop_foreign)
173 event_base_loopbreak(pt_to_priv_event(pt)->io_loop);
181 struct lws_context_per_thread *pt = &context->pt[(int)wsi->tsi];
182 struct lws_pt_eventlibs_libevent *ptpr = pt_to_priv_event(pt);
199 struct lws_context_per_thread *pt = &context->pt[tsi];
200 struct lws_pt_eventlibs_libevent *ptpr = pt_to_priv_event(pt);
207 context->pt[tsi].event_loop_foreign = 1;
222 lws_event_hrtimer_cb, pt);
225 lws_event_idle_timer_cb, pt);
235 if (pt->event_loop_foreign)
239 lws_event_sigint_cb, pt);
254 pt_to_priv_event(&context->pt[n])->w_sigint.context = context;
263 struct lws_context_per_thread *pt;
272 pt = &context->pt[(int)wsi->tsi];
273 ptpr = pt_to_priv_event(pt);
291 struct lws_context_per_thread *pt = &wsi->a.context->pt[(int)wsi->tsi];
292 struct lws_pt_eventlibs_libevent *ptpr = pt_to_priv_event(pt);
296 pt->is_destroyed)
329 if (pt_to_priv_event(&context->pt[tsi])->io_loop)
331 pt_to_priv_event(&context->pt[tsi])->io_loop);
351 struct lws_context_per_thread *pt = &context->pt[tsi];
352 struct lws_pt_eventlibs_libevent *ptpr = pt_to_priv_event(pt);
362 if (!pt->event_loop_foreign) {
366 // event_base_free(pt->event.io_loop);
367 // pt->event.io_loop = NULL;
375 struct lws_context_per_thread *pt;
381 pt = &wsi->a.context->pt[(int)wsi->tsi];
382 if (pt->is_destroyed)
409 struct lws_context_per_thread *pt;
424 pt = &wsi->a.context->pt[(int)wsi->tsi];
425 ptpr = pt_to_priv_event(pt);
446 struct lws_context_per_thread *pt;
453 pt = &context->pt[n];
454 ptpr = pt_to_priv_event(pt);
458 if (pt->event_loop_foreign || !ptpr->io_loop)