Home
last modified time | relevance | path

Searched refs:message_id (Results 1 – 25 of 29) sorted by relevance

12

/Zephyr-latest/tests/subsys/portability/cmsis_rtos_v2/src/
Dmsgq.c23 osMessageQueueId_t message_id; variable
37 status = osMessageQueuePut(message_id, &sample, 0, osWaitForever); in send_msg_thread()
41 zassert_equal(osMessageQueueGetCount(message_id), 0, in send_msg_thread()
43 zassert_equal(osMessageQueueGetSpace(message_id), Q_LEN, in send_msg_thread()
51 status = osMessageQueuePut(message_id, data + i, in send_msg_thread()
58 zassert_equal(osMessageQueueGetCount(message_id), Q_LEN, in send_msg_thread()
60 zassert_equal(osMessageQueueGetSpace(message_id), 0, in send_msg_thread()
67 status = osMessageQueuePut(message_id, &sample, 0, 0); in send_msg_thread()
75 status = osMessageQueuePut(message_id, &sample, 0, TIMEOUT_TICKS / 2); in send_msg_thread()
81 status = osMessageQueuePut(message_id, &sample, 0, TIMEOUT_TICKS * 2); in send_msg_thread()
[all …]
/Zephyr-latest/tests/subsys/portability/cmsis_rtos_v1/src/
Dmsgq.c18 osMessageQId message_id; variable
30 status = osMessagePut(message_id, data, osWaitForever); in send_msg_thread()
36 status = osMessagePut(message_id, data, osWaitForever); in send_msg_thread()
45 status = osMessagePut(message_id, data, 0); in send_msg_thread()
53 status = osMessagePut(message_id, data, TIMEOUT/2); in send_msg_thread()
59 status = osMessagePut(message_id, data, TIMEOUT*2); in send_msg_thread()
71 evt = osMessageGet(message_id, 0); in message_recv()
76 evt = osMessageGet(message_id, TIMEOUT); in message_recv()
81 evt = osMessageGet(message_id, osWaitForever); in message_recv()
92 evt = osMessageGet(message_id, osWaitForever); in message_recv()
[all …]
/Zephyr-latest/drivers/wifi/nrf_wifi/inc/
Dcoex_struct.h73 uint32_t message_id; member
88 uint32_t message_id; member
106 uint32_t message_id; member
125 uint32_t message_id; member
143 uint32_t message_id; member
163 uint32_t message_id; member
178 uint32_t message_id; member
/Zephyr-latest/samples/subsys/portability/cmsis_rtos_v2/timer_synchronization/src/
Dmain.c24 osMessageQueueId_t message_id; variable
44 status = osMessageQueueGet(message_id, (void *)&read_msg, in read_msg_callback()
57 status = osMessageQueuePut(message_id, &data, 0, osWaitForever); in send_msg_thread()
58 if (osMessageQueueGetCount(message_id) == 1 && status == osOK) { in send_msg_thread()
74 message_id = osMessageQueueNew(Q_LEN, sizeof(data), &mem_attrs); in main()
76 status = osMessageQueuePut(message_id, &data, 0, osWaitForever); in main()
78 if (osMessageQueueGetCount(message_id) == 1 && status == osOK) { in main()
/Zephyr-latest/samples/subsys/portability/cmsis_rtos_v1/timer_synchronization/src/
Dmain.c28 osMessageQId message_id; variable
35 evt = osMessageGet(message_id, 0); in read_msg_callback()
48 status = osMessagePut(message_id, data, osWaitForever); in send_msg_thread()
65 message_id = osMessageCreate(osMessageQ(messageq), NULL); in main()
/Zephyr-latest/samples/net/secure_mqtt_sensor_actuator/src/
Dmqtt_client.c174 LOG_INF("PUBACK packet ID: %u", evt->param.puback.message_id); in mqtt_event_handler()
183 LOG_INF("PUBREC packet ID: %u", evt->param.pubrec.message_id); in mqtt_event_handler()
186 .message_id = evt->param.pubrec.message_id in mqtt_event_handler()
198 LOG_INF("PUBREL packet ID: %u", evt->param.pubrel.message_id); in mqtt_event_handler()
201 .message_id = evt->param.pubrel.message_id in mqtt_event_handler()
213 LOG_INF("PUBCOMP packet ID: %u", evt->param.pubcomp.message_id); in mqtt_event_handler()
222 LOG_INF("SUBACK packet ID: %d", evt->param.suback.message_id); in mqtt_event_handler()
230 .message_id = p->message_id in mqtt_event_handler()
235 .message_id = p->message_id in mqtt_event_handler()
313 param.message_id = msg_id++; in app_mqtt_publish()
[all …]
/Zephyr-latest/include/zephyr/net/
Dmqtt.h211 uint16_t message_id; member
217 uint16_t message_id; member
223 uint16_t message_id; member
229 uint16_t message_id; member
235 uint16_t message_id; member
245 uint16_t message_id; member
256 uint16_t message_id; member
278 uint16_t message_id; member
/Zephyr-latest/tests/net/lib/mqtt/v3_1_1/mqtt_packet/src/
Dmqtt_packet.c371 .dup_flag = 0, .retain_flag = 0, .message_id = 0,
390 .dup_flag = 0, .retain_flag = 1, .message_id = 0,
409 .dup_flag = 0, .retain_flag = 1, .message_id = 1,
427 .dup_flag = 0, .retain_flag = 0, .message_id = 1,
453 .message_id = 1, .list_count = 1, .list = &topic_qos_0
467 .message_id = 1, .list_count = 1, .list = &topic_qos_1
481 .message_id = 1, .list_count = 1, .list = &topic_qos_2
495 .message_id = 1, .return_codes.len = 1,
510 .message_id = 1, .return_codes.len = 1,
525 .message_id = 1, .return_codes.len = 1,
[all …]
/Zephyr-latest/subsys/net/lib/mqtt/
Dmqtt_decoder.c258 err_code = unpack_uint16(buf, &param->message_id); in publish_decode()
281 return unpack_uint16(buf, &param->message_id); in publish_ack_decode()
286 return unpack_uint16(buf, &param->message_id); in publish_receive_decode()
291 return unpack_uint16(buf, &param->message_id); in publish_release_decode()
297 return unpack_uint16(buf, &param->message_id); in publish_complete_decode()
304 err_code = unpack_uint16(buf, &param->message_id); in subscribe_ack_decode()
315 return unpack_uint16(buf, &param->message_id); in unsubscribe_ack_decode()
Dmqtt_encoder.c253 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()
[all …]
Dmqtt.c300 client, client->internal.state, param->message_id); in mqtt_publish_qos1_ack()
337 client, client->internal.state, param->message_id); in mqtt_publish_qos2_receive()
374 client, client->internal.state, param->message_id); in mqtt_publish_qos2_release()
411 client, client->internal.state, param->message_id); in mqtt_publish_qos2_complete()
486 param->message_id, param->list_count); in mqtt_subscribe()
/Zephyr-latest/tests/net/lib/mqtt/v3_1_1/mqtt_client/src/
Dmain.c255 uint16_t message_id; in broker_validate_packet() local
259 message_id = sys_get_be16(buf); in broker_validate_packet()
260 zassert_equal(message_id, test_ctx.msg_id, in broker_validate_packet()
480 .message_id = evt->param.publish.message_id, in mqtt_evt_handler()
489 .message_id = evt->param.publish.message_id, in mqtt_evt_handler()
500 zassert_equal(evt->param.puback.message_id, test_ctx.msg_id, in mqtt_evt_handler()
508 .message_id = evt->param.pubrec.message_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()
[all …]
/Zephyr-latest/samples/net/cloud/aws_iot_mqtt/src/
Dmain.c107 .message_id = 1u, in subscribe_topic()
123 static uint32_t message_id = 1u; in publish_message() local
135 msg.message_id = message_id++; in publish_message()
143 msg.message_id, msg.message.topic.qos, payload_len); in publish_message()
157 (const char *)pub->message.topic.topic.utf8, pub->message_id, in handle_published_message()
180 puback.message_id = pub->message_id; in handle_published_message()
/Zephyr-latest/samples/net/cloud/mqtt_azure/src/
Dmain.c208 LOG_INF("SUBACK packet id: %u", evt->param.suback.message_id); in mqtt_event_handler()
212 LOG_INF("UNSUBACK packet id: %u", evt->param.suback.message_id); in mqtt_event_handler()
238 LOG_DBG("PUBACK packet id: %u\n", evt->param.puback.message_id); in mqtt_event_handler()
245 LOG_INF(" id: %d, qos: %d", evt->param.publish.message_id, in mqtt_event_handler()
263 puback.message_id = evt->param.publish.message_id; in mqtt_event_handler()
282 subs_list.message_id = 1U; in subscribe()
302 param.message_id = sys_rand16_get(); in publish()
/Zephyr-latest/drivers/wifi/nrf_wifi/src/
Dcoex.c153 params.message_id = HW_CONFIGURATION; in nrf_wifi_coex_config_non_pta()
212 params.message_id = HW_CONFIGURATION; in nrf_wifi_coex_config_pta()
269 params.message_id = HW_CONFIGURATION; in nrf_wifi_coex_hw_reset()
/Zephyr-latest/samples/net/mqtt_publisher/src/
Dmain.c174 LOG_INF("PUBACK packet id: %u", evt->param.puback.message_id); in mqtt_evt_handler()
184 LOG_INF("PUBREC packet id: %u", evt->param.pubrec.message_id); in mqtt_evt_handler()
187 .message_id = evt->param.pubrec.message_id in mqtt_evt_handler()
204 evt->param.pubcomp.message_id); in mqtt_evt_handler()
254 param.message_id = sys_rand16_get(); in publish()
/Zephyr-latest/subsys/shell/backends/
Dshell_mqtt.c306 .message_id = 1U }; in sh_mqtt_subscribe_handler()
448 sh_mqtt->pub_data.message_id++; in sh_mqtt_publish()
555 LOG_DBG("UNSUBACK packet id: %u", evt->param.suback.message_id); in mqtt_evt_handler()
574 LOG_DBG(" id: %d, qos: %d", pub->message_id, pub->message.topic.qos); in mqtt_evt_handler()
579 struct mqtt_puback_param puback = { .message_id = pub->message_id }; in mqtt_evt_handler()
631 LOG_DBG("PUBACK packet id: %u", evt->param.puback.message_id); in mqtt_evt_handler()
/Zephyr-latest/drivers/gnss/gnss_u_blox_protocol/
Dgnss_u_blox_protocol.c89 payload->message_id = UBX_CFG_PRT; in ubx_cfg_ack_payload_default()
178 payload->message_id = UBX_NMEA_GGA; in ubx_cfg_msg_payload_default()
Dgnss_u_blox_protocol.h51 uint8_t message_id; member
245 uint8_t message_id; member
/Zephyr-latest/subsys/modem/
Dmodem_ubx.c39 frame->message_id = msg_id; in modem_ubx_create_frame()
88 && frame_1->message_id == frame_2->message_id) { in modem_ubx_match_frame_type()
/Zephyr-latest/include/zephyr/modem/
Dubx.h52 uint8_t message_id; member
/Zephyr-latest/subsys/portability/cmsis_rtos_v1/
Dcmsis_msgq.c91 evt.def.message_id = queue_id; in osMessageGet()
/Zephyr-latest/drivers/gnss/
Dgnss_nmea0183.c33 const char *message_id; member
49 switch (args->message_id[2]) { in gnss_system_from_gsv_header_args()
/Zephyr-latest/drivers/usb_c/tcpc/
Ducpd_stm32.c720 data->msg_id_match = hdr.message_id; in ucpd_manage_tx()
965 tx_header.message_id = rx_header.message_id; in ucpd_send_good_crc()
1229 data->ucpd_crc_id = rx_header.message_id; in ucpd_isr()
/Zephyr-latest/include/zephyr/drivers/usb_c/
Dusbc_pd.h331 uint16_t message_id : 3; member

12