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
|
/* SPDX-License-Identifier: GPL-2.0-or-later */
#ifndef _DM_PCACHE_H
#define _DM_PCACHE_H
#include <linux/device-mapper.h>
#include "../dm-core.h"
#define CACHE_DEV_TO_PCACHE(cache_dev) (container_of(cache_dev, struct dm_pcache, cache_dev))
#define BACKING_DEV_TO_PCACHE(backing_dev) (container_of(backing_dev, struct dm_pcache, backing_dev))
#define CACHE_TO_PCACHE(cache) (container_of(cache, struct dm_pcache, cache))
#define PCACHE_STATE_RUNNING 1
#define PCACHE_STATE_STOPPING 2
struct pcache_cache_dev;
struct pcache_backing_dev;
struct pcache_cache;
struct pcache_cache_options;
struct dm_pcache {
struct dm_target *ti;
struct pcache_cache_dev cache_dev;
struct pcache_backing_dev backing_dev;
struct pcache_cache cache;
struct pcache_cache_options opts;
spinlock_t defered_req_list_lock;
struct list_head defered_req_list;
struct workqueue_struct *task_wq;
struct work_struct defered_req_work;
atomic_t state;
atomic_t inflight_reqs;
wait_queue_head_t inflight_wq;
};
static inline bool pcache_is_stopping(struct dm_pcache *pcache)
{
return (atomic_read(&pcache->state) == PCACHE_STATE_STOPPING);
}
#define pcache_dev_err(pcache, fmt, ...) \
pcache_err("%s " fmt, pcache->ti->table->md->name, ##__VA_ARGS__)
#define pcache_dev_info(pcache, fmt, ...) \
pcache_info("%s " fmt, pcache->ti->table->md->name, ##__VA_ARGS__)
#define pcache_dev_debug(pcache, fmt, ...) \
pcache_debug("%s " fmt, pcache->ti->table->md->name, ##__VA_ARGS__)
struct pcache_request {
struct dm_pcache *pcache;
struct bio *bio;
u64 off;
u32 data_len;
struct kref ref;
int ret;
struct list_head list_node;
};
void pcache_req_get(struct pcache_request *pcache_req);
void pcache_req_put(struct pcache_request *pcache_req, int ret);
void pcache_defer_reqs_kick(struct dm_pcache *pcache);
#endif /* _DM_PCACHE_H */
|
