Lines Matching refs:topic_name
258 struct mqtt_sn_data *topic_name) in mqtt_sn_topic_find_name() argument
263 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() argument
998 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()
1009 topic = mqtt_sn_topic_create(topic_name); in mqtt_sn_subscribe()
1028 struct mqtt_sn_data *topic_name) in mqtt_sn_unsubscribe() argument
1033 if (!client || !topic_name) { in mqtt_sn_unsubscribe()
1042 topic = mqtt_sn_topic_find_name(client, topic_name); in mqtt_sn_unsubscribe()
1044 LOG_HEXDUMP_ERR(topic_name->data, topic_name->size, "Topic not found"); in mqtt_sn_unsubscribe()
1060 struct mqtt_sn_data *topic_name, bool retain, struct mqtt_sn_data *data) in mqtt_sn_publish() argument
1066 if (!client || !topic_name) { in mqtt_sn_publish()
1080 topic = mqtt_sn_topic_find_name(client, topic_name); in mqtt_sn_publish()
1082 topic = mqtt_sn_topic_create(topic_name); in mqtt_sn_publish()
1543 struct mqtt_sn_data *topic_name) in mqtt_sn_get_topic_name() argument
1547 if (!client || !topic_name) { in mqtt_sn_get_topic_name()
1553 topic_name->data = (const uint8_t *)topic->name; in mqtt_sn_get_topic_name()
1554 topic_name->size = topic->namelen; in mqtt_sn_get_topic_name()