Ignore:
Timestamp:
Aug 28, 2020, 1:26:28 PM (4 years ago)
Author:
Thierry Delisle <tdelisle@…>
Branches:
ADT, arm-eh, ast-experimental, enum, forall-pointer-decay, jacob/cs343-translation, master, new-ast-unique-expr, pthread-emulation, qualifiedEnum
Children:
8e3034d
Parents:
8e2cb4a
Message:

Fixed some compilation errors.
Fixed file descriptor support in progress.

File:
1 edited

Legend:

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

    r8e2cb4a rd11d6eb  
    1212#include <kernel.hfa>
    1313#include <stats.hfa>
     14#include <time.hfa>
    1415#include <thread.hfa>
    1516
     
    1819#include "options.hfa"
    1920#include "worker.hfa"
     21
     22extern void register_fixed_files( cluster &, int *, unsigned count );
     23
     24Duration default_preemption() {
     25        return 0;
     26}
    2027
    2128//=============================================================================================
     
    8491        // Run Server Cluster
    8592        {
    86                 cluster cl = { "Server Cluster", options.clopts.flags };
     93                cluster cl = { "Server Cluster", options.clopts.params };
    8794                #if !defined(__CFA_NO_STATISTICS__)
    8895                        print_stats_at_exit( cl, CFA_STATS_READY_Q | CFA_STATS_IO );
     
    102109                }
    103110
     111                if(options.file_cache.fixed_fds) {
     112                        register_fixed_files(cl, fds, pipe_off);
     113                }
     114
    104115                {
    105116                        ServerProc procs[options.clopts.nprocs];
     
    107118                                Worker workers[options.clopts.nworkers];
    108119                                for(i; options.clopts.nworkers) {
    109                                         if( options.file_cache.fixed_fds ) {
    110                                                 workers[i].pipe[0] = pipe_off + (i * 2) + 0;
    111                                                 workers[i].pipe[1] = pipe_off + (i * 2) + 1;
    112                                         }
    113                                         else {
     120                                        // if( options.file_cache.fixed_fds ) {
     121                                        //      workers[i].pipe[0] = pipe_off + (i * 2) + 0;
     122                                        //      workers[i].pipe[1] = pipe_off + (i * 2) + 1;
     123                                        // }
     124                                        // else
     125                                        {
    114126                                                workers[i].pipe[0] = fds[pipe_off + (i * 2) + 0];
    115127                                                workers[i].pipe[1] = fds[pipe_off + (i * 2) + 1];
Note: See TracChangeset for help on using the changeset viewer.