src/collectors/proc.plugin/proc_net_sctp_snmp.c
// SPDX-License-Identifier: GPL-3.0-or-later
#include "plugin_proc.h"
#define PLUGIN_PROC_MODULE_NET_SCTP_SNMP_NAME "/proc/net/sctp/snmp"
int do_proc_net_sctp_snmp(int update_every, usec_t dt) {
(void)dt;
static procfile *ff = NULL;
static int
do_associations = -1,
do_transitions = -1,
do_packet_errors = -1,
do_packets = -1,
do_fragmentation = -1,
do_chunk_types = -1;
static ARL_BASE *arl_base = NULL;
static unsigned long long SctpCurrEstab = 0ULL;
static unsigned long long SctpActiveEstabs = 0ULL;
static unsigned long long SctpPassiveEstabs = 0ULL;
static unsigned long long SctpAborteds = 0ULL;
static unsigned long long SctpShutdowns = 0ULL;
static unsigned long long SctpOutOfBlues = 0ULL;
static unsigned long long SctpChecksumErrors = 0ULL;
static unsigned long long SctpOutCtrlChunks = 0ULL;
static unsigned long long SctpOutOrderChunks = 0ULL;
static unsigned long long SctpOutUnorderChunks = 0ULL;
static unsigned long long SctpInCtrlChunks = 0ULL;
static unsigned long long SctpInOrderChunks = 0ULL;
static unsigned long long SctpInUnorderChunks = 0ULL;
static unsigned long long SctpFragUsrMsgs = 0ULL;
static unsigned long long SctpReasmUsrMsgs = 0ULL;
static unsigned long long SctpOutSCTPPacks = 0ULL;
static unsigned long long SctpInSCTPPacks = 0ULL;
static unsigned long long SctpT1InitExpireds = 0ULL;
static unsigned long long SctpT1CookieExpireds = 0ULL;
static unsigned long long SctpT2ShutdownExpireds = 0ULL;
static unsigned long long SctpT3RtxExpireds = 0ULL;
static unsigned long long SctpT4RtoExpireds = 0ULL;
static unsigned long long SctpT5ShutdownGuardExpireds = 0ULL;
static unsigned long long SctpDelaySackExpireds = 0ULL;
static unsigned long long SctpAutocloseExpireds = 0ULL;
static unsigned long long SctpT3Retransmits = 0ULL;
static unsigned long long SctpPmtudRetransmits = 0ULL;
static unsigned long long SctpFastRetransmits = 0ULL;
static unsigned long long SctpInPktSoftirq = 0ULL;
static unsigned long long SctpInPktBacklog = 0ULL;
static unsigned long long SctpInPktDiscards = 0ULL;
static unsigned long long SctpInDataChunkDiscards = 0ULL;
if(unlikely(!arl_base)) {
do_associations = config_get_boolean_ondemand("plugin:proc:/proc/net/sctp/snmp", "established associations", CONFIG_BOOLEAN_AUTO);
do_transitions = config_get_boolean_ondemand("plugin:proc:/proc/net/sctp/snmp", "association transitions", CONFIG_BOOLEAN_AUTO);
do_fragmentation = config_get_boolean_ondemand("plugin:proc:/proc/net/sctp/snmp", "fragmentation", CONFIG_BOOLEAN_AUTO);
do_packets = config_get_boolean_ondemand("plugin:proc:/proc/net/sctp/snmp", "packets", CONFIG_BOOLEAN_AUTO);
do_packet_errors = config_get_boolean_ondemand("plugin:proc:/proc/net/sctp/snmp", "packet errors", CONFIG_BOOLEAN_AUTO);
do_chunk_types = config_get_boolean_ondemand("plugin:proc:/proc/net/sctp/snmp", "chunk types", CONFIG_BOOLEAN_AUTO);
arl_base = arl_create("sctp", NULL, 60);
arl_expect(arl_base, "SctpCurrEstab", &SctpCurrEstab);
arl_expect(arl_base, "SctpActiveEstabs", &SctpActiveEstabs);
arl_expect(arl_base, "SctpPassiveEstabs", &SctpPassiveEstabs);
arl_expect(arl_base, "SctpAborteds", &SctpAborteds);
arl_expect(arl_base, "SctpShutdowns", &SctpShutdowns);
arl_expect(arl_base, "SctpOutOfBlues", &SctpOutOfBlues);
arl_expect(arl_base, "SctpChecksumErrors", &SctpChecksumErrors);
arl_expect(arl_base, "SctpOutCtrlChunks", &SctpOutCtrlChunks);
arl_expect(arl_base, "SctpOutOrderChunks", &SctpOutOrderChunks);
arl_expect(arl_base, "SctpOutUnorderChunks", &SctpOutUnorderChunks);
arl_expect(arl_base, "SctpInCtrlChunks", &SctpInCtrlChunks);
arl_expect(arl_base, "SctpInOrderChunks", &SctpInOrderChunks);
arl_expect(arl_base, "SctpInUnorderChunks", &SctpInUnorderChunks);
arl_expect(arl_base, "SctpFragUsrMsgs", &SctpFragUsrMsgs);
arl_expect(arl_base, "SctpReasmUsrMsgs", &SctpReasmUsrMsgs);
arl_expect(arl_base, "SctpOutSCTPPacks", &SctpOutSCTPPacks);
arl_expect(arl_base, "SctpInSCTPPacks", &SctpInSCTPPacks);
arl_expect(arl_base, "SctpT1InitExpireds", &SctpT1InitExpireds);
arl_expect(arl_base, "SctpT1CookieExpireds", &SctpT1CookieExpireds);
arl_expect(arl_base, "SctpT2ShutdownExpireds", &SctpT2ShutdownExpireds);
arl_expect(arl_base, "SctpT3RtxExpireds", &SctpT3RtxExpireds);
arl_expect(arl_base, "SctpT4RtoExpireds", &SctpT4RtoExpireds);
arl_expect(arl_base, "SctpT5ShutdownGuardExpireds", &SctpT5ShutdownGuardExpireds);
arl_expect(arl_base, "SctpDelaySackExpireds", &SctpDelaySackExpireds);
arl_expect(arl_base, "SctpAutocloseExpireds", &SctpAutocloseExpireds);
arl_expect(arl_base, "SctpT3Retransmits", &SctpT3Retransmits);
arl_expect(arl_base, "SctpPmtudRetransmits", &SctpPmtudRetransmits);
arl_expect(arl_base, "SctpFastRetransmits", &SctpFastRetransmits);
arl_expect(arl_base, "SctpInPktSoftirq", &SctpInPktSoftirq);
arl_expect(arl_base, "SctpInPktBacklog", &SctpInPktBacklog);
arl_expect(arl_base, "SctpInPktDiscards", &SctpInPktDiscards);
arl_expect(arl_base, "SctpInDataChunkDiscards", &SctpInDataChunkDiscards);
}
if(unlikely(!ff)) {
char filename[FILENAME_MAX + 1];
snprintfz(filename, FILENAME_MAX, "%s%s", netdata_configured_host_prefix, "/proc/net/sctp/snmp");
ff = procfile_open(config_get("plugin:proc:/proc/net/sctp/snmp", "filename to monitor", filename), " \t:", PROCFILE_FLAG_DEFAULT);
if(unlikely(!ff))
return 1;
}
ff = procfile_readall(ff);
if(unlikely(!ff))
return 0; // we return 0, so that we will retry to open it next time
size_t lines = procfile_lines(ff), l;
arl_begin(arl_base);
for(l = 0; l < lines ;l++) {
size_t words = procfile_linewords(ff, l);
if(unlikely(words < 2)) {
if(unlikely(words)) collector_error("Cannot read /proc/net/sctp/snmp line %zu. Expected 2 params, read %zu.", l, words);
continue;
}
if(unlikely(arl_check(arl_base,
procfile_lineword(ff, l, 0),
procfile_lineword(ff, l, 1)))) break;
}
// --------------------------------------------------------------------
if(do_associations == CONFIG_BOOLEAN_YES || (do_associations == CONFIG_BOOLEAN_AUTO &&
(SctpCurrEstab || netdata_zero_metrics_enabled == CONFIG_BOOLEAN_YES))) {
do_associations = CONFIG_BOOLEAN_YES;
static RRDSET *st = NULL;
static RRDDIM *rd_established = NULL;
if(unlikely(!st)) {
st = rrdset_create_localhost(
"sctp"
, "established"
, NULL
, "associations"
, NULL
, "SCTP current total number of established associations"
, "associations"
, PLUGIN_PROC_NAME
, PLUGIN_PROC_MODULE_NET_SCTP_SNMP_NAME
, NETDATA_CHART_PRIO_SCTP
, update_every
, RRDSET_TYPE_LINE
);
rd_established = rrddim_add(st, "SctpCurrEstab", "established", 1, 1, RRD_ALGORITHM_ABSOLUTE);
}
rrddim_set_by_pointer(st, rd_established, SctpCurrEstab);
rrdset_done(st);
}
// --------------------------------------------------------------------
if(do_transitions == CONFIG_BOOLEAN_YES || (do_transitions == CONFIG_BOOLEAN_AUTO &&
(SctpActiveEstabs ||
SctpPassiveEstabs ||
SctpAborteds ||
SctpShutdowns ||
netdata_zero_metrics_enabled == CONFIG_BOOLEAN_YES))) {
do_transitions = CONFIG_BOOLEAN_YES;
static RRDSET *st = NULL;
static RRDDIM *rd_active = NULL,
*rd_passive = NULL,
*rd_aborted = NULL,
*rd_shutdown = NULL;
if(unlikely(!st)) {
st = rrdset_create_localhost(
"sctp"
, "transitions"
, NULL
, "transitions"
, NULL
, "SCTP Association Transitions"
, "transitions/s"
, PLUGIN_PROC_NAME
, PLUGIN_PROC_MODULE_NET_SCTP_SNMP_NAME
, NETDATA_CHART_PRIO_SCTP + 10
, update_every
, RRDSET_TYPE_LINE
);
rd_active = rrddim_add(st, "SctpActiveEstabs", "active", 1, 1, RRD_ALGORITHM_INCREMENTAL);
rd_passive = rrddim_add(st, "SctpPassiveEstabs", "passive", 1, 1, RRD_ALGORITHM_INCREMENTAL);
rd_aborted = rrddim_add(st, "SctpAborteds", "aborted", -1, 1, RRD_ALGORITHM_INCREMENTAL);
rd_shutdown = rrddim_add(st, "SctpShutdowns", "shutdown", -1, 1, RRD_ALGORITHM_INCREMENTAL);
}
rrddim_set_by_pointer(st, rd_active, SctpActiveEstabs);
rrddim_set_by_pointer(st, rd_passive, SctpPassiveEstabs);
rrddim_set_by_pointer(st, rd_aborted, SctpAborteds);
rrddim_set_by_pointer(st, rd_shutdown, SctpShutdowns);
rrdset_done(st);
}
// --------------------------------------------------------------------
if(do_packets == CONFIG_BOOLEAN_YES || (do_packets == CONFIG_BOOLEAN_AUTO &&
(SctpInSCTPPacks ||
SctpOutSCTPPacks ||
netdata_zero_metrics_enabled == CONFIG_BOOLEAN_YES))) {
do_packets = CONFIG_BOOLEAN_YES;
static RRDSET *st = NULL;
static RRDDIM *rd_received = NULL,
*rd_sent = NULL;
if(unlikely(!st)) {
st = rrdset_create_localhost(
"sctp"
, "packets"
, NULL
, "packets"
, NULL
, "SCTP Packets"
, "packets/s"
, PLUGIN_PROC_NAME
, PLUGIN_PROC_MODULE_NET_SCTP_SNMP_NAME
, NETDATA_CHART_PRIO_SCTP + 20
, update_every
, RRDSET_TYPE_LINE
);
rrdset_flag_set(st, RRDSET_FLAG_DETAIL);
rd_received = rrddim_add(st, "SctpInSCTPPacks", "received", 1, 1, RRD_ALGORITHM_INCREMENTAL);
rd_sent = rrddim_add(st, "SctpOutSCTPPacks", "sent", -1, 1, RRD_ALGORITHM_INCREMENTAL);
}
rrddim_set_by_pointer(st, rd_received, SctpInSCTPPacks);
rrddim_set_by_pointer(st, rd_sent, SctpOutSCTPPacks);
rrdset_done(st);
}
// --------------------------------------------------------------------
if(do_packet_errors == CONFIG_BOOLEAN_YES || (do_packet_errors == CONFIG_BOOLEAN_AUTO &&
(SctpOutOfBlues ||
SctpChecksumErrors ||
netdata_zero_metrics_enabled == CONFIG_BOOLEAN_YES))) {
do_packet_errors = CONFIG_BOOLEAN_YES;
static RRDSET *st = NULL;
static RRDDIM *rd_invalid = NULL,
*rd_csum = NULL;
if(unlikely(!st)) {
st = rrdset_create_localhost(
"sctp"
, "packet_errors"
, NULL
, "packets"
, NULL
, "SCTP Packet Errors"
, "packets/s"
, PLUGIN_PROC_NAME
, PLUGIN_PROC_MODULE_NET_SCTP_SNMP_NAME
, NETDATA_CHART_PRIO_SCTP + 30
, update_every
, RRDSET_TYPE_LINE
);
rrdset_flag_set(st, RRDSET_FLAG_DETAIL);
rd_invalid = rrddim_add(st, "SctpOutOfBlues", "invalid", 1, 1, RRD_ALGORITHM_INCREMENTAL);
rd_csum = rrddim_add(st, "SctpChecksumErrors", "checksum", 1, 1, RRD_ALGORITHM_INCREMENTAL);
}
rrddim_set_by_pointer(st, rd_invalid, SctpOutOfBlues);
rrddim_set_by_pointer(st, rd_csum, SctpChecksumErrors);
rrdset_done(st);
}
// --------------------------------------------------------------------
if(do_fragmentation == CONFIG_BOOLEAN_YES || (do_fragmentation == CONFIG_BOOLEAN_AUTO &&
(SctpFragUsrMsgs ||
SctpReasmUsrMsgs ||
netdata_zero_metrics_enabled == CONFIG_BOOLEAN_YES))) {
do_fragmentation = CONFIG_BOOLEAN_YES;
static RRDSET *st = NULL;
static RRDDIM *rd_fragmented = NULL,
*rd_reassembled = NULL;
if(unlikely(!st)) {
st = rrdset_create_localhost(
"sctp"
, "fragmentation"
, NULL
, "fragmentation"
, NULL
, "SCTP Fragmentation"
, "packets/s"
, PLUGIN_PROC_NAME
, PLUGIN_PROC_MODULE_NET_SCTP_SNMP_NAME
, NETDATA_CHART_PRIO_SCTP + 40
, update_every
, RRDSET_TYPE_LINE);
rrdset_flag_set(st, RRDSET_FLAG_DETAIL);
rd_reassembled = rrddim_add(st, "SctpReasmUsrMsgs", "reassembled", 1, 1, RRD_ALGORITHM_INCREMENTAL);
rd_fragmented = rrddim_add(st, "SctpFragUsrMsgs", "fragmented", -1, 1, RRD_ALGORITHM_INCREMENTAL);
}
rrddim_set_by_pointer(st, rd_reassembled, SctpReasmUsrMsgs);
rrddim_set_by_pointer(st, rd_fragmented, SctpFragUsrMsgs);
rrdset_done(st);
}
// --------------------------------------------------------------------
if(do_chunk_types == CONFIG_BOOLEAN_YES || (do_chunk_types == CONFIG_BOOLEAN_AUTO &&
(SctpInCtrlChunks ||
SctpInOrderChunks ||
SctpInUnorderChunks ||
SctpOutCtrlChunks ||
SctpOutOrderChunks ||
SctpOutUnorderChunks ||
netdata_zero_metrics_enabled == CONFIG_BOOLEAN_YES))) {
do_chunk_types = CONFIG_BOOLEAN_YES;
static RRDSET *st = NULL;
static RRDDIM
*rd_InCtrl = NULL,
*rd_InOrder = NULL,
*rd_InUnorder = NULL,
*rd_OutCtrl = NULL,
*rd_OutOrder = NULL,
*rd_OutUnorder = NULL;
if(unlikely(!st)) {
st = rrdset_create_localhost(
"sctp"
, "chunks"
, NULL
, "chunks"
, NULL
, "SCTP Chunk Types"
, "chunks/s"
, PLUGIN_PROC_NAME
, PLUGIN_PROC_MODULE_NET_SCTP_SNMP_NAME
, NETDATA_CHART_PRIO_SCTP + 50
, update_every
, RRDSET_TYPE_LINE
);
rrdset_flag_set(st, RRDSET_FLAG_DETAIL);
rd_InCtrl = rrddim_add(st, "SctpInCtrlChunks", "InCtrl", 1, 1, RRD_ALGORITHM_INCREMENTAL);
rd_InOrder = rrddim_add(st, "SctpInOrderChunks", "InOrder", 1, 1, RRD_ALGORITHM_INCREMENTAL);
rd_InUnorder = rrddim_add(st, "SctpInUnorderChunks", "InUnorder", 1, 1, RRD_ALGORITHM_INCREMENTAL);
rd_OutCtrl = rrddim_add(st, "SctpOutCtrlChunks", "OutCtrl", -1, 1, RRD_ALGORITHM_INCREMENTAL);
rd_OutOrder = rrddim_add(st, "SctpOutOrderChunks", "OutOrder", -1, 1, RRD_ALGORITHM_INCREMENTAL);
rd_OutUnorder = rrddim_add(st, "SctpOutUnorderChunks", "OutUnorder", -1, 1, RRD_ALGORITHM_INCREMENTAL);
}
rrddim_set_by_pointer(st, rd_InCtrl, SctpInCtrlChunks);
rrddim_set_by_pointer(st, rd_InOrder, SctpInOrderChunks);
rrddim_set_by_pointer(st, rd_InUnorder, SctpInUnorderChunks);
rrddim_set_by_pointer(st, rd_OutCtrl, SctpOutCtrlChunks);
rrddim_set_by_pointer(st, rd_OutOrder, SctpOutOrderChunks);
rrddim_set_by_pointer(st, rd_OutUnorder, SctpOutUnorderChunks);
rrdset_done(st);
}
return 0;
}