Lines Matching refs:msg_id

26 	uint16_t msg_id;  member
96 static uint16_t msg_id; in next_msg_id() local
98 return ++msg_id; in next_msg_id()
154 con->msg_id = next_msg_id(); in mqtt_sn_con_init()
201 uint16_t msg_id) in mqtt_sn_publish_find_msg_id() argument
206 if (pub->con.msg_id == msg_id) { in mqtt_sn_publish_find_msg_id()
273 uint16_t msg_id) in mqtt_sn_topic_find_msg_id() argument
278 if (topic->con.msg_id == msg_id) { in mqtt_sn_topic_find_msg_id()
292 LOG_WRN("Destroying publish msg_id %d", pub->con.msg_id); in mqtt_sn_topic_destroy()
309 LOG_WRN("Destroying publish msg_id %d", pub->con.msg_id); in mqtt_sn_topic_destroy_all()
420 p.params.subscribe.msg_id = topic->con.msg_id; in mqtt_sn_do_subscribe()
454 p.params.unsubscribe.msg_id = topic->con.msg_id; in mqtt_sn_do_unsubscribe()
486 p.params.reg.msg_id = topic->con.msg_id; in mqtt_sn_do_register()
518 p.params.publish.msg_id = pub->con.msg_id; in mqtt_sn_do_publish()
1258 response.params.regack.msg_id = p->msg_id; in handle_register()
1265 struct mqtt_sn_topic *topic = mqtt_sn_topic_find_msg_id(client, p->msg_id); in handle_regack()
1292 response.params.puback.msg_id = p->msg_id; in handle_publish()
1298 response.params.pubrec.msg_id = p->msg_id; in handle_publish()
1310 struct mqtt_sn_publish *pub = mqtt_sn_publish_find_msg_id(client, p->msg_id); in handle_puback()
1313 LOG_ERR("No matching PUBLISH found for msg id %u", p->msg_id); in handle_puback()
1323 struct mqtt_sn_publish *pub = mqtt_sn_publish_find_msg_id(client, p->msg_id); in handle_pubrec()
1326 LOG_ERR("No matching PUBLISH found for msg id %u", p->msg_id); in handle_pubrec()
1333 response.params.pubrel.msg_id = p->msg_id; in handle_pubrec()
1342 response.params.pubcomp.msg_id = p->msg_id; in handle_pubrel()
1349 struct mqtt_sn_publish *pub = mqtt_sn_publish_find_msg_id(client, p->msg_id); in handle_pubcomp()
1352 LOG_ERR("No matching PUBLISH found for msg id %u", p->msg_id); in handle_pubcomp()
1361 struct mqtt_sn_topic *topic = mqtt_sn_topic_find_msg_id(client, p->msg_id); in handle_suback()
1364 LOG_ERR("No matching SUBSCRIBE found for msg id %u", p->msg_id); in handle_suback()
1379 struct mqtt_sn_topic *topic = mqtt_sn_topic_find_msg_id(client, p->msg_id); in handle_unsuback()
1382 LOG_ERR("No matching UNSUBSCRIBE found for msg id %u", p->msg_id); in handle_unsuback()