Ignore:
Timestamp:
Aug 28, 2020, 2:17:36 PM (16 months ago)
Author:
Thierry Delisle <tdelisle@…>
Branches:
arm-eh, jacob/cs343-translation, master, new-ast-unique-expr
Children:
56c44dc
Parents:
d11d6eb
Message:

Every worker now does it's own accept.

File:
1 edited

Legend:

Unmodified
Added
Removed
  • benchmark/io/http/main.cfa

    rd11d6eb r8e3034d  
    126126                                                workers[i].pipe[0] = fds[pipe_off + (i * 2) + 0];
    127127                                                workers[i].pipe[1] = fds[pipe_off + (i * 2) + 1];
     128                                                workers[i].sockfd  = server_fd;
     129                                                workers[i].addr    = (struct sockaddr *)&address;
     130                                                workers[i].addrlen = (socklen_t*)&addrlen;
     131                                                workers[i].flags   = 0;
    128132                                        }
    129133                                        unpark( workers[i] __cfaabi_dbg_ctx2 );
     
    131135                                printf("%d workers started on %d processors\n", options.clopts.nworkers, options.clopts.nprocs);
    132136                                {
    133                                         Acceptor acceptor = { server_fd, (struct sockaddr *)&address, (socklen_t*)&addrlen, 0 };
    134 
    135137                                        char buffer[128];
    136138                                        while(!feof(stdin)) {
     
    139141
    140142                                        printf("Shutting Down\n");
    141                                 }
    142                                 printf("Acceptor Closed\n");
    143 
    144                                 // Clean-up the workers
    145                                 for(options.clopts.nworkers) {
    146                                         put( wait_connect, -1 );
    147143                                }
    148144                        }
Note: See TracChangeset for help on using the changeset viewer.