Home
last modified time | relevance | path

Searched refs:mqtt (Results 1 - 17 of 17) sorted by relevance

/third_party/libwebsockets/lib/secure-streams/protocols/
H A Dss-mqtt.c32 if (h->u.mqtt.heap_baggage) { in secstream_mqtt_cleanup()
33 lws_free(h->u.mqtt.heap_baggage); in secstream_mqtt_cleanup()
34 h->u.mqtt.heap_baggage = NULL; in secstream_mqtt_cleanup()
37 if (h->u.mqtt.sub_info.topic) { in secstream_mqtt_cleanup()
38 for (i = 0; i < h->u.mqtt.sub_info.num_topics; i++) { in secstream_mqtt_cleanup()
39 if (h->u.mqtt.sub_info.topic[i].name) { in secstream_mqtt_cleanup()
40 lws_free((void*)h->u.mqtt.sub_info.topic[i].name); in secstream_mqtt_cleanup()
41 h->u.mqtt.sub_info.topic[i].name = NULL; in secstream_mqtt_cleanup()
44 lws_free(h->u.mqtt.sub_info.topic); in secstream_mqtt_cleanup()
45 h->u.mqtt in secstream_mqtt_cleanup()
[all...]
/third_party/libwebsockets/lib/roles/mqtt/
H A Dops-mqtt.c43 * nwsi no longer has a wsi->mqtt of its own. in rops_handle_POLLIN_mqtt()
198 lws_close_free_wsi(wsi, LWS_CLOSE_STATUS_NOSTATUS, "mqtt svc fail"); in rops_handle_POLLIN_mqtt()
208 /* no http but socket... must be mqtt */
241 wsi->stash->cis[CIS_ALPN] = "x-amzn-mqtt-ca"; in rops_client_bind_mqtt()
263 /* if a recognized mqtt method, bind to it */ in rops_client_bind_mqtt()
283 if (wsi->mqtt && wsi->mqtt->send_pingreq && !wsi->mqtt->inside_payload) { in rops_handle_POLLOUT_mqtt()
291 wsi->mqtt->send_pingreq = 0; in rops_handle_POLLOUT_mqtt()
305 if (wsi->mqtt in rops_handle_POLLOUT_mqtt()
[all...]
H A Dmqtt.c26 * 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) in lws_mqtt_create_sub() argument
336 flag = lws_mqtt_validate_topic(topic, topiclen, mqtt->client.aws_iot); in lws_mqtt_create_sub()
367 mysub->next = mqtt->subs_head; in lws_mqtt_create_sub()
368 mqtt->subs_head = mysub; in lws_mqtt_create_sub()
372 lwsl_info("%s: Created mysub %p for wsi->mqtt %p\n", in lws_mqtt_create_sub()
373 __func__, mysub, mqtt); in lws_mqtt_create_sub()
379 lws_mqtt_client_remove_subs(struct _lws_mqtt_related *mqtt) in lws_mqtt_client_remove_subs() argument
413 struct _lws_mqtt_related *mqtt = lws_container_of(sul, lws_mqtt_publish_resend() local
426 struct _lws_mqtt_related *mqtt = lws_container_of(sul, lws_mqtt_unsuback_timeout() local
440 struct _lws_mqtt_related *mqtt = lws_container_of(sul, lws_mqtt_shadow_timeout() local
503 lws_mqtt_find_sub(struct _lws_mqtt_related* mqtt, const char* ptopic) lws_mqtt_find_sub() argument
[all...]
H A Dprivate-lib-roles-mqtt.h443 lws_mqtt_find_sub(struct _lws_mqtt_related *mqtt, const char *topic);
/third_party/libwebsockets/minimal-examples/secure-streams/minimal-secure-streams-policy2c/
H A Dminimal-secure-streams.c562 printf("\t.u = {\n\t\t.mqtt = {\n"); in main()
564 if (pol->u.mqtt.topic) in main()
566 pol->u.mqtt.topic); in main()
567 if (pol->u.mqtt.subscribe) in main()
569 pol->u.mqtt.subscribe); in main()
570 if (pol->u.mqtt.will_topic) in main()
572 pol->u.mqtt.will_topic); in main()
573 if (pol->u.mqtt.will_message) in main()
575 pol->u.mqtt.will_message); in main()
576 if (pol->u.mqtt in main()
[all...]
/third_party/curl/lib/
H A Dmqtt.c35 #include "mqtt.h"
107 DEBUGASSERT(data->req.p.mqtt == NULL); in mqtt_setup_conn()
113 data->req.p.mqtt = mq; in mqtt_setup_conn()
121 struct MQTT *mq = data->req.p.mqtt; in mqtt_send()
351 struct MQTT *mq = data->req.p.mqtt; in mqtt_disconnect()
360 struct MQTT *mq = data->req.p.mqtt; in mqtt_recv_atleast()
383 struct MQTT *mq = data->req.p.mqtt; in mqtt_recv_consume()
393 struct MQTT *mq = data->req.p.mqtt; in mqtt_verify_connack()
451 conn->proto.mqtt.packetid++; in mqtt_subscribe()
466 packet[1 + n] = (conn->proto.mqtt in mqtt_subscribe()
488 struct mqtt_conn *mqtt = &conn->proto.mqtt; mqtt_verify_suback() local
608 struct mqtt_conn *mqtt = &conn->proto.mqtt; mqstate() local
628 struct mqtt_conn *mqtt = &conn->proto.mqtt; mqtt_read_publish() local
744 struct mqtt_conn *mqtt = &conn->proto.mqtt; mqtt_doing() local
[all...]
H A Durldata.h177 #include "mqtt.h"
714 struct MQTT *mqtt; member
1055 struct mqtt_conn mqtt; member
/third_party/libwebsockets/lib/roles/mqtt/client/
H A Dclient-mqtt.c38 /* #include "lws-mqtt.h" */
93 lws_mqttc_t *c = &wsi->mqtt->client; in lws_read_mqtt()
106 wsi->mqtt = lws_zalloc(sizeof(*wsi->mqtt), "client mqtt struct"); in lws_create_client_mqtt_object()
107 if (!wsi->mqtt) in lws_create_client_mqtt_object()
110 wsi->mqtt->wsi = wsi; in lws_create_client_mqtt_object()
111 c = &wsi->mqtt->client; in lws_create_client_mqtt_object()
372 lws_close_free_wsi(wsi, LWS_CLOSE_STATUS_NOSTATUS, "mqtt svc fail"); in lws_mqtt_client_socket_service()
H A Dclient-mqtt-handshake.c35 const lws_mqttc_t *c = &wsi->mqtt->client; in lws_mqtt_client_send_connect()
/third_party/libwebsockets/lib/secure-streams/
H A Dpolicy-json.c265 "mqtt", /* LWSSSP_MQTT */
1014 pp = (char **)&a->curr[LTY_POLICY].p->u.mqtt.topic; in lws_ss_policy_parser_cb()
1018 pp = (char **)&a->curr[LTY_POLICY].p->u.mqtt.subscribe; in lws_ss_policy_parser_cb()
1022 a->curr[LTY_POLICY].p->u.mqtt.qos = (uint8_t)atoi(ctx->buf); in lws_ss_policy_parser_cb()
1026 a->curr[LTY_POLICY].p->u.mqtt.retain = in lws_ss_policy_parser_cb()
1031 a->curr[LTY_POLICY].p->u.mqtt.keep_alive = (uint16_t)atoi(ctx->buf); in lws_ss_policy_parser_cb()
1035 a->curr[LTY_POLICY].p->u.mqtt.clean_start = in lws_ss_policy_parser_cb()
1039 pp = (char **)&a->curr[LTY_POLICY].p->u.mqtt.will_topic; in lws_ss_policy_parser_cb()
1043 pp = (char **)&a->curr[LTY_POLICY].p->u.mqtt.will_message; in lws_ss_policy_parser_cb()
1047 a->curr[LTY_POLICY].p->u.mqtt in lws_ss_policy_parser_cb()
[all...]
H A Dprivate-lib-secure-streams.h159 } mqtt; member
/third_party/lwip/test/unit/
H A DFilelists.mk46 $(TESTDIR)/mqtt/test_mqtt.c \
/third_party/lwip/src/
H A DFilelists.mk190 MQTTFILES=$(LWIPDIR)/apps/mqtt/mqtt.c
/third_party/libwebsockets/include/libwebsockets/
H A Dlws-secure-streams-policy.h328 } mqtt; member
/third_party/libwebsockets/include/
H A Dlibwebsockets.h612 #include <libwebsockets/lws-mqtt.h>
/third_party/libwebsockets/lib/core-net/
H A Dprivate-lib-core-net.h638 struct _lws_mqtt_related *mqtt; member
/third_party/libwebsockets/minimal-examples/secure-streams/minimal-secure-streams-staticpolicy/
H A Dstatic-policy.h189 "protocol": "mqtt",
202 "protocol": "mqtt",
1335 .mqtt = {
1353 .mqtt = {

Completed in 20 milliseconds