Home
last modified time | relevance | path

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

123

/linux/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()
H A Dproc.c178 sk_rmem_alloc_get(sk), sk->sk_rcvbuf, in vcc_info()
/linux/tools/testing/selftests/net/packetdrill/
H A Dtcp_ooo-before-and-after-accept.pkt9 // its initial sk_rcvbuf (tcp_rmem[1]) when receiving ooo packets.
35 // Test that ooo packets for accepted sockets do increase sk_rcvbuf
/linux/include/trace/events/
H A Dsock.h80 __field(int, sk_rcvbuf)
86 __entry->sk_rcvbuf = READ_ONCE(sk->sk_rcvbuf);
89 TP_printk("rmem_alloc=%d truesize=%u sk_rcvbuf=%d",
90 __entry->rmem_alloc, __entry->truesize, __entry->sk_rcvbuf)
/linux/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()
861 int *sk_rcvbuf, in tipc_group_member_evt() argument
927 *sk_rcvbuf = tipc_group_rcvbuf_limit(grp); in tipc_group_member_evt()
H A Dsocket.c519 sk->sk_rcvbuf = READ_ONCE(sysctl_tipc_rmem[1]); in tipc_sk_create()
1814 tsk->rcv_win = tsk_adv_blocks(tsk->sk.sk_rcvbuf); in tipc_sk_build_ack()
2174 tipc_group_member_evt(tsk->group, &wakeup, &sk->sk_rcvbuf, in tipc_sk_proto_rcv()
2316 return READ_ONCE(sk->sk_rcvbuf); in rcvbuf_limit()
2319 return READ_ONCE(sk->sk_rcvbuf) << msg_importance(hdr); in rcvbuf_limit()
2322 return READ_ONCE(sk->sk_rcvbuf);
3106 tipc_group_join(net, grp, &tsk->sk.sk_rcvbuf); in tipc_sk_leave()
3990 i += scnprintf(buf + i, sz - i, " %d", sk->sk_rcvbuf); in tipc_sk_dump()
/linux/net/mptcp/
H A Dsockopt.c72 WRITE_ONCE(ssk->sk_rcvbuf, val); in __mptcp_subflow_set_rcvbuf()
109 __mptcp_subflow_set_rcvbuf(ssk, sk->sk_rcvbuf); in mptcp_sol_socket_sync_intval()
1574 __mptcp_subflow_set_rcvbuf(ssk, sk->sk_rcvbuf); in sync_socket_options()
1640 cap = sk->sk_rcvbuf >> 1; in mptcp_set_rcvlowat()
1654 if (space <= sk->sk_rcvbuf) in mptcp_set_rcvlowat()
1658 WRITE_ONCE(sk->sk_rcvbuf, space); in mptcp_set_rcvlowat()
1664 WRITE_ONCE(ssk->sk_rcvbuf, space); in mptcp_set_rcvlowat()
H A Dprotocol.c160 int limit = READ_ONCE(sk->sk_rcvbuf); in __mptcp_try_coalesce()
232 if (rcvbuf > sk->sk_rcvbuf) { in mptcp_rcvbuf_grow()
233 WRITE_ONCE(sk->sk_rcvbuf, rcvbuf); in mptcp_rcvbuf_grow()
756 if (own_msk && sk_rmem_alloc_get(sk) < sk->sk_rcvbuf) { in __mptcp_move_skbs_from_subflow()
2215 if (sk_rmem_alloc_get(sk) > sk->sk_rcvbuf) in __mptcp_move_skbs()
2247 sk_rmem_alloc_get(sk) > sk->sk_rcvbuf) in mptcp_can_spool_backlog()
3109 sk->sk_rcvbuf = READ_ONCE(net->ipv4.sysctl_tcp_rmem[1]); in mptcp_init_sock()
/linux/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.c377 if (atomic_read(&sk->sk_rmem_alloc) < (sk->sk_rcvbuf >> 1) && in x25_check_rbuf()
H A Dx25_in.c295 (sk->sk_rcvbuf >> 1)) in x25_state3_machine()
/linux/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/net/bluetooth/rfcomm/
H A Dsock.c58 if (atomic_read(&sk->sk_rmem_alloc) >= sk->sk_rcvbuf) in rfcomm_sk_data_ready()
307 sk->sk_rcvbuf = RFCOMM_MAX_CREDITS * RFCOMM_DEFAULT_MTU * 10; in rfcomm_sock_alloc()
628 if (atomic_read(&sk->sk_rmem_alloc) <= (sk->sk_rcvbuf >> 2)) in rfcomm_sock_recvmsg()
/linux/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()
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()
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 Ddiag.c177 mem[SK_MEMINFO_RCVBUF] = sk->sk_rcvbuf; in inet_sctp_diag_fill()
/linux/net/core/
H A Dsock.c493 if (atomic_read(&sk->sk_rmem_alloc) >= READ_ONCE(sk->sk_rcvbuf)) { in __sock_queue_rcv_skb()
557 if (sk_rcvqueues_full(sk, READ_ONCE(sk->sk_rcvbuf))) { in __sk_receive_skb()
575 } else if ((err = sk_add_backlog(sk, skb, READ_ONCE(sk->sk_rcvbuf)))) { in __sk_receive_skb()
987 WRITE_ONCE(sk->sk_rcvbuf, max_t(int, val * 2, SOCK_MIN_RCVBUF)); in __sock_set_rcvbuf()
993 ops->set_rcvbuf(sk, sk->sk_rcvbuf); in __sock_set_rcvbuf()
1777 v.val = READ_ONCE(sk->sk_rcvbuf); in sk_getsockopt()
3749 sk->sk_rcvbuf = READ_ONCE(sysctl_rmem_default); in sock_init_data_uid()
4075 mem[SK_MEMINFO_RCVBUF] = READ_ONCE(sk->sk_rcvbuf); in sock_inuse_init_net()
4558 CACHELINE_ASSERT_GROUP_MEMBER(struct sock, sock_read_rx, sk_rcvbuf); in sock_struct_check()
/linux/net/vmw_vsock/
H A Dhyperv_transport.c379 rcvbuf = max_t(int, sk->sk_rcvbuf, RINGBUFFER_HVS_RCV_SIZE); in hvs_open_connection()
453 sk->sk_rcvbuf = RINGBUFFER_HVS_RCV_SIZE; in hvs_sock_init()
/linux/include/net/
H A Dllc_c_ev.h215 (unsigned int)sk->sk_rcvbuf;
H A Dtcp.h1775 return tcp_win_from_space(sk, READ_ONCE(sk->sk_rcvbuf) -
1782 return tcp_win_from_space(sk, READ_ONCE(sk->sk_rcvbuf)); in __tcp_adjust_rcv_ssthresh()
1805 /* We provision sk_rcvbuf around 200% of sk_rcvlowat. in tcp_rmem_pressure()
1817 rcvbuf = READ_ONCE(sk->sk_rcvbuf); in tcp_epollin_ready()
1970 atomic_read(&sk->sk_rmem_alloc) < sk->sk_rcvbuf && in tcp_mib_init()
/linux/net/netlink/
H A Daf_netlink.c1220 if ((rmem == skb->truesize || rmem <= READ_ONCE(sk->sk_rcvbuf)) && in netlink_attachskb()
1240 if (((rmem && rmem + skb->truesize > READ_ONCE(sk->sk_rcvbuf)) || in netlink_attachskb()
1395 rcvbuf = READ_ONCE(sk->sk_rcvbuf); in netlink_broadcast_deliver()
1981 atomic_read(&sk->sk_rmem_alloc) <= sk->sk_rcvbuf / 2) { in netlink_recvmsg()
2301 rcvbuf = READ_ONCE(sk->sk_rcvbuf); in netlink_dump()
/linux/net/strparser/
H A Dstrparser.c344 strp->sk->sk_rcvbuf, READ_ONCE(strp->sk->sk_rcvtimeo));
/linux/net/ipv4/
H A Dtcp_input.c254 val = tcp_win_from_space(sk, sk->sk_rcvbuf); in tcp_measure_rcv_mss()
788 if (sk->sk_rcvbuf < rmem2 && in tcp_clamp_window()
792 WRITE_ONCE(sk->sk_rcvbuf, in tcp_clamp_window()
795 if (atomic_read(&sk->sk_rmem_alloc) > sk->sk_rcvbuf) in tcp_clamp_window()
934 * but will avoid sk_rcvbuf inflation and poor cache use. 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()
5331 return rmem <= sk->sk_rcvbuf; in tcp_try_rmem_schedule()
5882 if (sum_tiny > sk->sk_rcvbuf >> 3) in tcp_collapse_ofo_queue()
5905 * 3) Drop at least 12.5 % of sk_rcvbuf t
[all...]
/linux/net/xfrm/
H A Despintcp.c15 if (atomic_read(&sk->sk_rmem_alloc) >= sk->sk_rcvbuf || in handle_nonesp()

123