vrr/ntopng
2
0
Fork 0
mirror of https://github.com/ntop/ntopng.git synced 2026-04-29 07:29:32 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 3

Avoids generating unnecessary timeseries when unsupported

Browse source 
Fixes #5678
This commit is contained in:
Simone Mainardi 2021-07-14 15:05:11 +02:00
parent 9de3a3331b
commit d3566ba568
2 changed files with 37 additions and 19 deletions
Download patch file Download diff file Expand all files Collapse all files

44
scripts/lua/modules/ts_5min_dump_utils.lua
View file

@ -36,21 +36,33 @@ local ts_dump = {}
-- ########################################################
function ts_dump.l2_device_update_categories_rrds(when, devicename, device, ifstats, verbose)
-- nDPI Protocol CATEGORIES
for k, cat in pairs(device["ndpi_categories"] or {}) do
ts_utils.append("mac:ndpi_categories", {ifid=ifstats.id, mac=devicename, category=k,
bytes=cat["bytes"]}, when)
end
-- nDPI Protocol CATEGORIES
if not ifstats.isViewed and not ifstats.isView then
for k, cat in pairs(device["ndpi_categories"] or {}) do
ts_utils.append("mac:ndpi_categories",
{
ifid=ifstats.id, mac=devicename, category=k,
bytes=cat["bytes"]
}, when)
end
end
end
function ts_dump.l2_device_update_stats_rrds(when, devicename, device, ifstats, verbose)
ts_utils.append("mac:traffic", {ifid=ifstats.id, mac=devicename,
bytes_sent=device["bytes.sent"], bytes_rcvd=device["bytes.rcvd"]}, when, verbose)
ts_utils.append("mac:arp_rqst_sent_rcvd_rpls", {ifid=ifstats.id, mac=devicename,
request_packets_sent = device["arp_requests.sent"],
reply_packets_rcvd = device["arp_replies.rcvd"]},
when)
if not ifstats.isViewed and not ifstats.isView then
ts_utils.append("mac:traffic",
{
ifid=ifstats.id, mac=devicename,
bytes_sent=device["bytes.sent"], bytes_rcvd=device["bytes.rcvd"]
}, when, verbose)
ts_utils.append("mac:arp_rqst_sent_rcvd_rpls",
{
ifid=ifstats.id, mac=devicename,
request_packets_sent = device["arp_requests.sent"],
reply_packets_rcvd = device["arp_replies.rcvd"]
}, when)
end
end
-- ########################################################
@ -186,9 +198,11 @@ function ts_dump.asn_update_rrds(when, ifstats, verbose)
end
-- Save ASN RTT stats
ts_utils.append("asn:rtt",
{ifid=ifstats.id, asn=asn,
millis_rtt=asn_stats["round_trip_time"]}, when)
if not ifstats.isViewed and not ifstats.isView then
ts_utils.append("asn:rtt",
{ifid=ifstats.id, asn=asn,
millis_rtt=asn_stats["round_trip_time"]}, when)
end
-- Save ASN TCP stats
if not ifstats.isSampledTraffic then