| /Zephyr-Core-3.7.0/kernel/ |
| D | msg_q.c | 39 void k_msgq_init(struct k_msgq *msgq, char *buffer, size_t msg_size, in k_msgq_init() argument
42 msgq->msg_size = msg_size; in k_msgq_init()
45 msgq->buffer_end = buffer + (max_msgs * msg_size); in k_msgq_init()
65 int z_impl_k_msgq_alloc_init(struct k_msgq *msgq, size_t msg_size, in z_impl_k_msgq_alloc_init() argument
74 if (size_mul_overflow(msg_size, max_msgs, &total_size)) { in z_impl_k_msgq_alloc_init()
79 k_msgq_init(msgq, buffer, msg_size, max_msgs); in z_impl_k_msgq_alloc_init()
93 int z_vrfy_k_msgq_alloc_init(struct k_msgq *msgq, size_t msg_size, in z_vrfy_k_msgq_alloc_init() argument
98 return z_impl_k_msgq_alloc_init(msgq, msg_size, max_msgs); in z_vrfy_k_msgq_alloc_init()
144 msgq->msg_size); in z_impl_k_msgq_put()
154 (void)memcpy(msgq->write_ptr, (char *)data, msgq->msg_size); in z_impl_k_msgq_put()
[all …]
|
| /Zephyr-Core-3.7.0/samples/subsys/zbus/remote_mock/ |
| D | remote_mock.py | 26 msg_size = channels[channel_id]['message_size']
27 msg = ser.read(msg_size)
29 return (channel_name, msg_size, msg)
47 channel_name, msg_size, msg = fetch_sentence(ser) variable
|
| /Zephyr-Core-3.7.0/subsys/net/lib/dns/ |
| D | dns_pack.c | 121 dns_msg->msg_size - dns_msg->answer_offset); in dns_unpack_answer()
137 rem_size = dns_msg->msg_size - dname_len; in dns_unpack_answer()
189 size = msg->msg_size; in dns_unpack_response_header()
275 uint16_t msg_size; in dns_msg_pack_query() local
279 msg_size = DNS_MSG_HEADER_SIZE + DNS_QTYPE_LEN + DNS_QCLASS_LEN; in dns_msg_pack_query()
280 if (msg_size + qname_len > size) { in dns_msg_pack_query()
329 remaining_size = dns_msg->msg_size - dns_msg->query_offset; in dns_unpack_response_query()
341 if (offset >= dns_msg->msg_size) { in dns_unpack_response_query()
364 uint16_t msg_size = dns_msg->msg_size; in dns_copy_qname() local
372 if (pos >= msg_size) { in dns_copy_qname()
[all …]
|
| D | dns_pack.h | 81 uint16_t msg_size; member
84 #define DNS_MSG_INIT(b, s) {.msg = b, .msg_size = s, \
|
| D | dispatcher.c | 43 dns_msg.msg_size = data_len; in dns_dispatch()
46 if (dns_msg.msg_size < (sizeof(uint16_t) + sizeof(uint16_t))) { in dns_dispatch()
|
| D | mdns_responder.c | 418 dns_msg->msg_size, &filter, label, size, &n); in send_sd_response()
520 dns_msg.msg_size = data_len; in dns_read()
|
| D | resolve.c | 664 if (dns_msg->msg_size < (sizeof(*dns_id) + sizeof(uint16_t))) { in dns_validate_msg()
805 dns_msg->msg_size) { in dns_validate_msg()
911 dns_msg.msg_size = data_len; in dns_read()
|
| /Zephyr-Core-3.7.0/drivers/ipm/ |
| D | ipm_sedi.c | 98 int msg_size) in ipm_send_isr() argument
105 (uint32_t)msg_size); in ipm_send_isr()
118 int msg_size) in ipm_sedi_send() argument
127 if ((msg_size > IPC_DATA_LEN_MAX) || ((msg_size > 0) && (msg == NULL)) || in ipm_sedi_send()
139 return ipm_send_isr(dev, drbl, msg, msg_size); in ipm_sedi_send()
152 if (msg_size > 0) { in ipm_sedi_send()
154 (uint32_t)msg_size); in ipm_sedi_send()
|
| /Zephyr-Core-3.7.0/subsys/portability/cmsis_rtos_v2/ |
| D | msgq.c | 26 osMessageQueueId_t osMessageQueueNew(uint32_t msg_count, uint32_t msg_size, in osMessageQueueNew() argument
39 if ((attr != NULL) && (attr->mq_size < msg_count * msg_size)) { in osMessageQueueNew()
54 __ASSERT((msg_count * msg_size) <= in osMessageQueueNew()
59 msgq->pool = k_calloc(msg_count, msg_size); in osMessageQueueNew()
74 k_msgq_init(&msgq->z_msgq, msgq->pool, msg_size, msg_count); in osMessageQueueNew()
188 return msgq->z_msgq.msg_size; in osMessageQueueGetMsgSize()
|
| /Zephyr-Core-3.7.0/lib/posix/options/ |
| D | mqueue.c | 60 long msg_size = 0U, max_msgs = 0U; in mq_open() local
74 msg_size = attrs->mq_msgsize; in mq_open()
78 if ((name == NULL) || ((oflags & O_CREAT) != 0 && (msg_size <= 0 || in mq_open()
146 mq_buf_ptr = k_malloc(msg_size * max_msgs * sizeof(uint8_t)); in mq_open()
149 msg_size * max_msgs * sizeof(uint8_t)); in mq_open()
157 k_msgq_init(&msg_queue->queue, msg_queue->mem_buffer, msg_size, in mq_open()
313 mqstat->mq_msgsize = attrs.msg_size; in mq_getattr()
451 if (msg_len > mqd->mqueue->queue.msg_size) { in send_message()
491 if (msg_len < mqd->mqueue->queue.msg_size) { in receive_message()
503 ret = mqd->mqueue->queue.msg_size; in receive_message()
|
| /Zephyr-Core-3.7.0/samples/subsys/llext/edk/app/src/ |
| D | pubsub.c | 159 size_t msg_size; in z_impl_receive() local
165 msg_size = channel_subscribers[channel].chan->message_size; in z_impl_receive()
166 if (data_len < msg_size) { in z_impl_receive()
|
| /Zephyr-Core-3.7.0/subsys/net/lib/dhcpv6/ |
| D | dhcpv6.c | 430 size_t msg_size = sizeof(struct dhcpv6_msg_hdr); in dhcpv6_calculate_message_size() local
434 msg_size += DHCPV6_OPTION_HEADER_SIZE; in dhcpv6_calculate_message_size()
435 msg_size += sizeof(struct net_dhcpv6_duid_storage); in dhcpv6_calculate_message_size()
439 msg_size += DHCPV6_OPTION_HEADER_SIZE; in dhcpv6_calculate_message_size()
440 msg_size += sizeof(struct net_dhcpv6_duid_storage); in dhcpv6_calculate_message_size()
444 msg_size += DHCPV6_OPTION_HEADER_SIZE; in dhcpv6_calculate_message_size()
445 msg_size += DHCPV6_OPTION_ELAPSED_TIME_SIZE; in dhcpv6_calculate_message_size()
449 msg_size += DHCPV6_OPTION_HEADER_SIZE; in dhcpv6_calculate_message_size()
450 msg_size += DHCPV6_OPTION_IA_NA_HEADER_SIZE; in dhcpv6_calculate_message_size()
454 msg_size += DHCPV6_OPTION_HEADER_SIZE; in dhcpv6_calculate_message_size()
[all …]
|
| /Zephyr-Core-3.7.0/samples/subsys/zbus/hello_world/src/ |
| D | main.c | 44 static bool simple_chan_validator(const void *msg, size_t msg_size) in simple_chan_validator() argument
46 ARG_UNUSED(msg_size); in simple_chan_validator()
|
| /Zephyr-Core-3.7.0/samples/subsys/zbus/uart_bridge/ |
| D | decoder.py | 43 channel_name, msg_size, msg = fetch_sentence() variable
|
| /Zephyr-Core-3.7.0/tests/net/lib/dns_packet/src/ |
| D | main.c | 345 msg.msg_size = resp->res_len; in eval_response1()
1092 dns_msg.msg_size = len; in run_dns_malformed_response()
1116 dns_msg.msg_size = len; in run_dns_valid_response()
1157 dns_msg.msg_size = len; in run_dns_valid_cname_response()
1219 dns_msg.msg_size = sizeof(buf); in ZTEST()
1237 dns_msg.msg_size = sizeof(buf); in ZTEST()
|
| /Zephyr-Core-3.7.0/samples/subsys/zbus/benchmark/ |
| D | benchmark_256KB.robot | 23 FOR ${msg_size} IN 2 8 32 128 512
25 ... message_size=${msg_size}
|
| /Zephyr-Core-3.7.0/subsys/logging/backends/ |
| D | log_multidomain_backend.c | 103 size_t msg_size = slen + 1 + msg_offset + in get_name_response() local
106 uint8_t msg_buf[msg_size]; in get_name_response()
126 err = backend_remote->transport_api->send(backend_remote, outmsg, msg_size); in get_name_response()
|
| /Zephyr-Core-3.7.0/subsys/net/lib/ptp/ |
| D | msg.c | 359 static const int msg_size[] = { in ptp_msg_post_recv() local
375 if (msg_size[type] > cnt) { in ptp_msg_post_recv()
429 tlv_len = msg_tlv_post_recv(msg, cnt - msg_size[type]); in ptp_msg_post_recv()
435 if (msg_size[type] + tlv_len != msg->header.msg_length) { in ptp_msg_post_recv()
|
| /Zephyr-Core-3.7.0/subsys/logging/ |
| D | log_multidomain_link.c | 93 struct log_multidomain_msg *msg, size_t msg_size) in getter_msg_process() argument
97 err = link_remote->transport_api->send(link_remote, msg, msg_size); in getter_msg_process()
|
| /Zephyr-Core-3.7.0/include/zephyr/ |
| D | kernel.h | 4509 size_t msg_size; member
4542 .msg_size = q_msg_size, \
4564 size_t msg_size; member
4611 void k_msgq_init(struct k_msgq *msgq, char *buffer, size_t msg_size,
4633 __syscall int k_msgq_alloc_init(struct k_msgq *msgq, size_t msg_size,
|
| /Zephyr-Core-3.7.0/subsys/tracing/test/ |
| D | tracing_test.h | 296 sys_trace_k_msgq_alloc_init_enter(msgq, msg_size, max_msgs)
299 sys_trace_k_msgq_alloc_init_exit(msgq, msg_size, max_msgs, ret)
643 void sys_trace_k_msgq_alloc_init_enter(struct k_msgq *msgq, size_t msg_size, uint32_t max_msgs);
644 void sys_trace_k_msgq_alloc_init_exit(struct k_msgq *msgq, size_t msg_size, uint32_t max_msgs,
|
| /Zephyr-Core-3.7.0/include/zephyr/portability/ |
| D | cmsis_os2.h | 695 osMessageQueueId_t osMessageQueueNew(uint32_t msg_count, uint32_t msg_size, const osMessageQueueAtt…
|
| /Zephyr-Core-3.7.0/tests/subsys/zbus/unittests/src/ |
| D | main.c | 15 static bool hard_msg_validator(const void *msg, size_t msg_size) in hard_msg_validator() argument
17 ARG_UNUSED(msg_size); in hard_msg_validator()
|
| /Zephyr-Core-3.7.0/include/zephyr/zbus/ |
| D | zbus.h | 95 bool (*const validator)(const void *msg, size_t msg_size);
|
| /Zephyr-Core-3.7.0/subsys/tracing/sysview/ |
| D | SYSVIEW_Zephyr.txt | 64 59 k_msgq_init msgq=%I, buffer=%p, msg_size=%u, max_msgs=%us
|
