| [8834751] | 1 | #include <stdint.h> | 
|---|
|  | 2 | #include <stdlib.hfa> | 
|---|
|  | 3 |  | 
|---|
|  | 4 | #include <unistd.h>                                                             // STDERR_FILENO | 
|---|
| [7812a7b5] | 5 | #include <inttypes.h> | 
|---|
| [8834751] | 6 | #include "bits/debug.hfa" | 
|---|
| [73f4d08] | 7 | #include "bits/locks.hfa" | 
|---|
| [8834751] | 8 | #include "stats.hfa" | 
|---|
| [986cb99] | 9 | #include "strstream.hfa" | 
|---|
| [8834751] | 10 |  | 
|---|
|  | 11 | #if !defined(__CFA_NO_STATISTICS__) | 
|---|
|  | 12 | void __init_stats( struct __stats_t * stats ) { | 
|---|
| [d2fadeb] | 13 | stats->ready.push.local.attempt = 0; | 
|---|
|  | 14 | stats->ready.push.local.success = 0; | 
|---|
|  | 15 | stats->ready.push.share.attempt = 0; | 
|---|
|  | 16 | stats->ready.push.share.success = 0; | 
|---|
|  | 17 | stats->ready.push.extrn.attempt = 0; | 
|---|
|  | 18 | stats->ready.push.extrn.success = 0; | 
|---|
|  | 19 | stats->ready.pop.local .attempt = 0; | 
|---|
|  | 20 | stats->ready.pop.local .success = 0; | 
|---|
|  | 21 | stats->ready.pop.help  .attempt = 0; | 
|---|
|  | 22 | stats->ready.pop.help  .success = 0; | 
|---|
|  | 23 | stats->ready.pop.steal .attempt = 0; | 
|---|
|  | 24 | stats->ready.pop.steal .success = 0; | 
|---|
|  | 25 | stats->ready.pop.search.attempt = 0; | 
|---|
|  | 26 | stats->ready.pop.search.success = 0; | 
|---|
| [29cb302] | 27 | stats->ready.threads.migration = 0; | 
|---|
| [3bd4293] | 28 | stats->ready.threads.extunpark = 0; | 
|---|
| [ec43cf9] | 29 | stats->ready.threads.threads   = 0; | 
|---|
| [78ea291] | 30 | stats->ready.threads.cthreads  = 0; | 
|---|
| [941e14a] | 31 | stats->ready.threads.preempt.yield  = 0; | 
|---|
|  | 32 | stats->ready.threads.preempt.rllfwd = 0; | 
|---|
| [68f36f4] | 33 | stats->ready.sleep.halts   = 0; | 
|---|
|  | 34 | stats->ready.sleep.cancels = 0; | 
|---|
| [7cf3b1d] | 35 | stats->ready.sleep.early   = 0; | 
|---|
| [68f36f4] | 36 | stats->ready.sleep.wakes   = 0; | 
|---|
| [7cf3b1d] | 37 | stats->ready.sleep.seen    = 0; | 
|---|
| [68f36f4] | 38 | stats->ready.sleep.exits   = 0; | 
|---|
| [8834751] | 39 |  | 
|---|
| [5751a56] | 40 | #if defined(CFA_HAVE_LINUX_IO_URING_H) | 
|---|
| [d60d30e] | 41 | stats->io.alloc.fast        = 0; | 
|---|
|  | 42 | stats->io.alloc.slow        = 0; | 
|---|
|  | 43 | stats->io.alloc.fail        = 0; | 
|---|
|  | 44 | stats->io.alloc.revoke      = 0; | 
|---|
|  | 45 | stats->io.alloc.block       = 0; | 
|---|
|  | 46 | stats->io.submit.fast       = 0; | 
|---|
|  | 47 | stats->io.submit.slow       = 0; | 
|---|
| [7ce8873] | 48 | stats->io.submit.eagr       = 0; | 
|---|
|  | 49 | stats->io.submit.nblk       = 0; | 
|---|
| [74227c6] | 50 | stats->io.submit.extr       = 0; | 
|---|
| [d60d30e] | 51 | stats->io.flush.external    = 0; | 
|---|
| [74227c6] | 52 | stats->io.flush.signal      = 0; | 
|---|
| [70b4aeb9] | 53 | stats->io.flush.dirty       = 0; | 
|---|
|  | 54 | stats->io.flush.full        = 0; | 
|---|
|  | 55 | stats->io.flush.idle        = 0; | 
|---|
|  | 56 | stats->io.flush.eager       = 0; | 
|---|
| [dddb3dd0] | 57 | stats->io.calls.flush       = 0; | 
|---|
| [d60d30e] | 58 | stats->io.calls.submitted   = 0; | 
|---|
| [dddb3dd0] | 59 | stats->io.calls.drain       = 0; | 
|---|
| [d60d30e] | 60 | stats->io.calls.completed   = 0; | 
|---|
| [54c1196] | 61 | stats->io.calls.locked      = 0; | 
|---|
|  | 62 | stats->io.calls.helped      = 0; | 
|---|
| [d60d30e] | 63 | stats->io.calls.errors.busy = 0; | 
|---|
| [db614d0] | 64 | stats->io.ops.sockread      = 0; | 
|---|
|  | 65 | stats->io.ops.epllread      = 0; | 
|---|
|  | 66 | stats->io.ops.sockwrite     = 0; | 
|---|
|  | 67 | stats->io.ops.epllwrite     = 0; | 
|---|
| [8834751] | 68 | #endif | 
|---|
| [73f4d08] | 69 |  | 
|---|
|  | 70 | #if defined(CFA_STATS_ARRAY) | 
|---|
|  | 71 | stats->array.values = alloc(CFA_STATS_ARRAY); | 
|---|
|  | 72 | stats->array.cnt = 0; | 
|---|
|  | 73 | #endif | 
|---|
| [8834751] | 74 | } | 
|---|
|  | 75 |  | 
|---|
| [45b9b21] | 76 | static inline void tally_one( volatile uint64_t * agg, volatile uint64_t * val) { | 
|---|
|  | 77 | uint64_t add = __atomic_exchange_n(val, 0_l64u, __ATOMIC_RELAXED); | 
|---|
|  | 78 | __atomic_fetch_add(agg, add, __ATOMIC_RELAXED); | 
|---|
|  | 79 | } | 
|---|
|  | 80 |  | 
|---|
|  | 81 | static inline void tally_one( volatile int64_t * agg, volatile int64_t * val) { | 
|---|
|  | 82 | int64_t add = __atomic_exchange_n(val, 0_l64, __ATOMIC_RELAXED); | 
|---|
|  | 83 | __atomic_fetch_add(agg, add, __ATOMIC_RELAXED); | 
|---|
|  | 84 | } | 
|---|
|  | 85 |  | 
|---|
| [8834751] | 86 | void __tally_stats( struct __stats_t * cltr, struct __stats_t * proc ) { | 
|---|
| [941e14a] | 87 | tally_one( &cltr->ready.push.local.attempt    , &proc->ready.push.local.attempt     ); | 
|---|
|  | 88 | tally_one( &cltr->ready.push.local.success    , &proc->ready.push.local.success     ); | 
|---|
|  | 89 | tally_one( &cltr->ready.push.share.attempt    , &proc->ready.push.share.attempt     ); | 
|---|
|  | 90 | tally_one( &cltr->ready.push.share.success    , &proc->ready.push.share.success     ); | 
|---|
|  | 91 | tally_one( &cltr->ready.push.extrn.attempt    , &proc->ready.push.extrn.attempt     ); | 
|---|
|  | 92 | tally_one( &cltr->ready.push.extrn.success    , &proc->ready.push.extrn.success     ); | 
|---|
|  | 93 | tally_one( &cltr->ready.pop.local .attempt    , &proc->ready.pop.local .attempt     ); | 
|---|
|  | 94 | tally_one( &cltr->ready.pop.local .success    , &proc->ready.pop.local .success     ); | 
|---|
|  | 95 | tally_one( &cltr->ready.pop.help  .attempt    , &proc->ready.pop.help  .attempt     ); | 
|---|
|  | 96 | tally_one( &cltr->ready.pop.help  .success    , &proc->ready.pop.help  .success     ); | 
|---|
|  | 97 | tally_one( &cltr->ready.pop.steal .attempt    , &proc->ready.pop.steal .attempt     ); | 
|---|
|  | 98 | tally_one( &cltr->ready.pop.steal .success    , &proc->ready.pop.steal .success     ); | 
|---|
|  | 99 | tally_one( &cltr->ready.pop.search.attempt    , &proc->ready.pop.search.attempt     ); | 
|---|
|  | 100 | tally_one( &cltr->ready.pop.search.success    , &proc->ready.pop.search.success     ); | 
|---|
|  | 101 | tally_one( &cltr->ready.threads.migration     , &proc->ready.threads.migration      ); | 
|---|
|  | 102 | tally_one( &cltr->ready.threads.extunpark     , &proc->ready.threads.extunpark      ); | 
|---|
|  | 103 | tally_one( &cltr->ready.threads.threads       , &proc->ready.threads.threads        ); | 
|---|
|  | 104 | tally_one( &cltr->ready.threads.cthreads      , &proc->ready.threads.cthreads       ); | 
|---|
|  | 105 | tally_one( &cltr->ready.threads.preempt.yield , &proc->ready.threads.preempt.yield  ); | 
|---|
|  | 106 | tally_one( &cltr->ready.threads.preempt.rllfwd, &proc->ready.threads.preempt.rllfwd ); | 
|---|
|  | 107 | tally_one( &cltr->ready.sleep.halts           , &proc->ready.sleep.halts            ); | 
|---|
|  | 108 | tally_one( &cltr->ready.sleep.cancels         , &proc->ready.sleep.cancels          ); | 
|---|
|  | 109 | tally_one( &cltr->ready.sleep.early           , &proc->ready.sleep.early            ); | 
|---|
|  | 110 | tally_one( &cltr->ready.sleep.wakes           , &proc->ready.sleep.wakes            ); | 
|---|
|  | 111 | tally_one( &cltr->ready.sleep.seen            , &proc->ready.sleep.wakes            ); | 
|---|
|  | 112 | tally_one( &cltr->ready.sleep.exits           , &proc->ready.sleep.exits            ); | 
|---|
| [8834751] | 113 |  | 
|---|
| [5751a56] | 114 | #if defined(CFA_HAVE_LINUX_IO_URING_H) | 
|---|
| [45b9b21] | 115 | tally_one( &cltr->io.alloc.fast       , &proc->io.alloc.fast        ); | 
|---|
|  | 116 | tally_one( &cltr->io.alloc.slow       , &proc->io.alloc.slow        ); | 
|---|
|  | 117 | tally_one( &cltr->io.alloc.fail       , &proc->io.alloc.fail        ); | 
|---|
|  | 118 | tally_one( &cltr->io.alloc.revoke     , &proc->io.alloc.revoke      ); | 
|---|
|  | 119 | tally_one( &cltr->io.alloc.block      , &proc->io.alloc.block       ); | 
|---|
|  | 120 | tally_one( &cltr->io.submit.fast      , &proc->io.submit.fast       ); | 
|---|
|  | 121 | tally_one( &cltr->io.submit.slow      , &proc->io.submit.slow       ); | 
|---|
| [7ce8873] | 122 | tally_one( &cltr->io.submit.eagr      , &proc->io.submit.eagr       ); | 
|---|
|  | 123 | tally_one( &cltr->io.submit.nblk      , &proc->io.submit.nblk       ); | 
|---|
| [74227c6] | 124 | tally_one( &cltr->io.submit.extr      , &proc->io.submit.extr       ); | 
|---|
| [45b9b21] | 125 | tally_one( &cltr->io.flush.external   , &proc->io.flush.external    ); | 
|---|
| [74227c6] | 126 | tally_one( &cltr->io.flush.signal     , &proc->io.flush.signal      ); | 
|---|
| [70b4aeb9] | 127 | tally_one( &cltr->io.flush.dirty      , &proc->io.flush.dirty       ); | 
|---|
|  | 128 | tally_one( &cltr->io.flush.full       , &proc->io.flush.full        ); | 
|---|
|  | 129 | tally_one( &cltr->io.flush.idle       , &proc->io.flush.idle        ); | 
|---|
|  | 130 | tally_one( &cltr->io.flush.eager      , &proc->io.flush.eager       ); | 
|---|
| [45b9b21] | 131 | tally_one( &cltr->io.calls.flush      , &proc->io.calls.flush       ); | 
|---|
|  | 132 | tally_one( &cltr->io.calls.submitted  , &proc->io.calls.submitted   ); | 
|---|
|  | 133 | tally_one( &cltr->io.calls.drain      , &proc->io.calls.drain       ); | 
|---|
|  | 134 | tally_one( &cltr->io.calls.completed  , &proc->io.calls.completed   ); | 
|---|
| [54c1196] | 135 | tally_one( &cltr->io.calls.locked     , &proc->io.calls.locked      ); | 
|---|
|  | 136 | tally_one( &cltr->io.calls.helped     , &proc->io.calls.helped      ); | 
|---|
| [45b9b21] | 137 | tally_one( &cltr->io.calls.errors.busy, &proc->io.calls.errors.busy ); | 
|---|
| [db614d0] | 138 | tally_one( &cltr->io.ops.sockread     , &proc->io.ops.sockread      ); | 
|---|
|  | 139 | tally_one( &cltr->io.ops.epllread     , &proc->io.ops.epllread      ); | 
|---|
|  | 140 | tally_one( &cltr->io.ops.sockwrite    , &proc->io.ops.sockwrite     ); | 
|---|
|  | 141 | tally_one( &cltr->io.ops.epllwrite    , &proc->io.ops.epllwrite     ); | 
|---|
| [8834751] | 142 | #endif | 
|---|
|  | 143 | } | 
|---|
|  | 144 |  | 
|---|
| [986cb99] | 145 | #define eng3(X) (ws(3, 3, unit(eng( X )))) | 
|---|
|  | 146 |  | 
|---|
| [1b033b8] | 147 | void __print_stats( struct __stats_t * stats, int flags, const char * type, const char * name, void * id ) with( *stats ) { | 
|---|
| [8834751] | 148 |  | 
|---|
| [986cb99] | 149 | char buf[1024]; | 
|---|
| [bbbd2c4] | 150 | ostrstream sstr = { buf, 1024 }; | 
|---|
| [986cb99] | 151 |  | 
|---|
| [69fbc61] | 152 | if( flags & CFA_STATS_READY_Q ) { | 
|---|
| [986cb99] | 153 |  | 
|---|
| [78ea291] | 154 | sstr | "----- " | type | " \"" | name | "\" (" | "" | id | "" | ") - Ready Q Stats -----"; | 
|---|
| [986cb99] | 155 |  | 
|---|
|  | 156 | uint64_t totalR = ready.pop.local.success + ready.pop.help.success + ready.pop.steal.success + ready.pop.search.success; | 
|---|
|  | 157 | uint64_t totalS = ready.push.local.success + ready.push.share.success + ready.push.extrn.success; | 
|---|
| [78ea291] | 158 | sstr | "- totals   : " | eng3(totalR) | "run," | eng3(totalS) | "schd (" | eng3(ready.push.extrn.success) | "ext," | 
|---|
|  | 159 | | eng3(ready.threads.migration) | "mig," | eng3(ready.threads.extunpark) | " eupk," | ready.threads.threads | " t," | ready.threads.cthreads | " cthr)"; | 
|---|
| [986cb99] | 160 |  | 
|---|
|  | 161 | double push_len = ((double)ready.push.local.attempt + ready.push.share.attempt + ready.push.extrn.attempt) / totalS; | 
|---|
| [d2fadeb] | 162 | double sLcl_len = ready.push.local.success ? ((double)ready.push.local.attempt) / ready.push.local.success : 0; | 
|---|
|  | 163 | double sOth_len = ready.push.share.success ? ((double)ready.push.share.attempt) / ready.push.share.success : 0; | 
|---|
|  | 164 | double sExt_len = ready.push.extrn.success ? ((double)ready.push.extrn.attempt) / ready.push.extrn.success : 0; | 
|---|
| [986cb99] | 165 | sstr | "- push avg : " | ws(3, 3, push_len) | 
|---|
|  | 166 | | "- l: " | eng3(ready.push.local.attempt) | " (" | ws(3, 3, sLcl_len) | ")" | 
|---|
|  | 167 | | ", s: " | eng3(ready.push.share.attempt) | " (" | ws(3, 3, sOth_len) | ")" | 
|---|
|  | 168 | | ", e: " | eng3(ready.push.extrn.attempt) | " (" | ws(3, 3, sExt_len) | ")"; | 
|---|
|  | 169 |  | 
|---|
|  | 170 | double rLcl_pc = (100.0 * (double)ready.pop.local .success) / totalR; | 
|---|
|  | 171 | sstr | "- local    : " | eng3(ready.pop.local .success) | "-"| ws(3, 3, rLcl_pc) | '%' | 
|---|
| [78ea291] | 172 | | " (" | eng3(ready.pop.local .attempt) | " try)"; | 
|---|
| [986cb99] | 173 | double rHlp_pc = (100.0 * (double)ready.pop.help  .success) / totalR; | 
|---|
|  | 174 | sstr | "- help     : " | eng3(ready.pop.help  .success) | "-"| ws(3, 3, rHlp_pc) | '%' | 
|---|
| [78ea291] | 175 | | " (" | eng3(ready.pop.help  .attempt) | " try)"; | 
|---|
| [986cb99] | 176 | double rStl_pc = (100.0 * (double)ready.pop.steal .success) / totalR; | 
|---|
|  | 177 | sstr | "- steal    : " | eng3(ready.pop.steal .success) | "-"| ws(3, 3, rStl_pc) | '%' | 
|---|
| [78ea291] | 178 | | " (" | eng3(ready.pop.steal .attempt) | " try)"; | 
|---|
| [986cb99] | 179 | double rSch_pc = (100.0 * (double)ready.pop.search.success) / totalR; | 
|---|
|  | 180 | sstr | "- search   : " | eng3(ready.pop.search.success) | "-"| ws(3, 3, rSch_pc) | '%' | 
|---|
| [78ea291] | 181 | | " (" | eng3(ready.pop.search.attempt) | " try)"; | 
|---|
| [986cb99] | 182 |  | 
|---|
| [7cf3b1d] | 183 | sstr | "- Idle Slp : " | eng3(ready.sleep.halts) | "halt," | eng3(ready.sleep.cancels) | "cancel," | 
|---|
|  | 184 | | eng3(ready.sleep.wakes + ready.sleep.early) | '(' | eng3(ready.sleep.early) | ',' | eng3(ready.sleep.seen) | ')' | " wake(early, seen)," | 
|---|
|  | 185 | | eng3(ready.sleep.exits) | "exit"; | 
|---|
| [941e14a] | 186 | sstr | "- Preemption : " | eng3(ready.threads.preempt.yield) | "yields," | eng3(ready.threads.preempt.rllfwd) | "delayed"; | 
|---|
| [986cb99] | 187 | sstr | nl; | 
|---|
| [69fbc61] | 188 | } | 
|---|
|  | 189 |  | 
|---|
| [5751a56] | 190 | #if defined(CFA_HAVE_LINUX_IO_URING_H) | 
|---|
| [69fbc61] | 191 | if( flags & CFA_STATS_IO ) { | 
|---|
| [78ea291] | 192 | sstr | "----- " | type | " \"" | name | "\" (" | "" | id | "" | ") - I/O Stats -----"; | 
|---|
| [986cb99] | 193 |  | 
|---|
| [d60d30e] | 194 | uint64_t total_allocs = io.alloc.fast + io.alloc.slow; | 
|---|
| [69fbc61] | 195 |  | 
|---|
| [d60d30e] | 196 | uint64_t total_submits = io.submit.fast + io.submit.slow; | 
|---|
| [78ea291] | 197 | sstr | "- totals : allc" | eng3(io.alloc .fast) | nonl; | 
|---|
|  | 198 | if(io.alloc.slow) { | 
|---|
|  | 199 | double avgfasta = (100.0 * (double)io.alloc.fast) / total_allocs; | 
|---|
|  | 200 | sstr | "fast," | eng3(io.alloc .slow) | "slow (" | ws(3, 3, avgfasta) | "%)" | nonl; | 
|---|
|  | 201 | } | 
|---|
|  | 202 | sstr | " - subm" | eng3(io.submit.fast) | nonl; | 
|---|
|  | 203 | if(io.alloc.slow) { | 
|---|
|  | 204 | double avgfasts = (100.0 * (double)io.submit.fast) / total_submits; | 
|---|
| [74227c6] | 205 | sstr | "fast," | eng3(io.submit.slow) | "slow (" | ws(3, 3, avgfasts) | "%)," | eng3(io.submit.extr) | "external" | nonl; | 
|---|
| [78ea291] | 206 | } | 
|---|
| [7ce8873] | 207 | sstr | " - eager" | eng3(io.submit.eagr) | nonl; | 
|---|
|  | 208 | sstr | " - no-wait" | eng3(io.submit.nblk) | nonl; | 
|---|
| [78ea291] | 209 | sstr | nl; | 
|---|
| [986cb99] | 210 |  | 
|---|
| [78ea291] | 211 | if(io.alloc.fail || io.alloc.revoke || io.alloc.block) | 
|---|
|  | 212 | sstr | "-     failures      : " | eng3(io.alloc.fail) | "oom, " | eng3(io.alloc.revoke) | "rvk, " | eng3(io.alloc.block) | "blk"; | 
|---|
| [70b4aeb9] | 213 | // if(io.flush.external) | 
|---|
|  | 214 | //      sstr | "- flush external    : " | eng3(io.flush.external); | 
|---|
| [69fbc61] | 215 |  | 
|---|
| [dddb3dd0] | 216 | double avgsubs = ((double)io.calls.submitted) / io.calls.flush; | 
|---|
|  | 217 | double avgcomp = ((double)io.calls.completed) / io.calls.drain; | 
|---|
| [78ea291] | 218 | sstr | "- syscll : " | 
|---|
| [70b4aeb9] | 219 | |   " sub " | eng3(io.calls.submitted) | "/" | eng3(io.calls.flush) | "(" | ws(3, 3, avgsubs) | "/flush)" | 
|---|
|  | 220 | | " - cmp " | eng3(io.calls.completed) | "/" | eng3(io.calls.drain) | "(" | ws(3, 3, avgcomp) | "/drain)" | 
|---|
| [54c1196] | 221 | | " - cmp " | eng3(io.calls.locked) | "locked, " | eng3(io.calls.helped) | "helped" | 
|---|
| [78ea291] | 222 | | " - " | eng3(io.calls.errors.busy) | " EBUSY"; | 
|---|
| [74227c6] | 223 | 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) | '/' | eng3(io.flush.signal) | "ext"; | 
|---|
| [db614d0] | 224 | sstr | "- ops blk: " | 
|---|
|  | 225 | |   " sk rd: " | eng3(io.ops.sockread)  | "epll: " | eng3(io.ops.epllread) | 
|---|
|  | 226 | |   " sk wr: " | eng3(io.ops.sockwrite) | "epll: " | eng3(io.ops.epllwrite); | 
|---|
| [986cb99] | 227 | sstr | nl; | 
|---|
| [69fbc61] | 228 | } | 
|---|
| [c34ebf2] | 229 | #endif | 
|---|
| [986cb99] | 230 |  | 
|---|
|  | 231 | if(flags) write( sstr, stdout ); | 
|---|
| [8834751] | 232 | } | 
|---|
| [73f4d08] | 233 |  | 
|---|
|  | 234 | #if defined(CFA_STATS_ARRAY) | 
|---|
|  | 235 | extern "C" { | 
|---|
|  | 236 | #include <stdio.h> | 
|---|
|  | 237 | #include <errno.h> | 
|---|
|  | 238 | #include <sys/stat.h> | 
|---|
|  | 239 | #include <fcntl.h> | 
|---|
|  | 240 | } | 
|---|
|  | 241 |  | 
|---|
|  | 242 | void __flush_stat( struct __stats_t * this, const char * name, void * handle) { | 
|---|
|  | 243 | int ret = mkdir(".cfadata", 0755); | 
|---|
|  | 244 | if(ret < 0 && errno != EEXIST) abort("Failed to create directory .cfadata: %d\n", errno); | 
|---|
|  | 245 |  | 
|---|
|  | 246 | char filename[100]; | 
|---|
|  | 247 | snprintf(filename, 100, ".cfadata/%s%p.data", name, handle); | 
|---|
|  | 248 |  | 
|---|
|  | 249 | int fd = open(filename, O_WRONLY | O_APPEND | O_CREAT, 0644); | 
|---|
|  | 250 | if(fd < 0) abort("Failed to create file %s: %d\n", filename, errno); | 
|---|
|  | 251 |  | 
|---|
|  | 252 | for(i; this->array.cnt) { | 
|---|
|  | 253 | char line[100]; | 
|---|
|  | 254 | size_t n = snprintf(line, 100, "%llu, %lld\n", this->array.values[i].ts, this->array.values[i].value); | 
|---|
|  | 255 | write(fd, line, n); | 
|---|
|  | 256 | } | 
|---|
|  | 257 |  | 
|---|
|  | 258 | this->array.cnt = 0; | 
|---|
|  | 259 | close(fd); | 
|---|
|  | 260 | } | 
|---|
|  | 261 |  | 
|---|
|  | 262 | static __spinlock_t stats_lock; | 
|---|
|  | 263 |  | 
|---|
|  | 264 | void __push_stat( struct __stats_t * this, int64_t value, bool external, const char * name, void * handle ) { | 
|---|
|  | 265 | if(external) lock(stats_lock __cfaabi_dbg_ctx2); | 
|---|
|  | 266 |  | 
|---|
|  | 267 | if( this->array.cnt >= CFA_STATS_ARRAY ) __flush_stat( this, name, handle ); | 
|---|
|  | 268 |  | 
|---|
|  | 269 | size_t idx = this->array.cnt; | 
|---|
|  | 270 | this->array.cnt++; | 
|---|
|  | 271 |  | 
|---|
|  | 272 | if(external) unlock(stats_lock); | 
|---|
|  | 273 |  | 
|---|
|  | 274 | this->array.values[idx].ts = rdtscl(); | 
|---|
|  | 275 | this->array.values[idx].value = value; | 
|---|
|  | 276 | } | 
|---|
|  | 277 | #endif | 
|---|
| [bbbd2c4] | 278 | #endif | 
|---|