Lines Matching refs:pt
93 struct lws_context_per_thread *pt;
102 pt = &context->pt[tsi];
109 if (!pt->service_tid_detected && context->vhost_list) {
115 pt->service_tid = context->vhost_list->protocols[0].callback(
117 pt->service_tid_detected = 1;
129 lws_pt_lock(pt, __func__);
131 us = __lws_sul_service_ripe(pt->pt_sul_owner,
137 lws_pt_unlock(pt);
140 n = poll(pt->fds, pt->fds_count, timeout_us / LWS_US_PER_MS);
144 if (pt->context->tls_ops &&
145 pt->context->tls_ops->fake_POLLIN_for_buffered)
146 m = pt->context->tls_ops->fake_POLLIN_for_buffered(pt);
148 if (/*!pt->ws.rx_draining_ext_list && */!m && !n) /* nothing to do */
165 for (n = 0; n < (int)pt->fds_count && c; n++) {
166 if (!pt->fds[n].revents)
171 if (pt->fds[n].fd == pt->dummy_pipe_fds[0]) {
172 if (read(pt->fds[n].fd, &buf, 1) != 1)
177 m = lws_service_fd_tsi(context, &pt->fds[n], tsi);
224 struct lws_context_per_thread *pt = &context->pt[(int)wsi->tsi];
226 pt->fds[pt->fds_count++].revents = 0;
233 struct lws_context_per_thread *pt = &context->pt[(int)wsi->tsi];
235 pt->fds_count--;