Home
last modified time | relevance | path

Searched refs:msg_iov (Results 1 – 25 of 30) sorted by relevance

12

/Zephyr-latest/subsys/net/lib/sockets/
Dsockets.c82 if (msg->msg_iov[i].iov_len) { in msghdr_non_empty_iov_count()
402 msg_copy.msg_iov = k_usermode_alloc_from_copy(msg->msg_iov, in z_vrfy_zsock_sendmsg()
404 if (!msg_copy.msg_iov) { in z_vrfy_zsock_sendmsg()
410 msg_copy.msg_iov[i].iov_base = in z_vrfy_zsock_sendmsg()
411 k_usermode_alloc_from_copy(msg->msg_iov[i].iov_base, in z_vrfy_zsock_sendmsg()
412 msg->msg_iov[i].iov_len); in z_vrfy_zsock_sendmsg()
413 if (!msg_copy.msg_iov[i].iov_base) { in z_vrfy_zsock_sendmsg()
418 msg_copy.msg_iov[i].iov_len = msg->msg_iov[i].iov_len; in z_vrfy_zsock_sendmsg()
446 k_free(msg_copy.msg_iov[i].iov_base); in z_vrfy_zsock_sendmsg()
449 k_free(msg_copy.msg_iov); in z_vrfy_zsock_sendmsg()
[all …]
Dsockets_inet.c1141 if (msg->msg_iovlen < 1 || msg->msg_iov == NULL) { in zsock_recv_dgram()
1152 buf = msg->msg_iov[iovec].iov_base; in zsock_recv_dgram()
1158 len = MIN(tmp_read_len, msg->msg_iov[iovec].iov_len); in zsock_recv_dgram()
1167 msg->msg_iov[iovec].iov_len = len; in zsock_recv_dgram()
1336 buf = msg->msg_iov[iovec].iov_base; in zsock_recv_stream_timed()
1337 available_len = msg->msg_iov[iovec].iov_len; in zsock_recv_stream_timed()
1338 msg->msg_iov[iovec].iov_len = 0; in zsock_recv_stream_timed()
1368 msg->msg_iov[iovec].iov_len += res; in zsock_recv_stream_timed()
1369 buf = (uint8_t *)(msg->msg_iov[iovec].iov_base) + res; in zsock_recv_stream_timed()
1381 buf = msg->msg_iov[iovec].iov_base; in zsock_recv_stream_timed()
[all …]
Dsocketpair.c1086 len += msg->msg_iov[i].iov_len; in spair_sendmsg()
1107 res = spair_write(spair, msg->msg_iov[i].iov_base, in spair_sendmsg()
1108 msg->msg_iov[i].iov_len); in spair_sendmsg()
/Zephyr-latest/subsys/net/lib/mqtt/
Dmqtt_transport_socket_tcp.c94 total_len += message->msg_iov[i].iov_len; in mqtt_client_tcp_write_msg()
110 if (ret < message->msg_iov[i].iov_len) { in mqtt_client_tcp_write_msg()
111 message->msg_iov[i].iov_len -= ret; in mqtt_client_tcp_write_msg()
112 message->msg_iov[i].iov_base = in mqtt_client_tcp_write_msg()
113 (uint8_t *)message->msg_iov[i].iov_base + ret; in mqtt_client_tcp_write_msg()
117 ret -= message->msg_iov[i].iov_len; in mqtt_client_tcp_write_msg()
118 message->msg_iov[i].iov_len = 0; in mqtt_client_tcp_write_msg()
Dmqtt_transport_socket_tls.c150 total_len += message->msg_iov[i].iov_len; in mqtt_client_tls_write_msg()
166 if (ret < message->msg_iov[i].iov_len) { in mqtt_client_tls_write_msg()
167 message->msg_iov[i].iov_len -= ret; in mqtt_client_tls_write_msg()
168 message->msg_iov[i].iov_base = in mqtt_client_tls_write_msg()
169 (uint8_t *)message->msg_iov[i].iov_base + ret; in mqtt_client_tls_write_msg()
173 ret -= message->msg_iov[i].iov_len; in mqtt_client_tls_write_msg()
174 message->msg_iov[i].iov_len = 0; in mqtt_client_tls_write_msg()
Dmqtt_transport_websocket.c126 message->msg_iov[i].iov_base, in mqtt_client_websocket_write_msg()
127 message->msg_iov[i].iov_len, opcode, in mqtt_client_websocket_write_msg()
Dmqtt.c276 msg.msg_iov = io_vector; in mqtt_publish()
/Zephyr-latest/tests/net/socket/websocket/src/
Dmain.c306 ret = test_recv_buf(msg->msg_iov[0].iov_base, in verify_sent_and_received_msg()
307 msg->msg_iov[0].iov_len, in verify_sent_and_received_msg()
318 split_len = msg->msg_iov[1].iov_len / 2; in verify_sent_and_received_msg()
320 ret = test_recv_buf(msg->msg_iov[1].iov_base, in verify_sent_and_received_msg()
331 ret = test_recv_buf((uint8_t *)msg->msg_iov[1].iov_base + in verify_sent_and_received_msg()
333 msg->msg_iov[1].iov_len - total_read, in verify_sent_and_received_msg()
354 msg->msg_iov[0].iov_len, total_read); in verify_sent_and_received_msg()
356 return msg->msg_iov[0].iov_len + total_read; in verify_sent_and_received_msg()
/Zephyr-latest/drivers/modem/
Dublox-sara-r4.c311 if (!msg->msg_iov[i].iov_base || msg->msg_iov[i].iov_len == 0) { in send_socket_data()
315 buf_len += msg->msg_iov[i].iov_len; in send_socket_data()
413 int len = MIN(buf_len, msg->msg_iov[i].iov_len); in send_socket_data()
418 mctx.iface.write(&mctx.iface, msg->msg_iov[i].iov_base, len); in send_socket_data()
1691 struct iovec msg_iov = { in offload_sendto() local
1699 .msg_iov = &msg_iov, in offload_sendto()
1769 if (!msg->msg_iov[i].iov_base || msg->msg_iov[i].iov_len == 0) { in offload_sendmsg()
1773 full_len += msg->msg_iov[i].iov_len; in offload_sendmsg()
1784 crafted_msg.msg_iov = &msg->msg_iov[0]; in offload_sendmsg()
1791 if (to_removed >= msg->msg_iov[i].iov_len) { in offload_sendmsg()
[all …]
Dquectel-bg9x.c822 const char *buf = msg->msg_iov[i].iov_base; in offload_sendmsg()
823 size_t len = msg->msg_iov[i].iov_len; in offload_sendmsg()
/Zephyr-latest/drivers/net/
Dnsos_adapt.c545 struct iovec *msg_iov; in nsos_adapt_sendmsg() local
554 msg_iov = calloc(msg_mid->msg_iovlen, sizeof(*msg_iov)); in nsos_adapt_sendmsg()
555 if (!msg_iov) { in nsos_adapt_sendmsg()
561 msg_iov[i].iov_base = msg_mid->msg_iov[i].iov_base; in nsos_adapt_sendmsg()
562 msg_iov[i].iov_len = msg_mid->msg_iov[i].iov_len; in nsos_adapt_sendmsg()
567 msg.msg_iov = msg_iov; in nsos_adapt_sendmsg()
578 free(msg_iov); in nsos_adapt_sendmsg()
Dnsos_sockets.c843 struct nsos_mid_iovec *msg_iov; in nsos_sendmsg() local
859 msg_iov = k_calloc(msg->msg_iovlen, sizeof(*msg_iov)); in nsos_sendmsg()
860 if (!msg_iov) { in nsos_sendmsg()
866 msg_iov[i].iov_base = msg->msg_iov[i].iov_base; in nsos_sendmsg()
867 msg_iov[i].iov_len = msg->msg_iov[i].iov_len; in nsos_sendmsg()
872 msg_mid.msg_iov = msg_iov; in nsos_sendmsg()
886 k_free(msg_iov); in nsos_sendmsg()
Dnsos.h123 struct nsos_mid_iovec *msg_iov; /* scatter/gather array */ member
/Zephyr-latest/tests/net/socket/udp/src/
Dmain.c382 len += client_msg->msg_iov[i].iov_len; in comm_sendmsg_recvfrom()
455 msg.msg_iov = io_vector; in ZTEST_USER()
507 msg.msg_iov = io_vector; in ZTEST_USER()
559 msg.msg_iov = io_vector; in ZTEST_USER()
622 msg.msg_iov = io_vector; in ZTEST_USER()
682 msg.msg_iov = io_vector; in ZTEST_USER()
920 len += client_msg->msg_iov[i].iov_len; in comm_sendmsg_with_txtime()
1083 msg.msg_iov = io_vector; in ZTEST_USER()
1437 msg.msg_iov = io_vector; in ZTEST_USER()
1490 len += client_msg->msg_iov[i].iov_len; in comm_sendmsg_recvmsg()
[all …]
/Zephyr-latest/subsys/net/lib/websocket/
Dwebsocket.c554 total_len += message->msg_iov[i].iov_len; in sendmsg_all()
588 if (ret < message->msg_iov[i].iov_len) { in sendmsg_all()
589 message->msg_iov[i].iov_len -= ret; in sendmsg_all()
590 message->msg_iov[i].iov_base = in sendmsg_all()
591 (uint8_t *)message->msg_iov[i].iov_base + ret; in sendmsg_all()
595 ret -= message->msg_iov[i].iov_len; in sendmsg_all()
596 message->msg_iov[i].iov_len = 0; in sendmsg_all()
619 msg.msg_iov = io_vector; in websocket_prepare_and_send()
/Zephyr-latest/tests/net/socket/tcp/src/
Dmain.c754 msg.msg_iov = io_vector; in ZTEST_USER()
771 msg.msg_iov = io_vector; in ZTEST_USER()
777 zassert_mem_equal(msg.msg_iov[0].iov_base, TEST_STR_SMALL, msg.msg_iov[0].iov_len, in ZTEST_USER()
779 zassert_mem_equal(msg.msg_iov[1].iov_base, &TEST_STR_SMALL[msg.msg_iov[0].iov_len], in ZTEST_USER()
780 msg.msg_iov[1].iov_len, in ZTEST_USER()
796 msg.msg_iov = io_vector; in ZTEST_USER()
802 len += msg.msg_iov[i].iov_len; in ZTEST_USER()
806 zassert_mem_equal(msg.msg_iov[0].iov_base, TEST_STR_LONG, msg.msg_iov[0].iov_len, in ZTEST_USER()
808 zassert_mem_equal(msg.msg_iov[1].iov_base, &TEST_STR_LONG[msg.msg_iov[0].iov_len], in ZTEST_USER()
809 msg.msg_iov[1].iov_len, in ZTEST_USER()
[all …]
/Zephyr-latest/drivers/can/
Dcan_native_linux_adapt.c125 msg.msg_iov = &iov; in linux_socketcan_read_data()
/Zephyr-latest/subsys/tracing/ctf/
Dctf_top.c460 for (int i = 0; msg->msg_iov != NULL && i < msg->msg_iovlen; i++) { in sys_trace_socket_sendmsg_enter()
461 len += msg->msg_iov[i].iov_len; in sys_trace_socket_sendmsg_enter()
508 for (int i = 0; msg->msg_iov != NULL && i < msg->msg_iovlen; i++) { in sys_trace_socket_recvmsg_enter()
509 max_len += msg->msg_iov[i].iov_len; in sys_trace_socket_recvmsg_enter()
520 for (int i = 0; msg->msg_iov != NULL && i < msg->msg_iovlen; i++) { in sys_trace_socket_recvmsg_exit()
521 len += msg->msg_iov[i].iov_len; in sys_trace_socket_recvmsg_exit()
/Zephyr-latest/tests/net/socket/socketpair/src/
Dhappy_path.c83 msghdr.msg_iov = &iovec; in happy_path()
/Zephyr-latest/tests/posix/headers/src/
Dsys_socket_h.c44 zassert_not_equal(-1, offsetof(struct msghdr, msg_iov)); in ZTEST()
/Zephyr-latest/tests/net/socket/tls/src/
Dmain.c133 struct iovec *vec = msg->msg_iov + i; in test_sendmsg()
625 msg.msg_iov = &iov[1]; in test_dtls_sendmsg_no_buf()
639 msg.msg_iov = iov; in test_dtls_sendmsg_no_buf()
713 msg.msg_iov = iov; in test_dtls_sendmsg()
731 msg.msg_iov = iov; in test_dtls_sendmsg()
750 msg.msg_iov = iov; in test_dtls_sendmsg()
773 msg.msg_iov = iov; in test_dtls_sendmsg()
/Zephyr-latest/subsys/logging/backends/
Dlog_backend_net.c76 msg.msg_iov = io_vector; in line_out()
/Zephyr-latest/subsys/net/lib/ptp/
Dtransport.c300 msghdr.msg_iov = &iov; in ptp_transport_recv()
/Zephyr-latest/samples/net/sockets/txtime/src/
Dmain.c179 msg.msg_iov = io_vector; in tx()
/Zephyr-latest/include/zephyr/net/
Dnet_ip.h260 struct iovec *msg_iov; /**< Scatter/gather array */ member

12