Lines Matching defs:wsi
80 lws_set_timeout(context->async_dns.wsi, 1, LWS_TO_KILL_ASYNC);
81 context->async_dns.wsi = NULL;
114 lwsl_wsi_debug(q->dns ? q->dns->wsi : NULL, "q: %p, c: %p, refcount %d -> %d",
133 lwsl_wsi_info(q->dns ? q->dns->wsi : NULL, "in");
136 if (q->dns && q->dns->wsi) {
138 lws_callback_on_writable(q->dns->wsi);
143 lws_async_dns_writeable(struct lws *wsi, lws_adns_q_t *q)
168 * for rewrite according to the wsi retry policy.
171 * wsi close.
177 lws_retry_sul_schedule_retry_wsi(wsi, &q->sul,
180 lwsl_wsi_info(wsi, "failing query");
209 lwsl_wsi_info(wsi, "%s, which %d", name, which);
240 lwsl_wsi_err(wsi, "name too big");
253 m = lws_write(wsi, pkt + LWS_PRE, (unsigned int)n, 0);
255 lwsl_wsi_notice(wsi, "dns write failed %d %d errno %d",
262 lwsl_wsi_debug(wsi, "request writeable for ipv6");
263 lws_callback_on_writable(wsi);
270 lwsl_wsi_warn(wsi, "failing query doing NULL completion");
277 lwsl_wsi_debug(wsi, "destroy firstcache");
286 callback_async_dns(struct lws *wsi, enum lws_callback_reasons reason,
289 struct lws_async_dns *dns = &(lws_get_context(wsi)->async_dns);
296 //lwsl_wsi_user(wsi, "LWS_CALLBACK_RAW_ADOPT");
300 //lwsl_wsi_user(wsi, "LWS_CALLBACK_RAW_CLOSE");
304 //lwsl_wsi_user(wsi, "LWS_CALLBACK_RAW_RX (%d)", (int)len);
305 // lwsl_hexdump_wsi_notice(wsi, in, len);
310 //lwsl_wsi_user(wsi, "LWS_CALLBACK_RAW_WRITEABLE");
318 lws_async_dns_writeable(wsi, q);
340 if (dns->wsi)
372 dns->wsi = lws_create_adopt_udp(context->vhost_list, ads, 53, 0,
375 if (!dns->wsi) {
380 context->async_dns.wsi->udp->sa46 = dns->sa46;
401 // lwsl_wsi_notice(dns->wsi, "%s vs %s (inc %d)", name, c->name, c->incomplete);
424 lwsl_wsi_info(dns->wsi, "ADNS cache %u entries",
431 lwsl_wsi_info(dns->wsi, "cache: '%s', exp: %lldus, incomp %d, "
441 lwsl_wsi_info(dns->wsi, "q: '%s', sent %d, resp %d",
485 lwsl_wsi_info(q->dns ? q->dns->wsi : NULL, "failing");
534 lwsl_wsi_info(dns->wsi, "acache %p: refcount %d on purge",
555 if (dns->wsi && !dns->dns_server_connected) {
556 lwsl_wsi_notice(dns->wsi, "late free of incomplete dns wsi");
557 __lws_lc_untag(dns->wsi->a.context, &dns->wsi->lc);
559 lws_metrics_tags_destroy(&dns->wsi->cal_conn.mtags_owner);
561 lws_free_set_NULL(dns->wsi->udp);
562 lws_free_set_NULL(dns->wsi);
588 lws_async_dns_cancel(struct lws *wsi)
590 lws_async_dns_t *dns = &wsi->a.context->async_dns;
592 lws_dll2_foreach_safe(&dns->waiting, wsi, cancel);
650 struct lws *wsi, void *opaque)
689 if (wsi) {
690 if (!lws_dll2_is_detached(&wsi->adns)) {
692 lws_wsi_tag(wsi), wsi->adns.owner);
695 wsi->adns_cb = cb;
712 if (cb(wsi, name, c->results, m, opaque) == NULL)
756 if (wsi) {
757 wsi->adns_cb = cb;
758 lws_dll2_add_head(&wsi->adns, &tmq.tq.wsi_adns);
812 if (wsi)
813 lws_dll2_add_head(&wsi->adns, &q->wsi_adns);
844 if (wsi)
845 lws_dll2_add_head(&wsi->adns, &q->wsi_adns);
860 if (!wsi)
863 /* schedule a retry according to the retry policy on the wsi */
864 if (lws_retry_sul_schedule_retry_wsi(dns->wsi, &q->sul,
885 lws_callback_on_writable(dns->wsi);
900 if (!cb(wsi, NULL, NULL, LADNS_RET_FAILED, opaque))