| /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/tools/testing/selftests/net/ |
| H A D | tcp_mmap.c | 84 static int rcvbuf; /* Default: autotuning. Can be set with -r <integer> option */ variable
325 if (rcvbuf && setsockopt(fd, SOL_SOCKET, in apply_rcvsnd_buf()
326 SO_RCVBUF, &rcvbuf, sizeof(rcvbuf)) == -1) { in apply_rcvsnd_buf()
477 rcvbuf = atoi(optarg); in main()
|
| /linux/drivers/media/usb/dvb-usb/ |
| H A D | digitv.c | 37 memset(st->rcvbuf, 0, 7); in digitv_ctrl_msg()
47 ret = dvb_usb_generic_rw(d, st->sndbuf, 7, st->rcvbuf, 7, 10); in digitv_ctrl_msg()
48 memcpy(rbuf, &st->rcvbuf[3], rlen); in digitv_ctrl_msg()
|
| H A D | digitv.h | 12 unsigned char rcvbuf[7]; member
|
| /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"
334 if [ "$rcvbuf" -gt 0 ]; then
335 extra_args+=" -R $rcvbuf"
|
| /linux/drivers/media/usb/dvb-usb-v2/ |
| H A D | mxl111sf.h | 96 u8 rcvbuf[MXL_MAX_XFER_SIZE]; member
|
| H A D | mxl111sf.c | 68 memset(state->rcvbuf, 0, rlen); in mxl111sf_ctrl_msg()
74 dvb_usbv2_generic_rw(d, state->sndbuf, 1+wlen, state->rcvbuf, in mxl111sf_ctrl_msg()
78 memcpy(rbuf, state->rcvbuf, rlen); in mxl111sf_ctrl_msg()
|
| /linux/net/rds/ |
| H A D | af_rds.c | 821 sinfo.rcvbuf = rds_sk_rcvbuf(rs); in rds_sock_info()
856 sinfo6.rcvbuf = rds_sk_rcvbuf(rs); in rds6_sock_info()
|
| /linux/include/net/ |
| H A D | tcp.h | 1599 int rcvbuf, threshold; in tcp_rmem_pressure() local
1604 rcvbuf = READ_ONCE(sk->sk_rcvbuf); in tcp_rmem_pressure()
1605 threshold = rcvbuf - (rcvbuf >> 3); in tcp_rmem_pressure()
|
| /linux/net/mptcp/ |
| H A D | protocol.c | 2054 int rcvbuf; in mptcp_rcv_space_adjust() local
2063 rcvbuf = min_t(u64, mptcp_space_from_win(sk, rcvwin), in mptcp_rcv_space_adjust()
2066 if (rcvbuf > sk->sk_rcvbuf) { in mptcp_rcv_space_adjust()
2069 window_clamp = mptcp_win_from_space(sk, rcvbuf); in mptcp_rcv_space_adjust()
2070 WRITE_ONCE(sk->sk_rcvbuf, rcvbuf); in mptcp_rcv_space_adjust()
2083 WRITE_ONCE(ssk->sk_rcvbuf, rcvbuf); in mptcp_rcv_space_adjust()
|
| /linux/net/ipv4/ |
| H A D | udp.c | 1677 int size, rcvbuf; in __udp_enqueue_schedule_skb() local
1683 rcvbuf = READ_ONCE(sk->sk_rcvbuf); in __udp_enqueue_schedule_skb()
1684 if (rmem > rcvbuf) in __udp_enqueue_schedule_skb()
1693 if (rmem > (rcvbuf >> 1)) { in __udp_enqueue_schedule_skb()
|
| H A D | tcp_input.c | 765 int rcvbuf; in tcp_rcv_space_adjust() local
777 rcvbuf = min_t(u64, tcp_space_from_win(sk, rcvwin), in tcp_rcv_space_adjust()
779 if (rcvbuf > sk->sk_rcvbuf) { in tcp_rcv_space_adjust()
780 WRITE_ONCE(sk->sk_rcvbuf, rcvbuf); in tcp_rcv_space_adjust()
784 tcp_win_from_space(sk, rcvbuf)); in tcp_rcv_space_adjust()
|
| /linux/Documentation/networking/ |
| H A D | rds.rst | 253 number of bytes queued equals or exceeds rcvbuf then the socket
|
| H A D | ip-sysctl.rst | 3143 - 1: rcvbuf space is per association
3144 - 0: rcvbuf space is per socket
|
| /linux/net/packet/ |
| H A D | af_packet.c | 1343 int rcvbuf = READ_ONCE(sk->sk_rcvbuf); in __packet_rcv_has_room() local
1344 int avail = rcvbuf - atomic_read(&sk->sk_rmem_alloc) in __packet_rcv_has_room()
1347 if (avail > (rcvbuf >> ROOM_POW_OFF)) in __packet_rcv_has_room()
|
| /linux/fs/nfs/ |
| H A D | nfs4xdr.c | 5382 struct xdr_buf *rcvbuf = &req->rq_rcv_buf; in decode_readlink() local
5396 if (len >= rcvbuf->page_len || len <= 0) { in decode_readlink()
5413 xdr_terminate_string(rcvbuf, len); in decode_readlink()
|