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

Caching storage status to avoi too many queries to disk

Browse source
This commit is contained in:
Alfredo Cardigliano 2018-12-12 18:28:24 +01:00
parent cc8e951933
commit 8f6d29d7bc
2 changed files with 45 additions and 49 deletions
Download patch file Download diff file Expand all files Collapse all files

47
scripts/lua/modules/storage_utils.lua
View file

@ -12,6 +12,7 @@ end
require "lua_utils"
local json = require("dkjson")
local rrd_utils = require "rrd_utils"
local recording_utils = require "recording_utils"
@ -21,28 +22,36 @@ local storage_utils = {}
function storage_utils.interfaceStorageInfo(ifid)
local info = { total = 0}
local total_used = 0
-- if ts_utils.getDriverName() == "rrd" then
local rrd_storage_info = rrd_utils.storageInfo(ifid)
info["rrd"] = rrd_storage_info.total
info["total"] = info["total"] + rrd_storage_info.total
-- end
local key = "ntopng.cache."..ifid..".storage_info"
if ntop.isEnterprise() and hasNindexSupport() then
local nindex_utils = require "nindex_utils"
local flows_storage_info = nindex_utils.storageInfo(ifid)
info["flows"] = flows_storage_info.total
info["total"] = info["total"] + flows_storage_info.total
local info_json = ntop.getCache(key)
if not isEmptyString(info_json) then
info = json.decode(info_json)
else
-- if ts_utils.getDriverName() == "rrd" then
local rrd_storage_info = rrd_utils.storageInfo(ifid)
info["rrd"] = rrd_storage_info.total
info["total"] = info["total"] + rrd_storage_info.total
-- end
if ntop.isEnterprise() and hasNindexSupport() then
local nindex_utils = require "nindex_utils"
local flows_storage_info = nindex_utils.storageInfo(ifid)
info["flows"] = flows_storage_info.total
info["total"] = info["total"] + flows_storage_info.total
end
-- if recording_utils.isAvailable() then
local pcap_storage_info = recording_utils.storageInfo(ifid)
local total_pcap_dump_used = (pcap_storage_info.if_used + pcap_storage_info.extraction_used)
info["pcap"] = total_pcap_dump_used
info["total"] = info["total"] + total_pcap_dump_used
-- end
ntop.setCache(key, json.encode(info), 60)
end
-- if recording_utils.isAvailable() then
local pcap_storage_info = recording_utils.storageInfo(ifid)
local total_pcap_dump_used = (pcap_storage_info.if_used + pcap_storage_info.extraction_used)
info["pcap"] = total_pcap_dump_used
info["total"] = info["total"] + total_pcap_dump_used
-- end
return info
end