Changes in benchmark/io/http/worker.cfa [d9c2284:c82af9f]

File:

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

benchmark/io/http/worker.cfa

@@ -12 +12 @@
 #include "filecache.hfa"
 
+extern "C" {
+// extern ssize_t sendfile(int out_fd, int in_fd, off_t *offset, size_t count);
+extern ssize_t splice(int fd_in, loff_t *off_in, int fd_out, loff_t *off_out, size_t len, unsigned int flags);
+}
+
+ssize_t sendfile(int out_fd, int in_fd, off_t *offset, size_t count) {
+        return splice(in_fd, offset, out_fd, 0p, count, 0);
+}
+
+
 //=============================================================================================
 // Worker Thread
 //=============================================================================================
 void ?{}( Worker & this ) {
-        ((thread&)this){ "Server Worker Thread", *options.clopts.instance };
-        this.pipe[0] = -1;
-        this.pipe[1] = -1;
+        ((thread&)this){ "Server Worker Thread", *options.the_cluster };
+        int ret = pipe(this.pipe);
+        if( ret < 0 ) { abort( "pipe error: (%d) %s\n", (int)errno, strerror(errno) ); }
 }
 
 void main( Worker & this ) {
-        park( __cfaabi_dbg_ctx );
-        /* paranoid */ assert( this.pipe[0] != -1 );
-        /* paranoid */ assert( this.pipe[1] != -1 );
-
         CONNECTION:
-        for() {
-                int fd = take(wait_connect);
-                if (fd < 0) break;
-
-                printf("New connection %d, waiting for requests\n", fd);
+        while( int fd = take(wait_connect); fd >= 0) {
+            printf("New connection, waiting for requests\n");
                 REQUEST:
                 for() {
@@ -40 +43 @@
 
                         // Read the http request
-                        size_t len = options.socket.buflen;
+                        size_t len = 1024;
                         char buffer[len];
                         printf("Reading request\n");
@@ -53 +56 @@
                         // If this wasn't a request retrun 400
                         if( code != OK200 ) {
-                                printf("Invalid Request : %d\n", code_val(code));
+                                printf("Invalid Request\n");
                                 answer_error(fd, code);
                                 continue REQUEST;
                         }
 
-                        printf("Request for file %.*s\n", (int)name_size, file);
+                        printf("Request for file %.*s\n", name_size, file);
 
                         // Get the fd from the file cache
@@ -87 +90 @@
 //=============================================================================================
 void ?{}( Acceptor & this, int sockfd, struct sockaddr * addr, socklen_t * addrlen, int flags ) {
-        ((thread&)this){ "Acceptor Thread", *options.clopts.instance };
+        ((thread&)this){ "Acceptor Thread", *options.the_cluster };
         this.sockfd  = sockfd;
         this.addr    = addr;
@@ -102 +105 @@
                 }
 
-                printf("New connection accepted\n");
+            printf("New connection accepted\n");
                 put( wait_connect, ret );
-        }
+      }
 }