Home
last modified time | relevance | path

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

12

/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)
H A Dmptcp.h229 __entry->rcvbuf = sk->sk_rcvbuf;
/linux/net/atm/
H A Datm_misc.c17 if (atomic_read(&sk_atm(vcc)->sk_rmem_alloc) <= sk_atm(vcc)->sk_rcvbuf) in atm_charge()
/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.c520 sk->sk_rcvbuf = READ_ONCE(sysctl_tipc_rmem[1]); in tipc_sk_create()
1815 tsk->rcv_win = tsk_adv_blocks(tsk->sk.sk_rcvbuf); in tipc_sk_build_ack()
2175 tipc_group_member_evt(tsk->group, &wakeup, &sk->sk_rcvbuf, in tipc_sk_proto_rcv()
2317 return READ_ONCE(sk->sk_rcvbuf); in rcvbuf_limit()
2320 return READ_ONCE(sk->sk_rcvbuf) << msg_importance(hdr); in rcvbuf_limit()
2323 return READ_ONCE(sk->sk_rcvbuf); in rcvbuf_limit()
3107 tipc_group_join(net, grp, &tsk->sk.sk_rcvbuf); in tipc_sk_join()
3991 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.c166 int limit = READ_ONCE(sk->sk_rcvbuf); in __mptcp_try_coalesce()
238 if (rcvbuf > sk->sk_rcvbuf) { in mptcp_rcvbuf_grow()
239 WRITE_ONCE(sk->sk_rcvbuf, rcvbuf); in mptcp_rcvbuf_grow()
276 if (mem <= sk->sk_rcvbuf) in mptcp_prune_ofo_queue()
291 return unlikely(sk_rmem_alloc_get(sk) <= READ_ONCE(sk->sk_rcvbuf)) || in mptcp_can_ingest()
765 limit = READ_ONCE(sk->sk_rcvbuf); in __mptcp_add_backlog()
3252 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/net/core/
H A Dbpf_ksock.c134 ks->sock->sk->sk_rcvbuf = SOCK_MIN_RCVBUF; in bpf_ksock_create()
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()
986 WRITE_ONCE(sk->sk_rcvbuf, max_t(int, val * 2, SOCK_MIN_RCVBUF)); in __sock_set_rcvbuf()
992 ops->set_rcvbuf(sk, sk->sk_rcvbuf); in __sock_set_rcvbuf()
1776 v.val = READ_ONCE(sk->sk_rcvbuf); in sk_getsockopt()
3751 sk->sk_rcvbuf = READ_ONCE(sysctl_rmem_default); in sock_init_data_uid()
4077 mem[SK_MEMINFO_RCVBUF] = READ_ONCE(sk->sk_rcvbuf); in sk_get_meminfo()
4560 CACHELINE_ASSERT_GROUP_MEMBER(struct sock, sock_read_rx, sk_rcvbuf); in sock_struct_check()
/linux/net/bluetooth/rfcomm/
H A Dsock.c58 if (atomic_read(&sk->sk_rmem_alloc) >= sk->sk_rcvbuf) in rfcomm_sk_data_ready()
308 sk->sk_rcvbuf = RFCOMM_MAX_CREDITS * RFCOMM_DEFAULT_MTU * 10; in rfcomm_sock_alloc()
629 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()
1456 (asoc->base.sk->sk_rcvbuf >> net->sctp.rwnd_upd_shift), in sctp_peer_needs_update()
1546 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.c178 mem[SK_MEMINFO_RCVBUF] = sk->sk_rcvbuf; in inet_sctp_diag_fill()
/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/net/strparser/
H A Dstrparser.c344 strp->sk->sk_rcvbuf, READ_ONCE(strp->sk->sk_rcvtimeo));
/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/include/net/
H A Dudp.h292 up->forward_threshold = sk->sk_rcvbuf >> 2; in udp_lib_init_sock()
/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()
949 if (rcvbuf > sk->sk_rcvbuf) { in tcp_rcvbuf_grow()
950 WRITE_ONCE(sk->sk_rcvbuf, rcvbuf); in tcp_rcvbuf_grow()
5361 return rmem <= sk->sk_rcvbuf; in tcp_can_ingest()
5912 if (sum_tiny > sk->sk_rcvbuf >> 3) in tcp_collapse_ofo_queue()
5949 goal = sk->sk_rcvbuf >> 3; in tcp_prune_ofo_queue()
5968 goal = sk->sk_rcvbuf >> 3; in tcp_prune_ofo_queue()
/linux/net/xfrm/
H A Despintcp.c15 if (atomic_read(&sk->sk_rmem_alloc) >= sk->sk_rcvbuf || in handle_nonesp()
/linux/net/rds/
H A Dtcp.c543 sk->sk_rcvbuf = rtn->rcvbuf_size; in rds_tcp_tune()

12