51 static __always_inline void dctcp_reset(const struct tcp_sock *tp,  in dctcp_reset()  argument
54 	ca->next_seq = tp->snd_nxt;  in dctcp_reset()
56 	ca->old_delivered = tp->delivered;  in dctcp_reset()
57 	ca->old_delivered_ce = tp->delivered_ce;  in dctcp_reset()
63 	const struct tcp_sock *tp = tcp_sk(sk);  in BPF_PROG()  local
67 	if (!(tp->ecn_flags & TCP_ECN_OK) && fallback[0]) {  in BPF_PROG()
94 	ca->prior_rcv_nxt = tp->rcv_nxt;  in BPF_PROG()
99 	stg = bpf_sk_storage_get(&sk_stg_map, (void *)tp, NULL, 0);  in BPF_PROG()
102 		bpf_sk_storage_delete(&sk_stg_map, (void *)tp);  in BPF_PROG()
104 	dctcp_reset(tp, ca);  in BPF_PROG()
111 	struct tcp_sock *tp = tcp_sk(sk);  in BPF_PROG()  local
113 	ca->loss_cwnd = tp->snd_cwnd;  in BPF_PROG()
114 	return max(tp->snd_cwnd - ((tp->snd_cwnd * ca->dctcp_alpha) >> 11U), 2U);  in BPF_PROG()
120 	const struct tcp_sock *tp = tcp_sk(sk);  in BPF_PROG()  local
124 	if (!before(tp->snd_una, ca->next_seq)) {  in BPF_PROG()
125 		__u32 delivered_ce = tp->delivered_ce - ca->old_delivered_ce;  in BPF_PROG()
132 			__u32 delivered = tp->delivered - ca->old_delivered;  in BPF_PROG()
143 		dctcp_reset(tp, ca);  in BPF_PROG()
150 	struct tcp_sock *tp = tcp_sk(sk);  in dctcp_react_to_loss()  local
152 	ca->loss_cwnd = tp->snd_cwnd;  in dctcp_react_to_loss()
153 	tp->snd_ssthresh = max(tp->snd_cwnd >> 1U, 2U);  in dctcp_react_to_loss()
169 	struct tcp_sock *tp = tcp_sk(sk);  in dctcp_ece_ack_cwr()  local
172 		tp->ecn_flags |= TCP_ECN_DEMAND_CWR;  in dctcp_ece_ack_cwr()
174 		tp->ecn_flags &= ~TCP_ECN_DEMAND_CWR;  in dctcp_ece_ack_cwr()