Lines Matching refs:tp
30 const struct tcp_sock *tp = tcp_sk(sk); in tcp_clamp_rto_to_user_timeout() local
38 elapsed = tcp_time_stamp_ts(tp) - tp->retrans_stamp; in tcp_clamp_rto_to_user_timeout()
39 if (tp->tcp_usec_ts) in tcp_clamp_rto_to_user_timeout()
107 struct tcp_sock *tp = tcp_sk(sk); in tcp_out_of_resources() local
112 if ((s32)(tcp_jiffies32 - tp->lsndtime) > 2*tcp_rto_max(sk) || !do_reset) in tcp_out_of_resources()
122 if ((s32)(tcp_jiffies32 - tp->lsndtime) <= TCP_TIMEWAIT_LEN || in tcp_out_of_resources()
124 (!tp->snd_wnd && !tp->packets_out)) in tcp_out_of_resources()
217 struct tcp_sock *tp = tcp_sk(sk); in retransmits_timed_out() local
223 start_ts = tp->retrans_stamp; in retransmits_timed_out()
232 if (tp->tcp_usec_ts) { in retransmits_timed_out()
234 delta = tp->tcp_mstamp - start_ts + jiffies_to_usecs(1); in retransmits_timed_out()
237 return (s32)(tcp_time_stamp_ts(tp) - start_ts - timeout) >= 0; in retransmits_timed_out()
244 struct tcp_sock *tp = tcp_sk(sk); in tcp_write_timeout() local
287 if (BPF_SOCK_OPS_TEST_FLAG(tp, BPF_SOCK_OPS_RTO_CB_FLAG)) in tcp_write_timeout()
299 tp->timeout_rehash++; in tcp_write_timeout()
310 struct tcp_sock *tp = tcp_sk(sk); in tcp_delack_timer_handler() local
316 if (tp->compressed_ack) { in tcp_delack_timer_handler()
317 tcp_mstamp_refresh(tp); in tcp_delack_timer_handler()
343 tcp_mstamp_refresh(tp); in tcp_delack_timer_handler()
391 struct tcp_sock *tp = tcp_sk(sk); in tcp_probe_timer() local
394 if (tp->packets_out || !skb) { in tcp_probe_timer()
441 struct tcp_sock *tp = tcp_sk(sk); in tcp_update_rto_stats() local
444 tp->total_rto_recoveries++; in tcp_update_rto_stats()
445 tp->rto_stamp = tcp_time_stamp_ms(tp); in tcp_update_rto_stats()
448 tp->total_rto++; in tcp_update_rto_stats()
458 struct tcp_sock *tp = tcp_sk(sk); in tcp_fastopen_synack_timer() local
484 if (!tp->retrans_stamp) in tcp_fastopen_synack_timer()
485 tp->retrans_stamp = tcp_time_stamp_ts(tp); in tcp_fastopen_synack_timer()
496 const struct tcp_sock *tp = tcp_sk(sk); in tcp_rtx_probe0_timed_out() local
513 rcv_delta = icsk_timeout(icsk) - tp->rcv_tstamp; in tcp_rtx_probe0_timed_out()
533 struct tcp_sock *tp = tcp_sk(sk); in tcp_retransmit_timer() local
539 req = rcu_dereference_protected(tp->fastopen_rsk, in tcp_retransmit_timer()
551 if (!tp->packets_out) in tcp_retransmit_timer()
558 if (!tp->snd_wnd && !sock_flag(sk, SOCK_DEAD) && in tcp_retransmit_timer()
568 rtx_delta = tcp_time_stamp_ts(tp) - (tp->retrans_stamp ?: in tcp_retransmit_timer()
569 tcp_skb_timestamp_ts(tp->tcp_usec_ts, skb)); in tcp_retransmit_timer()
570 if (tp->tcp_usec_ts) in tcp_retransmit_timer()
576 inet->inet_num, tp->snd_una, tp->snd_nxt, in tcp_retransmit_timer()
577 jiffies_to_msecs(jiffies - tp->rcv_tstamp), in tcp_retransmit_timer()
584 inet->inet_num, tp->snd_una, tp->snd_nxt, in tcp_retransmit_timer()
585 jiffies_to_msecs(jiffies - tp->rcv_tstamp), in tcp_retransmit_timer()
607 if (tcp_is_sack(tp)) in tcp_retransmit_timer()
614 tp->sacked_out) { in tcp_retransmit_timer()
615 if (tcp_is_sack(tp)) in tcp_retransmit_timer()
664 (tp->thin_lto || READ_ONCE(net->ipv4.sysctl_tcp_thin_linear_timeouts)) && in tcp_retransmit_timer()
665 tcp_stream_is_thin(tp) && in tcp_retransmit_timer()
668 icsk->icsk_rto = clamp(__tcp_set_rto(tp), in tcp_retransmit_timer()
672 tp->total_rto > in tcp_retransmit_timer()
783 struct tcp_sock *tp = tcp_sk(sk); in tcp_keepalive_timer() local
799 tcp_mstamp_refresh(tp); in tcp_keepalive_timer()
801 if (READ_ONCE(tp->linger2) >= 0) { in tcp_keepalive_timer()
817 elapsed = keepalive_time_when(tp); in tcp_keepalive_timer()
820 if (tp->packets_out || !tcp_write_queue_empty(sk)) in tcp_keepalive_timer()
823 elapsed = keepalive_time_elapsed(tp); in tcp_keepalive_timer()
825 if (elapsed >= keepalive_time_when(tp)) { in tcp_keepalive_timer()
835 icsk->icsk_probes_out >= keepalive_probes(tp))) { in tcp_keepalive_timer()
843 elapsed = keepalive_intvl_when(tp); in tcp_keepalive_timer()
852 elapsed = keepalive_time_when(tp) - elapsed; in tcp_keepalive_timer()
869 struct tcp_sock *tp = container_of(timer, struct tcp_sock, compressed_ack_timer); in tcp_compressed_ack_kick() local
870 struct sock *sk = (struct sock *)tp; in tcp_compressed_ack_kick()
874 if (tp->compressed_ack) { in tcp_compressed_ack_kick()
879 tp->compressed_ack--; in tcp_compressed_ack_kick()
880 tcp_mstamp_refresh(tp); in tcp_compressed_ack_kick()