net/mptcp/mib.c

0001 // SPDX-License-Identifier: GPL-2.0-or-later
0002
0003 #include <linux/seq_file.h>
0004 #include <net/ip.h>
0005 #include <net/mptcp.h>
0006 #include <net/snmp.h>
0007 #include <net/net_namespace.h>
0008
0009 #include "mib.h"
0010
0011 static const struct snmp_mib mptcp_snmp_list[] = {
0012     SNMP_MIB_ITEM("MPCapableSYNRX", MPTCP_MIB_MPCAPABLEPASSIVE),
0013     SNMP_MIB_ITEM("MPCapableSYNTX", MPTCP_MIB_MPCAPABLEACTIVE),
0014     SNMP_MIB_ITEM("MPCapableSYNACKRX", MPTCP_MIB_MPCAPABLEACTIVEACK),
0015     SNMP_MIB_ITEM("MPCapableACKRX", MPTCP_MIB_MPCAPABLEPASSIVEACK),
0016     SNMP_MIB_ITEM("MPCapableFallbackACK", MPTCP_MIB_MPCAPABLEPASSIVEFALLBACK),
0017     SNMP_MIB_ITEM("MPCapableFallbackSYNACK", MPTCP_MIB_MPCAPABLEACTIVEFALLBACK),
0018     SNMP_MIB_ITEM("MPFallbackTokenInit", MPTCP_MIB_TOKENFALLBACKINIT),
0019     SNMP_MIB_ITEM("MPTCPRetrans", MPTCP_MIB_RETRANSSEGS),
0020     SNMP_MIB_ITEM("MPJoinNoTokenFound", MPTCP_MIB_JOINNOTOKEN),
0021     SNMP_MIB_ITEM("MPJoinSynRx", MPTCP_MIB_JOINSYNRX),
0022     SNMP_MIB_ITEM("MPJoinSynAckRx", MPTCP_MIB_JOINSYNACKRX),
0023     SNMP_MIB_ITEM("MPJoinSynAckHMacFailure", MPTCP_MIB_JOINSYNACKMAC),
0024     SNMP_MIB_ITEM("MPJoinAckRx", MPTCP_MIB_JOINACKRX),
0025     SNMP_MIB_ITEM("MPJoinAckHMacFailure", MPTCP_MIB_JOINACKMAC),
0026     SNMP_MIB_ITEM("DSSNotMatching", MPTCP_MIB_DSSNOMATCH),
0027     SNMP_MIB_ITEM("InfiniteMapTx", MPTCP_MIB_INFINITEMAPTX),
0028     SNMP_MIB_ITEM("InfiniteMapRx", MPTCP_MIB_INFINITEMAPRX),
0029     SNMP_MIB_ITEM("DSSNoMatchTCP", MPTCP_MIB_DSSTCPMISMATCH),
0030     SNMP_MIB_ITEM("DataCsumErr", MPTCP_MIB_DATACSUMERR),
0031     SNMP_MIB_ITEM("OFOQueueTail", MPTCP_MIB_OFOQUEUETAIL),
0032     SNMP_MIB_ITEM("OFOQueue", MPTCP_MIB_OFOQUEUE),
0033     SNMP_MIB_ITEM("OFOMerge", MPTCP_MIB_OFOMERGE),
0034     SNMP_MIB_ITEM("NoDSSInWindow", MPTCP_MIB_NODSSWINDOW),
0035     SNMP_MIB_ITEM("DuplicateData", MPTCP_MIB_DUPDATA),
0036     SNMP_MIB_ITEM("AddAddr", MPTCP_MIB_ADDADDR),
0037     SNMP_MIB_ITEM("EchoAdd", MPTCP_MIB_ECHOADD),
0038     SNMP_MIB_ITEM("PortAdd", MPTCP_MIB_PORTADD),
0039     SNMP_MIB_ITEM("AddAddrDrop", MPTCP_MIB_ADDADDRDROP),
0040     SNMP_MIB_ITEM("MPJoinPortSynRx", MPTCP_MIB_JOINPORTSYNRX),
0041     SNMP_MIB_ITEM("MPJoinPortSynAckRx", MPTCP_MIB_JOINPORTSYNACKRX),
0042     SNMP_MIB_ITEM("MPJoinPortAckRx", MPTCP_MIB_JOINPORTACKRX),
0043     SNMP_MIB_ITEM("MismatchPortSynRx", MPTCP_MIB_MISMATCHPORTSYNRX),
0044     SNMP_MIB_ITEM("MismatchPortAckRx", MPTCP_MIB_MISMATCHPORTACKRX),
0045     SNMP_MIB_ITEM("RmAddr", MPTCP_MIB_RMADDR),
0046     SNMP_MIB_ITEM("RmAddrDrop", MPTCP_MIB_RMADDRDROP),
0047     SNMP_MIB_ITEM("RmSubflow", MPTCP_MIB_RMSUBFLOW),
0048     SNMP_MIB_ITEM("MPPrioTx", MPTCP_MIB_MPPRIOTX),
0049     SNMP_MIB_ITEM("MPPrioRx", MPTCP_MIB_MPPRIORX),
0050     SNMP_MIB_ITEM("MPFailTx", MPTCP_MIB_MPFAILTX),
0051     SNMP_MIB_ITEM("MPFailRx", MPTCP_MIB_MPFAILRX),
0052     SNMP_MIB_ITEM("MPFastcloseTx", MPTCP_MIB_MPFASTCLOSETX),
0053     SNMP_MIB_ITEM("MPFastcloseRx", MPTCP_MIB_MPFASTCLOSERX),
0054     SNMP_MIB_ITEM("MPRstTx", MPTCP_MIB_MPRSTTX),
0055     SNMP_MIB_ITEM("MPRstRx", MPTCP_MIB_MPRSTRX),
0056     SNMP_MIB_ITEM("RcvPruned", MPTCP_MIB_RCVPRUNED),
0057     SNMP_MIB_ITEM("SubflowStale", MPTCP_MIB_SUBFLOWSTALE),
0058     SNMP_MIB_ITEM("SubflowRecover", MPTCP_MIB_SUBFLOWRECOVER),
0059     SNMP_MIB_ITEM("SndWndShared", MPTCP_MIB_SNDWNDSHARED),
0060     SNMP_MIB_ITEM("RcvWndShared", MPTCP_MIB_RCVWNDSHARED),
0061     SNMP_MIB_ITEM("RcvWndConflictUpdate", MPTCP_MIB_RCVWNDCONFLICTUPDATE),
0062     SNMP_MIB_ITEM("RcvWndConflict", MPTCP_MIB_RCVWNDCONFLICT),
0063     SNMP_MIB_SENTINEL
0064 };
0065
0066 /* mptcp_mib_alloc - allocate percpu mib counters
0067  *
0068  * These are allocated when the first mptcp socket is created so
0069  * we do not waste percpu memory if mptcp isn't in use.
0070  */
0071 bool mptcp_mib_alloc(struct net *net)
0072 {
0073     struct mptcp_mib __percpu *mib = alloc_percpu(struct mptcp_mib);
0074
0075     if (!mib)
0076         return false;
0077
0078     if (cmpxchg(&net->mib.mptcp_statistics, NULL, mib))
0079         free_percpu(mib);
0080
0081     return true;
0082 }
0083
0084 void mptcp_seq_show(struct seq_file *seq)
0085 {
0086     unsigned long sum[ARRAY_SIZE(mptcp_snmp_list) - 1];
0087     struct net *net = seq->private;
0088     int i;
0089
0090     seq_puts(seq, "MPTcpExt:");
0091     for (i = 0; mptcp_snmp_list[i].name; i++)
0092         seq_printf(seq, " %s", mptcp_snmp_list[i].name);
0093
0094     seq_puts(seq, "\nMPTcpExt:");
0095
0096     memset(sum, 0, sizeof(sum));
0097     if (net->mib.mptcp_statistics)
0098         snmp_get_cpu_field_batch(sum, mptcp_snmp_list,
0099                      net->mib.mptcp_statistics);
0100
0101     for (i = 0; mptcp_snmp_list[i].name; i++)
0102         seq_printf(seq, " %lu", sum[i]);
0103
0104     seq_putc(seq, '\n');
0105 }