/Zephyr-latest/tests/net/socket/tls/src/ |
D | main.c | 194 recved = zsock_recv(sock, rx_buf, sizeof(rx_buf), ZSOCK_MSG_DONTWAIT); in test_eof() 199 recved = zsock_recv(sock, rx_buf, sizeof(rx_buf), ZSOCK_MSG_DONTWAIT); in test_eof() 562 rv = zsock_recv(s_sock, rx_buf, sizeof(rx_buf), ZSOCK_MSG_DONTWAIT); in test_msg_trunc() 1097 ret = zsock_recv(new_sock, rx_buf, sizeof(rx_buf), ZSOCK_MSG_DONTWAIT); in ZTEST() 1194 ZSOCK_MSG_DONTWAIT); in ZTEST() 1221 ret = zsock_recv(new_sock, rx_buf, sizeof(rx_buf), ZSOCK_MSG_DONTWAIT); in ZTEST() 1299 ret = zsock_recv(new_sock, rx_buf, sizeof(rx_buf), ZSOCK_MSG_DONTWAIT); in ZTEST() 1567 ret = zsock_recv(new_sock, rx_buf, sizeof(rx_buf), ZSOCK_MSG_DONTWAIT); in ZTEST() 1603 ret = zsock_recv(s_sock, rx_buf, sizeof(rx_buf), ZSOCK_MSG_DONTWAIT); in ZTEST() 1648 ret = zsock_recv(new_sock, rx_buf, sizeof(rx_buf), ZSOCK_MSG_DONTWAIT); in ZTEST() [all …]
|
/Zephyr-latest/include/zephyr/posix/sys/ |
D | socket.h | 18 #define MSG_DONTWAIT ZSOCK_MSG_DONTWAIT
|
/Zephyr-latest/subsys/net/lib/sockets/ |
D | sockets_packet.c | 249 if ((flags & ZSOCK_MSG_DONTWAIT) || sock_is_nonblock(ctx)) { in zpacket_sendto_ctx() 282 if ((flags & ZSOCK_MSG_DONTWAIT) || sock_is_nonblock(ctx)) { in zpacket_sendmsg_ctx() 305 if ((flags & ZSOCK_MSG_DONTWAIT) || sock_is_nonblock(ctx)) { in zpacket_recvfrom_ctx()
|
D | sockets_can.c | 241 if ((flags & ZSOCK_MSG_DONTWAIT) || sock_is_nonblock(ctx)) { in zcan_sendto_ctx() 285 if ((flags & ZSOCK_MSG_DONTWAIT) || sock_is_nonblock(ctx)) { in zcan_recvfrom_ctx()
|
D | sockets_net_mgmt.c | 156 if (flags & ZSOCK_MSG_DONTWAIT) { in znet_mgmt_recvfrom()
|
D | sockets_tls.c | 802 return !((flags & ZSOCK_MSG_DONTWAIT) || (sock_flags & O_NONBLOCK)); in is_blocking() 858 sent = zsock_sendto(tls_ctx->sock, buf, len, ZSOCK_MSG_DONTWAIT, in dtls_tx() 881 ZSOCK_MSG_DONTWAIT, &addr, &addrlen); in dtls_rx() 921 ZSOCK_MSG_DONTWAIT, NULL, 0); in tls_tx() 939 ZSOCK_MSG_DONTWAIT, NULL, 0); in tls_rx() 3096 ctx->flags = ZSOCK_MSG_DONTWAIT; in ztls_socket_data_check() 3308 ZSOCK_MSG_DONTWAIT); in poll_offload_dtls_client_retry()
|
D | sockets_inet.c | 605 if ((flags & ZSOCK_MSG_DONTWAIT) || sock_is_nonblock(ctx)) { in zsock_sendto_ctx() 661 if ((flags & ZSOCK_MSG_DONTWAIT) || sock_is_nonblock(ctx)) { in zsock_sendmsg_ctx() 1064 if ((flags & ZSOCK_MSG_DONTWAIT) || sock_is_nonblock(ctx)) { in zsock_recv_dgram() 1429 if ((flags & ZSOCK_MSG_DONTWAIT) || sock_is_nonblock(ctx)) { in zsock_recv_stream()
|
/Zephyr-latest/tests/net/socket/reuseaddr_reuseport/src/ |
D | main.c | 791 test_recvfrom_success(server_sock, &rx_buf, sizeof(rx_buf), ZSOCK_MSG_DONTWAIT, in test_reuseport_udp_server_client_common() 828 test_recvfrom_fail(server_sock, &rx_buf, sizeof(rx_buf), ZSOCK_MSG_DONTWAIT, in test_reuseport_udp_server_client_common() 832 test_recv_success(accept_sock, &rx_buf, sizeof(rx_buf), ZSOCK_MSG_DONTWAIT); in test_reuseport_udp_server_client_common() 836 test_recvfrom_success(server_sock, &rx_buf, sizeof(rx_buf), ZSOCK_MSG_DONTWAIT, in test_reuseport_udp_server_client_common() 840 test_recv_fail(accept_sock, &rx_buf, sizeof(rx_buf), ZSOCK_MSG_DONTWAIT); in test_reuseport_udp_server_client_common()
|
/Zephyr-latest/subsys/net/lib/mqtt/ |
D | mqtt_transport_socket_tcp.c | 132 flags |= ZSOCK_MSG_DONTWAIT; in mqtt_client_tcp_read()
|
D | mqtt_transport_socket_tls.c | 188 flags |= ZSOCK_MSG_DONTWAIT; in mqtt_client_tls_read()
|
/Zephyr-latest/subsys/logging/backends/ |
D | log_backend_ws.c | 45 ret = zsock_send(sock, output, len, ZSOCK_MSG_DONTWAIT); in ws_send_all()
|
D | log_backend_net.c | 79 ret = zsock_sendmsg(ctx->sock, &msg, ctx->is_tcp ? 0 : ZSOCK_MSG_DONTWAIT); in line_out()
|
/Zephyr-latest/subsys/net/lib/websocket/ |
D | websocket.c | 647 K_TIMEOUT_EQ(tout, K_NO_WAIT) ? ZSOCK_MSG_DONTWAIT : 0, in websocket_prepare_and_send() 998 ctx->recv_buf.size, ZSOCK_MSG_DONTWAIT); in websocket_recv_msg() 1137 if (flags & ZSOCK_MSG_DONTWAIT) { in websocket_sendto_ctx() 1154 if (flags & ZSOCK_MSG_DONTWAIT) { in websocket_recvfrom_ctx()
|
/Zephyr-latest/include/zephyr/net/ |
D | socket.h | 76 #define ZSOCK_MSG_DONTWAIT 0x40 macro
|
/Zephyr-latest/subsys/net/lib/ptp/ |
D | transport.c | 305 cnt = zsock_recvmsg(port->socket[idx], &msghdr, ZSOCK_MSG_DONTWAIT); in ptp_transport_recv()
|
/Zephyr-latest/subsys/net/lib/zperf/ |
D | zperf_udp_uploader.c | 130 ret = zsock_recv(sock, stats, sizeof(stats), ZSOCK_MSG_DONTWAIT); in zperf_upload_fin()
|
/Zephyr-latest/subsys/shell/backends/ |
D | shell_websocket.c | 70 block ? 0 : ZSOCK_MSG_DONTWAIT); in ws_send()
|
D | shell_telnet.c | 200 block ? 0 : ZSOCK_MSG_DONTWAIT); in telnet_send()
|
/Zephyr-latest/subsys/mgmt/updatehub/ |
D | updatehub.c | 428 rcvd = zsock_recv(ctx.sock, data, MAX_DOWNLOAD_DATA, ZSOCK_MSG_DONTWAIT); in install_update_cb() 696 rcvd = zsock_recv(ctx.sock, tmp, MAX_DOWNLOAD_DATA, ZSOCK_MSG_DONTWAIT); in probe_cb()
|
/Zephyr-latest/tests/net/socket/tcp/src/ |
D | main.c | 1390 rv = zsock_send(c_sock, tx_buf, sizeof(tx_buf), ZSOCK_MSG_DONTWAIT); in ZTEST() 1399 rv = zsock_send(c_sock, tx_buf, 1, ZSOCK_MSG_DONTWAIT); in ZTEST() 1482 rv = zsock_send(c_sock, tx_buf, sizeof(tx_buf), ZSOCK_MSG_DONTWAIT); in ZTEST() 1486 rv = zsock_send(c_sock, tx_buf, 1, ZSOCK_MSG_DONTWAIT); in ZTEST() 1671 rv = zsock_send(c_sock, tx_buf, sizeof(tx_buf), ZSOCK_MSG_DONTWAIT); in ZTEST() 1732 rv = zsock_send(c_sock, tx_buf, sizeof(tx_buf), ZSOCK_MSG_DONTWAIT); in ZTEST()
|
/Zephyr-latest/tests/net/socket/misc/src/ |
D | main.c | 246 ret = zsock_recv(sock_s, recv_buf, sizeof(recv_buf), ZSOCK_MSG_DONTWAIT); in test_so_bindtodevice() 283 ret = zsock_recv(sock_s, recv_buf, sizeof(recv_buf), ZSOCK_MSG_DONTWAIT); in test_so_bindtodevice()
|
/Zephyr-latest/drivers/wifi/eswifi/ |
D | eswifi_socket_offload.c | 348 if (flags & ZSOCK_MSG_DONTWAIT) { in eswifi_socket_recv()
|
/Zephyr-latest/drivers/net/ |
D | nsos_sockets.c | 152 nsos_socket_flag_convert(&flags, ZSOCK_MSG_DONTWAIT, in socket_flags_to_nsos_mid() 613 if (flags & ZSOCK_MSG_DONTWAIT) { in nsos_poll_if_blocking()
|
/Zephyr-latest/subsys/net/lib/coap/ |
D | coap_server.c | 139 received = zsock_recvfrom(sock_fd, buf, sizeof(buf), ZSOCK_MSG_DONTWAIT, &client_addr, in coap_server_process()
|
/Zephyr-latest/tests/net/lib/mqtt/v3_1_1/mqtt_client/src/ |
D | main.c | 334 ZSOCK_MSG_DONTWAIT); in broker_receive()
|