1 | #pragma once
|
---|
2 |
|
---|
3 | #include <stdint.h>
|
---|
4 |
|
---|
5 | enum {
|
---|
6 | CFA_STATS_READY_Q = 0x01,
|
---|
7 | CFA_STATS_IO = 0x02,
|
---|
8 | };
|
---|
9 |
|
---|
10 | #if defined(__CFA_NO_STATISTICS__)
|
---|
11 | struct __stats_t;
|
---|
12 | static inline void __init_stats( struct __stats_t * ) {}
|
---|
13 | static inline void __tally_stats( struct __stats_t *, struct __stats_t * ) {}
|
---|
14 | static inline void __print_stats( struct __stats_t *, int, const char *, const char *, void * ) {}
|
---|
15 | #else
|
---|
16 |
|
---|
17 | struct __attribute__((aligned(64))) __stats_readQ_t {
|
---|
18 | struct {
|
---|
19 | // Push statistic
|
---|
20 | struct {
|
---|
21 | // number of attemps at pushing something
|
---|
22 | volatile uint64_t attempt;
|
---|
23 |
|
---|
24 | // number of successes at pushing
|
---|
25 | volatile uint64_t success;
|
---|
26 |
|
---|
27 | // number of attemps at pushing something to preferred queues
|
---|
28 | volatile uint64_t local;
|
---|
29 |
|
---|
30 | // number of successes at pushing to preferred queues
|
---|
31 | volatile uint64_t lsuccess;
|
---|
32 | } push;
|
---|
33 |
|
---|
34 | struct {
|
---|
35 | // number of attemps at pushing something
|
---|
36 | volatile uint64_t attempt;
|
---|
37 |
|
---|
38 | // number of successes at pushing
|
---|
39 | volatile uint64_t success;
|
---|
40 |
|
---|
41 | // number of attemps at pushing something to preferred queues
|
---|
42 | volatile uint64_t local;
|
---|
43 |
|
---|
44 | // number of successes at pushing to preferred queues
|
---|
45 | volatile uint64_t lsuccess;
|
---|
46 | } ext;
|
---|
47 |
|
---|
48 | // Pop statistic
|
---|
49 | struct {
|
---|
50 | // number of reads of the mask
|
---|
51 | // picking an empty __cfa_readyQ_mask_t counts here
|
---|
52 | // but not as an attempt
|
---|
53 | volatile uint64_t probe;
|
---|
54 |
|
---|
55 | // number of attemps at poping something
|
---|
56 | volatile uint64_t attempt;
|
---|
57 |
|
---|
58 | // number of successes at poping
|
---|
59 | volatile uint64_t success;
|
---|
60 |
|
---|
61 | // number of attemps at poping something to preferred queues
|
---|
62 | volatile uint64_t local;
|
---|
63 |
|
---|
64 | // number of successes at poping to preferred queues
|
---|
65 | volatile uint64_t lsuccess;
|
---|
66 | } pop;
|
---|
67 | } pick;
|
---|
68 | struct {
|
---|
69 | volatile uint64_t migration;
|
---|
70 | volatile int64_t threads; // number of threads in the system, includes only local change
|
---|
71 | } threads;
|
---|
72 | struct {
|
---|
73 | volatile uint64_t halts;
|
---|
74 | volatile uint64_t cancels;
|
---|
75 | volatile uint64_t wakes;
|
---|
76 | volatile uint64_t exits;
|
---|
77 | } sleep;
|
---|
78 | };
|
---|
79 |
|
---|
80 | #if defined(CFA_HAVE_LINUX_IO_URING_H)
|
---|
81 | struct __attribute__((aligned(64))) __stats_io_t{
|
---|
82 | struct {
|
---|
83 | volatile uint64_t fast;
|
---|
84 | volatile uint64_t slow;
|
---|
85 | volatile uint64_t fail;
|
---|
86 | volatile uint64_t revoke;
|
---|
87 | volatile uint64_t block;
|
---|
88 | } alloc;
|
---|
89 | struct {
|
---|
90 | volatile uint64_t fast;
|
---|
91 | volatile uint64_t slow;
|
---|
92 | } submit;
|
---|
93 | struct {
|
---|
94 | volatile uint64_t external;
|
---|
95 | } flush;
|
---|
96 | struct {
|
---|
97 | volatile uint64_t drain;
|
---|
98 | volatile uint64_t completed;
|
---|
99 | volatile uint64_t flush;
|
---|
100 | volatile uint64_t submitted;
|
---|
101 | struct {
|
---|
102 | volatile uint64_t busy;
|
---|
103 | } errors;
|
---|
104 | } calls;
|
---|
105 | struct {
|
---|
106 | volatile uint64_t sleeps;
|
---|
107 | } poller;
|
---|
108 | };
|
---|
109 | #endif
|
---|
110 |
|
---|
111 | struct __attribute__((aligned(128))) __stats_t {
|
---|
112 | __stats_readQ_t ready;
|
---|
113 | #if defined(CFA_HAVE_LINUX_IO_URING_H)
|
---|
114 | __stats_io_t io;
|
---|
115 | #endif
|
---|
116 | };
|
---|
117 |
|
---|
118 | void __init_stats ( struct __stats_t * );
|
---|
119 | void __tally_stats( struct __stats_t *, struct __stats_t * );
|
---|
120 | void __print_stats( struct __stats_t *, int, const char *, const char *, void * );
|
---|
121 | #endif
|
---|
122 |
|
---|