blob: dd5ad01ae269d56e5f8853601c603f5853bcb8b4 (
plain)
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
|
#ifndef _RAID5_H
#define _RAID5_H
#include <linux/raid/md.h>
#include <linux/raid/xor.h>
struct disk_info {
kdev_t dev;
int operational;
int number;
int raid_disk;
int write_only;
int spare;
int used_slot;
};
struct stripe_head {
md_spinlock_t stripe_lock;
struct stripe_head *hash_next, **hash_pprev; /* hash pointers */
struct stripe_head *free_next; /* pool of free sh's */
struct buffer_head *buffer_pool; /* pool of free buffers */
struct buffer_head *bh_pool; /* pool of free bh's */
struct raid5_private_data *raid_conf;
struct buffer_head *bh_old[MD_SB_DISKS]; /* disk image */
struct buffer_head *bh_new[MD_SB_DISKS]; /* buffers of the MD device (present in buffer cache) */
struct buffer_head *bh_copy[MD_SB_DISKS]; /* copy on write of bh_new (bh_new can change from under us) */
struct buffer_head *bh_req[MD_SB_DISKS]; /* copy of bh_new (only the buffer heads), queued to the lower levels */
int cmd_new[MD_SB_DISKS]; /* READ/WRITE for new */
int new[MD_SB_DISKS]; /* buffer added since the last handle_stripe() */
unsigned long sector; /* sector of this row */
int size; /* buffers size */
int pd_idx; /* parity disk index */
atomic_t nr_pending; /* nr of pending cmds */
unsigned long state; /* state flags */
int cmd; /* stripe cmd */
atomic_t count; /* nr of waiters */
int write_method; /* reconstruct-write / read-modify-write */
int phase; /* PHASE_BEGIN, ..., PHASE_COMPLETE */
md_wait_queue_head_t wait; /* processes waiting for this stripe */
int sync_redone;
};
/*
* Phase
*/
#define PHASE_BEGIN 0
#define PHASE_READ_OLD 1
#define PHASE_WRITE 2
#define PHASE_READ 3
#define PHASE_COMPLETE 4
/*
* Write method
*/
#define METHOD_NONE 0
#define RECONSTRUCT_WRITE 1
#define READ_MODIFY_WRITE 2
/*
* Stripe state
*/
#define STRIPE_LOCKED 0
#define STRIPE_ERROR 1
/*
* Stripe commands
*/
#define STRIPE_NONE 0
#define STRIPE_WRITE 1
#define STRIPE_READ 2
#define STRIPE_SYNC 3
struct raid5_private_data {
struct stripe_head **stripe_hashtbl;
mddev_t *mddev;
mdk_thread_t *thread, *resync_thread;
struct disk_info disks[MD_SB_DISKS];
struct disk_info *spare;
int buffer_size;
int chunk_size, level, algorithm;
int raid_disks, working_disks, failed_disks;
unsigned long next_sector;
atomic_t nr_handle;
struct stripe_head *next_free_stripe;
atomic_t nr_stripes;
int resync_parity;
int max_nr_stripes;
int clock;
atomic_t nr_hashed_stripes;
atomic_t nr_locked_stripes;
atomic_t nr_pending_stripes;
atomic_t nr_cached_stripes;
/*
* Free stripes pool
*/
atomic_t nr_free_sh;
struct stripe_head *free_sh_list;
md_wait_queue_head_t wait_for_stripe;
md_spinlock_t device_lock;
};
typedef struct raid5_private_data raid5_conf_t;
#define mddev_to_conf(mddev) ((raid5_conf_t *) mddev->private)
/*
* Our supported algorithms
*/
#define ALGORITHM_LEFT_ASYMMETRIC 0
#define ALGORITHM_RIGHT_ASYMMETRIC 1
#define ALGORITHM_LEFT_SYMMETRIC 2
#define ALGORITHM_RIGHT_SYMMETRIC 3
#endif
|
