mirror of
https://github.com/ntop/ntopng.git
synced 2026-04-29 23:49:33 +00:00
Added check for flows towards local (nil) ASN
This commit is contained in:
Luca Deri
parent
22cc48a6c5
commit
c0e33b26d0
1 changed files with 270 additions and 270 deletions
|
|
@ -47,39 +47,39 @@ local traffic_criteria = {INGRESS = 0, EGRESS = 1, TOTAL = 2, ING_EGR = 3, AS_TR
|
|||
local criteria
|
||||
|
||||
if criteria_as == "as_traffic_criteria" then
|
||||
criteria = traffic_criteria.AS_TRAFFIC
|
||||
criteria = traffic_criteria.AS_TRAFFIC
|
||||
else
|
||||
criteria = traffic_criteria.ING_EGR
|
||||
criteria = traffic_criteria.ING_EGR
|
||||
end
|
||||
|
||||
-- ################################################
|
||||
|
||||
if isEmptyString(ifid) then
|
||||
rc = rest_utils.consts.err.invalid_interface
|
||||
rest_utils.answer(rc)
|
||||
return
|
||||
rc = rest_utils.consts.err.invalid_interface
|
||||
rest_utils.answer(rc)
|
||||
return
|
||||
end
|
||||
|
||||
-- ################################################
|
||||
|
||||
local node_ids = {}
|
||||
local last_node_id = 0
|
||||
local debug = false
|
||||
local sankey_debug = false
|
||||
|
||||
function find_node_id(node)
|
||||
local rc = node_ids[node]
|
||||
local rc = node_ids[node]
|
||||
|
||||
if (rc == nil) then
|
||||
rc = last_node_id .. ""
|
||||
last_node_id = last_node_id + 1
|
||||
node_ids[node] = rc
|
||||
if (rc == nil) then
|
||||
rc = last_node_id .. ""
|
||||
last_node_id = last_node_id + 1
|
||||
node_ids[node] = rc
|
||||
|
||||
if (debug) then tprint("Adding " .. node .. " as " .. rc) end
|
||||
if (sankey_debug) then tprint("Adding " .. node .. " as " .. rc) end
|
||||
|
||||
return (rc)
|
||||
else
|
||||
return (rc)
|
||||
end
|
||||
return (rc)
|
||||
else
|
||||
return (rc)
|
||||
end
|
||||
end
|
||||
|
||||
-- ################################################
|
||||
|
|
@ -93,18 +93,18 @@ local max_len = 32
|
|||
local ifstats = interface.getStats()
|
||||
|
||||
table.insert(nodes, {
|
||||
link = ntop.getHttpPrefix() .. "/lua/hosts_stats.lua?asn=" .. asn .. "",
|
||||
node_id = as_root_key,
|
||||
label = shortenString(format_utils.formatASN(asn), 64)
|
||||
link = ntop.getHttpPrefix() .. "/lua/hosts_stats.lua?asn=" .. asn .. "",
|
||||
node_id = as_root_key,
|
||||
label = shortenString(format_utils.formatASN(asn), 64)
|
||||
})
|
||||
|
||||
-- ####################
|
||||
|
||||
local function add_unique_node(node_id, label, link)
|
||||
if not node_set[node_id] then
|
||||
table.insert(nodes, {node_id = node_id, label = shortenString(label, 64), link = link})
|
||||
node_set[node_id] = true
|
||||
end
|
||||
if not node_set[node_id] then
|
||||
table.insert(nodes, {node_id = node_id, label = shortenString(label, 64), link = link})
|
||||
node_set[node_id] = true
|
||||
end
|
||||
end
|
||||
|
||||
-- ####################
|
||||
|
|
@ -114,26 +114,26 @@ local function reset_nodes() node_set = {} end
|
|||
-- ####################
|
||||
|
||||
local function add_link(source_node_id, target_node_id, label, value)
|
||||
table.insert(links, {
|
||||
source_node_id = source_node_id,
|
||||
target_node_id = target_node_id,
|
||||
label = label,
|
||||
value = value
|
||||
})
|
||||
table.insert(links, {
|
||||
source_node_id = source_node_id,
|
||||
target_node_id = target_node_id,
|
||||
label = label,
|
||||
value = value
|
||||
})
|
||||
end
|
||||
|
||||
-- ####################
|
||||
|
||||
local function search_probe(ip)
|
||||
for interface_id, probe_list in pairs(ifstats.probes or {}) do
|
||||
for probe_ip, probe_info in pairsByKeys(probe_list or {}) do
|
||||
for exporter_ip, exporter_info in pairsByKeys(probe_info.exporters or {}) do
|
||||
if exporter_ip==ip then
|
||||
return {probe_uuid = probe_info["probe.uuid_num"], exporter_uuid = exporter_info["unique_source_id"]}
|
||||
end
|
||||
end
|
||||
end
|
||||
end
|
||||
for interface_id, probe_list in pairs(ifstats.probes or {}) do
|
||||
for probe_ip, probe_info in pairsByKeys(probe_list or {}) do
|
||||
for exporter_ip, exporter_info in pairsByKeys(probe_info.exporters or {}) do
|
||||
if exporter_ip==ip then
|
||||
return {probe_uuid = probe_info["probe.uuid_num"], exporter_uuid = exporter_info["unique_source_id"]}
|
||||
end
|
||||
end
|
||||
end
|
||||
end
|
||||
end
|
||||
|
||||
-- ####################
|
||||
|
|
@ -144,41 +144,41 @@ local tot_bytes_exporter = {}
|
|||
local tot_bytes_transit = {}
|
||||
|
||||
local function init_exporter(device_ip)
|
||||
local key = device_ip
|
||||
if not tot_bytes_exporter[key] then
|
||||
tot_bytes_exporter[key] = {sent = 0, rcvd = 0}
|
||||
end
|
||||
local key = device_ip
|
||||
if not tot_bytes_exporter[key] then
|
||||
tot_bytes_exporter[key] = {sent = 0, rcvd = 0}
|
||||
end
|
||||
end
|
||||
|
||||
local function init_transit(transit)
|
||||
local key = transit
|
||||
if not tot_bytes_transit[key] then
|
||||
tot_bytes_transit[key] = {sent = 0, rcvd = 0}
|
||||
end
|
||||
local key = transit
|
||||
if not tot_bytes_transit[key] then
|
||||
tot_bytes_transit[key] = {sent = 0, rcvd = 0}
|
||||
end
|
||||
end
|
||||
|
||||
-- ####################
|
||||
|
||||
local function inc_exporter_sent(key, bytes)
|
||||
tot_bytes_exporter[key].sent = tot_bytes_exporter[key].sent + bytes
|
||||
tot_bytes_exporter[key].sent = tot_bytes_exporter[key].sent + bytes
|
||||
end
|
||||
|
||||
-- ####################
|
||||
|
||||
local function inc_exporter_rcvd(key, bytes)
|
||||
tot_bytes_exporter[key].rcvd = tot_bytes_exporter[key].rcvd + bytes
|
||||
tot_bytes_exporter[key].rcvd = tot_bytes_exporter[key].rcvd + bytes
|
||||
end
|
||||
|
||||
-- ####################
|
||||
|
||||
local function inc_transit_sent(key, bytes)
|
||||
tot_bytes_transit[key].sent = tot_bytes_transit[key].sent + bytes
|
||||
tot_bytes_transit[key].sent = tot_bytes_transit[key].sent + bytes
|
||||
end
|
||||
|
||||
-- ####################
|
||||
|
||||
local function inc_transit_rcvd(key, bytes)
|
||||
tot_bytes_transit[key].rcvd = tot_bytes_transit[key].rcvd + bytes
|
||||
tot_bytes_transit[key].rcvd = tot_bytes_transit[key].rcvd + bytes
|
||||
end
|
||||
|
||||
-- ####################
|
||||
|
|
@ -189,314 +189,314 @@ local tot_bytes_exp_if = {}
|
|||
local tot_bytes_as_transit = {}
|
||||
|
||||
local function get_interface_key(device_ip, interface_index)
|
||||
return device_ip .. "@" .. interface_index
|
||||
return device_ip .. "@" .. interface_index
|
||||
end
|
||||
|
||||
local function get_as_key(transit, src_dst_as)
|
||||
return transit .. "@" .. src_dst_as
|
||||
return transit .. "@" .. src_dst_as
|
||||
end
|
||||
|
||||
-- ####################
|
||||
|
||||
local function init_interface(device_ip, interface_index)
|
||||
local key = get_interface_key(device_ip, interface_index)
|
||||
if not tot_bytes_exp_if[key] then
|
||||
tot_bytes_exp_if[key] = {
|
||||
sent = 0,
|
||||
rcvd = 0,
|
||||
exporter_ip = device_ip,
|
||||
port_index = interface_index
|
||||
}
|
||||
end
|
||||
local key = get_interface_key(device_ip, interface_index)
|
||||
if not tot_bytes_exp_if[key] then
|
||||
tot_bytes_exp_if[key] = {
|
||||
sent = 0,
|
||||
rcvd = 0,
|
||||
exporter_ip = device_ip,
|
||||
port_index = interface_index
|
||||
}
|
||||
end
|
||||
end
|
||||
|
||||
local function init_src_dst_as(transit, src_dst_as)
|
||||
local key = get_as_key(transit, src_dst_as)
|
||||
if not tot_bytes_as_transit[key] then
|
||||
tot_bytes_as_transit[key] = {
|
||||
sent = 0,
|
||||
rcvd = 0,
|
||||
transit = transit,
|
||||
src_dst_as = src_dst_as
|
||||
}
|
||||
end
|
||||
local key = get_as_key(transit, src_dst_as)
|
||||
if not tot_bytes_as_transit[key] then
|
||||
tot_bytes_as_transit[key] = {
|
||||
sent = 0,
|
||||
rcvd = 0,
|
||||
transit = transit,
|
||||
src_dst_as = src_dst_as
|
||||
}
|
||||
end
|
||||
end
|
||||
|
||||
-- ####################
|
||||
|
||||
local function inc_interface_sent(key, bytes)
|
||||
tot_bytes_exp_if[key].sent = tot_bytes_exp_if[key].sent + bytes
|
||||
tot_bytes_exp_if[key].sent = tot_bytes_exp_if[key].sent + bytes
|
||||
end
|
||||
|
||||
-- ####################
|
||||
|
||||
local function inc_interface_rcvd(key, bytes)
|
||||
tot_bytes_exp_if[key].rcvd = tot_bytes_exp_if[key].rcvd + bytes
|
||||
tot_bytes_exp_if[key].rcvd = tot_bytes_exp_if[key].rcvd + bytes
|
||||
end
|
||||
|
||||
-- ####################
|
||||
|
||||
local function inc_as_sent(key, bytes)
|
||||
tot_bytes_as_transit[key].sent = tot_bytes_as_transit[key].sent + bytes
|
||||
tot_bytes_as_transit[key].sent = tot_bytes_as_transit[key].sent + bytes
|
||||
end
|
||||
|
||||
-- ####################
|
||||
|
||||
local function inc_as_rcvd(key, bytes)
|
||||
tot_bytes_as_transit[key].rcvd = tot_bytes_as_transit[key].rcvd + bytes
|
||||
tot_bytes_as_transit[key].rcvd = tot_bytes_as_transit[key].rcvd + bytes
|
||||
end
|
||||
|
||||
-- ####################
|
||||
|
||||
local function build_interface_exporter(criteria, tot_bytes_exp_if,
|
||||
exporter_nodes)
|
||||
for n_id, data in pairs(tot_bytes_exp_if) do
|
||||
if (criteria == traffic_criteria.INGRESS and data.sent > 0) or
|
||||
(criteria == traffic_criteria.EGRESS and data.rcvd > 0) or
|
||||
(criteria == traffic_criteria.TOTAL and (data.rcvd + data.sent) > 0) then
|
||||
-- tprint(n_id .. " " .. criteria .. " " .. data.sent .. " " .. data.rcvd)
|
||||
local exporter_ip = getProbeName(data.exporter_ip)
|
||||
local port_index = format_portidx_name(data.exporter_ip,
|
||||
data.port_index, true) or "?"
|
||||
local exporter_node_id = find_node_id(exporter_ip)
|
||||
local port_node_id = find_node_id(n_id)
|
||||
for n_id, data in pairs(tot_bytes_exp_if) do
|
||||
if (criteria == traffic_criteria.INGRESS and data.sent > 0) or
|
||||
(criteria == traffic_criteria.EGRESS and data.rcvd > 0) or
|
||||
(criteria == traffic_criteria.TOTAL and (data.rcvd + data.sent) > 0) then
|
||||
-- tprint(n_id .. " " .. criteria .. " " .. data.sent .. " " .. data.rcvd)
|
||||
local exporter_ip = getProbeName(data.exporter_ip)
|
||||
local port_index = format_portidx_name(data.exporter_ip,
|
||||
data.port_index, true) or "?"
|
||||
local exporter_node_id = find_node_id(exporter_ip)
|
||||
local port_node_id = find_node_id(n_id)
|
||||
|
||||
if criteria == traffic_criteria.EGRESS then
|
||||
exporter_node_id = "egress" .. "_" .. exporter_node_id
|
||||
port_node_id = "egress" .. "_" .. port_node_id
|
||||
else
|
||||
exporter_node_id = "ingress" .. "_" .. exporter_node_id
|
||||
port_node_id = "ingress" .. "_" .. port_node_id
|
||||
end
|
||||
if criteria == traffic_criteria.EGRESS then
|
||||
exporter_node_id = "egress" .. "_" .. exporter_node_id
|
||||
port_node_id = "egress" .. "_" .. port_node_id
|
||||
else
|
||||
exporter_node_id = "ingress" .. "_" .. exporter_node_id
|
||||
port_node_id = "ingress" .. "_" .. port_node_id
|
||||
end
|
||||
|
||||
if (exporter_nodes[data.exporter_ip] == nil) then
|
||||
exporter_nodes[data.exporter_ip] = exporter_node_id
|
||||
end
|
||||
nprobe_stats = search_probe(data.exporter_ip)
|
||||
|
||||
local url = "#"
|
||||
if ntop.isEnterprise() and nprobe_stats then
|
||||
url = ntop.getHttpPrefix() ..
|
||||
'/lua/pro/enterprise/exporter_details.lua?ip=' .. exporter_ip ..
|
||||
'&exporter_uuid=' .. nprobe_stats.exporter_uuid ..
|
||||
'&probe_uuid=' .. nprobe_stats.probe_uuid
|
||||
end
|
||||
add_unique_node(exporter_node_id, exporter_ip, url)
|
||||
url = "#"
|
||||
if ntop.isEnterprise() then
|
||||
url = ntop.getHttpPrefix() ..
|
||||
'/lua/pro/enterprise/snmp_interface_details.lua?host='.. data.exporter_ip ..
|
||||
'&snmp_port_idx='.. data.port_index
|
||||
end
|
||||
add_unique_node(port_node_id, port_index, url)
|
||||
if (exporter_nodes[data.exporter_ip] == nil) then
|
||||
exporter_nodes[data.exporter_ip] = exporter_node_id
|
||||
end
|
||||
nprobe_stats = search_probe(data.exporter_ip)
|
||||
|
||||
if criteria == traffic_criteria.INGRESS then
|
||||
-- Interface -> Exporter
|
||||
add_link(port_node_id, exporter_node_id, bytesToSize(data.sent), data.sent)
|
||||
elseif criteria == traffic_criteria.EGRESS then
|
||||
-- Exporter -> Interface
|
||||
add_link(exporter_node_id, port_node_id, bytesToSize(data.rcvd), data.rcvd)
|
||||
elseif criteria == traffic_criteria.TOTAL then
|
||||
-- Interface -> Exporter
|
||||
add_link(port_node_id, exporter_node_id,
|
||||
bytesToSize(data.rcvd + data.sent), data.rcvd + data.sent)
|
||||
end
|
||||
end
|
||||
end
|
||||
local url = "#"
|
||||
if ntop.isEnterprise() and nprobe_stats then
|
||||
url = ntop.getHttpPrefix() ..
|
||||
'/lua/pro/enterprise/exporter_details.lua?ip=' .. exporter_ip ..
|
||||
'&exporter_uuid=' .. nprobe_stats.exporter_uuid ..
|
||||
'&probe_uuid=' .. nprobe_stats.probe_uuid
|
||||
end
|
||||
add_unique_node(exporter_node_id, exporter_ip, url)
|
||||
url = "#"
|
||||
if ntop.isEnterprise() then
|
||||
url = ntop.getHttpPrefix() ..
|
||||
'/lua/pro/enterprise/snmp_interface_details.lua?host='.. data.exporter_ip ..
|
||||
'&snmp_port_idx='.. data.port_index
|
||||
end
|
||||
add_unique_node(port_node_id, port_index, url)
|
||||
|
||||
if criteria == traffic_criteria.INGRESS then
|
||||
-- Interface -> Exporter
|
||||
add_link(port_node_id, exporter_node_id, bytesToSize(data.sent), data.sent)
|
||||
elseif criteria == traffic_criteria.EGRESS then
|
||||
-- Exporter -> Interface
|
||||
add_link(exporter_node_id, port_node_id, bytesToSize(data.rcvd), data.rcvd)
|
||||
elseif criteria == traffic_criteria.TOTAL then
|
||||
-- Interface -> Exporter
|
||||
add_link(port_node_id, exporter_node_id,
|
||||
bytesToSize(data.rcvd + data.sent), data.rcvd + data.sent)
|
||||
end
|
||||
end
|
||||
end
|
||||
end
|
||||
|
||||
-- ####################
|
||||
|
||||
local function build_as_transit(criteria, tot_bytes_as_transit, transit_nodes)
|
||||
for n_id, data in pairs(tot_bytes_as_transit) do
|
||||
if (criteria == traffic_criteria.INGRESS and data.sent > 0) or
|
||||
(criteria == traffic_criteria.EGRESS and data.rcvd > 0) or
|
||||
(criteria == traffic_criteria.TOTAL and (data.rcvd + data.sent) > 0) then
|
||||
-- tprint(n_id .. " " .. criteria .. " " .. data.sent .. " " .. data.rcvd)
|
||||
local transit = shortenString(format_utils.formatASN(data.transit), 64)
|
||||
local src_dst_as = shortenString(format_utils.formatASN(data.src_dst_as), 64)
|
||||
local transit_node_id = find_node_id(transit)
|
||||
local src_dst_as_id = find_node_id(n_id)
|
||||
-- tprint("--- " .. transit .. " " .. src_dst_as)
|
||||
if criteria == traffic_criteria.EGRESS then
|
||||
transit_node_id = "egress" .. "_" .. transit_node_id
|
||||
src_dst_as_id = "egress" .. "_" .. src_dst_as_id
|
||||
else
|
||||
transit_node_id = "ingress" .. "_" .. transit_node_id
|
||||
src_dst_as_id = "ingress" .. "_" .. src_dst_as_id
|
||||
end
|
||||
for n_id, data in pairs(tot_bytes_as_transit) do
|
||||
if (criteria == traffic_criteria.INGRESS and data.sent > 0) or
|
||||
(criteria == traffic_criteria.EGRESS and data.rcvd > 0) or
|
||||
(criteria == traffic_criteria.TOTAL and (data.rcvd + data.sent) > 0) then
|
||||
-- tprint(n_id .. " " .. criteria .. " " .. data.sent .. " " .. data.rcvd)
|
||||
local transit = shortenString(format_utils.formatASN(data.transit), 64)
|
||||
local src_dst_as = shortenString(format_utils.formatASN(data.src_dst_as), 64)
|
||||
local transit_node_id = find_node_id(transit)
|
||||
local src_dst_as_id = find_node_id(n_id)
|
||||
-- tprint("--- " .. transit .. " " .. src_dst_as)
|
||||
if criteria == traffic_criteria.EGRESS then
|
||||
transit_node_id = "egress" .. "_" .. transit_node_id
|
||||
src_dst_as_id = "egress" .. "_" .. src_dst_as_id
|
||||
else
|
||||
transit_node_id = "ingress" .. "_" .. transit_node_id
|
||||
src_dst_as_id = "ingress" .. "_" .. src_dst_as_id
|
||||
end
|
||||
|
||||
if (transit_nodes[data.transit] == nil and data.transit ~= data.src_dst_as) then
|
||||
transit_nodes[data.transit] = transit_node_id
|
||||
end
|
||||
|
||||
local url = ntop.getHttpPrefix() .. "/lua/hosts_stats.lua?asn=" .. src_dst_as .. ""
|
||||
add_unique_node(src_dst_as_id, src_dst_as, url)
|
||||
if data.transit ~= data.src_dst_as then
|
||||
url = ntop.getHttpPrefix() .. "/lua/hosts_stats.lua?asn=" .. data.transit .. ""
|
||||
add_unique_node(transit_node_id, transit, url)
|
||||
end
|
||||
|
||||
if (transit_nodes[data.transit] == nil and data.transit ~= data.src_dst_as) then
|
||||
transit_nodes[data.transit] = transit_node_id
|
||||
end
|
||||
|
||||
if criteria == traffic_criteria.INGRESS then
|
||||
if data.transit ~= data.src_dst_as then
|
||||
add_link(src_dst_as_id, transit_node_id, bytesToSize(data.sent), data.sent)
|
||||
else
|
||||
add_link(src_dst_as_id, as_root_key, bytesToSize(data.sent), data.sent)
|
||||
end
|
||||
elseif criteria == traffic_criteria.EGRESS then
|
||||
if data.transit ~= data.src_dst_as then
|
||||
add_link(transit_node_id, src_dst_as_id, bytesToSize(data.rcvd), data.rcvd)
|
||||
else
|
||||
add_link(as_root_key, src_dst_as_id, bytesToSize(data.rcvd), data.rcvd)
|
||||
end
|
||||
elseif criteria == traffic_criteria.TOTAL then
|
||||
if data.transit ~= data.src_dst_as then
|
||||
add_link(src_dst_as_id, transit_node_id,
|
||||
bytesToSize(data.rcvd + data.sent), data.rcvd + data.sent)
|
||||
else
|
||||
add_link(src_dst_as_id, as_root_key,
|
||||
bytesToSize(data.rcvd + data.sent), data.rcvd + data.sent)
|
||||
end
|
||||
end
|
||||
end
|
||||
end
|
||||
local url = ntop.getHttpPrefix() .. "/lua/hosts_stats.lua?asn=" .. src_dst_as .. ""
|
||||
add_unique_node(src_dst_as_id, src_dst_as, url)
|
||||
if data.transit ~= data.src_dst_as then
|
||||
url = ntop.getHttpPrefix() .. "/lua/hosts_stats.lua?asn=" .. data.transit .. ""
|
||||
add_unique_node(transit_node_id, transit, url)
|
||||
end
|
||||
|
||||
|
||||
if criteria == traffic_criteria.INGRESS then
|
||||
if data.transit ~= data.src_dst_as then
|
||||
add_link(src_dst_as_id, transit_node_id, bytesToSize(data.sent), data.sent)
|
||||
else
|
||||
add_link(src_dst_as_id, as_root_key, bytesToSize(data.sent), data.sent)
|
||||
end
|
||||
elseif criteria == traffic_criteria.EGRESS then
|
||||
if data.transit ~= data.src_dst_as then
|
||||
add_link(transit_node_id, src_dst_as_id, bytesToSize(data.rcvd), data.rcvd)
|
||||
else
|
||||
add_link(as_root_key, src_dst_as_id, bytesToSize(data.rcvd), data.rcvd)
|
||||
end
|
||||
elseif criteria == traffic_criteria.TOTAL then
|
||||
if data.transit ~= data.src_dst_as then
|
||||
add_link(src_dst_as_id, transit_node_id,
|
||||
bytesToSize(data.rcvd + data.sent), data.rcvd + data.sent)
|
||||
else
|
||||
add_link(src_dst_as_id, as_root_key,
|
||||
bytesToSize(data.rcvd + data.sent), data.rcvd + data.sent)
|
||||
end
|
||||
end
|
||||
end
|
||||
end
|
||||
end
|
||||
|
||||
-- ####################
|
||||
|
||||
local function build_to_as(criteria, nodes, tot_bytes)
|
||||
for id, node_id in pairs(nodes) do
|
||||
local sent = tot_bytes[id].sent
|
||||
local rcvd = tot_bytes[id].rcvd
|
||||
for id, node_id in pairs(nodes) do
|
||||
local sent = tot_bytes[id].sent
|
||||
local rcvd = tot_bytes[id].rcvd
|
||||
|
||||
if criteria == traffic_criteria.INGRESS and sent > 0 then
|
||||
add_link(node_id,as_root_key,bytesToSize(sent),sent)
|
||||
elseif criteria == traffic_criteria.EGRESS and rcvd > 0 then
|
||||
add_link(as_root_key, node_id, bytesToSize(rcvd), rcvd)
|
||||
elseif criteria == traffic_criteria.TOTAL then
|
||||
add_link(node_id, as_root_key, bytesToSize(rcvd + sent),rcvd + sent)
|
||||
end
|
||||
end
|
||||
if criteria == traffic_criteria.INGRESS and sent > 0 then
|
||||
add_link(node_id,as_root_key,bytesToSize(sent),sent)
|
||||
elseif criteria == traffic_criteria.EGRESS and rcvd > 0 then
|
||||
add_link(as_root_key, node_id, bytesToSize(rcvd), rcvd)
|
||||
elseif criteria == traffic_criteria.TOTAL then
|
||||
add_link(node_id, as_root_key, bytesToSize(rcvd + sent),rcvd + sent)
|
||||
end
|
||||
end
|
||||
end
|
||||
|
||||
-- Flow iterator callback
|
||||
function callback(_, flow)
|
||||
if (debug) then
|
||||
-- tprint(flow.bytes_sent .. " / " .. flow.bytes_rcvd)
|
||||
tprint("[AS] " .. flow.src_as .. " -> " .. flow.dst_as .. " | [IDX] " ..
|
||||
flow.in_index .. " -> " .. flow.out_index .. " | " ..
|
||||
flow.bytes_sent .. " / " .. flow.bytes_rcvd)
|
||||
end
|
||||
if (sankey_debug) then
|
||||
-- tprint(flow.bytes_sent .. " / " .. flow.bytes_rcvd)
|
||||
tprint("[AS] " .. flow.src_as .. " -> " .. flow.dst_as .. " | [IDX] " ..
|
||||
flow.in_index .. " -> " .. flow.out_index .. " | " ..
|
||||
flow.bytes_sent .. " / " .. flow.bytes_rcvd)
|
||||
end
|
||||
|
||||
-- Initialize hash entries if not yet popupated
|
||||
init_exporter(flow.device_ip)
|
||||
init_interface(flow.device_ip, flow.in_index)
|
||||
init_interface(flow.device_ip, flow.out_index)
|
||||
if (flow.src_as == asn) then
|
||||
if (criteria ~= traffic_criteria.AS_TRAFFIC or
|
||||
(criteria == traffic_criteria.AS_TRAFFIC
|
||||
and (remote_asn[tostring(flow.dst_as)] ~= nil) -- This ASN is listed among the remote/relevant ones
|
||||
and customer_asn[tostring(asn)]==nil)) then
|
||||
inc_interface_sent(get_interface_key(flow.device_ip, flow.in_index),
|
||||
-- Initialize hash entries if not yet popupated
|
||||
init_exporter(flow.device_ip)
|
||||
init_interface(flow.device_ip, flow.in_index)
|
||||
init_interface(flow.device_ip, flow.out_index)
|
||||
if (flow.src_as == asn) then
|
||||
if (criteria ~= traffic_criteria.AS_TRAFFIC or
|
||||
(criteria == traffic_criteria.AS_TRAFFIC
|
||||
and (remote_asn[tostring(flow.dst_as)] ~= nil) -- This ASN is listed among the remote/relevant ones
|
||||
and customer_asn[tostring(asn)]==nil)) then
|
||||
inc_interface_sent(get_interface_key(flow.device_ip, flow.in_index),
|
||||
flow.bytes_rcvd)
|
||||
inc_interface_rcvd(get_interface_key(flow.device_ip, flow.in_index),
|
||||
inc_interface_rcvd(get_interface_key(flow.device_ip, flow.in_index),
|
||||
flow.bytes_sent)
|
||||
inc_exporter_sent(flow.device_ip, flow.bytes_rcvd)
|
||||
inc_exporter_rcvd(flow.device_ip, flow.bytes_sent)
|
||||
inc_exporter_sent(flow.device_ip, flow.bytes_rcvd)
|
||||
inc_exporter_rcvd(flow.device_ip, flow.bytes_sent)
|
||||
|
||||
-- Transit
|
||||
if(flow.dst_peer_as ~= nil) then
|
||||
init_transit(flow.dst_peer_as)
|
||||
init_src_dst_as(flow.dst_peer_as, flow.dst_as)
|
||||
inc_as_sent(get_as_key(flow.dst_peer_as, flow.dst_as),
|
||||
flow.bytes_rcvd)
|
||||
inc_as_rcvd(get_as_key(flow.dst_peer_as, flow.dst_as),
|
||||
flow.bytes_sent)
|
||||
inc_transit_sent(flow.dst_peer_as, flow.bytes_rcvd)
|
||||
inc_transit_rcvd(flow.dst_peer_as, flow.bytes_sent)
|
||||
end
|
||||
end
|
||||
-- Transit
|
||||
if((flow.dst_peer_as ~= nil) and (flow.dst_as ~= nil)) then
|
||||
init_transit(flow.dst_peer_as)
|
||||
init_src_dst_as(flow.dst_peer_as, flow.dst_as)
|
||||
inc_as_sent(get_as_key(flow.dst_peer_as, flow.dst_as),
|
||||
flow.bytes_rcvd)
|
||||
inc_as_rcvd(get_as_key(flow.dst_peer_as, flow.dst_as),
|
||||
flow.bytes_sent)
|
||||
inc_transit_sent(flow.dst_peer_as, flow.bytes_rcvd)
|
||||
inc_transit_rcvd(flow.dst_peer_as, flow.bytes_sent)
|
||||
end
|
||||
end
|
||||
|
||||
elseif (flow.dst_as == asn) then
|
||||
if (criteria ~= traffic_criteria.AS_TRAFFIC or
|
||||
(criteria == traffic_criteria.AS_TRAFFIC and remote_asn[tostring(flow.src_as)]
|
||||
and customer_asn[tostring(asn)]==nil)) then
|
||||
inc_interface_sent(get_interface_key(flow.device_ip, flow.out_index),
|
||||
elseif (flow.dst_as == asn) then
|
||||
if (criteria ~= traffic_criteria.AS_TRAFFIC or
|
||||
(criteria == traffic_criteria.AS_TRAFFIC and remote_asn[tostring(flow.src_as)]
|
||||
and customer_asn[tostring(asn)]==nil)) then
|
||||
inc_interface_sent(get_interface_key(flow.device_ip, flow.out_index),
|
||||
flow.bytes_sent)
|
||||
inc_interface_rcvd(get_interface_key(flow.device_ip, flow.out_index),
|
||||
inc_interface_rcvd(get_interface_key(flow.device_ip, flow.out_index),
|
||||
flow.bytes_rcvd)
|
||||
inc_exporter_sent(flow.device_ip, flow.bytes_sent)
|
||||
inc_exporter_rcvd(flow.device_ip, flow.bytes_rcvd)
|
||||
inc_exporter_sent(flow.device_ip, flow.bytes_sent)
|
||||
inc_exporter_rcvd(flow.device_ip, flow.bytes_rcvd)
|
||||
|
||||
-- Transit
|
||||
if(flow.src_peer_as ~= nil) then
|
||||
init_transit(flow.src_peer_as)
|
||||
init_src_dst_as(flow.src_peer_as, flow.src_as)
|
||||
inc_as_sent(get_as_key(flow.src_peer_as, flow.src_as),
|
||||
flow.bytes_sent)
|
||||
inc_as_rcvd(get_as_key(flow.src_peer_as, flow.src_as),
|
||||
flow.bytes_rcvd)
|
||||
inc_transit_sent(flow.src_peer_as, flow.bytes_sent)
|
||||
inc_transit_sent(flow.src_peer_as, flow.bytes_rcvd)
|
||||
end
|
||||
end
|
||||
end
|
||||
-- Transit
|
||||
if((flow.src_peer_as ~= nil) and (flow.src_as ~= nil)) then
|
||||
init_transit(flow.src_peer_as)
|
||||
init_src_dst_as(flow.src_peer_as, flow.src_as)
|
||||
inc_as_sent(get_as_key(flow.src_peer_as, flow.src_as),
|
||||
flow.bytes_sent)
|
||||
inc_as_rcvd(get_as_key(flow.src_peer_as, flow.src_as),
|
||||
flow.bytes_rcvd)
|
||||
inc_transit_sent(flow.src_peer_as, flow.bytes_sent)
|
||||
inc_transit_sent(flow.src_peer_as, flow.bytes_rcvd)
|
||||
end
|
||||
end
|
||||
end
|
||||
end
|
||||
|
||||
local flows_filter = {
|
||||
asnFilter = asn,
|
||||
detailsLevel = "normal",
|
||||
maxHits = 10000,
|
||||
perPage = 10000
|
||||
asnFilter = asn,
|
||||
detailsLevel = "normal",
|
||||
maxHits = 10000,
|
||||
perPage = 10000
|
||||
}
|
||||
|
||||
callback_utils.foreachFlow(ifid, os.time() + 30, -- deadline
|
||||
callback, flows_filter)
|
||||
callback, flows_filter)
|
||||
|
||||
-- ###################################################
|
||||
|
||||
if (debug) then
|
||||
tprint(tot_bytes_exp_if)
|
||||
tprint(tot_bytes_exporter)
|
||||
if (sankey_debug) then
|
||||
tprint(tot_bytes_exp_if)
|
||||
tprint(tot_bytes_exporter)
|
||||
end
|
||||
|
||||
local exporter_nodes = {}
|
||||
local transit_nodes = {}
|
||||
|
||||
if (criteria == traffic_criteria.ING_EGR) then
|
||||
-- Ingress
|
||||
build_interface_exporter(traffic_criteria.INGRESS, tot_bytes_exp_if,
|
||||
exporter_nodes)
|
||||
build_to_as(traffic_criteria.INGRESS, exporter_nodes, tot_bytes_exporter)
|
||||
-- Ingress
|
||||
build_interface_exporter(traffic_criteria.INGRESS, tot_bytes_exp_if,
|
||||
exporter_nodes)
|
||||
build_to_as(traffic_criteria.INGRESS, exporter_nodes, tot_bytes_exporter)
|
||||
|
||||
reset_nodes()
|
||||
exporter_nodes = {}
|
||||
reset_nodes()
|
||||
exporter_nodes = {}
|
||||
|
||||
-- Egress
|
||||
build_interface_exporter(traffic_criteria.EGRESS, tot_bytes_exp_if,
|
||||
exporter_nodes)
|
||||
build_to_as(traffic_criteria.EGRESS, exporter_nodes, tot_bytes_exporter)
|
||||
-- Egress
|
||||
build_interface_exporter(traffic_criteria.EGRESS, tot_bytes_exp_if,
|
||||
exporter_nodes)
|
||||
build_to_as(traffic_criteria.EGRESS, exporter_nodes, tot_bytes_exporter)
|
||||
|
||||
elseif (criteria == traffic_criteria.AS_TRAFFIC) then
|
||||
-- Ingress
|
||||
build_as_transit(traffic_criteria.INGRESS, tot_bytes_as_transit,
|
||||
transit_nodes)
|
||||
build_to_as(traffic_criteria.INGRESS, transit_nodes, tot_bytes_transit)
|
||||
-- Ingress
|
||||
build_as_transit(traffic_criteria.INGRESS, tot_bytes_as_transit,
|
||||
transit_nodes)
|
||||
build_to_as(traffic_criteria.INGRESS, transit_nodes, tot_bytes_transit)
|
||||
|
||||
reset_nodes()
|
||||
transit_nodes = {}
|
||||
reset_nodes()
|
||||
transit_nodes = {}
|
||||
|
||||
-- Egress
|
||||
build_as_transit(traffic_criteria.EGRESS, tot_bytes_as_transit,
|
||||
transit_nodes)
|
||||
build_to_as(traffic_criteria.EGRESS, transit_nodes, tot_bytes_transit)
|
||||
-- Egress
|
||||
build_as_transit(traffic_criteria.EGRESS, tot_bytes_as_transit,
|
||||
transit_nodes)
|
||||
build_to_as(traffic_criteria.EGRESS, transit_nodes, tot_bytes_transit)
|
||||
|
||||
else
|
||||
-- Build Interface <-> Exporter links
|
||||
build_interface_exporter(criteria, tot_bytes_exp_if, exporter_nodes)
|
||||
-- Build Exporter <-> AS links
|
||||
build_exporter_as(criteria, exporter_nodes)
|
||||
-- Build Interface <-> Exporter links
|
||||
build_interface_exporter(criteria, tot_bytes_exp_if, exporter_nodes)
|
||||
-- Build Exporter <-> AS links
|
||||
build_exporter_as(criteria, exporter_nodes)
|
||||
end
|
||||
rsp["nodes"] = nodes
|
||||
rsp["links"] = links
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue