mirror of
https://github.com/kellyjonbrazil/jc.git
synced 2025-06-17 00:07:37 +02:00
add netstat -r support for linux
This commit is contained in:
@ -374,16 +374,19 @@ Returns:
|
||||
"sndbuf": integer,
|
||||
"rxbytes": integer,
|
||||
"txbytes": integer,
|
||||
|
||||
|
||||
"destination": string,
|
||||
"gateway": string,
|
||||
"route_flags": string,
|
||||
"route_refs": integer,
|
||||
"use": integer,
|
||||
"mtu": integer,
|
||||
"netif": string,
|
||||
"expire": string
|
||||
"expire": string,
|
||||
"genmask": string,
|
||||
"mss": integer,
|
||||
"window": integer,
|
||||
"irtt": integer,
|
||||
"iface": string,
|
||||
"metric": integer
|
||||
}
|
||||
]
|
||||
|
||||
|
@ -381,16 +381,19 @@ def process(proc_data):
|
||||
"sndbuf": integer,
|
||||
"rxbytes": integer,
|
||||
"txbytes": integer,
|
||||
|
||||
|
||||
"destination": string,
|
||||
"gateway": string,
|
||||
"route_flags": string,
|
||||
"route_refs": integer,
|
||||
"use": integer,
|
||||
"mtu": integer,
|
||||
"netif": string,
|
||||
"expire": string
|
||||
"expire": string,
|
||||
"genmask": string,
|
||||
"mss": integer,
|
||||
"window": integer,
|
||||
"irtt": integer,
|
||||
"iface": string,
|
||||
"metric": integer
|
||||
}
|
||||
]
|
||||
"""
|
||||
@ -398,7 +401,7 @@ def process(proc_data):
|
||||
# integer changes
|
||||
int_list = ['recv_q', 'send_q', 'pid', 'refcnt', 'inode', 'unit', 'vendor', 'class',
|
||||
'osx_flags', 'subcla', 'pcbcount', 'rcvbuf', 'sndbuf', 'rxbytes', 'txbytes',
|
||||
'route_refs', 'use', 'mtu']
|
||||
'route_refs', 'use', 'mtu', 'mss', 'window', 'irtt', 'metric']
|
||||
for key in int_list:
|
||||
if key in entry:
|
||||
try:
|
||||
|
@ -14,6 +14,15 @@ def normalize_headers(header):
|
||||
return header
|
||||
|
||||
|
||||
def normalize_route_headers(header):
|
||||
header = header.lower()
|
||||
header = header.replace('flags', 'route_flags')
|
||||
header = header.replace('ref', 'route_refs')
|
||||
header = header.replace('-', '_')
|
||||
|
||||
return header
|
||||
|
||||
|
||||
def parse_network(headers, entry):
|
||||
# Count words in header
|
||||
# if len of line is one less than len of header, then insert None in field 5
|
||||
@ -62,6 +71,14 @@ def parse_socket(header_text, headers, entry):
|
||||
return output_line
|
||||
|
||||
|
||||
def parse_route(headers, entry):
|
||||
entry = entry.split(maxsplit=len(headers) - 1)
|
||||
output_line = dict(zip(headers, entry))
|
||||
output_line['kind'] = 'route'
|
||||
|
||||
return output_line
|
||||
|
||||
|
||||
def parse_post(raw_data):
|
||||
# clean up trailing whitespace on each item in each entry
|
||||
# flags --- = null
|
||||
@ -139,6 +156,7 @@ def parse(cleandata):
|
||||
network = False
|
||||
socket = False
|
||||
bluetooth = False
|
||||
routing_table = False
|
||||
headers = None
|
||||
|
||||
for line in cleandata:
|
||||
@ -147,18 +165,28 @@ def parse(cleandata):
|
||||
network = True
|
||||
socket = False
|
||||
bluetooth = False
|
||||
routing_table = False
|
||||
continue
|
||||
|
||||
if line.startswith('Active UNIX'):
|
||||
network = False
|
||||
socket = True
|
||||
bluetooth = False
|
||||
routing_table = False
|
||||
continue
|
||||
|
||||
if line.startswith('Active Bluetooth'):
|
||||
network = False
|
||||
socket = False
|
||||
bluetooth = True
|
||||
routing_table = False
|
||||
continue
|
||||
|
||||
if line.startswith('Kernel IP routing table'):
|
||||
network = False
|
||||
socket = False
|
||||
bluetooth = False
|
||||
routing_table = True
|
||||
continue
|
||||
|
||||
if line.startswith('Proto'):
|
||||
@ -166,6 +194,11 @@ def parse(cleandata):
|
||||
headers = header_text.split()
|
||||
continue
|
||||
|
||||
if line.startswith('Destination '):
|
||||
header_text = normalize_route_headers(line)
|
||||
headers = header_text.split()
|
||||
continue
|
||||
|
||||
if network:
|
||||
raw_output.append(parse_network(headers, line))
|
||||
continue
|
||||
@ -178,4 +211,8 @@ def parse(cleandata):
|
||||
# not implemented
|
||||
continue
|
||||
|
||||
if routing_table:
|
||||
raw_output.append(parse_route(headers, line))
|
||||
continue
|
||||
|
||||
return parse_post(raw_output)
|
||||
|
@ -17,6 +17,7 @@ def normalize_route_headers(header):
|
||||
header = header.lower()
|
||||
header = header.replace('flags', 'route_flags')
|
||||
header = header.replace('refs', 'route_refs')
|
||||
header = header.replace('netif', 'iface')
|
||||
header = header.replace('-', '_')
|
||||
|
||||
return header
|
||||
|
5
tests/fixtures/centos-7.7/netstat-r.out
vendored
Normal file
5
tests/fixtures/centos-7.7/netstat-r.out
vendored
Normal file
@ -0,0 +1,5 @@
|
||||
Kernel IP routing table
|
||||
Destination Gateway Genmask Flags MSS Window irtt Iface
|
||||
default gateway 0.0.0.0 UG 0 0 0 ens33
|
||||
172.17.0.0 0.0.0.0 255.255.0.0 U 0 0 0 docker0
|
||||
192.168.71.0 0.0.0.0 255.255.255.0 U 0 0 0 ens33
|
5
tests/fixtures/centos-7.7/netstat-rne.out
vendored
Normal file
5
tests/fixtures/centos-7.7/netstat-rne.out
vendored
Normal file
@ -0,0 +1,5 @@
|
||||
Kernel IP routing table
|
||||
Destination Gateway Genmask Flags Metric Ref Use Iface
|
||||
0.0.0.0 192.168.71.2 0.0.0.0 UG 100 0 0 ens33
|
||||
172.17.0.0 0.0.0.0 255.255.0.0 U 0 0 0 docker0
|
||||
192.168.71.0 0.0.0.0 255.255.255.0 U 100 0 0 ens33
|
5
tests/fixtures/centos-7.7/netstat-rnee.out
vendored
Normal file
5
tests/fixtures/centos-7.7/netstat-rnee.out
vendored
Normal file
@ -0,0 +1,5 @@
|
||||
Kernel IP routing table
|
||||
Destination Gateway Genmask Flags Metric Ref Use Iface MSS Window irtt
|
||||
0.0.0.0 192.168.71.2 0.0.0.0 UG 100 0 0 ens33 0 0 0
|
||||
172.17.0.0 0.0.0.0 255.255.0.0 U 0 0 0 docker 0 0 0
|
||||
192.168.71.0 0.0.0.0 255.255.255.0 U 100 0 0 ens33 0 0 0
|
2
tests/fixtures/osx-10.14.6/netstat-r.json
vendored
2
tests/fixtures/osx-10.14.6/netstat-r.json
vendored
File diff suppressed because one or more lines are too long
2
tests/fixtures/osx-10.14.6/netstat-rnl.json
vendored
2
tests/fixtures/osx-10.14.6/netstat-rnl.json
vendored
File diff suppressed because one or more lines are too long
Reference in New Issue
Block a user