raid5.h
上传用户:szlgq88
上传日期:2009-04-28
资源大小:48287k
文件大小:10k
源码类别:

嵌入式Linux

开发平台:

Unix_Linux

  1. #ifndef _RAID5_H
  2. #define _RAID5_H
  3. #include <linux/raid/md.h>
  4. #include <linux/raid/xor.h>
  5. /*
  6.  *
  7.  * Each stripe contains one buffer per disc.  Each buffer can be in
  8.  * one of a number of states stored in "flags".  Changes between
  9.  * these states happen *almost* exclusively under a per-stripe
  10.  * spinlock.  Some very specific changes can happen in bi_end_io, and
  11.  * these are not protected by the spin lock.
  12.  *
  13.  * The flag bits that are used to represent these states are:
  14.  *   R5_UPTODATE and R5_LOCKED
  15.  *
  16.  * State Empty == !UPTODATE, !LOCK
  17.  *        We have no data, and there is no active request
  18.  * State Want == !UPTODATE, LOCK
  19.  *        A read request is being submitted for this block
  20.  * State Dirty == UPTODATE, LOCK
  21.  *        Some new data is in this buffer, and it is being written out
  22.  * State Clean == UPTODATE, !LOCK
  23.  *        We have valid data which is the same as on disc
  24.  *
  25.  * The possible state transitions are:
  26.  *
  27.  *  Empty -> Want   - on read or write to get old data for  parity calc
  28.  *  Empty -> Dirty  - on compute_parity to satisfy write/sync request.(RECONSTRUCT_WRITE)
  29.  *  Empty -> Clean  - on compute_block when computing a block for failed drive
  30.  *  Want  -> Empty  - on failed read
  31.  *  Want  -> Clean  - on successful completion of read request
  32.  *  Dirty -> Clean  - on successful completion of write request
  33.  *  Dirty -> Clean  - on failed write
  34.  *  Clean -> Dirty  - on compute_parity to satisfy write/sync (RECONSTRUCT or RMW)
  35.  *
  36.  * The Want->Empty, Want->Clean, Dirty->Clean, transitions
  37.  * all happen in b_end_io at interrupt time.
  38.  * Each sets the Uptodate bit before releasing the Lock bit.
  39.  * This leaves one multi-stage transition:
  40.  *    Want->Dirty->Clean
  41.  * This is safe because thinking that a Clean buffer is actually dirty
  42.  * will at worst delay some action, and the stripe will be scheduled
  43.  * for attention after the transition is complete.
  44.  *
  45.  * There is one possibility that is not covered by these states.  That
  46.  * is if one drive has failed and there is a spare being rebuilt.  We
  47.  * can't distinguish between a clean block that has been generated
  48.  * from parity calculations, and a clean block that has been
  49.  * successfully written to the spare ( or to parity when resyncing).
  50.  * To distingush these states we have a stripe bit STRIPE_INSYNC that
  51.  * is set whenever a write is scheduled to the spare, or to the parity
  52.  * disc if there is no spare.  A sync request clears this bit, and
  53.  * when we find it set with no buffers locked, we know the sync is
  54.  * complete.
  55.  *
  56.  * Buffers for the md device that arrive via make_request are attached
  57.  * to the appropriate stripe in one of two lists linked on b_reqnext.
  58.  * One list (bh_read) for read requests, one (bh_write) for write.
  59.  * There should never be more than one buffer on the two lists
  60.  * together, but we are not guaranteed of that so we allow for more.
  61.  *
  62.  * If a buffer is on the read list when the associated cache buffer is
  63.  * Uptodate, the data is copied into the read buffer and it's b_end_io
  64.  * routine is called.  This may happen in the end_request routine only
  65.  * if the buffer has just successfully been read.  end_request should
  66.  * remove the buffers from the list and then set the Uptodate bit on
  67.  * the buffer.  Other threads may do this only if they first check
  68.  * that the Uptodate bit is set.  Once they have checked that they may
  69.  * take buffers off the read queue.
  70.  *
  71.  * When a buffer on the write list is committed for write it is copied
  72.  * into the cache buffer, which is then marked dirty, and moved onto a
  73.  * third list, the written list (bh_written).  Once both the parity
  74.  * block and the cached buffer are successfully written, any buffer on
  75.  * a written list can be returned with b_end_io.
  76.  *
  77.  * The write list and read list both act as fifos.  The read list is
  78.  * protected by the device_lock.  The write and written lists are
  79.  * protected by the stripe lock.  The device_lock, which can be
  80.  * claimed while the stipe lock is held, is only for list
  81.  * manipulations and will only be held for a very short time.  It can
  82.  * be claimed from interrupts.
  83.  *
  84.  *
  85.  * Stripes in the stripe cache can be on one of two lists (or on
  86.  * neither).  The "inactive_list" contains stripes which are not
  87.  * currently being used for any request.  They can freely be reused
  88.  * for another stripe.  The "handle_list" contains stripes that need
  89.  * to be handled in some way.  Both of these are fifo queues.  Each
  90.  * stripe is also (potentially) linked to a hash bucket in the hash
  91.  * table so that it can be found by sector number.  Stripes that are
  92.  * not hashed must be on the inactive_list, and will normally be at
  93.  * the front.  All stripes start life this way.
  94.  *
  95.  * The inactive_list, handle_list and hash bucket lists are all protected by the
  96.  * device_lock.
  97.  *  - stripes on the inactive_list never have their stripe_lock held.
  98.  *  - stripes have a reference counter. If count==0, they are on a list.
  99.  *  - If a stripe might need handling, STRIPE_HANDLE is set.
  100.  *  - When refcount reaches zero, then if STRIPE_HANDLE it is put on
  101.  *    handle_list else inactive_list
  102.  *
  103.  * This, combined with the fact that STRIPE_HANDLE is only ever
  104.  * cleared while a stripe has a non-zero count means that if the
  105.  * refcount is 0 and STRIPE_HANDLE is set, then it is on the
  106.  * handle_list and if recount is 0 and STRIPE_HANDLE is not set, then
  107.  * the stripe is on inactive_list.
  108.  *
  109.  * The possible transitions are:
  110.  *  activate an unhashed/inactive stripe (get_active_stripe())
  111.  *     lockdev check-hash unlink-stripe cnt++ clean-stripe hash-stripe unlockdev
  112.  *  activate a hashed, possibly active stripe (get_active_stripe())
  113.  *     lockdev check-hash if(!cnt++)unlink-stripe unlockdev
  114.  *  attach a request to an active stripe (add_stripe_bh())
  115.  *     lockdev attach-buffer unlockdev
  116.  *  handle a stripe (handle_stripe())
  117.  *     lockstripe clrSTRIPE_HANDLE ... (lockdev check-buffers unlockdev) .. change-state .. record io needed unlockstripe schedule io
  118.  *  release an active stripe (release_stripe())
  119.  *     lockdev if (!--cnt) { if  STRIPE_HANDLE, add to handle_list else add to inactive-list } unlockdev
  120.  *
  121.  * The refcount counts each thread that have activated the stripe,
  122.  * plus raid5d if it is handling it, plus one for each active request
  123.  * on a cached buffer.
  124.  */
  125. struct stripe_head {
  126. struct stripe_head *hash_next, **hash_pprev; /* hash pointers */
  127. struct list_head lru; /* inactive_list or handle_list */
  128. struct raid5_private_data *raid_conf;
  129. sector_t sector; /* sector of this row */
  130. int pd_idx; /* parity disk index */
  131. unsigned long state; /* state flags */
  132. atomic_t count; /* nr of active thread/requests */
  133. spinlock_t lock;
  134. int bm_seq; /* sequence number for bitmap flushes */
  135. struct r5dev {
  136. struct bio req;
  137. struct bio_vec vec;
  138. struct page *page;
  139. struct bio *toread, *towrite, *written;
  140. sector_t sector; /* sector of this page */
  141. unsigned long flags;
  142. } dev[1]; /* allocated with extra space depending of RAID geometry */
  143. };
  144. /* Flags */
  145. #define R5_UPTODATE 0 /* page contains current data */
  146. #define R5_LOCKED 1 /* IO has been submitted on "req" */
  147. #define R5_OVERWRITE 2 /* towrite covers whole page */
  148. /* and some that are internal to handle_stripe */
  149. #define R5_Insync 3 /* rdev && rdev->in_sync at start */
  150. #define R5_Wantread 4 /* want to schedule a read */
  151. #define R5_Wantwrite 5
  152. #define R5_Syncio 6 /* this io need to be accounted as resync io */
  153. #define R5_Overlap 7 /* There is a pending overlapping request on this block */
  154. /*
  155.  * Write method
  156.  */
  157. #define RECONSTRUCT_WRITE 1
  158. #define READ_MODIFY_WRITE 2
  159. /* not a write method, but a compute_parity mode */
  160. #define CHECK_PARITY 3
  161. /*
  162.  * Stripe state
  163.  */
  164. #define STRIPE_HANDLE 2
  165. #define STRIPE_SYNCING 3
  166. #define STRIPE_INSYNC 4
  167. #define STRIPE_PREREAD_ACTIVE 5
  168. #define STRIPE_DELAYED 6
  169. #define STRIPE_DEGRADED 7
  170. #define STRIPE_BIT_DELAY 8
  171. /*
  172.  * Plugging:
  173.  *
  174.  * To improve write throughput, we need to delay the handling of some
  175.  * stripes until there has been a chance that several write requests
  176.  * for the one stripe have all been collected.
  177.  * In particular, any write request that would require pre-reading
  178.  * is put on a "delayed" queue until there are no stripes currently
  179.  * in a pre-read phase.  Further, if the "delayed" queue is empty when
  180.  * a stripe is put on it then we "plug" the queue and do not process it
  181.  * until an unplug call is made. (the unplug_io_fn() is called).
  182.  *
  183.  * When preread is initiated on a stripe, we set PREREAD_ACTIVE and add
  184.  * it to the count of prereading stripes.
  185.  * When write is initiated, or the stripe refcnt == 0 (just in case) we
  186.  * clear the PREREAD_ACTIVE flag and decrement the count
  187.  * Whenever the delayed queue is empty and the device is not plugged, we
  188.  * move any strips from delayed to handle and clear the DELAYED flag and set PREREAD_ACTIVE.
  189.  * In stripe_handle, if we find pre-reading is necessary, we do it if
  190.  * PREREAD_ACTIVE is set, else we set DELAYED which will send it to the delayed queue.
  191.  * HANDLE gets cleared if stripe_handle leave nothing locked.
  192.  */
  193.  
  194. struct disk_info {
  195. mdk_rdev_t *rdev;
  196. };
  197. struct raid5_private_data {
  198. struct stripe_head **stripe_hashtbl;
  199. mddev_t *mddev;
  200. struct disk_info *spare;
  201. int chunk_size, level, algorithm;
  202. int raid_disks, working_disks, failed_disks;
  203. int max_nr_stripes;
  204. struct list_head handle_list; /* stripes needing handling */
  205. struct list_head delayed_list; /* stripes that have plugged requests */
  206. struct list_head bitmap_list; /* stripes delaying awaiting bitmap update */
  207. atomic_t preread_active_stripes; /* stripes with scheduled io */
  208. char cache_name[20];
  209. kmem_cache_t *slab_cache; /* for allocating stripes */
  210. int seq_flush, seq_write;
  211. int quiesce;
  212. int fullsync;  /* set to 1 if a full sync is needed,
  213.     * (fresh device added).
  214.     * Cleared when a sync completes.
  215.     */
  216. /*
  217.  * Free stripes pool
  218.  */
  219. atomic_t active_stripes;
  220. struct list_head inactive_list;
  221. wait_queue_head_t wait_for_stripe;
  222. wait_queue_head_t wait_for_overlap;
  223. int inactive_blocked; /* release of inactive stripes blocked,
  224.  * waiting for 25% to be free
  225.  */        
  226. spinlock_t device_lock;
  227. struct disk_info disks[0];
  228. };
  229. typedef struct raid5_private_data raid5_conf_t;
  230. #define mddev_to_conf(mddev) ((raid5_conf_t *) mddev->private)
  231. /*
  232.  * Our supported algorithms
  233.  */
  234. #define ALGORITHM_LEFT_ASYMMETRIC 0
  235. #define ALGORITHM_RIGHT_ASYMMETRIC 1
  236. #define ALGORITHM_LEFT_SYMMETRIC 2
  237. #define ALGORITHM_RIGHT_SYMMETRIC 3
  238. #endif