Changeset c25338d

Timestamp:

Jun 10, 2022, 4:12:40 PM (23 months ago)

Author:

Thierry Delisle <tdelisle@…>

Branches:

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

Children:

bf7c7ea

Parents:

10ba012

Message:

Added accept 10 method (it doesn't really work).

File:

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

benchmark/io/http/worker.cfa

@@ -187 +187 @@
 }
 
+#define ACCEPT_SPIN
+
 void main( Acceptor & this ) {
         park();
         unsigned long long last = rdtscl();
+
+#if defined(ACCEPT_SPIN)
         if( options.log ) sout | "=== Accepting connection ===";
         for() {
@@ -236 +240 @@
                 if( options.log ) sout | "=== Accepting connection ===";
         }
-}
+
+#elif define(ACCEPT_MANY)
+        const int nacc = 10;
+        io_future_t results[nacc];
+
+        for(i; nacc) {
+                io_future_t & res = results[i];
+                reset(res);
+                /* paranoid */ assert(!available(res));
+                if( options.log ) mutex(sout) sout | "=== Re-arming accept no" | i | " ===";
+                async_accept4(res, this.sockfd, this.[addr, addrlen, flags], CFA_IO_LAZY);
+        }
+
+        for() {
+                if (stats_thrd) {
+                        unsigned long long next = rdtscl();
+                        if(next > (last + 500000000)) {
+                                if(try_lock(stats_thrd->stats.lock __cfaabi_dbg_ctx2)) {
+                                        push(this.stats, stats_thrd->stats.accpt);
+                                        unlock(stats_thrd->stats.lock);
+                                        last = next;
+                                }
+                        }
+                }
+
+                for(i; nacc) {
+                        io_future_t & res = results[i];
+                        if(available(res)) {
+                                if( options.log ) mutex(sout) sout | "=== Accept no " | i | "completed with result" | res.result | "===";
+                                int fd = get_res(res);
+                                reset(res);
+                                this.stats.accepts++;
+                                if(fd < 0) {
+                                        if( errno == ECONNABORTED ) continue;
+                                        if( this.done && (errno == EINVAL || errno == EBADF) ) continue;
+                                        abort( "accept error: (%d) %s\n", (int)errno, strerror(errno) );
+                                }
+                                push_connection( this, fd );
+
+                                /* paranoid */ assert(!available(res));
+                                if( options.log ) mutex(sout) sout | "=== Re-arming accept no" | i | " ===";
+                                async_accept4(res, this.sockfd, this.[addr, addrlen, flags], CFA_IO_LAZY);
+                        }
+                }
+                if(this.done) return;
+
+                if( options.log ) mutex(sout) sout | "=== Waiting for any accept ===";
+                this.stats.eagains++;
+                wait_any(results, nacc);
+
+                if( options.log ) mutex(sout) {
+                        sout | "=== Acceptor wake-up ===";
+                        for(i; nacc) {
+                                io_future_t & res = results[i];
+                                sout | i | "available:" | available(res);
+                        }
+                }
+
+        }
+
+        for(i; nacc) {
+                wait(results[i]);
+        }
+#else
+#error no accept algorithm specified
+#endif
+}