Changeset 153dc387 for benchmark

Timestamp:

Jan 14, 2021, 2:32:36 PM (4 years ago)

Author:

Thierry Delisle <tdelisle@…>

Branches:

ADT, arm-eh, ast-experimental, enum, forall-pointer-decay, jacob/cs343-translation, master, new-ast-unique-expr, pthread-emulation, qualifiedEnum

Children:

7223dbf2

Parents:

ee59ede

Message:

Main now print stats every 10 sec

File:

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

benchmark/io/http/main.cfa

@@ -11 +11 @@
 
 #include <kernel.hfa>
+#include <iofwd.hfa>
 #include <stats.hfa>
 #include <time.hfa>
@@ -48 +49 @@
 extern void init_protocol(void);
 extern void deinit_protocol(void);
+
+//=============================================================================================
+// Stats Printer
+//============================================================================================='
+
+thread StatsPrinter {};
+
+void ?{}( StatsPrinter & this ) {
+        ((thread&)this){ "Stats Printer Thread" };
+}
+
+void main(StatsPrinter & this) {
+        LOOP: for() {
+                waitfor( ^?{} : this) {
+                        break LOOP;
+                }
+                or else {}
+
+                sleep(10`s);
+
+                print_stats_now( *options.clopts.instance, CFA_STATS_READY_Q | CFA_STATS_IO );
+        }
+}
 
 //=============================================================================================
@@ -128 +152 @@
                 {
                         ServerProc procs[options.clopts.nprocs];
+                        StatsPrinter printer;
 
                         init_protocol();
@@ -152 +177 @@
                                         char buffer[128];
                                         while(!feof(stdin)) {
-                                                fgets(buffer, 128, stdin);
+                                                int ret = cfa_read(0, buffer, 128, 0, -1`s, 0p, 0p);
+                                                if(ret < 0) abort( "main read error: (%d) %s\n", (int)errno, strerror(errno) );
                                         }
 
@@ -159 +185 @@
 
                                 for(i; options.clopts.nworkers) {
-                                        printf("Cancelling %p\n", (void*)workers[i].cancel.target);
                                         workers[i].done = true;
                                         cancel(workers[i].cancel);