Changeset 137974ae for benchmark/io/http/main.cfa

Timestamp:

Jun 9, 2022, 10:56:34 AM (2 years ago)

Author:

Thierry Delisle <tdelisle@…>

Branches:

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

Children:

430ce61

Parents:

8c58e73

Message:

Moved stats printer to it's own file and now using push-stats rather than pull

File:

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

benchmark/io/http/main.cfa

@@ -25 +25 @@
 #include "options.hfa"
 #include "socket.hfa"
+#include "printer.hfa"
 #include "worker.hfa"
 
@@ -31 +32 @@
 Duration default_preemption() {
         return 0;
-}
-
-//=============================================================================================
-// Stats Printer
-//============================================================================================='
-
-thread StatsPrinter {
-        connection ** conns;
-        volatile int conn_cnt;
-        condition_variable(fast_block_lock) var;
-};
-
-void ?{}( StatsPrinter & this, cluster & cl ) {
-        ((thread&)this){ "Stats Printer Thread", cl };
-        this.conn_cnt = 0;
-}
-
-void ^?{}( StatsPrinter & mutex this ) {}
-
-#define eng3(X) (ws(3, 3, unit(eng( X ))))
-
-void main(StatsPrinter & this) {
-        LOOP: for() {
-                waitfor( ^?{} : this) {
-                        break LOOP;
-                }
-                or else {}
-
-                wait(this.var, 10`s);
-
-                print_stats_now( *active_cluster(), CFA_STATS_READY_Q | CFA_STATS_IO );
-                if(this.conn_cnt != 0) {
-                        uint64_t tries = 0;
-                        uint64_t calls = 0;
-                        uint64_t header = 0;
-                        uint64_t splcin = 0;
-                        uint64_t splcot = 0;
-                        struct {
-                                volatile uint64_t calls;
-                                volatile uint64_t bytes;
-                        } avgrd[zipf_cnts];
-                        memset(avgrd, 0, sizeof(avgrd));
-
-                        for(i; this.conn_cnt) {
-                                tries += this.conns[i]->stats.sendfile.tries;
-                                calls += this.conns[i]->stats.sendfile.calls;
-                                header += this.conns[i]->stats.sendfile.header;
-                                splcin += this.conns[i]->stats.sendfile.splcin;
-                                splcot += this.conns[i]->stats.sendfile.splcot;
-                                for(j; zipf_cnts) {
-                                        avgrd[j].calls += this.conns[i]->stats.sendfile.avgrd[j].calls;
-                                        avgrd[j].bytes += this.conns[i]->stats.sendfile.avgrd[j].bytes;
-                                }
-                        }
-
-                        double ratio = ((double)tries) / calls;
-
-                        sout | "----- Connection Stats -----";
-                        sout | "sendfile  : " | calls | "calls," | tries | "tries (" | ratio | " try/call)";
-                        sout | "            " | header | "header," | splcin | "splice in," | splcot | "splice out";
-                        sout | " - zipf sizes:";
-                        for(i; zipf_cnts) {
-                                double written = avgrd[i].calls > 0 ? ((double)avgrd[i].bytes) / avgrd[i].calls : 0;
-                                sout | "        " | zipf_sizes[i] | "bytes," | avgrd[i].calls | "shorts," | written | "written";
-                        }
-                }
-                else {
-                        sout | "No Connections!";
-                }
-        }
 }
 
@@ -109 +40 @@
         cluster self;
         processor    * procs;
-        // io_context   * ctxs;
-        StatsPrinter * prnt;
 
 };
@@ -152 +81 @@
         }
 
-        if(options.stats) {
-                this.prnt = alloc();
-                (*this.prnt){ this.self };
-        } else {
-                this.prnt = 0p;
-        }
-
         #if !defined(__CFA_NO_STATISTICS__)
                 print_stats_at_exit( this.self, CFA_STATS_READY_Q | CFA_STATS_IO );
@@ -167 +89 @@
 
 void ^?{}( ServerCluster & this ) {
-        delete(this.prnt);
-
         for(i; options.clopts.nprocs) {
                 ^(this.procs[i]){};
@@ -268 +188 @@
                         Q * queues = 0p;
                         ServerCluster cl;
+
+                        if(options.stats) {
+                                stats_thrd = alloc();
+                                (*stats_thrd){ cl.self };
+                        } else {
+                                stats_thrd = 0p;
+                        }
 
                         init_protocol();
@@ -319 +246 @@
                                         }
                                 }
-                                cl.prnt->conns = conns;
-                                cl.prnt->conn_cnt = options.clopts.nworkers;
+
                                 sout | options.clopts.nworkers | "workers started on" | options.clopts.nprocs | "processors";
                                 sout | nl;
@@ -436 +362 @@
 
                         sout | "Stopping printer threads..." | nonl; flush( sout );
-                        StatsPrinter * p = cl.prnt;
-                        if(p) {
-                                notify_one(p->var);
-                                join(*p);
-                        }
+                        if(stats_thrd) {
+                                notify_one(stats_thrd->var);
+                        }
+                        delete(stats_thrd);
                         sout | "done";