Ignore:
Timestamp:
Feb 19, 2021, 1:48:14 PM (9 months ago)
Author:
Thierry Delisle <tdelisle@…>
Branches:
arm-eh, jacob/cs343-translation, master, new-ast-unique-expr
Children:
d60d30e
Parents:
78da4ab
Message:

Fix httpforall after changes to I/O

File:
1 edited

Legend:

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

    r78da4ab r4f762d3  
    4747                }
    4848        #endif
     49}
     50
     51struct ServerIoContext {
     52        io_context self;
     53};
     54
     55void ?{}( ServerIoContext & this ) {
     56        /* paranoid */ assert( options.clopts.instance != 0p );
     57        (this.self){ *options.clopts.instance };
    4958}
    5059
     
    153162                }
    154163
    155                 if(options.file_cache.path && options.file_cache.fixed_fds) {
    156                         register_fixed_files(cl, fds, pipe_off);
    157                 }
     164                // if(options.file_cache.path && options.file_cache.fixed_fds) {
     165                //      register_fixed_files(cl, fds, pipe_off);
     166                // }
    158167
    159168                {
    160169                        ServerProc procs[options.clopts.nprocs];
    161                         StatsPrinter printer;
     170                        ServerIoContext ioctxs[options.clopts.nprocs];
     171                        // StatsPrinter printer;
    162172
    163173                        init_protocol();
     
    183193                                {
    184194                                        char buffer[128];
    185                                         while(int ret = cfa_read(0, buffer, 128, 0, -1`s, 0p, 0p); ret != 0) {
     195                                        while(int ret = cfa_read(0, buffer, 128, 0); ret != 0) {
    186196                                                if(ret < 0) abort( "main read error: (%d) %s\n", (int)errno, strerror(errno) );
    187197                                        }
     
    193203                                for(i; options.clopts.nworkers) {
    194204                                        workers[i].done = true;
    195                                         cancel(workers[i].cancel);
    196205                                }
    197206                                sout | "done";
Note: See TracChangeset for help on using the changeset viewer.