system/freebsd-src
system/freebsd-src
1
0
Fork 0
mirror of https://github.com/freebsd/freebsd-src synced 2024-07-21 18:27:22 +00:00
Code Issues Actions 2 Packages Projects Releases Wiki Activity

tcp: account sent/received IP ECN markings independently

Browse source 
Have tcpstats (netstat -s) differentiate between received and sent
ECN-marked packets. Also account for IP ECN bits (on TCP packets)
even when the tcp session has not negotiated ECN support.

Event:			IETF 115 Hackathon
Reviewed By:		glebius, tuexen, #transport
Sponsored by:		NetApp, Inc.
Differential Revision:	https://reviews.freebsd.org/D37314
This commit is contained in:
Richard Scheffenegger 2022-11-10 11:35:02 +01:00
parent 8526120ad4
commit 1a70101a87
3 changed files with 44 additions and 24 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

40
sys/netinet/tcp_ecn.c
View file

@ -288,19 +288,19 @@ tcp_ecn_input_segment(struct tcpcb *tp, uint16_t thflags, int tlen, int pkts, in
{
int delta_cep = 0;
if (tp->t_flags2 & (TF2_ECN_PERMIT | TF2_ACE_PERMIT)) {
switch (iptos & IPTOS_ECN_MASK) {
case IPTOS_ECN_CE:
TCPSTAT_INC(tcps_ecn_ce);
break;
case IPTOS_ECN_ECT0:
TCPSTAT_INC(tcps_ecn_ect0);
break;
case IPTOS_ECN_ECT1:
TCPSTAT_INC(tcps_ecn_ect1);
break;
}
switch (iptos & IPTOS_ECN_MASK) {
case IPTOS_ECN_CE:
TCPSTAT_INC(tcps_ecn_rcvce);
break;
case IPTOS_ECN_ECT0:
TCPSTAT_INC(tcps_ecn_rcvect0);
break;
case IPTOS_ECN_ECT1:
TCPSTAT_INC(tcps_ecn_rcvect1);
break;
}
if (tp->t_flags2 & (TF2_ECN_PERMIT | TF2_ACE_PERMIT)) {
if (tp->t_flags2 & TF2_ACE_PERMIT) {
if ((iptos & IPTOS_ECN_MASK) == IPTOS_ECN_CE)
tp->t_rcep += 1;
@ -413,10 +413,10 @@ tcp_ecn_output_established(struct tcpcb *tp, uint16_t *thflags, int len, bool rx
if (newdata) {
if (tp->t_flags2 & TF2_ECN_USE_ECT1) {
ipecn = IPTOS_ECN_ECT1;
TCPSTAT_INC(tcps_ecn_ect1);
TCPSTAT_INC(tcps_ecn_sndect1);
} else {
ipecn = IPTOS_ECN_ECT0;
TCPSTAT_INC(tcps_ecn_ect0);
TCPSTAT_INC(tcps_ecn_sndect0);
}
}
/*
@ -497,6 +497,18 @@ tcp_ecn_syncache_add(uint16_t thflags, int iptos)
{
int scflags = 0;
switch (iptos & IPTOS_ECN_MASK) {
case IPTOS_ECN_CE:
TCPSTAT_INC(tcps_ecn_rcvce);
break;
case IPTOS_ECN_ECT0:
TCPSTAT_INC(tcps_ecn_rcvect0);
break;
case IPTOS_ECN_ECT1:
TCPSTAT_INC(tcps_ecn_rcvect1);
break;
}
switch (thflags & (TH_AE|TH_CWR|TH_ECE)) {
/* no ECN */
case (0|0|0):

12
sys/netinet/tcp_var.h
View file

@ -787,9 +787,9 @@ struct tcpstat {
uint64_t tcps_sack_sboverflow; /* times scoreboard overflowed */
/* ECN related stats */
uint64_t tcps_ecn_ce; /* ECN Congestion Experienced */
uint64_t tcps_ecn_ect0; /* ECN Capable Transport */
uint64_t tcps_ecn_ect1; /* ECN Capable Transport */
uint64_t tcps_ecn_rcvce; /* ECN Congestion Experienced */
uint64_t tcps_ecn_rcvect0; /* ECN Capable Transport */
uint64_t tcps_ecn_rcvect1; /* ECN Capable Transport */
uint64_t tcps_ecn_shs; /* ECN successful handshakes */
uint64_t tcps_ecn_rcwnd; /* # times ECN reduced the cwnd */
@ -824,7 +824,11 @@ struct tcpstat {
uint64_t tcps_ace_ect0; /* ACE SYN packet with ECT0 */
uint64_t tcps_ace_ce; /* ACE SYN packet with CE */
uint64_t _pad[6]; /* 6 TBD placeholder for STABLE */
/* ECN related stats */
uint64_t tcps_ecn_sndect0; /* ECN Capable Transport */
uint64_t tcps_ecn_sndect1; /* ECN Capable Transport */
uint64_t _pad[4]; /* 4 TBD placeholder for STABLE */
};
#define tcps_rcvmemdrop tcps_rcvreassfull /* compat */

16
usr.bin/netstat/inet.c
View file

@ -818,12 +818,16 @@ tcp_stats(u_long off, const char *name, int af1 __unused, int proto __unused)
xo_close_container("sack");
xo_open_container("ecn");
p(tcps_ecn_ce, "\t{:ce-packets/%ju} "
"{N:/packet%s with ECN CE bit set}\n");
p(tcps_ecn_ect0, "\t{:ect0-packets/%ju} "
"{N:/packet%s with ECN ECT(0) bit set}\n");
p(tcps_ecn_ect1, "\t{:ect1-packets/%ju} "
"{N:/packet%s with ECN ECT(1) bit set}\n");
p(tcps_ecn_rcvce, "\t{:received-ce-packets/%ju} "
"{N:/packet%s received with ECN CE bit set}\n");
p(tcps_ecn_rcvect0, "\t{:received-ect0-packets/%ju} "
"{N:/packet%s received with ECN ECT(0) bit set}\n");
p(tcps_ecn_rcvect1, "\t{:received-ect1-packets/%ju} "
"{N:/packet%s received with ECN ECT(1) bit set}\n");
p(tcps_ecn_sndect0, "\t{:sent-ect0-packets/%ju} "
"{N:/packet%s sent with ECN ECT(0) bit set}\n");
p(tcps_ecn_sndect1, "\t{:sent-ect1-packets/%ju} "
"{N:/packet%s sent with ECN ECT(1) bit set}\n");
p(tcps_ecn_shs, "\t{:handshakes/%ju} "
"{N:/successful ECN handshake%s}\n");
p(tcps_ecn_rcwnd, "\t{:congestion-reductions/%ju} "