Home
last modified time | relevance | path

Searched refs:sk_rcvbuf (Results 1 – 25 of 68) sorted by relevance

123

/linux-6.15/net/atm/
H A Datm_misc.c18 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-6.15/include/trace/events/
H A Dsock.h81 __field(int, sk_rcvbuf)
87 __entry->sk_rcvbuf = READ_ONCE(sk->sk_rcvbuf);
91 __entry->rmem_alloc, __entry->truesize, __entry->sk_rcvbuf)
/linux-6.15/net/tipc/
H A Dgroup.h61 int *sk_rcvbuf, struct tipc_msg *hdr,
H A Dgroup.c197 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-6.15/net/mptcp/
H A Dsockopt.c103 WRITE_ONCE(ssk->sk_rcvbuf, sk->sk_rcvbuf); in mptcp_sol_socket_sync_intval()
1532 WRITE_ONCE(ssk->sk_rcvbuf, sk->sk_rcvbuf); in sync_socket_options()
1597 cap = sk->sk_rcvbuf >> 1; in mptcp_set_rcvlowat()
1611 if (space <= sk->sk_rcvbuf) in mptcp_set_rcvlowat()
1615 WRITE_ONCE(sk->sk_rcvbuf, space); in mptcp_set_rcvlowat()
1621 WRITE_ONCE(ssk->sk_rcvbuf, space); in mptcp_set_rcvlowat()
H A Dprotocol.c129 ((to->len + from->len) > (sk->sk_rcvbuf >> 3)) || in mptcp_try_coalesce()
588 if (sk_rmem_alloc_get(sk) > sk->sk_rcvbuf) in __mptcp_move_skbs_from_subflow()
756 if (unlikely(ssk->sk_rcvbuf > sk->sk_rcvbuf)) in __mptcp_rcvbuf_update()
757 WRITE_ONCE(sk->sk_rcvbuf, ssk->sk_rcvbuf); in __mptcp_rcvbuf_update()
1972 if (rcvbuf > sk->sk_rcvbuf) { in mptcp_rcv_space_adjust()
1976 WRITE_ONCE(sk->sk_rcvbuf, rcvbuf); in mptcp_rcv_space_adjust()
1989 WRITE_ONCE(ssk->sk_rcvbuf, rcvbuf); in mptcp_rcv_space_adjust()
2042 if (sk_rmem_alloc_get(sk) > sk->sk_rcvbuf) in __mptcp_move_skbs()
2786 sk->sk_rcvbuf = READ_ONCE(net->ipv4.sysctl_tcp_rmem[1]); in mptcp_init_sock()
/linux-6.15/net/x25/
H A Dx25_dev.c58 queued = !sk_add_backlog(sk, skb, READ_ONCE(sk->sk_rcvbuf)); in x25_receive_data()
H A Dx25_subr.c376 if (atomic_read(&sk->sk_rmem_alloc) < (sk->sk_rcvbuf >> 1) && in x25_check_rbuf()
H A Dx25_in.c292 (sk->sk_rcvbuf >> 1)) in x25_state3_machine()
/linux-6.15/net/ax25/
H A Dax25_std_timer.c63 (sk->sk_rcvbuf >> 1) && in ax25_std_heartbeat_expiry()
H A Dax25_ds_timer.c125 (sk->sk_rcvbuf >> 1) && in ax25_ds_heartbeat_expiry()
H A Dax25_in.c264 sk->sk_rcvbuf) { in ax25_rcv()
/linux-6.15/include/crypto/
H A Dif_alg.h216 return max_t(int, max_t(int, sk->sk_rcvbuf & PAGE_MASK, PAGE_SIZE) - in af_alg_rcvbuf()
/linux-6.15/net/bluetooth/rfcomm/
H A Dsock.c60 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()
/linux-6.15/net/netrom/
H A Dnr_timer.c136 if (atomic_read(&sk->sk_rmem_alloc) < (sk->sk_rcvbuf / 2) && in nr_heartbeat_expiry()
/linux-6.15/net/rose/
H A Drose_timer.c146 if (atomic_read(&sk->sk_rmem_alloc) < (sk->sk_rcvbuf / 2) && in rose_heartbeat_expiry()
H A Drose_in.c183 (sk->sk_rcvbuf >> 1)) in rose_state3_machine()
/linux-6.15/net/sctp/
H A Dassociola.c163 if ((sk->sk_rcvbuf/2) < SCTP_DEFAULT_MINWINDOW) in sctp_association_init()
166 asoc->rwnd = sk->sk_rcvbuf/2; in sctp_association_init()
1460 (asoc->base.sk->sk_rcvbuf >> net->sctp.rwnd_upd_shift), in sctp_peer_needs_update()
1550 if (rx_count >= asoc->base.sk->sk_rcvbuf) in sctp_assoc_rwnd_decrease()
H A Dinput.c312 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()
H A Dproc.c287 sk->sk_rcvbuf); in sctp_assocs_seq_show()
/linux-6.15/include/net/
H A Dllc_c_ev.h221 (unsigned int)sk->sk_rcvbuf; in llc_conn_space()
/linux-6.15/net/ipv4/
H A Dtcp_input.c252 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()
798 if (rcvbuf > sk->sk_rcvbuf) { in tcp_rcv_space_adjust()
799 WRITE_ONCE(sk->sk_rcvbuf, rcvbuf); in tcp_rcv_space_adjust()
5576 if (sum_tiny > sk->sk_rcvbuf >> 3) in tcp_collapse_ofo_queue()
5613 goal = sk->sk_rcvbuf >> 3; in tcp_prune_ofo_queue()
5632 goal = sk->sk_rcvbuf >> 3; in tcp_prune_ofo_queue()
5663 if (atomic_read(&sk->sk_rmem_alloc) >= sk->sk_rcvbuf) in tcp_prune_queue()
[all …]
/linux-6.15/net/vmw_vsock/
H A Dhyperv_transport.c379 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()
/linux-6.15/net/netlink/
H A Daf_netlink.c1219 if ((atomic_read(&sk->sk_rmem_alloc) > sk->sk_rcvbuf || in netlink_attachskb()
1233 if ((atomic_read(&sk->sk_rmem_alloc) > sk->sk_rcvbuf || in netlink_attachskb()
1387 if (atomic_read(&sk->sk_rmem_alloc) <= sk->sk_rcvbuf && in netlink_broadcast_deliver()
1391 return atomic_read(&sk->sk_rmem_alloc) > (sk->sk_rcvbuf >> 1); in netlink_broadcast_deliver()
1964 atomic_read(&sk->sk_rmem_alloc) <= sk->sk_rcvbuf / 2) { in netlink_recvmsg()
2261 if (atomic_read(&sk->sk_rmem_alloc) >= sk->sk_rcvbuf) in netlink_dump()
/linux-6.15/net/core/
H A Dsock.c491 if (atomic_read(&sk->sk_rmem_alloc) >= READ_ONCE(sk->sk_rcvbuf)) { in __sock_queue_rcv_skb()
561 if (sk_rcvqueues_full(sk, READ_ONCE(sk->sk_rcvbuf))) { in __sk_receive_skb()
578 } else if (sk_add_backlog(sk, skb, READ_ONCE(sk->sk_rcvbuf))) { in __sk_receive_skb()
994 WRITE_ONCE(sk->sk_rcvbuf, max_t(int, val * 2, SOCK_MIN_RCVBUF)); in __sock_set_rcvbuf()
1750 v.val = READ_ONCE(sk->sk_rcvbuf); in sk_getsockopt()
3626 sk->sk_rcvbuf = READ_ONCE(sysctl_rmem_default); in sock_init_data_uid()
3938 mem[SK_MEMINFO_RCVBUF] = READ_ONCE(sk->sk_rcvbuf); in sk_get_meminfo()
4417 CACHELINE_ASSERT_GROUP_MEMBER(struct sock, sock_read_rx, sk_rcvbuf); in sock_struct_check()

123