30 	struct lws_context_per_thread *pt = &wsi->context->pt[(int)wsi->tsi];  in lws_callback_as_writeable()  local
33 	lws_stats_bump(pt, LWSSTATS_C_WRITEABLE_CB, 1);  in lws_callback_as_writeable()
39 		lws_stats_bump(pt, LWSSTATS_US_WRITABLE_DELAY_AVG, ul);  in lws_callback_as_writeable()
40 		lws_stats_max(pt, LWSSTATS_US_WORST_WRITABLE_DELAY, ul);  in lws_callback_as_writeable()
248 	struct lws_context_per_thread *pt = &wsi->context->pt[(int)wsi->tsi];  in lws_rxflow_cache()  local
284 			lws_dll2_add_head(&wsi->dll_buflist, &pt->dll_buflist_owner);  in lws_rxflow_cache()
297 	struct lws_context_per_thread *pt;  in lws_service_adjust_timeout()  local
302 	pt = &context->pt[tsi];  in lws_service_adjust_timeout()
311 	if (pt->ws.rx_draining_ext_list)  in lws_service_adjust_timeout()
319 	if (pt->context->tls_ops &&  in lws_service_adjust_timeout()
320 	    pt->context->tls_ops->fake_POLLIN_for_buffered &&  in lws_service_adjust_timeout()
321 	    pt->context->tls_ops->fake_POLLIN_for_buffered(pt))  in lws_service_adjust_timeout()
330 	lws_start_foreach_dll(struct lws_dll2 *, d, pt->dll_buflist_owner.head) {  in lws_service_adjust_timeout()
353 lws_buflist_aware_read(struct lws_context_per_thread *pt, struct lws *wsi,  in lws_buflist_aware_read()  argument
364 		ebuf->token = pt->serv_buf + LWS_PRE;  in lws_buflist_aware_read()
418 					  &pt->dll_buflist_owner);  in lws_buflist_aware_read()
445 	struct lws_context_per_thread *pt = &wsi->context->pt[(int)wsi->tsi];  in lws_buflist_aware_finished_consuming()  local
487 					 &pt->dll_buflist_owner);  in lws_buflist_aware_finished_consuming()
496 lws_service_do_ripe_rxflow(struct lws_context_per_thread *pt)  in lws_service_do_ripe_rxflow()  argument
500 	if (!pt->dll_buflist_owner.head)  in lws_service_do_ripe_rxflow()
508 	lws_pt_lock(pt, __func__);  in lws_service_do_ripe_rxflow()
511 				   pt->dll_buflist_owner.head) {  in lws_service_do_ripe_rxflow()
524 			pt->inside_lws_service = 1;  in lws_service_do_ripe_rxflow()
526 			if ((wsi->role_ops->handle_POLLIN)(pt, wsi, &pfd) ==  in lws_service_do_ripe_rxflow()
530 			pt->inside_lws_service = 0;  in lws_service_do_ripe_rxflow()
535 	lws_pt_unlock(pt);  in lws_service_do_ripe_rxflow()
547 	struct lws_context_per_thread *pt;  in lws_service_flag_pending()  local
553 	pt = &context->pt[tsi];  in lws_service_flag_pending()
555 	lws_pt_lock(pt, __func__);  in lws_service_flag_pending()
562 	lws_start_foreach_dll(struct lws_dll2 *, d, pt->dll_buflist_owner.head) {  in lws_service_flag_pending()
584 			lws_dll2_get_head(&pt->tls.dll_pending_tls_owner)) {  in lws_service_flag_pending()
590 		pt->fds[wsi->position_in_fds_table].revents |=  in lws_service_flag_pending()
591 			pt->fds[wsi->position_in_fds_table].events & LWS_POLLIN;  in lws_service_flag_pending()
592 		if (pt->fds[wsi->position_in_fds_table].revents & LWS_POLLIN) {  in lws_service_flag_pending()
607 	lws_pt_unlock(pt);  in lws_service_flag_pending()
616 	struct lws_context_per_thread *pt;  in lws_service_fd_tsi()  local
622 	pt = &context->pt[tsi];  in lws_service_fd_tsi()
693 	pt->inside_lws_service = 1;  in lws_service_fd_tsi()
703 	switch ((wsi->role_ops->handle_POLLIN)(pt, wsi, pollfd)) {  in lws_service_fd_tsi()
705 		pt->inside_lws_service = 0;  in lws_service_fd_tsi()
730 		pt->inside_lws_service = 0;  in lws_service_fd_tsi()
739 	pt->inside_lws_service = 0;  in lws_service_fd_tsi()
753 	struct lws_context_per_thread *pt;  in lws_service()  local
759 	pt = &context->pt[0];  in lws_service()
760 	pt->inside_service = 1;  in lws_service()
766 		pt->inside_service = 0;  in lws_service()
772 	pt->inside_service = 0;  in lws_service()
780 	struct lws_context_per_thread *pt;  in lws_service_tsi()  local
786 	pt = &context->pt[tsi];  in lws_service_tsi()
787 	pt->inside_service = 1;  in lws_service_tsi()
789 	pt->self = pthread_self();  in lws_service_tsi()
796 		pt->inside_service = 0;  in lws_service_tsi()
803 	pt->inside_service = 0;  in lws_service_tsi()