Changeset 2e9b59b for benchmark/io/http/protocol.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/protocol.cfa (modified) (17 diffs)

benchmark/io/http/protocol.cfa

@@ -24 +24 @@
 
 #include "options.hfa"
+#include "worker.hfa"
 
 #define PLAINTEXT_1WRITE
@@ -156 +157 @@
 
                 count -= ret;
-                offset += ret;
                 size_t in_pipe = ret;
                 SPLICE2: while(in_pipe > 0) {
@@ -249 +249 @@
 }
 
-static inline int wait_and_process(header_g & this) {
+static inline int wait_and_process(header_g & this, sendfile_stats_t & stats) {
         wait(this.f);
 
@@ -278 +278 @@
         }
 
+        stats.header++;
+
         // It must be a Short read
         this.len  -= this.f.result;
@@ -289 +291 @@
         io_future_t f;
         int fd; int pipe; size_t len; off_t off;
+        short zipf_idx;
         FSM_Result res;
 };
@@ -297 +300 @@
         this.len = len;
         this.off = 0;
+        this.zipf_idx = -1;
+        STATS: for(i; zipf_cnts) {
+                if(len <= zipf_sizes[i]) {
+                        this.zipf_idx = i;
+                        break STATS;
+                }
+        }
+        if(this.zipf_idx < 0) mutex(serr) serr | "SPLICE IN" | len | " greated than biggest zipf file";
 }
 
@@ -312 +323 @@
 }
 
-static inline int wait_and_process(splice_in_t & this) {
+static inline int wait_and_process(splice_in_t & this, sendfile_stats_t & stats ) {
         wait(this.f);
 
@@ -328 +339 @@
                         return error(this.res, -ECONNRESET);
                 }
+                mutex(serr) serr | "SPLICE IN got" | error | ", WTF!";
+                return error(this.res, -ECONNRESET);
         }
 
@@ -340 +353 @@
                 return done(this.res);
         }
+
+        stats.splcin++;
+        stats.avgrd[this.zipf_idx].calls++;
+        stats.avgrd[this.zipf_idx].bytes += this.f.result;
 
         // It must be a Short read
@@ -381 +398 @@
 }
 
-static inline void wait_and_process(splice_out_g & this) {
+static inline void wait_and_process(splice_out_g & this, sendfile_stats_t & stats ) {
         wait(this.f);
 
@@ -397 +414 @@
                         return error(this, -ECONNRESET);
                 }
+                mutex(serr) serr | "SPLICE OUT got" | error | ", WTF!";
+                return error(this, -ECONNRESET);
         }
 
@@ -411 +430 @@
 
 SHORT_WRITE:
+        stats.splcot++;
+
         // It must be a Short Write
         this.len -= this.f.result;
@@ -417 +438 @@
 }
 
-int answer_sendfile( int pipe[2], int fd, int ans_fd, size_t fsize ) {
+int answer_sendfile( int pipe[2], int fd, int ans_fd, size_t fsize, sendfile_stats_t & stats ) {
+        stats.calls++;
         #if defined(LINKED_IO)
                 char buffer[512];
@@ -426 +448 @@
 
                 RETRY_LOOP: for() {
+                        stats.tries++;
                         int have = need(header.res) + need(splice_in.res) + 1;
                         int idx = 0;
@@ -444 +467 @@
                         // we may need to kill the connection if it fails
                         // If it already completed, this is a no-op
-                        wait_and_process(splice_in);
+                        wait_and_process(splice_in, stats);
 
                         if(is_error(splice_in.res)) {
@@ -452 +475 @@
 
                         // Process the other 2
-                        wait_and_process(header);
-                        wait_and_process(splice_out);
+                        wait_and_process(header, stats);
+                        wait_and_process(splice_out, stats);
 
                         if(is_done(splice_out.res)) {
@@ -473 +496 @@
                 return len + fsize;
         #else
+                stats.tries++;
                 int ret = answer_header(fd, fsize);
                 if( ret < 0 ) { close(fd); return ret; }