Lines Matching refs:mddev
134 struct mddev *mddev; /* RAID array if running */ member
390 struct mddev { struct
607 void (*sync_super)(struct mddev *mddev, struct md_rdev *rdev); argument
677 static inline bool md_is_rdwr(struct mddev *mddev) in md_is_rdwr() argument
679 return (mddev->ro == MD_RDWR); in md_is_rdwr()
682 static inline bool reshape_interrupted(struct mddev *mddev) in reshape_interrupted() argument
685 if (mddev->reshape_position == MaxSector) in reshape_interrupted()
689 if (!test_bit(MD_RECOVERY_RUNNING, &mddev->recovery)) in reshape_interrupted()
693 if (test_bit(MD_RECOVERY_WAIT, &mddev->recovery) || in reshape_interrupted()
694 test_bit(MD_RECOVERY_INTR, &mddev->recovery) || in reshape_interrupted()
695 test_bit(MD_RECOVERY_FROZEN, &mddev->recovery)) in reshape_interrupted()
701 static inline int __must_check mddev_lock(struct mddev *mddev) in mddev_lock() argument
705 ret = mutex_lock_interruptible(&mddev->reconfig_mutex); in mddev_lock()
710 if (!ret && test_bit(MD_DELETED, &mddev->flags)) { in mddev_lock()
712 mutex_unlock(&mddev->reconfig_mutex); in mddev_lock()
724 static inline void mddev_lock_nointr(struct mddev *mddev) in mddev_lock_nointr() argument
726 mutex_lock(&mddev->reconfig_mutex); in mddev_lock_nointr()
729 static inline int mddev_trylock(struct mddev *mddev) in mddev_trylock() argument
733 ret = mutex_trylock(&mddev->reconfig_mutex); in mddev_trylock()
734 if (!ret && test_bit(MD_DELETED, &mddev->flags)) { in mddev_trylock()
736 mutex_unlock(&mddev->reconfig_mutex); in mddev_trylock()
740 extern void mddev_unlock(struct mddev *mddev);
746 bool __must_check (*make_request)(struct mddev *mddev, struct bio *bio);
751 int (*run)(struct mddev *mddev);
753 int (*start)(struct mddev *mddev);
754 void (*free)(struct mddev *mddev, void *priv);
755 void (*status)(struct seq_file *seq, struct mddev *mddev);
759 void (*error_handler)(struct mddev *mddev, struct md_rdev *rdev);
760 int (*hot_add_disk) (struct mddev *mddev, struct md_rdev *rdev);
761 int (*hot_remove_disk) (struct mddev *mddev, struct md_rdev *rdev);
762 int (*spare_active) (struct mddev *mddev);
763 sector_t (*sync_request)(struct mddev *mddev, sector_t sector_nr,
765 int (*resize) (struct mddev *mddev, sector_t sectors);
766 sector_t (*size) (struct mddev *mddev, sector_t sectors, int raid_disks);
767 int (*check_reshape) (struct mddev *mddev);
768 int (*start_reshape) (struct mddev *mddev);
769 void (*finish_reshape) (struct mddev *mddev);
770 void (*update_reshape_pos) (struct mddev *mddev);
771 void (*prepare_suspend) (struct mddev *mddev);
776 void (*quiesce) (struct mddev *mddev, int quiesce);
786 void *(*takeover) (struct mddev *mddev);
788 int (*change_consistency_policy)(struct mddev *mddev, const char *buf);
790 void (*bitmap_sector)(struct mddev *mddev, sector_t *offset,
796 ssize_t (*show)(struct mddev *, char *);
797 ssize_t (*store)(struct mddev *, const char *, size_t);
813 static inline char * mdname (struct mddev * mddev) in mdname() argument
815 return mddev->gendisk ? mddev->gendisk->disk_name : "mdX"; in mdname()
818 static inline int sysfs_link_rdev(struct mddev *mddev, struct md_rdev *rdev) in sysfs_link_rdev() argument
823 mddev->kobj.sd) { in sysfs_link_rdev()
825 return sysfs_create_link(&mddev->kobj, &rdev->kobj, nm); in sysfs_link_rdev()
830 static inline void sysfs_unlink_rdev(struct mddev *mddev, struct md_rdev *rdev) in sysfs_unlink_rdev() argument
835 mddev->kobj.sd) { in sysfs_unlink_rdev()
837 sysfs_remove_link(&mddev->kobj, nm); in sysfs_unlink_rdev()
851 #define rdev_for_each(rdev, mddev) \ argument
852 list_for_each_entry(rdev, &((mddev)->disks), same_set)
854 #define rdev_for_each_safe(rdev, tmp, mddev) \ argument
855 list_for_each_entry_safe(rdev, tmp, &((mddev)->disks), same_set)
857 #define rdev_for_each_rcu(rdev, mddev) \ argument
858 list_for_each_entry_rcu(rdev, &((mddev)->disks), same_set)
862 struct mddev *mddev; member
871 struct mddev *mddev; member
891 struct mddev *mddev,
893 extern void md_unregister_thread(struct mddev *mddev, struct md_thread __rcu **threadp);
895 extern void md_check_recovery(struct mddev *mddev);
896 extern void md_reap_sync_thread(struct mddev *mddev);
897 extern enum sync_action md_sync_action(struct mddev *mddev);
900 extern void md_write_start(struct mddev *mddev, struct bio *bi);
901 extern void md_write_inc(struct mddev *mddev, struct bio *bi);
902 extern void md_write_end(struct mddev *mddev);
903 extern void md_done_sync(struct mddev *mddev, int blocks, int ok);
904 extern void md_error(struct mddev *mddev, struct md_rdev *rdev);
905 extern void md_finish_reshape(struct mddev *mddev);
906 void md_submit_discard_bio(struct mddev *mddev, struct md_rdev *rdev,
908 void md_account_bio(struct mddev *mddev, struct bio **bio);
911 extern bool __must_check md_flush_request(struct mddev *mddev, struct bio *bio);
912 extern void md_super_write(struct mddev *mddev, struct md_rdev *rdev,
914 extern int md_super_wait(struct mddev *mddev);
919 extern void md_allow_write(struct mddev *mddev);
920 extern void md_wait_for_blocked_rdev(struct md_rdev *rdev, struct mddev *mddev);
921 extern void md_set_array_sectors(struct mddev *mddev, sector_t array_sectors);
922 extern int md_check_no_bitmap(struct mddev *mddev);
923 extern int md_integrity_register(struct mddev *mddev);
926 extern int mddev_init(struct mddev *mddev);
927 extern void mddev_destroy(struct mddev *mddev);
929 struct mddev *md_alloc(dev_t dev, char *name);
930 void mddev_put(struct mddev *mddev);
931 extern int md_run(struct mddev *mddev);
932 extern int md_start(struct mddev *mddev);
933 extern void md_stop(struct mddev *mddev);
934 extern void md_stop_writes(struct mddev *mddev);
938 extern bool md_handle_request(struct mddev *mddev, struct bio *bio);
939 extern int mddev_suspend(struct mddev *mddev, bool interruptible);
940 extern void mddev_resume(struct mddev *mddev);
941 extern void md_idle_sync_thread(struct mddev *mddev);
942 extern void md_frozen_sync_thread(struct mddev *mddev);
943 extern void md_unfrozen_sync_thread(struct mddev *mddev);
945 extern void md_update_sb(struct mddev *mddev, int force);
946 extern void mddev_create_serial_pool(struct mddev *mddev, struct md_rdev *rdev);
947 extern void mddev_destroy_serial_pool(struct mddev *mddev,
949 struct md_rdev *md_find_rdev_nr_rcu(struct mddev *mddev, int nr);
950 struct md_rdev *md_find_rdev_rcu(struct mddev *mddev, dev_t dev);
957 static inline void rdev_dec_pending(struct md_rdev *rdev, struct mddev *mddev) in rdev_dec_pending() argument
961 set_bit(MD_RECOVERY_NEEDED, &mddev->recovery); in rdev_dec_pending()
962 md_wakeup_thread(mddev->thread); in rdev_dec_pending()
966 static inline int mddev_is_clustered(struct mddev *mddev) in mddev_is_clustered() argument
968 return mddev->cluster_info && mddev->bitmap_info.nodes > 1; in mddev_is_clustered()
972 static inline void mddev_clear_unsupported_flags(struct mddev *mddev, in mddev_clear_unsupported_flags() argument
975 mddev->flags &= ~unsupported_flags; in mddev_clear_unsupported_flags()
978 static inline void mddev_check_write_zeroes(struct mddev *mddev, struct bio *bio) in mddev_check_write_zeroes() argument
982 mddev->gendisk->queue->limits.max_write_zeroes_sectors = 0; in mddev_check_write_zeroes()
985 static inline int mddev_suspend_and_lock(struct mddev *mddev) in mddev_suspend_and_lock() argument
989 ret = mddev_suspend(mddev, true); in mddev_suspend_and_lock()
993 ret = mddev_lock(mddev); in mddev_suspend_and_lock()
995 mddev_resume(mddev); in mddev_suspend_and_lock()
1000 static inline void mddev_suspend_and_lock_nointr(struct mddev *mddev) in mddev_suspend_and_lock_nointr() argument
1002 mddev_suspend(mddev, false); in mddev_suspend_and_lock_nointr()
1003 mutex_lock(&mddev->reconfig_mutex); in mddev_suspend_and_lock_nointr()
1006 static inline void mddev_unlock_and_resume(struct mddev *mddev) in mddev_unlock_and_resume() argument
1008 mddev_unlock(mddev); in mddev_unlock_and_resume()
1009 mddev_resume(mddev); in mddev_unlock_and_resume()
1018 int md_set_array_info(struct mddev *mddev, struct mdu_array_info_s *info);
1019 int md_add_new_disk(struct mddev *mddev, struct mdu_disk_info_s *info);
1020 int do_md_run(struct mddev *mddev);
1022 int mddev_stack_rdev_limits(struct mddev *mddev, struct queue_limits *lim,
1024 int mddev_stack_new_rdev(struct mddev *mddev, struct md_rdev *rdev);
1025 void mddev_update_io_opt(struct mddev *mddev, unsigned int nr_stripes);
1032 static inline bool mddev_is_dm(struct mddev *mddev) in mddev_is_dm() argument
1034 return !mddev->gendisk; in mddev_is_dm()
1037 static inline void mddev_trace_remap(struct mddev *mddev, struct bio *bio, in mddev_trace_remap() argument
1040 if (!mddev_is_dm(mddev)) in mddev_trace_remap()
1041 trace_block_bio_remap(bio, disk_devt(mddev->gendisk), sector); in mddev_trace_remap()
1068 #define mddev_add_trace_msg(mddev, fmt, args...) \ argument
1070 if (!mddev_is_dm(mddev)) \
1071 blk_add_trace_msg((mddev)->gendisk->queue, fmt, ##args); \