Ignore:
Timestamp:
Jun 8, 2022, 7:24:27 PM (2 years ago)
Author:
Thierry Delisle <tdelisle@…>
Branches:
ADT, ast-experimental, master, pthread-emulation, qualifiedEnum
Children:
137974ae
Parents:
bbf61838
Message:

Removed webserver feature to have multiple clusters (it never actually worked)

File:
1 edited

Legend:

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

    rbbf61838 r8c58e73  
    163163        #endif
    164164
    165         options.clopts.instance[options.clopts.cltr_cnt] = &this.self;
    166         options.clopts.cltr_cnt++;
     165        options.clopts.instance = &this.self;
    167166}
    168167
     
    268267                        Acceptor * acceptors = 0p;
    269268                        Q * queues = 0p;
    270                         ServerCluster cl[options.clopts.nclusters];
     269                        ServerCluster cl;
    271270
    272271                        init_protocol();
     
    320319                                        }
    321320                                }
    322                                 cl[0].prnt->conns = conns;
    323                                 cl[0].prnt->conn_cnt = options.clopts.nworkers;
    324                                 sout | options.clopts.nworkers | "workers started on" | options.clopts.nprocs | "processors /" | options.clopts.nclusters | "clusters";
    325                                 for(i; options.clopts.nclusters) {
    326                                         sout | options.clopts.thrd_cnt[i] | nonl;
    327                                 }
     321                                cl.prnt->conns = conns;
     322                                cl.prnt->conn_cnt = options.clopts.nworkers;
     323                                sout | options.clopts.nworkers | "workers started on" | options.clopts.nprocs | "processors";
    328324                                sout | nl;
    329325                                {
     
    440436
    441437                        sout | "Stopping printer threads..." | nonl; flush( sout );
    442                         for(i; options.clopts.nclusters) {
    443                                 StatsPrinter * p = cl[i].prnt;
    444                                 if(p) {
    445                                         notify_one(p->var);
    446                                         join(*p);
    447                                 }
     438                        StatsPrinter * p = cl.prnt;
     439                        if(p) {
     440                                notify_one(p->var);
     441                                join(*p);
    448442                        }
    449443                        sout | "done";
Note: See TracChangeset for help on using the changeset viewer.