xref: /OK3568_Linux_fs/kernel/include/linux/percpu_counter.h (revision 4882a59341e53eb6f0b4789bf948001014eff981)
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