Lines Matching refs:mqtt
26 * http://docs.oasis-open.org/mqtt/mqtt/v5.0/mqtt-v5.0.html
330 lws_mqtt_create_sub(struct _lws_mqtt_related *mqtt, const char *topic)
336 flag = lws_mqtt_validate_topic(topic, topiclen, mqtt->client.aws_iot);
367 mysub->next = mqtt->subs_head;
368 mqtt->subs_head = mysub;
372 lwsl_info("%s: Created mysub %p for wsi->mqtt %p\n",
373 __func__, mysub, mqtt);
379 lws_mqtt_client_remove_subs(struct _lws_mqtt_related *mqtt)
381 lws_mqtt_subs_t *s = mqtt->subs_head;
385 lwsl_info("%s: Called to remove subs from wsi->mqtt %p\n",
386 __func__, mqtt);
396 lwsl_info("%s: Removing sub %p from wsi->mqtt %p\n",
397 __func__, temp, mqtt);
413 struct _lws_mqtt_related *mqtt = lws_container_of(sul,
416 lwsl_notice("%s: %s\n", __func__, lws_wsi_tag(mqtt->wsi));
418 if (mqtt->wsi->a.protocol->callback(mqtt->wsi, LWS_CALLBACK_MQTT_RESEND,
419 mqtt->wsi->user_space, NULL, 0))
420 lws_set_timeout(mqtt->wsi, 1, LWS_TO_KILL_ASYNC);
426 struct _lws_mqtt_related *mqtt = lws_container_of(sul,
429 lwsl_debug("%s: %s\n", __func__, lws_wsi_tag(mqtt->wsi));
431 if (mqtt->wsi->a.protocol->callback(mqtt->wsi,
433 mqtt->wsi->user_space, NULL, 0))
434 lws_set_timeout(mqtt->wsi, 1, LWS_TO_KILL_ASYNC);
440 struct _lws_mqtt_related *mqtt = lws_container_of(sul,
443 lwsl_debug("%s: %s\n", __func__, lws_wsi_tag(mqtt->wsi));
445 if (mqtt->wsi->a.protocol->callback(mqtt->wsi,
447 mqtt->wsi->user_space, NULL, 0))
448 lws_set_timeout(mqtt->wsi, 1, LWS_TO_KILL_ASYNC);
503 lws_mqtt_subs_t* lws_mqtt_find_sub(struct _lws_mqtt_related* mqtt,
505 lws_mqtt_subs_t *s = mqtt->subs_head;
729 wsi->mqtt->ack_pkt_id = par->cpkt_id;
765 wsi->mqtt->ack_pkt_id = par->cpkt_id;
801 wsi->mqtt->ack_pkt_id = par->cpkt_id;
810 if (lwsi_role_client(wsi) && wsi->mqtt->inside_subscribe) {
863 assert(!wsi->mqtt->rx_cpkt_param);
864 wsi->mqtt->rx_cpkt_param = lws_zalloc(
866 if (!wsi->mqtt->rx_cpkt_param)
868 pub = (lws_mqtt_publish_param_t *)wsi->mqtt->rx_cpkt_param;
905 lws_free_set_NULL(wsi->mqtt->rx_cpkt_param);
913 (lws_mqtt_publish_param_t *)wsi->mqtt->rx_cpkt_param;
923 wsi->mqtt->peer_ack_pkt_id = par->cpkt_id;
938 (lws_mqtt_publish_param_t *)wsi->mqtt->rx_cpkt_param;
978 lws_mqttc_t *c = &wsi->mqtt->client;
1014 wsi->mqtt->session_resumed = ((unsigned int)par->cpkt_flags &
1081 wsi->mqtt->ack_pkt_id = par->cpkt_id;
1151 wsi->mqtt->ack_pkt_id = par->cpkt_id;
1311 w->mqtt = wsi->mqtt;
1312 wsi->mqtt = lws_zalloc(sizeof(*wsi->mqtt), "nwsi mqtt");
1313 if (!wsi->mqtt)
1315 w->mqtt->wsi = w;
1377 if (w->mqtt->unacked_publish &&
1378 w->mqtt->ack_pkt_id == par->cpkt_id) {
1381 w->mqtt->unacked_publish = 0;
1382 w->mqtt->unacked_pubrel = 1;
1399 lws_sul_cancel(&w->mqtt->
1417 wsi->mqtt->send_pubrel = 1;
1427 if (w->mqtt->unacked_pubrel > 0 &&
1428 w->mqtt->ack_pkt_id == par->cpkt_id) {
1429 w->mqtt->unacked_pubrel = 0;
1451 wsi->mqtt->send_pubcomp = 1;
1466 if (w->mqtt->unacked_publish &&
1467 w->mqtt->ack_pkt_id == par->cpkt_id) {
1470 w->mqtt->unacked_publish = 0;
1486 lws_sul_cancel(&w->mqtt->sul_qos_puback_pubrec_wait);
1534 if (w->mqtt->inside_subscribe &&
1535 w->mqtt->ack_pkt_id == par->cpkt_id) {
1536 w->mqtt->inside_subscribe = 0;
1576 if (w->mqtt->inside_unsubscribe &&
1577 w->mqtt->ack_pkt_id == par->cpkt_id) {
1584 lws_mqtt_client_remove_subs(nwsi->mqtt);
1586 w->mqtt->inside_unsubscribe = 0;
1597 lws_sul_cancel(&w->mqtt->sul_unsuback_wait);
1628 wsi->mqtt->rx_cpkt_param;
1649 if (lws_mqtt_find_sub(w->mqtt,
1658 lws_free_set_NULL(wsi->mqtt->rx_cpkt_param);
1684 wsi->mqtt->send_puback = 1;
1688 wsi->mqtt->send_pubrec = 1;
1694 lws_free_set_NULL(wsi->mqtt->rx_cpkt_param);
1978 if (wsi->mqtt->inside_payload) {
1987 wsi->mqtt->inside_payload = 0;
2044 nwsi->mqtt->pkt_id++;
2045 wsi->mqtt->ack_pkt_id = pub->packet_id = nwsi->mqtt->pkt_id;
2047 (int)wsi->mqtt->ack_pkt_id);
2062 nwsi->mqtt->inside_payload = wsi->mqtt->inside_payload = 1;
2081 wsi->mqtt->inside_payload = nwsi->mqtt->inside_payload = 0;
2084 wsi->mqtt->unacked_publish = 1;
2103 wsi->mqtt->sul_qos_puback_pubrec_wait.cb = lws_mqtt_publish_resend;
2105 &wsi->mqtt->sul_qos_puback_pubrec_wait,
2109 if (wsi->mqtt->inside_shadow) {
2110 wsi->mqtt->sul_shadow_wait.cb = lws_mqtt_shadow_timeout;
2112 &wsi->mqtt->sul_shadow_wait,
2162 mysub = lws_mqtt_find_sub(nwsi->mqtt, sub->topic[n].name);
2170 * Attach the topic we're subscribing to, to wsi->mqtt
2172 if (!lws_mqtt_create_sub(wsi->mqtt, sub->topic[n].name)) {
2215 wsi->mqtt->sub_size = (uint16_t)rem_len;
2235 wsi->mqtt->ack_pkt_id = sub->packet_id = ++nwsi->mqtt->pkt_id;
2238 lws_ser_wu16be(p, wsi->mqtt->ack_pkt_id);
2240 nwsi->mqtt->client.aws_iot = wsi->mqtt->client.aws_iot;
2259 * Attach the topic we're subscribing to, to nwsi->mqtt
2263 if (!lws_mqtt_create_sub(nwsi->mqtt, sub->topic[n].name))
2292 if (wsi->mqtt->inside_resume_session)
2299 wsi->mqtt->inside_subscribe = 1;
2326 mysub = lws_mqtt_find_sub(nwsi->mqtt,
2385 wsi->mqtt->sub_size = (uint16_t)rem_len;
2405 wsi->mqtt->ack_pkt_id = ++nwsi->mqtt->pkt_id;
2407 (int)wsi->mqtt->ack_pkt_id);
2408 lws_ser_wu16be(p, wsi->mqtt->ack_pkt_id);
2410 nwsi->mqtt->client.aws_iot = wsi->mqtt->client.aws_iot;
2452 wsi->mqtt->inside_unsubscribe = 1;
2454 wsi->mqtt->sul_unsuback_wait.cb = lws_mqtt_unsuback_timeout;
2456 &wsi->mqtt->sul_unsuback_wait,