Lines Matching refs:icsk
28 struct inet_connection_sock *icsk = inet_csk(sk); in tcp_clamp_rto_to_user_timeout() local
33 if (!icsk->icsk_user_timeout) in tcp_clamp_rto_to_user_timeout()
34 return icsk->icsk_rto; in tcp_clamp_rto_to_user_timeout()
36 remaining = icsk->icsk_user_timeout - elapsed; in tcp_clamp_rto_to_user_timeout()
40 return min_t(u32, icsk->icsk_rto, msecs_to_jiffies(remaining)); in tcp_clamp_rto_to_user_timeout()
142 static void tcp_mtu_probing(struct inet_connection_sock *icsk, struct sock *sk) in tcp_mtu_probing() argument
151 if (!icsk->icsk_mtup.enabled) { in tcp_mtu_probing()
152 icsk->icsk_mtup.enabled = 1; in tcp_mtu_probing()
153 icsk->icsk_mtup.probe_timestamp = tcp_jiffies32; in tcp_mtu_probing()
155 mss = tcp_mtu_to_mss(sk, icsk->icsk_mtup.search_low) >> 1; in tcp_mtu_probing()
159 icsk->icsk_mtup.search_low = tcp_mss_to_mtu(sk, mss); in tcp_mtu_probing()
161 tcp_sync_mss(sk, icsk->icsk_pmtu_cookie); in tcp_mtu_probing()
215 struct inet_connection_sock *icsk = inet_csk(sk); in tcp_write_timeout() local
222 if (icsk->icsk_retransmits) { in tcp_write_timeout()
227 retry_until = icsk->icsk_syn_retries ? : net->ipv4.sysctl_tcp_syn_retries; in tcp_write_timeout()
228 expired = icsk->icsk_retransmits >= retry_until; in tcp_write_timeout()
232 tcp_mtu_probing(icsk, sk); in tcp_write_timeout()
241 const bool alive = icsk->icsk_rto < TCP_RTO_MAX; in tcp_write_timeout()
253 icsk->icsk_user_timeout); in tcp_write_timeout()
258 icsk->icsk_retransmits, in tcp_write_timeout()
259 icsk->icsk_rto, (int)expired); in tcp_write_timeout()
273 struct inet_connection_sock *icsk = inet_csk(sk); in tcp_delack_timer_handler() local
278 !(icsk->icsk_ack.pending & ICSK_ACK_TIMER)) in tcp_delack_timer_handler()
281 if (time_after(icsk->icsk_ack.timeout, jiffies)) { in tcp_delack_timer_handler()
282 sk_reset_timer(sk, &icsk->icsk_delack_timer, icsk->icsk_ack.timeout); in tcp_delack_timer_handler()
285 icsk->icsk_ack.pending &= ~ICSK_ACK_TIMER; in tcp_delack_timer_handler()
290 icsk->icsk_ack.ato = min(icsk->icsk_ack.ato << 1, icsk->icsk_rto); in tcp_delack_timer_handler()
296 icsk->icsk_ack.ato = TCP_ATO_MIN; in tcp_delack_timer_handler()
320 struct inet_connection_sock *icsk = in tcp_delack_timer() local
321 from_timer(icsk, t, icsk_delack_timer); in tcp_delack_timer()
322 struct sock *sk = &icsk->icsk_inet.sk; in tcp_delack_timer()
328 icsk->icsk_ack.blocked = 1; in tcp_delack_timer()
340 struct inet_connection_sock *icsk = inet_csk(sk); in tcp_probe_timer() local
346 icsk->icsk_probes_out = 0; in tcp_probe_timer()
358 if (icsk->icsk_user_timeout) { in tcp_probe_timer()
359 u32 elapsed = tcp_model_timeout(sk, icsk->icsk_probes_out, in tcp_probe_timer()
362 if (elapsed >= icsk->icsk_user_timeout) in tcp_probe_timer()
368 const bool alive = inet_csk_rto_backoff(icsk, TCP_RTO_MAX) < TCP_RTO_MAX; in tcp_probe_timer()
371 if (!alive && icsk->icsk_backoff >= max_probes) in tcp_probe_timer()
377 if (icsk->icsk_probes_out >= max_probes) { in tcp_probe_timer()
391 struct inet_connection_sock *icsk = inet_csk(sk); in tcp_fastopen_synack_timer() local
392 int max_retries = icsk->icsk_syn_retries ? : in tcp_fastopen_synack_timer()
403 if (icsk->icsk_retransmits == 1) in tcp_fastopen_synack_timer()
412 icsk->icsk_retransmits++; in tcp_fastopen_synack_timer()
435 struct inet_connection_sock *icsk = inet_csk(sk); in tcp_retransmit_timer() local
492 if (icsk->icsk_retransmits == 0) { in tcp_retransmit_timer()
495 if (icsk->icsk_ca_state == TCP_CA_Recovery) { in tcp_retransmit_timer()
500 } else if (icsk->icsk_ca_state == TCP_CA_Loss) { in tcp_retransmit_timer()
502 } else if ((icsk->icsk_ca_state == TCP_CA_Disorder) || in tcp_retransmit_timer()
515 icsk->icsk_retransmits++; in tcp_retransmit_timer()
541 icsk->icsk_backoff++; in tcp_retransmit_timer()
556 icsk->icsk_retransmits <= TCP_THIN_LINEAR_RETRIES) { in tcp_retransmit_timer()
557 icsk->icsk_backoff = 0; in tcp_retransmit_timer()
558 icsk->icsk_rto = min(__tcp_set_rto(tp), TCP_RTO_MAX); in tcp_retransmit_timer()
561 icsk->icsk_rto = min(icsk->icsk_rto << 1, TCP_RTO_MAX); in tcp_retransmit_timer()
575 struct inet_connection_sock *icsk = inet_csk(sk); in tcp_write_timer_handler() local
579 !icsk->icsk_pending) in tcp_write_timer_handler()
582 if (time_after(icsk->icsk_timeout, jiffies)) { in tcp_write_timer_handler()
583 sk_reset_timer(sk, &icsk->icsk_retransmit_timer, icsk->icsk_timeout); in tcp_write_timer_handler()
588 event = icsk->icsk_pending; in tcp_write_timer_handler()
598 icsk->icsk_pending = 0; in tcp_write_timer_handler()
602 icsk->icsk_pending = 0; in tcp_write_timer_handler()
613 struct inet_connection_sock *icsk = in tcp_write_timer() local
614 from_timer(icsk, t, icsk_retransmit_timer); in tcp_write_timer()
615 struct sock *sk = &icsk->icsk_inet.sk; in tcp_write_timer()
653 struct inet_connection_sock *icsk = inet_csk(sk); in tcp_keepalive_timer() local
700 if ((icsk->icsk_user_timeout != 0 && in tcp_keepalive_timer()
701 elapsed >= msecs_to_jiffies(icsk->icsk_user_timeout) && in tcp_keepalive_timer()
702 icsk->icsk_probes_out > 0) || in tcp_keepalive_timer()
703 (icsk->icsk_user_timeout == 0 && in tcp_keepalive_timer()
704 icsk->icsk_probes_out >= keepalive_probes(tp))) { in tcp_keepalive_timer()
710 icsk->icsk_probes_out++; in tcp_keepalive_timer()