Lines Matching defs:mddev
27 struct mddev *mddev; /* pointing back to mddev. */
61 struct mddev *mddev; /* the md device which md_cluster_info belongs to */
150 struct mddev *mddev)
162 || test_bit(MD_CLOSING, &mddev->flags));
183 static struct dlm_lock_resource *lockres_init(struct mddev *mddev,
188 struct md_cluster_info *cinfo = mddev->cluster_info;
196 res->mddev = mddev;
268 static int read_resync_info(struct mddev *mddev,
272 struct md_cluster_info *cinfo = mddev->cluster_info;
288 struct mddev *mddev = thread->mddev;
289 struct md_cluster_info *cinfo = mddev->cluster_info;
299 bm_lockres = lockres_init(mddev, str, NULL, 1);
305 ret = dlm_lock_sync_interruptible(bm_lockres, DLM_LOCK_PW, mddev);
311 ret = md_bitmap_copy_from_slot(mddev, slot, &lo, &hi, true);
325 if (test_bit(MD_RESYNCING_REMOTE, &mddev->recovery) &&
326 test_bit(MD_RECOVERY_RESHAPE, &mddev->recovery) &&
327 mddev->reshape_position != MaxSector)
328 md_wakeup_thread(mddev->sync_thread);
331 if (lo < mddev->recovery_cp)
332 mddev->recovery_cp = lo;
335 if (mddev->recovery_cp != MaxSector) {
341 &mddev->recovery);
342 set_bit(MD_RECOVERY_NEEDED, &mddev->recovery);
343 md_wakeup_thread(mddev->thread);
354 struct mddev *mddev = arg;
355 struct md_cluster_info *cinfo = mddev->cluster_info;
359 static void __recover_slot(struct mddev *mddev, int slot)
361 struct md_cluster_info *cinfo = mddev->cluster_info;
366 md_register_thread(recover_bitmaps, mddev, "recover"));
377 struct mddev *mddev = arg;
378 struct md_cluster_info *cinfo = mddev->cluster_info;
381 mddev->bitmap_info.cluster_name,
386 __recover_slot(mddev, slot->slot - 1);
393 struct mddev *mddev = arg;
394 struct md_cluster_info *cinfo = mddev->cluster_info;
422 struct md_cluster_info *cinfo = res->mddev->cluster_info;
432 static void remove_suspend_info(struct mddev *mddev, int slot)
434 struct md_cluster_info *cinfo = mddev->cluster_info;
435 mddev->pers->quiesce(mddev, 1);
440 mddev->pers->quiesce(mddev, 0);
443 static void process_suspend_info(struct mddev *mddev,
446 struct md_cluster_info *cinfo = mddev->cluster_info;
455 clear_bit(MD_RESYNCING_REMOTE, &mddev->recovery);
456 remove_suspend_info(mddev, slot);
457 set_bit(MD_RECOVERY_NEEDED, &mddev->recovery);
458 md_wakeup_thread(mddev->thread);
462 rdev_for_each(rdev, mddev)
490 md_bitmap_sync_with_cluster(mddev, cinfo->sync_low,
495 mddev->pers->quiesce(mddev, 1);
501 mddev->pers->quiesce(mddev, 0);
504 static void process_add_new_disk(struct mddev *mddev, struct cluster_msg *cmsg)
507 struct md_cluster_info *cinfo = mddev->cluster_info;
519 kobject_uevent_env(&disk_to_dev(mddev->gendisk)->kobj, KOBJ_CHANGE, envp);
526 static void process_metadata_update(struct mddev *mddev, struct cluster_msg *msg)
530 struct md_cluster_info *cinfo = mddev->cluster_info;
531 mddev->good_device_nr = le32_to_cpu(msg->raid_slot);
536 thread = rcu_dereference_protected(mddev->thread, true);
538 (got_lock = mddev_trylock(mddev)) ||
540 md_reload_sb(mddev, mddev->good_device_nr);
542 mddev_unlock(mddev);
545 static void process_remove_disk(struct mddev *mddev, struct cluster_msg *msg)
550 rdev = md_find_rdev_nr_rcu(mddev, le32_to_cpu(msg->raid_slot));
553 set_bit(MD_RECOVERY_NEEDED, &mddev->recovery);
554 md_wakeup_thread(mddev->thread);
562 static void process_readd_disk(struct mddev *mddev, struct cluster_msg *msg)
567 rdev = md_find_rdev_nr_rcu(mddev, le32_to_cpu(msg->raid_slot));
576 static int process_recvd_msg(struct mddev *mddev, struct cluster_msg *msg)
580 if (WARN(mddev->cluster_info->slot_number - 1 == le32_to_cpu(msg->slot),
585 process_metadata_update(mddev, msg);
588 set_capacity_and_notify(mddev->gendisk, mddev->array_sectors);
591 set_bit(MD_RESYNCING_REMOTE, &mddev->recovery);
592 process_suspend_info(mddev, le32_to_cpu(msg->slot),
597 process_add_new_disk(mddev, msg);
600 process_remove_disk(mddev, msg);
603 process_readd_disk(mddev, msg);
606 __recover_slot(mddev, le32_to_cpu(msg->slot));
609 if (le64_to_cpu(msg->high) != mddev->pers->size(mddev, 0, 0))
610 ret = md_bitmap_resize(mddev->bitmap,
626 struct md_cluster_info *cinfo = thread->mddev->cluster_info;
642 ret = process_recvd_msg(thread->mddev, &msg);
691 struct mddev *mddev = cinfo->mddev;
704 md_wakeup_thread(mddev->thread);
801 static int gather_all_resync_info(struct mddev *mddev, int total_slots)
803 struct md_cluster_info *cinfo = mddev->cluster_info;
813 bm_lockres = lockres_init(mddev, str, NULL, 1);
824 if (read_resync_info(mddev, bm_lockres)) {
842 ret = md_bitmap_copy_from_slot(mddev, i, &lo, &hi, false);
848 if ((hi > 0) && (lo < mddev->recovery_cp)) {
849 set_bit(MD_RECOVERY_NEEDED, &mddev->recovery);
850 mddev->recovery_cp = lo;
851 md_check_recovery(mddev);
860 static int join(struct mddev *mddev, int nodes)
877 mddev->cluster_info = cinfo;
878 cinfo->mddev = mddev;
881 sprintf(str, "%pU", mddev->uuid);
882 ret = dlm_new_lockspace(str, mddev->bitmap_info.cluster_name,
883 0, LVB_SIZE, &md_ls_ops, mddev,
897 md_register_thread(recv_daemon, mddev, "cluster_recv"));
902 cinfo->message_lockres = lockres_init(mddev, "message", NULL, 1);
905 cinfo->token_lockres = lockres_init(mddev, "token", NULL, 0);
908 cinfo->no_new_dev_lockres = lockres_init(mddev, "no-new-dev", NULL, 0);
918 cinfo->ack_lockres = lockres_init(mddev, "ack", ack_bast, 0);
935 cinfo->bitmap_lockres = lockres_init(mddev, str, NULL, 1);
946 cinfo->resync_lockres = lockres_init(mddev, "resync", NULL, 0);
955 md_unregister_thread(mddev, &cinfo->recovery_thread);
956 md_unregister_thread(mddev, &cinfo->recv_thread);
965 mddev->cluster_info = NULL;
970 static void load_bitmaps(struct mddev *mddev, int total_slots)
972 struct md_cluster_info *cinfo = mddev->cluster_info;
975 if (gather_all_resync_info(mddev, total_slots))
983 static void resync_bitmap(struct mddev *mddev)
985 struct md_cluster_info *cinfo = mddev->cluster_info;
996 static void unlock_all_bitmaps(struct mddev *mddev);
997 static int leave(struct mddev *mddev)
999 struct md_cluster_info *cinfo = mddev->cluster_info;
1012 if ((cinfo->slot_number > 0 && mddev->recovery_cp != MaxSector) ||
1013 (mddev->reshape_position != MaxSector &&
1014 test_bit(MD_CLOSING, &mddev->flags)))
1015 resync_bitmap(mddev);
1018 md_unregister_thread(mddev, &cinfo->recovery_thread);
1019 md_unregister_thread(mddev, &cinfo->recv_thread);
1026 unlock_all_bitmaps(mddev);
1036 static int slot_number(struct mddev *mddev)
1038 struct md_cluster_info *cinfo = mddev->cluster_info;
1049 static int metadata_update_start(struct mddev *mddev)
1051 struct md_cluster_info *cinfo = mddev->cluster_info;
1061 md_wakeup_thread(mddev->thread);
1078 static int metadata_update_finish(struct mddev *mddev)
1080 struct md_cluster_info *cinfo = mddev->cluster_info;
1090 rdev_for_each(rdev, mddev)
1105 static void metadata_update_cancel(struct mddev *mddev)
1107 struct md_cluster_info *cinfo = mddev->cluster_info;
1112 static int update_bitmap_size(struct mddev *mddev, sector_t size)
1114 struct md_cluster_info *cinfo = mddev->cluster_info;
1127 static int resize_bitmaps(struct mddev *mddev, sector_t newsize, sector_t oldsize)
1132 struct bitmap *bitmap = mddev->bitmap;
1140 rv = update_bitmap_size(mddev, newsize);
1144 for (i = 0; i < mddev->bitmap_info.nodes; i++) {
1145 if (i == md_cluster_ops->slot_number(mddev))
1148 bitmap = get_bitmap_from_slot(mddev, i);
1161 bm_lockres = lockres_init(mddev, str, NULL, 1);
1184 update_bitmap_size(mddev, oldsize);
1191 static int cluster_check_sync_size(struct mddev *mddev)
1196 int node_num = mddev->bitmap_info.nodes;
1197 int current_slot = md_cluster_ops->slot_number(mddev);
1198 struct bitmap *bitmap = mddev->bitmap;
1210 bitmap = get_bitmap_from_slot(mddev, i);
1221 bm_lockres = lockres_init(mddev, str, NULL, 1);
1258 static void update_size(struct mddev *mddev, sector_t old_dev_sectors)
1260 struct md_cluster_info *cinfo = mddev->cluster_info;
1266 md_update_sb(mddev, 1);
1274 rdev_for_each(rdev, mddev)
1304 if (cluster_check_sync_size(mddev) == 0) {
1311 set_capacity_and_notify(mddev->gendisk, mddev->array_sectors);
1314 ret = mddev->pers->resize(mddev, old_dev_sectors);
1323 static int resync_start(struct mddev *mddev)
1325 struct md_cluster_info *cinfo = mddev->cluster_info;
1326 return dlm_lock_sync_interruptible(cinfo->resync_lockres, DLM_LOCK_EX, mddev);
1329 static void resync_info_get(struct mddev *mddev, sector_t *lo, sector_t *hi)
1331 struct md_cluster_info *cinfo = mddev->cluster_info;
1339 static int resync_info_update(struct mddev *mddev, sector_t lo, sector_t hi)
1341 struct md_cluster_info *cinfo = mddev->cluster_info;
1369 static int resync_finish(struct mddev *mddev)
1371 struct md_cluster_info *cinfo = mddev->cluster_info;
1374 clear_bit(MD_RESYNCING_REMOTE, &mddev->recovery);
1380 if (!test_bit(MD_CLOSING, &mddev->flags))
1381 ret = resync_info_update(mddev, 0, 0);
1386 static int area_resyncing(struct mddev *mddev, int direction,
1389 struct md_cluster_info *cinfo = mddev->cluster_info;
1407 static int add_new_disk(struct mddev *mddev, struct md_rdev *rdev)
1409 struct md_cluster_info *cinfo = mddev->cluster_info;
1439 * md_wakeup_thread(mddev->thread)
1454 static void add_new_disk_cancel(struct mddev *mddev)
1456 struct md_cluster_info *cinfo = mddev->cluster_info;
1461 static int new_disk_ack(struct mddev *mddev, bool ack)
1463 struct md_cluster_info *cinfo = mddev->cluster_info;
1466 pr_warn("md-cluster(%s): Spurious cluster confirmation\n", mdname(mddev));
1476 static int remove_disk(struct mddev *mddev, struct md_rdev *rdev)
1479 struct md_cluster_info *cinfo = mddev->cluster_info;
1485 static int lock_all_bitmaps(struct mddev *mddev)
1489 struct md_cluster_info *cinfo = mddev->cluster_info;
1492 kcalloc(mddev->bitmap_info.nodes - 1,
1499 my_slot = slot_number(mddev);
1500 for (slot = 0; slot < mddev->bitmap_info.nodes; slot++) {
1506 cinfo->other_bitmap_lockres[i] = lockres_init(mddev, str, NULL, 1);
1520 static void unlock_all_bitmaps(struct mddev *mddev)
1522 struct md_cluster_info *cinfo = mddev->cluster_info;
1527 for (i = 0; i < mddev->bitmap_info.nodes - 1; i++) {
1542 struct mddev *mddev = rdev->mddev;
1543 struct md_cluster_info *cinfo = mddev->cluster_info;
1551 for (sn = 0; sn < mddev->bitmap_info.nodes; sn++) {
1554 err = md_bitmap_copy_from_slot(mddev, sn, &lo, &hi, false);
1559 if ((hi > 0) && (lo < mddev->recovery_cp))
1560 mddev->recovery_cp = lo;