Changes in / [bbfe226:a488783]


Ignore:
Location:
libcfa/src/concurrency
Files:
4 edited

Legend:

Unmodified
Added
Removed

  • libcfa/src/concurrency/io.cfa

    rbbfe226 ra488783  
    306306                ctx->proc->io.pending = true;
    307307                ctx->proc->io.dirty   = true;
    308                 if(sq.to_submit > 30) {
    309                         __tls_stats()->io.flush.full++;
    310                         __cfa_io_flush( ctx->proc, 0 );
    311                 }
    312                 if(!lazy) {
    313                         __tls_stats()->io.flush.eager++;
     308                if(sq.to_submit > 30 || !lazy) {
    314309                        __cfa_io_flush( ctx->proc, 0 );
    315310                }

  • libcfa/src/concurrency/kernel.cfa

    rbbfe226 ra488783  
    196196
    197197                        if( !readyThread ) {
    198                                 __tls_stats()->io.flush.idle++;
    199198                                __cfa_io_flush( this, 0 );
    200199
    … …  
    245244
    246245                        if(this->io.pending && !this->io.dirty) {
    247                                 __tls_stats()->io.flush.dirty++;
    248246                                __cfa_io_flush( this, 0 );
    249247                        }

  • libcfa/src/concurrency/stats.cfa

    rbbfe226 ra488783  
    4545                        stats->io.submit.slow       = 0;
    4646                        stats->io.flush.external    = 0;
    47                         stats->io.flush.dirty       = 0;
    48                         stats->io.flush.full        = 0;
    49                         stats->io.flush.idle        = 0;
    50                         stats->io.flush.eager       = 0;
    5147                        stats->io.calls.flush       = 0;
    5248                        stats->io.calls.submitted   = 0;
    … …  
    111107                        tally_one( &cltr->io.submit.slow      , &proc->io.submit.slow       );
    112108                        tally_one( &cltr->io.flush.external   , &proc->io.flush.external    );
    113                         tally_one( &cltr->io.flush.dirty      , &proc->io.flush.dirty       );
    114                         tally_one( &cltr->io.flush.full       , &proc->io.flush.full        );
    115                         tally_one( &cltr->io.flush.idle       , &proc->io.flush.idle        );
    116                         tally_one( &cltr->io.flush.eager      , &proc->io.flush.eager       );
    117109                        tally_one( &cltr->io.calls.flush      , &proc->io.calls.flush       );
    118110                        tally_one( &cltr->io.calls.submitted  , &proc->io.calls.submitted   );
    … …  
    192184                                if(io.alloc.fail || io.alloc.revoke || io.alloc.block)
    193185                                        sstr | "-     failures      : " | eng3(io.alloc.fail) | "oom, " | eng3(io.alloc.revoke) | "rvk, " | eng3(io.alloc.block) | "blk";
    194                                 // if(io.flush.external)
    195                                 //      sstr | "- flush external    : " | eng3(io.flush.external);
     186                                if(io.flush.external)
     187                                        sstr | "- flush external    : " | eng3(io.flush.external);
    196188
    197189                                double avgsubs = ((double)io.calls.submitted) / io.calls.flush;
    198190                                double avgcomp = ((double)io.calls.completed) / io.calls.drain;
    199191                                sstr | "- syscll : "
    200                                      |   " sub " | eng3(io.calls.submitted) | "/" | eng3(io.calls.flush) | "(" | ws(3, 3, avgsubs) | "/flush)"
    201                                      | " - cmp " | eng3(io.calls.completed) | "/" | eng3(io.calls.drain) | "(" | ws(3, 3, avgcomp) | "/drain)"
     192                                     |   " sub " | eng3(io.calls.flush) | "/" | eng3(io.calls.submitted) | "(" | ws(3, 3, avgsubs) | "/flush)"
     193                                     | " - cmp " | eng3(io.calls.drain) | "/" | eng3(io.calls.completed) | "(" | ws(3, 3, avgcomp) | "/drain)"
    202194                                     | " - " | eng3(io.calls.errors.busy) | " EBUSY";
    203                                 sstr | " - sub: " | eng3(io.flush.full) | "full, " | eng3(io.flush.dirty) | "drty, " | eng3(io.flush.idle) | "idle, " | eng3(io.flush.eager) | "eagr, " | eng3(io.flush.external) | "ext";
    204195                                sstr | "- ops blk: "
    205196                                     |   " sk rd: " | eng3(io.ops.sockread)  | "epll: " | eng3(io.ops.epllread)

  • libcfa/src/concurrency/stats.hfa

    rbbfe226 ra488783  
    9191                        struct {
    9292                                volatile uint64_t external;
    93                                 volatile uint64_t dirty;
    94                                 volatile uint64_t full;
    95                                 volatile uint64_t idle;
    96                                 volatile uint64_t eager;
    9793                        } flush;
    9894                        struct {
Note: See TracChangeset for help on using the changeset viewer.