Searched refs:topic_name (Results 1 – 5 of 5) sorted by relevance
412 struct mqtt_sn_data *topic_name);424 struct mqtt_sn_data *topic_name);440 struct mqtt_sn_data *topic_name, bool retain, struct mqtt_sn_data *data);465 struct mqtt_sn_data *topic_name);
258 struct mqtt_sn_data *topic_name) in mqtt_sn_topic_find_name() argument263 if (topic->namelen == topic_name->size && in mqtt_sn_topic_find_name()264 memcmp(topic->name, topic_name->data, topic_name->size) == 0) { in mqtt_sn_topic_find_name()426 p.params.subscribe.topic.topic_name.data = topic->name; in mqtt_sn_do_subscribe()427 p.params.subscribe.topic.topic_name.size = topic->namelen; in mqtt_sn_do_subscribe()458 p.params.unsubscribe.topic.topic_name.data = topic->name; in mqtt_sn_do_unsubscribe()459 p.params.unsubscribe.topic.topic_name.size = topic->namelen; in mqtt_sn_do_unsubscribe()993 struct mqtt_sn_data *topic_name) in mqtt_sn_subscribe() argument998 if (!client || !topic_name || !topic_name->data || !topic_name->size) { in mqtt_sn_subscribe()1007 topic = mqtt_sn_topic_find_name(client, topic_name); in mqtt_sn_subscribe()[all …]
146 struct mqtt_sn_data topic_name; member162 struct mqtt_sn_data topic_name; member
314 msgsz += params->topic.topic_name.size; in mqtt_sn_encode_msg_subscribe()328 net_buf_simple_add_data(buf, ¶ms->topic.topic_name); in mqtt_sn_encode_msg_subscribe()344 msgsz += params->topic.topic_name.size; in mqtt_sn_encode_msg_unsubscribe()359 net_buf_simple_add_data(buf, ¶ms->topic.topic_name); in mqtt_sn_encode_msg_unsubscribe()
463 .topic.topic_name = MQTT_SN_DATA_STRING_LITERAL("/zephyr")