| /linux-6.15/net/dccp/ |
| H A D | timer.c | 37 if (icsk->icsk_retransmits != 0) in dccp_write_timeout() 98 if (icsk->icsk_retransmits == 0) in dccp_retransmit_timer() 107 icsk->icsk_retransmits = 1; in dccp_retransmit_timer() 109 min(icsk->icsk_rto, in dccp_retransmit_timer() 115 icsk->icsk_backoff++; in dccp_retransmit_timer() 117 icsk->icsk_rto = min(icsk->icsk_rto << 1, DCCP_RTO_MAX); in dccp_retransmit_timer() 144 icsk_timeout(icsk)); in dccp_write_timer() 148 event = icsk->icsk_pending; in dccp_write_timer() 149 icsk->icsk_pending = 0; in dccp_write_timer() 199 icsk->icsk_ack.ato = min_t(u32, icsk->icsk_ack.ato << 1, in dccp_delack_timer() [all …]
|
| H A D | output.c | 73 if (icsk->icsk_retransmits == 0) in dccp_transmit_skb() 131 icsk->icsk_af_ops->send_check(sk, skb); in dccp_transmit_skb() 163 struct inet_connection_sock *icsk = inet_csk(sk); in dccp_sync_mss() local 169 cur_mps -= (icsk->icsk_af_ops->net_header_len + icsk->icsk_ext_hdr_len + in dccp_sync_mss() 189 icsk->icsk_pmtu_cookie = pmtu; in dccp_sync_mss() 546 struct inet_connection_sock *icsk = inet_csk(sk); in dccp_connect() local 573 icsk->icsk_retransmits = 0; in dccp_connect() 575 icsk->icsk_rto, DCCP_RTO_MAX); in dccp_connect() 619 if (icsk->icsk_ack.pending & ICSK_ACK_TIMER) { 625 if (icsk->icsk_ack.blocked) { [all …]
|
| H A D | diag.c | 19 const struct inet_connection_sock *icsk = inet_csk(sk); in dccp_get_info() local 24 info->tcpi_retransmits = icsk->icsk_retransmits; in dccp_get_info() 25 info->tcpi_probes = icsk->icsk_probes_out; in dccp_get_info() 26 info->tcpi_backoff = icsk->icsk_backoff; in dccp_get_info() 27 info->tcpi_pmtu = icsk->icsk_pmtu_cookie; in dccp_get_info()
|
| H A D | minisocks.c | 40 const struct inet_connection_sock *icsk = inet_csk(sk); in dccp_time_wait() local 41 const int rto = (icsk->icsk_rto << 2) - (icsk->icsk_rto >> 1); in dccp_time_wait()
|
| H A D | input.c | 401 const struct inet_connection_sock *icsk = inet_csk(sk); in dccp_rcv_request_sent_state_process() local 443 dccp_sync_mss(sk, icsk->icsk_pmtu_cookie); in dccp_rcv_request_sent_state_process() 472 icsk->icsk_af_ops->rebuild_header(sk); in dccp_rcv_request_sent_state_process() 480 icsk->icsk_accept_queue.rskq_defer_accept) { in dccp_rcv_request_sent_state_process()
|
| /linux-6.15/net/ipv4/ |
| H A D | tcp_timer.c | 36 return icsk->icsk_rto; in tcp_clamp_rto_to_user_timeout() 250 if (icsk->icsk_retransmits) in tcp_write_timeout() 264 tcp_mtu_probing(icsk, sk); in tcp_write_timeout() 335 icsk->icsk_ack.ato = min_t(u32, icsk->icsk_ack.ato << 1, icsk->icsk_rto); in tcp_delack_timer_handler() 395 icsk->icsk_probes_out = 0; in tcp_probe_timer() 447 icsk->icsk_retransmits++; in tcp_update_rto_stats() 667 icsk->icsk_backoff = 0; in tcp_retransmit_timer() 677 icsk->icsk_backoff++; in tcp_retransmit_timer() 678 icsk->icsk_rto = min(icsk->icsk_rto << 1, tcp_rto_max(sk)); in tcp_retransmit_timer() 697 !icsk->icsk_pending) in tcp_write_timer_handler() [all …]
|
| H A D | tcp_cong.c | 43 if (icsk->icsk_ca_ops->set_state) in tcp_set_ca_state() 45 icsk->icsk_ca_state = ca_state; in tcp_set_ca_state() 225 icsk->icsk_ca_ops = ca; in tcp_assign_congestion_control() 228 memset(icsk->icsk_ca_priv, 0, sizeof(icsk->icsk_ca_priv)); in tcp_assign_congestion_control() 240 if (icsk->icsk_ca_ops->init) in tcp_init_congestion_control() 241 icsk->icsk_ca_ops->init(sk); in tcp_init_congestion_control() 255 icsk->icsk_ca_ops = ca; in tcp_reinit_congestion_control() 256 icsk->icsk_ca_setsockopt = 1; in tcp_reinit_congestion_control() 257 memset(icsk->icsk_ca_priv, 0, sizeof(icsk->icsk_ca_priv)); in tcp_reinit_congestion_control() 273 if (icsk->icsk_ca_initialized && icsk->icsk_ca_ops->release) in tcp_cleanup_congestion_control() [all …]
|
| H A D | tcp_ulp.c | 106 struct inet_connection_sock *icsk = inet_csk(sk); in tcp_update_ulp() local 108 if (icsk->icsk_ulp_ops->update) in tcp_update_ulp() 114 struct inet_connection_sock *icsk = inet_csk(sk); in tcp_cleanup_ulp() local 120 if (!icsk->icsk_ulp_ops) in tcp_cleanup_ulp() 123 if (icsk->icsk_ulp_ops->release) in tcp_cleanup_ulp() 124 icsk->icsk_ulp_ops->release(sk); in tcp_cleanup_ulp() 125 module_put(icsk->icsk_ulp_ops->owner); in tcp_cleanup_ulp() 127 icsk->icsk_ulp_ops = NULL; in tcp_cleanup_ulp() 132 struct inet_connection_sock *icsk = inet_csk(sk); in __tcp_set_ulp() local 136 if (icsk->icsk_ulp_ops) in __tcp_set_ulp() [all …]
|
| H A D | inet_connection_sock.c | 768 icsk->icsk_pending = icsk->icsk_ack.pending = 0; in inet_csk_init_xmit_timers() 776 smp_store_release(&icsk->icsk_pending, 0); in inet_csk_clear_xmit_timers() 777 smp_store_release(&icsk->icsk_ack.pending, 0); in inet_csk_clear_xmit_timers() 780 sk_stop_timer(sk, &icsk->icsk_delack_timer); in inet_csk_clear_xmit_timers() 792 smp_store_release(&icsk->icsk_pending, 0); in inet_csk_clear_xmit_timers_sync() 1075 struct inet_connection_sock *icsk; in reqsk_timer_handler() local 1104 icsk = inet_csk(sk_listener); in reqsk_timer_handler() 1125 queue = &icsk->icsk_accept_queue; in reqsk_timer_handler() 1219 if (!icsk->icsk_ulp_ops) in inet_clone_ulp() 1342 if (icsk->icsk_ulp_ops && !icsk->icsk_ulp_ops->clone) in inet_ulp_can_listen() [all …]
|
| H A D | tcp_output.c | 177 if ((u32)(now - icsk->icsk_ack.lrcvtime) < icsk->icsk_ack.ato) in tcp_event_data_sent() 2473 interval = icsk->icsk_mtup.search_high - icsk->icsk_mtup.search_low; in tcp_mtu_probe() 3127 icsk->icsk_ack.quick = 0; in __tcp_select_window() 3186 icsk->icsk_ack.quick = 0; in __tcp_select_window() 3876 bpf_module_put(icsk->icsk_ca_ops, icsk->icsk_ca_ops->owner); in tcp_ca_dst_init() 3878 icsk->icsk_ca_ops = ca; in tcp_ca_dst_init() 4262 icsk->icsk_ack.retry++; in __tcp_send_ack() 4391 icsk->icsk_probes_out = 0; in tcp_send_probe0() 4392 icsk->icsk_backoff = 0; in tcp_send_probe0() 4397 icsk->icsk_probes_out++; in tcp_send_probe0() [all …]
|
| H A D | tcp_input.c | 620 icsk->icsk_ack.quick = 0; in tcp_clamp_window() 847 if (!icsk->icsk_ack.ato) { in tcp_event_data_recv() 858 icsk->icsk_ack.ato = (icsk->icsk_ack.ato >> 1) + TCP_ATO_MIN / 2; in tcp_event_data_recv() 860 icsk->icsk_ack.ato = (icsk->icsk_ack.ato >> 1) + m; in tcp_event_data_recv() 861 if (icsk->icsk_ack.ato > icsk->icsk_rto) in tcp_event_data_recv() 862 icsk->icsk_ack.ato = icsk->icsk_rto; in tcp_event_data_recv() 2213 (icsk->icsk_ca_state == TCP_CA_Loss && !icsk->icsk_retransmits)) { in tcp_enter_loss() 2806 icsk->icsk_mtup.search_high = icsk->icsk_mtup.probe_size - 1; in tcp_mtup_probe_failed() 2828 icsk->icsk_mtup.search_low = icsk->icsk_mtup.probe_size; in tcp_mtup_probe_success() 3535 icsk = inet_csk(sk); in tcp_clean_rtx_queue() [all …]
|
| H A D | tcp_htcp.c | 84 const struct inet_connection_sock *icsk = inet_csk(sk); in measure_rtt() local 92 if (icsk->icsk_ca_state == TCP_CA_Open) { in measure_rtt() 104 const struct inet_connection_sock *icsk = inet_csk(sk); in measure_achieved_throughput() local 109 if (icsk->icsk_ca_state == TCP_CA_Open) in measure_achieved_throughput() 119 if (!((1 << icsk->icsk_ca_state) & (TCPF_CA_Open | TCPF_CA_Disorder))) { in measure_achieved_throughput()
|
| H A D | inet_timewait_sock.c | 113 const struct inet_connection_sock *icsk = inet_csk(sk); in inet_twsk_hashdance_schedule() local 130 tw->tw_tb = icsk->icsk_bind_hash; in inet_twsk_hashdance_schedule() 131 WARN_ON(!icsk->icsk_bind_hash); in inet_twsk_hashdance_schedule() 133 tw->tw_tb2 = icsk->icsk_bind2_hash; in inet_twsk_hashdance_schedule() 134 WARN_ON(!icsk->icsk_bind2_hash); in inet_twsk_hashdance_schedule()
|
| H A D | tcp_diag.c | 115 struct inet_connection_sock *icsk = inet_csk(sk); in tcp_diag_get_aux() local 133 ulp_ops = icsk->icsk_ulp_ops; in tcp_diag_get_aux() 145 struct inet_connection_sock *icsk = inet_csk(sk); in tcp_diag_get_aux_size() local 169 ulp_ops = icsk->icsk_ulp_ops; in tcp_diag_get_aux_size()
|
| H A D | tcp.c | 434 icsk->icsk_rto = TCP_TIMEOUT_INIT; in tcp_init_sock() 472 icsk->icsk_sync_mss = tcp_sync_mss; in tcp_init_sock() 3351 icsk->icsk_backoff = 0; in tcp_disconnect() 3352 icsk->icsk_probes_out = 0; in tcp_disconnect() 3353 icsk->icsk_probes_tstamp = 0; in tcp_disconnect() 3365 if (icsk->icsk_ca_initialized && icsk->icsk_ca_ops->release) in tcp_disconnect() 3366 icsk->icsk_ca_ops->release(sk); in tcp_disconnect() 3367 memset(icsk->icsk_ca_priv, 0, sizeof(icsk->icsk_ca_priv)); in tcp_disconnect() 3368 icsk->icsk_ca_initialized = 0; in tcp_disconnect() 4426 ca_ops = icsk->icsk_ca_ops; in do_tcp_getsockopt() [all …]
|
| H A D | tcp_minisocks.c | 307 const struct inet_connection_sock *icsk = inet_csk(sk); in tcp_time_wait() local 316 const int rto = (icsk->icsk_rto << 2) - (icsk->icsk_rto >> 1); in tcp_time_wait() 471 struct inet_connection_sock *icsk = inet_csk(sk); in tcp_ca_openreq_child() local 481 icsk->icsk_ca_dst_locked = tcp_ca_dst_locked(dst); in tcp_ca_openreq_child() 482 icsk->icsk_ca_ops = ca; in tcp_ca_openreq_child() 490 (!icsk->icsk_ca_setsockopt || in tcp_ca_openreq_child() 491 !bpf_try_module_get(icsk->icsk_ca_ops, icsk->icsk_ca_ops->owner))) in tcp_ca_openreq_child()
|
| /linux-6.15/include/net/ |
| H A D | inet_connection_sock.h | 201 struct inet_connection_sock *icsk = inet_csk(sk); in inet_csk_clear_xmit_timer() local 204 smp_store_release(&icsk->icsk_pending, 0); in inet_csk_clear_xmit_timer() 209 smp_store_release(&icsk->icsk_ack.pending, 0); in inet_csk_clear_xmit_timer() 210 icsk->icsk_ack.retry = 0; in inet_csk_clear_xmit_timer() 212 sk_stop_timer(sk, &icsk->icsk_delack_timer); in inet_csk_clear_xmit_timer() 237 smp_store_release(&icsk->icsk_pending, what); in inet_csk_reset_xmit_timer() 240 smp_store_release(&icsk->icsk_ack.pending, in inet_csk_reset_xmit_timer() 241 icsk->icsk_ack.pending | ICSK_ACK_TIMER); in inet_csk_reset_xmit_timer() 252 u64 when = (u64)icsk->icsk_rto << icsk->icsk_backoff; in inet_csk_rto_backoff() 351 if (icsk->icsk_ack.pingpong < U8_MAX) in inet_csk_inc_pingpong_cnt() [all …]
|
| H A D | espintcp.h | 35 const struct inet_connection_sock *icsk = inet_csk(sk); in espintcp_getctx() local 38 return (__force void *)icsk->icsk_ulp_data; in espintcp_getctx()
|
| /linux-6.15/tools/testing/selftests/bpf/progs/ |
| H A D | bpf_iter_tcp4.c | 77 const struct inet_connection_sock *icsk; in dump_tcp_sock() local 88 icsk = &tp->inet_conn; in dump_tcp_sock() 89 inet = &icsk->icsk_inet; in dump_tcp_sock() 91 fastopenq = &icsk->icsk_accept_queue.fastopenq; in dump_tcp_sock() 98 if (icsk->icsk_pending == ICSK_TIME_RETRANS || in dump_tcp_sock() 100 icsk->icsk_pending == ICSK_TIME_LOSS_PROBE) { in dump_tcp_sock() 130 icsk->icsk_retransmits, uid, in dump_tcp_sock() 131 icsk->icsk_probes_out, in dump_tcp_sock() 136 jiffies_to_clock_t(icsk->icsk_rto), in dump_tcp_sock() 137 jiffies_to_clock_t(icsk->icsk_ack.ato), in dump_tcp_sock() [all …]
|
| H A D | bpf_iter_tcp6.c | 77 const struct inet_connection_sock *icsk; in dump_tcp6_sock() local 88 icsk = &tp->tcp.inet_conn; in dump_tcp6_sock() 89 inet = &icsk->icsk_inet; in dump_tcp6_sock() 91 fastopenq = &icsk->icsk_accept_queue.fastopenq; in dump_tcp6_sock() 98 if (icsk->icsk_pending == ICSK_TIME_RETRANS || in dump_tcp6_sock() 100 icsk->icsk_pending == ICSK_TIME_LOSS_PROBE) { in dump_tcp6_sock() 134 icsk->icsk_retransmits, uid, in dump_tcp6_sock() 135 icsk->icsk_probes_out, in dump_tcp6_sock() 140 jiffies_to_clock_t(icsk->icsk_rto), in dump_tcp6_sock() 141 jiffies_to_clock_t(icsk->icsk_ack.ato), in dump_tcp6_sock() [all …]
|
| H A D | mptcp_subflow.c | 88 struct inet_connection_sock *icsk; in _check_getsockopt_subflow_cc() local 93 icsk = bpf_core_cast(ssk, struct inet_connection_sock); in _check_getsockopt_subflow_cc() 96 __builtin_memcmp(icsk->icsk_ca_ops->name, cc, TCP_CA_NAME_MAX)) { in _check_getsockopt_subflow_cc()
|
| H A D | sock_destroy_prog.c | 77 const struct inet_connection_sock *icsk; in iter_tcp6_server() local 92 icsk = &tcp_sk->tcp.inet_conn; in iter_tcp6_server() 93 inet = &icsk->icsk_inet; in iter_tcp6_server()
|
| /linux-6.15/net/mptcp/ |
| H A D | token_test.c | 34 struct inet_connection_sock *icsk; in build_icsk() local 36 icsk = kunit_kzalloc(test, sizeof(struct inet_connection_sock), in build_icsk() 38 KUNIT_EXPECT_NOT_ERR_OR_NULL(test, icsk); in build_icsk() 39 return icsk; in build_icsk() 73 struct inet_connection_sock *icsk = build_icsk(test); in mptcp_token_test_msk_basic() local 79 rcu_assign_pointer(icsk->icsk_ulp_data, ctx); in mptcp_token_test_msk_basic() 84 mptcp_token_new_connect((struct sock *)icsk)); in mptcp_token_test_msk_basic()
|
| /linux-6.15/net/tls/ |
| H A D | tls_toe.c | 48 struct inet_connection_sock *icsk = inet_csk(sk); in tls_toe_sk_destruct() local 53 rcu_assign_pointer(icsk->icsk_ulp_data, NULL); in tls_toe_sk_destruct()
|
| /linux-6.15/net/ipv6/ |
| H A D | tcp_ipv6.c | 221 u32 exthdrlen = icsk->icsk_ext_hdr_len; in tcp_v6_connect() 232 WRITE_ONCE(icsk->icsk_af_ops, &ipv6_mapped); in tcp_v6_connect() 243 icsk->icsk_ext_hdr_len = exthdrlen; in tcp_v6_connect() 301 icsk->icsk_ext_hdr_len = 0; in tcp_v6_connect() 303 icsk->icsk_ext_hdr_len = opt->opt_flen + in tcp_v6_connect() 2131 icsk->icsk_af_ops = &ipv6_specific; 2198 timer_expires = icsk_timeout(icsk); 2201 timer_expires = icsk_timeout(icsk); 2233 icsk->icsk_retransmits, 2235 icsk->icsk_probes_out, [all …]
|