Changes in / [1ed9cb63:c600df1]


Ignore:
Files:
5 edited

Legend:

Unmodified
Added
Removed

  • benchmark/io/http/http_ring.cpp

    r1ed9cb63 rc600df1  
    118118// Get a fix reply based on the return code
    119119const char * http_msgs[] = {
    120         "HTTP/1.1 200 OK\r\nServer: HttpForall\r\nContent-Type: text/plain\r\nContent-Length: 15\r\nConnection: keep-alive\r\n\r\nHello, World!\r\n",
    121         "HTTP/1.1 400 Bad Request\r\nServer: HttpForall\r\nContent-Type: text/plain\r\nContent-Length: 0 \r\n\r\n",
    122         "HTTP/1.1 404 Not Found\r\nServer: HttpForall\r\nContent-Type: text/plain\r\nContent-Length: 0 \r\n\r\n",
    123         "HTTP/1.1 405 Method Not \r\nServer: HttpForall\r\nContent-Type: text/plain\r\nContent-Length: 0 \r\n\r\n",
    124         "HTTP/1.1 408 Request Timeout\r\nServer: HttpForall\r\nContent-Type: text/plain\r\nContent-Length: 0 \r\n\r\n",
    125         "HTTP/1.1 413 Payload Too Large\r\nServer: HttpForall\r\nContent-Type: text/plain\r\nContent-Length: 0 \r\n\r\n",
    126         "HTTP/1.1 414 URI Too Long\r\nServer: HttpForall\r\nContent-Type: text/plain\r\nContent-Length: 0 \r\n\r\n",
     120        "HTTP/1.1 200 OK\r\nServer: HttoForall\r\nContent-Type: text/plain\r\nContent-Length: 15\r\nConnection: keep-alive\r\n\r\nHello, World!\r\n",
     121        "HTTP/1.1 400 Bad Request\r\nServer: HttoForall\r\nContent-Type: text/plain\r\nContent-Length: 0 \r\n\r\n",
     122        "HTTP/1.1 404 Not Found\r\nServer: HttoForall\r\nContent-Type: text/plain\r\nContent-Length: 0 \r\n\r\n",
     123        "HTTP/1.1 405 Method Not \r\nServer: HttoForall\r\nContent-Type: text/plain\r\nContent-Length: 0 \r\n\r\n",
     124        "HTTP/1.1 408 Request Timeout\r\nServer: HttoForall\r\nContent-Type: text/plain\r\nContent-Length: 0 \r\n\r\n",
     125        "HTTP/1.1 413 Payload Too Large\r\nServer: HttoForall\r\nContent-Type: text/plain\r\nContent-Length: 0 \r\n\r\n",
     126        "HTTP/1.1 414 URI Too Long\r\nServer: HttoForall\r\nContent-Type: text/plain\r\nContent-Length: 0 \r\n\r\n",
    127127};
    128128static_assert( KNOWN_CODES == (sizeof(http_msgs) / sizeof(http_msgs[0])) );

  • benchmark/io/http/options.cfa

    r1ed9cb63 rc600df1  
    5252        // bool sqkpoll = false;
    5353        // bool iokpoll = false;
    54         unsigned nentries = 0;
     54        unsigned nentries = 16;
    5555        bool isolate = false;
    5656
    … …  
    7979        parse_args( argc, argv, opt, opt_cnt, "[OPTIONS]... [PATH]\ncforall http server", left );
    8080
    81         if( nentries != 0 && !is_pow2(nentries) ) {
     81        if( !is_pow2(nentries) ) {
    8282                unsigned v = nentries;
    8383                v--;

  • benchmark/io/http/protocol.cfa

    r1ed9cb63 rc600df1  
    214214
    215215const char * original_http_msgs[] = {
    216         "HTTP/1.1 200 OK\nServer: HttpForall\nDate: %s \nContent-Type: text/plain\nContent-Length: ",
    217         "HTTP/1.1 200 OK\nServer: HttpForall\nDate: %s \nContent-Type: text/plain\nContent-Length: 15\n\nHello, World!\n\n",
    218         "HTTP/1.1 400 Bad Request\nServer: HttpForall\nDate: %s \nContent-Type: text/plain\nContent-Length: 0 \n\n",
    219         "HTTP/1.1 404 Not Found\nServer: HttpForall\nDate: %s \nContent-Type: text/plain\nContent-Length: 0 \n\n",
    220         "HTTP/1.1 405 Method Not Allowed\nServer: HttpForall\nDate: %s \nContent-Type: text/plain\nContent-Length: 0 \n\n",
    221         "HTTP/1.1 408 Request Timeout\nServer: HttpForall\nDate: %s \nContent-Type: text/plain\nContent-Length: 0 \n\n",
    222         "HTTP/1.1 413 Payload Too Large\nServer: HttpForall\nDate: %s \nContent-Type: text/plain\nContent-Length: 0 \n\n",
    223         "HTTP/1.1 414 URI Too Long\nServer: HttpForall\nDate: %s \nContent-Type: text/plain\nContent-Length: 0 \n\n",
     216        "HTTP/1.1 200 OK\nServer: HttoForall\nDate: %s \nContent-Type: text/plain\nContent-Length: ",
     217        "HTTP/1.1 200 OK\nServer: HttoForall\nDate: %s \nContent-Type: text/plain\nContent-Length: 15\n\nHello, World!\n\n",
     218        "HTTP/1.1 400 Bad Request\nServer: HttoForall\nDate: %s \nContent-Type: text/plain\nContent-Length: 0 \n\n",
     219        "HTTP/1.1 404 Not Found\nServer: HttoForall\nDate: %s \nContent-Type: text/plain\nContent-Length: 0 \n\n",
     220        "HTTP/1.1 405 Method Not Allowed\nServer: HttoForall\nDate: %s \nContent-Type: text/plain\nContent-Length: 0 \n\n",
     221        "HTTP/1.1 408 Request Timeout\nServer: HttoForall\nDate: %s \nContent-Type: text/plain\nContent-Length: 0 \n\n",
     222        "HTTP/1.1 413 Payload Too Large\nServer: HttoForall\nDate: %s \nContent-Type: text/plain\nContent-Length: 0 \n\n",
     223        "HTTP/1.1 414 URI Too Long\nServer: HttoForall\nDate: %s \nContent-Type: text/plain\nContent-Length: 0 \n\n",
    224224};
    225225
    … …  
    251251                Time now = timeHiRes();
    252252                strftime( buff, 100, "%a, %d %b %Y %H:%M:%S %Z", now );
    253                 if( options.log ) sout | "Updated date to '" | buff | "'";
     253                sout | "Updated date to '" | buff | "'";
    254254
    255255                for(i; KNOWN_CODES) {
    … …  
    264264                this.idx = (this.idx + 1) % 2;
    265265
    266                 if( options.log ) sout | "Date thread sleeping";
     266                sout | "Date thread sleeping";
    267267
    268268                sleep(1`s);

  • libcfa/src/concurrency/io.cfa

    r1ed9cb63 rc600df1  
    183183                ctx.proc->io.pending = false;
    184184
     185                ready_schedule_lock();
    185186                __cfa_io_drain( proc );
     187                ready_schedule_unlock();
    186188                // for(i; 2) {
    187189                //      unsigned idx = proc->rdq.id + i;
    … …  
    314316                ctx->proc->io.dirty   = true;
    315317                if(sq.to_submit > 30 || !lazy) {
    316                         ready_schedule_lock();
    317318                        __cfa_io_flush( ctx->proc );
    318                         ready_schedule_unlock();
    319319                }
    320320        }

  • libcfa/src/concurrency/kernel.cfa

    r1ed9cb63 rc600df1  
    196196
    197197                        if( !readyThread ) {
    198                                 ready_schedule_lock();
    199198                                __cfa_io_flush( this );
    200                                 ready_schedule_unlock();
    201 
    202199                                readyThread = __next_thread_slow( this->cltr );
    203200                        }
    … …  
    280277
    281278                        if(this->io.pending && !this->io.dirty) {
    282                                 ready_schedule_lock();
    283279                                __cfa_io_flush( this );
    284                                 ready_schedule_unlock();
    285280                        }
    286281
    … …  
    322317
    323318                                // Don't block if we are done
    324                                 if( __atomic_load_n(&this->do_terminate, __ATOMIC_SEQ_CST) ) {
    325                                         ready_schedule_unlock();
    326                                         break MAIN_LOOP;
    327                                 }
     319                                if( __atomic_load_n(&this->do_terminate, __ATOMIC_SEQ_CST) ) break MAIN_LOOP;
    328320
    329321                                __STATS( __tls_stats()->ready.sleep.halts++; )
    … …  
    947939                        /* paranoid */ verifyf( it, "Unexpected null iterator, at index %u of %u\n", i, count);
    948940                        /* paranoid */ verify( it->local_data->this_stats );
    949                         // __print_stats( it->local_data->this_stats, cltr->print_stats, "Processor", it->name, (void*)it );
    950941                        __tally_stats( cltr->stats, it->local_data->this_stats );
    951942                        it = &(*it)`next;
    … …  
    957948                // this doesn't solve all problems but does solve many
    958949                // so it's probably good enough
    959                 disable_interrupts();
    960950                uint_fast32_t last_size = ready_mutate_lock();
    961951
    … …  
    965955                // Unlock the RWlock
    966956                ready_mutate_unlock( last_size );
    967                 enable_interrupts();
    968957        }
    969958
Note: See TracChangeset for help on using the changeset viewer.