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

When tracking Node (AP) latency, use median instead of avg

Browse Source
This commit is contained in:
Robert Chacón
2022-11-01 04:29:04 -06:00
committed by GitHub
parent b2af210ae2
commit 5aef51ce4d
1 changed files with 5 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
v1.3/graphInfluxDB.py
View File

@@ -3,6 +3,7 @@ import json
import subprocess
from datetime import datetime
from pathlib import Path
import statistics
from influxdb_client import InfluxDBClient, Point
from influxdb_client.client.write_api import SYNCHRONOUS
@@ -287,16 +288,14 @@ def getParentNodeLatencyStats(parentNodes, subscriberCircuits):
parentNode['stats']['sinceLastQuery'] = {}
for parentNode in parentNodes:
combinedSubLatencies = 0.0
thisParentNodeStats = {'sinceLastQuery': {}}
circuitsMatched = 0
circuitsMatchedLatencies = []
for circuit in subscriberCircuits:
if circuit['ParentNode'] == parentNode['parentNodeName']:
if circuit['stats']['sinceLastQuery']['tcpLatency'] != None:
combinedSubLatencies += circuit['stats']['sinceLastQuery']['tcpLatency']
circuitsMatched += 1
if circuitsMatched > 0:
thisParentNodeStats['sinceLastQuery']['tcpLatency'] = float(combinedSubLatencies / circuitsMatched)
circuitsMatchedLatencies.append(circuit['stats']['sinceLastQuery']['tcpLatency'])
if len(circuitsMatchedLatencies) > 0:
thisParentNodeStats['sinceLastQuery']['tcpLatency'] = statistics.median(items)
else:
thisParentNodeStats['sinceLastQuery']['tcpLatency'] = None
parentNode['stats'] = thisParentNodeStats