| /Zephyr-latest/subsys/net/lib/mqtt_sn/ |
| D | mqtt_sn_msg.h | 101 uint16_t msg_id; member
107 uint16_t msg_id; member
118 uint16_t msg_id; member
123 uint16_t msg_id; member
129 uint16_t msg_id; member
133 uint16_t msg_id; member
137 uint16_t msg_id; member
144 uint16_t msg_id; member
154 uint16_t msg_id; member
160 uint16_t msg_id; member
[all …]
|
| D | mqtt_sn.c | 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()
[all …]
|
| D | mqtt_sn_decoder.c | 170 params->msg_id = net_buf_simple_pull_be16(buf); in decode_msg_register()
183 params->msg_id = net_buf_simple_pull_be16(buf); in decode_msg_regack()
203 params->msg_id = net_buf_simple_pull_be16(buf); in decode_msg_publish()
216 params->msg_id = net_buf_simple_pull_be16(buf); in decode_msg_puback()
228 params->msg_id = net_buf_simple_pull_be16(buf); in decode_msg_pubrec()
239 params->msg_id = net_buf_simple_pull_be16(buf); in decode_msg_pubrel()
250 params->msg_id = net_buf_simple_pull_be16(buf); in decode_msg_pubcomp()
268 params->msg_id = net_buf_simple_pull_be16(buf); in decode_msg_suback()
280 params->msg_id = net_buf_simple_pull_be16(buf); in decode_msg_unsuback()
|
| D | mqtt_sn_encoder.c | 184 net_buf_simple_add_be16(buf, params->msg_id); in mqtt_sn_encode_msg_register()
202 net_buf_simple_add_be16(buf, params->msg_id); in mqtt_sn_encode_msg_regack()
227 net_buf_simple_add_be16(buf, params->msg_id); in mqtt_sn_encode_msg_publish()
250 net_buf_simple_add_be16(buf, params->msg_id); in mqtt_sn_encode_msg_puback()
267 net_buf_simple_add_be16(buf, params->msg_id); in mqtt_sn_encode_msg_pubrec()
283 net_buf_simple_add_be16(buf, params->msg_id); in mqtt_sn_encode_msg_pubrel()
299 net_buf_simple_add_be16(buf, params->msg_id); in mqtt_sn_encode_msg_pubcomp()
325 net_buf_simple_add_be16(buf, params->msg_id); in mqtt_sn_encode_msg_subscribe()
356 net_buf_simple_add_be16(buf, params->msg_id); in mqtt_sn_encode_msg_unsubscribe()
|
| /Zephyr-latest/drivers/gnss/gnss_u_blox_protocol/ |
| D | gnss_u_blox_protocol.c | 21 static inline int ubx_validate_payload_size_ack(uint8_t msg_id, uint16_t payload_size) in ubx_validate_payload_size_ack() argument
23 switch (msg_id) { in ubx_validate_payload_size_ack()
33 static inline int ubx_validate_payload_size_cfg(uint8_t msg_id, uint16_t payload_size) in ubx_validate_payload_size_cfg() argument
35 switch (msg_id) { in ubx_validate_payload_size_cfg()
55 static inline int ubx_validate_payload_size(uint8_t msg_cls, uint8_t msg_id, uint16_t payload_size) in ubx_validate_payload_size() argument
67 return ubx_validate_payload_size_ack(msg_id, payload_size); in ubx_validate_payload_size()
69 return ubx_validate_payload_size_cfg(msg_id, payload_size); in ubx_validate_payload_size()
76 uint8_t msg_id, const void *payload, uint16_t payload_size) in ubx_create_and_validate_frame() argument
78 if (ubx_validate_payload_size(msg_cls, msg_id, payload_size)) { in ubx_create_and_validate_frame()
82 return modem_ubx_create_frame(ubx_frame, ubx_frame_size, msg_cls, msg_id, payload, in ubx_create_and_validate_frame()
|
| D | gnss_u_blox_protocol.h | 47 uint8_t msg_id, const void *payload, uint16_t payload_size);
|
| /Zephyr-latest/tests/net/lib/mqtt_sn_packet/src/ |
| D | mqtt_sn_packet.c | 159 .msg_id = 0x1C1D,
173 .msg_id = 0x1C1D,
188 .msg_id = 0x1C1D,
202 .msg_id = 0x1C1D,
212 .msg_id = 0xBEEF,
221 .msg_id = 0xBEEF,
230 .msg_id = 0xBEEF,
240 .msg_id = 0x1909,
251 .msg_id = 0x1337,
384 .msg_id = 0x1C1D,
[all …]
|
| /Zephyr-latest/tests/net/lib/mqtt/v3_1_1/mqtt_client/src/ |
| D | main.c | 43 uint16_t msg_id; member
260 zassert_equal(message_id, test_ctx.msg_id, in broker_validate_packet()
500 zassert_equal(evt->param.puback.message_id, test_ctx.msg_id, in mqtt_evt_handler()
512 zassert_equal(evt->param.pubrec.message_id, test_ctx.msg_id, in mqtt_evt_handler()
523 zassert_equal(evt->param.pubcomp.message_id, test_ctx.msg_id, in mqtt_evt_handler()
531 zassert_equal(evt->param.suback.message_id, test_ctx.msg_id, in mqtt_evt_handler()
539 zassert_equal(evt->param.unsuback.message_id, test_ctx.msg_id, in mqtt_evt_handler()
610 while (test_ctx.msg_id == 0) { in test_publish()
611 test_ctx.msg_id = sys_rand16_get(); in test_publish()
620 param.message_id = test_ctx.msg_id; in test_publish()
[all …]
|
| /Zephyr-latest/subsys/modem/ |
| D | modem_ubx.c | 15 static int modem_ubx_validate_frame_size(uint16_t ubx_frame_size, uint8_t msg_cls, uint8_t msg_id, in modem_ubx_validate_frame_size() argument
28 uint8_t msg_id, const void *payload, uint16_t payload_size) in modem_ubx_create_frame() argument
30 if (modem_ubx_validate_frame_size(ubx_frame_size, msg_cls, msg_id, payload_size)) { in modem_ubx_create_frame()
39 frame->message_id = msg_id; in modem_ubx_create_frame()
|
| /Zephyr-latest/subsys/usb/usb_c/ |
| D | usbc_prl.h | 32 int msg_id[NUM_SOP_STAR_TYPES]; member
|
| D | usbc_prl.c | 565 prl_rx->msg_id[i] = -1; in prl_init()
697 prl_rx->msg_id[prl_tx->emsg.type] = -1; in prl_tx_layer_reset_for_transmit_entry()
1021 prl_rx->msg_id[i] = -1; in prl_hr_reset_layer_entry()
1215 prl_rx->msg_id[pkt_type] = -1; in prl_rx_wait_for_phy_message()
1233 if (prl_rx->msg_id[pkt_type] == msid) { in prl_rx_wait_for_phy_message()
1254 prl_rx->msg_id[pkt_type] = msid; in prl_rx_wait_for_phy_message()
|
| /Zephyr-latest/include/zephyr/modem/ |
| D | ubx.h | 166 uint8_t msg_id, const void *payload, uint16_t payload_size);
|
| /Zephyr-latest/samples/net/secure_mqtt_sensor_actuator/src/ |
| D | mqtt_client.c | 296 static uint16_t msg_id = 1; in app_mqtt_publish() local
313 param.message_id = msg_id++; in app_mqtt_publish()
|
| /Zephyr-latest/drivers/gnss/ |
| D | gnss_u_blox_m8.c | 243 enum ubx_msg_class msg_cls, enum ubx_config_message msg_id) in ubx_m8_modem_ubx_script_init() argument
249 .message_id = msg_id, in ubx_m8_modem_ubx_script_init()
261 msg_id, payload, payld_sz); in ubx_m8_modem_ubx_script_init()
|
