Changeset 7f0ac12 for benchmark/io/http/worker.hfa

Timestamp:

Jun 8, 2022, 7:07:51 PM (2 years ago)

Author:

Thierry Delisle <tdelisle@…>

Branches:

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

Children:

bbf61838

Parents:

6e2b04e

Message:

First draft at acceptor thread webserver

File:

• benchmark/io/http/worker.hfa (modified) (3 diffs)

benchmark/io/http/worker.hfa

@@ -1 +1 @@
 #pragma once
 
+#include <iofwd.hfa>
+#include <queueLockFree.hfa>
 #include <thread.hfa>
 
@@ -26 +28 @@
 };
 
-thread Worker {
+void ?{}( sendfile_stats_t & this );
+
+struct connection {
         int pipe[2];
+        struct {
+                sendfile_stats_t sendfile;
+        } stats;
+};
+
+static inline void ?{}( connection & this ) {
+        this.pipe[0] = -1;
+        this.pipe[1] = -1;
+}
+
+thread AcceptWorker {
+        connection conn;
         int sockfd;
         struct sockaddr * addr;
@@ -33 +49 @@
         int flags;
         volatile bool done;
+};
+void ?{}( AcceptWorker & this);
+void main( AcceptWorker & );
+
+
+struct PendingRead {
+        PendingRead * volatile next;
+        io_future_t f;
         struct {
-                sendfile_stats_t sendfile;
-        } stats;
+                void * buf;
+                size_t len;
+        } in;
+        struct {
+                volatile int fd;
+        } out;
 };
-void ?{}( Worker & this);
-void main( Worker & );
+
+static inline PendingRead * volatile & ?`next ( PendingRead * node ) {
+        return node->next;
+}
+
+thread ChannelWorker {
+        connection conn;
+        volatile bool done;
+        mpsc_queue(PendingRead) * queue;
+};
+void ?{}( ChannelWorker & );
+void main( ChannelWorker & );
+
+thread Acceptor {
+        mpsc_queue(PendingRead) * queue;
+        int sockfd;
+        struct sockaddr * addr;
+        socklen_t * addrlen;
+        int flags;
+        volatile bool done;
+};
+void ?{}( Acceptor & );
+void main( Acceptor & );