Implements Netfilter queue monitoring

This commit is contained in:
Simone Mainardi 2018-06-15 12:07:22 +02:00
parent c382fd4631
commit fd42cfd0cb
7 changed files with 81 additions and 48 deletions

View file

@ -158,19 +158,13 @@ function rrd_dump.run_min_dump(_ifname, ifstats, config, when, verbose)
rrd_dump.profiles_update_stats(when, ifstats, basedir, verbose)
end
if ntop.isnEdge() then
local st = ntop.systemHostStat()
local queue_dropped = st["queue_dropped"] or 0
local user_dropped = st["user_dropped"] or 0
local queue_total = st["queue_total"] or 0
local id_sequence = st["id_sequence"] or 0
if ntop.isnEdge() and ifstats.type == "netfilter" then
local st = ifstats.netfilter or {}
-- tprint({queue_dropped=queue_dropped, user_dropped=user_dropped, queue_total=queue_total, id_sequence=id_sequence})
ts_utils.append(ts_schemas.iface_nfq_drops, {ifid=ifstats.id, num_nfq_drops=queue_dropped}, when, verbose)
ts_utils.append(ts_schemas.iface_nfq_udrops, {ifid=ifstats.id, num_nfq_udrops=user_dropped}, when, verbose)
ts_utils.append(ts_schemas.iface_nfq_total, {ifid=ifstats.id, num_nfq_total=queue_total}, when, verbose)
ts_utils.append(ts_schemas.iface_nfq_drops, {ifid=ifstats.id, num_nfq_drops = st.queue_dropped}, when, verbose)
ts_utils.append(ts_schemas.iface_nfq_udrops, {ifid=ifstats.id, num_nfq_udrops = st.user_dropped}, when, verbose)
ts_utils.append(ts_schemas.iface_nfq_total, {ifid=ifstats.id, num_nfq_total = st.queue_total}, when, verbose)
end
ts_utils.flush()