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

checking available disk space for extractions (avoid using disk space required for recording), delaying extractions in case there is no space

Browse source
This commit is contained in:
Alfredo Cardigliano 2018-11-16 10:53:27 +01:00
parent 6f029bb74c
commit aca57418c3
2 changed files with 33 additions and 8 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -794,15 +794,39 @@ function recording_utils.checkExtractionJobs()
if not isEmptyString(job_json) then
local job = json.decode(job_json)
ntop.runExtraction(job.id,
tonumber(job.ifid),
tonumber(job.time_from),
tonumber(job.time_to),
job.filter,
0) -- extraction limit (bytes)
-- computing available space as safety check
local extraction_limit = 0
local max_if_used = 0
local disk_space = ntop.getCache('ntopng.prefs.ifid_'..job.ifid..'.traffic_recording.disk_space')
if not isEmptyString(disk_space) then
max_if_used = tonumber(disk_space)
end
local storage_info = recording_utils.storageInfo(job.ifid)
local currently_avail = storage_info.total - storage_info.avail
if storage_info.avail > (max_if_used - storage_info.if_used) then
local avail = storage_info.avail - (max_if_used - storage_info.if_used)
extraction_limit = avail*1024*1024
else
extraction_limit = nil
end
job.status = 'processing'
ntop.setHashCache(extraction_jobs_key, job.id, json.encode(job))
if extraction_limit ~= nil then
-- running extraction
ntop.runExtraction(job.id,
tonumber(job.ifid),
tonumber(job.time_from),
tonumber(job.time_to),
job.filter,
extraction_limit)
job.status = 'processing'
ntop.setHashCache(extraction_jobs_key, job.id, json.encode(job))
else
-- no space available - delay this job
job.status = 'waiting_nospace'
ntop.setHashCache(extraction_jobs_key, job.id, json.encode(job))
ntop.rpushCache(extraction_queue_key, tostring(job.id))
end
end
end
end