Lines Matching defs:wsi
249 return task->args.ss->wsi;
251 return task->args.wsi;
321 struct lws *wsi;
338 wsi = task_to_wsi(task);
339 if (!wsi || wsi->tsi != tsi ||
353 lws_callback_on_writable(wsi);
362 wsi = task_to_wsi(task);
364 if (wsi && wsi->tsi == tsi &&
377 lws_callback_on_writable(wsi);
397 struct lws *wsi;
410 wsi = task_to_wsi(task);
413 * if the wsi is no longer attached to this task, there is
419 if (!wsi) {
421 "wsi to sync to\n", __func__, pool->tp->name,
444 * a callback on writeable on the wsi we are associated with.
446 lws_cancel_service(lws_get_context(wsi));
450 * on the wsi, but for whatever reason, we are never going to
585 lwsl_info("%s: stopping on wsi gone\n", __func__);
602 "outlive lost wsi asked "
638 if (!pool->task->args.wsi &&
648 * there is no longer any wsi attached, so nothing is
660 /* signal the associated wsi to take a fresh look at
852 /* disconnect from wsi, and wsi from task */
855 task->args.wsi = NULL;
920 /* disconnect from wsi, and wsi from task */
923 task->args.wsi = NULL;
942 task->args.wsi = NULL;
955 lws_threadpool_dequeue(struct lws *wsi) /* deprecated */
959 if (!wsi->tp_task_owner.count)
961 assert(wsi->tp_task_owner.count != 1);
963 task = lws_container_of(wsi->tp_task_owner.head,
981 assert(args->ss || args->wsi);
1026 * mark the wsi itself as depending on this tp (so wsi close for
1032 lws_dll2_add_tail(&task->list, &args->ss->wsi->tp_task_owner);
1035 lws_dll2_add_tail(&task->list, &args->wsi->tp_task_owner);
1089 lws_threadpool_task_status_wsi(struct lws *wsi,
1094 if (!wsi->tp_task_owner.count) {
1095 lwsl_notice("%s: wsi has no task, ~=FINISHED\n", __func__);
1099 assert(wsi->tp_task_owner.count == 1); /* see deprecation docs in hdr */
1101 task = lws_container_of(wsi->tp_task_owner.head,
1125 lws_threadpool_foreach_task_wsi(struct lws *wsi, void *user,
1131 if (wsi->tp_task_owner.head == NULL)
1134 task1 = lws_container_of(wsi->tp_task_owner.head,
1140 wsi->tp_task_owner.head) {
1162 if (!ss->wsi)
1165 return lws_threadpool_foreach_task_wsi(ss->wsi, user, cb);
1173 task->args.wsi = NULL;
1180 lws_threadpool_wsi_closing(struct lws *wsi)
1182 lws_threadpool_foreach_task_wsi(wsi, NULL, disassociate_wsi);
1186 lws_threadpool_get_task_wsi(struct lws *wsi)
1188 if (wsi->tp_task_owner.head == NULL)
1191 return lws_container_of(wsi->tp_task_owner.head,
1199 return lws_threadpool_get_task_wsi(ss->wsi);