Changeset d9c2284 for benchmark/io/http/main.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/main.cfa (modified) (2 diffs)

benchmark/io/http/main.cfa

@@ -93 +93 @@
                 &wait_connect = &chan;
 
+                int pipe_cnt = options.clopts.nworkers * 2;
+                int pipe_off;
+                int * fds;
+                [fds, pipe_off] = filefds( pipe_cnt );
+                for(i; 0 ~ pipe_cnt ~ 2) {
+                        int ret = pipe(&fds[pipe_off + i]);
+                        if( ret < 0 ) { abort( "pipe error: (%d) %s\n", (int)errno, strerror(errno) ); }
+                }
+
                 {
                         ServerProc procs[options.clopts.nprocs];
                         {
                                 Worker workers[options.clopts.nworkers];
+                                for(i; options.clopts.nworkers) {
+                                        if( options.file_cache.fixed_fds ) {
+                                                workers[i].pipe[0] = pipe_off + (i * 2) + 0;
+                                                workers[i].pipe[1] = pipe_off + (i * 2) + 1;
+                                        }
+                                        else {
+                                                workers[i].pipe[0] = fds[pipe_off + (i * 2) + 0];
+                                                workers[i].pipe[1] = fds[pipe_off + (i * 2) + 1];
+                                        }
+                                        unpark( workers[i] __cfaabi_dbg_ctx2 );
+                                }
                                 printf("%d workers started on %d processors\n", options.clopts.nworkers, options.clopts.nprocs);
                                 {
@@ -117 +137 @@
                         printf("Workers Closed\n");
                 }
+
+                for(i; pipe_cnt) {
+                        ret = close( fds[pipe_off + i] );
+                        if(ret < 0) {
+                                abort( "close pipe error: (%d) %s\n", (int)errno, strerror(errno) );
+                        }
+                }
+                free(fds);
         }