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

File:

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

benchmark/io/http/worker.cfa

@@ -26 +26 @@
 //=============================================================================================
 void ?{}( Worker & this ) {
-        ((thread&)this){ "Server Worker Thread", *options.clopts.instance };
+        ((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) ); }
@@ -33 +33 @@
 void main( Worker & this ) {
         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() {
@@ -46 +43 @@
 
                         // Read the http request
-                        size_t len = options.socket.buflen;
+                        size_t len = 1024;
                         char buffer[len];
                         printf("Reading request\n");
@@ -59 +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
@@ -93 +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;
@@ -108 +105 @@
                 }
 
-                printf("New connection accepted\n");
+            printf("New connection accepted\n");
                 put( wait_connect, ret );
-        }
+      }
 }