Changeset ce98816

Timestamp:

Jun 4, 2022, 2:43:16 PM (23 months ago)

Author:

Thierry Delisle <tdelisle@…>

Branches:

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

Children:

f11296a

Parents:

c4b10e2

Message:

Stats printer now uses a condition variable to sleep so it exists immediately.

File:

• benchmark/io/http/main.cfa (modified) (4 diffs)

benchmark/io/http/main.cfa

@@ -16 +16 @@
 #include <fstream.hfa>
 #include <kernel.hfa>
+#include <locks.hfa>
 #include <iofwd.hfa>
 #include <stats.hfa>
@@ -39 +40 @@
         Worker * workers;
         int worker_cnt;
+        condition_variable(fast_block_lock) var;
 };
 
@@ -57 +59 @@
                 or else {}
 
-                sleep(10`s);
+                wait(this.var, 10`s);
 
                 print_stats_now( *active_cluster(), CFA_STATS_READY_Q | CFA_STATS_IO );
@@ -342 +344 @@
                         for(i; options.clopts.nclusters) {
                                 StatsPrinter * p = cl[i].prnt;
-                                if(p) join(*p);
+                                if(p) {
+                                        notify_one(p->var);
+                                        join(*p);
+                                }
                         }
                         sout | "done";