Home
last modified time | relevance | path

Searched refs:ZSOCK_MSG_DONTWAIT (Results 1 – 25 of 32) sorted by relevance

12

/Zephyr-4.1.0/tests/net/socket/tls/src/
Dmain.c194 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-4.1.0/include/zephyr/posix/sys/
Dsocket.h18 #define MSG_DONTWAIT ZSOCK_MSG_DONTWAIT
/Zephyr-4.1.0/subsys/net/lib/sockets/
Dsockets_packet.c249 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()
Dsockets_can.c241 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()
Dsockets_net_mgmt.c156 if (flags & ZSOCK_MSG_DONTWAIT) { in znet_mgmt_recvfrom()
Dsockets_tls.c802 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()
Dsockets_inet.c610 if ((flags & ZSOCK_MSG_DONTWAIT) || sock_is_nonblock(ctx)) { in zsock_sendto_ctx()
666 if ((flags & ZSOCK_MSG_DONTWAIT) || sock_is_nonblock(ctx)) { in zsock_sendmsg_ctx()
1069 if ((flags & ZSOCK_MSG_DONTWAIT) || sock_is_nonblock(ctx)) { in zsock_recv_dgram()
1426 if ((flags & ZSOCK_MSG_DONTWAIT) || sock_is_nonblock(ctx)) { in zsock_recv_stream()
/Zephyr-4.1.0/tests/net/socket/reuseaddr_reuseport/src/
Dmain.c791 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-4.1.0/subsys/net/lib/mqtt/
Dmqtt_transport_socket_tcp.c132 flags |= ZSOCK_MSG_DONTWAIT; in mqtt_client_tcp_read()
Dmqtt_transport_socket_tls.c188 flags |= ZSOCK_MSG_DONTWAIT; in mqtt_client_tls_read()
/Zephyr-4.1.0/subsys/logging/backends/
Dlog_backend_ws.c40 ret = zsock_send(sock, output, len, ZSOCK_MSG_DONTWAIT); in ws_send_all()
Dlog_backend_net.c79 ret = zsock_sendmsg(ctx->sock, &msg, ctx->is_tcp ? 0 : ZSOCK_MSG_DONTWAIT); in line_out()
/Zephyr-4.1.0/subsys/net/lib/websocket/
Dwebsocket.c647 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-4.1.0/subsys/net/lib/ptp/
Dtransport.c305 cnt = zsock_recvmsg(port->socket[idx], &msghdr, ZSOCK_MSG_DONTWAIT); in ptp_transport_recv()
/Zephyr-4.1.0/subsys/shell/backends/
Dshell_websocket.c72 block ? 0 : ZSOCK_MSG_DONTWAIT); in ws_send()
Dshell_telnet.c200 block ? 0 : ZSOCK_MSG_DONTWAIT); in telnet_send()
/Zephyr-4.1.0/include/zephyr/net/
Dsocket.h76 #define ZSOCK_MSG_DONTWAIT 0x40 macro
/Zephyr-4.1.0/subsys/net/lib/zperf/
Dzperf_udp_uploader.c130 ret = zsock_recv(sock, stats, sizeof(stats), ZSOCK_MSG_DONTWAIT); in zperf_upload_fin()
/Zephyr-4.1.0/subsys/mgmt/updatehub/
Dupdatehub.c428 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-4.1.0/tests/net/socket/tcp/src/
Dmain.c1405 rv = zsock_send(c_sock, tx_buf, sizeof(tx_buf), ZSOCK_MSG_DONTWAIT); in ZTEST()
1414 rv = zsock_send(c_sock, tx_buf, 1, ZSOCK_MSG_DONTWAIT); in ZTEST()
1497 rv = zsock_send(c_sock, tx_buf, sizeof(tx_buf), ZSOCK_MSG_DONTWAIT); in ZTEST()
1501 rv = zsock_send(c_sock, tx_buf, 1, ZSOCK_MSG_DONTWAIT); in ZTEST()
1686 rv = zsock_send(c_sock, tx_buf, sizeof(tx_buf), ZSOCK_MSG_DONTWAIT); in ZTEST()
1747 rv = zsock_send(c_sock, tx_buf, sizeof(tx_buf), ZSOCK_MSG_DONTWAIT); in ZTEST()
/Zephyr-4.1.0/tests/net/socket/misc/src/
Dmain.c276 ret = zsock_recv(sock_s, recv_buf, sizeof(recv_buf), ZSOCK_MSG_DONTWAIT); in test_so_bindtodevice()
313 ret = zsock_recv(sock_s, recv_buf, sizeof(recv_buf), ZSOCK_MSG_DONTWAIT); in test_so_bindtodevice()
/Zephyr-4.1.0/drivers/wifi/eswifi/
Deswifi_socket_offload.c348 if (flags & ZSOCK_MSG_DONTWAIT) { in eswifi_socket_recv()
/Zephyr-4.1.0/drivers/net/
Dnsos_sockets.c152 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-4.1.0/tests/net/lib/mqtt/v3_1_1/mqtt_client/src/
Dmain.c334 ZSOCK_MSG_DONTWAIT); in broker_receive()
/Zephyr-4.1.0/subsys/net/lib/coap/
Dcoap_server.c138 int flags = ZSOCK_MSG_DONTWAIT; in coap_server_process()

12