Changeset d9c2284 for benchmark/io/http/worker.cfa

Timestamp:

Jul 20, 2020, 4:32:04 PM (3 years ago)

Author:

Thierry Delisle <tdelisle@…>

Branches:

ADT, arm-eh, enum, forall-pointer-decay, jacob/cs343-translation, master, new-ast, new-ast-unique-expr, pthread-emulation, qualifiedEnum

Children:

5751a56

Parents:

124c1b7

Message:

Started doing preliminary work to use Fixed FDs. Starting with the thread pipes.

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
@@ -27 +17 @@
 void ?{}( Worker & this ) {
         ((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) ); }
+        this.pipe[0] = -1;
+        this.pipe[1] = -1;
 }
 
 void main( Worker & this ) {
+        park( __cfaabi_dbg_ctx );
+        /* paranoid */ assert( this.pipe[0] != -1 );
+        /* paranoid */ assert( this.pipe[1] != -1 );
+
         CONNECTION:
         for() {