Lines Matching refs:topic_len
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] = bkp; in mqtt_message_received()
1103 u16_t topic_len; in mqtt_publish() local
1113 topic_len = (u16_t)topic_strlen; in mqtt_publish()
1114 total_len = 2 + topic_len + payload_length; in mqtt_publish()
1142 mqtt_output_append_string(&client->output, topic, topic_len); in mqtt_publish()
1176 u16_t topic_len; in mqtt_sub_unsub() local
1187 topic_len = (u16_t)topic_strlen; in mqtt_sub_unsub()
1189 total_len = topic_len + 2 + 2 + (sub != 0); in mqtt_sub_unsub()
1216 mqtt_output_append_string(&client->output, topic, topic_len); in mqtt_sub_unsub()