Changes in benchmark/io/http/worker.cfa [3e417bf:857a1c6]

File:

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

benchmark/io/http/worker.cfa

@@ -18 +18 @@
 void ?{}( Worker & this ) {
         size_t cli = rand() % options.clopts.cltr_cnt;
-        ((thread&)this){ "Server Worker Thread", *options.clopts.instance[cli], 64000 };
+        ((thread&)this){ "Server Worker Thread", *options.clopts.instance[cli], 512000 };
         options.clopts.thrd_cnt[cli]++;
         this.pipe[0] = -1;
@@ -122 +122 @@
                         }
 
+                        // Send the header
+                        int ret = answer_header(fd, count);
+                        if( ret == -ECONNRESET ) break REQUEST;
+
                         // Send the desired file
-                        int ret = answer_sendfile( this.pipe, fd, ans_fd, count);
+                        ret = sendfile( this.pipe, fd, ans_fd, count);
                         if( ret == -ECONNRESET ) break REQUEST;
 
@@ -130 +134 @@
 
                 if( options.log ) sout | "=== Connection closed ===";
+                close(fd);
                 continue CONNECTION;
         }