Lines Matching refs:dev_replace

75 	struct btrfs_dev_replace *dev_replace = &fs_info->dev_replace;  in btrfs_init_dev_replace()  local
110 dev_replace->replace_state = in btrfs_init_dev_replace()
112 dev_replace->cont_reading_from_srcdev_mode = in btrfs_init_dev_replace()
114 dev_replace->time_started = 0; in btrfs_init_dev_replace()
115 dev_replace->time_stopped = 0; in btrfs_init_dev_replace()
116 atomic64_set(&dev_replace->num_write_errors, 0); in btrfs_init_dev_replace()
117 atomic64_set(&dev_replace->num_uncorrectable_read_errors, 0); in btrfs_init_dev_replace()
118 dev_replace->cursor_left = 0; in btrfs_init_dev_replace()
119 dev_replace->committed_cursor_left = 0; in btrfs_init_dev_replace()
120 dev_replace->cursor_left_last_write_of_item = 0; in btrfs_init_dev_replace()
121 dev_replace->cursor_right = 0; in btrfs_init_dev_replace()
122 dev_replace->srcdev = NULL; in btrfs_init_dev_replace()
123 dev_replace->tgtdev = NULL; in btrfs_init_dev_replace()
124 dev_replace->is_valid = 0; in btrfs_init_dev_replace()
125 dev_replace->item_needs_writeback = 0; in btrfs_init_dev_replace()
140 dev_replace->cont_reading_from_srcdev_mode = in btrfs_init_dev_replace()
142 dev_replace->replace_state = btrfs_dev_replace_replace_state(eb, ptr); in btrfs_init_dev_replace()
143 dev_replace->time_started = btrfs_dev_replace_time_started(eb, ptr); in btrfs_init_dev_replace()
144 dev_replace->time_stopped = in btrfs_init_dev_replace()
146 atomic64_set(&dev_replace->num_write_errors, in btrfs_init_dev_replace()
148 atomic64_set(&dev_replace->num_uncorrectable_read_errors, in btrfs_init_dev_replace()
150 dev_replace->cursor_left = btrfs_dev_replace_cursor_left(eb, ptr); in btrfs_init_dev_replace()
151 dev_replace->committed_cursor_left = dev_replace->cursor_left; in btrfs_init_dev_replace()
152 dev_replace->cursor_left_last_write_of_item = dev_replace->cursor_left; in btrfs_init_dev_replace()
153 dev_replace->cursor_right = btrfs_dev_replace_cursor_right(eb, ptr); in btrfs_init_dev_replace()
154 dev_replace->is_valid = 1; in btrfs_init_dev_replace()
156 dev_replace->item_needs_writeback = 0; in btrfs_init_dev_replace()
157 switch (dev_replace->replace_state) { in btrfs_init_dev_replace()
170 dev_replace->srcdev = NULL; in btrfs_init_dev_replace()
171 dev_replace->tgtdev = NULL; in btrfs_init_dev_replace()
176 dev_replace->tgtdev = btrfs_find_device(fs_info->fs_devices, &args); in btrfs_init_dev_replace()
178 dev_replace->srcdev = btrfs_find_device(fs_info->fs_devices, &args); in btrfs_init_dev_replace()
184 if (!dev_replace->srcdev && in btrfs_init_dev_replace()
193 if (!dev_replace->tgtdev && in btrfs_init_dev_replace()
202 if (dev_replace->tgtdev) { in btrfs_init_dev_replace()
203 if (dev_replace->srcdev) { in btrfs_init_dev_replace()
204 dev_replace->tgtdev->total_bytes = in btrfs_init_dev_replace()
205 dev_replace->srcdev->total_bytes; in btrfs_init_dev_replace()
206 dev_replace->tgtdev->disk_total_bytes = in btrfs_init_dev_replace()
207 dev_replace->srcdev->disk_total_bytes; in btrfs_init_dev_replace()
208 dev_replace->tgtdev->commit_total_bytes = in btrfs_init_dev_replace()
209 dev_replace->srcdev->commit_total_bytes; in btrfs_init_dev_replace()
210 dev_replace->tgtdev->bytes_used = in btrfs_init_dev_replace()
211 dev_replace->srcdev->bytes_used; in btrfs_init_dev_replace()
212 dev_replace->tgtdev->commit_bytes_used = in btrfs_init_dev_replace()
213 dev_replace->srcdev->commit_bytes_used; in btrfs_init_dev_replace()
216 &dev_replace->tgtdev->dev_state); in btrfs_init_dev_replace()
219 dev_replace->tgtdev->io_width = fs_info->sectorsize; in btrfs_init_dev_replace()
220 dev_replace->tgtdev->io_align = fs_info->sectorsize; in btrfs_init_dev_replace()
221 dev_replace->tgtdev->sector_size = fs_info->sectorsize; in btrfs_init_dev_replace()
222 dev_replace->tgtdev->fs_info = fs_info; in btrfs_init_dev_replace()
224 &dev_replace->tgtdev->dev_state); in btrfs_init_dev_replace()
353 struct btrfs_dev_replace *dev_replace = &fs_info->dev_replace; in btrfs_run_dev_replace() local
355 down_read(&dev_replace->rwsem); in btrfs_run_dev_replace()
356 if (!dev_replace->is_valid || in btrfs_run_dev_replace()
357 !dev_replace->item_needs_writeback) { in btrfs_run_dev_replace()
358 up_read(&dev_replace->rwsem); in btrfs_run_dev_replace()
361 up_read(&dev_replace->rwsem); in btrfs_run_dev_replace()
419 down_write(&dev_replace->rwsem); in btrfs_run_dev_replace()
420 if (dev_replace->srcdev) in btrfs_run_dev_replace()
422 dev_replace->srcdev->devid); in btrfs_run_dev_replace()
426 dev_replace->cont_reading_from_srcdev_mode); in btrfs_run_dev_replace()
428 dev_replace->replace_state); in btrfs_run_dev_replace()
429 btrfs_set_dev_replace_time_started(eb, ptr, dev_replace->time_started); in btrfs_run_dev_replace()
430 btrfs_set_dev_replace_time_stopped(eb, ptr, dev_replace->time_stopped); in btrfs_run_dev_replace()
432 atomic64_read(&dev_replace->num_write_errors)); in btrfs_run_dev_replace()
434 atomic64_read(&dev_replace->num_uncorrectable_read_errors)); in btrfs_run_dev_replace()
435 dev_replace->cursor_left_last_write_of_item = in btrfs_run_dev_replace()
436 dev_replace->cursor_left; in btrfs_run_dev_replace()
438 dev_replace->cursor_left_last_write_of_item); in btrfs_run_dev_replace()
440 dev_replace->cursor_right); in btrfs_run_dev_replace()
441 dev_replace->item_needs_writeback = 0; in btrfs_run_dev_replace()
442 up_write(&dev_replace->rwsem); in btrfs_run_dev_replace()
601 struct btrfs_dev_replace *dev_replace = &fs_info->dev_replace; in btrfs_dev_replace_start() local
640 down_write(&dev_replace->rwsem); in btrfs_dev_replace_start()
641 dev_replace->replace_task = current; in btrfs_dev_replace_start()
642 switch (dev_replace->replace_state) { in btrfs_dev_replace_start()
651 up_write(&dev_replace->rwsem); in btrfs_dev_replace_start()
655 dev_replace->cont_reading_from_srcdev_mode = read_src; in btrfs_dev_replace_start()
656 dev_replace->srcdev = src_device; in btrfs_dev_replace_start()
657 dev_replace->tgtdev = tgt_device; in btrfs_dev_replace_start()
669 dev_replace->replace_state = BTRFS_IOCTL_DEV_REPLACE_STATE_STARTED; in btrfs_dev_replace_start()
670 dev_replace->time_started = ktime_get_real_seconds(); in btrfs_dev_replace_start()
671 dev_replace->cursor_left = 0; in btrfs_dev_replace_start()
672 dev_replace->committed_cursor_left = 0; in btrfs_dev_replace_start()
673 dev_replace->cursor_left_last_write_of_item = 0; in btrfs_dev_replace_start()
674 dev_replace->cursor_right = 0; in btrfs_dev_replace_start()
675 dev_replace->is_valid = 1; in btrfs_dev_replace_start()
676 dev_replace->item_needs_writeback = 1; in btrfs_dev_replace_start()
677 atomic64_set(&dev_replace->num_write_errors, 0); in btrfs_dev_replace_start()
678 atomic64_set(&dev_replace->num_uncorrectable_read_errors, 0); in btrfs_dev_replace_start()
679 up_write(&dev_replace->rwsem); in btrfs_dev_replace_start()
696 down_write(&dev_replace->rwsem); in btrfs_dev_replace_start()
697 dev_replace->replace_state = in btrfs_dev_replace_start()
699 dev_replace->srcdev = NULL; in btrfs_dev_replace_start()
700 dev_replace->tgtdev = NULL; in btrfs_dev_replace_start()
701 up_write(&dev_replace->rwsem); in btrfs_dev_replace_start()
711 &dev_replace->scrub_progress, 0, 1); in btrfs_dev_replace_start()
776 wait_event(fs_info->dev_replace.replace_wait, !percpu_counter_sum( in btrfs_rm_dev_replace_blocked()
777 &fs_info->dev_replace.bio_counter)); in btrfs_rm_dev_replace_blocked()
786 wake_up(&fs_info->dev_replace.replace_wait); in btrfs_rm_dev_replace_unblocked()
870 struct btrfs_dev_replace *dev_replace = &fs_info->dev_replace; in btrfs_dev_replace_finishing() local
880 mutex_lock(&dev_replace->lock_finishing_cancel_unmount); in btrfs_dev_replace_finishing()
882 down_read(&dev_replace->rwsem); in btrfs_dev_replace_finishing()
884 if (dev_replace->replace_state != in btrfs_dev_replace_finishing()
886 up_read(&dev_replace->rwsem); in btrfs_dev_replace_finishing()
887 mutex_unlock(&dev_replace->lock_finishing_cancel_unmount); in btrfs_dev_replace_finishing()
891 tgt_device = dev_replace->tgtdev; in btrfs_dev_replace_finishing()
892 src_device = dev_replace->srcdev; in btrfs_dev_replace_finishing()
893 up_read(&dev_replace->rwsem); in btrfs_dev_replace_finishing()
901 mutex_unlock(&dev_replace->lock_finishing_cancel_unmount); in btrfs_dev_replace_finishing()
914 mutex_unlock(&dev_replace->lock_finishing_cancel_unmount); in btrfs_dev_replace_finishing()
933 down_write(&dev_replace->rwsem); in btrfs_dev_replace_finishing()
934 dev_replace->replace_state = in btrfs_dev_replace_finishing()
937 dev_replace->tgtdev = NULL; in btrfs_dev_replace_finishing()
938 dev_replace->srcdev = NULL; in btrfs_dev_replace_finishing()
939 dev_replace->time_stopped = ktime_get_real_seconds(); in btrfs_dev_replace_finishing()
940 dev_replace->item_needs_writeback = 1; in btrfs_dev_replace_finishing()
961 up_write(&dev_replace->rwsem); in btrfs_dev_replace_finishing()
968 mutex_unlock(&dev_replace->lock_finishing_cancel_unmount); in btrfs_dev_replace_finishing()
995 dev_replace->replace_task = NULL; in btrfs_dev_replace_finishing()
996 up_write(&dev_replace->rwsem); in btrfs_dev_replace_finishing()
1030 mutex_unlock(&dev_replace->lock_finishing_cancel_unmount); in btrfs_dev_replace_finishing()
1044 struct btrfs_dev_replace *dev_replace = &fs_info->dev_replace; in btrfs_dev_replace_progress() local
1047 switch (dev_replace->replace_state) { in btrfs_dev_replace_progress()
1057 ret = div64_u64(dev_replace->cursor_left, in btrfs_dev_replace_progress()
1059 dev_replace->srcdev), 1000)); in btrfs_dev_replace_progress()
1069 struct btrfs_dev_replace *dev_replace = &fs_info->dev_replace; in btrfs_dev_replace_status() local
1071 down_read(&dev_replace->rwsem); in btrfs_dev_replace_status()
1075 args->status.replace_state = dev_replace->replace_state; in btrfs_dev_replace_status()
1076 args->status.time_started = dev_replace->time_started; in btrfs_dev_replace_status()
1077 args->status.time_stopped = dev_replace->time_stopped; in btrfs_dev_replace_status()
1079 atomic64_read(&dev_replace->num_write_errors); in btrfs_dev_replace_status()
1081 atomic64_read(&dev_replace->num_uncorrectable_read_errors); in btrfs_dev_replace_status()
1083 up_read(&dev_replace->rwsem); in btrfs_dev_replace_status()
1088 struct btrfs_dev_replace *dev_replace = &fs_info->dev_replace; in btrfs_dev_replace_cancel() local
1099 mutex_lock(&dev_replace->lock_finishing_cancel_unmount); in btrfs_dev_replace_cancel()
1100 down_write(&dev_replace->rwsem); in btrfs_dev_replace_cancel()
1101 switch (dev_replace->replace_state) { in btrfs_dev_replace_cancel()
1106 up_write(&dev_replace->rwsem); in btrfs_dev_replace_cancel()
1109 tgt_device = dev_replace->tgtdev; in btrfs_dev_replace_cancel()
1110 src_device = dev_replace->srcdev; in btrfs_dev_replace_cancel()
1111 up_write(&dev_replace->rwsem); in btrfs_dev_replace_cancel()
1133 tgt_device = dev_replace->tgtdev; in btrfs_dev_replace_cancel()
1134 src_device = dev_replace->srcdev; in btrfs_dev_replace_cancel()
1135 dev_replace->tgtdev = NULL; in btrfs_dev_replace_cancel()
1136 dev_replace->srcdev = NULL; in btrfs_dev_replace_cancel()
1137 dev_replace->replace_state = in btrfs_dev_replace_cancel()
1139 dev_replace->time_stopped = ktime_get_real_seconds(); in btrfs_dev_replace_cancel()
1140 dev_replace->item_needs_writeback = 1; in btrfs_dev_replace_cancel()
1142 up_write(&dev_replace->rwsem); in btrfs_dev_replace_cancel()
1149 mutex_unlock(&dev_replace->lock_finishing_cancel_unmount); in btrfs_dev_replace_cancel()
1164 up_write(&dev_replace->rwsem); in btrfs_dev_replace_cancel()
1168 mutex_unlock(&dev_replace->lock_finishing_cancel_unmount); in btrfs_dev_replace_cancel()
1174 struct btrfs_dev_replace *dev_replace = &fs_info->dev_replace; in btrfs_dev_replace_suspend_for_unmount() local
1176 mutex_lock(&dev_replace->lock_finishing_cancel_unmount); in btrfs_dev_replace_suspend_for_unmount()
1177 down_write(&dev_replace->rwsem); in btrfs_dev_replace_suspend_for_unmount()
1179 switch (dev_replace->replace_state) { in btrfs_dev_replace_suspend_for_unmount()
1186 dev_replace->replace_state = in btrfs_dev_replace_suspend_for_unmount()
1188 dev_replace->time_stopped = ktime_get_real_seconds(); in btrfs_dev_replace_suspend_for_unmount()
1189 dev_replace->item_needs_writeback = 1; in btrfs_dev_replace_suspend_for_unmount()
1194 up_write(&dev_replace->rwsem); in btrfs_dev_replace_suspend_for_unmount()
1195 mutex_unlock(&dev_replace->lock_finishing_cancel_unmount); in btrfs_dev_replace_suspend_for_unmount()
1202 struct btrfs_dev_replace *dev_replace = &fs_info->dev_replace; in btrfs_resume_dev_replace_async() local
1204 down_write(&dev_replace->rwsem); in btrfs_resume_dev_replace_async()
1206 switch (dev_replace->replace_state) { in btrfs_resume_dev_replace_async()
1210 up_write(&dev_replace->rwsem); in btrfs_resume_dev_replace_async()
1215 dev_replace->replace_state = in btrfs_resume_dev_replace_async()
1219 if (!dev_replace->tgtdev || !dev_replace->tgtdev->bdev) { in btrfs_resume_dev_replace_async()
1224 dev_replace->replace_state = in btrfs_resume_dev_replace_async()
1226 up_write(&dev_replace->rwsem); in btrfs_resume_dev_replace_async()
1229 up_write(&dev_replace->rwsem); in btrfs_resume_dev_replace_async()
1237 down_write(&dev_replace->rwsem); in btrfs_resume_dev_replace_async()
1238 dev_replace->replace_state = in btrfs_resume_dev_replace_async()
1240 up_write(&dev_replace->rwsem); in btrfs_resume_dev_replace_async()
1253 struct btrfs_dev_replace *dev_replace = &fs_info->dev_replace; in btrfs_dev_replace_kthread() local
1261 btrfs_dev_name(dev_replace->srcdev), in btrfs_dev_replace_kthread()
1262 dev_replace->srcdev->devid, in btrfs_dev_replace_kthread()
1263 btrfs_dev_name(dev_replace->tgtdev), in btrfs_dev_replace_kthread()
1266 ret = btrfs_scrub_dev(fs_info, dev_replace->srcdev->devid, in btrfs_dev_replace_kthread()
1267 dev_replace->committed_cursor_left, in btrfs_dev_replace_kthread()
1268 btrfs_device_get_total_bytes(dev_replace->srcdev), in btrfs_dev_replace_kthread()
1269 &dev_replace->scrub_progress, 0, 1); in btrfs_dev_replace_kthread()
1277 int __pure btrfs_dev_replace_is_ongoing(struct btrfs_dev_replace *dev_replace) in btrfs_dev_replace_is_ongoing() argument
1279 if (!dev_replace->is_valid) in btrfs_dev_replace_is_ongoing()
1282 switch (dev_replace->replace_state) { in btrfs_dev_replace_is_ongoing()
1306 percpu_counter_sub(&fs_info->dev_replace.bio_counter, amount); in btrfs_bio_counter_sub()
1307 cond_wake_up_nomb(&fs_info->dev_replace.replace_wait); in btrfs_bio_counter_sub()
1313 percpu_counter_inc(&fs_info->dev_replace.bio_counter); in btrfs_bio_counter_inc_blocked()
1319 wait_event(fs_info->dev_replace.replace_wait, in btrfs_bio_counter_inc_blocked()