topic_len (reference) in projects: third_party - OpenGrok search results

Repository(s)

Full Search		Search through all text tokens(words,strings,identifiers,numbers) in index.
Definition		Only finds symbol definitions(where e.g a variable(function,...) is defined).
Symbol		Only finds symbol(e.g. methods classes,function,variables).
File Path		Path of the source file(use "/").If you want just exact path,enclose it in "".Source files end with: .jar/.bz2/.a/.h/.java...
History		History log comments.
Type		Type of analyzer used to filter file types include with selected(e.g. just C sources).

Help

Searched refs:topic_len (Results 1 - 7 of 7) sorted by relevance

/third_party/lwip/src/apps/mqtt/
H A D	mqtt.c	721 u16_t topic_len; in mqtt_message_received() local 727 topic_len = var_hdr_payload[0]; in mqtt_message_received() 728 topic_len = (topic_len << 8) + (u16_t)(var_hdr_payload[1]); in mqtt_message_received() 729 if ((topic_len > length - (2 + qos_len)) \|\| in mqtt_message_received() 730 (topic_len > var_hdr_payload_bufsize - (2 + qos_len))) { in mqtt_message_received() 736 after_topic = 2 + topic_len; in mqtt_message_received() 755 bkp = topic[topic_len]; in mqtt_message_received() 757 topic[topic_len] = 0; in mqtt_message_received() 768 topic[topic_len] in mqtt_message_received() 1103 u16_t topic_len; mqtt_publish() local 1176 u16_t topic_len; mqtt_sub_unsub() local [all...]
/third_party/curl/tests/server/
H A D	mqttd.c	`500 size_t topic_len; in mqttit() local 636 topic_len = (size_t)(buffer[2] << 8) \| buffer[3]; in mqttit() 637 if(topic_len != (remaining_length - 5)) { in mqttit() 639 topic_len, remaining_length - 5); in mqttit() 642 memcpy(topic, &buffer[4], topic_len); in mqttit() 643 topic[topic_len] = 0; in mqttit()`
/third_party/libwebsockets/lib/roles/mqtt/
H A D	mqtt.c	870 pub->topic_len = (uint16_t)par->n; in _lws_mqtt_rx_parser() 873 pub->topic = (char *)lws_zalloc((size_t)pub->topic_len + 1, in _lws_mqtt_rx_parser() 878 (size_t)pub->topic_len + 1); in _lws_mqtt_rx_parser() 879 buf += pub->topic_len; in _lws_mqtt_rx_parser() 880 len -= pub->topic_len; in _lws_mqtt_rx_parser() 889 (unsigned int)(2 + pub->topic_len + ((pub->qos) ? 2 : 0)); in _lws_mqtt_rx_parser() 929 (unsigned int)(2 + pub->topic_len + ((pub->qos) ? 2 : 0)); in _lws_mqtt_rx_parser() 2007 vh_len = (unsigned int)(2 + pub->topic_len + ((pub->qos) ? 2 : 0)); in lws_mqtt_client_send_publish() 2021 lws_ser_wu16be(p, pub->topic_len); in lws_mqtt_client_send_publish() 2030 (uint16_t)(unsigned int)(pub->topic_len in lws_mqtt_client_send_publish() [all...]
/third_party/libwebsockets/minimal-examples/mqtt-client/minimal-mqtt-client/
H A D	minimal-mqtt-client.c	`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/libwebsockets/lib/secure-streams/protocols/
H A D	ss-mqtt.c	`190 mqpp.topic_len = (uint16_t)strlen(mqpp.topic); in secstream_mqtt_publish() 484 size_t used_in = 0, used_out = 0, topic_len = 0; in secstream_mqtt() local 670 topic_len = omd->length; in secstream_mqtt() 674 pmqpp->topic_len); in secstream_mqtt() 682 topic_len); in secstream_mqtt() 698 pmqpp->topic, pmqpp->topic_len) \|\| in secstream_mqtt()`
/third_party/libwebsockets/include/libwebsockets/
H A D	lws-mqtt.h	`128 uint16_t topic_len; member`
/third_party/libwebsockets/minimal-examples/mqtt-client/minimal-mqtt-client-multi/
H A D	minimal-mqtt-client-multi.c	`275 pss->pub_param.topic_len = (uint16_t)strlen(pss->pub_param.topic); in callback_mqtt()`

Completed in 8 milliseconds