Context Navigation

stats.cfa @ de917da3

ADTarm-ehast-experimentalenumforall-pointer-decayjacob/cs343-translationnew-astnew-ast-unique-exprpthread-emulationqualifiedEnum

Last change on this file since de917da3 was 13c5e19, checked in by Thierry Delisle <tdelisle@…>, 4 years ago
Moved snzi and subqueues outside of ready_queue.cfa. Added random.hfa with multiple prng. Minor optimizations to ready-queue Stats now track number of local pops( bias pops ) Fixed stats for io Fixed calculaton of nprocessors Fixed IO to work with new ready-queue
Property mode set to `100644`
File size: 7.2 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 .local = 0;
15	stats->ready.pick.pop .success = 0;
16	stats->ready.sleep.halts = 0;
17	stats->ready.sleep.cancels = 0;
18	stats->ready.sleep.wakes = 0;
19	stats->ready.sleep.exits = 0;
20
21	#if defined(HAVE_LINUX_IO_URING_H)
22	stats->io.submit_q.submit_avg.rdy = 0;
23	stats->io.submit_q.submit_avg.csm = 0;
24	stats->io.submit_q.submit_avg.avl = 0;
25	stats->io.submit_q.submit_avg.cnt = 0;
26	stats->io.submit_q.look_avg.val = 0;
27	stats->io.submit_q.look_avg.cnt = 0;
28	stats->io.submit_q.look_avg.block = 0;
29	stats->io.submit_q.alloc_avg.val = 0;
30	stats->io.submit_q.alloc_avg.cnt = 0;
31	stats->io.submit_q.alloc_avg.block = 0;
32	stats->io.complete_q.completed_avg.val = 0;
33	stats->io.complete_q.completed_avg.slow_cnt = 0;
34	stats->io.complete_q.completed_avg.fast_cnt = 0;
35	#endif
36	}
37
38	void __tally_stats( struct __stats_t * cltr, struct __stats_t * proc ) {
39	__atomic_fetch_add( &cltr->ready.pick.push.attempt, proc->ready.pick.push.attempt, __ATOMIC_SEQ_CST );
40	__atomic_fetch_add( &cltr->ready.pick.push.local , proc->ready.pick.push.local , __ATOMIC_SEQ_CST );
41	__atomic_fetch_add( &cltr->ready.pick.push.success, proc->ready.pick.push.success, __ATOMIC_SEQ_CST );
42	__atomic_fetch_add( &cltr->ready.pick.pop .probe , proc->ready.pick.pop .probe , __ATOMIC_SEQ_CST );
43	__atomic_fetch_add( &cltr->ready.pick.pop .attempt, proc->ready.pick.pop .attempt, __ATOMIC_SEQ_CST );
44	__atomic_fetch_add( &cltr->ready.pick.pop .local , proc->ready.pick.pop .local , __ATOMIC_SEQ_CST );
45	__atomic_fetch_add( &cltr->ready.pick.pop .success, proc->ready.pick.pop .success, __ATOMIC_SEQ_CST );
46	__atomic_fetch_add( &cltr->ready.sleep.halts , proc->ready.sleep.halts , __ATOMIC_SEQ_CST );
47	__atomic_fetch_add( &cltr->ready.sleep.cancels, proc->ready.sleep.cancels, __ATOMIC_SEQ_CST );
48	__atomic_fetch_add( &cltr->ready.sleep.wakes , proc->ready.sleep.wakes , __ATOMIC_SEQ_CST );
49	__atomic_fetch_add( &cltr->ready.sleep.exits , proc->ready.sleep.exits , __ATOMIC_SEQ_CST );
50
51	#if defined(HAVE_LINUX_IO_URING_H)
52	__atomic_fetch_add( &cltr->io.submit_q.submit_avg.rdy , proc->io.submit_q.submit_avg.rdy , __ATOMIC_SEQ_CST );
53	__atomic_fetch_add( &cltr->io.submit_q.submit_avg.csm , proc->io.submit_q.submit_avg.csm , __ATOMIC_SEQ_CST );
54	__atomic_fetch_add( &cltr->io.submit_q.submit_avg.avl , proc->io.submit_q.submit_avg.avl , __ATOMIC_SEQ_CST );
55	__atomic_fetch_add( &cltr->io.submit_q.submit_avg.cnt , proc->io.submit_q.submit_avg.cnt , __ATOMIC_SEQ_CST );
56	__atomic_fetch_add( &cltr->io.submit_q.look_avg.val , proc->io.submit_q.look_avg.val , __ATOMIC_SEQ_CST );
57	__atomic_fetch_add( &cltr->io.submit_q.look_avg.cnt , proc->io.submit_q.look_avg.cnt , __ATOMIC_SEQ_CST );
58	__atomic_fetch_add( &cltr->io.submit_q.look_avg.block , proc->io.submit_q.look_avg.block , __ATOMIC_SEQ_CST );
59	__atomic_fetch_add( &cltr->io.submit_q.alloc_avg.val , proc->io.submit_q.alloc_avg.val , __ATOMIC_SEQ_CST );
60	__atomic_fetch_add( &cltr->io.submit_q.alloc_avg.cnt , proc->io.submit_q.alloc_avg.cnt , __ATOMIC_SEQ_CST );
61	__atomic_fetch_add( &cltr->io.submit_q.alloc_avg.block , proc->io.submit_q.alloc_avg.block , __ATOMIC_SEQ_CST );
62	__atomic_fetch_add( &cltr->io.complete_q.completed_avg.val , proc->io.complete_q.completed_avg.val , __ATOMIC_SEQ_CST );
63	__atomic_fetch_add( &cltr->io.complete_q.completed_avg.slow_cnt, proc->io.complete_q.completed_avg.slow_cnt, __ATOMIC_SEQ_CST );
64	__atomic_fetch_add( &cltr->io.complete_q.completed_avg.fast_cnt, proc->io.complete_q.completed_avg.fast_cnt, __ATOMIC_SEQ_CST );
65	#endif
66	}
67
68	void __print_stats( struct __stats_t * stats ) with( *stats ) {
69
70	double push_sur = (100.0 * ((double)ready.pick.push.success) / ready.pick.push.attempt);
71	double pop_sur = (100.0 * ((double)ready.pick.pop .success) / ready.pick.pop .attempt);
72
73	double push_len = ((double)ready.pick.push.attempt) / ready.pick.push.success;
74	double pop_len = ((double)ready.pick.pop .attempt) / ready.pick.pop .success;
75
76	#if defined(HAVE_LINUX_IO_URING_H)
77	double avgrdy = ((double)io.submit_q.submit_avg.rdy) / io.submit_q.submit_avg.cnt;
78	double avgcsm = ((double)io.submit_q.submit_avg.csm) / io.submit_q.submit_avg.cnt;
79	double avgavl = ((double)io.submit_q.submit_avg.avl) / io.submit_q.submit_avg.cnt;
80
81	double lavgv = 0;
82	double lavgb = 0;
83	if(io.submit_q.look_avg.cnt != 0) {
84	lavgv = ((double)io.submit_q.look_avg.val ) / io.submit_q.look_avg.cnt;
85	lavgb = ((double)io.submit_q.look_avg.block) / io.submit_q.look_avg.cnt;
86	}
87
88	double aavgv = 0;
89	double aavgb = 0;
90	if(io.submit_q.alloc_avg.cnt != 0) {
91	aavgv = ((double)io.submit_q.alloc_avg.val ) / io.submit_q.alloc_avg.cnt;
92	aavgb = ((double)io.submit_q.alloc_avg.block) / io.submit_q.alloc_avg.cnt;
93	}
94	#endif
95
96	__cfaabi_bits_print_safe( STDOUT_FILENO,
97	"----- Ready Q Stats -----\n"
98	"- total threads run : %'15lu\n"
99	"- total threads scheduled: %'15lu\n"
100	"- push average probe len : %'18.2lf, %'18.2lf%% (%'15lu attempts, %'15lu local)\n"
101	"- pop average probe len : %'18.2lf, %'18.2lf%% (%'15lu attempts, %'15lu local)\n"
102	"- Idle Sleep -\n"
103	"-- halts : %'15lu\n"
104	"-- cancelled halts : %'15lu\n"
105	"-- schedule wake : %'15lu\n"
106	"-- wake on exit : %'15lu\n"
107	#if defined(HAVE_LINUX_IO_URING_H)
108	"\n"
109	"----- I/O Stats -----\n"
110	"- total submit calls : %'15lu\n"
111	"- avg ready entries : %'18.2lf\n"
112	"- avg submitted entries : %'18.2lf\n"
113	"- avg available entries : %'18.2lf\n"
114	"- total ready search : %'15lu\n"
115	"- avg ready search len : %'18.2lf\n"
116	"- avg ready search block : %'18.2lf\n"
117	"- total alloc search : %'15lu\n"
118	"- avg alloc search len : %'18.2lf\n"
119	"- avg alloc search block : %'18.2lf\n"
120	"- total wait calls : %'15lu (%'lu slow, %'lu fast)\n"
121	"- avg completion/wait : %'18.2lf\n"
122	#endif
123	, ready.pick.pop.success
124	, ready.pick.push.success
125	, push_len, push_sur, ready.pick.push.attempt, ready.pick.push.local
126	, pop_len , pop_sur , ready.pick.pop .attempt, ready.pick.pop .local
127	, ready.sleep.halts, ready.sleep.cancels, ready.sleep.wakes, ready.sleep.exits
128	#if defined(HAVE_LINUX_IO_URING_H)
129	, io.submit_q.submit_avg.cnt
130	, avgrdy
131	, avgcsm
132	, avgavl
133	, io.submit_q.look_avg.cnt
134	, lavgv
135	, lavgb
136	, io.submit_q.alloc_avg.cnt
137	, aavgv
138	, aavgb
139	, io.complete_q.completed_avg.slow_cnt + io.complete_q.completed_avg.fast_cnt
140	, io.complete_q.completed_avg.slow_cnt, io.complete_q.completed_avg.fast_cnt
141	, ((double)io.complete_q.completed_avg.val) / (io.complete_q.completed_avg.slow_cnt + io.complete_q.completed_avg.fast_cnt)
142	#endif
143	);
144	}
145	#endif

Note: See TracBrowser for help on using the repository browser.

Download in other formats:

Original Format