Commit a69258f7 authored by Yuchung Cheng's avatar Yuchung Cheng Committed by David S. Miller

tcp: remove DELAYED ACK events in DCTCP

After fixing the way DCTCP tracking delayed ACKs, the delayed-ACK
related callbacks are no longer needed
Signed-off-by: default avatarYuchung Cheng <ycheng@google.com>
Signed-off-by: default avatarEric Dumazet <edumazet@google.com>
Acked-by: default avatarNeal Cardwell <ncardwell@google.com>
Acked-by: default avatarLawrence Brakmo <brakmo@fb.com>
Signed-off-by: default avatarDavid S. Miller <davem@davemloft.net>
parent b0c05d0e
...@@ -912,8 +912,6 @@ enum tcp_ca_event { ...@@ -912,8 +912,6 @@ enum tcp_ca_event {
CA_EVENT_LOSS, /* loss timeout */ CA_EVENT_LOSS, /* loss timeout */
CA_EVENT_ECN_NO_CE, /* ECT set, but not CE marked */ CA_EVENT_ECN_NO_CE, /* ECT set, but not CE marked */
CA_EVENT_ECN_IS_CE, /* received CE marked IP packet */ CA_EVENT_ECN_IS_CE, /* received CE marked IP packet */
CA_EVENT_DELAYED_ACK, /* Delayed ack is sent */
CA_EVENT_NON_DELAYED_ACK,
}; };
/* Information about inbound ACK, passed to cong_ops->in_ack_event() */ /* Information about inbound ACK, passed to cong_ops->in_ack_event() */
......
...@@ -55,7 +55,6 @@ struct dctcp { ...@@ -55,7 +55,6 @@ struct dctcp {
u32 dctcp_alpha; u32 dctcp_alpha;
u32 next_seq; u32 next_seq;
u32 ce_state; u32 ce_state;
u32 delayed_ack_reserved;
u32 loss_cwnd; u32 loss_cwnd;
}; };
...@@ -96,7 +95,6 @@ static void dctcp_init(struct sock *sk) ...@@ -96,7 +95,6 @@ static void dctcp_init(struct sock *sk)
ca->dctcp_alpha = min(dctcp_alpha_on_init, DCTCP_MAX_ALPHA); ca->dctcp_alpha = min(dctcp_alpha_on_init, DCTCP_MAX_ALPHA);
ca->delayed_ack_reserved = 0;
ca->loss_cwnd = 0; ca->loss_cwnd = 0;
ca->ce_state = 0; ca->ce_state = 0;
...@@ -250,25 +248,6 @@ static void dctcp_state(struct sock *sk, u8 new_state) ...@@ -250,25 +248,6 @@ static void dctcp_state(struct sock *sk, u8 new_state)
} }
} }
static void dctcp_update_ack_reserved(struct sock *sk, enum tcp_ca_event ev)
{
struct dctcp *ca = inet_csk_ca(sk);
switch (ev) {
case CA_EVENT_DELAYED_ACK:
if (!ca->delayed_ack_reserved)
ca->delayed_ack_reserved = 1;
break;
case CA_EVENT_NON_DELAYED_ACK:
if (ca->delayed_ack_reserved)
ca->delayed_ack_reserved = 0;
break;
default:
/* Don't care for the rest. */
break;
}
}
static void dctcp_cwnd_event(struct sock *sk, enum tcp_ca_event ev) static void dctcp_cwnd_event(struct sock *sk, enum tcp_ca_event ev)
{ {
switch (ev) { switch (ev) {
...@@ -278,10 +257,6 @@ static void dctcp_cwnd_event(struct sock *sk, enum tcp_ca_event ev) ...@@ -278,10 +257,6 @@ static void dctcp_cwnd_event(struct sock *sk, enum tcp_ca_event ev)
case CA_EVENT_ECN_NO_CE: case CA_EVENT_ECN_NO_CE:
dctcp_ce_state_1_to_0(sk); dctcp_ce_state_1_to_0(sk);
break; break;
case CA_EVENT_DELAYED_ACK:
case CA_EVENT_NON_DELAYED_ACK:
dctcp_update_ack_reserved(sk, ev);
break;
default: default:
/* Don't care for the rest. */ /* Don't care for the rest. */
break; break;
......
...@@ -3523,8 +3523,6 @@ void tcp_send_delayed_ack(struct sock *sk) ...@@ -3523,8 +3523,6 @@ void tcp_send_delayed_ack(struct sock *sk)
int ato = icsk->icsk_ack.ato; int ato = icsk->icsk_ack.ato;
unsigned long timeout; unsigned long timeout;
tcp_ca_event(sk, CA_EVENT_DELAYED_ACK);
if (ato > TCP_DELACK_MIN) { if (ato > TCP_DELACK_MIN) {
const struct tcp_sock *tp = tcp_sk(sk); const struct tcp_sock *tp = tcp_sk(sk);
int max_ato = HZ / 2; int max_ato = HZ / 2;
...@@ -3581,8 +3579,6 @@ void tcp_send_ack(struct sock *sk) ...@@ -3581,8 +3579,6 @@ void tcp_send_ack(struct sock *sk)
if (sk->sk_state == TCP_CLOSE) if (sk->sk_state == TCP_CLOSE)
return; return;
tcp_ca_event(sk, CA_EVENT_NON_DELAYED_ACK);
/* We are not putting this on the write queue, so /* We are not putting this on the write queue, so
* tcp_transmit_skb() will set the ownership to this * tcp_transmit_skb() will set the ownership to this
* sock. * sock.
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment