Lines Matching refs:pt
44 struct lws_context_per_thread *pt;
53 pt = &context->pt[tsi];
54 vpt = (volatile struct lws_context_per_thread *)pt;
90 if (!pt->service_tid_detected && context->vhost_list) {
91 lws_fakewsi_def_plwsa(pt);
95 pt->service_tid = context->vhost_list->protocols[0].callback(
98 pt->service_tid_detected = 1;
117 lws_pt_lock(pt, __func__);
119 us = __lws_sul_service_ripe(pt->pt_sul_owner,
125 lws_pt_unlock(pt);
128 // n = poll(pt->fds, pt->fds_count, timeout_ms);
138 for (n = 0; n < (int)pt->fds_count; n++) {
139 pt->fds[n].revents = 0;
140 if (pt->fds[n].fd >= max_fd)
141 max_fd = pt->fds[n].fd;
142 if (pt->fds[n].events & LWS_POLLIN)
143 FD_SET(pt->fds[n].fd, &readfds);
144 if (pt->fds[n].events & LWS_POLLOUT)
145 FD_SET(pt->fds[n].fd, &writefds);
146 FD_SET(pt->fds[n].fd, &errfds);
156 for (m = 0; m < (int)pt->fds_count; m++) {
158 if (FD_ISSET(pt->fds[m].fd, &readfds)) {
159 pt->fds[m].revents |= LWS_POLLIN;
162 if (FD_ISSET(pt->fds[m].fd, &writefds)) {
163 pt->fds[m].revents |= LWS_POLLOUT;
166 if (FD_ISSET(pt->fds[m].fd, &errfds)) {
167 // lwsl_notice("errfds %d\n", pt->fds[m].fd);
168 pt->fds[m].revents |= LWS_POLLHUP;
180 m |= !!pt->ws.rx_draining_ext_list;
184 if (pt->context->tls_ops &&
185 pt->context->tls_ops->fake_POLLIN_for_buffered)
186 m |= pt->context->tls_ops->fake_POLLIN_for_buffered(pt);
197 for (n = 0; n < (int)pt->fds_count && c; n++) {
198 if (!pt->fds[n].revents)
203 m = lws_service_fd_tsi(context, &pt->fds[n], tsi);