2 * Copyright (C) 2012 STRATO. All rights reserved.
4 * This program is free software; you can redistribute it and/or
5 * modify it under the terms of the GNU General Public
6 * License v2 as published by the Free Software Foundation.
8 * This program is distributed in the hope that it will be useful,
9 * but WITHOUT ANY WARRANTY; without even the implied warranty of
10 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
11 * General Public License for more details.
13 * You should have received a copy of the GNU General Public
14 * License along with this program; if not, write to the
15 * Free Software Foundation, Inc., 59 Temple Place - Suite 330,
16 * Boston, MA 021110-1307, USA.
24 #include <sys/ioctl.h>
32 #include "kerncompat.h"
42 static int print_replace_status(int fd
, const char *path
, int once
);
43 static char *time2string(char *buf
, size_t s
, __u64 t
);
44 static char *progress2string(char *buf
, size_t s
, int progress_1000
);
47 static const char *replace_dev_result2string(__u64 result
)
50 case BTRFS_IOCTL_DEV_REPLACE_RESULT_NO_ERROR
:
52 case BTRFS_IOCTL_DEV_REPLACE_RESULT_NOT_STARTED
:
54 case BTRFS_IOCTL_DEV_REPLACE_RESULT_ALREADY_STARTED
:
55 return "already started";
57 return "<illegal result value>";
61 static const char * const replace_cmd_group_usage
[] = {
62 "btrfs replace <command> [<args>]",
66 static int is_numerical(const char *str
)
68 if (!(*str
>= '0' && *str
<= '9'))
70 while (*str
>= '0' && *str
<= '9')
77 static int dev_replace_cancel_fd
= -1;
78 static void dev_replace_sigint_handler(int signal
)
81 struct btrfs_ioctl_dev_replace_args args
= {0};
83 args
.cmd
= BTRFS_IOCTL_DEV_REPLACE_CMD_CANCEL
;
84 ret
= ioctl(dev_replace_cancel_fd
, BTRFS_IOC_DEV_REPLACE
, &args
);
86 perror("Device replace cancel failed");
89 static int dev_replace_handle_sigint(int fd
)
91 struct sigaction sa
= {
92 .sa_handler
= fd
== -1 ? SIG_DFL
: dev_replace_sigint_handler
95 dev_replace_cancel_fd
= fd
;
96 return sigaction(SIGINT
, &sa
, NULL
);
99 static const char *const cmd_start_replace_usage
[] = {
100 "btrfs replace start [-Bfr] <srcdev>|<devid> <targetdev> <mount_point>",
101 "Replace device of a btrfs filesystem.",
102 "On a live filesystem, duplicate the data to the target device which",
103 "is currently stored on the source device. If the source device is not",
104 "available anymore, or if the -r option is set, the data is built",
105 "only using the RAID redundancy mechanisms. After completion of the",
106 "operation, the source device is removed from the filesystem.",
107 "If the <srcdev> is a numerical value, it is assumed to be the device id",
108 "of the filesystem which is mounted at <mount_point>, otherwise it is",
109 "the path to the source device. If the source device is disconnected,",
110 "from the system, you have to use the <devid> parameter format.",
111 "The <targetdev> needs to be same size or larger than the <srcdev>.",
113 "-r only read from <srcdev> if no other zero-defect mirror exists",
114 " (enable this if your drive has lots of read errors, the access",
115 " would be very slow)",
116 "-f force using and overwriting <targetdev> even if it looks like",
117 " containing a valid btrfs filesystem. A valid filesystem is",
118 " assumed if a btrfs superblock is found which contains a",
119 " correct checksum. Devices which are currently mounted are",
120 " never allowed to be used as the <targetdev>",
121 "-B do not background",
125 static int cmd_start_replace(int argc
, char **argv
)
127 struct btrfs_ioctl_dev_replace_args start_args
= {0};
128 struct btrfs_ioctl_dev_replace_args status_args
= {0};
138 int avoid_reading_from_srcdev
= 0;
139 int force_using_targetdev
= 0;
141 u64 dstdev_block_count
;
142 int do_not_background
= 0;
144 DIR *dirstream
= NULL
;
145 char estr
[100]; /* check test_dev_for_mkfs() for error string size*/
147 while ((c
= getopt(argc
, argv
, "Brf")) != -1) {
150 do_not_background
= 1;
153 avoid_reading_from_srcdev
= 1;
156 force_using_targetdev
= 1;
160 usage(cmd_start_replace_usage
);
164 start_args
.start
.cont_reading_from_srcdev_mode
=
165 avoid_reading_from_srcdev
?
166 BTRFS_IOCTL_DEV_REPLACE_CONT_READING_FROM_SRCDEV_MODE_AVOID
:
167 BTRFS_IOCTL_DEV_REPLACE_CONT_READING_FROM_SRCDEV_MODE_ALWAYS
;
168 if (check_argc_exact(argc
- optind
, 3))
169 usage(cmd_start_replace_usage
);
170 path
= argv
[optind
+ 2];
172 fdmnt
= open_path_or_dev_mnt(path
, &dirstream
);
177 "ERROR: '%s' is not a mounted btrfs device\n",
180 fprintf(stderr
, "ERROR: can't access '%s': %s\n",
181 path
, strerror(errno
));
182 goto leave_with_error
;
185 /* check for possible errors before backgrounding */
186 status_args
.cmd
= BTRFS_IOCTL_DEV_REPLACE_CMD_STATUS
;
187 ret
= ioctl(fdmnt
, BTRFS_IOC_DEV_REPLACE
, &status_args
);
190 "ERROR: ioctl(DEV_REPLACE_STATUS) failed on \"%s\": %s, %s\n",
191 path
, strerror(errno
),
192 replace_dev_result2string(status_args
.result
));
193 goto leave_with_error
;
196 if (status_args
.result
!= BTRFS_IOCTL_DEV_REPLACE_RESULT_NO_ERROR
) {
198 "ERROR: ioctl(DEV_REPLACE_STATUS) on \"%s\" returns error: %s\n",
199 path
, replace_dev_result2string(status_args
.result
));
200 goto leave_with_error
;
203 if (status_args
.status
.replace_state
==
204 BTRFS_IOCTL_DEV_REPLACE_STATE_STARTED
) {
206 "ERROR: btrfs replace on \"%s\" already started!\n",
208 goto leave_with_error
;
211 srcdev
= argv
[optind
];
212 dstdev
= canonicalize_path(argv
[optind
+ 1]);
215 "ERROR: Could not canonicalize path '%s': %s\n",
216 argv
[optind
+ 1], strerror(errno
));
217 goto leave_with_error
;
220 if (is_numerical(srcdev
)) {
221 struct btrfs_ioctl_fs_info_args fi_args
;
222 struct btrfs_ioctl_dev_info_args
*di_args
= NULL
;
224 start_args
.start
.srcdevid
= arg_strtou64(srcdev
);
226 ret
= get_fs_info(path
, &fi_args
, &di_args
);
228 fprintf(stderr
, "ERROR: getting dev info for devstats failed: "
229 "%s\n", strerror(-ret
));
231 goto leave_with_error
;
233 if (!fi_args
.num_devices
) {
234 fprintf(stderr
, "ERROR: no devices found\n");
236 goto leave_with_error
;
239 for (i
= 0; i
< fi_args
.num_devices
; i
++)
240 if (start_args
.start
.srcdevid
== di_args
[i
].devid
)
243 if (i
== fi_args
.num_devices
) {
244 fprintf(stderr
, "Error: '%s' is not a valid devid for filesystem '%s'\n",
246 goto leave_with_error
;
249 fdsrcdev
= open(srcdev
, O_RDWR
);
251 fprintf(stderr
, "Error: Unable to open device '%s'\n",
253 fprintf(stderr
, "\tTry using the devid instead of the path\n");
254 goto leave_with_error
;
256 ret
= fstat(fdsrcdev
, &st
);
258 fprintf(stderr
, "Error: Unable to stat '%s'\n", srcdev
);
259 goto leave_with_error
;
261 if (!S_ISBLK(st
.st_mode
)) {
262 fprintf(stderr
, "Error: '%s' is not a block device\n",
264 goto leave_with_error
;
266 strncpy((char *)start_args
.start
.srcdev_name
, srcdev
,
267 BTRFS_DEVICE_PATH_NAME_MAX
);
270 start_args
.start
.srcdevid
= 0;
273 ret
= test_dev_for_mkfs(dstdev
, force_using_targetdev
, estr
);
275 fprintf(stderr
, "%s", estr
);
276 goto leave_with_error
;
278 fddstdev
= open(dstdev
, O_RDWR
);
280 fprintf(stderr
, "Unable to open %s\n", dstdev
);
281 goto leave_with_error
;
283 strncpy((char *)start_args
.start
.tgtdev_name
, dstdev
,
284 BTRFS_DEVICE_PATH_NAME_MAX
);
285 ret
= btrfs_prepare_device(fddstdev
, dstdev
, 1, &dstdev_block_count
, 0,
288 goto leave_with_error
;
295 dev_replace_handle_sigint(fdmnt
);
296 if (!do_not_background
) {
297 if (daemon(0, 0) < 0) {
298 fprintf(stderr
, "ERROR, backgrounding failed: %s\n",
300 goto leave_with_error
;
304 start_args
.cmd
= BTRFS_IOCTL_DEV_REPLACE_CMD_START
;
305 ret
= ioctl(fdmnt
, BTRFS_IOC_DEV_REPLACE
, &start_args
);
306 if (do_not_background
) {
309 "ERROR: ioctl(DEV_REPLACE_START) failed on \"%s\": %s, %s\n",
310 path
, strerror(errno
),
311 replace_dev_result2string(start_args
.result
));
313 if (errno
== EOPNOTSUPP
)
315 "WARNING: dev_replace does not yet handle RAID5/6\n");
317 goto leave_with_error
;
320 if (start_args
.result
!=
321 BTRFS_IOCTL_DEV_REPLACE_RESULT_NO_ERROR
) {
323 "ERROR: ioctl(DEV_REPLACE_START) on \"%s\" returns error: %s\n",
325 replace_dev_result2string(start_args
.result
));
326 goto leave_with_error
;
329 close_file_or_dir(fdmnt
, dirstream
);
344 static const char *const cmd_status_replace_usage
[] = {
345 "btrfs replace status [-1] <mount_point>",
346 "Print status and progress information of a running device replace",
349 "-1 print once instead of print continuously until the replace",
350 " operation finishes (or is canceled)",
354 static int cmd_status_replace(int argc
, char **argv
)
362 DIR *dirstream
= NULL
;
364 while ((c
= getopt(argc
, argv
, "1")) != -1) {
371 usage(cmd_status_replace_usage
);
375 if (check_argc_exact(argc
- optind
, 1))
376 usage(cmd_status_replace_usage
);
379 fd
= open_file_or_dir(path
, &dirstream
);
382 fprintf(stderr
, "ERROR: can't access \"%s\": %s\n",
387 ret
= print_replace_status(fd
, path
, once
);
388 close_file_or_dir(fd
, dirstream
);
392 static int print_replace_status(int fd
, const char *path
, int once
)
394 struct btrfs_ioctl_dev_replace_args args
= {0};
395 struct btrfs_ioctl_dev_replace_status_params
*status
;
397 int prevent_loop
= 0;
405 args
.cmd
= BTRFS_IOCTL_DEV_REPLACE_CMD_STATUS
;
406 ret
= ioctl(fd
, BTRFS_IOC_DEV_REPLACE
, &args
);
408 fprintf(stderr
, "ERROR: ioctl(DEV_REPLACE_STATUS) failed on \"%s\": %s, %s\n",
409 path
, strerror(errno
),
410 replace_dev_result2string(args
.result
));
414 status
= &args
.status
;
415 if (args
.result
!= BTRFS_IOCTL_DEV_REPLACE_RESULT_NO_ERROR
) {
416 fprintf(stderr
, "ERROR: ioctl(DEV_REPLACE_STATUS) on \"%s\" returns error: %s\n",
418 replace_dev_result2string(args
.result
));
424 switch (status
->replace_state
) {
425 case BTRFS_IOCTL_DEV_REPLACE_STATE_STARTED
:
428 progress2string(string3
,
430 status
->progress_1000
));
432 case BTRFS_IOCTL_DEV_REPLACE_STATE_FINISHED
:
434 printf("Started on %s, finished on %s",
435 time2string(string1
, sizeof(string1
),
436 status
->time_started
),
437 time2string(string2
, sizeof(string2
),
438 status
->time_stopped
));
440 case BTRFS_IOCTL_DEV_REPLACE_STATE_CANCELED
:
442 printf("Started on %s, canceled on %s at %s",
443 time2string(string1
, sizeof(string1
),
444 status
->time_started
),
445 time2string(string2
, sizeof(string2
),
446 status
->time_stopped
),
447 progress2string(string3
, sizeof(string3
),
448 status
->progress_1000
));
450 case BTRFS_IOCTL_DEV_REPLACE_STATE_SUSPENDED
:
452 printf("Started on %s, suspended on %s at %s",
453 time2string(string1
, sizeof(string1
),
454 status
->time_started
),
455 time2string(string2
, sizeof(string2
),
456 status
->time_stopped
),
457 progress2string(string3
, sizeof(string3
),
458 status
->progress_1000
));
460 case BTRFS_IOCTL_DEV_REPLACE_STATE_NEVER_STARTED
:
463 printf("Never started");
468 "Unknown btrfs dev replace status:%llu",
469 status
->replace_state
);
476 ", %llu write errs, %llu uncorr. read errs",
477 (unsigned long long)status
->num_write_errors
,
479 status
->num_uncorrectable_read_errors
);
480 if (once
|| prevent_loop
|| ret
) {
487 while (num_chars
> 0) {
497 time2string(char *buf
, size_t s
, __u64 t
)
502 t_time_t
= (time_t)t
;
503 assert((__u64
)t_time_t
== t
);
504 localtime_r(&t_time_t
, &t_tm
);
505 strftime(buf
, s
, "%e.%b %T", &t_tm
);
510 progress2string(char *buf
, size_t s
, int progress_1000
)
512 snprintf(buf
, s
, "%d.%01d%%", progress_1000
/ 10, progress_1000
% 10);
518 static const char *const cmd_cancel_replace_usage
[] = {
519 "btrfs replace cancel <mount_point>",
520 "Cancel a running device replace operation.",
524 static int cmd_cancel_replace(int argc
, char **argv
)
526 struct btrfs_ioctl_dev_replace_args args
= {0};
532 DIR *dirstream
= NULL
;
534 while ((c
= getopt(argc
, argv
, "")) != -1) {
538 usage(cmd_cancel_replace_usage
);
542 if (check_argc_exact(argc
- optind
, 1))
543 usage(cmd_cancel_replace_usage
);
546 fd
= open_file_or_dir(path
, &dirstream
);
548 fprintf(stderr
, "ERROR: can't access \"%s\": %s\n",
549 path
, strerror(errno
));
553 args
.cmd
= BTRFS_IOCTL_DEV_REPLACE_CMD_CANCEL
;
554 ret
= ioctl(fd
, BTRFS_IOC_DEV_REPLACE
, &args
);
556 close_file_or_dir(fd
, dirstream
);
558 fprintf(stderr
, "ERROR: ioctl(DEV_REPLACE_CANCEL) failed on \"%s\": %s, %s\n",
560 replace_dev_result2string(args
.result
));
563 if (args
.result
== BTRFS_IOCTL_DEV_REPLACE_RESULT_NOT_STARTED
) {
564 printf("INFO: ioctl(DEV_REPLACE_CANCEL)\"%s\": %s\n",
565 path
, replace_dev_result2string(args
.result
));
571 const struct cmd_group replace_cmd_group
= {
572 replace_cmd_group_usage
, NULL
, {
573 { "start", cmd_start_replace
, cmd_start_replace_usage
, NULL
,
575 { "status", cmd_status_replace
, cmd_status_replace_usage
, NULL
,
577 { "cancel", cmd_cancel_replace
, cmd_cancel_replace_usage
, NULL
,
583 int cmd_replace(int argc
, char **argv
)
585 return handle_command_group(&replace_cmd_group
, argc
, argv
);