78 	struct btrfs_dev_replace *dev_replace = &fs_info->dev_replace;  in btrfs_init_dev_replace()  local
113 		dev_replace->replace_state =  in btrfs_init_dev_replace()
115 		dev_replace->cont_reading_from_srcdev_mode =  in btrfs_init_dev_replace()
117 		dev_replace->time_started = 0;  in btrfs_init_dev_replace()
118 		dev_replace->time_stopped = 0;  in btrfs_init_dev_replace()
119 		atomic64_set(&dev_replace->num_write_errors, 0);  in btrfs_init_dev_replace()
120 		atomic64_set(&dev_replace->num_uncorrectable_read_errors, 0);  in btrfs_init_dev_replace()
121 		dev_replace->cursor_left = 0;  in btrfs_init_dev_replace()
122 		dev_replace->committed_cursor_left = 0;  in btrfs_init_dev_replace()
123 		dev_replace->cursor_left_last_write_of_item = 0;  in btrfs_init_dev_replace()
124 		dev_replace->cursor_right = 0;  in btrfs_init_dev_replace()
125 		dev_replace->srcdev = NULL;  in btrfs_init_dev_replace()
126 		dev_replace->tgtdev = NULL;  in btrfs_init_dev_replace()
127 		dev_replace->is_valid = 0;  in btrfs_init_dev_replace()
128 		dev_replace->item_needs_writeback = 0;  in btrfs_init_dev_replace()
143 	dev_replace->cont_reading_from_srcdev_mode =  in btrfs_init_dev_replace()
145 	dev_replace->replace_state = btrfs_dev_replace_replace_state(eb, ptr);  in btrfs_init_dev_replace()
146 	dev_replace->time_started = btrfs_dev_replace_time_started(eb, ptr);  in btrfs_init_dev_replace()
147 	dev_replace->time_stopped =  in btrfs_init_dev_replace()
149 	atomic64_set(&dev_replace->num_write_errors,  in btrfs_init_dev_replace()
151 	atomic64_set(&dev_replace->num_uncorrectable_read_errors,  in btrfs_init_dev_replace()
153 	dev_replace->cursor_left = btrfs_dev_replace_cursor_left(eb, ptr);  in btrfs_init_dev_replace()
154 	dev_replace->committed_cursor_left = dev_replace->cursor_left;  in btrfs_init_dev_replace()
155 	dev_replace->cursor_left_last_write_of_item = dev_replace->cursor_left;  in btrfs_init_dev_replace()
156 	dev_replace->cursor_right = btrfs_dev_replace_cursor_right(eb, ptr);  in btrfs_init_dev_replace()
157 	dev_replace->is_valid = 1;  in btrfs_init_dev_replace()
159 	dev_replace->item_needs_writeback = 0;  in btrfs_init_dev_replace()
160 	switch (dev_replace->replace_state) {  in btrfs_init_dev_replace()
173 			dev_replace->srcdev = NULL;  in btrfs_init_dev_replace()
174 			dev_replace->tgtdev = NULL;  in btrfs_init_dev_replace()
179 		dev_replace->tgtdev = btrfs_find_device(fs_info->fs_devices, &args);  in btrfs_init_dev_replace()
181 		dev_replace->srcdev = btrfs_find_device(fs_info->fs_devices, &args);  in btrfs_init_dev_replace()
187 		if (!dev_replace->srcdev &&  in btrfs_init_dev_replace()
196 		if (!dev_replace->tgtdev &&  in btrfs_init_dev_replace()
205 		if (dev_replace->tgtdev) {  in btrfs_init_dev_replace()
206 			if (dev_replace->srcdev) {  in btrfs_init_dev_replace()
207 				dev_replace->tgtdev->total_bytes =  in btrfs_init_dev_replace()
208 					dev_replace->srcdev->total_bytes;  in btrfs_init_dev_replace()
209 				dev_replace->tgtdev->disk_total_bytes =  in btrfs_init_dev_replace()
210 					dev_replace->srcdev->disk_total_bytes;  in btrfs_init_dev_replace()
211 				dev_replace->tgtdev->commit_total_bytes =  in btrfs_init_dev_replace()
212 					dev_replace->srcdev->commit_total_bytes;  in btrfs_init_dev_replace()
213 				dev_replace->tgtdev->bytes_used =  in btrfs_init_dev_replace()
214 					dev_replace->srcdev->bytes_used;  in btrfs_init_dev_replace()
215 				dev_replace->tgtdev->commit_bytes_used =  in btrfs_init_dev_replace()
216 					dev_replace->srcdev->commit_bytes_used;  in btrfs_init_dev_replace()
219 				&dev_replace->tgtdev->dev_state);  in btrfs_init_dev_replace()
222 			dev_replace->tgtdev->io_width = fs_info->sectorsize;  in btrfs_init_dev_replace()
223 			dev_replace->tgtdev->io_align = fs_info->sectorsize;  in btrfs_init_dev_replace()
224 			dev_replace->tgtdev->sector_size = fs_info->sectorsize;  in btrfs_init_dev_replace()
225 			dev_replace->tgtdev->fs_info = fs_info;  in btrfs_init_dev_replace()
227 				&dev_replace->tgtdev->dev_state);  in btrfs_init_dev_replace()
354 	struct btrfs_dev_replace *dev_replace = &fs_info->dev_replace;  in btrfs_run_dev_replace()  local
356 	down_read(&dev_replace->rwsem);  in btrfs_run_dev_replace()
357 	if (!dev_replace->is_valid ||  in btrfs_run_dev_replace()
358 	    !dev_replace->item_needs_writeback) {  in btrfs_run_dev_replace()
359 		up_read(&dev_replace->rwsem);  in btrfs_run_dev_replace()
362 	up_read(&dev_replace->rwsem);  in btrfs_run_dev_replace()
420 	down_write(&dev_replace->rwsem);  in btrfs_run_dev_replace()
421 	if (dev_replace->srcdev)  in btrfs_run_dev_replace()
423 			dev_replace->srcdev->devid);  in btrfs_run_dev_replace()
427 		dev_replace->cont_reading_from_srcdev_mode);  in btrfs_run_dev_replace()
429 		dev_replace->replace_state);  in btrfs_run_dev_replace()
430 	btrfs_set_dev_replace_time_started(eb, ptr, dev_replace->time_started);  in btrfs_run_dev_replace()
431 	btrfs_set_dev_replace_time_stopped(eb, ptr, dev_replace->time_stopped);  in btrfs_run_dev_replace()
433 		atomic64_read(&dev_replace->num_write_errors));  in btrfs_run_dev_replace()
435 		atomic64_read(&dev_replace->num_uncorrectable_read_errors));  in btrfs_run_dev_replace()
436 	dev_replace->cursor_left_last_write_of_item =  in btrfs_run_dev_replace()
437 		dev_replace->cursor_left;  in btrfs_run_dev_replace()
439 		dev_replace->cursor_left_last_write_of_item);  in btrfs_run_dev_replace()
441 		dev_replace->cursor_right);  in btrfs_run_dev_replace()
442 	dev_replace->item_needs_writeback = 0;  in btrfs_run_dev_replace()
443 	up_write(&dev_replace->rwsem);  in btrfs_run_dev_replace()
607 	struct btrfs_dev_replace *dev_replace = &fs_info->dev_replace;  in btrfs_dev_replace_start()  local
646 	down_write(&dev_replace->rwsem);  in btrfs_dev_replace_start()
647 	switch (dev_replace->replace_state) {  in btrfs_dev_replace_start()
656 		up_write(&dev_replace->rwsem);  in btrfs_dev_replace_start()
660 	dev_replace->cont_reading_from_srcdev_mode = read_src;  in btrfs_dev_replace_start()
661 	dev_replace->srcdev = src_device;  in btrfs_dev_replace_start()
662 	dev_replace->tgtdev = tgt_device;  in btrfs_dev_replace_start()
674 	dev_replace->replace_state = BTRFS_IOCTL_DEV_REPLACE_STATE_STARTED;  in btrfs_dev_replace_start()
675 	dev_replace->time_started = ktime_get_real_seconds();  in btrfs_dev_replace_start()
676 	dev_replace->cursor_left = 0;  in btrfs_dev_replace_start()
677 	dev_replace->committed_cursor_left = 0;  in btrfs_dev_replace_start()
678 	dev_replace->cursor_left_last_write_of_item = 0;  in btrfs_dev_replace_start()
679 	dev_replace->cursor_right = 0;  in btrfs_dev_replace_start()
680 	dev_replace->is_valid = 1;  in btrfs_dev_replace_start()
681 	dev_replace->item_needs_writeback = 1;  in btrfs_dev_replace_start()
682 	atomic64_set(&dev_replace->num_write_errors, 0);  in btrfs_dev_replace_start()
683 	atomic64_set(&dev_replace->num_uncorrectable_read_errors, 0);  in btrfs_dev_replace_start()
684 	up_write(&dev_replace->rwsem);  in btrfs_dev_replace_start()
701 		down_write(&dev_replace->rwsem);  in btrfs_dev_replace_start()
702 		dev_replace->replace_state =  in btrfs_dev_replace_start()
704 		dev_replace->srcdev = NULL;  in btrfs_dev_replace_start()
705 		dev_replace->tgtdev = NULL;  in btrfs_dev_replace_start()
706 		up_write(&dev_replace->rwsem);  in btrfs_dev_replace_start()
716 			      &dev_replace->scrub_progress, 0, 1);  in btrfs_dev_replace_start()
765 	wait_event(fs_info->dev_replace.replace_wait, !percpu_counter_sum(  in btrfs_rm_dev_replace_blocked()
766 		   &fs_info->dev_replace.bio_counter));  in btrfs_rm_dev_replace_blocked()
775 	wake_up(&fs_info->dev_replace.replace_wait);  in btrfs_rm_dev_replace_unblocked()
838 	struct btrfs_dev_replace *dev_replace = &fs_info->dev_replace;  in btrfs_dev_replace_finishing()  local
848 	mutex_lock(&dev_replace->lock_finishing_cancel_unmount);  in btrfs_dev_replace_finishing()
850 	down_read(&dev_replace->rwsem);  in btrfs_dev_replace_finishing()
852 	if (dev_replace->replace_state !=  in btrfs_dev_replace_finishing()
854 		up_read(&dev_replace->rwsem);  in btrfs_dev_replace_finishing()
855 		mutex_unlock(&dev_replace->lock_finishing_cancel_unmount);  in btrfs_dev_replace_finishing()
859 	tgt_device = dev_replace->tgtdev;  in btrfs_dev_replace_finishing()
860 	src_device = dev_replace->srcdev;  in btrfs_dev_replace_finishing()
861 	up_read(&dev_replace->rwsem);  in btrfs_dev_replace_finishing()
869 		mutex_unlock(&dev_replace->lock_finishing_cancel_unmount);  in btrfs_dev_replace_finishing()
882 			mutex_unlock(&dev_replace->lock_finishing_cancel_unmount);  in btrfs_dev_replace_finishing()
901 	down_write(&dev_replace->rwsem);  in btrfs_dev_replace_finishing()
902 	dev_replace->replace_state =  in btrfs_dev_replace_finishing()
905 	dev_replace->tgtdev = NULL;  in btrfs_dev_replace_finishing()
906 	dev_replace->srcdev = NULL;  in btrfs_dev_replace_finishing()
907 	dev_replace->time_stopped = ktime_get_real_seconds();  in btrfs_dev_replace_finishing()
908 	dev_replace->item_needs_writeback = 1;  in btrfs_dev_replace_finishing()
929 		up_write(&dev_replace->rwsem);  in btrfs_dev_replace_finishing()
936 		mutex_unlock(&dev_replace->lock_finishing_cancel_unmount);  in btrfs_dev_replace_finishing()
963 	up_write(&dev_replace->rwsem);  in btrfs_dev_replace_finishing()
998 	mutex_unlock(&dev_replace->lock_finishing_cancel_unmount);  in btrfs_dev_replace_finishing()
1012 	struct btrfs_dev_replace *dev_replace = &fs_info->dev_replace;  in btrfs_dev_replace_progress()  local
1015 	switch (dev_replace->replace_state) {  in btrfs_dev_replace_progress()
1025 		ret = div64_u64(dev_replace->cursor_left,  in btrfs_dev_replace_progress()
1027 						dev_replace->srcdev), 1000));  in btrfs_dev_replace_progress()
1037 	struct btrfs_dev_replace *dev_replace = &fs_info->dev_replace;  in btrfs_dev_replace_status()  local
1039 	down_read(&dev_replace->rwsem);  in btrfs_dev_replace_status()
1043 	args->status.replace_state = dev_replace->replace_state;  in btrfs_dev_replace_status()
1044 	args->status.time_started = dev_replace->time_started;  in btrfs_dev_replace_status()
1045 	args->status.time_stopped = dev_replace->time_stopped;  in btrfs_dev_replace_status()
1047 		atomic64_read(&dev_replace->num_write_errors);  in btrfs_dev_replace_status()
1049 		atomic64_read(&dev_replace->num_uncorrectable_read_errors);  in btrfs_dev_replace_status()
1051 	up_read(&dev_replace->rwsem);  in btrfs_dev_replace_status()
1056 	struct btrfs_dev_replace *dev_replace = &fs_info->dev_replace;  in btrfs_dev_replace_cancel()  local
1067 	mutex_lock(&dev_replace->lock_finishing_cancel_unmount);  in btrfs_dev_replace_cancel()
1068 	down_write(&dev_replace->rwsem);  in btrfs_dev_replace_cancel()
1069 	switch (dev_replace->replace_state) {  in btrfs_dev_replace_cancel()
1074 		up_write(&dev_replace->rwsem);  in btrfs_dev_replace_cancel()
1077 		tgt_device = dev_replace->tgtdev;  in btrfs_dev_replace_cancel()
1078 		src_device = dev_replace->srcdev;  in btrfs_dev_replace_cancel()
1079 		up_write(&dev_replace->rwsem);  in btrfs_dev_replace_cancel()
1101 		tgt_device = dev_replace->tgtdev;  in btrfs_dev_replace_cancel()
1102 		src_device = dev_replace->srcdev;  in btrfs_dev_replace_cancel()
1103 		dev_replace->tgtdev = NULL;  in btrfs_dev_replace_cancel()
1104 		dev_replace->srcdev = NULL;  in btrfs_dev_replace_cancel()
1105 		dev_replace->replace_state =  in btrfs_dev_replace_cancel()
1107 		dev_replace->time_stopped = ktime_get_real_seconds();  in btrfs_dev_replace_cancel()
1108 		dev_replace->item_needs_writeback = 1;  in btrfs_dev_replace_cancel()
1110 		up_write(&dev_replace->rwsem);  in btrfs_dev_replace_cancel()
1117 			mutex_unlock(&dev_replace->lock_finishing_cancel_unmount);  in btrfs_dev_replace_cancel()
1132 		up_write(&dev_replace->rwsem);  in btrfs_dev_replace_cancel()
1136 	mutex_unlock(&dev_replace->lock_finishing_cancel_unmount);  in btrfs_dev_replace_cancel()
1142 	struct btrfs_dev_replace *dev_replace = &fs_info->dev_replace;  in btrfs_dev_replace_suspend_for_unmount()  local
1144 	mutex_lock(&dev_replace->lock_finishing_cancel_unmount);  in btrfs_dev_replace_suspend_for_unmount()
1145 	down_write(&dev_replace->rwsem);  in btrfs_dev_replace_suspend_for_unmount()
1147 	switch (dev_replace->replace_state) {  in btrfs_dev_replace_suspend_for_unmount()
1154 		dev_replace->replace_state =  in btrfs_dev_replace_suspend_for_unmount()
1156 		dev_replace->time_stopped = ktime_get_real_seconds();  in btrfs_dev_replace_suspend_for_unmount()
1157 		dev_replace->item_needs_writeback = 1;  in btrfs_dev_replace_suspend_for_unmount()
1162 	up_write(&dev_replace->rwsem);  in btrfs_dev_replace_suspend_for_unmount()
1163 	mutex_unlock(&dev_replace->lock_finishing_cancel_unmount);  in btrfs_dev_replace_suspend_for_unmount()
1170 	struct btrfs_dev_replace *dev_replace = &fs_info->dev_replace;  in btrfs_resume_dev_replace_async()  local
1172 	down_write(&dev_replace->rwsem);  in btrfs_resume_dev_replace_async()
1174 	switch (dev_replace->replace_state) {  in btrfs_resume_dev_replace_async()
1178 		up_write(&dev_replace->rwsem);  in btrfs_resume_dev_replace_async()
1183 		dev_replace->replace_state =  in btrfs_resume_dev_replace_async()
1187 	if (!dev_replace->tgtdev || !dev_replace->tgtdev->bdev) {  in btrfs_resume_dev_replace_async()
1192 		dev_replace->replace_state =  in btrfs_resume_dev_replace_async()
1194 		up_write(&dev_replace->rwsem);  in btrfs_resume_dev_replace_async()
1197 	up_write(&dev_replace->rwsem);  in btrfs_resume_dev_replace_async()
1205 		down_write(&dev_replace->rwsem);  in btrfs_resume_dev_replace_async()
1206 		dev_replace->replace_state =  in btrfs_resume_dev_replace_async()
1208 		up_write(&dev_replace->rwsem);  in btrfs_resume_dev_replace_async()
1221 	struct btrfs_dev_replace *dev_replace = &fs_info->dev_replace;  in btrfs_dev_replace_kthread()  local
1229 		btrfs_dev_name(dev_replace->srcdev),  in btrfs_dev_replace_kthread()
1230 		dev_replace->srcdev->devid,  in btrfs_dev_replace_kthread()
1231 		btrfs_dev_name(dev_replace->tgtdev),  in btrfs_dev_replace_kthread()
1234 	ret = btrfs_scrub_dev(fs_info, dev_replace->srcdev->devid,  in btrfs_dev_replace_kthread()
1235 			      dev_replace->committed_cursor_left,  in btrfs_dev_replace_kthread()
1236 			      btrfs_device_get_total_bytes(dev_replace->srcdev),  in btrfs_dev_replace_kthread()
1237 			      &dev_replace->scrub_progress, 0, 1);  in btrfs_dev_replace_kthread()
1245 int __pure btrfs_dev_replace_is_ongoing(struct btrfs_dev_replace *dev_replace)  in btrfs_dev_replace_is_ongoing()  argument
1247 	if (!dev_replace->is_valid)  in btrfs_dev_replace_is_ongoing()
1250 	switch (dev_replace->replace_state) {  in btrfs_dev_replace_is_ongoing()
1274 	percpu_counter_sub(&fs_info->dev_replace.bio_counter, amount);  in btrfs_bio_counter_sub()
1275 	cond_wake_up_nomb(&fs_info->dev_replace.replace_wait);  in btrfs_bio_counter_sub()
1281 		percpu_counter_inc(&fs_info->dev_replace.bio_counter);  in btrfs_bio_counter_inc_blocked()
1287 		wait_event(fs_info->dev_replace.replace_wait,  in btrfs_bio_counter_inc_blocked()