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

File:

• benchmark/io/http/worker.cfa (modified) (2 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
@@ -17 +27 @@
 void ?{}( Worker & this ) {
         ((thread&)this){ "Server Worker Thread", *options.clopts.instance };
-        this.pipe[0] = -1;
-        this.pipe[1] = -1;
+        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() {