IntenseWebs/LibreQoS
3
0
Fork 0
mirror of https://github.com/LibreQoE/LibreQoS.git synced 2025-02-25 18:55:32 -06:00
Code Issues Packages Projects Releases Wiki Activity

Update graphInfluxDB.py

Browse Source
This commit is contained in:
Robert Chacón 2023-02-02 21:46:24 -07:00 committed by GitHub
parent 4acfb77ea8
commit b89f5254c6
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/graphInfluxDB.py
View File

@ -306,16 +306,18 @@ def getParentNodeLatencyStats(parentNodes, subscriberCircuits):
def getCircuitLatencyStats(subscriberCircuits):
command = './src/bin/xdp_pping'
listOfEntries = json.loads(subprocess.run(command.split(' '), stdout=subprocess.PIPE).stdout.decode('utf-8'))
command = './bin/xdp_pping'
consoleOutput = subprocess.run(command.split(' '), stdout=subprocess.PIPE).stdout.decode('utf-8')
consoleOutput = consoleOutput.replace('\n','').replace('}{', '}, {')
listOfEntries = json.loads(consoleOutput)
tcpLatencyForClassID = {}
for entry in listOfEntries:
if 'tc' in entry:
handle = hex(int(entry['tc'].split(':')[0])) + ':' + hex(int(entry['tc'].split(':')[1]))
handle = '0x' + entry['tc'].split(':')[0] + ':' + '0x' + entry['tc'].split(':')[1]
# To avoid outliers messing up avg for each circuit - cap at ceiling of 200ms
ceiling = 200.0
tcpLatencyForClassID[handle] = min(entry['avg'], ceiling)
tcpLatencyForClassID[handle] = min(entry['median'], ceiling)
for circuit in subscriberCircuits:
if 'stats' not in circuit: