raid1.h 3.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131
  1. #ifndef _RAID1_H
  2. #define _RAID1_H
  3. typedef struct mirror_info mirror_info_t;
  4. struct mirror_info {
  5. mdk_rdev_t *rdev;
  6. sector_t head_position;
  7. };
  8. /*
  9. * memory pools need a pointer to the mddev, so they can force an unplug
  10. * when memory is tight, and a count of the number of drives that the
  11. * pool was allocated for, so they know how much to allocate and free.
  12. * mddev->raid_disks cannot be used, as it can change while a pool is active
  13. * These two datums are stored in a kmalloced struct.
  14. */
  15. struct pool_info {
  16. mddev_t *mddev;
  17. int raid_disks;
  18. };
  19. typedef struct r1bio_s r1bio_t;
  20. struct r1_private_data_s {
  21. mddev_t *mddev;
  22. mirror_info_t *mirrors;
  23. int raid_disks;
  24. int last_used;
  25. sector_t next_seq_sect;
  26. spinlock_t device_lock;
  27. struct list_head retry_list;
  28. /* queue pending writes and submit them on unplug */
  29. struct bio_list pending_bio_list;
  30. /* queue of writes that have been unplugged */
  31. struct bio_list flushing_bio_list;
  32. /* for use when syncing mirrors: */
  33. spinlock_t resync_lock;
  34. int nr_pending;
  35. int nr_waiting;
  36. int nr_queued;
  37. int barrier;
  38. sector_t next_resync;
  39. int fullsync; /* set to 1 if a full sync is needed,
  40. * (fresh device added).
  41. * Cleared when a sync completes.
  42. */
  43. wait_queue_head_t wait_barrier;
  44. struct pool_info *poolinfo;
  45. struct page *tmppage;
  46. mempool_t *r1bio_pool;
  47. mempool_t *r1buf_pool;
  48. /* When taking over an array from a different personality, we store
  49. * the new thread here until we fully activate the array.
  50. */
  51. struct mdk_thread_s *thread;
  52. };
  53. typedef struct r1_private_data_s conf_t;
  54. /*
  55. * this is our 'private' RAID1 bio.
  56. *
  57. * it contains information about what kind of IO operations were started
  58. * for this RAID1 operation, and about their status:
  59. */
  60. struct r1bio_s {
  61. atomic_t remaining; /* 'have we finished' count,
  62. * used from IRQ handlers
  63. */
  64. atomic_t behind_remaining; /* number of write-behind ios remaining
  65. * in this BehindIO request
  66. */
  67. sector_t sector;
  68. int sectors;
  69. unsigned long state;
  70. mddev_t *mddev;
  71. /*
  72. * original bio going to /dev/mdx
  73. */
  74. struct bio *master_bio;
  75. /*
  76. * if the IO is in READ direction, then this is where we read
  77. */
  78. int read_disk;
  79. struct list_head retry_list;
  80. struct bitmap_update *bitmap_update;
  81. /*
  82. * if the IO is in WRITE direction, then multiple bios are used.
  83. * We choose the number when they are allocated.
  84. */
  85. struct bio *bios[0];
  86. /* DO NOT PUT ANY NEW FIELDS HERE - bios array is contiguously alloced*/
  87. };
  88. /* when we get a read error on a read-only array, we redirect to another
  89. * device without failing the first device, or trying to over-write to
  90. * correct the read error. To keep track of bad blocks on a per-bio
  91. * level, we store IO_BLOCKED in the appropriate 'bios' pointer
  92. */
  93. #define IO_BLOCKED ((struct bio*)1)
  94. /* bits for r1bio.state */
  95. #define R1BIO_Uptodate 0
  96. #define R1BIO_IsSync 1
  97. #define R1BIO_Degraded 2
  98. #define R1BIO_BehindIO 3
  99. #define R1BIO_Barrier 4
  100. #define R1BIO_BarrierRetry 5
  101. /* For write-behind requests, we call bi_end_io when
  102. * the last non-write-behind device completes, providing
  103. * any write was successful. Otherwise we call when
  104. * any write-behind write succeeds, otherwise we call
  105. * with failure when last write completes (and all failed).
  106. * Record that bi_end_io was called with this flag...
  107. */
  108. #define R1BIO_Returned 6
  109. #endif