Fix Stress Test (#1935)

Author: utpilla

stress/src/logs.rs

@@ -1,9 +1,9 @@
 /*
     Stress test results:
-    OS: Ubuntu 22.04.3 LTS (5.15.146.1-microsoft-standard-WSL2)
-    Hardware: AMD EPYC 7763 64-Core Processor - 2.44 GHz, 16vCPUs,
+    OS: Ubuntu 22.04.4 LTS (5.15.153.1-microsoft-standard-WSL2)
+    Hardware: Intel(R) Xeon(R) Platinum 8370C CPU @ 2.80GHz, 16vCPUs,
     RAM: 64.0 GB
-    69 M/sec
+    ~31 M/sec
 */
 
 use opentelemetry_appender_tracing::layer;

stress/src/metrics_counter.rs

@@ -1,9 +1,9 @@
 /*
     Stress test results:
-    OS: Ubuntu 22.04.3 LTS (5.15.146.1-microsoft-standard-WSL2)
-    Hardware: AMD EPYC 7763 64-Core Processor - 2.44 GHz, 16vCPUs,
+    OS: Ubuntu 22.04.4 LTS (5.15.153.1-microsoft-standard-WSL2)
+    Hardware: Intel(R) Xeon(R) Platinum 8370C CPU @ 2.80GHz, 16vCPUs,
     RAM: 64.0 GB
-    35 M /sec
+    ~9.5 M /sec
 */
 
 use lazy_static::lazy_static;

stress/src/metrics_histogram.rs

@@ -1,9 +1,9 @@
 /*
     Stress test results:
-    OS: Ubuntu 22.04.3 LTS (5.15.146.1-microsoft-standard-WSL2)
-    Hardware: AMD EPYC 7763 64-Core Processor - 2.44 GHz, 16vCPUs,
+    OS: Ubuntu 22.04.4 LTS (5.15.153.1-microsoft-standard-WSL2)
+    Hardware: Intel(R) Xeon(R) Platinum 8370C CPU @ 2.80GHz, 16vCPUs,
     RAM: 64.0 GB
-    4.6M /sec
+    ~1.8 M/sec
 */
 
 use lazy_static::lazy_static;

stress/src/metrics_overflow.rs

@@ -1,9 +1,9 @@
 /*
     Stress test results:
-    OS: Ubuntu 22.04.3 LTS (5.15.146.1-microsoft-standard-WSL2)
-    Hardware: AMD EPYC 7763 64-Core Processor - 2.44 GHz, 16vCPUs,
+    OS: Ubuntu 22.04.4 LTS (5.15.153.1-microsoft-standard-WSL2)
+    Hardware: Intel(R) Xeon(R) Platinum 8370C CPU @ 2.80GHz, 16vCPUs,
     RAM: 64.0 GB
-    4.5M /sec
+    ~1.9 M/sec
 */
 
 use lazy_static::lazy_static;

stress/src/random.rs

@@ -1,9 +1,9 @@
 /*
     Stress test results:
-    OS: Ubuntu 22.04.3 LTS (5.15.146.1-microsoft-standard-WSL2)
-    Hardware: AMD EPYC 7763 64-Core Processor - 2.44 GHz, 16vCPUs,
+    OS: Ubuntu 22.04.4 LTS (5.15.153.1-microsoft-standard-WSL2)
+    Hardware: Intel(R) Xeon(R) Platinum 8370C CPU @ 2.80GHz, 16vCPUs,
     RAM: 64.0 GB
-    1.25 B/sec
+    ~540 M/sec
 */
 
 use rand::{

stress/src/throughput.rs

@@ -69,8 +69,7 @@ where
     let worker_stats_shared_monitor = Arc::clone(&worker_stats_shared);
 
     let handle_main_thread = thread::spawn(move || {
-        let mut start_time = Instant::now();
-        let mut end_time = start_time;
+        let mut last_collect_time = Instant::now();
         let mut total_count_old: u64 = 0;
 
         #[cfg(feature = "stats")]
@@ -79,12 +78,14 @@ where
         let mut system = System::new_all();
 
         loop {
-            let elapsed = end_time.duration_since(start_time).as_secs();
+            let current_time = Instant::now();
+            let elapsed = current_time.duration_since(last_collect_time).as_secs();
             if elapsed >= SLIDING_WINDOW_SIZE {
                 let total_count_u64: u64 = worker_stats_shared_monitor
                     .iter()
                     .map(|worker_stat| worker_stat.count.load(Ordering::Relaxed))
                     .sum();
+                last_collect_time = Instant::now();
                 let current_count = total_count_u64 - total_count_old;
                 total_count_old = total_count_u64;
                 let throughput = current_count / elapsed;
@@ -112,14 +113,12 @@ where
                 }
 
                 println!("\n");
-                start_time = Instant::now();
             }
 
             if STOP.load(Ordering::SeqCst) {
                 break;
             }
 
-            end_time = Instant::now();
             thread::sleep(Duration::from_millis(5000));
         }
     });

stress/src/traces.rs

@@ -1,9 +1,9 @@
 /*
     Stress test results:
-    OS: Ubuntu 22.04.3 LTS (5.15.146.1-microsoft-standard-WSL2)
-    Hardware: AMD EPYC 7763 64-Core Processor - 2.44 GHz, 16vCPUs,
+    OS: Ubuntu 22.04.4 LTS (5.15.153.1-microsoft-standard-WSL2)
+    Hardware: Intel(R) Xeon(R) Platinum 8370C CPU @ 2.80GHz, 16vCPUs,
     RAM: 64.0 GB
-    9 M/sec
+    ~6.5 M/sec
 */
 
 use lazy_static::lazy_static;