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

Implements checks for SQLite recipient queue push return

Browse source
This commit is contained in:
Simone Mainardi 2020-09-01 11:15:07 +02:00
parent ddf2970843
commit 7b7f2f193b
3 changed files with 26 additions and 15 deletions
Download patch file Download diff file Expand all files Collapse all files

20
scripts/lua/modules/recipients/recipients_lua_utils.lua
View file

@ -61,12 +61,13 @@ end
-- @return true If the dispatching has been successfull, false otherwise
function recipients_lua_utils.dispatch_trigger_notification(notification)
local all_instances = get_all_instances_cache()
local res = true
for _, instance in pairs(all_instances) do
instance:dispatch_trigger_notification(notification)
res = res and instance:dispatch_trigger_notification(notification)
end
return true
return res
end
-- ##############################################
@ -76,12 +77,13 @@ end
-- @return true If the dispatching has been successfull, false otherwise
function recipients_lua_utils.dispatch_release_notification(notification)
local all_instances = get_all_instances_cache()
local res = true
for _, instance in pairs(all_instances) do
instance:dispatch_release_notification(notification)
res = res and instance:dispatch_release_notification(notification)
end
return true
return res
end
-- ##############################################
@ -91,12 +93,13 @@ end
-- @return true If the dispatching has been successfull, false otherwise
function recipients_lua_utils.dispatch_store_notification(notification)
local all_instances = get_all_instances_cache()
local res = true
for _, instance in pairs(all_instances) do
instance:dispatch_store_notification(notification)
res = res and instance:dispatch_store_notification(notification)
end
return true
return res
end
-- ##############################################
@ -104,12 +107,13 @@ end
-- @brief Processs notifications previously dispatched for every available recipient
function recipients_lua_utils.process_notifications(notification)
local all_instances = get_all_instances_cache()
local res = true
for _, instance in pairs(all_instances) do
instance:process_notifications(notification)
res = res and instance:process_notifications(notification)
end
return true
return res
end
-- ##############################################