| /net/atm/ |
| A D | atm_misc.c | 18 if (atomic_read(&sk_atm(vcc)->sk_rmem_alloc) <= sk_atm(vcc)->sk_rcvbuf) in atm_charge()
33 if (atomic_read(&sk->sk_rmem_alloc) <= sk->sk_rcvbuf) { in atm_alloc_charge()
|
| A D | proc.c | 200 sk_rmem_alloc_get(sk), sk->sk_rcvbuf, in vcc_info()
|
| /net/mptcp/ |
| A D | sockopt.c | 103 WRITE_ONCE(ssk->sk_rcvbuf, sk->sk_rcvbuf); in mptcp_sol_socket_sync_intval()
1556 WRITE_ONCE(ssk->sk_rcvbuf, sk->sk_rcvbuf); in sync_socket_options()
1622 cap = sk->sk_rcvbuf >> 1; in mptcp_set_rcvlowat()
1636 if (space <= sk->sk_rcvbuf) in mptcp_set_rcvlowat()
1640 WRITE_ONCE(sk->sk_rcvbuf, space); in mptcp_set_rcvlowat()
1646 WRITE_ONCE(ssk->sk_rcvbuf, space); in mptcp_set_rcvlowat()
|
| A D | protocol.c | 152 ((to->len + from->len) > (sk->sk_rcvbuf >> 3)) || in mptcp_try_coalesce()
607 if (sk_rmem_alloc_get(sk) > sk->sk_rcvbuf) in __mptcp_move_skbs_from_subflow()
775 if (unlikely(ssk->sk_rcvbuf > sk->sk_rcvbuf)) in __mptcp_rcvbuf_update()
776 WRITE_ONCE(sk->sk_rcvbuf, ssk->sk_rcvbuf); in __mptcp_rcvbuf_update()
2001 if (rcvbuf > sk->sk_rcvbuf) { in mptcp_rcv_space_adjust()
2005 WRITE_ONCE(sk->sk_rcvbuf, rcvbuf); in mptcp_rcv_space_adjust()
2018 WRITE_ONCE(ssk->sk_rcvbuf, rcvbuf); in mptcp_rcv_space_adjust()
2071 if (sk_rmem_alloc_get(sk) > sk->sk_rcvbuf) in __mptcp_move_skbs()
2830 sk->sk_rcvbuf = READ_ONCE(net->ipv4.sysctl_tcp_rmem[1]); in mptcp_init_sock()
|
| /net/tipc/ |
| A D | group.h | 61 int *sk_rcvbuf, struct tipc_msg *hdr,
|
| A D | group.c | 197 void tipc_group_join(struct net *net, struct tipc_group *grp, int *sk_rcvbuf) in tipc_group_join() argument
209 *sk_rcvbuf = tipc_group_rcvbuf_limit(grp); in tipc_group_join()
857 int *sk_rcvbuf, in tipc_group_member_evt() argument
923 *sk_rcvbuf = tipc_group_rcvbuf_limit(grp); in tipc_group_member_evt()
|
| A D | socket.c | 518 sk->sk_rcvbuf = READ_ONCE(sysctl_tipc_rmem[1]); in tipc_sk_create()
1810 tsk->rcv_win = tsk_adv_blocks(tsk->sk.sk_rcvbuf); in tipc_sk_build_ack()
2170 tipc_group_member_evt(tsk->group, &wakeup, &sk->sk_rcvbuf, in tipc_sk_proto_rcv()
2310 return READ_ONCE(sk->sk_rcvbuf); in rcvbuf_limit()
2313 return READ_ONCE(sk->sk_rcvbuf) << msg_importance(hdr); in rcvbuf_limit()
2316 return READ_ONCE(sk->sk_rcvbuf); in rcvbuf_limit()
3102 tipc_group_join(net, grp, &tsk->sk.sk_rcvbuf); in tipc_sk_join()
3986 i += scnprintf(buf + i, sz - i, " %d", sk->sk_rcvbuf); in tipc_sk_dump()
|
| /net/x25/ |
| A D | x25_dev.c | 58 queued = !sk_add_backlog(sk, skb, READ_ONCE(sk->sk_rcvbuf)); in x25_receive_data()
|
| A D | x25_subr.c | 376 if (atomic_read(&sk->sk_rmem_alloc) < (sk->sk_rcvbuf >> 1) && in x25_check_rbuf()
|
| A D | x25_in.c | 292 (sk->sk_rcvbuf >> 1)) in x25_state3_machine()
|
| /net/ax25/ |
| A D | ax25_std_timer.c | 63 (sk->sk_rcvbuf >> 1) && in ax25_std_heartbeat_expiry()
|
| A D | ax25_ds_timer.c | 125 (sk->sk_rcvbuf >> 1) && in ax25_ds_heartbeat_expiry()
|
| A D | ax25_in.c | 264 sk->sk_rcvbuf) { in ax25_rcv()
|
| /net/bluetooth/rfcomm/ |
| A D | sock.c | 60 if (atomic_read(&sk->sk_rmem_alloc) >= sk->sk_rcvbuf) in rfcomm_sk_data_ready()
297 sk->sk_rcvbuf = RFCOMM_MAX_CREDITS * RFCOMM_DEFAULT_MTU * 10; in rfcomm_sock_alloc()
612 if (atomic_read(&sk->sk_rmem_alloc) <= (sk->sk_rcvbuf >> 2)) in rfcomm_sock_recvmsg()
|
| /net/sctp/ |
| A D | associola.c | 163 if ((sk->sk_rcvbuf/2) < SCTP_DEFAULT_MINWINDOW) in sctp_association_init()
166 asoc->rwnd = sk->sk_rcvbuf/2; in sctp_association_init()
1442 (asoc->base.sk->sk_rcvbuf >> net->sctp.rwnd_upd_shift), in sctp_peer_needs_update()
1532 if (rx_count >= asoc->base.sk->sk_rcvbuf) in sctp_assoc_rwnd_decrease()
|
| A D | input.c | 312 if (sk_add_backlog(sk, skb, READ_ONCE(sk->sk_rcvbuf))) in sctp_backlog_rcv()
327 if (!sk_add_backlog(sk, skb, READ_ONCE(sk->sk_rcvbuf))) in sctp_backlog_rcv()
354 ret = sk_add_backlog(sk, skb, READ_ONCE(sk->sk_rcvbuf)); in sctp_add_backlog()
|
| A D | proc.c | 287 sk->sk_rcvbuf); in sctp_assocs_seq_show()
|
| /net/rose/ |
| A D | rose_in.c | 184 (sk->sk_rcvbuf >> 1)) in rose_state3_machine()
|
| A D | rose_timer.c | 146 if (atomic_read(&sk->sk_rmem_alloc) < (sk->sk_rcvbuf / 2) && in rose_heartbeat_expiry()
|
| /net/netrom/ |
| A D | nr_timer.c | 136 if (atomic_read(&sk->sk_rmem_alloc) < (sk->sk_rcvbuf / 2) && in nr_heartbeat_expiry()
|
| /net/vmw_vsock/ |
| A D | hyperv_transport.c | 379 rcvbuf = max_t(int, sk->sk_rcvbuf, RINGBUFFER_HVS_RCV_SIZE); in hvs_open_connection()
454 sk->sk_rcvbuf = RINGBUFFER_HVS_RCV_SIZE; in hvs_sock_init()
|
| /net/core/ |
| A D | sock.c | 493 if (atomic_read(&sk->sk_rmem_alloc) >= READ_ONCE(sk->sk_rcvbuf)) { in __sock_queue_rcv_skb()
564 if (sk_rcvqueues_full(sk, READ_ONCE(sk->sk_rcvbuf))) { in __sk_receive_skb()
582 } else if ((err = sk_add_backlog(sk, skb, READ_ONCE(sk->sk_rcvbuf)))) { in __sk_receive_skb()
992 WRITE_ONCE(sk->sk_rcvbuf, max_t(int, val * 2, SOCK_MIN_RCVBUF)); in __sock_set_rcvbuf()
1764 v.val = READ_ONCE(sk->sk_rcvbuf); in sk_getsockopt()
3657 sk->sk_rcvbuf = READ_ONCE(sysctl_rmem_default); in sock_init_data_uid()
3969 mem[SK_MEMINFO_RCVBUF] = READ_ONCE(sk->sk_rcvbuf); in sk_get_meminfo()
4448 CACHELINE_ASSERT_GROUP_MEMBER(struct sock, sock_read_rx, sk_rcvbuf); in sock_struct_check()
|
| /net/netlink/ |
| A D | af_netlink.c | 1221 if ((rmem == skb->truesize || rmem <= READ_ONCE(sk->sk_rcvbuf)) && in netlink_attachskb()
1241 if (((rmem && rmem + skb->truesize > READ_ONCE(sk->sk_rcvbuf)) || in netlink_attachskb()
1396 rcvbuf = READ_ONCE(sk->sk_rcvbuf); in netlink_broadcast_deliver()
1977 atomic_read(&sk->sk_rmem_alloc) <= sk->sk_rcvbuf / 2) { in netlink_recvmsg()
2297 rcvbuf = READ_ONCE(sk->sk_rcvbuf); in netlink_dump()
|
| /net/caif/ |
| A D | caif_socket.c | 105 return cf_sk->sk.sk_rcvbuf / 4; in sk_rcvbuf_lowwater()
129 (unsigned int)sk->sk_rcvbuf && rx_flow_is_on(cf_sk)) { in caif_queue_rcv_skb()
|
| /net/ipv4/ |
| A D | tcp_input.c | 252 val = tcp_win_from_space(sk, sk->sk_rcvbuf); in tcp_measure_rcv_mss()
623 if (sk->sk_rcvbuf < rmem2 && in tcp_clamp_window()
627 WRITE_ONCE(sk->sk_rcvbuf, in tcp_clamp_window()
630 if (atomic_read(&sk->sk_rmem_alloc) > sk->sk_rcvbuf) in tcp_clamp_window()
766 if (rcvbuf > sk->sk_rcvbuf) { in tcp_rcvbuf_grow()
767 WRITE_ONCE(sk->sk_rcvbuf, rcvbuf); in tcp_rcvbuf_grow()
4898 return new_mem <= sk->sk_rcvbuf; in tcp_can_ingest()
5467 if (sum_tiny > sk->sk_rcvbuf >> 3) in tcp_collapse_ofo_queue()
5504 goal = sk->sk_rcvbuf >> 3; in tcp_prune_ofo_queue()
5523 goal = sk->sk_rcvbuf >> 3; in tcp_prune_ofo_queue()
|