Lines Matching defs:context
34 struct lws_context *context;
69 context = wsi->a.context;
70 pt = &context->pt[(int)wsi->tsi];
169 if (context->event_loop_ops->io) {
171 context->event_loop_ops->io(wsi,
175 context->event_loop_ops->io(wsi,
179 context->event_loop_ops->io(wsi,
183 context->event_loop_ops->io(wsi,
189 * ... and we're running in a different thread context
198 if (lws_plat_change_pollfd(context, wsi, pfd)) {
226 lws_accept_modulation(struct lws_context *context,
229 struct lws_vhost *vh = context->vhost_list;
253 lwsl_cx_warn(pt->context, "fds_count %u, %s", pt->fds_count, s);
256 struct lws *wsi = wsi_from_fd(pt->context, pt->fds[n].fd);
258 lwsl_cx_warn(pt->context, " %d: fd %d, wsi %s, pos_in_fds: %d",
268 __insert_wsi_socket_into_fds(struct lws_context *context, struct lws *wsi)
273 struct lws_context_per_thread *pt = &context->pt[(int)wsi->tsi];
283 if ((unsigned int)pt->fds_count >= context->fd_limit_per_thread) {
284 lwsl_cx_err(context, "Too many fds (%d vs %d)", context->max_fds,
285 context->fd_limit_per_thread);
290 if (!wsi->a.context->max_fds_unrelated_to_ulimit &&
291 wsi->desc.sockfd - lws_plat_socket_offset() >= (int)context->max_fds) {
292 lwsl_cx_err(context, "Socket fd %d is too high (%d) offset %d",
293 wsi->desc.sockfd, context->max_fds,
302 assert(wsi->event_pipe || wsi->a.vhost || wsi == pt->context->netlink);
316 if (insert_wsi(context, wsi))
327 lws_plat_insert_socket_into_fds(context, wsi);
339 if ((unsigned int)pt->fds_count == context->fd_limit_per_thread - 1)
340 lws_accept_modulation(context, pt, 0);
360 struct lws_context *context = wsi->a.context;
364 struct lws_context_per_thread *pt = &context->pt[(int)wsi->tsi];
373 if (!wsi->a.context->max_fds_unrelated_to_ulimit &&
374 wsi->desc.sockfd - lws_plat_socket_offset() > (int)context->max_fds) {
377 context->max_fds);
397 if (context->event_loop_ops->io)
398 context->event_loop_ops->io(wsi, LWS_EV_STOP | LWS_EV_READ |
411 delete_from_fd(context, wsi->desc.sockfd);
422 lws_plat_delete_socket_from_fds(context, wsi, m);
428 end_wsi = wsi_from_fd(context, v);
454 if (!context->being_destroyed &&
456 (unsigned int)pt->fds_count < context->fd_limit_per_thread - 1)
457 lws_accept_modulation(context, pt, 1);
475 struct lws_context *context;
483 context = lws_get_context(wsi);
484 if (!context)
512 pt = &wsi->a.context->pt[(int)wsi->tsi];
565 lws_context_lock(wsi->a.context, __func__);
575 lws_context_unlock(wsi->a.context);
591 lws_context_lock(wsi->a.context, __func__);
597 lws_context_unlock(wsi->a.context);
633 lws_callback_on_writable_all_protocol(const struct lws_context *context,
639 if (!context)
642 vhost = context->vhost_list;