diff options
| author | Dmitry Torokhov <dmitry.torokhov@gmail.com> | 2008-08-08 16:21:02 -0400 |
|---|---|---|
| committer | Dmitry Torokhov <dmitry.torokhov@gmail.com> | 2008-08-08 16:21:02 -0400 |
| commit | e4ddcb0a6bf04d53ce77b4eb87bbbb32c4261d11 (patch) | |
| tree | d27d2fea50a384d97aa2d0cf5c8657c916f761d4 /include/linux/raid | |
| parent | f2afa7711f8585ffc088ba538b9a510e0d5dca12 (diff) | |
| parent | 6e86841d05f371b5b9b86ce76c02aaee83352298 (diff) | |
Merge commit 'v2.6.27-rc1' into for-linus
Diffstat (limited to 'include/linux/raid')
| -rw-r--r-- | include/linux/raid/bitmap.h | 1 | ||||
| -rw-r--r-- | include/linux/raid/linear.h | 2 | ||||
| -rw-r--r-- | include/linux/raid/md.h | 2 | ||||
| -rw-r--r-- | include/linux/raid/md_k.h | 17 | ||||
| -rw-r--r-- | include/linux/raid/md_p.h | 3 | ||||
| -rw-r--r-- | include/linux/raid/raid5.h | 64 |
6 files changed, 61 insertions, 28 deletions
diff --git a/include/linux/raid/bitmap.h b/include/linux/raid/bitmap.h index 78bfdea24a8e..e98900671ca9 100644 --- a/include/linux/raid/bitmap.h +++ b/include/linux/raid/bitmap.h | |||
| @@ -221,6 +221,7 @@ struct bitmap { | |||
| 221 | unsigned long syncchunk; | 221 | unsigned long syncchunk; |
| 222 | 222 | ||
| 223 | __u64 events_cleared; | 223 | __u64 events_cleared; |
| 224 | int need_sync; | ||
| 224 | 225 | ||
| 225 | /* bitmap spinlock */ | 226 | /* bitmap spinlock */ |
| 226 | spinlock_t lock; | 227 | spinlock_t lock; |
diff --git a/include/linux/raid/linear.h b/include/linux/raid/linear.h index ba15469daf11..7e375111d007 100644 --- a/include/linux/raid/linear.h +++ b/include/linux/raid/linear.h | |||
| @@ -16,7 +16,7 @@ struct linear_private_data | |||
| 16 | struct linear_private_data *prev; /* earlier version */ | 16 | struct linear_private_data *prev; /* earlier version */ |
| 17 | dev_info_t **hash_table; | 17 | dev_info_t **hash_table; |
| 18 | sector_t hash_spacing; | 18 | sector_t hash_spacing; |
| 19 | sector_t array_size; | 19 | sector_t array_sectors; |
| 20 | int preshift; /* shift before dividing by hash_spacing */ | 20 | int preshift; /* shift before dividing by hash_spacing */ |
| 21 | dev_info_t disks[0]; | 21 | dev_info_t disks[0]; |
| 22 | }; | 22 | }; |
diff --git a/include/linux/raid/md.h b/include/linux/raid/md.h index b7386ae9d288..dc0e3fcb9f28 100644 --- a/include/linux/raid/md.h +++ b/include/linux/raid/md.h | |||
| @@ -95,7 +95,7 @@ extern int sync_page_io(struct block_device *bdev, sector_t sector, int size, | |||
| 95 | struct page *page, int rw); | 95 | struct page *page, int rw); |
| 96 | extern void md_do_sync(mddev_t *mddev); | 96 | extern void md_do_sync(mddev_t *mddev); |
| 97 | extern void md_new_event(mddev_t *mddev); | 97 | extern void md_new_event(mddev_t *mddev); |
| 98 | extern void md_allow_write(mddev_t *mddev); | 98 | extern int md_allow_write(mddev_t *mddev); |
| 99 | extern void md_wait_for_blocked_rdev(mdk_rdev_t *rdev, mddev_t *mddev); | 99 | extern void md_wait_for_blocked_rdev(mdk_rdev_t *rdev, mddev_t *mddev); |
| 100 | 100 | ||
| 101 | #endif /* CONFIG_MD */ | 101 | #endif /* CONFIG_MD */ |
diff --git a/include/linux/raid/md_k.h b/include/linux/raid/md_k.h index 3dea9f545c8f..9f2549ac0e2d 100644 --- a/include/linux/raid/md_k.h +++ b/include/linux/raid/md_k.h | |||
| @@ -59,7 +59,7 @@ struct mdk_rdev_s | |||
| 59 | int sb_loaded; | 59 | int sb_loaded; |
| 60 | __u64 sb_events; | 60 | __u64 sb_events; |
| 61 | sector_t data_offset; /* start of data in array */ | 61 | sector_t data_offset; /* start of data in array */ |
| 62 | sector_t sb_offset; | 62 | sector_t sb_start; /* offset of the super block (in 512byte sectors) */ |
| 63 | int sb_size; /* bytes in the superblock */ | 63 | int sb_size; /* bytes in the superblock */ |
| 64 | int preferred_minor; /* autorun support */ | 64 | int preferred_minor; /* autorun support */ |
| 65 | 65 | ||
| @@ -87,6 +87,9 @@ struct mdk_rdev_s | |||
| 87 | #define Blocked 8 /* An error occured on an externally | 87 | #define Blocked 8 /* An error occured on an externally |
| 88 | * managed array, don't allow writes | 88 | * managed array, don't allow writes |
| 89 | * until it is cleared */ | 89 | * until it is cleared */ |
| 90 | #define StateChanged 9 /* Faulty or Blocked has changed during | ||
| 91 | * interrupt, so it needs to be | ||
| 92 | * notified by the thread */ | ||
| 90 | wait_queue_head_t blocked_wait; | 93 | wait_queue_head_t blocked_wait; |
| 91 | 94 | ||
| 92 | int desc_nr; /* descriptor index in the superblock */ | 95 | int desc_nr; /* descriptor index in the superblock */ |
| @@ -147,7 +150,7 @@ struct mddev_s | |||
| 147 | int raid_disks; | 150 | int raid_disks; |
| 148 | int max_disks; | 151 | int max_disks; |
| 149 | sector_t size; /* used size of component devices */ | 152 | sector_t size; /* used size of component devices */ |
| 150 | sector_t array_size; /* exported array size */ | 153 | sector_t array_sectors; /* exported array size */ |
| 151 | __u64 events; | 154 | __u64 events; |
| 152 | 155 | ||
| 153 | char uuid[16]; | 156 | char uuid[16]; |
| @@ -188,6 +191,7 @@ struct mddev_s | |||
| 188 | * NEEDED: we might need to start a resync/recover | 191 | * NEEDED: we might need to start a resync/recover |
| 189 | * RUNNING: a thread is running, or about to be started | 192 | * RUNNING: a thread is running, or about to be started |
| 190 | * SYNC: actually doing a resync, not a recovery | 193 | * SYNC: actually doing a resync, not a recovery |
| 194 | * RECOVER: doing recovery, or need to try it. | ||
| 191 | * INTR: resync needs to be aborted for some reason | 195 | * INTR: resync needs to be aborted for some reason |
| 192 | * DONE: thread is done and is waiting to be reaped | 196 | * DONE: thread is done and is waiting to be reaped |
| 193 | * REQUEST: user-space has requested a sync (used with SYNC) | 197 | * REQUEST: user-space has requested a sync (used with SYNC) |
| @@ -198,6 +202,7 @@ struct mddev_s | |||
| 198 | */ | 202 | */ |
| 199 | #define MD_RECOVERY_RUNNING 0 | 203 | #define MD_RECOVERY_RUNNING 0 |
| 200 | #define MD_RECOVERY_SYNC 1 | 204 | #define MD_RECOVERY_SYNC 1 |
| 205 | #define MD_RECOVERY_RECOVER 2 | ||
| 201 | #define MD_RECOVERY_INTR 3 | 206 | #define MD_RECOVERY_INTR 3 |
| 202 | #define MD_RECOVERY_DONE 4 | 207 | #define MD_RECOVERY_DONE 4 |
| 203 | #define MD_RECOVERY_NEEDED 5 | 208 | #define MD_RECOVERY_NEEDED 5 |
| @@ -210,7 +215,8 @@ struct mddev_s | |||
| 210 | 215 | ||
| 211 | int in_sync; /* know to not need resync */ | 216 | int in_sync; /* know to not need resync */ |
| 212 | struct mutex reconfig_mutex; | 217 | struct mutex reconfig_mutex; |
| 213 | atomic_t active; | 218 | atomic_t active; /* general refcount */ |
| 219 | atomic_t openers; /* number of active opens */ | ||
| 214 | 220 | ||
| 215 | int changed; /* true if we might need to reread partition info */ | 221 | int changed; /* true if we might need to reread partition info */ |
| 216 | int degraded; /* whether md should consider | 222 | int degraded; /* whether md should consider |
| @@ -227,6 +233,8 @@ struct mddev_s | |||
| 227 | atomic_t recovery_active; /* blocks scheduled, but not written */ | 233 | atomic_t recovery_active; /* blocks scheduled, but not written */ |
| 228 | wait_queue_head_t recovery_wait; | 234 | wait_queue_head_t recovery_wait; |
| 229 | sector_t recovery_cp; | 235 | sector_t recovery_cp; |
| 236 | sector_t resync_min; /* user requested sync | ||
| 237 | * starts here */ | ||
| 230 | sector_t resync_max; /* resync should pause | 238 | sector_t resync_max; /* resync should pause |
| 231 | * when it gets here */ | 239 | * when it gets here */ |
| 232 | 240 | ||
| @@ -331,6 +339,9 @@ static inline char * mdname (mddev_t * mddev) | |||
| 331 | #define rdev_for_each(rdev, tmp, mddev) \ | 339 | #define rdev_for_each(rdev, tmp, mddev) \ |
| 332 | rdev_for_each_list(rdev, tmp, (mddev)->disks) | 340 | rdev_for_each_list(rdev, tmp, (mddev)->disks) |
| 333 | 341 | ||
| 342 | #define rdev_for_each_rcu(rdev, mddev) \ | ||
| 343 | list_for_each_entry_rcu(rdev, &((mddev)->disks), same_set) | ||
| 344 | |||
| 334 | typedef struct mdk_thread_s { | 345 | typedef struct mdk_thread_s { |
| 335 | void (*run) (mddev_t *mddev); | 346 | void (*run) (mddev_t *mddev); |
| 336 | mddev_t *mddev; | 347 | mddev_t *mddev; |
diff --git a/include/linux/raid/md_p.h b/include/linux/raid/md_p.h index 3f2cd98c508b..8b4de4a41ff1 100644 --- a/include/linux/raid/md_p.h +++ b/include/linux/raid/md_p.h | |||
| @@ -43,14 +43,11 @@ | |||
| 43 | */ | 43 | */ |
| 44 | #define MD_RESERVED_BYTES (64 * 1024) | 44 | #define MD_RESERVED_BYTES (64 * 1024) |
| 45 | #define MD_RESERVED_SECTORS (MD_RESERVED_BYTES / 512) | 45 | #define MD_RESERVED_SECTORS (MD_RESERVED_BYTES / 512) |
| 46 | #define MD_RESERVED_BLOCKS (MD_RESERVED_BYTES / BLOCK_SIZE) | ||
| 47 | 46 | ||
| 48 | #define MD_NEW_SIZE_SECTORS(x) ((x & ~(MD_RESERVED_SECTORS - 1)) - MD_RESERVED_SECTORS) | 47 | #define MD_NEW_SIZE_SECTORS(x) ((x & ~(MD_RESERVED_SECTORS - 1)) - MD_RESERVED_SECTORS) |
| 49 | #define MD_NEW_SIZE_BLOCKS(x) ((x & ~(MD_RESERVED_BLOCKS - 1)) - MD_RESERVED_BLOCKS) | ||
| 50 | 48 | ||
| 51 | #define MD_SB_BYTES 4096 | 49 | #define MD_SB_BYTES 4096 |
| 52 | #define MD_SB_WORDS (MD_SB_BYTES / 4) | 50 | #define MD_SB_WORDS (MD_SB_BYTES / 4) |
| 53 | #define MD_SB_BLOCKS (MD_SB_BYTES / BLOCK_SIZE) | ||
| 54 | #define MD_SB_SECTORS (MD_SB_BYTES / 512) | 51 | #define MD_SB_SECTORS (MD_SB_BYTES / 512) |
| 55 | 52 | ||
| 56 | /* | 53 | /* |
diff --git a/include/linux/raid/raid5.h b/include/linux/raid/raid5.h index f0827d31ae6f..3b2672792457 100644 --- a/include/linux/raid/raid5.h +++ b/include/linux/raid/raid5.h | |||
| @@ -158,6 +158,43 @@ | |||
| 158 | * the compute block completes. | 158 | * the compute block completes. |
| 159 | */ | 159 | */ |
| 160 | 160 | ||
| 161 | /* | ||
| 162 | * Operations state - intermediate states that are visible outside of sh->lock | ||
| 163 | * In general _idle indicates nothing is running, _run indicates a data | ||
| 164 | * processing operation is active, and _result means the data processing result | ||
| 165 | * is stable and can be acted upon. For simple operations like biofill and | ||
| 166 | * compute that only have an _idle and _run state they are indicated with | ||
| 167 | * sh->state flags (STRIPE_BIOFILL_RUN and STRIPE_COMPUTE_RUN) | ||
| 168 | */ | ||
| 169 | /** | ||
| 170 | * enum check_states - handles syncing / repairing a stripe | ||
| 171 | * @check_state_idle - check operations are quiesced | ||
| 172 | * @check_state_run - check operation is running | ||
| 173 | * @check_state_result - set outside lock when check result is valid | ||
| 174 | * @check_state_compute_run - check failed and we are repairing | ||
| 175 | * @check_state_compute_result - set outside lock when compute result is valid | ||
| 176 | */ | ||
| 177 | enum check_states { | ||
| 178 | check_state_idle = 0, | ||
| 179 | check_state_run, /* parity check */ | ||
| 180 | check_state_check_result, | ||
| 181 | check_state_compute_run, /* parity repair */ | ||
| 182 | check_state_compute_result, | ||
| 183 | }; | ||
| 184 | |||
| 185 | /** | ||
| 186 | * enum reconstruct_states - handles writing or expanding a stripe | ||
| 187 | */ | ||
| 188 | enum reconstruct_states { | ||
| 189 | reconstruct_state_idle = 0, | ||
| 190 | reconstruct_state_prexor_drain_run, /* prexor-write */ | ||
| 191 | reconstruct_state_drain_run, /* write */ | ||
| 192 | reconstruct_state_run, /* expand */ | ||
| 193 | reconstruct_state_prexor_drain_result, | ||
| 194 | reconstruct_state_drain_result, | ||
| 195 | reconstruct_state_result, | ||
| 196 | }; | ||
| 197 | |||
| 161 | struct stripe_head { | 198 | struct stripe_head { |
| 162 | struct hlist_node hash; | 199 | struct hlist_node hash; |
| 163 | struct list_head lru; /* inactive_list or handle_list */ | 200 | struct list_head lru; /* inactive_list or handle_list */ |
| @@ -169,19 +206,13 @@ struct stripe_head { | |||
| 169 | spinlock_t lock; | 206 | spinlock_t lock; |
| 170 | int bm_seq; /* sequence number for bitmap flushes */ | 207 | int bm_seq; /* sequence number for bitmap flushes */ |
| 171 | int disks; /* disks in stripe */ | 208 | int disks; /* disks in stripe */ |
| 209 | enum check_states check_state; | ||
| 210 | enum reconstruct_states reconstruct_state; | ||
| 172 | /* stripe_operations | 211 | /* stripe_operations |
| 173 | * @pending - pending ops flags (set for request->issue->complete) | ||
| 174 | * @ack - submitted ops flags (set for issue->complete) | ||
| 175 | * @complete - completed ops flags (set for complete) | ||
| 176 | * @target - STRIPE_OP_COMPUTE_BLK target | 212 | * @target - STRIPE_OP_COMPUTE_BLK target |
| 177 | * @count - raid5_runs_ops is set to run when this is non-zero | ||
| 178 | */ | 213 | */ |
| 179 | struct stripe_operations { | 214 | struct stripe_operations { |
| 180 | unsigned long pending; | ||
| 181 | unsigned long ack; | ||
| 182 | unsigned long complete; | ||
| 183 | int target; | 215 | int target; |
| 184 | int count; | ||
| 185 | u32 zero_sum_result; | 216 | u32 zero_sum_result; |
| 186 | } ops; | 217 | } ops; |
| 187 | struct r5dev { | 218 | struct r5dev { |
| @@ -202,6 +233,7 @@ struct stripe_head_state { | |||
| 202 | int locked, uptodate, to_read, to_write, failed, written; | 233 | int locked, uptodate, to_read, to_write, failed, written; |
| 203 | int to_fill, compute, req_compute, non_overwrite; | 234 | int to_fill, compute, req_compute, non_overwrite; |
| 204 | int failed_num; | 235 | int failed_num; |
| 236 | unsigned long ops_request; | ||
| 205 | }; | 237 | }; |
| 206 | 238 | ||
| 207 | /* r6_state - extra state data only relevant to r6 */ | 239 | /* r6_state - extra state data only relevant to r6 */ |
| @@ -228,9 +260,7 @@ struct r6_state { | |||
| 228 | #define R5_Wantfill 12 /* dev->toread contains a bio that needs | 260 | #define R5_Wantfill 12 /* dev->toread contains a bio that needs |
| 229 | * filling | 261 | * filling |
| 230 | */ | 262 | */ |
| 231 | #define R5_Wantprexor 13 /* distinguish blocks ready for rmw from | 263 | #define R5_Wantdrain 13 /* dev->towrite needs to be drained */ |
| 232 | * other "towrites" | ||
| 233 | */ | ||
| 234 | /* | 264 | /* |
| 235 | * Write method | 265 | * Write method |
| 236 | */ | 266 | */ |
| @@ -254,8 +284,10 @@ struct r6_state { | |||
| 254 | #define STRIPE_EXPAND_READY 11 | 284 | #define STRIPE_EXPAND_READY 11 |
| 255 | #define STRIPE_IO_STARTED 12 /* do not count towards 'bypass_count' */ | 285 | #define STRIPE_IO_STARTED 12 /* do not count towards 'bypass_count' */ |
| 256 | #define STRIPE_FULL_WRITE 13 /* all blocks are set to be overwritten */ | 286 | #define STRIPE_FULL_WRITE 13 /* all blocks are set to be overwritten */ |
| 287 | #define STRIPE_BIOFILL_RUN 14 | ||
| 288 | #define STRIPE_COMPUTE_RUN 15 | ||
| 257 | /* | 289 | /* |
| 258 | * Operations flags (in issue order) | 290 | * Operation request flags |
| 259 | */ | 291 | */ |
| 260 | #define STRIPE_OP_BIOFILL 0 | 292 | #define STRIPE_OP_BIOFILL 0 |
| 261 | #define STRIPE_OP_COMPUTE_BLK 1 | 293 | #define STRIPE_OP_COMPUTE_BLK 1 |
| @@ -263,14 +295,6 @@ struct r6_state { | |||
| 263 | #define STRIPE_OP_BIODRAIN 3 | 295 | #define STRIPE_OP_BIODRAIN 3 |
| 264 | #define STRIPE_OP_POSTXOR 4 | 296 | #define STRIPE_OP_POSTXOR 4 |
| 265 | #define STRIPE_OP_CHECK 5 | 297 | #define STRIPE_OP_CHECK 5 |
| 266 | #define STRIPE_OP_IO 6 | ||
| 267 | |||
| 268 | /* modifiers to the base operations | ||
| 269 | * STRIPE_OP_MOD_REPAIR_PD - compute the parity block and write it back | ||
| 270 | * STRIPE_OP_MOD_DMA_CHECK - parity is not corrupted by the check | ||
| 271 | */ | ||
| 272 | #define STRIPE_OP_MOD_REPAIR_PD 7 | ||
| 273 | #define STRIPE_OP_MOD_DMA_CHECK 8 | ||
| 274 | 298 | ||
| 275 | /* | 299 | /* |
| 276 | * Plugging: | 300 | * Plugging: |
