Changeset 7f0ac12 for benchmark/io/http/protocol.cfa

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/protocol.cfa (modified) (4 diffs)

benchmark/io/http/protocol.cfa

@@ -30 +30 @@
 #define PLAINTEXT_NOCOPY
 #define LINKED_IO
+
+static inline __s32 wait_res( io_future_t & this ) {
+        wait( this );
+        if( this.result < 0 ) {{
+                errno = -this.result;
+                return -1;
+        }}
+        return this.result;
+}
 
 struct https_msg_str {
@@ -470 +479 @@
 
                         if(is_error(splice_in.res)) {
+                                if(splice_in.res.error == -EPIPE) return -ECONNRESET;
                                 mutex(serr) serr | "SPLICE IN failed with" | splice_in.res.error;
                                 close(fd);
@@ -503 +513 @@
 }
 
-[HttpCode code, bool closed, * const char file, size_t len] http_read(int fd, []char buffer, size_t len) {
+[HttpCode code, bool closed, * const char file, size_t len] http_read(volatile int & fd, []char buffer, size_t len, io_future_t * f) {
         char * it = buffer;
         size_t count = len - 1;
@@ -509 +519 @@
         READ:
         for() {
-                int ret = cfa_recv(fd, (void*)it, count, 0, CFA_IO_LAZY);
+                int ret;
+                if( f ) {
+                        ret = wait_res(*f);
+                        reset(*f);
+                        f = 0p;
+                } else {
+                        ret = cfa_recv(fd, (void*)it, count, 0, CFA_IO_LAZY);
+                }
                 // int ret = read(fd, (void*)it, count);
                 if(ret == 0 ) return [OK200, true, 0, 0];