| /third_party/libwebsockets/lib/secure-streams/protocols/ |
| D | ss-mqtt.c | 32 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.sub_info.topic = NULL; in secstream_mqtt_cleanup()
[all …]
|
| /third_party/libwebsockets/lib/roles/mqtt/ |
| D | ops-mqtt.c | 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 && !wsi->mqtt->inside_payload && in rops_handle_POLLOUT_mqtt()
306 (wsi->mqtt->send_pubrec || wsi->mqtt->send_pubrel || in rops_handle_POLLOUT_mqtt()
307 wsi->mqtt->send_pubcomp)) { in rops_handle_POLLOUT_mqtt()
311 if (wsi->mqtt->send_pubrec) { in rops_handle_POLLOUT_mqtt()
313 __func__, wsi->mqtt->peer_ack_pkt_id); in rops_handle_POLLOUT_mqtt()
317 wsi->mqtt->peer_ack_pkt_id); in rops_handle_POLLOUT_mqtt()
318 wsi->mqtt->send_pubrec = 0; in rops_handle_POLLOUT_mqtt()
319 } else if (wsi->mqtt->send_pubrel) { in rops_handle_POLLOUT_mqtt()
[all …]
|
| D | mqtt.c | 326 lws_mqtt_subs_t* lws_mqtt_find_sub(struct _lws_mqtt_related* mqtt, in lws_mqtt_find_sub() argument
328 lws_mqtt_subs_t *s = mqtt->subs_head; in lws_mqtt_find_sub()
405 lws_mqtt_create_sub(struct _lws_mqtt_related *mqtt, const char *topic) in lws_mqtt_create_sub() argument
411 flag = lws_mqtt_validate_topic(topic, topiclen, mqtt->client.aws_iot); in lws_mqtt_create_sub()
442 mysub->next = mqtt->subs_head; in lws_mqtt_create_sub()
443 mqtt->subs_head = mysub; in lws_mqtt_create_sub()
448 __func__, mysub, mqtt); in lws_mqtt_create_sub()
454 lws_mqtt_client_remove_subs(struct _lws_mqtt_related *mqtt) in lws_mqtt_client_remove_subs() argument
456 lws_mqtt_subs_t *s = mqtt->subs_head; in lws_mqtt_client_remove_subs()
461 __func__, mqtt); in lws_mqtt_client_remove_subs()
[all …]
|
| D | CMakeLists.txt | 36 roles/mqtt/mqtt.c
37 roles/mqtt/ops-mqtt.c
38 roles/mqtt/primitives.c
39 roles/mqtt/client/client-mqtt.c
40 roles/mqtt/client/client-mqtt-handshake.c
|
| D | private-lib-roles-mqtt.h | 438 lws_mqtt_find_sub(struct _lws_mqtt_related *mqtt, const char *topic);
|
| /third_party/libwebsockets/minimal-examples/secure-streams/minimal-secure-streams-policy2c/ |
| D | minimal-secure-streams.c | 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()
577 if (pol->u.mqtt.keep_alive) in main()
579 pol->u.mqtt.keep_alive); in main()
[all …]
|
| /third_party/libwebsockets/minimal-examples/mqtt-client/ |
| D | README.md | 3 minimal-mqtt-client|Simple demo for mqtt client operation
4 minimal-mqtt-client-multi|Demonstrates automatic binding / muxing of independent connections to sha…
|
| /third_party/libwebsockets/minimal-examples/mqtt-client/minimal-mqtt-client/ |
| D | CMakeLists.txt | 1 project(lws-minimal-mqtt-client C)
6 set(SAMP lws-minimal-mqtt-client)
7 set(SRCS minimal-mqtt-client.c)
|
| /third_party/libwebsockets/minimal-examples/mqtt-client/minimal-mqtt-client-multi/ |
| D | CMakeLists.txt | 1 project(lws-minimal-mqtt-client-multi C)
8 set(SAMP lws-minimal-mqtt-client-multi)
9 set(SRCS minimal-mqtt-client-multi.c)
|
| /third_party/libwebsockets/lib/roles/mqtt/client/ |
| D | client-mqtt.c | 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()
|
| D | client-mqtt-handshake.c | 35 const lws_mqttc_t *c = &wsi->mqtt->client; in lws_mqtt_client_send_connect()
|
| /third_party/libwebsockets/lib/secure-streams/ |
| D | policy-json.c | 1012 pp = (char **)&a->curr[LTY_POLICY].p->u.mqtt.topic; in lws_ss_policy_parser_cb()
1016 pp = (char **)&a->curr[LTY_POLICY].p->u.mqtt.subscribe; in lws_ss_policy_parser_cb()
1020 a->curr[LTY_POLICY].p->u.mqtt.qos = (uint8_t)atoi(ctx->buf); in lws_ss_policy_parser_cb()
1024 a->curr[LTY_POLICY].p->u.mqtt.keep_alive = (uint16_t)atoi(ctx->buf); in lws_ss_policy_parser_cb()
1028 a->curr[LTY_POLICY].p->u.mqtt.clean_start = in lws_ss_policy_parser_cb()
1032 pp = (char **)&a->curr[LTY_POLICY].p->u.mqtt.will_topic; in lws_ss_policy_parser_cb()
1036 pp = (char **)&a->curr[LTY_POLICY].p->u.mqtt.will_message; in lws_ss_policy_parser_cb()
1040 a->curr[LTY_POLICY].p->u.mqtt.will_qos = (uint8_t)atoi(ctx->buf); in lws_ss_policy_parser_cb()
1043 a->curr[LTY_POLICY].p->u.mqtt.will_retain = in lws_ss_policy_parser_cb()
1047 pp = (char **)&a->curr[LTY_POLICY].p->u.mqtt.birth_topic; in lws_ss_policy_parser_cb()
[all …]
|
| /third_party/typescript/tests/cases/user/mqtt/ |
| D | index.ts | 1 import mqtt = require("mqtt");
|
| /third_party/lwip/doc/ |
| D | mqtt_client.txt | 6 http://docs.oasis-open.org/mqtt/mqtt/v3.1.1/os/mqtt-v3.1.1-os.html
|
| /third_party/libwebsockets/minimal-examples/secure-streams/minimal-secure-streams-staticpolicy/ |
| D | static-policy.h | 1335 .mqtt = {
1353 .mqtt = {
|
| /third_party/lwip/test/unit/ |
| D | Filelists.mk | 46 $(TESTDIR)/mqtt/test_mqtt.c \
|
| D | Filelists.cmake | 26 ${LWIP_TESTDIR}/mqtt/test_mqtt.c
|
| /third_party/curl/ |
| D | backport-CVE-2022-42915.patch | 125 +mqtt
140 …xample telnet://another ftp://yes ftps://again imap://more ldap://perhaps mqtt://yes pop3://mail r…
|
| /third_party/lwip/src/ |
| D | Filelists.mk | 190 MQTTFILES=$(LWIPDIR)/apps/mqtt/mqtt.c
|
| D | Filelists.cmake | 213 ${LWIP_DIR}/src/apps/mqtt/mqtt.c
|
| /third_party/libwebsockets/include/libwebsockets/ |
| D | lws-secure-streams-policy.h | 327 } mqtt; member
|
| /third_party/libwebsockets/lib/roles/ |
| D | CMakeLists.txt | 35 add_subdir_include_directories(mqtt)
|
| /third_party/lwip/ |
| D | lwip.gni | 204 MQTTFILES = [ "$LWIPDIR/apps/mqtt/mqtt.c" ]
|
| /third_party/libwebsockets/ |
| D | bug_report.md | 15 raw / http / ws / mqtt / other (give me a hint)
|
| D | BUILD.gn | 202 "//third_party/libwebsockets/lib/roles/mqtt",
203 "//third_party/libwebsockets/lib/roles/mqtt/client",
307 "//third_party/libwebsockets/lib/roles/mqtt",
|