source: libcfa/src/concurrency/stats.cfa@ 64a7146

ADT arm-eh ast-experimental enum forall-pointer-decay jacob/cs343-translation new-ast new-ast-unique-expr pthread-emulation qualifiedEnum
Last change on this file since 64a7146 was 8834751, checked in by Thierry Delisle <tdelisle@…>, 5 years ago

Moved statistics to stats.cfa to combine ready Q stats and IO stats
  • Property mode set to 100644
File size: 5.8 KB
Line 
1#include <stdint.h>
2#include <stdlib.hfa>
3
4#include <unistd.h> // STDERR_FILENO
5#include "bits/debug.hfa"
6#include "stats.hfa"
7
8#if !defined(__CFA_NO_STATISTICS__)
9 void __init_stats( struct __stats_t * stats ) {
10 stats->ready.pick.push.attempt = 0;
11 stats->ready.pick.push.success = 0;
12 stats->ready.pick.pop .probe = 0;
13 stats->ready.pick.pop .attempt = 0;
14 stats->ready.pick.pop .success = 0;
15
16 #if defined(HAVE_LINUX_IO_URING_H)
17 stats->io.submit_q.submit_avg.rdy = 0;
18 stats->io.submit_q.submit_avg.csm = 0;
19 stats->io.submit_q.submit_avg.avl = 0;
20 stats->io.submit_q.submit_avg.cnt = 0;
21 stats->io.submit_q.look_avg.val = 0;
22 stats->io.submit_q.look_avg.cnt = 0;
23 stats->io.submit_q.look_avg.block = 0;
24 stats->io.submit_q.alloc_avg.val = 0;
25 stats->io.submit_q.alloc_avg.cnt = 0;
26 stats->io.submit_q.alloc_avg.block = 0;
27 stats->io.complete_q.completed_avg.val = 0;
28 stats->io.complete_q.completed_avg.slow_cnt = 0;
29 stats->io.complete_q.completed_avg.fast_cnt = 0;
30 #endif
31 }
32
33 void __tally_stats( struct __stats_t * cltr, struct __stats_t * proc ) {
34 __atomic_fetch_add( &cltr->ready.pick.push.attempt, proc->ready.pick.push.attempt, __ATOMIC_SEQ_CST );
35 __atomic_fetch_add( &cltr->ready.pick.push.success, proc->ready.pick.push.success, __ATOMIC_SEQ_CST );
36 __atomic_fetch_add( &cltr->ready.pick.pop .probe , proc->ready.pick.pop .probe , __ATOMIC_SEQ_CST );
37 __atomic_fetch_add( &cltr->ready.pick.pop .attempt, proc->ready.pick.pop .attempt, __ATOMIC_SEQ_CST );
38 __atomic_fetch_add( &cltr->ready.pick.pop .success, proc->ready.pick.pop .success, __ATOMIC_SEQ_CST );
39
40 #if defined(HAVE_LINUX_IO_URING_H)
41 __atomic_fetch_add( &cltr->io.submit_q.submit_avg.rdy , proc->io.submit_q.submit_avg.rdy , __ATOMIC_SEQ_CST );
42 __atomic_fetch_add( &cltr->io.submit_q.submit_avg.csm , proc->io.submit_q.submit_avg.csm , __ATOMIC_SEQ_CST );
43 __atomic_fetch_add( &cltr->io.submit_q.submit_avg.avl , proc->io.submit_q.submit_avg.avl , __ATOMIC_SEQ_CST );
44 __atomic_fetch_add( &cltr->io.submit_q.submit_avg.cnt , proc->io.submit_q.submit_avg.cnt , __ATOMIC_SEQ_CST );
45 __atomic_fetch_add( &cltr->io.submit_q.look_avg.val , proc->io.submit_q.look_avg.val , __ATOMIC_SEQ_CST );
46 __atomic_fetch_add( &cltr->io.submit_q.look_avg.cnt , proc->io.submit_q.look_avg.cnt , __ATOMIC_SEQ_CST );
47 __atomic_fetch_add( &cltr->io.submit_q.look_avg.block , proc->io.submit_q.look_avg.block , __ATOMIC_SEQ_CST );
48 __atomic_fetch_add( &cltr->io.submit_q.alloc_avg.val , proc->io.submit_q.alloc_avg.val , __ATOMIC_SEQ_CST );
49 __atomic_fetch_add( &cltr->io.submit_q.alloc_avg.cnt , proc->io.submit_q.alloc_avg.cnt , __ATOMIC_SEQ_CST );
50 __atomic_fetch_add( &cltr->io.submit_q.alloc_avg.block , proc->io.submit_q.alloc_avg.block , __ATOMIC_SEQ_CST );
51 __atomic_fetch_add( &cltr->io.complete_q.completed_avg.val , proc->io.complete_q.completed_avg.val , __ATOMIC_SEQ_CST );
52 __atomic_fetch_add( &cltr->io.complete_q.completed_avg.slow_cnt, proc->io.complete_q.completed_avg.slow_cnt, __ATOMIC_SEQ_CST );
53 __atomic_fetch_add( &cltr->io.complete_q.completed_avg.fast_cnt, proc->io.complete_q.completed_avg.fast_cnt, __ATOMIC_SEQ_CST );
54 #endif
55 }
56
57 void __print_stats( struct __stats_t * stats ) {
58
59 double push_sur = (100.0 * ((double)stats->ready.pick.push.success) / stats->ready.pick.push.attempt);
60 double pop_sur = (100.0 * ((double)stats->ready.pick.pop .success) / stats->ready.pick.pop .attempt);
61
62 double push_len = ((double)stats->ready.pick.push.attempt) / stats->ready.pick.push.success;
63 double pop_len = ((double)stats->ready.pick.pop .attempt) / stats->ready.pick.pop .success;
64
65 #if defined(HAVE_LINUX_IO_URING_H)
66 double avgrdy = ((double)submit_avg.rdy) / submit_avg.cnt;
67 double avgcsm = ((double)submit_avg.csm) / submit_avg.cnt;
68 double avgavl = ((double)submit_avg.avl) / submit_avg.cnt;
69
70 double lavgv = 0;
71 double lavgb = 0;
72 if(look_avg.cnt != 0) {
73 lavgv = ((double)look_avg.val ) / look_avg.cnt;
74 lavgb = ((double)look_avg.block) / look_avg.cnt;
75 }
76
77 double aavgv = 0;
78 double aavgb = 0;
79 if(alloc_avg.cnt != 0) {
80 aavgv = ((double)alloc_avg.val ) / alloc_avg.cnt;
81 aavgb = ((double)alloc_avg.block) / alloc_avg.cnt;
82 }
83 #endif
84
85 __cfaabi_bits_print_safe( STDOUT_FILENO,
86 "----- Ready Q Stats -----\n"
87 "- total threads run : %'15lu\n"
88 "- total threads scheduled: %'15lu\n"
89 "- push average probe len : %'18.2lf, %'18.2lf%% (%'15lu attempts)\n"
90 "- pop average probe len : %'18.2lf, %'18.2lf%% (%'15lu attempts)\n"
91 #if defined(HAVE_LINUX_IO_URING_H)
92 "\n"
93 "----- I/O Stats -----\n"
94 "- total submit calls : %'15llu\n"
95 "- avg ready entries : %'18.2lf\n"
96 "- avg submitted entries : %'18.2lf\n"
97 "- avg available entries : %'18.2lf\n"
98 "- total ready search : %'15llu\n"
99 "- avg ready search len : %'18.2lf\n"
100 "- avg ready search block : %'18.2lf\n"
101 "- total alloc search : %'15llu\n"
102 "- avg alloc search len : %'18.2lf\n"
103 "- avg alloc search block : %'18.2lf\n"
104 "- total wait calls : %'15llu (%'llu slow, %'llu fast)\n"
105 "- avg completion/wait : %'18.2lf\n"
106 #endif
107 , stats->ready.pick.pop.success
108 , stats->ready.pick.push.success
109 , push_len, push_sur, stats->ready.pick.push.attempt
110 , pop_len , pop_sur , stats->ready.pick.pop .attempt
111 #if defined(HAVE_LINUX_IO_URING_H)
112 , submit_avg.cnt
113 , avgrdy
114 , avgcsm
115 , avgavl
116 , look_avg.cnt
117 , lavgv
118 , lavgb
119 , alloc_avg.cnt
120 , aavgv
121 , aavgb
122 , completed_avg.slow_cnt + completed_avg.fast_cnt
123 , completed_avg.slow_cnt, completed_avg.fast_cnt
124 , ((double)completed_avg.val) / (completed_avg.slow_cnt + completed_avg.fast_cnt)
125 #endif
126 );
127 }
128#endif
Note: See TracBrowser for help on using the repository browser.