Lines Matching refs:tp
31 const struct tcp_sock *tp = tcp_sk(sk); in tcp_clamp_rto_to_user_timeout() local
39 elapsed = tcp_time_stamp_ts(tp) - tp->retrans_stamp; in tcp_clamp_rto_to_user_timeout()
40 if (tp->tcp_usec_ts) in tcp_clamp_rto_to_user_timeout()
109 struct tcp_sock *tp = tcp_sk(sk); in tcp_out_of_resources() local
114 if ((s32)(tcp_jiffies32 - tp->lsndtime) > 2*tcp_rto_max(sk) || !do_reset) in tcp_out_of_resources()
124 if ((s32)(tcp_jiffies32 - tp->lsndtime) <= TCP_TIMEWAIT_LEN || in tcp_out_of_resources()
126 (!tp->snd_wnd && !tp->packets_out)) in tcp_out_of_resources()
219 struct tcp_sock *tp = tcp_sk(sk); in retransmits_timed_out() local
225 start_ts = tp->retrans_stamp; in retransmits_timed_out()
234 if (tp->tcp_usec_ts) { in retransmits_timed_out()
236 delta = tp->tcp_mstamp - start_ts + jiffies_to_usecs(1); in retransmits_timed_out()
239 return (s32)(tcp_time_stamp_ts(tp) - start_ts - timeout) >= 0; in retransmits_timed_out()
246 struct tcp_sock *tp = tcp_sk(sk); in tcp_write_timeout() local
289 if (BPF_SOCK_OPS_TEST_FLAG(tp, BPF_SOCK_OPS_RTO_CB_FLAG)) in tcp_write_timeout()
301 WRITE_ONCE(tp->timeout_rehash, tp->timeout_rehash + 1); in tcp_write_timeout()
312 struct tcp_sock *tp = tcp_sk(sk); in tcp_delack_timer_handler() local
318 if (tp->compressed_ack) { in tcp_delack_timer_handler()
319 tcp_mstamp_refresh(tp); in tcp_delack_timer_handler()
347 tcp_mstamp_refresh(tp); in tcp_delack_timer_handler()
395 struct tcp_sock *tp = tcp_sk(sk); in tcp_probe_timer() local
398 if (tp->packets_out || !skb) { in tcp_probe_timer()
445 struct tcp_sock *tp = tcp_sk(sk); in tcp_update_rto_stats() local
448 tp->total_rto_recoveries++; in tcp_update_rto_stats()
449 tp->rto_stamp = tcp_time_stamp_ms(tp); in tcp_update_rto_stats()
452 tp->total_rto++; in tcp_update_rto_stats()
462 struct tcp_sock *tp = tcp_sk(sk); in tcp_fastopen_synack_timer() local
490 if (!tp->retrans_stamp) in tcp_fastopen_synack_timer()
491 tp->retrans_stamp = tcp_time_stamp_ts(tp); in tcp_fastopen_synack_timer()
502 const struct tcp_sock *tp = tcp_sk(sk); in tcp_rtx_probe0_timed_out() local
519 rcv_delta = tcp_timeout_expires(sk) - tp->rcv_tstamp; in tcp_rtx_probe0_timed_out()
539 struct tcp_sock *tp = tcp_sk(sk); in tcp_retransmit_timer() local
545 req = rcu_dereference_protected(tp->fastopen_rsk, in tcp_retransmit_timer()
557 if (!tp->packets_out) in tcp_retransmit_timer()
564 if (!tp->snd_wnd && !sock_flag(sk, SOCK_DEAD) && in tcp_retransmit_timer()
574 rtx_delta = tcp_time_stamp_ts(tp) - (tp->retrans_stamp ?: in tcp_retransmit_timer()
575 tcp_skb_timestamp_ts(tp->tcp_usec_ts, skb)); in tcp_retransmit_timer()
576 if (tp->tcp_usec_ts) in tcp_retransmit_timer()
582 inet->inet_num, tp->snd_una, tp->snd_nxt, in tcp_retransmit_timer()
583 jiffies_to_msecs(jiffies - tp->rcv_tstamp), in tcp_retransmit_timer()
590 inet->inet_num, tp->snd_una, tp->snd_nxt, in tcp_retransmit_timer()
591 jiffies_to_msecs(jiffies - tp->rcv_tstamp), in tcp_retransmit_timer()
613 if (tcp_is_sack(tp)) in tcp_retransmit_timer()
620 tp->sacked_out) { in tcp_retransmit_timer()
621 if (tcp_is_sack(tp)) in tcp_retransmit_timer()
670 (tp->thin_lto || READ_ONCE(net->ipv4.sysctl_tcp_thin_linear_timeouts)) && in tcp_retransmit_timer()
671 tcp_stream_is_thin(tp) && in tcp_retransmit_timer()
674 icsk->icsk_rto = clamp(__tcp_set_rto(tp), in tcp_retransmit_timer()
678 tp->total_rto > in tcp_retransmit_timer()
786 struct tcp_sock *tp = tcp_sk(sk); in tcp_keepalive_timer() local
802 tcp_mstamp_refresh(tp); in tcp_keepalive_timer()
804 if (READ_ONCE(tp->linger2) >= 0) { in tcp_keepalive_timer()
820 elapsed = keepalive_time_when(tp); in tcp_keepalive_timer()
823 if (tp->packets_out || !tcp_write_queue_empty(sk)) in tcp_keepalive_timer()
826 elapsed = keepalive_time_elapsed(tp); in tcp_keepalive_timer()
828 if (elapsed >= keepalive_time_when(tp)) { in tcp_keepalive_timer()
838 icsk->icsk_probes_out >= keepalive_probes(tp))) { in tcp_keepalive_timer()
846 elapsed = keepalive_intvl_when(tp); in tcp_keepalive_timer()
855 elapsed = keepalive_time_when(tp) - elapsed; in tcp_keepalive_timer()
872 struct tcp_sock *tp = container_of(timer, struct tcp_sock, compressed_ack_timer); in tcp_compressed_ack_kick() local
873 struct sock *sk = (struct sock *)tp; in tcp_compressed_ack_kick()
877 if (tp->compressed_ack) { in tcp_compressed_ack_kick()
882 tp->compressed_ack--; in tcp_compressed_ack_kick()
883 tcp_mstamp_refresh(tp); in tcp_compressed_ack_kick()