Searched refs:topic_len (Results 1 – 7 of 7) sorted by relevance
721 u16_t topic_len; in mqtt_message_received() local727 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] = bkp; in mqtt_message_received()1103 u16_t topic_len; in mqtt_publish() local[all …]
500 unsigned int topic_len; in mqttit() local632 topic_len = (buffer[2] << 8) | buffer[3]; in mqttit()633 if(topic_len != (remaining_length - 5)) { in mqttit()635 topic_len, remaining_length - 5); in mqttit()638 memcpy(topic, &buffer[4], topic_len); in mqttit()639 topic[topic_len] = 0; in mqttit()
825 pub->topic_len = (uint16_t)par->n; in _lws_mqtt_rx_parser()828 pub->topic = (char *)lws_zalloc((size_t)pub->topic_len + 1, in _lws_mqtt_rx_parser()833 (size_t)pub->topic_len + 1); in _lws_mqtt_rx_parser()834 buf += pub->topic_len; in _lws_mqtt_rx_parser()835 len -= pub->topic_len; in _lws_mqtt_rx_parser()844 (unsigned int)(2 + pub->topic_len + ((pub->qos) ? 2 : 0)); in _lws_mqtt_rx_parser()884 (unsigned int)(2 + pub->topic_len + ((pub->qos) ? 2 : 0)); in _lws_mqtt_rx_parser()1994 vh_len = (unsigned int)(2 + pub->topic_len + ((pub->qos) ? 2 : 0)); in lws_mqtt_client_send_publish()2008 lws_ser_wu16be(p, pub->topic_len); in lws_mqtt_client_send_publish()2017 (uint16_t)(unsigned int)(pub->topic_len + ((pub->qos) ? 2u : 0u) + len), in lws_mqtt_client_send_publish()[all …]
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()
105 uint16_t topic_len; member
275 pss->pub_param.topic_len = (uint16_t)strlen(pss->pub_param.topic); in callback_mqtt()
188 mqpp.topic_len = (uint16_t)strlen(mqpp.topic); in secstream_mqtt_publish()