| /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
|
| /third_party/curl/lib/ |
| D | mqtt.c | 103 DEBUGASSERT(data->req.p.mqtt == NULL); in mqtt_setup_conn()
108 data->req.p.mqtt = mq; in mqtt_setup_conn()
118 struct MQTT *mq = data->req.p.mqtt; in mqtt_send()
408 conn->proto.mqtt.packetid++; in mqtt_subscribe()
423 packet[1 + n] = (conn->proto.mqtt.packetid >> 8) & 0xff; in mqtt_subscribe()
424 packet[2 + n] = conn->proto.mqtt.packetid & 0xff; in mqtt_subscribe()
448 struct mqtt_conn *mqtt = &conn->proto.mqtt; in mqtt_verify_suback() local
463 if(readbuf[0] != ((mqtt->packetid >> 8) & 0xff) || in mqtt_verify_suback()
464 readbuf[1] != (mqtt->packetid & 0xff) || in mqtt_verify_suback()
565 struct mqtt_conn *mqtt = &conn->proto.mqtt; in mqstate() local
[all …]
|
| /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/curl/tests/data/ |
| D | test1191 | 20 mqtt
23 mqtt
29 mqtt://%HOSTIP:%MQTTPORT/%TESTNUMBER -d something
|
| D | test1193 | 20 mqtt
23 mqtt
29 mqtt://%HOSTIP:%MQTTPORT/%TESTNUMBER -d @log/payload%TESTNUMBER
|
| D | test1199 | 24 mqtt
27 mqtt
33 mqtt://%HOSTIP:%MQTTPORT -d ""
|
| D | test2205 | 20 mqtt
23 mqtt
32 mqtt://%HOSTIP:%MQTTPORT/%TESTNUMBER -K log/input%TESTNUMBER
|
| D | test2201 | 20 mqtt
23 mqtt
29 mqtt://%HOSTIP:%MQTTPORT/%TESTNUMBER -d something -u testuser:testpasswd
|
| D | test1190 | 24 mqtt
27 mqtt
33 mqtt://%HOSTIP:%MQTTPORT/%TESTNUMBER
|
| D | test2202 | 25 mqtt
28 mqtt
34 mqtt://%HOSTIP:%MQTTPORT/%TESTNUMBER -d something -u fakeuser:fakepasswd
|
| D | test1198 | 24 mqtt
27 mqtt
33 mqtt://%HOSTIP:%MQTTPORT/%20 -d ""
|
| D | test1916 | 24 mqtt
27 mqtt
36 "mqtt://%HOSTIP:%MQTTPORT/%20"
|
| D | test1195 | 28 mqtt
31 mqtt
37 mqtt://%HOSTIP:%MQTTPORT/%TESTNUMBER
|
| D | test2204 | 24 mqtt
27 mqtt
33 mqtt://%HOSTIP:%MQTTPORT/%TESTNUMBER -u testuser:testpasswd
|
| D | test2203 | 29 mqtt
32 mqtt
38 mqtt://%HOSTIP:%MQTTPORT/%TESTNUMBER
|
| D | test1194 | 27 mqtt
30 mqtt
36 mqtt://%HOSTIP:%MQTTPORT/%TESTNUMBER
|
| D | test1192 | 24 mqtt
27 mqtt
33 mqtt://%HOSTIP:%MQTTPORT/AAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAA…
|
| D | test1917 | 26 mqtt
30 mqtt
39 "mqtt://%HOSTIP:%MQTTPORT/%20"
|
| D | test1196 | 29 mqtt
32 mqtt
38 mqtt://%HOSTIP:%MQTTPORT/%TESTNUMBER
|