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

traffic extraction improvements

Browse source
This commit is contained in:
Alfredo Cardigliano 2018-10-16 18:59:34 +02:00
parent ded832dfad
commit b304c68d33
5 changed files with 23 additions and 22 deletions
Download patch file Download diff file Expand all files Collapse all files

27
scripts/lua/modules/recording_utils.lua
View file

@ -424,24 +424,21 @@ function recording_utils.scheduleExtraction(ifid, params)
end
local function setJobAsCompleted()
local last_id = ntop.getCache(extraction_seqnum_key)
if not isEmptyString(last_id) then
local job_json = ntop.getHashCache(extraction_jobs_key, last_id)
local datapath_extractions = ntop.getExtractionStatus()
for id,status in pairs(datapath_extractions) do
local job_json = ntop.getHashCache(extraction_jobs_key, id)
if not isEmptyString(job_json) then
local job = json.decode(job_json)
local datapath_extractions = ntop.getExtractionStatus()
for id,status in pairs(datapath_extractions) do
if job.id == tonumber(id) and job.status == "processing" then
if status.status == 0 then
job.status = "completed"
else
job.status = "failed"
job.error_code = status.status
end
job.extracted_pkts = status.extracted_pkts
job.extracted_bytes = status.extracted_bytes
ntop.setHashCache(extraction_jobs_key, job.id, json.encode(job))
if job.status == "processing" then
if status.status == 0 then
job.status = "completed"
else
job.status = "failed"
job.error_code = status.status
end
job.extracted_pkts = status.extracted_pkts
job.extracted_bytes = status.extracted_bytes
ntop.setHashCache(extraction_jobs_key, job.id, json.encode(job))
end
end
end