| /linux-6.15/net/rxrpc/ |
| H A D | recvmsg.c | 198 if (!(flags & MSG_PEEK)) in rxrpc_recvmsg_data() 256 if (!(flags & MSG_PEEK)) in rxrpc_recvmsg_data() 261 if (!(flags & MSG_PEEK)) { in rxrpc_recvmsg_data() 354 if (!(flags & MSG_PEEK)) in rxrpc_recvmsg() 428 if (!(flags & MSG_PEEK)) in rxrpc_recvmsg() 447 if (!(flags & MSG_PEEK)) { in rxrpc_recvmsg()
|
| /linux-6.15/net/smc/ |
| H A D | smc_rx.c | 297 if (!(flags & MSG_PEEK)) in smc_rx_recv_urg() 311 if (!(flags & MSG_PEEK)) in smc_rx_recv_urg() 449 if ((flags & MSG_PEEK) && peeked_bytes) in smc_rx_recvmsg() 486 if (flags & MSG_PEEK) in smc_rx_recvmsg() 498 if (!(flags & MSG_PEEK)) { in smc_rx_recvmsg()
|
| /linux-6.15/tools/testing/selftests/net/ |
| H A D | sk_so_peek_off.c | 125 len = recv(recv_sock, buf, 1, MSG_PEEK); in sk_peek_offset_test() 136 len = recv(recv_sock, buf, 2, MSG_PEEK); in sk_peek_offset_test()
|
| H A D | tls.c | 883 MSG_WAITALL | MSG_PEEK), in TEST_F() 1053 EXPECT_EQ(recv(self->cfd, buf, send_len, MSG_PEEK), send_len); in TEST_F() 1070 EXPECT_NE(recv(self->cfd, buf, send_len, MSG_PEEK), -1); in TEST_F() 1144 MSG_PEEK | MSG_WAITALL)), -1); in TEST_F() 1496 buf, sizeof(buf), MSG_WAITALL | MSG_PEEK), in TEST_F() 1550 EXPECT_EQ(recv(self->cfd, buf, sizeof(buf), MSG_PEEK), send_len); in TEST_F() 1551 EXPECT_EQ(recv(self->cfd, buf, sizeof(buf), MSG_PEEK), send_len); in TEST_F() 1932 EXPECT_EQ(recv(self->cfd, buf, sizeof(buf), MSG_PEEK), send_len); in TEST_F() 1939 EXPECT_EQ(recv(self->cfd, buf, send_len, MSG_PEEK), -1); in TEST_F() 1942 tls_recv_keyupdate(_metadata, self->cfd, MSG_PEEK); in TEST_F() [all …]
|
| /linux-6.15/net/llc/ |
| H A D | af_llc.c | 782 if (flags & MSG_PEEK) { in llc_ui_recvmsg() 822 (flags & MSG_PEEK)) in llc_ui_recvmsg() 858 if ((flags & MSG_PEEK) && peek_seq != llc->copied_seq) { in llc_ui_recvmsg() 894 if (!(flags & MSG_PEEK)) { in llc_ui_recvmsg() 912 if (!(flags & MSG_PEEK)) { in llc_ui_recvmsg()
|
| /linux-6.15/net/core/ |
| H A D | datagram.c | 176 if (unlikely(flags & MSG_PEEK && *off >= 0)) { in __skb_try_recv_from_queue() 183 if (flags & MSG_PEEK) { in __skb_try_recv_from_queue() 334 if (flags & MSG_PEEK) { in __sk_queue_drop_skb()
|
| /linux-6.15/net/phonet/ |
| H A D | datagram.c | 119 if (flags & ~(MSG_PEEK|MSG_TRUNC|MSG_DONTWAIT|MSG_NOSIGNAL| in pn_recvmsg()
|
| H A D | pep.c | 1269 if (flags & ~(MSG_OOB|MSG_PEEK|MSG_TRUNC|MSG_DONTWAIT|MSG_WAITALL| in pep_recvmsg() 1280 if (flags & MSG_PEEK) in pep_recvmsg()
|
| /linux-6.15/tools/testing/vsock/ |
| H A D | vsock_test.c | 300 recv_buf(fd, buf_peek, sizeof(buf_peek), MSG_PEEK | MSG_DONTWAIT, in test_msg_peek_server() 306 recv_buf(fd, buf_half, sizeof(buf_half), MSG_PEEK, sizeof(buf_half)); in test_msg_peek_server() 309 recv_buf(fd, buf_peek, sizeof(buf_peek), MSG_PEEK, sizeof(buf_peek)); in test_msg_peek_server() 322 recv_buf(fd, buf_half, sizeof(buf_half), MSG_PEEK | MSG_TRUNC, in test_msg_peek_server() 1404 res = recv(fd, buf, buf_size, MSG_PEEK); in test_stream_credit_update_test()
|
| /linux-6.15/tools/testing/selftests/net/tcp_ao/lib/ |
| H A D | repair.c | 64 ret = recv(sk, q->buf, qlen, MSG_PEEK | MSG_DONTWAIT); in test_sock_checkpoint_queue()
|
| /linux-6.15/tools/perf/trace/beauty/include/linux/ |
| H A D | socket.h | 305 #define MSG_PEEK 2 macro
|
| /linux-6.15/tools/testing/selftests/bpf/ |
| H A D | netlink_helpers.c | 117 len = __rtnl_recvmsg(fd, msg, MSG_PEEK | MSG_TRUNC); in rtnl_recvmsg()
|
| /linux-6.15/include/linux/ |
| H A D | socket.h | 305 #define MSG_PEEK 2 macro
|
| /linux-6.15/include/trace/events/ |
| H A D | sock.h | 293 !(__entry->flags & MSG_PEEK) ?
|
| /linux-6.15/net/atm/ |
| H A D | common.c | 534 if (flags & ~(MSG_DONTWAIT | MSG_PEEK)) in vcc_recvmsg() 558 if (!(flags & MSG_PEEK)) { in vcc_recvmsg()
|
| /linux-6.15/net/unix/ |
| H A D | af_unix.c | 2423 if (!(flags & MSG_PEEK)) in __unix_dgram_recvmsg() 2476 if (!(flags & MSG_PEEK)) { in __unix_dgram_recvmsg() 2619 if (!(state->flags & MSG_PEEK)) in unix_stream_recv_urg() 2627 if (!(state->flags & MSG_PEEK)) in unix_stream_recv_urg() 2653 } else if (flags & MSG_PEEK) { in manage_oob() 2670 } else if (!(flags & MSG_PEEK)) { in manage_oob() 2889 if (!(flags & MSG_PEEK)) { in unix_stream_read_generic()
|
| /linux-6.15/net/nfc/ |
| H A D | llcp_sock.c | 867 if (!(flags & MSG_PEEK)) in llcp_sock_recvmsg() 891 if (!(flags & MSG_PEEK)) { in llcp_sock_recvmsg()
|
| /linux-6.15/net/dccp/ |
| H A D | proto.c | 842 if (!(flags & MSG_PEEK)) in dccp_recvmsg() 909 if (!(flags & MSG_PEEK)) in dccp_recvmsg()
|
| /linux-6.15/net/ipv4/ |
| H A D | tcp.c | 1410 if (!(flags & MSG_PEEK)) in tcp_recv_urg() 2616 if (!(flags & MSG_PEEK)) in tcp_recvmsg_locked() 2630 if (flags & MSG_PEEK) { in tcp_recvmsg_locked() 2674 WARN(!(flags & MSG_PEEK), in tcp_recvmsg_locked() 2734 if ((flags & MSG_PEEK) && in tcp_recvmsg_locked() 2809 if (flags & MSG_PEEK) in tcp_recvmsg_locked() 2831 if (!(flags & MSG_PEEK)) in tcp_recvmsg_locked() 2838 if (!(flags & MSG_PEEK)) in tcp_recvmsg_locked()
|
| H A D | tcp_bpf.c | 226 int peek = flags & MSG_PEEK; in tcp_bpf_recvmsg_parser()
|
| /linux-6.15/tools/testing/selftests/net/mptcp/ |
| H A D | mptcp_connect.c | 579 ret = recv(fd, buf, cap, MSG_PEEK); in do_rnd_read() 582 ret = recv(fd, buf, cap, MSG_PEEK); in do_rnd_read()
|
| /linux-6.15/tools/testing/selftests/net/af_unix/ |
| H A D | msg_oob.c | 319 buf_len, (flags) | MSG_PEEK); \
|
| /linux-6.15/net/iucv/ |
| H A D | af_iucv.c | 1280 if (!(flags & MSG_PEEK)) { in iucv_sock_recvmsg() 1333 if (flags & MSG_PEEK) in iucv_sock_recvmsg() 1339 if (!(flags & MSG_PEEK)) in iucv_sock_recvmsg()
|
| /linux-6.15/net/mctp/ |
| H A D | af_mctp.c | 216 if (flags & ~(MSG_DONTWAIT | MSG_TRUNC | MSG_PEEK)) in mctp_recvmsg()
|
| /linux-6.15/net/bluetooth/ |
| H A D | af_bluetooth.c | 462 if (!(flags & MSG_PEEK)) { in bt_sock_stream_recvmsg()
|