~ [ source navigation ] ~ [ diff markup ] ~ [ identifier search ] ~

TOMOYO Linux Cross Reference
Linux/net/ipv4/tcp_dctcp.h

Version: ~ [ linux-6.11.5 ] ~ [ linux-6.10.14 ] ~ [ linux-6.9.12 ] ~ [ linux-6.8.12 ] ~ [ linux-6.7.12 ] ~ [ linux-6.6.58 ] ~ [ linux-6.5.13 ] ~ [ linux-6.4.16 ] ~ [ linux-6.3.13 ] ~ [ linux-6.2.16 ] ~ [ linux-6.1.114 ] ~ [ linux-6.0.19 ] ~ [ linux-5.19.17 ] ~ [ linux-5.18.19 ] ~ [ linux-5.17.15 ] ~ [ linux-5.16.20 ] ~ [ linux-5.15.169 ] ~ [ linux-5.14.21 ] ~ [ linux-5.13.19 ] ~ [ linux-5.12.19 ] ~ [ linux-5.11.22 ] ~ [ linux-5.10.228 ] ~ [ linux-5.9.16 ] ~ [ linux-5.8.18 ] ~ [ linux-5.7.19 ] ~ [ linux-5.6.19 ] ~ [ linux-5.5.19 ] ~ [ linux-5.4.284 ] ~ [ linux-5.3.18 ] ~ [ linux-5.2.21 ] ~ [ linux-5.1.21 ] ~ [ linux-5.0.21 ] ~ [ linux-4.20.17 ] ~ [ linux-4.19.322 ] ~ [ linux-4.18.20 ] ~ [ linux-4.17.19 ] ~ [ linux-4.16.18 ] ~ [ linux-4.15.18 ] ~ [ linux-4.14.336 ] ~ [ linux-4.13.16 ] ~ [ linux-4.12.14 ] ~ [ linux-4.11.12 ] ~ [ linux-4.10.17 ] ~ [ linux-4.9.337 ] ~ [ linux-4.4.302 ] ~ [ linux-3.10.108 ] ~ [ linux-2.6.32.71 ] ~ [ linux-2.6.0 ] ~ [ linux-2.4.37.11 ] ~ [ unix-v6-master ] ~ [ ccs-tools-1.8.9 ] ~ [ policy-sample ] ~
Architecture: ~ [ i386 ] ~ [ alpha ] ~ [ m68k ] ~ [ mips ] ~ [ ppc ] ~ [ sparc ] ~ [ sparc64 ] ~

  1 #ifndef _TCP_DCTCP_H
  2 #define _TCP_DCTCP_H
  3 
  4 static inline void dctcp_ece_ack_cwr(struct sock *sk, u32 ce_state)
  5 {
  6         struct tcp_sock *tp = tcp_sk(sk);
  7 
  8         if (ce_state == 1)
  9                 tp->ecn_flags |= TCP_ECN_DEMAND_CWR;
 10         else
 11                 tp->ecn_flags &= ~TCP_ECN_DEMAND_CWR;
 12 }
 13 
 14 /* Minimal DCTP CE state machine:
 15  *
 16  * S:   0 <- last pkt was non-CE
 17  *      1 <- last pkt was CE
 18  */
 19 static inline void dctcp_ece_ack_update(struct sock *sk, enum tcp_ca_event evt,
 20                                         u32 *prior_rcv_nxt, u32 *ce_state)
 21 {
 22         u32 new_ce_state = (evt == CA_EVENT_ECN_IS_CE) ? 1 : 0;
 23 
 24         if (*ce_state != new_ce_state) {
 25                 /* CE state has changed, force an immediate ACK to
 26                  * reflect the new CE state. If an ACK was delayed,
 27                  * send that first to reflect the prior CE state.
 28                  */
 29                 if (inet_csk(sk)->icsk_ack.pending & ICSK_ACK_TIMER) {
 30                         dctcp_ece_ack_cwr(sk, *ce_state);
 31                         __tcp_send_ack(sk, *prior_rcv_nxt);
 32                 }
 33                 inet_csk(sk)->icsk_ack.pending |= ICSK_ACK_NOW;
 34         }
 35         *prior_rcv_nxt = tcp_sk(sk)->rcv_nxt;
 36         *ce_state = new_ce_state;
 37         dctcp_ece_ack_cwr(sk, new_ce_state);
 38 }
 39 
 40 #endif
 41 

~ [ source navigation ] ~ [ diff markup ] ~ [ identifier search ] ~

kernel.org | git.kernel.org | LWN.net | Project Home | SVN repository | Mail admin

Linux® is a registered trademark of Linus Torvalds in the United States and other countries.
TOMOYO® is a registered trademark of NTT DATA CORPORATION.

sflogo.php