| /linux/net/sunrpc/xprtrdma/ |
| H A D | svc_rdma_backchannel.c | 25 struct xdr_buf *rcvbuf = &rqstp->rq_arg; in svc_rdma_handle_bc_reply() local
26 struct kvec *dst, *src = &rcvbuf->head[0]; in svc_rdma_handle_bc_reply()
54 xprt_complete_rqst(req->rq_task, rcvbuf->len); in svc_rdma_handle_bc_reply()
56 rcvbuf->len = 0; in svc_rdma_handle_bc_reply()
|
| /linux/net/vmw_vsock/ |
| H A D | hyperv_transport.c | 305 int rcvbuf; in hvs_open_connection() local
374 rcvbuf = RINGBUFFER_HVS_RCV_SIZE; in hvs_open_connection()
379 rcvbuf = max_t(int, sk->sk_rcvbuf, RINGBUFFER_HVS_RCV_SIZE); in hvs_open_connection()
380 rcvbuf = min_t(int, rcvbuf, RINGBUFFER_HVS_MAX_SIZE); in hvs_open_connection()
381 rcvbuf = VMBUS_RING_SIZE(rcvbuf); in hvs_open_connection()
386 ret = vmbus_open(chan, sndbuf, rcvbuf, NULL, 0, hvs_channel_cb, in hvs_open_connection()
|
| /linux/tools/testing/selftests/net/ |
| H A D | tcp_mmap.c | 84 static int rcvbuf; /* Default: autotuning. Can be set with -r <integer> option */ variable
327 if (rcvbuf && setsockopt(fd, SOL_SOCKET, in apply_rcvsnd_buf()
328 SO_RCVBUF, &rcvbuf, sizeof(rcvbuf)) == -1) { in apply_rcvsnd_buf()
479 rcvbuf = atoi(optarg); in main()
|
| /linux/drivers/media/usb/dvb-usb/ |
| H A D | digitv.h | 12 unsigned char rcvbuf[7]; member
|
| /linux/include/trace/events/ |
| H A D | mptcp.h | 200 __field(__u32, rcvbuf)
229 __entry->rcvbuf = sk->sk_rcvbuf;
254 __entry->scaling_ratio, __entry->rcvbuf, __entry->rcv_wnd,
|
| /linux/tools/testing/selftests/bpf/ |
| H A D | netlink_helpers.c | 14 static int rcvbuf = 1024 * 1024; variable
44 &rcvbuf, sizeof(rcvbuf)) < 0) { in rtnl_open_byproto()
|
| /linux/include/uapi/linux/ |
| H A D | rds.h | 203 __u32 rcvbuf; member
213 __u32 rcvbuf; member
|
| /linux/tools/testing/selftests/net/mptcp/ |
| H A D | mptcp_connect.sh | 30 rcvbuf=0
104 rcvbuf="$OPTARG"
338 if [ "$rcvbuf" -gt 0 ]; then
339 extra_args+=" -R $rcvbuf"
|
| /linux/drivers/media/usb/dvb-usb-v2/ |
| H A D | mxl111sf.h | 96 u8 rcvbuf[MXL_MAX_XFER_SIZE]; member
|
| /linux/net/netlink/ |
| H A D | af_netlink.c | 1392 unsigned int rmem, rcvbuf; in netlink_broadcast_deliver() local
1395 rcvbuf = READ_ONCE(sk->sk_rcvbuf); in netlink_broadcast_deliver()
1397 if ((rmem == skb->truesize || rmem <= rcvbuf) && in netlink_broadcast_deliver()
1401 return rmem > (rcvbuf >> 1); in netlink_broadcast_deliver()
2265 unsigned int rmem, rcvbuf; in netlink_dump() local
2301 rcvbuf = READ_ONCE(sk->sk_rcvbuf); in netlink_dump()
2303 if (rmem != skb->truesize && rmem >= rcvbuf) { in netlink_dump()
|
| /linux/net/mptcp/ |
| H A D | options.c | 1197 u32 rcvbuf = READ_ONCE(sk->sk_rcvbuf); in mptcp_over_limit() local
1199 if (likely((u32)sk_rmem_alloc_get(sk) <= rcvbuf && in mptcp_over_limit()
1200 READ_ONCE(msk->backlog_len) <= rcvbuf)) in mptcp_over_limit()
|
| H A D | protocol.c | 218 u32 rcvwin, rcvbuf, cap, oldval; in mptcp_rcvbuf_grow() local
237 rcvbuf = min_t(u32, mptcp_space_from_win(sk, rcvwin), cap); in mptcp_rcvbuf_grow()
238 if (rcvbuf > sk->sk_rcvbuf) { in mptcp_rcvbuf_grow()
239 WRITE_ONCE(sk->sk_rcvbuf, rcvbuf); in mptcp_rcvbuf_grow()
|
| /linux/include/net/ |
| H A D | tcp.h | 1812 int rcvbuf, threshold; in tcp_rmem_pressure() local
1817 rcvbuf = READ_ONCE(sk->sk_rcvbuf); in tcp_rmem_pressure()
1818 threshold = rcvbuf - (rcvbuf >> 3); in tcp_rmem_pressure()
|
| /linux/tools/testing/selftests/net/ovpn/ |
| H A D | ovpn-cli.c | 1129 int sndbuf = RT_SNDBUF_SIZE, rcvbuf = RT_RCVBUF_SIZE, fd; in ovpn_rt_socket() local
1144 if (setsockopt(fd, SOL_SOCKET, SO_RCVBUF, &rcvbuf, in ovpn_rt_socket()
1145 sizeof(rcvbuf)) < 0) { in ovpn_rt_socket()
|
| /linux/net/ipv4/ |
| H A D | udp.c | 1663 unsigned int rmem, rcvbuf; in __udp_enqueue_schedule_skb() local
1671 rcvbuf = READ_ONCE(sk->sk_rcvbuf); in __udp_enqueue_schedule_skb()
1681 if (rmem + size > rcvbuf) { in __udp_enqueue_schedule_skb()
1682 if (rcvbuf > INT_MAX >> 1) in __udp_enqueue_schedule_skb()
1696 if (rmem > (rcvbuf >> 1)) { in __udp_enqueue_schedule_skb()
|
| H A D | tcp_input.c | 915 u32 rcvwin, rcvbuf, cap, oldval; in tcp_rcvbuf_grow() local
948 rcvbuf = min_t(u32, tcp_space_from_win(sk, rcvwin), cap); in tcp_rcvbuf_grow()
949 if (rcvbuf > sk->sk_rcvbuf) { in tcp_rcvbuf_grow()
950 WRITE_ONCE(sk->sk_rcvbuf, rcvbuf); in tcp_rcvbuf_grow()
953 tcp_win_from_space(sk, rcvbuf)); in tcp_rcvbuf_grow()
|
| /linux/net/packet/ |
| H A D | af_packet.c | 1277 int rcvbuf = READ_ONCE(sk->sk_rcvbuf); in __packet_rcv_has_room() local
1278 int avail = rcvbuf - atomic_read(&sk->sk_rmem_alloc) in __packet_rcv_has_room()
1281 if (avail > (rcvbuf >> ROOM_POW_OFF)) in __packet_rcv_has_room()
|