| /Linux-v5.15/net/atm/ |
| 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()
|
| /Linux-v5.15/include/trace/events/ |
| D | sock.h | 80 __field(int, sk_rcvbuf) 86 __entry->sk_rcvbuf = READ_ONCE(sk->sk_rcvbuf); 90 __entry->rmem_alloc, __entry->truesize, __entry->sk_rcvbuf)
|
| /Linux-v5.15/net/mptcp/ |
| D | sockopt.c | 99 WRITE_ONCE(ssk->sk_rcvbuf, sk->sk_rcvbuf); in mptcp_sol_socket_sync_intval() 733 WRITE_ONCE(ssk->sk_rcvbuf, sk->sk_rcvbuf); in sync_socket_options()
|
| D | protocol.c | 567 sk_rbuf = READ_ONCE(sk->sk_rcvbuf); in __mptcp_move_skbs_from_subflow() 570 int ssk_rbuf = READ_ONCE(ssk->sk_rcvbuf); in __mptcp_move_skbs_from_subflow() 573 WRITE_ONCE(sk->sk_rcvbuf, ssk_rbuf); in __mptcp_move_skbs_from_subflow() 731 ssk_rbuf = READ_ONCE(ssk->sk_rcvbuf); in mptcp_data_ready() 732 sk_rbuf = READ_ONCE(sk->sk_rcvbuf); in mptcp_data_ready() 1878 if (rcvbuf > sk->sk_rcvbuf) { in mptcp_rcv_space_adjust() 1882 WRITE_ONCE(sk->sk_rcvbuf, rcvbuf); in mptcp_rcv_space_adjust() 1895 WRITE_ONCE(ssk->sk_rcvbuf, rcvbuf); in mptcp_rcv_space_adjust() 2512 sk->sk_rcvbuf = sock_net(sk)->ipv4.sysctl_tcp_rmem[1]; in mptcp_init_sock()
|
| /Linux-v5.15/net/tipc/ |
| D | group.h | 61 int *sk_rcvbuf, struct tipc_msg *hdr,
|
| 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()
|
| /Linux-v5.15/net/x25/ |
| D | x25_dev.c | 58 queued = !sk_add_backlog(sk, skb, READ_ONCE(sk->sk_rcvbuf)); in x25_receive_data()
|
| D | x25_subr.c | 376 if (atomic_read(&sk->sk_rmem_alloc) < (sk->sk_rcvbuf >> 1) && in x25_check_rbuf()
|
| D | x25_in.c | 292 (sk->sk_rcvbuf >> 1)) in x25_state3_machine()
|
| /Linux-v5.15/net/ax25/ |
| D | ax25_std_timer.c | 63 (sk->sk_rcvbuf >> 1) && in ax25_std_heartbeat_expiry()
|
| D | ax25_ds_timer.c | 125 (sk->sk_rcvbuf >> 1) && in ax25_ds_heartbeat_expiry()
|
| /Linux-v5.15/include/net/ |
| D | dn_nsp.h | 190 return atomic_read(&sk->sk_rmem_alloc) > (sk->sk_rcvbuf >> 1); in dn_congested()
|
| D | llc_c_ev.h | 222 (unsigned int)sk->sk_rcvbuf; in llc_conn_space()
|
| /Linux-v5.15/include/crypto/ |
| D | if_alg.h | 213 return max_t(int, max_t(int, sk->sk_rcvbuf & PAGE_MASK, PAGE_SIZE) - in af_alg_rcvbuf()
|
| /Linux-v5.15/net/rose/ |
| D | rose_timer.c | 141 if (atomic_read(&sk->sk_rmem_alloc) < (sk->sk_rcvbuf / 2) && in rose_heartbeat_expiry()
|
| D | rose_in.c | 182 (sk->sk_rcvbuf >> 1)) in rose_state3_machine()
|
| /Linux-v5.15/net/netrom/ |
| D | nr_timer.c | 134 if (atomic_read(&sk->sk_rmem_alloc) < (sk->sk_rcvbuf / 2) && in nr_heartbeat_expiry()
|
| /Linux-v5.15/net/vmw_vsock/ |
| D | hyperv_transport.c | 370 rcvbuf = max_t(int, sk->sk_rcvbuf, RINGBUFFER_HVS_RCV_SIZE); in hvs_open_connection() 443 sk->sk_rcvbuf = RINGBUFFER_HVS_RCV_SIZE; in hvs_sock_init()
|
| /Linux-v5.15/net/bluetooth/rfcomm/ |
| D | sock.c | 60 if (atomic_read(&sk->sk_rmem_alloc) >= sk->sk_rcvbuf) in rfcomm_sk_data_ready() 299 sk->sk_rcvbuf = RFCOMM_MAX_CREDITS * RFCOMM_DEFAULT_MTU * 10; in rfcomm_sock_alloc() 640 if (atomic_read(&sk->sk_rmem_alloc) <= (sk->sk_rcvbuf >> 2)) in rfcomm_sock_recvmsg()
|
| /Linux-v5.15/net/sctp/ |
| D | associola.c | 162 if ((sk->sk_rcvbuf/2) < SCTP_DEFAULT_MINWINDOW) in sctp_association_init() 165 asoc->rwnd = sk->sk_rcvbuf/2; in sctp_association_init() 1463 (asoc->base.sk->sk_rcvbuf >> net->sctp.rwnd_upd_shift), in sctp_peer_needs_update() 1553 if (rx_count >= asoc->base.sk->sk_rcvbuf) in sctp_assoc_rwnd_decrease()
|
| D | input.c | 325 if (sk_add_backlog(sk, skb, READ_ONCE(sk->sk_rcvbuf))) in sctp_backlog_rcv() 340 if (!sk_add_backlog(sk, skb, READ_ONCE(sk->sk_rcvbuf))) in sctp_backlog_rcv() 367 ret = sk_add_backlog(sk, skb, READ_ONCE(sk->sk_rcvbuf)); in sctp_add_backlog()
|
| /Linux-v5.15/net/ipv4/ |
| D | tcp_input.c | 572 if (sk->sk_rcvbuf < net->ipv4.sysctl_tcp_rmem[2] && in tcp_clamp_window() 576 WRITE_ONCE(sk->sk_rcvbuf, in tcp_clamp_window() 580 if (atomic_read(&sk->sk_rmem_alloc) > sk->sk_rcvbuf) in tcp_clamp_window() 741 if (rcvbuf > sk->sk_rcvbuf) { in tcp_rcv_space_adjust() 742 WRITE_ONCE(sk->sk_rcvbuf, rcvbuf); in tcp_rcv_space_adjust() 4740 if (atomic_read(&sk->sk_rmem_alloc) > sk->sk_rcvbuf || in tcp_try_rmem_schedule() 5270 if (sum_tiny > sk->sk_rcvbuf >> 3) in tcp_collapse_ofo_queue() 5305 goal = sk->sk_rcvbuf >> 3; in tcp_prune_ofo_queue() 5314 if (atomic_read(&sk->sk_rmem_alloc) <= sk->sk_rcvbuf && in tcp_prune_ofo_queue() 5317 goal = sk->sk_rcvbuf >> 3; in tcp_prune_ofo_queue() [all …]
|
| /Linux-v5.15/net/core/ |
| D | sock.c | 462 if (atomic_read(&sk->sk_rmem_alloc) >= sk->sk_rcvbuf) { in __sock_queue_rcv_skb() 514 if (sk_rcvqueues_full(sk, sk->sk_rcvbuf)) { in __sk_receive_skb() 531 } else if (sk_add_backlog(sk, skb, READ_ONCE(sk->sk_rcvbuf))) { in __sk_receive_skb() 923 WRITE_ONCE(sk->sk_rcvbuf, max_t(int, val * 2, SOCK_MIN_RCVBUF)); in __sock_set_rcvbuf() 1460 v.val = sk->sk_rcvbuf; in sock_getsockopt() 3125 sk->sk_rcvbuf = sysctl_rmem_default; in sock_init_data() 3442 mem[SK_MEMINFO_RCVBUF] = READ_ONCE(sk->sk_rcvbuf); in sk_get_meminfo()
|
| /Linux-v5.15/net/smc/ |
| D | af_smc.c | 302 nsk->sk_rcvbuf = osk->sk_rcvbuf; in smc_copy_sock_settings() 1856 new_smc->sk.sk_rcvbuf = lsmc->sk.sk_rcvbuf; in smc_tcp_listen_work() 2506 smc->sk.sk_rcvbuf = max(smc->clcsock->sk->sk_rcvbuf, SMC_BUF_MIN_SIZE); in smc_create()
|
| /Linux-v5.15/net/netlink/ |
| D | af_netlink.c | 1226 if ((atomic_read(&sk->sk_rmem_alloc) > sk->sk_rcvbuf || in netlink_attachskb() 1240 if ((atomic_read(&sk->sk_rmem_alloc) > sk->sk_rcvbuf || in netlink_attachskb() 1395 if (atomic_read(&sk->sk_rmem_alloc) <= sk->sk_rcvbuf && in netlink_broadcast_deliver() 1399 return atomic_read(&sk->sk_rmem_alloc) > (sk->sk_rcvbuf >> 1); in netlink_broadcast_deliver() 2017 atomic_read(&sk->sk_rmem_alloc) <= sk->sk_rcvbuf / 2) { in netlink_recvmsg() 2245 if (atomic_read(&sk->sk_rmem_alloc) >= sk->sk_rcvbuf) in netlink_dump()
|