1*4882a593Smuzhiyun /* SPDX-License-Identifier: GPL-2.0 */
2*4882a593Smuzhiyun #ifndef _LINUX_PERCPU_COUNTER_H
3*4882a593Smuzhiyun #define _LINUX_PERCPU_COUNTER_H
4*4882a593Smuzhiyun /*
5*4882a593Smuzhiyun * A simple "approximate counter" for use in ext2 and ext3 superblocks.
6*4882a593Smuzhiyun *
7*4882a593Smuzhiyun * WARNING: these things are HUGE. 4 kbytes per counter on 32-way P4.
8*4882a593Smuzhiyun */
9*4882a593Smuzhiyun
10*4882a593Smuzhiyun #include <linux/spinlock.h>
11*4882a593Smuzhiyun #include <linux/smp.h>
12*4882a593Smuzhiyun #include <linux/list.h>
13*4882a593Smuzhiyun #include <linux/threads.h>
14*4882a593Smuzhiyun #include <linux/percpu.h>
15*4882a593Smuzhiyun #include <linux/types.h>
16*4882a593Smuzhiyun #include <linux/gfp.h>
17*4882a593Smuzhiyun
18*4882a593Smuzhiyun #ifdef CONFIG_SMP
19*4882a593Smuzhiyun
20*4882a593Smuzhiyun struct percpu_counter {
21*4882a593Smuzhiyun raw_spinlock_t lock;
22*4882a593Smuzhiyun s64 count;
23*4882a593Smuzhiyun #ifdef CONFIG_HOTPLUG_CPU
24*4882a593Smuzhiyun struct list_head list; /* All percpu_counters are on a list */
25*4882a593Smuzhiyun #endif
26*4882a593Smuzhiyun s32 __percpu *counters;
27*4882a593Smuzhiyun };
28*4882a593Smuzhiyun
29*4882a593Smuzhiyun extern int percpu_counter_batch;
30*4882a593Smuzhiyun
31*4882a593Smuzhiyun int __percpu_counter_init(struct percpu_counter *fbc, s64 amount, gfp_t gfp,
32*4882a593Smuzhiyun struct lock_class_key *key);
33*4882a593Smuzhiyun
34*4882a593Smuzhiyun #define percpu_counter_init(fbc, value, gfp) \
35*4882a593Smuzhiyun ({ \
36*4882a593Smuzhiyun static struct lock_class_key __key; \
37*4882a593Smuzhiyun \
38*4882a593Smuzhiyun __percpu_counter_init(fbc, value, gfp, &__key); \
39*4882a593Smuzhiyun })
40*4882a593Smuzhiyun
41*4882a593Smuzhiyun void percpu_counter_destroy(struct percpu_counter *fbc);
42*4882a593Smuzhiyun void percpu_counter_set(struct percpu_counter *fbc, s64 amount);
43*4882a593Smuzhiyun void percpu_counter_add_batch(struct percpu_counter *fbc, s64 amount,
44*4882a593Smuzhiyun s32 batch);
45*4882a593Smuzhiyun s64 __percpu_counter_sum(struct percpu_counter *fbc);
46*4882a593Smuzhiyun int __percpu_counter_compare(struct percpu_counter *fbc, s64 rhs, s32 batch);
47*4882a593Smuzhiyun void percpu_counter_sync(struct percpu_counter *fbc);
48*4882a593Smuzhiyun
percpu_counter_compare(struct percpu_counter * fbc,s64 rhs)49*4882a593Smuzhiyun static inline int percpu_counter_compare(struct percpu_counter *fbc, s64 rhs)
50*4882a593Smuzhiyun {
51*4882a593Smuzhiyun return __percpu_counter_compare(fbc, rhs, percpu_counter_batch);
52*4882a593Smuzhiyun }
53*4882a593Smuzhiyun
percpu_counter_add(struct percpu_counter * fbc,s64 amount)54*4882a593Smuzhiyun static inline void percpu_counter_add(struct percpu_counter *fbc, s64 amount)
55*4882a593Smuzhiyun {
56*4882a593Smuzhiyun percpu_counter_add_batch(fbc, amount, percpu_counter_batch);
57*4882a593Smuzhiyun }
58*4882a593Smuzhiyun
percpu_counter_sum_positive(struct percpu_counter * fbc)59*4882a593Smuzhiyun static inline s64 percpu_counter_sum_positive(struct percpu_counter *fbc)
60*4882a593Smuzhiyun {
61*4882a593Smuzhiyun s64 ret = __percpu_counter_sum(fbc);
62*4882a593Smuzhiyun return ret < 0 ? 0 : ret;
63*4882a593Smuzhiyun }
64*4882a593Smuzhiyun
percpu_counter_sum(struct percpu_counter * fbc)65*4882a593Smuzhiyun static inline s64 percpu_counter_sum(struct percpu_counter *fbc)
66*4882a593Smuzhiyun {
67*4882a593Smuzhiyun return __percpu_counter_sum(fbc);
68*4882a593Smuzhiyun }
69*4882a593Smuzhiyun
percpu_counter_read(struct percpu_counter * fbc)70*4882a593Smuzhiyun static inline s64 percpu_counter_read(struct percpu_counter *fbc)
71*4882a593Smuzhiyun {
72*4882a593Smuzhiyun return fbc->count;
73*4882a593Smuzhiyun }
74*4882a593Smuzhiyun
75*4882a593Smuzhiyun /*
76*4882a593Smuzhiyun * It is possible for the percpu_counter_read() to return a small negative
77*4882a593Smuzhiyun * number for some counter which should never be negative.
78*4882a593Smuzhiyun *
79*4882a593Smuzhiyun */
percpu_counter_read_positive(struct percpu_counter * fbc)80*4882a593Smuzhiyun static inline s64 percpu_counter_read_positive(struct percpu_counter *fbc)
81*4882a593Smuzhiyun {
82*4882a593Smuzhiyun /* Prevent reloads of fbc->count */
83*4882a593Smuzhiyun s64 ret = READ_ONCE(fbc->count);
84*4882a593Smuzhiyun
85*4882a593Smuzhiyun if (ret >= 0)
86*4882a593Smuzhiyun return ret;
87*4882a593Smuzhiyun return 0;
88*4882a593Smuzhiyun }
89*4882a593Smuzhiyun
percpu_counter_initialized(struct percpu_counter * fbc)90*4882a593Smuzhiyun static inline bool percpu_counter_initialized(struct percpu_counter *fbc)
91*4882a593Smuzhiyun {
92*4882a593Smuzhiyun return (fbc->counters != NULL);
93*4882a593Smuzhiyun }
94*4882a593Smuzhiyun
95*4882a593Smuzhiyun #else /* !CONFIG_SMP */
96*4882a593Smuzhiyun
97*4882a593Smuzhiyun struct percpu_counter {
98*4882a593Smuzhiyun s64 count;
99*4882a593Smuzhiyun };
100*4882a593Smuzhiyun
percpu_counter_init(struct percpu_counter * fbc,s64 amount,gfp_t gfp)101*4882a593Smuzhiyun static inline int percpu_counter_init(struct percpu_counter *fbc, s64 amount,
102*4882a593Smuzhiyun gfp_t gfp)
103*4882a593Smuzhiyun {
104*4882a593Smuzhiyun fbc->count = amount;
105*4882a593Smuzhiyun return 0;
106*4882a593Smuzhiyun }
107*4882a593Smuzhiyun
percpu_counter_destroy(struct percpu_counter * fbc)108*4882a593Smuzhiyun static inline void percpu_counter_destroy(struct percpu_counter *fbc)
109*4882a593Smuzhiyun {
110*4882a593Smuzhiyun }
111*4882a593Smuzhiyun
percpu_counter_set(struct percpu_counter * fbc,s64 amount)112*4882a593Smuzhiyun static inline void percpu_counter_set(struct percpu_counter *fbc, s64 amount)
113*4882a593Smuzhiyun {
114*4882a593Smuzhiyun fbc->count = amount;
115*4882a593Smuzhiyun }
116*4882a593Smuzhiyun
percpu_counter_compare(struct percpu_counter * fbc,s64 rhs)117*4882a593Smuzhiyun static inline int percpu_counter_compare(struct percpu_counter *fbc, s64 rhs)
118*4882a593Smuzhiyun {
119*4882a593Smuzhiyun if (fbc->count > rhs)
120*4882a593Smuzhiyun return 1;
121*4882a593Smuzhiyun else if (fbc->count < rhs)
122*4882a593Smuzhiyun return -1;
123*4882a593Smuzhiyun else
124*4882a593Smuzhiyun return 0;
125*4882a593Smuzhiyun }
126*4882a593Smuzhiyun
127*4882a593Smuzhiyun static inline int
__percpu_counter_compare(struct percpu_counter * fbc,s64 rhs,s32 batch)128*4882a593Smuzhiyun __percpu_counter_compare(struct percpu_counter *fbc, s64 rhs, s32 batch)
129*4882a593Smuzhiyun {
130*4882a593Smuzhiyun return percpu_counter_compare(fbc, rhs);
131*4882a593Smuzhiyun }
132*4882a593Smuzhiyun
133*4882a593Smuzhiyun static inline void
percpu_counter_add(struct percpu_counter * fbc,s64 amount)134*4882a593Smuzhiyun percpu_counter_add(struct percpu_counter *fbc, s64 amount)
135*4882a593Smuzhiyun {
136*4882a593Smuzhiyun preempt_disable();
137*4882a593Smuzhiyun fbc->count += amount;
138*4882a593Smuzhiyun preempt_enable();
139*4882a593Smuzhiyun }
140*4882a593Smuzhiyun
141*4882a593Smuzhiyun static inline void
percpu_counter_add_batch(struct percpu_counter * fbc,s64 amount,s32 batch)142*4882a593Smuzhiyun percpu_counter_add_batch(struct percpu_counter *fbc, s64 amount, s32 batch)
143*4882a593Smuzhiyun {
144*4882a593Smuzhiyun percpu_counter_add(fbc, amount);
145*4882a593Smuzhiyun }
146*4882a593Smuzhiyun
percpu_counter_read(struct percpu_counter * fbc)147*4882a593Smuzhiyun static inline s64 percpu_counter_read(struct percpu_counter *fbc)
148*4882a593Smuzhiyun {
149*4882a593Smuzhiyun return fbc->count;
150*4882a593Smuzhiyun }
151*4882a593Smuzhiyun
152*4882a593Smuzhiyun /*
153*4882a593Smuzhiyun * percpu_counter is intended to track positive numbers. In the UP case the
154*4882a593Smuzhiyun * number should never be negative.
155*4882a593Smuzhiyun */
percpu_counter_read_positive(struct percpu_counter * fbc)156*4882a593Smuzhiyun static inline s64 percpu_counter_read_positive(struct percpu_counter *fbc)
157*4882a593Smuzhiyun {
158*4882a593Smuzhiyun return fbc->count;
159*4882a593Smuzhiyun }
160*4882a593Smuzhiyun
percpu_counter_sum_positive(struct percpu_counter * fbc)161*4882a593Smuzhiyun static inline s64 percpu_counter_sum_positive(struct percpu_counter *fbc)
162*4882a593Smuzhiyun {
163*4882a593Smuzhiyun return percpu_counter_read_positive(fbc);
164*4882a593Smuzhiyun }
165*4882a593Smuzhiyun
percpu_counter_sum(struct percpu_counter * fbc)166*4882a593Smuzhiyun static inline s64 percpu_counter_sum(struct percpu_counter *fbc)
167*4882a593Smuzhiyun {
168*4882a593Smuzhiyun return percpu_counter_read(fbc);
169*4882a593Smuzhiyun }
170*4882a593Smuzhiyun
percpu_counter_initialized(struct percpu_counter * fbc)171*4882a593Smuzhiyun static inline bool percpu_counter_initialized(struct percpu_counter *fbc)
172*4882a593Smuzhiyun {
173*4882a593Smuzhiyun return true;
174*4882a593Smuzhiyun }
175*4882a593Smuzhiyun
percpu_counter_sync(struct percpu_counter * fbc)176*4882a593Smuzhiyun static inline void percpu_counter_sync(struct percpu_counter *fbc)
177*4882a593Smuzhiyun {
178*4882a593Smuzhiyun }
179*4882a593Smuzhiyun #endif /* CONFIG_SMP */
180*4882a593Smuzhiyun
percpu_counter_inc(struct percpu_counter * fbc)181*4882a593Smuzhiyun static inline void percpu_counter_inc(struct percpu_counter *fbc)
182*4882a593Smuzhiyun {
183*4882a593Smuzhiyun percpu_counter_add(fbc, 1);
184*4882a593Smuzhiyun }
185*4882a593Smuzhiyun
percpu_counter_dec(struct percpu_counter * fbc)186*4882a593Smuzhiyun static inline void percpu_counter_dec(struct percpu_counter *fbc)
187*4882a593Smuzhiyun {
188*4882a593Smuzhiyun percpu_counter_add(fbc, -1);
189*4882a593Smuzhiyun }
190*4882a593Smuzhiyun
percpu_counter_sub(struct percpu_counter * fbc,s64 amount)191*4882a593Smuzhiyun static inline void percpu_counter_sub(struct percpu_counter *fbc, s64 amount)
192*4882a593Smuzhiyun {
193*4882a593Smuzhiyun percpu_counter_add(fbc, -amount);
194*4882a593Smuzhiyun }
195*4882a593Smuzhiyun
196*4882a593Smuzhiyun #endif /* _LINUX_PERCPU_COUNTER_H */
197