| [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 |
|---|
