Changeset 2e9b59b for benchmark/io/http/main.cfa

Timestamp:

Apr 19, 2022, 3:00:04 PM (3 years ago)

Author:

m3zulfiq <m3zulfiq@…>

Branches:

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

Children:

5b84a321

Parents:

ba897d21 (diff), bb7c77d (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:

added benchmark and evaluations chapter to thesis

File:

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

benchmark/io/http/main.cfa

@@ -33 +33 @@
 //============================================================================================='
 
-thread StatsPrinter {};
+thread StatsPrinter {
+        Worker * workers;
+        int worker_cnt;
+};
 
 void ?{}( StatsPrinter & this, cluster & cl ) {
         ((thread&)this){ "Stats Printer Thread", cl };
+        this.worker_cnt = 0;
 }
 
 void ^?{}( StatsPrinter & mutex this ) {}
+
+#define eng3(X) (ws(3, 3, unit(eng( X ))))
 
 void main(StatsPrinter & this) {
@@ -51 +57 @@
 
                 print_stats_now( *active_cluster(), CFA_STATS_READY_Q | CFA_STATS_IO );
+                if(this.worker_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.worker_cnt) {
+                                tries += this.workers[i].stats.sendfile.tries;
+                                calls += this.workers[i].stats.sendfile.calls;
+                                header += this.workers[i].stats.sendfile.header;
+                                splcin += this.workers[i].stats.sendfile.splcin;
+                                splcot += this.workers[i].stats.sendfile.splcot;
+                                for(j; zipf_cnts) {
+                                        avgrd[j].calls += this.workers[i].stats.sendfile.avgrd[j].calls;
+                                        avgrd[j].bytes += this.workers[i].stats.sendfile.avgrd[j].bytes;
+                                }
+                        }
+
+                        double ratio = ((double)tries) / calls;
+
+                        sout | "----- Worker 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 Workers!";
+                }
         }
 }
@@ -218 +262 @@
                         {
                                 Worker * workers = anew(options.clopts.nworkers);
+                                cl[0].prnt->workers = workers;
+                                cl[0].prnt->worker_cnt = options.clopts.nworkers;
                                 for(i; options.clopts.nworkers) {
                                         // if( options.file_cache.fixed_fds ) {
@@ -311 +357 @@
         }
 }
+
+const size_t zipf_sizes[] = { 102, 204, 307, 409, 512, 614, 716, 819, 921, 1024, 2048, 3072, 4096, 5120, 6144, 7168, 8192, 9216, 10240, 20480, 30720, 40960, 51200, 61440, 71680, 81920, 92160, 102400, 204800, 307200, 409600, 512000, 614400, 716800, 819200, 921600 };
+static_assert(zipf_cnts == sizeof(zipf_sizes) / sizeof(zipf_sizes[0]));