[netperf-dev] netperf2 commit notice r614 - trunk/src

[raj at netperf.org]

Author: raj
Date: 2012-11-26 16:35:38 -0800 (Mon, 26 Nov 2012)
New Revision: 614

Modified:
   trunk/src/netlib.c
   trunk/src/netlib.h
   trunk/src/nettest_omni.c
Log:

try to do something sane with the time histogram when we have a receive timeout

Modified: trunk/src/netlib.c
===================================================================
--- trunk/src/netlib.c	2012-11-26 23:17:51 UTC (rev 613)
+++ trunk/src/netlib.c	2012-11-27 00:35:38 UTC (rev 614)
@@ -4093,7 +4093,6 @@
 }
 
 void demo_interval_final() {
-
   double actual_interval;
 
   switch (demo_mode) {

Modified: trunk/src/netlib.h
===================================================================
--- trunk/src/netlib.h	2012-11-26 23:17:51 UTC (rev 613)
+++ trunk/src/netlib.h	2012-11-27 00:35:38 UTC (rev 614)
@@ -600,6 +600,7 @@
 extern void     find_system_info(char **system_model, char **cpu_model, int *cpu_frequency);
 extern int      HIST_get_percentile();
 extern void     HIST_get_stats();
+extern void     HIST_purge();
 extern void     find_security_info(int *enabled, int *type, char **specific);
 extern void     demo_first_timestamp();
 extern void     demo_reset();

Modified: trunk/src/nettest_omni.c
===================================================================
--- trunk/src/nettest_omni.c	2012-11-26 23:17:51 UTC (rev 613)
+++ trunk/src/nettest_omni.c	2012-11-27 00:35:38 UTC (rev 614)
@@ -4346,7 +4346,8 @@
 	  /* we timed-out on a data receive.  this is only allowed for
 	     a UDP_RR test.  we want to set things up so we start
 	     ramping up again like we were at the beginning. if we
-	     actually timeout it means that all has been lost */
+	     actually timeout it means that all has been lost.  or at
+	     least we assume so */
 	  if (debug) {
 	    fprintf(where,"Timeout receiving resonse from remote\n");
 	    fflush(where);
@@ -4355,6 +4356,9 @@
 	    requests_outstanding = 0;
 	    request_cwnd = request_cwnd_initial;
 	  }
+	  if (keep_histogram) {
+	    HIST_purge(time_hist);
+	  }
 #ifdef WANT_DEMO
 	  demo_reset();
 #endif /* WANT_DEMO */