Lines Matching refs:mqtt
43 * nwsi no longer has a wsi->mqtt of its own.
198 lws_close_free_wsi(wsi, LWS_CLOSE_STATUS_NOSTATUS, "mqtt svc fail");
208 /* no http but socket... must be mqtt */
241 wsi->stash->cis[CIS_ALPN] = "x-amzn-mqtt-ca";
263 /* if a recognized mqtt method, bind to it */
283 if (wsi->mqtt && wsi->mqtt->send_pingreq && !wsi->mqtt->inside_payload) {
291 wsi->mqtt->send_pingreq = 0;
305 if (wsi->mqtt && !wsi->mqtt->inside_payload &&
306 (wsi->mqtt->send_pubrec || wsi->mqtt->send_pubrel ||
307 wsi->mqtt->send_pubcomp)) {
311 if (wsi->mqtt->send_pubrec) {
313 __func__, wsi->mqtt->peer_ack_pkt_id);
317 wsi->mqtt->peer_ack_pkt_id);
318 wsi->mqtt->send_pubrec = 0;
319 } else if (wsi->mqtt->send_pubrel) {
321 __func__, wsi->mqtt->ack_pkt_id);
324 wsi->mqtt->ack_pkt_id);
325 wsi->mqtt->send_pubrel = 0;
328 __func__, wsi->mqtt->peer_ack_pkt_id);
331 wsi->mqtt->peer_ack_pkt_id);
332 wsi->mqtt->send_pubcomp = 0;
350 if (!wsi->mqtt)
370 if (wsi->mqtt->inside_payload && !(*wsi2)->mqtt->inside_payload)
387 !wsi->mqtt->inside_payload &&
388 wsi->mqtt->send_puback) {
391 __func__, wsi->mqtt->ack_pkt_id);
398 lws_ser_wu16be(&buf[LWS_PRE + 2], wsi->mqtt->peer_ack_pkt_id);
404 wsi->mqtt->send_puback = 0;
414 "mqtt pollout handle");
442 nwsi->mqtt->send_pingreq = 1;
456 if (!wsi->mqtt)
459 c = &wsi->mqtt->client;
461 lws_sul_cancel(&wsi->mqtt->sul_qos_puback_pubrec_wait);
471 s = wsi->mqtt->subs_head;
472 wsi->mqtt->subs_head = NULL;
478 mysub = lws_mqtt_find_sub(nwsi->mqtt, (const char *)&s[1]);
490 wsi->mqtt->rx_cpkt_param;
495 lws_free_set_NULL(wsi->mqtt->rx_cpkt_param);
497 lws_free_set_NULL(wsi->mqtt);
609 /* role name */ "mqtt",
610 /* alpn id */ "x-amzn-mqtt-ca", /* "mqtt/3.1.1" */