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

Old sprobe code cleanup

Browse source
This commit is contained in:
Simone Mainardi 2018-11-06 15:38:49 +01:00
parent 16467640fd
commit 94386fd5ff
6 changed files with 97 additions and 108 deletions
Download patch file Download diff file Expand all files Collapse all files

34
scripts/lua/sprobe_host_process_data.lua
View file

@ -22,44 +22,44 @@ for key, value in pairs(flows_stats) do
flow = flows_stats[key]
if((host_ip ~= nil)
and (flow["cli.ip"] ~= host_ip)
and (flow["srv.ip"] ~= host_ip)) then
and (flow["cli.ip"] ~= host_ip)
and (flow["srv.ip"] ~= host_ip)) then
-- wrong
elseif((flow["client_process"] ~= nil) or (flow["server_process"] ~= nil)) then
elseif((flow["client_process"] ~= nil) or (flow["server_process"] ~= nil)) then
if((flow["client_process"] ~= nil)
and (flow["server_process"] ~= nil)) then
and (flow["server_process"] ~= nil)) then
if(n > 0) then print(",") end
print('\n\t{"source": "'..flow["client_process"]["name"]..'", "source_type": "proc", "source_pid": '..
flow["client_process"]["pid"] ..', "source_name": "'.. flow["client_process"]["name"] ..'", "target": "'
..flow["server_process"]["name"]..'", "target_type": "proc", "target_pid": '..
flow["server_process"]["pid"] ..', "target_name": "'.. flow["server_process"]["name"] ..'", "type": "proc2proc"}')
flow["client_process"]["pid"] ..', "source_name": "'.. flow["client_process"]["name"] ..'", "target": "'
..flow["server_process"]["name"]..'", "target_type": "proc", "target_pid": '..
flow["server_process"]["pid"] ..', "target_name": "'.. flow["server_process"]["name"] ..'", "type": "proc2proc"}')
n = n + 1
else
if((flow["cli.ip"] == host_ip) and (flow["srv.ip"] == host_ip)) then
-- Skip
else
if(n > 0) then print(",") end
n = n + 1
n = n + 1
if(flow["client_process"] ~= nil) then
if(flow["cli.ip"] == host_ip) then
print('\n\t{"source": "'..flow["client_process"]["pid"]..'", "source_type": "proc", "source_pid": '.. flow["client_process"]["pid"] ..', "source_name": "'..
flow["client_process"]["name"]..'", "target": "'..flow["srv.ip"]..'", "target_type": "host", "target_pid": -1, "target_name": "'
.. getResolvedAddress(hostkey2hostinfo(flow["srv.ip"])) ..'", "type": "proc2host"}')
flow["client_process"]["name"]..'", "target": "'..flow["srv.ip"]..'", "target_type": "host", "target_pid": -1, "target_name": "'
.. getResolvedAddress(hostkey2hostinfo(flow["srv.ip"])) ..'", "type": "proc2host"}')
else
print('\n\t{"target": "'..flow["client_process"]["pid"]..'", "target_type": "proc", "target_pid": '.. flow["client_process"]["pid"] ..
', "target_name": "'.. flow["client_process"]["name"].."@".. flow["srv.ip"] ..'", "source": "'..flow["cli.ip"]..
'", "source_type": "host", "source_pid": -1, "source_name": "'.. getResolvedAddress(hostkey2hostinfo(flow["cli.ip"])) ..'", "type": "host2proc"}')
', "target_name": "'.. flow["client_process"]["name"].."@".. flow["srv.ip"] ..'", "source": "'..flow["cli.ip"]..
'", "source_type": "host", "source_pid": -1, "source_name": "'.. getResolvedAddress(hostkey2hostinfo(flow["cli.ip"])) ..'", "type": "host2proc"}')
end
elseif(flow["server_process"] ~= nil) then
elseif(flow["server_process"] ~= nil) then
if(flow["srv.ip"] == host_ip) then
print('\n\t{"target": "'..flow["server_process"]["pid"]..'", "target_type": "proc", "target_pid": '.. flow["server_process"]["pid"]
..', "target_name": "'.. flow["server_process"]["name"]..'", "source": "'..flow["cli.ip"]..
'", "source_type": "host", "source_pid": -1, "source_name": "'.. getResolvedAddress(hostkey2hostinfo(flow["cli.ip"])) ..'", "type": "proc2host"}')
..', "target_name": "'.. flow["server_process"]["name"]..'", "source": "'..flow["cli.ip"]..
'", "source_type": "host", "source_pid": -1, "source_name": "'.. getResolvedAddress(hostkey2hostinfo(flow["cli.ip"])) ..'", "type": "proc2host"}')
else
print('\n\t{"target": "'..flow["server_process"]["pid"]..'", "target_type": "proc", "target_pid": '.. flow["server_process"]["pid"] ..
', "target_name": "'.. flow["server_process"]["name"].."@".. flow["srv.ip"] ..'", "source": "'..flow["cli.ip"]..
'", "source_type": "host", "source_pid": -1, "source_name": "'.. getResolvedAddress(hostkey2hostinfo(flow["cli.ip"])) ..'", "type": "host2proc"}')
', "target_name": "'.. flow["server_process"]["name"].."@".. flow["srv.ip"] ..'", "source": "'..flow["cli.ip"]..
'", "source_type": "host", "source_pid": -1, "source_name": "'.. getResolvedAddress(hostkey2hostinfo(flow["cli.ip"])) ..'", "type": "host2proc"}')
end
end
end