1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
|
#ifndef _BCACHE_SUPER_H
#define _BCACHE_SUPER_H
#include "extents.h"
static inline size_t sector_to_bucket(const struct cache *ca, sector_t s)
{
return s >> ca->bucket_bits;
}
static inline sector_t bucket_to_sector(const struct cache *ca, size_t b)
{
return ((sector_t) b) << ca->bucket_bits;
}
static inline sector_t bucket_remainder(const struct cache *ca, sector_t s)
{
return s & (ca->mi.bucket_size - 1);
}
#define cache_member_info_get(_c) \
(rcu_read_lock(), rcu_dereference((_c)->members))
#define cache_member_info_put() rcu_read_unlock()
static inline struct cache *bch_next_cache_rcu(struct cache_set *c,
unsigned *iter)
{
struct cache *ret = NULL;
while (*iter < c->sb.nr_in_set &&
!(ret = rcu_dereference(c->cache[*iter])))
(*iter)++;
return ret;
}
#define for_each_cache_rcu(ca, c, iter) \
for ((iter) = 0; ((ca) = bch_next_cache_rcu((c), &(iter))); (iter)++)
static inline struct cache *bch_get_next_cache(struct cache_set *c,
unsigned *iter)
{
struct cache *ret;
rcu_read_lock();
if ((ret = bch_next_cache_rcu(c, iter)))
percpu_ref_get(&ret->ref);
rcu_read_unlock();
return ret;
}
/*
* If you break early, you must drop your ref on the current cache
*/
#define for_each_cache(ca, c, iter) \
for ((iter) = 0; \
(ca = bch_get_next_cache(c, &(iter))); \
percpu_ref_put(&ca->ref), (iter)++)
void bch_check_mark_super_slowpath(struct cache_set *,
const struct bkey_i *, bool);
static inline bool bch_check_super_marked(struct cache_set *c,
const struct bkey_i *k, bool meta)
{
struct bkey_s_c_extent e = bkey_i_to_s_c_extent(k);
const struct bch_extent_ptr *ptr;
struct cache_member_cpu *mi = cache_member_info_get(c)->m;
bool ret = true;
extent_for_each_ptr(e, ptr)
if (!(meta
? mi[ptr->dev].has_metadata
: mi[ptr->dev].has_data) &&
bch_extent_ptr_is_dirty(c, e, ptr)) {
ret = false;
break;
}
cache_member_info_put();
return ret;
}
static inline void bch_check_mark_super(struct cache_set *c,
const struct bkey_i *k, bool meta)
{
if (bch_check_super_marked(c, k, meta))
return;
bch_check_mark_super_slowpath(c, k, meta);
}
static inline bool bch_cache_may_remove(struct cache *ca)
{
struct cache_set *c = ca->set;
struct cache_group *tier = &c->cache_tiers[ca->mi.tier];
/*
* Right now, we can't remove the last device from a tier,
* - For tier 0, because all metadata lives in tier 0 and because
* there is no way to have foreground writes go directly to tier 1.
* - For tier 1, because the code doesn't completely support an
* empty tier 1.
*/
/*
* Turning a device read-only removes it from the cache group,
* so there may only be one read-write device in a tier, and yet
* the device we are removing is in the same tier, so we have
* to check for identity.
* Removing the last RW device from a tier requires turning the
* whole cache set RO.
*/
return tier->nr_devices != 1 ||
rcu_access_pointer(tier->d[0].dev) != ca;
}
void free_super(struct bcache_superblock *);
int bch_super_realloc(struct bcache_superblock *, unsigned);
void bcache_write_super(struct cache_set *);
void __write_super(struct cache_set *, struct bcache_superblock *);
void bch_cache_set_release(struct kobject *);
void bch_cache_release(struct kobject *);
void bch_cache_set_unregister(struct cache_set *);
void bch_cache_set_stop(struct cache_set *);
const char *bch_register_one(const char *path);
const char *bch_register_cache_set(char * const *, unsigned,
struct cache_set_opts,
struct cache_set **);
bool bch_cache_set_read_only(struct cache_set *);
bool bch_cache_set_emergency_read_only(struct cache_set *);
void bch_cache_set_read_only_sync(struct cache_set *);
const char *bch_cache_set_read_write(struct cache_set *);
bool bch_cache_read_only(struct cache *);
const char *bch_cache_read_write(struct cache *);
bool bch_cache_remove(struct cache *, bool force);
int bch_cache_set_add_cache(struct cache_set *, const char *);
extern struct mutex bch_register_lock;
extern struct list_head bch_cache_sets;
extern struct idr bch_cache_set_minor;
extern struct workqueue_struct *bcache_io_wq;
extern struct crypto_shash *bch_sha1;
extern struct kobj_type bch_cache_set_ktype;
extern struct kobj_type bch_cache_set_internal_ktype;
extern struct kobj_type bch_cache_set_time_stats_ktype;
extern struct kobj_type bch_cache_set_opts_dir_ktype;
extern struct kobj_type bch_cache_ktype;
#endif /* _BCACHE_SUPER_H */
|
