Changeset 8e3034d for benchmark/io/http/main.cfa

Timestamp:

Aug 28, 2020, 2:17:36 PM (2 years ago)

Author:

Thierry Delisle <tdelisle@…>

Branches:

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

Children:

56c44dc

Parents:

d11d6eb

Message:

Every worker now does it's own accept.

File:

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

benchmark/io/http/main.cfa

@@ -126 +126 @@
                                                 workers[i].pipe[0] = fds[pipe_off + (i * 2) + 0];
                                                 workers[i].pipe[1] = fds[pipe_off + (i * 2) + 1];
+                                                workers[i].sockfd  = server_fd;
+                                                workers[i].addr    = (struct sockaddr *)&address;
+                                                workers[i].addrlen = (socklen_t*)&addrlen;
+                                                workers[i].flags   = 0;
                                         }
                                         unpark( workers[i] __cfaabi_dbg_ctx2 );
@@ -131 +135 @@
                                 printf("%d workers started on %d processors\n", options.clopts.nworkers, options.clopts.nprocs);
                                 {
-                                        Acceptor acceptor = { server_fd, (struct sockaddr *)&address, (socklen_t*)&addrlen, 0 };
-
                                         char buffer[128];
                                         while(!feof(stdin)) {
@@ -139 +141 @@
 
                                         printf("Shutting Down\n");
-                                }
-                                printf("Acceptor Closed\n");
-
-                                // Clean-up the workers
-                                for(options.clopts.nworkers) {
-                                        put( wait_connect, -1 );
                                 }
                         }