1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
|
--
-- (C) 2013-22 - ntop.org
--
local dirs = ntop.getDirs()
package.path = dirs.installdir .. "/scripts/lua/modules/?.lua;" .. package.path
require "lua_utils"
local discover_utils = require "discover_utils"
local callback_utils = require "callback_utils"
-- ########################################################
local ifnames = interface.getIfNames()
-- ########################################################
local periodic_discovery_condition = function(ifId)
return discover_utils.interfaceNetworkDiscoveryEnabled(ifId)
end
-- ########################################################
local oneshot_discovery_condition = function(ifId)
return discover_utils.networkDiscoveryRequested(ifId)
end
-- ########################################################
local discovery_function = function(ifname, ifstats)
if interface.isDiscoverableInterface() then
ntop.setPref("ntopng.prefs.is_periodic_network_discovery_running.ifid_" .. interface.getId(), "1")
ntop.setCache("ntopng.cache.network_discovery_executed.ifid_" .. interface.getId(), "1", 300)
traceError(TRACE_INFO,TRACE_CONSOLE, "[Discover] Started periodic discovery on interface "..ifname)
local res = discover_utils.discover2table(ifname, true --[[ recache --]])
traceError(TRACE_INFO,TRACE_CONSOLE, "[Discover] Completed periodic discovery on interface "..ifname)
discover_utils.clearNetworkDiscovery(ifstats.id)
ntop.setPref("ntopng.prefs.is_periodic_network_discovery_running.ifid_" .. interface.getId(), "0")
end
end
-- ########################################################
-- periodic discovery enabled
local discovery_enabled = (ntop.getPref("ntopng.prefs.is_periodic_network_discovery_enabled") == "1")
local discovery_interval = ntop.getPref("ntopng.prefs.network_discovery_interval")
-- Run this script for a minute before quitting (this reduces load on Lua VM infrastructure)
local num_runs = 12
for i=1,num_runs do
if(ntop.isShutdown()) then break end
if discovery_enabled then
if isEmptyString(discovery_interval) then discovery_interval = 15 * 60 --[[ 15 minutes --]] end
local now = os.time()
local diff = now % tonumber(discovery_interval)
if diff < 5 then
callback_utils.foreachInterface(ifnames, periodic_discovery_condition, discovery_function)
end
end
-- discovery requests performed by the user from the GUI
callback_utils.foreachInterface(ifnames, oneshot_discovery_condition, discovery_function)
ntop.msleep(5000) -- 5 seconds frequency
end
|
