Lines Matching refs:message_id
253 static int mqtt_message_id_only_enc(uint8_t message_type, uint16_t message_id, in mqtt_message_id_only_enc() argument
260 if (message_id == 0U) { in mqtt_message_id_only_enc()
268 err_code = pack_uint16(message_id, buf); in mqtt_message_id_only_enc()
407 if ((param->message.topic.qos) && (param->message_id == 0U)) { in publish_encode()
421 err_code = pack_uint16(param->message_id, buf); in publish_encode()
448 return mqtt_message_id_only_enc(message_type, param->message_id, buf); in publish_ack_encode()
457 return mqtt_message_id_only_enc(message_type, param->message_id, buf); in publish_receive_encode()
466 return mqtt_message_id_only_enc(message_type, param->message_id, buf); in publish_release_encode()
475 return mqtt_message_id_only_enc(message_type, param->message_id, buf); in publish_complete_encode()
502 if (param->message_id == 0U) { in subscribe_encode()
510 err_code = pack_uint16(param->message_id, buf); in subscribe_encode()
542 err_code = pack_uint16(param->message_id, buf); in unsubscribe_encode()