Home
last modified time | relevance | path

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

12

/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.c189 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/mptcp/
H A Dsockopt.c103 WRITE_ONCE(ssk->sk_rcvbuf, sk->sk_rcvbuf); in mptcp_sol_socket_sync_intval()
1563 WRITE_ONCE(ssk->sk_rcvbuf, sk->sk_rcvbuf); in sync_socket_options()
1629 cap = sk->sk_rcvbuf >> 1; in mptcp_set_rcvlowat()
1643 if (space <= sk->sk_rcvbuf) in mptcp_set_rcvlowat()
1647 WRITE_ONCE(sk->sk_rcvbuf, space); in mptcp_set_rcvlowat()
1653 WRITE_ONCE(ssk->sk_rcvbuf, space);
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()
742 if (own_msk && sk_rmem_alloc_get(sk) < sk->sk_rcvbuf) { in __mptcp_move_skbs_from_subflow()
2172 * exceed ssk->sk_rcvbuf). in mptcp_rcv_space_adjust()
2201 if (sk_rmem_alloc_get(sk) > sk->sk_rcvbuf) in __mptcp_move_skbs()
2233 sk_rmem_alloc_get(sk) > sk->sk_rcvbuf) in mptcp_can_spool_backlog()
3087 sk->sk_rcvbuf = READ_ONCE(net->ipv4.sysctl_tcp_rmem[1]); in mptcp_init_sock()
/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.c518 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()
2312 return READ_ONCE(sk->sk_rcvbuf); in rcvbuf_limit()
2315 return READ_ONCE(sk->sk_rcvbuf) << msg_importance(hdr); in rcvbuf_limit()
2318 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()
/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()
H A Daf_x25.c603 sk->sk_rcvbuf = osk->sk_rcvbuf; in x25_make_new()
/linux/include/crypto/
H A Dif_alg.h218 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.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()
613 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/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/include/net/
H A Dllc_c_ev.h221 (unsigned int)sk->sk_rcvbuf; in llc_conn_space()
H A Dtcp.h1765 return tcp_win_from_space(sk, READ_ONCE(sk->sk_rcvbuf) - in tcp_space()
1772 return tcp_win_from_space(sk, READ_ONCE(sk->sk_rcvbuf)); in tcp_full_space()
1807 rcvbuf = READ_ONCE(sk->sk_rcvbuf); in tcp_rmem_pressure()
1960 atomic_read(&sk->sk_rmem_alloc) < sk->sk_rcvbuf && in tcp_fast_path_check()
/linux/net/netlink/
H A Daf_netlink.c1219 if ((rmem == skb->truesize || rmem <= READ_ONCE(sk->sk_rcvbuf)) && in netlink_attachskb()
1239 if (((rmem && rmem + skb->truesize > READ_ONCE(sk->sk_rcvbuf)) || in netlink_attachskb()
1394 rcvbuf = READ_ONCE(sk->sk_rcvbuf); in netlink_broadcast_deliver()
1975 atomic_read(&sk->sk_rmem_alloc) <= sk->sk_rcvbuf / 2) { in netlink_recvmsg()
2295 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()
949 if (rcvbuf > sk->sk_rcvbuf) { in tcp_rcvbuf_grow()
950 WRITE_ONCE(sk->sk_rcvbuf, rcvbuf); in tcp_rcvbuf_grow()
5328 return rmem <= sk->sk_rcvbuf; in tcp_can_ingest()
5879 if (sum_tiny > sk->sk_rcvbuf >> 3) in tcp_collapse_ofo_queue()
5916 goal = sk->sk_rcvbuf >> 3; in tcp_prune_ofo_queue()
5935 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()

12