Changeset 3f95dab for benchmark/io/http/worker.cfa

Timestamp:

Jul 28, 2022, 12:04:19 PM (22 months ago)

Author:

Thierry Delisle <tdelisle@…>

Branches:

ADT, ast-experimental, master, pthread-emulation

Children:

c4c8571

Parents:

7ce8873

Message:

Committing hopefully last version of the webserver

File:

• benchmark/io/http/worker.cfa (modified) (13 diffs)

benchmark/io/http/worker.cfa

@@ -13 +13 @@
 #include "protocol.hfa"
 #include "filecache.hfa"
+
+static const unsigned long long period = 50_000_000;
 
 //=============================================================================================
@@ -95 +97 @@
                 // Send the desired file
                 int ret = answer_sendfile( this.pipe, fd, ans_fd, count, this.stats.sendfile );
-                if( ret == -ECONNRESET ) break REQUEST;
+                if(ret < 0) {
+                        if( ret == -ECONNABORTED ) break REQUEST;
+                        if( ret == -ECONNRESET ) break REQUEST;
+                        if( ret == -EPIPE ) break REQUEST;
+                        abort( "sendfile error: %d (%d) %s\n", ret, (int)errno, strerror(errno) );
+                }
 
                 if( options.log ) mutex(sout) sout | "=== Answer sent ===";
@@ -102 +109 @@
         if (stats_thrd) {
                 unsigned long long next = rdtscl();
-                if(next > (last + 500000000)) {
+                if(next > (last + period)) {
                         if(try_lock(stats_thrd->stats.lock __cfaabi_dbg_ctx2)) {
                                 push(this.stats.sendfile, stats_thrd->stats.send);
@@ -141 +148 @@
                 char buffer[len];
                 handle_connection( this.conn, fd, buffer, len, 0p, last );
+                this.conn.stats.sendfile.maxfd = max(this.conn.stats.sendfile.maxfd, fd);
+                this.conn.stats.sendfile.close++;
 
                 if( options.log ) mutex(sout) sout | "=== Connection closed ===";
@@ -162 +171 @@
         /* paranoid */ assert( this.conn.pipe[0] != -1 );
         /* paranoid */ assert( this.conn.pipe[1] != -1 );
+        this.conn.stats.sendfile.maxfd = max(this.conn.pipe[0], this.conn.pipe[1]);
         for() {
                 size_t len = options.socket.buflen;
@@ -173 +183 @@
                 if( options.log ) mutex(sout) sout | "=== Waiting new connection ===";
                 handle_connection( this.conn, p.out.fd, buffer, len, &p.f, last );
+                if(this.done) break;
+                this.conn.stats.sendfile.maxfd = max(this.conn.stats.sendfile.maxfd, p.out.fd);
+                this.conn.stats.sendfile.close++;
 
                 if( options.log ) mutex(sout) sout | "=== Connection closed ===";
-                if(this.done) break;
-        }
+        }
+
+        lock(stats_thrd->stats.lock __cfaabi_dbg_ctx2);
+        push(this.conn.stats.sendfile, stats_thrd->stats.send);
+        unlock(stats_thrd->stats.lock);
 }
 
@@ -198 +214 @@
 
 static inline void push_connection( Acceptor & this, int fd ) {
+        this.stats.accepts++;
         PendingRead * p = 0p;
         for() {
@@ -212 +229 @@
 
 // #define ACCEPT_SPIN
-#define ACCEPT_MANY
+#define ACCEPT_ONE
+// #define ACCEPT_MANY
 
 void main( Acceptor & this ) {
@@ -232 +250 @@
                         abort( "accept error: (%d) %s\n", (int)errno, strerror(errno) );
                 }
-                this.stats.accepts++;
 
                 if(this.done) return;
@@ -242 +259 @@
                 if (stats_thrd) {
                         unsigned long long next = rdtscl();
-                        if(next > (last + 500000000)) {
+                        if(next > (last + period)) {
+                                if(try_lock(stats_thrd->stats.lock)) {
+                                        push(this.stats, stats_thrd->stats.accpt);
+                                        unlock(stats_thrd->stats.lock);
+                                        last = next;
+                                }
+                        }
+                }
+
+                if( options.log ) sout | "=== Accepting connection ===";
+        }
+
+#elif defined(ACCEPT_ONE)
+        if( options.log ) sout | "=== Accepting connection ===";
+        for() {
+                int fd = cfa_accept4(this.sockfd, this.[addr, addrlen, flags], 0);
+                if(fd < 0) {
+                        if( errno == ECONNABORTED ) break;
+                        if( this.done && (errno == EINVAL || errno == EBADF) ) break;
+                        abort( "accept error: (%d) %s\n", (int)errno, strerror(errno) );
+                }
+
+                if(this.done) return;
+
+                if( options.log ) sout | "=== New connection" | fd | "" | ", waiting for requests ===";
+
+                if(fd) push_connection(this, fd);
+
+                if (stats_thrd) {
+                        unsigned long long next = rdtscl();
+                        if(next > (last + period)) {
                                 if(try_lock(stats_thrd->stats.lock)) {
                                         push(this.stats, stats_thrd->stats.accpt);
@@ -269 +316 @@
                 if (stats_thrd) {
                         unsigned long long next = rdtscl();
-                        if(next > (last + 500000000)) {
+                        if(next > (last + period)) {
                                 if(try_lock(stats_thrd->stats.lock __cfaabi_dbg_ctx2)) {
                                         push(this.stats, stats_thrd->stats.accpt);
@@ -284 +331 @@
                                 int fd = get_res(res);
                                 reset(res);
-                                this.stats.accepts++;
                                 if(fd < 0) {
                                         if( errno == ECONNABORTED ) continue;
@@ -319 +365 @@
 #error no accept algorithm specified
 #endif
-}
+        lock(stats_thrd->stats.lock);
+        push(this.stats, stats_thrd->stats.accpt);
+        unlock(stats_thrd->stats.lock);
+}