Changeset 74ec742 for benchmark/readyQ/transfer.rs

Timestamp:

May 20, 2022, 10:36:45 AM (4 years ago)

Author:

m3zulfiq <m3zulfiq@…>

Branches:

ADT, ast-experimental, master, pthread-emulation, qualifiedEnum

Children:

25fa20a

Parents:

29d8c02 (diff), 7831e8fb (diff)
Note: this is a merge changeset, the changes displayed below correspond to the merge itself.
Use the (diff) links above to see all the changes relative to each parent.

Message:

Merge branch 'master' of plg.uwaterloo.ca:software/cfa/cfa-cc

File:

• benchmark/readyQ/transfer.rs (modified) (10 diffs)

benchmark/readyQ/transfer.rs

@@ -6 +6 @@
 use std::hint;
 use std::sync::Arc;
-use std::sync::atomic::{AtomicUsize, Ordering};
+use std::sync::atomic::{AtomicBool, AtomicUsize, Ordering};
 use std::time::{Instant,Duration};
 
@@ -44 +44 @@
                         match val {
                                 "yes" => true,
+                                "Y" => true,
+                                "y" => true,
                                 "no"  => false,
+                                "N"  => false,
+                                "n"  => false,
                                 "maybe" | "I don't know" | "Can you repeat the question?" => {
                                         eprintln!("Lines for 'Malcolm in the Middle' are not acceptable values of parameter 'exhaust'");
@@ -64 +68 @@
         id: AtomicUsize,
         idx: AtomicUsize,
+        estop: AtomicBool,
         seed: u128,
 }
@@ -72 +77 @@
                         id: AtomicUsize::new(nthreads),
                         idx: AtomicUsize::new(0),
+                        estop: AtomicBool::new(false),
                         seed: process::id() as u128
                 };
@@ -100 +106 @@
 }
 
-fn waitgroup(idx: usize, threads: &Vec<Arc<MyThread>>) {
+fn waitgroup(leader: &LeaderInfo, idx: usize, threads: &Vec<Arc<MyThread>>, main_sem: &sync::Semaphore) {
         let start = Instant::now();
-        for t in threads {
+        'outer: for t in threads {
                 debug!( "Waiting for :{} ({})", t.id, t.idx.load(Ordering::Relaxed) );
                 while t.idx.load(Ordering::Relaxed) != idx {
@@ -108 +114 @@
                         if start.elapsed() > Duration::from_secs(5) {
                                 eprintln!("Programs has been blocked for more than 5 secs");
-                                std::process::exit(1);
+                                leader.estop.store(true, Ordering::Relaxed);
+                                main_sem.add_permits(1);
+                                break 'outer;
                         }
                 }
@@ -131 +139 @@
         leader.idx.store(nidx, Ordering::Relaxed);
 
-        if nidx as u64 > exp.stop_count {
+        if nidx as u64 > exp.stop_count || leader.estop.load(Ordering::Relaxed) {
                 debug!( "Leader {} done", this.id);
                 main_sem.add_permits(1);
@@ -139 +147 @@
         debug!( "====================\nLeader no {} : {}", nidx, this.id);
 
-        waitgroup(nidx, threads);
+        waitgroup(leader, nidx, threads, main_sem);
 
         leader.next( threads.len() );
@@ -192 +200 @@
                         wait( exhaust, &leader, &threads[me], &mut rechecks ).await;
                 }
-                if leader.idx.load(Ordering::Relaxed) as u64 > exp.stop_count { break; }
+                if leader.idx.load(Ordering::Relaxed) as u64 > exp.stop_count || leader.estop.load(Ordering::Relaxed) { break; }
         }
 
@@ -273 +281 @@
         println!("Number of processors    : {}", (nprocs).to_formatted_string(&Locale::en));
         println!("Number of threads       : {}", (nthreads).to_formatted_string(&Locale::en));
-        println!("Total Operations(ops)   : {:>15}", (exp.stop_count).to_formatted_string(&Locale::en));
+        println!("Total Operations(ops)   : {:>15}", (leader.idx.load(Ordering::Relaxed) - 1).to_formatted_string(&Locale::en));
         println!("Threads parking on wait : {}", if exhaust { "yes" } else { "no" });
         println!("Rechecking              : {}", rechecks );
-}
+        println!("ns per transfer         : {}", ((duration.as_nanos() as f64) / leader.idx.load(Ordering::Relaxed) as f64));
+
+}