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

Implemented debug code for RRD

Browse source
This commit is contained in:
Luca Deri 2020-02-28 17:20:30 +01:00
parent 2990c1d38b
commit 8e1da33141
1 changed files with 24 additions and 11 deletions
Download patch file Download diff file Expand all files Collapse all files

35
scripts/lua/modules/timeseries/drivers/rrd.lua
View file

@ -356,7 +356,7 @@ end
-- ##############################################
local function update_rrd(schema, rrdfile, timestamp, data, dont_recover)
local params = {number_to_rrd_string(timestamp), }
local params = { number_to_rrd_string(timestamp), }
if isDebugEnabled() then
traceError(TRACE_NORMAL, TRACE_CONSOLE, string.format("Going to update %s [%s]", schema.name, rrdfile))
@ -427,14 +427,24 @@ end
-- ##############################################
local function log_ts(rrdfile, schema, timestamp, tags, metrics)
local what = {}
local function ts2json(rrdfile, schema, timestamp, tags, metrics)
local what = { }
local j
what.file = rrdfile
what.params = { number_to_rrd_string(timestamp) }
for _, metric in ipairs(schema._metrics) do
what.params[#params + 1] = number_to_rrd_string(metrics[metric])
end
what.file = rrdfile
what.params = params
j = json.encode(what)
return(json.encode(what))
end
-- ##############################################
local function log_ts(rrdfile, schema, timestamp, tags, metrics)
local j = ts2json(rrdfile, schema, timestamp, tags, metrics)
if(schema.options.is_critical_ts) then
critical = "[Critical]"
@ -453,16 +463,19 @@ function driver:append(schema, timestamp, tags, metrics)
local base, rrd = schema_get_path(schema, tags)
local rrdfile = os_utils.fixPath(base .. "/" .. rrd .. ".rrd")
if(false) then -- Work in progress
local j = log_ts(rrdfile, schema, timestamp, tags, metrics)
if(false) then
if(false) then -- Uncomment here
if(not schema.options.is_critical_ts) then
local j = ts2json(rrdfile, schema, timestamp, tags, metrics)
ntop.lpushCache(rrd_update_queue, j)
curr_num_rrd_updates = curr_num_rrd_updates + 1
if(curr_num_rrd_updates == 100) then
ntop.ltrimCache(rrd_update_queue, 0, max_rrd_queueLen)
curr_num_rrd_updates = 0
end
return true
end
end