raid5.h
上传用户:lgb322
上传日期:2013-02-24
资源大小:30529k
文件大小: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 determined by bh_state.  Changes between
  9.  * these states happen *almost* exclusively under a per-stripe
  10.  * spinlock.  Some very specific changes can happen in b_end_io, and
  11.  * these are not protected by the spin lock.
  12.  *
  13.  * The bh_state bits that are used to represent these states are:
  14.  *   BH_Uptodate, BH_Lock
  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 is it 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. struct buffer_head *bh_cache[MD_SB_DISKS]; /* buffered copy */
  130. struct buffer_head *bh_read[MD_SB_DISKS]; /* read request buffers of the MD device */
  131. struct buffer_head *bh_write[MD_SB_DISKS]; /* write request buffers of the MD device */
  132. struct buffer_head *bh_written[MD_SB_DISKS]; /* write request buffers of the MD device that have been scheduled for write */
  133. struct page *bh_page[MD_SB_DISKS]; /* saved bh_cache[n]->b_page when reading around the cache */
  134. unsigned long sector; /* sector of this row */
  135. int size; /* buffers size */
  136. int pd_idx; /* parity disk index */
  137. unsigned long state; /* state flags */
  138. atomic_t count; /* nr of active thread/requests */
  139. spinlock_t lock;
  140. int sync_redone;
  141. };
  142. /*
  143.  * Write method
  144.  */
  145. #define RECONSTRUCT_WRITE 1
  146. #define READ_MODIFY_WRITE 2
  147. /* not a write method, but a compute_parity mode */
  148. #define CHECK_PARITY 3
  149. /*
  150.  * Stripe state
  151.  */
  152. #define STRIPE_ERROR 1
  153. #define STRIPE_HANDLE 2
  154. #define STRIPE_SYNCING 3
  155. #define STRIPE_INSYNC 4
  156. #define STRIPE_PREREAD_ACTIVE 5
  157. #define STRIPE_DELAYED 6
  158. /*
  159.  * Plugging:
  160.  *
  161.  * To improve write throughput, we need to delay the handling of some
  162.  * stripes until there has been a chance that several write requests
  163.  * for the one stripe have all been collected.
  164.  * In particular, any write request that would require pre-reading
  165.  * is put on a "delayed" queue until there are no stripes currently
  166.  * in a pre-read phase.  Further, if the "delayed" queue is empty when
  167.  * a stripe is put on it then we "plug" the queue and do not process it
  168.  * until an unplg call is made. (the tq_disk list is run).
  169.  *
  170.  * When preread is initiated on a stripe, we set PREREAD_ACTIVE and add
  171.  * it to the count of prereading stripes.
  172.  * When write is initiated, or the stripe refcnt == 0 (just in case) we
  173.  * clear the PREREAD_ACTIVE flag and decrement the count
  174.  * Whenever the delayed queue is empty and the device is not plugged, we
  175.  * move any strips from delayed to handle and clear the DELAYED flag and set PREREAD_ACTIVE.
  176.  * In stripe_handle, if we find pre-reading is necessary, we do it if
  177.  * PREREAD_ACTIVE is set, else we set DELAYED which will send it to the delayed queue.
  178.  * HANDLE gets cleared if stripe_handle leave nothing locked.
  179.  */
  180.  
  181. struct disk_info {
  182. kdev_t dev;
  183. int operational;
  184. int number;
  185. int raid_disk;
  186. int write_only;
  187. int spare;
  188. int used_slot;
  189. };
  190. struct raid5_private_data {
  191. struct stripe_head **stripe_hashtbl;
  192. mddev_t *mddev;
  193. mdk_thread_t *thread, *resync_thread;
  194. struct disk_info disks[MD_SB_DISKS];
  195. struct disk_info *spare;
  196. int buffer_size;
  197. int chunk_size, level, algorithm;
  198. int raid_disks, working_disks, failed_disks;
  199. int resync_parity;
  200. int max_nr_stripes;
  201. struct list_head handle_list; /* stripes needing handling */
  202. struct list_head delayed_list; /* stripes that have plugged requests */
  203. atomic_t preread_active_stripes; /* stripes with scheduled io */
  204. /*
  205.  * Free stripes pool
  206.  */
  207. atomic_t active_stripes;
  208. struct list_head inactive_list;
  209. md_wait_queue_head_t wait_for_stripe;
  210. int inactive_blocked; /* release of inactive stripes blocked,
  211.  * waiting for 25% to be free
  212.  */        
  213. md_spinlock_t device_lock;
  214. int plugged;
  215. struct tq_struct plug_tq;
  216. };
  217. typedef struct raid5_private_data raid5_conf_t;
  218. #define mddev_to_conf(mddev) ((raid5_conf_t *) mddev->private)
  219. /*
  220.  * Our supported algorithms
  221.  */
  222. #define ALGORITHM_LEFT_ASYMMETRIC 0
  223. #define ALGORITHM_RIGHT_ASYMMETRIC 1
  224. #define ALGORITHM_LEFT_SYMMETRIC 2
  225. #define ALGORITHM_RIGHT_SYMMETRIC 3
  226. #endif