4 #include <linux/kernel.h>
5 #include <linux/blkdev.h>
6 #include <linux/ktime.h>
7 #include <linux/rcupdate.h>
8 #include <linux/timer.h>
12 * 3 bits: reserved for other usage
16 #define BLK_STAT_RES_BITS 3
17 #define BLK_STAT_SIZE_BITS 12
18 #define BLK_STAT_RES_SHIFT (64 - BLK_STAT_RES_BITS)
19 #define BLK_STAT_SIZE_SHIFT (BLK_STAT_RES_SHIFT - BLK_STAT_SIZE_BITS)
20 #define BLK_STAT_TIME_MASK ((1ULL << BLK_STAT_SIZE_SHIFT) - 1)
21 #define BLK_STAT_SIZE_MASK \
22 (((1ULL << BLK_STAT_SIZE_BITS) - 1) << BLK_STAT_SIZE_SHIFT)
23 #define BLK_STAT_RES_MASK (~((1ULL << BLK_STAT_RES_SHIFT) - 1))
26 * struct blk_stat_callback - Block statistics callback.
28 * A &struct blk_stat_callback is associated with a &struct request_queue. While
29 * @timer is active, that queue's request completion latencies are sorted into
30 * buckets by @bucket_fn and added to a per-cpu buffer, @cpu_stat. When the
31 * timer fires, @cpu_stat is flushed to @stat and @timer_fn is invoked.
33 struct blk_stat_callback
{
35 * @list: RCU list of callbacks for a &struct request_queue.
37 struct list_head list
;
40 * @timer: Timer for the next callback invocation.
42 struct timer_list timer
;
45 * @cpu_stat: Per-cpu statistics buckets.
47 struct blk_rq_stat __percpu
*cpu_stat
;
50 * @bucket_fn: Given a request, returns which statistics bucket it
51 * should be accounted under. Return -1 for no bucket for this
54 int (*bucket_fn
)(const struct request
*);
57 * @buckets: Number of statistics buckets.
62 * @stat: Array of statistics buckets.
64 struct blk_rq_stat
*stat
;
67 * @fn: Callback function.
69 void (*timer_fn
)(struct blk_stat_callback
*);
72 * @data: Private pointer for the user.
79 struct blk_queue_stats
*blk_alloc_queue_stats(void);
80 void blk_free_queue_stats(struct blk_queue_stats
*);
82 void blk_stat_add(struct request
*);
84 static inline u64
__blk_stat_time(u64 time
)
86 return time
& BLK_STAT_TIME_MASK
;
89 static inline u64
blk_stat_time(struct blk_issue_stat
*stat
)
91 return __blk_stat_time(stat
->stat
);
94 static inline sector_t
blk_capped_size(sector_t size
)
96 return size
& ((1ULL << BLK_STAT_SIZE_BITS
) - 1);
99 static inline sector_t
blk_stat_size(struct blk_issue_stat
*stat
)
101 return (stat
->stat
& BLK_STAT_SIZE_MASK
) >> BLK_STAT_SIZE_SHIFT
;
104 static inline void blk_stat_set_issue(struct blk_issue_stat
*stat
,
107 stat
->stat
= (stat
->stat
& BLK_STAT_RES_MASK
) |
108 (ktime_to_ns(ktime_get()) & BLK_STAT_TIME_MASK
) |
109 (((u64
)blk_capped_size(size
)) << BLK_STAT_SIZE_SHIFT
);
112 /* record time/size info in request but not add a callback */
113 void blk_stat_enable_accounting(struct request_queue
*q
);
116 * blk_stat_alloc_callback() - Allocate a block statistics callback.
117 * @timer_fn: Timer callback function.
118 * @bucket_fn: Bucket callback function.
119 * @buckets: Number of statistics buckets.
120 * @data: Value for the @data field of the &struct blk_stat_callback.
122 * See &struct blk_stat_callback for details on the callback functions.
124 * Return: &struct blk_stat_callback on success or NULL on ENOMEM.
126 struct blk_stat_callback
*
127 blk_stat_alloc_callback(void (*timer_fn
)(struct blk_stat_callback
*),
128 int (*bucket_fn
)(const struct request
*),
129 unsigned int buckets
, void *data
);
132 * blk_stat_add_callback() - Add a block statistics callback to be run on a
134 * @q: The request queue.
137 * Note that a single &struct blk_stat_callback can only be added to a single
138 * &struct request_queue.
140 void blk_stat_add_callback(struct request_queue
*q
,
141 struct blk_stat_callback
*cb
);
144 * blk_stat_remove_callback() - Remove a block statistics callback from a
146 * @q: The request queue.
149 * When this returns, the callback is not running on any CPUs and will not be
150 * called again unless readded.
152 void blk_stat_remove_callback(struct request_queue
*q
,
153 struct blk_stat_callback
*cb
);
156 * blk_stat_free_callback() - Free a block statistics callback.
159 * @cb may be NULL, in which case this does nothing. If it is not NULL, @cb must
160 * not be associated with a request queue. I.e., if it was previously added with
161 * blk_stat_add_callback(), it must also have been removed since then with
162 * blk_stat_remove_callback().
164 void blk_stat_free_callback(struct blk_stat_callback
*cb
);
167 * blk_stat_is_active() - Check if a block statistics callback is currently
168 * gathering statistics.
171 static inline bool blk_stat_is_active(struct blk_stat_callback
*cb
)
173 return timer_pending(&cb
->timer
);
177 * blk_stat_activate_nsecs() - Gather block statistics during a time window in
180 * @nsecs: Number of nanoseconds to gather statistics for.
182 * The timer callback will be called when the window expires.
184 static inline void blk_stat_activate_nsecs(struct blk_stat_callback
*cb
,
187 mod_timer(&cb
->timer
, jiffies
+ nsecs_to_jiffies(nsecs
));
191 * blk_stat_activate_msecs() - Gather block statistics during a time window in
194 * @msecs: Number of milliseconds to gather statistics for.
196 * The timer callback will be called when the window expires.
198 static inline void blk_stat_activate_msecs(struct blk_stat_callback
*cb
,
201 mod_timer(&cb
->timer
, jiffies
+ msecs_to_jiffies(msecs
));