add a wider variety of jitter calculations

mas-bandwidth · Sep 17, 2024 · 4d3e7a4 · 4d3e7a4
1 parent eb68892
commit 4d3e7a4
Show file tree

Hide file tree

Showing 3 changed files with 68 additions and 9 deletions.
diff --git a/reliable.c b/reliable.c
@@ -511,7 +511,9 @@ struct reliable_endpoint_t
     float rtt_min;
     float rtt_max;
     float rtt_avg;
-    float jitter;
+    float jitter_avg_vs_min_rtt;
+    float jitter_max_vs_min_rtt;
+    float jitter_stddev_vs_avg_rtt;
     float packet_loss;
     float sent_bandwidth_kbps;
     float received_bandwidth_kbps;
@@ -1384,7 +1386,7 @@ void reliable_endpoint_update( struct reliable_endpoint_t * endpoint, double tim
         }
     }
 
-    // calculate jitter
+    // calculate average jitter vs. min rtt
     {
         float sum = 0.0f;
         int count = 0;
@@ -1398,11 +1400,51 @@ void reliable_endpoint_update( struct reliable_endpoint_t * endpoint, double tim
         }
         if ( count > 0 )
         {
-            endpoint->jitter = sum / (float)count;
+            endpoint->jitter_avg_vs_min_rtt = sum / (float)count;
         }
         else
         {
-            endpoint->jitter = 0.0f;
+            endpoint->jitter_avg_vs_min_rtt = 0.0f;
+        }
+    }
+
+    // calculate max jitter vs. min rtt
+    {
+        float max = 0.0f;
+        for ( int i = 0; i < endpoint->config.rtt_history_size; i++ )
+        {
+            if ( endpoint->rtt_history_buffer[i] >= 0.0f )
+            {
+                float difference = ( endpoint->rtt_history_buffer[i] - endpoint->rtt_min );
+                if ( difference > max )
+                {
+                    max = difference;
+                }
+            }
+        }
+        endpoint->jitter_max_vs_min_rtt = max;
+    }
+
+    // calculate stddev jitter vs. avg rtt
+    {
+        float sum = 0.0f;
+        int count = 0;
+        for ( int i = 0; i < endpoint->config.rtt_history_size; i++ )
+        {
+            if ( endpoint->rtt_history_buffer[i] >= 0.0f )
+            {
+                float deviation = ( endpoint->rtt_history_buffer[i] - endpoint->rtt_min );
+                sum += deviation * deviation;
+                count++;
+            }
+        }
+        if ( count > 0 )
+        {
+            endpoint->jitter_stddev_vs_avg_rtt = pow( sum / (float)count, 0.5f );
+        }
+        else
+        {
+            endpoint->jitter_stddev_vs_avg_rtt = 0.0f;
         }
     }
 
@@ -1592,10 +1634,23 @@ float reliable_endpoint_rtt_avg( struct reliable_endpoint_t * endpoint )
     return endpoint->rtt_avg;
 }
 
-float reliable_endpoint_jitter( struct reliable_endpoint_t * endpoint )
+float reliable_endpoint_jitter_avg_vs_min_rtt( struct reliable_endpoint_t * endpoint )
+{
+    reliable_assert( endpoint );
+    return endpoint->jitter_avg_vs_min_rtt;
+}
+
+float reliable_endpoint_jitter_max_vs_min_rtt( struct reliable_endpoint_t * endpoint )
+{
+    reliable_assert( endpoint );
+    return endpoint->jitter_max_vs_min_rtt;
+}
+
+
+float reliable_endpoint_jitter_stddev_vs_avg_rtt( struct reliable_endpoint_t * endpoint )
 {
     reliable_assert( endpoint );
-    return endpoint->jitter;
+    return endpoint->jitter_stddev_vs_avg_rtt;
 }
 
 float reliable_endpoint_packet_loss( struct reliable_endpoint_t * endpoint )

diff --git a/reliable.h b/reliable.h
@@ -138,15 +138,19 @@ void reliable_endpoint_reset( struct reliable_endpoint_t * endpoint );
 
 void reliable_endpoint_update( struct reliable_endpoint_t * endpoint, double time );
 
-float reliable_endpoint_rtt( struct reliable_endpoint_t * endpoint );
+float reliable_endpoint_rtt( struct reliable_endpoint_t * endpoint );       // exponentially smoothed moving average
 
 float reliable_endpoint_rtt_min( struct reliable_endpoint_t * endpoint );
 
 float reliable_endpoint_rtt_max( struct reliable_endpoint_t * endpoint );
 
 float reliable_endpoint_rtt_avg( struct reliable_endpoint_t * endpoint );
 
-float reliable_endpoint_jitter( struct reliable_endpoint_t * endpoint );
+float reliable_endpoint_jitter_avg_vs_min_rtt( struct reliable_endpoint_t * endpoint );
+
+float reliable_endpoint_jitter_max_vs_min_rtt( struct reliable_endpoint_t * endpoint );
+
+float reliable_endpoint_jitter_stddev_vs_avg_rtt( struct reliable_endpoint_t * endpoint );
 
 float reliable_endpoint_packet_loss( struct reliable_endpoint_t * endpoint );
 

diff --git a/stats.c b/stats.c
@@ -222,7 +222,7 @@ void stats_iteration( double time )
         counters[RELIABLE_ENDPOINT_COUNTER_NUM_PACKETS_RECEIVED],
         counters[RELIABLE_ENDPOINT_COUNTER_NUM_PACKETS_ACKED],
         (int) reliable_endpoint_rtt_min( global_context.client ),
-        (int) reliable_endpoint_jitter( global_context.client ),
+        (int) reliable_endpoint_jitter_avg_vs_min_rtt( global_context.client ),
         (int) ( reliable_endpoint_packet_loss( global_context.client ) + 0.5f ),
         (int) sent_bandwidth_kbps,
         (int) received_bandwidth_kbps,