Home
last modified time | relevance | path

Searched refs:topic (Results 1 - 25 of 26) sorted by relevance

12

/third_party/libwebsockets/lib/secure-streams/protocols/
H A Dss-mqtt.c37 if (h->u.mqtt.sub_info.topic) { 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()
81 " topic with no output\n", in secstream_mqtt_subscribe()
90 "topic", in secstream_mqtt_subscribe()
101 lwsl_err("%s, failed to expand MQTT subscribe topic\n", in secstream_mqtt_subscribe()
121 h->u.mqtt.sub_info.topic in secstream_mqtt_subscribe()
145 secstream_mqtt_publish(struct lws *wsi, uint8_t *buf, size_t buf_len, uint32_t payload_len, const char* topic, lws_mqtt_qos_levels_t qos, uint8_t retain, uint8_t dup, int f) secstream_mqtt_publish() argument
350 secstream_mqtt_is_shadow_matched(struct lws *wsi, const char *topic) secstream_mqtt_is_shadow_matched() argument
[all...]
/third_party/lwip/src/include/lwip/apps/
H A Dmqtt.h77 /** will topic, set to NULL if will is not to be used,
140 * arrives to a subscribed topic @see mqtt_subscribe
155 * arrives to a subscribed topic @see mqtt_subscribe
158 * @param topic Zero terminated Topic text string, topic may not be referenced after callback return
161 typedef void (*mqtt_incoming_publish_cb_t)(void *arg, const char *topic, u32_t tot_len);
189 err_t mqtt_sub_unsub(mqtt_client_t *client, const char *topic, u8_t qos, mqtt_request_cb_t cb, void *arg, u8_t sub);
192 *Subscribe to topic */
193 #define mqtt_subscribe(client, topic, qos, cb, arg) mqtt_sub_unsub(client, topic, qo
[all...]
/third_party/libwebsockets/lib/roles/mqtt/client/
H A Dclient-mqtt-handshake.c63 if (c->conn_flags & LMQCFT_WILL_FLAG && c->will.topic) { in lws_mqtt_client_send_connect()
64 len = len + (unsigned int)c->will.topic->len + 2; in lws_mqtt_client_send_connect()
85 * 4. Payload - Client ID, Will topic & message, in lws_mqtt_client_send_connect()
108 if (lws_mqtt_str_is_not_empty(c->will.topic)) { in lws_mqtt_client_send_connect()
109 lws_ser_wu16be(p, c->will.topic->len); in lws_mqtt_client_send_connect()
111 memcpy(p, c->will.topic->buf, c->will.topic->len); in lws_mqtt_client_send_connect()
112 p += c->will.topic->len; in lws_mqtt_client_send_connect()
H A Dclient-mqtt.c136 if (cp->will_param.topic && in lws_create_client_mqtt_object()
137 *cp->will_param.topic) { in lws_create_client_mqtt_object()
138 c->will.topic = lws_mqtt_str_create_cstr_dup( in lws_create_client_mqtt_object()
139 cp->will_param.topic, 0); in lws_create_client_mqtt_object()
140 if (!c->will.topic) in lws_create_client_mqtt_object()
178 lws_mqtt_str_free(&c->will.topic); in lws_create_client_mqtt_object()
/third_party/libwebsockets/lib/roles/mqtt/
H A Dmqtt.c274 lws_mqtt_validate_topic(const char *topic, size_t topiclen, uint8_t awsiot) in lws_mqtt_validate_topic() argument
277 const char *sub = topic; in lws_mqtt_validate_topic()
284 if (topic[0] == '$') { in lws_mqtt_validate_topic()
291 if (topic[0] == '$') in lws_mqtt_validate_topic()
297 /* topic == "+foo" || "a/+foo" ? */ in lws_mqtt_validate_topic()
301 /* topic == "foo+" or "foo+/a" ? */ in lws_mqtt_validate_topic()
307 /* topic == "foo#" ? */ in lws_mqtt_validate_topic()
311 /* topic == "#foo" ? */ in lws_mqtt_validate_topic()
330 lws_mqtt_create_sub(struct _lws_mqtt_related *mqtt, const char *topic) in lws_mqtt_create_sub() argument
333 size_t topiclen = strlen(topic); in lws_mqtt_create_sub()
[all...]
H A Dprivate-lib-roles-mqtt.h327 char topic[]; member
344 struct lws_mqtt_str_st *topic; member
443 lws_mqtt_find_sub(struct _lws_mqtt_related *mqtt, const char *topic);
H A Dops-mqtt.c466 lws_mqtt_str_free(&c->will.topic); in rops_close_role_mqtt()
493 lws_free_set_NULL(pub->topic); in rops_close_role_mqtt()
/third_party/libwebsockets/minimal-examples/mqtt-client/minimal-mqtt-client/
H A Dminimal-mqtt-client.c24 STATE_SUBSCRIBE, /* subscribe to the topic */
48 .topic = "good/bye",
65 .topic = &topics[0],
216 pub_param.topic = "test/topic"; in callback_mqtt()
217 pub_param.topic_len = (uint16_t)strlen(pub_param.topic); in callback_mqtt()
287 lwsl_hexdump_notice(pub->topic, pub->topic_len); in callback_mqtt()
/third_party/lwip/src/apps/mqtt/
H A Dmqtt.c43 * - Fix restriction of a single topic in each (UN)SUBSCRIBE message (protocol has support for multiple topics)
717 /* Should have topic and pkt id*/ in mqtt_message_received()
718 u8_t *topic; in mqtt_message_received() local
731 LWIP_DEBUGF(MQTT_DEBUG_WARN,( "mqtt_message_received: Received short PUBLISH packet (topic)\n")); in mqtt_message_received()
735 topic = var_hdr_payload + 2; in mqtt_message_received()
739 LWIP_DEBUGF(MQTT_DEBUG_WARN, ("mqtt_message_received: Receive buffer can not fit topic + pkt_id\n")); in mqtt_message_received()
754 /* Take backup of byte after topic */ in mqtt_message_received()
755 bkp = topic[topic_len]; in mqtt_message_received()
757 topic[topic_len] = 0; in mqtt_message_received()
762 LWIP_DEBUGF(MQTT_DEBUG_TRACE, ("mqtt_incomming_publish: Received message with QoS %d at topic in mqtt_message_received()
1096 mqtt_publish(mqtt_client_t *client, const char *topic, const void *payload, u16_t payload_length, u8_t qos, u8_t retain, mqtt_request_cb_t cb, void *arg) mqtt_publish() argument
1172 mqtt_sub_unsub(mqtt_client_t *client, const char *topic, u8_t qos, mqtt_request_cb_t cb, void *arg, u8_t sub) mqtt_sub_unsub() argument
[all...]
/third_party/libwebsockets/include/libwebsockets/
H A Dlws-mqtt.h105 const char *topic; member
112 const char *topic; member
127 char *topic; /* Topic Name */ member
156 lws_mqtt_topic_elem_t *topic; /* Array of topic elements */ member
351 * \param sub: which topic(s) we want to subscribe to
367 * \param sub: which topic(s) we want to unsubscribe from
H A Dlws-secure-streams-policy.h309 const char *topic; /* stream sends on this topic */ member
310 const char *subscribe; /* stream subscribes to this topic */
/third_party/libwebsockets/minimal-examples/mqtt-client/minimal-mqtt-client-multi/
H A Dminimal-mqtt-client-multi.c32 STATE_SUBSCRIBE, /* subscribe to the topic */
60 .topic = "good/bye",
75 .topic = &topics[0],
273 pss->pub_param.topic = pss->state == STATE_PUBLISH_QOS0 ? in callback_mqtt()
275 pss->pub_param.topic_len = (uint16_t)strlen(pss->pub_param.topic); in callback_mqtt()
354 (int)(item - &items[0]), pub->topic, (int)pub->payload_pos, in callback_mqtt()
/third_party/ffmpeg/fftools/
H A Dopt_common.c576 char *topic, *par; in show_help() local
579 topic = av_strdup(arg ? arg : ""); in show_help()
580 if (!topic) in show_help()
582 par = strchr(topic, '='); in show_help()
586 if (!*topic) { in show_help()
587 show_help_default(topic, par); in show_help()
588 } else if (!strcmp(topic, "decoder")) { in show_help()
590 } else if (!strcmp(topic, "encoder")) { in show_help()
592 } else if (!strcmp(topic, "demuxer")) { in show_help()
594 } else if (!strcmp(topic, "muxe in show_help()
[all...]
/third_party/curl/lib/
H A Dmqtt.c419 char **topic, size_t *topiclen) in mqtt_get_topic()
424 result = Curl_urldecode(path + 1, 0, topic, topiclen, REJECT_NADA); in mqtt_get_topic()
426 failf(data, "Too long MQTT topic"); in mqtt_get_topic()
431 failf(data, "No MQTT topic found. Forgot to URL encode it?"); in mqtt_get_topic()
439 char *topic = NULL; in mqtt_subscribe() local
447 result = mqtt_get_topic(data, &topic, &topiclen); in mqtt_subscribe()
453 packetlen = topiclen + 5; /* packetid + topic (has a two byte length field) in mqtt_subscribe()
454 + 2 bytes topic length + QoS byte */ in mqtt_subscribe()
470 memcpy(&packet[5 + n], topic, topiclen); in mqtt_subscribe()
476 free(topic); in mqtt_subscribe()
418 mqtt_get_topic(struct Curl_easy *data, char **topic, size_t *topiclen) mqtt_get_topic() argument
518 char *topic = NULL; mqtt_publish() local
[all...]
/third_party/curl/tests/server/
H A Dmqttd.c394 char *topic, char *payload, size_t payloadlen) in publish()
396 size_t topiclen = strlen(topic); in publish()
431 memcpy(&packet[3 + encodedlen], topic, topiclen); in publish()
454 static char topic[MAX_TOPIC_LENGTH + 1]; variable
635 /* two bytes topic length */ in mqttit()
638 logmsg("Wrong topic length, got %zu expected %zu", in mqttit()
642 memcpy(topic, &buffer[4], topic_len); in mqttit()
643 topic[topic_len] = 0; in mqttit()
645 /* there's a QoS byte (two bits) after the topic */ in mqttit()
647 logmsg("SUBSCRIBE to '%s' [%d]", topic, packet_i in mqttit()
392 publish(FILE *dump, curl_socket_t fd, unsigned short packetid, char *topic, char *payload, size_t payloadlen) publish() argument
[all...]
/third_party/gn/src/gn/
H A Dstandard_out.cc222 const std::string& topic, in PrintSectionHelp()
228 } else if (topic.size()) { in PrintSectionHelp()
229 OutputString("\n" + line + " (type \"gn help " + topic + in PrintSectionHelp()
221 PrintSectionHelp(const std::string& line, const std::string& topic, const std::string& tag) PrintSectionHelp() argument
H A Dstandard_out.h35 const std::string& topic,
H A Dcommand_check.cc50 The topic "gn help check" has general information on how checking works and
/third_party/python/Lib/
H A Dpydoc.py1805 # These dictionaries map a topic name to either an alias, or a tuple
1884 for topic, symbols_ in _symbols_inverse.items():
1886 topics = symbols.get(symbol, topic)
1887 if topic not in topics:
1888 topics = topics + ' ' + topic
1890 del topic, symbols_, symbol, topics
2073 Enter the name of any module, keyword, or topic to get help on writing
2113 Here is a list of available topics. Enter any topic name to get more help.
2118 def showtopic(self, topic, more_xrefs=''):
2123 Sorry, topic an
[all...]
H A Dpdb.py1566 topic = getattr(self, 'help_' + arg)
1567 return topic()
/third_party/libuv/docs/src/sphinx-plugins/
H A Dmanpage.py24 ref = s.substitute(num=manpage_num, topic=name)
/third_party/lz4/tests/
H A Dtest-lz4-speed.py76 def send_email(emails, topic, text, have_mutt, have_mail):
82 execute('mutt -s "' + topic + '" ' + emails + ' < ' + logFileName, verbose)
84 execute('mail -s "' + topic + '" ' + emails + ' < ' + logFileName, verbose)
/third_party/libwebsockets/minimal-examples/secure-streams/minimal-secure-streams-policy2c/
H A Dminimal-secure-streams.c564 if (pol->u.mqtt.topic) in main()
565 printf("\t\t\t.topic = \"%s\",\n", in main()
566 pol->u.mqtt.topic); in main()
/third_party/libwebsockets/lib/secure-streams/
H A Dpolicy-json.c1014 pp = (char **)&a->curr[LTY_POLICY].p->u.mqtt.topic; in lws_ss_policy_parser_cb()
/third_party/skia/third_party/externals/microhttpd/doc/
H A Dtexinfo.tex4355 % There is also \dosubind {index}{topic}{subtopic}
4853 % \entry {sortstring}{page}{topic}
4855 % \entry {sortstring}{page}{topic}{subtopic}
4859 % before the first topic whose initial is c
4860 % \entry {topic}{pagelist}
4861 % for a topic that is used without subtopics
4862 % \primary {topic}
4863 % for the beginning of a topic that is used with subtopics

Completed in 29 milliseconds

12