mirror of
https://github.com/ntop/ntopng.git
synced 2026-05-06 03:45:26 +00:00
482c2ca834
This commits adds two reset buttons to the interface page. One button allows the reset of all interface counters, namely, packets and bytes received, packets dropped, and the number of flows exported and dropped (when mysql or elasticsearch is enabled). The other button allows the reset of only the drops.
124 lines
4.8 KiB
Lua
124 lines
4.8 KiB
Lua
--
|
|
-- (C) 2013-16 - ntop.org
|
|
--
|
|
|
|
dirs = ntop.getDirs()
|
|
package.path = dirs.installdir .. "/scripts/lua/modules/?.lua;" .. package.path
|
|
|
|
require "lua_utils"
|
|
json = require("dkjson")
|
|
|
|
--sendHTTPHeader('text/html; charset=iso-8859-1')
|
|
sendHTTPHeader('application/json')
|
|
|
|
function dumpInterfaceStats(interface_name)
|
|
interface.select(interface_name)
|
|
|
|
local ifstats = interface.getStats()
|
|
local stats = interface.getFlowsStats()
|
|
|
|
local res = {}
|
|
if(ifstats ~= nil) then
|
|
uptime = ntop.getUptime()
|
|
prefs = ntop.getPrefs()
|
|
|
|
-- Round up
|
|
hosts_pctg = math.floor(1+((ifstats.stats.hosts*100)/prefs.max_num_hosts))
|
|
flows_pctg = math.floor(1+((ifstats.stats.flows*100)/prefs.max_num_flows))
|
|
|
|
res["ifname"] = interface_name
|
|
-- network load is used by web pages that are shown to the user
|
|
-- so we must return statistics since the latest (possible) reset
|
|
res["packets"] = ifstats.stats_since_reset.packets
|
|
res["bytes"] = ifstats.stats_since_reset.bytes
|
|
res["drops"] = ifstats.stats_since_reset.drops
|
|
|
|
if prefs.is_dump_flows_to_es_enabled == true
|
|
or prefs.is_dump_flows_to_mysql_enabled == true then
|
|
res["flow_export_drops"] = ifstats.stats_since_reset.flow_export_drops
|
|
res["flow_export_rate"] = ifstats.stats_since_reset.flow_export_rate
|
|
res["flow_export_count"] = ifstats.stats_since_reset.flow_export_count
|
|
end
|
|
|
|
if prefs.are_alerts_enabled == true then
|
|
local alert_cache = interface.getCachedNumAlerts()
|
|
res["alerts"] = alert_cache["num_alerts"]
|
|
res["engaged_alerts"] = alert_cache["num_alerts_engaged"]
|
|
res["error_level_alerts"] = alert_cache["error_level_alerts"]
|
|
end
|
|
|
|
|
|
res["num_flows"] = ifstats.stats.flows
|
|
res["num_hosts"] = ifstats.stats.hosts
|
|
res["num_devices"] = ifstats.stats.devices
|
|
res["epoch"] = os.time()
|
|
res["tz_offset"] = get_timezone_offset()
|
|
res["localtime"] = format_time(res["epoch"], "!%H:%M:%S %z", res["tz_offset"])
|
|
res["uptime"] = secondsToTime(uptime)
|
|
res["hosts_pctg"] = hosts_pctg
|
|
res["flows_pctg"] = flows_pctg
|
|
res["remote_pps"] = ifstats.remote_pps
|
|
res["remote_bps"] = ifstats.remote_bps
|
|
res["is_view"] = ifstats.isView
|
|
|
|
res["local2remote"] = ifstats["localstats"]["bytes"]["local2remote"]
|
|
res["remote2local"] = ifstats["localstats"]["bytes"]["remote2local"]
|
|
|
|
if(ifstats.zmqRecvStats ~= nil) then
|
|
res["zmqRecvStats"] = {}
|
|
res["zmqRecvStats"]["flows"] = ifstats.zmqRecvStats.flows
|
|
res["zmqRecvStats"]["events"] = ifstats.zmqRecvStats.events
|
|
res["zmqRecvStats"]["counters"] = ifstats.zmqRecvStats.counters
|
|
res["zmqRecvStats"]["zmq_msg_drops"] = ifstats.zmqRecvStats.zmq_msg_drops
|
|
end
|
|
|
|
res["tcpPacketStats"] = {}
|
|
res["tcpPacketStats"]["retransmissions"] = ifstats.tcpPacketStats.retransmissions
|
|
res["tcpPacketStats"]["out_of_order"] = ifstats.tcpPacketStats.out_of_order
|
|
res["tcpPacketStats"]["lost"] = ifstats.tcpPacketStats.lost
|
|
|
|
if(ifstats["bridge.device_a"] ~= nil) then
|
|
res["a_to_b_in_pkts"] = ifstats["bridge.a_to_b.in_pkts"]
|
|
res["a_to_b_in_bytes"] = ifstats["bridge.a_to_b.in_bytes"]
|
|
res["a_to_b_out_pkts"] = ifstats["bridge.a_to_b.out_pkts"]
|
|
res["a_to_b_out_bytes"] = ifstats["bridge.a_to_b.out_bytes"]
|
|
res["a_to_b_filtered_pkts"] = ifstats["bridge.a_to_b.filtered_pkts"]
|
|
res["a_to_b_shaped_pkts"] = ifstats["bridge.a_to_b.shaped_pkts"]
|
|
|
|
res["b_to_a_in_pkts"] = ifstats["bridge.b_to_a.in_pkts"]
|
|
res["b_to_a_in_bytes"] = ifstats["bridge.b_to_a.in_bytes"]
|
|
res["b_to_a_out_pkts"] = ifstats["bridge.b_to_a.out_pkts"]
|
|
res["b_to_a_out_bytes"] = ifstats["bridge.b_to_a.out_bytes"]
|
|
res["b_to_a_filtered_pkts"] = ifstats["bridge.b_to_a.filtered_pkts"]
|
|
res["b_to_a_shaped_pkts"] = ifstats["bridge.b_to_a.shaped_pkts"]
|
|
|
|
res["a_to_b_num_pkts_send_buffer_full"] = ifstats["bridge.a_to_b.num_pkts_send_buffer_full"]
|
|
res["a_to_b_num_pkts_send_error"] = ifstats["bridge.a_to_b.num_pkts_send_error"]
|
|
res["b_to_a_num_pkts_send_buffer_full"] = ifstats["bridge.b_to_a.num_pkts_send_buffer_full"]
|
|
res["b_to_a_num_pkts_send_error"] = ifstats["bridge.b_to_a.num_pkts_send_error"]
|
|
end
|
|
|
|
if(ifstats["profiles"] ~= nil) then
|
|
res["profiles"] = ifstats["profiles"]
|
|
end
|
|
|
|
res["breed"] = stats["breeds"]
|
|
end
|
|
return res
|
|
end
|
|
|
|
-- ###############################
|
|
|
|
local res = {}
|
|
if(_GET["ifname"] == "all") then
|
|
local names = interface.getIfNames()
|
|
local n = 1
|
|
local sortedKeys = getKeysSortedByValue(names, function(a, b) return a < b end)
|
|
for k,v in ipairs(sortedKeys) do
|
|
res[n] = dumpInterfaceStats(names[v])
|
|
n = n + 1
|
|
end
|
|
else
|
|
res = dumpInterfaceStats(ifname)
|
|
end
|
|
print(json.encode(res, nil, 1))
|