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

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.the_cluster };
+        ((thread&)this){ "Server Worker Thread", *options.clopts.instance };
         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:
-        while( int fd = take(wait_connect); fd >= 0) {
-            printf("New connection, waiting for requests\n");
+        for() {
+                int fd = take(wait_connect);
+                if (fd < 0) break;
+
+                printf("New connection %d, waiting for requests\n", fd);
                 REQUEST:
                 for() {
@@ -43 +46 @@
 
                         // Read the http request
-                        size_t len = 1024;
+                        size_t len = options.socket.buflen;
                         char buffer[len];
                         printf("Reading request\n");
@@ -56 +59 @@
                         // If this wasn't a request retrun 400
                         if( code != OK200 ) {
-                                printf("Invalid Request\n");
+                                printf("Invalid Request : %d\n", code_val(code));
                                 answer_error(fd, code);
                                 continue REQUEST;
                         }
 
-                        printf("Request for file %.*s\n", name_size, file);
+                        printf("Request for file %.*s\n", (int)name_size, file);
 
                         // Get the fd from the file cache
@@ -90 +93 @@
 //=============================================================================================
 void ?{}( Acceptor & this, int sockfd, struct sockaddr * addr, socklen_t * addrlen, int flags ) {
-        ((thread&)this){ "Acceptor Thread", *options.the_cluster };
+        ((thread&)this){ "Acceptor Thread", *options.clopts.instance };
         this.sockfd  = sockfd;
         this.addr    = addr;
@@ -105 +108 @@
                 }
 
-            printf("New connection accepted\n");
+                printf("New connection accepted\n");
                 put( wait_connect, ret );
-      }
+        }
 }