vrr/ntopng
2
0
Fork 0
mirror of https://github.com/ntop/ntopng.git synced 2026-05-10 17:58:09 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

Implements per-AS nw latency stats rrds

Browse source
This commit is contained in:
Simone Mainardi 2018-02-05 18:32:13 +01:00
parent f37b071d72
commit 3ef543fecd
12 changed files with 63 additions and 22 deletions
Download patch file Download diff file Expand all files Collapse all files

28
src/AutonomousSystem.cpp
View file

@ -21,6 +21,8 @@
#include "ntop_includes.h"
// #define AS_LATENCY_DEBUG 1
/* *************************************** */
AutonomousSystem::AutonomousSystem(NetworkInterface *_iface, IpAddress *ipa) : GenericHashEntry(_iface), GenericTrafficElement() {
@ -45,6 +47,31 @@ AutonomousSystem::~AutonomousSystem() {
/* *************************************** */
void AutonomousSystem::updateNetworkLatency(bool as_client, u_int32_t latency_msecs) {
/* EWMA formula is EWMA(n) = (alpha_percent * sample + (100 - alpha_percent) * EWMA(n-1)) / 100
We read the EWMA alpha_percent from the preferences
*/
u_int8_t ewma_alpha_percent = ntop->getPrefs()->get_ewma_alpha_percent();
if(as_client) ; /* Currently not relevant, only account for server network latency */
else {
#ifdef AS_LATENCY_DEBUG
u_int32_t old_latency = server_network_latency;
#endif
if(server_network_latency)
Utils::update_ewma(latency_msecs, &server_network_latency, ewma_alpha_percent);
else
server_network_latency = latency_msecs;
#ifdef AS_LATENCY_DEBUG
printf("Updating latency EWMA: [asn: %u][sample msecs: %u][old latency: %u][new latency: %u][alpha percent: %u]\n",
asn, latency_msecs, old_latency, server_network_latency, ewma_alpha_percent);
#endif
}
}
/* *************************************** */
bool AutonomousSystem::idle() {
bool rc;
@ -82,6 +109,7 @@ void AutonomousSystem::lua(lua_State* vm, DetailsLevel details_level, bool asLis
lua_push_int_table_entry(vm, "duration", get_duration());
lua_push_int_table_entry(vm, "num_hosts", getNumHosts());
lua_push_int_table_entry(vm, "server_network_latency", server_network_latency);
if(details_level >= details_higher)
if(ndpiStats) ndpiStats->lua(iface, vm);