2 * Copyright (C) 2011 Red Hat. 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.
20 #include "kerncompat.h"
28 #include <sys/types.h>
29 #include <lzo/lzoconf.h>
30 #include <lzo/lzo1x.h>
37 #include <sys/types.h>
38 #include <sys/xattr.h>
42 #include "print-tree.h"
43 #include "transaction.h"
50 static char fs_name
[PATH_MAX
];
51 static char path_name
[PATH_MAX
];
52 static char symlink_target
[PATH_MAX
];
53 static int get_snaps
= 0;
54 static int verbose
= 0;
55 static int restore_metadata
= 0;
56 static int restore_symlinks
= 0;
57 static int ignore_errors
= 0;
58 static int overwrite
= 0;
59 static int get_xattrs
= 0;
60 static int dry_run
= 0;
63 #define lzo1x_worst_compress(x) ((x) + ((x) / 16) + 64 + 3)
65 static int decompress_zlib(char *inbuf
, char *outbuf
, u64 compress_len
,
71 memset(&strm
, 0, sizeof(strm
));
72 ret
= inflateInit(&strm
);
74 error("zlib init returned %d", ret
);
78 strm
.avail_in
= compress_len
;
79 strm
.next_in
= (unsigned char *)inbuf
;
80 strm
.avail_out
= decompress_len
;
81 strm
.next_out
= (unsigned char *)outbuf
;
82 ret
= inflate(&strm
, Z_NO_FLUSH
);
83 if (ret
!= Z_STREAM_END
) {
84 (void)inflateEnd(&strm
);
85 error("zlib inflate failed: %d", ret
);
89 (void)inflateEnd(&strm
);
92 static inline size_t read_compress_length(unsigned char *buf
)
95 memcpy(&dlen
, buf
, LZO_LEN
);
96 return le32_to_cpu(dlen
);
99 static int decompress_lzo(struct btrfs_root
*root
, unsigned char *inbuf
,
100 char *outbuf
, u64 compress_len
, u64
*decompress_len
)
110 if (ret
!= LZO_E_OK
) {
111 error("lzo init returned %d", ret
);
115 tot_len
= read_compress_length(inbuf
);
119 while (tot_in
< tot_len
) {
122 in_len
= read_compress_length(inbuf
);
124 if ((tot_in
+ LZO_LEN
+ in_len
) > tot_len
) {
125 error("bad compress length %lu",
126 (unsigned long)in_len
);
132 new_len
= lzo1x_worst_compress(root
->fs_info
->sectorsize
);
133 ret
= lzo1x_decompress_safe((const unsigned char *)inbuf
, in_len
,
134 (unsigned char *)outbuf
,
135 (void *)&new_len
, NULL
);
136 if (ret
!= LZO_E_OK
) {
137 error("lzo decompress failed: %d", ret
);
146 * If the 4 byte header does not fit to the rest of the page we
147 * have to move to the next one, unless we read some garbage
149 mod_page
= tot_in
% root
->fs_info
->sectorsize
;
150 rem_page
= root
->fs_info
->sectorsize
- mod_page
;
151 if (rem_page
< LZO_LEN
) {
157 *decompress_len
= out_len
;
162 static int decompress_zstd(const char *inbuf
, char *outbuf
, u64 compress_len
,
165 #if !BTRFSRESTORE_ZSTD
166 error("btrfs not compiled with zstd support");
172 ZSTD_inBuffer in
= {inbuf
, compress_len
, 0};
173 ZSTD_outBuffer out
= {outbuf
, decompress_len
, 0};
175 strm
= ZSTD_createDStream();
177 error("zstd create failed");
181 zret
= ZSTD_initDStream(strm
);
182 if (ZSTD_isError(zret
)) {
183 error("zstd init failed: %s", ZSTD_getErrorName(zret
));
188 zret
= ZSTD_decompressStream(strm
, &out
, &in
);
189 if (ZSTD_isError(zret
)) {
190 error("zstd decompress failed %s\n", ZSTD_getErrorName(zret
));
195 error("zstd frame incomplete");
201 ZSTD_freeDStream(strm
);
206 static int decompress(struct btrfs_root
*root
, char *inbuf
, char *outbuf
,
207 u64 compress_len
, u64
*decompress_len
, int compress
)
210 case BTRFS_COMPRESS_ZLIB
:
211 return decompress_zlib(inbuf
, outbuf
, compress_len
,
213 case BTRFS_COMPRESS_LZO
:
214 return decompress_lzo(root
, (unsigned char *)inbuf
, outbuf
,
215 compress_len
, decompress_len
);
216 case BTRFS_COMPRESS_ZSTD
:
217 return decompress_zstd(inbuf
, outbuf
, compress_len
,
223 error("invalid compression type: %d", compress
);
227 static int next_leaf(struct btrfs_root
*root
, struct btrfs_path
*path
)
232 struct extent_buffer
*c
;
233 struct extent_buffer
*next
= NULL
;
234 struct btrfs_fs_info
*fs_info
= root
->fs_info
;
237 for (; level
< BTRFS_MAX_LEVEL
; level
++) {
238 if (path
->nodes
[level
])
242 if (level
>= BTRFS_MAX_LEVEL
)
245 slot
= path
->slots
[level
] + 1;
247 while(level
< BTRFS_MAX_LEVEL
) {
248 if (!path
->nodes
[level
])
251 slot
= path
->slots
[level
] + offset
;
252 c
= path
->nodes
[level
];
253 if (slot
>= btrfs_header_nritems(c
)) {
255 if (level
== BTRFS_MAX_LEVEL
)
262 reada_for_search(root
, path
, level
, slot
, 0);
264 next
= read_node_slot(fs_info
, c
, slot
);
265 if (extent_buffer_uptodate(next
))
269 path
->slots
[level
] = slot
;
272 c
= path
->nodes
[level
];
273 free_extent_buffer(c
);
274 path
->nodes
[level
] = next
;
275 path
->slots
[level
] = 0;
279 reada_for_search(root
, path
, level
, 0, 0);
280 next
= read_node_slot(fs_info
, next
, 0);
281 if (!extent_buffer_uptodate(next
))
287 static int copy_one_inline(struct btrfs_root
*root
, int fd
,
288 struct btrfs_path
*path
, u64 pos
)
290 struct extent_buffer
*leaf
= path
->nodes
[0];
291 struct btrfs_file_extent_item
*fi
;
302 fi
= btrfs_item_ptr(leaf
, path
->slots
[0],
303 struct btrfs_file_extent_item
);
304 ptr
= btrfs_file_extent_inline_start(fi
);
305 len
= btrfs_file_extent_ram_bytes(leaf
, fi
);
306 inline_item_len
= btrfs_file_extent_inline_item_len(leaf
, btrfs_item_nr(path
->slots
[0]));
307 read_extent_buffer(leaf
, buf
, ptr
, inline_item_len
);
309 compress
= btrfs_file_extent_compression(leaf
, fi
);
310 if (compress
== BTRFS_COMPRESS_NONE
) {
311 done
= pwrite(fd
, buf
, len
, pos
);
313 fprintf(stderr
, "Short inline write, wanted %d, did "
314 "%zd: %d\n", len
, done
, errno
);
320 ram_size
= btrfs_file_extent_ram_bytes(leaf
, fi
);
321 outbuf
= calloc(1, ram_size
);
323 error("not enough memory");
327 ret
= decompress(root
, buf
, outbuf
, inline_item_len
, &ram_size
,
334 done
= pwrite(fd
, outbuf
, ram_size
, pos
);
336 if (done
< ram_size
) {
337 fprintf(stderr
, "Short compressed inline write, wanted %Lu, "
338 "did %zd: %d\n", ram_size
, done
, errno
);
345 static int copy_one_extent(struct btrfs_root
*root
, int fd
,
346 struct extent_buffer
*leaf
,
347 struct btrfs_file_extent_item
*fi
, u64 pos
)
349 struct btrfs_multi_bio
*multi
= NULL
;
350 struct btrfs_device
*device
;
351 char *inbuf
, *outbuf
= NULL
;
352 ssize_t done
, total
= 0;
368 compress
= btrfs_file_extent_compression(leaf
, fi
);
369 bytenr
= btrfs_file_extent_disk_bytenr(leaf
, fi
);
370 disk_size
= btrfs_file_extent_disk_num_bytes(leaf
, fi
);
371 ram_size
= btrfs_file_extent_ram_bytes(leaf
, fi
);
372 offset
= btrfs_file_extent_offset(leaf
, fi
);
373 num_bytes
= btrfs_file_extent_num_bytes(leaf
, fi
);
374 size_left
= disk_size
;
375 if (compress
== BTRFS_COMPRESS_NONE
)
378 if (verbose
&& offset
)
379 printf("offset is %Lu\n", offset
);
380 /* we found a hole */
384 inbuf
= malloc(size_left
);
386 error("not enough memory");
390 if (compress
!= BTRFS_COMPRESS_NONE
) {
391 outbuf
= calloc(1, ram_size
);
393 error("not enough memory");
400 ret
= btrfs_map_block(root
->fs_info
, READ
, bytenr
, &length
, &multi
,
403 error("cannot map block logical %llu length %llu: %d",
404 (unsigned long long)bytenr
,
405 (unsigned long long)length
, ret
);
408 device
= multi
->stripes
[0].dev
;
411 dev_bytenr
= multi
->stripes
[0].physical
;
414 if (size_left
< length
)
417 done
= pread(dev_fd
, inbuf
+count
, length
, dev_bytenr
);
418 /* Need both checks, or we miss negative values due to u64 conversion */
419 if (done
< 0 || done
< length
) {
420 num_copies
= btrfs_num_copies(root
->fs_info
, bytenr
, length
);
422 /* mirror_num is 1-indexed, so num_copies is a valid mirror. */
423 if (mirror_num
> num_copies
) {
425 error("exhausted mirrors trying to read (%d > %d)",
426 mirror_num
, num_copies
);
429 fprintf(stderr
, "Trying another mirror\n");
440 if (compress
== BTRFS_COMPRESS_NONE
) {
441 while (total
< num_bytes
) {
442 done
= pwrite(fd
, inbuf
+total
, num_bytes
-total
,
446 error("cannot write data: %d %m", errno
);
455 ret
= decompress(root
, inbuf
, outbuf
, disk_size
, &ram_size
, compress
);
457 num_copies
= btrfs_num_copies(root
->fs_info
, bytenr
, length
);
459 if (mirror_num
>= num_copies
) {
463 fprintf(stderr
, "Trying another mirror\n");
467 while (total
< num_bytes
) {
468 done
= pwrite(fd
, outbuf
+ offset
+ total
,
489 static enum loop_response
ask_to_continue(const char *file
)
494 printf("We seem to be looping a lot on %s, do you want to keep going "
495 "on ? (y/N/a): ", file
);
497 ret
= fgets(buf
, 2, stdin
);
498 if (*ret
== '\n' || tolower(*ret
) == 'n')
500 if (tolower(*ret
) == 'a')
502 if (tolower(*ret
) != 'y') {
503 printf("Please enter one of 'y', 'n', or 'a': ");
507 return LOOP_CONTINUE
;
511 static int set_file_xattrs(struct btrfs_root
*root
, u64 inode
,
512 int fd
, const char *file_name
)
514 struct btrfs_key key
;
515 struct btrfs_path path
;
516 struct extent_buffer
*leaf
;
517 struct btrfs_dir_item
*di
;
526 btrfs_init_path(&path
);
527 key
.objectid
= inode
;
528 key
.type
= BTRFS_XATTR_ITEM_KEY
;
530 ret
= btrfs_search_slot(NULL
, root
, &key
, &path
, 0, 0);
534 leaf
= path
.nodes
[0];
536 if (path
.slots
[0] >= btrfs_header_nritems(leaf
)) {
538 ret
= next_leaf(root
, &path
);
540 error("searching for extended attributes: %d",
544 /* No more leaves to search */
548 leaf
= path
.nodes
[0];
553 btrfs_item_key_to_cpu(leaf
, &key
, path
.slots
[0]);
554 if (key
.type
!= BTRFS_XATTR_ITEM_KEY
|| key
.objectid
!= inode
)
557 total_len
= btrfs_item_size_nr(leaf
, path
.slots
[0]);
558 di
= btrfs_item_ptr(leaf
, path
.slots
[0],
559 struct btrfs_dir_item
);
561 while (cur
< total_len
) {
562 len
= btrfs_dir_name_len(leaf
, di
);
563 if (len
> name_len
) {
565 name
= (char *) malloc(len
+ 1);
571 read_extent_buffer(leaf
, name
,
572 (unsigned long)(di
+ 1), len
);
576 len
= btrfs_dir_data_len(leaf
, di
);
577 if (len
> data_len
) {
579 data
= (char *) malloc(len
);
585 read_extent_buffer(leaf
, data
,
586 (unsigned long)(di
+ 1) + name_len
,
590 if (fsetxattr(fd
, name
, data
, data_len
, 0))
591 error("setting extended attribute %s on file %s: %m",
594 len
= sizeof(*di
) + name_len
+ data_len
;
596 di
= (struct btrfs_dir_item
*)((char *)di
+ len
);
602 btrfs_release_path(&path
);
609 static int copy_metadata(struct btrfs_root
*root
, int fd
,
610 struct btrfs_key
*key
)
612 struct btrfs_path path
;
613 struct btrfs_inode_item
*inode_item
;
616 btrfs_init_path(&path
);
617 ret
= btrfs_lookup_inode(NULL
, root
, &path
, key
, 0);
619 struct btrfs_timespec
*bts
;
620 struct timespec times
[2];
622 inode_item
= btrfs_item_ptr(path
.nodes
[0], path
.slots
[0],
623 struct btrfs_inode_item
);
625 ret
= fchown(fd
, btrfs_inode_uid(path
.nodes
[0], inode_item
),
626 btrfs_inode_gid(path
.nodes
[0], inode_item
));
628 error("failed to change owner: %m");
632 ret
= fchmod(fd
, btrfs_inode_mode(path
.nodes
[0], inode_item
));
634 error("failed to change mode: %m");
638 bts
= btrfs_inode_atime(inode_item
);
639 times
[0].tv_sec
= btrfs_timespec_sec(path
.nodes
[0], bts
);
640 times
[0].tv_nsec
= btrfs_timespec_nsec(path
.nodes
[0], bts
);
642 bts
= btrfs_inode_mtime(inode_item
);
643 times
[1].tv_sec
= btrfs_timespec_sec(path
.nodes
[0], bts
);
644 times
[1].tv_nsec
= btrfs_timespec_nsec(path
.nodes
[0], bts
);
646 ret
= futimens(fd
, times
);
648 error("failed to set times: %m");
653 btrfs_release_path(&path
);
657 static int copy_file(struct btrfs_root
*root
, int fd
, struct btrfs_key
*key
,
660 struct extent_buffer
*leaf
;
661 struct btrfs_path path
;
662 struct btrfs_file_extent_item
*fi
;
663 struct btrfs_inode_item
*inode_item
;
664 struct btrfs_timespec
*bts
;
665 struct btrfs_key found_key
;
671 struct timespec times
[2];
674 btrfs_init_path(&path
);
675 ret
= btrfs_lookup_inode(NULL
, root
, &path
, key
, 0);
677 inode_item
= btrfs_item_ptr(path
.nodes
[0], path
.slots
[0],
678 struct btrfs_inode_item
);
679 found_size
= btrfs_inode_size(path
.nodes
[0], inode_item
);
681 if (restore_metadata
) {
683 * Change the ownership and mode now, set times when
684 * copyout is finished.
687 ret
= fchown(fd
, btrfs_inode_uid(path
.nodes
[0], inode_item
),
688 btrfs_inode_gid(path
.nodes
[0], inode_item
));
689 if (ret
&& !ignore_errors
)
692 ret
= fchmod(fd
, btrfs_inode_mode(path
.nodes
[0], inode_item
));
693 if (ret
&& !ignore_errors
)
696 bts
= btrfs_inode_atime(inode_item
);
697 times
[0].tv_sec
= btrfs_timespec_sec(path
.nodes
[0], bts
);
698 times
[0].tv_nsec
= btrfs_timespec_nsec(path
.nodes
[0], bts
);
700 bts
= btrfs_inode_mtime(inode_item
);
701 times
[1].tv_sec
= btrfs_timespec_sec(path
.nodes
[0], bts
);
702 times
[1].tv_nsec
= btrfs_timespec_nsec(path
.nodes
[0], bts
);
706 btrfs_release_path(&path
);
709 key
->type
= BTRFS_EXTENT_DATA_KEY
;
711 ret
= btrfs_search_slot(NULL
, root
, key
, &path
, 0, 0);
713 error("searching extent data returned %d", ret
);
717 leaf
= path
.nodes
[0];
719 ret
= next_leaf(root
, &path
);
721 error("cannot get next leaf: %d", ret
);
723 } else if (ret
> 0) {
724 /* No more leaves to search */
728 leaf
= path
.nodes
[0];
732 if (loops
>= 0 && loops
++ >= 1024) {
733 enum loop_response resp
;
735 resp
= ask_to_continue(file
);
736 if (resp
== LOOP_STOP
)
738 else if (resp
== LOOP_CONTINUE
)
740 else if (resp
== LOOP_DONTASK
)
743 if (path
.slots
[0] >= btrfs_header_nritems(leaf
)) {
745 ret
= next_leaf(root
, &path
);
747 fprintf(stderr
, "Error searching %d\n", ret
);
750 /* No more leaves to search */
751 btrfs_release_path(&path
);
754 leaf
= path
.nodes
[0];
758 btrfs_item_key_to_cpu(leaf
, &found_key
, path
.slots
[0]);
759 if (found_key
.objectid
!= key
->objectid
)
761 if (found_key
.type
!= key
->type
)
763 fi
= btrfs_item_ptr(leaf
, path
.slots
[0],
764 struct btrfs_file_extent_item
);
765 extent_type
= btrfs_file_extent_type(leaf
, fi
);
766 compression
= btrfs_file_extent_compression(leaf
, fi
);
767 if (compression
>= BTRFS_COMPRESS_LAST
) {
768 warning("compression type %d not supported",
774 if (extent_type
== BTRFS_FILE_EXTENT_PREALLOC
)
776 if (extent_type
== BTRFS_FILE_EXTENT_INLINE
) {
777 ret
= copy_one_inline(root
, fd
, &path
, found_key
.offset
);
780 } else if (extent_type
== BTRFS_FILE_EXTENT_REG
) {
781 ret
= copy_one_extent(root
, fd
, leaf
, fi
,
786 warning("weird extent type %d", extent_type
);
792 btrfs_release_path(&path
);
795 ret
= ftruncate(fd
, (loff_t
)found_size
);
800 ret
= set_file_xattrs(root
, key
->objectid
, fd
, file
);
804 if (restore_metadata
&& times_ok
) {
805 ret
= futimens(fd
, times
);
812 btrfs_release_path(&path
);
818 * 0 if the file exists and should be skipped.
819 * 1 if the file does NOT exist
820 * 2 if the file exists but is OK to overwrite
822 static int overwrite_ok(const char * path
)
828 /* don't be fooled by symlinks */
829 ret
= fstatat(AT_FDCWD
, path_name
, &st
, AT_SYMLINK_NOFOLLOW
);
835 if (verbose
|| !warn
)
836 printf("Skipping existing file"
839 printf("If you wish to overwrite use -o\n");
846 static int copy_symlink(struct btrfs_root
*root
, struct btrfs_key
*key
,
849 struct btrfs_path path
;
850 struct extent_buffer
*leaf
;
851 struct btrfs_file_extent_item
*extent_item
;
852 struct btrfs_inode_item
*inode_item
;
856 struct btrfs_timespec
*bts
;
857 struct timespec times
[2];
859 ret
= overwrite_ok(path_name
);
861 return 0; /* skip this file */
863 /* symlink() can't overwrite, so unlink first */
865 ret
= unlink(path_name
);
867 fprintf(stderr
, "failed to unlink '%s' for overwrite\n",
873 btrfs_init_path(&path
);
874 key
->type
= BTRFS_EXTENT_DATA_KEY
;
876 ret
= btrfs_search_slot(NULL
, root
, key
, &path
, 0, 0);
880 leaf
= path
.nodes
[0];
882 fprintf(stderr
, "Error getting leaf for symlink '%s'\n", file
);
887 extent_item
= btrfs_item_ptr(leaf
, path
.slots
[0],
888 struct btrfs_file_extent_item
);
890 len
= btrfs_file_extent_inline_item_len(leaf
,
891 btrfs_item_nr(path
.slots
[0]));
892 if (len
>= PATH_MAX
) {
893 fprintf(stderr
, "Symlink '%s' target length %d is longer than PATH_MAX\n",
899 name_offset
= (unsigned long) extent_item
900 + offsetof(struct btrfs_file_extent_item
, disk_bytenr
);
901 read_extent_buffer(leaf
, symlink_target
, name_offset
, len
);
903 symlink_target
[len
] = 0;
906 ret
= symlink(symlink_target
, path_name
);
908 fprintf(stderr
, "Failed to restore symlink '%s': %m\n",
913 printf("SYMLINK: '%s' => '%s'\n", path_name
, symlink_target
);
916 if (!restore_metadata
)
920 * Symlink metadata operates differently than files/directories, so do
923 key
->type
= BTRFS_INODE_ITEM_KEY
;
926 btrfs_release_path(&path
);
928 ret
= btrfs_lookup_inode(NULL
, root
, &path
, key
, 0);
930 fprintf(stderr
, "Failed to lookup inode for '%s'\n", file
);
934 inode_item
= btrfs_item_ptr(path
.nodes
[0], path
.slots
[0],
935 struct btrfs_inode_item
);
937 ret
= fchownat(-1, file
, btrfs_inode_uid(path
.nodes
[0], inode_item
),
938 btrfs_inode_gid(path
.nodes
[0], inode_item
),
939 AT_SYMLINK_NOFOLLOW
);
941 fprintf(stderr
, "Failed to change owner: %m\n");
945 bts
= btrfs_inode_atime(inode_item
);
946 times
[0].tv_sec
= btrfs_timespec_sec(path
.nodes
[0], bts
);
947 times
[0].tv_nsec
= btrfs_timespec_nsec(path
.nodes
[0], bts
);
949 bts
= btrfs_inode_mtime(inode_item
);
950 times
[1].tv_sec
= btrfs_timespec_sec(path
.nodes
[0], bts
);
951 times
[1].tv_nsec
= btrfs_timespec_nsec(path
.nodes
[0], bts
);
953 ret
= utimensat(-1, file
, times
, AT_SYMLINK_NOFOLLOW
);
955 fprintf(stderr
, "Failed to set times: %m\n");
957 btrfs_release_path(&path
);
961 static int search_dir(struct btrfs_root
*root
, struct btrfs_key
*key
,
962 const char *output_rootdir
, const char *in_dir
,
965 struct btrfs_path path
;
966 struct extent_buffer
*leaf
;
967 struct btrfs_dir_item
*dir_item
;
968 struct btrfs_key found_key
, location
;
969 char filename
[BTRFS_NAME_LEN
+ 1];
970 unsigned long name_ptr
;
977 btrfs_init_path(&path
);
979 key
->type
= BTRFS_DIR_INDEX_KEY
;
980 ret
= btrfs_search_slot(NULL
, root
, key
, &path
, 0, 0);
982 fprintf(stderr
, "Error searching %d\n", ret
);
988 leaf
= path
.nodes
[0];
991 printf("No leaf after search, looking for the next "
993 ret
= next_leaf(root
, &path
);
995 fprintf(stderr
, "Error getting next leaf %d\n",
998 } else if (ret
> 0) {
999 /* No more leaves to search */
1001 printf("Reached the end of the tree looking "
1002 "for the directory\n");
1006 leaf
= path
.nodes
[0];
1010 if (loops
++ >= 1024) {
1011 printf("We have looped trying to restore files in %s "
1012 "too many times to be making progress, "
1013 "stopping\n", in_dir
);
1017 if (path
.slots
[0] >= btrfs_header_nritems(leaf
)) {
1019 ret
= next_leaf(root
, &path
);
1021 fprintf(stderr
, "Error searching %d\n",
1024 } else if (ret
> 0) {
1025 /* No more leaves to search */
1027 printf("Reached the end of "
1028 "the tree searching the"
1033 leaf
= path
.nodes
[0];
1037 btrfs_item_key_to_cpu(leaf
, &found_key
, path
.slots
[0]);
1038 if (found_key
.objectid
!= key
->objectid
) {
1040 printf("Found objectid=%Lu, key=%Lu\n",
1041 found_key
.objectid
, key
->objectid
);
1044 if (found_key
.type
!= key
->type
) {
1046 printf("Found type=%u, want=%u\n",
1047 found_key
.type
, key
->type
);
1050 dir_item
= btrfs_item_ptr(leaf
, path
.slots
[0],
1051 struct btrfs_dir_item
);
1052 name_ptr
= (unsigned long)(dir_item
+ 1);
1053 name_len
= btrfs_dir_name_len(leaf
, dir_item
);
1054 read_extent_buffer(leaf
, filename
, name_ptr
, name_len
);
1055 filename
[name_len
] = '\0';
1056 type
= btrfs_dir_type(leaf
, dir_item
);
1057 btrfs_dir_item_key_to_cpu(leaf
, dir_item
, &location
);
1059 /* full path from root of btrfs being restored */
1060 snprintf(fs_name
, PATH_MAX
, "%s/%s", in_dir
, filename
);
1062 if (mreg
&& REG_NOMATCH
== regexec(mreg
, fs_name
, 0, NULL
, 0))
1065 /* full path from system root */
1066 snprintf(path_name
, PATH_MAX
, "%s%s", output_rootdir
, fs_name
);
1069 * Restore directories, files, symlinks and metadata.
1071 if (type
== BTRFS_FT_REG_FILE
) {
1072 if (!overwrite_ok(path_name
))
1076 printf("Restoring %s\n", path_name
);
1079 fd
= open(path_name
, O_CREAT
|O_WRONLY
, 0644);
1081 fprintf(stderr
, "Error creating %s: %d\n",
1089 ret
= copy_file(root
, fd
, &location
, path_name
);
1092 fprintf(stderr
, "Error copying data for %s\n",
1098 } else if (type
== BTRFS_FT_DIR
) {
1099 struct btrfs_root
*search_root
= root
;
1100 char *dir
= strdup(fs_name
);
1103 fprintf(stderr
, "Ran out of memory\n");
1108 if (location
.type
== BTRFS_ROOT_ITEM_KEY
) {
1110 * If we are a snapshot and this is the index
1111 * object to ourselves just skip it.
1113 if (location
.objectid
==
1114 root
->root_key
.objectid
) {
1119 location
.offset
= (u64
)-1;
1120 search_root
= btrfs_read_fs_root(root
->fs_info
,
1122 if (IS_ERR(search_root
)) {
1124 fprintf(stderr
, "Error reading "
1125 "subvolume %s: %lu\n",
1127 PTR_ERR(search_root
));
1130 ret
= PTR_ERR(search_root
);
1135 * A subvolume will have a key.offset of 0, a
1136 * snapshot will have key.offset of a transid.
1138 if (search_root
->root_key
.offset
!= 0 &&
1141 printf("Skipping snapshot %s\n",
1145 location
.objectid
= BTRFS_FIRST_FREE_OBJECTID
;
1149 printf("Restoring %s\n", path_name
);
1155 ret
= mkdir(path_name
, 0755);
1156 if (ret
&& errno
!= EEXIST
) {
1158 fprintf(stderr
, "Error mkdiring %s: %d\n",
1166 ret
= search_dir(search_root
, &location
,
1167 output_rootdir
, dir
, mreg
);
1170 fprintf(stderr
, "Error searching %s\n",
1176 } else if (type
== BTRFS_FT_SYMLINK
) {
1177 if (restore_symlinks
)
1178 ret
= copy_symlink(root
, &location
, path_name
);
1182 btrfs_release_path(&path
);
1190 if (restore_metadata
) {
1191 snprintf(path_name
, PATH_MAX
, "%s%s", output_rootdir
, in_dir
);
1192 fd
= open(path_name
, O_RDONLY
);
1194 fprintf(stderr
, "ERROR: Failed to access %s to restore metadata\n",
1196 if (!ignore_errors
) {
1202 * Set owner/mode/time on the directory as well
1204 key
->type
= BTRFS_INODE_ITEM_KEY
;
1205 ret
= copy_metadata(root
, fd
, key
);
1207 if (ret
&& !ignore_errors
)
1213 printf("Done searching %s\n", in_dir
);
1215 btrfs_release_path(&path
);
1219 static int do_list_roots(struct btrfs_root
*root
)
1221 struct btrfs_key key
;
1222 struct btrfs_key found_key
;
1223 struct btrfs_disk_key disk_key
;
1224 struct btrfs_path path
;
1225 struct extent_buffer
*leaf
;
1226 struct btrfs_root_item ri
;
1227 unsigned long offset
;
1231 root
= root
->fs_info
->tree_root
;
1233 btrfs_init_path(&path
);
1236 key
.type
= BTRFS_ROOT_ITEM_KEY
;
1237 ret
= btrfs_search_slot(NULL
, root
, &key
, &path
, 0, 0);
1239 fprintf(stderr
, "Failed to do search %d\n", ret
);
1240 btrfs_release_path(&path
);
1244 leaf
= path
.nodes
[0];
1247 slot
= path
.slots
[0];
1248 if (slot
>= btrfs_header_nritems(leaf
)) {
1249 ret
= btrfs_next_leaf(root
, &path
);
1252 leaf
= path
.nodes
[0];
1253 slot
= path
.slots
[0];
1255 btrfs_item_key(leaf
, &disk_key
, slot
);
1256 btrfs_disk_key_to_cpu(&found_key
, &disk_key
);
1257 if (found_key
.type
!= BTRFS_ROOT_ITEM_KEY
) {
1262 offset
= btrfs_item_ptr_offset(leaf
, slot
);
1263 read_extent_buffer(leaf
, &ri
, offset
, sizeof(ri
));
1265 btrfs_print_key(&disk_key
);
1266 printf(" %Lu level %d\n", btrfs_root_bytenr(&ri
),
1267 btrfs_root_level(&ri
));
1270 btrfs_release_path(&path
);
1275 static struct btrfs_root
*open_fs(const char *dev
, u64 root_location
,
1276 int super_mirror
, int list_roots
)
1278 struct btrfs_fs_info
*fs_info
= NULL
;
1279 struct btrfs_root
*root
= NULL
;
1283 for (i
= super_mirror
; i
< BTRFS_SUPER_MIRROR_MAX
; i
++) {
1284 bytenr
= btrfs_sb_offset(i
);
1287 * Restore won't allocate extent and doesn't care anything
1288 * in extent tree. Skip block group item search will allow
1289 * restore to be executed on heavily damaged fs.
1291 fs_info
= open_ctree_fs_info(dev
, bytenr
, root_location
, 0,
1292 OPEN_CTREE_PARTIAL
|
1293 OPEN_CTREE_NO_BLOCK_GROUPS
);
1296 fprintf(stderr
, "Could not open root, trying backup super\n");
1303 * All we really need to succeed is reading the chunk tree, everything
1304 * else we can do by hand, since we only need to read the tree root and
1307 if (!extent_buffer_uptodate(fs_info
->tree_root
->node
)) {
1310 root
= fs_info
->tree_root
;
1312 root_location
= btrfs_super_root(fs_info
->super_copy
);
1313 generation
= btrfs_super_generation(fs_info
->super_copy
);
1314 root
->node
= read_tree_block(fs_info
, root_location
,
1316 if (!extent_buffer_uptodate(root
->node
)) {
1317 fprintf(stderr
, "Error opening tree root\n");
1323 if (!list_roots
&& !fs_info
->fs_root
) {
1324 struct btrfs_key key
;
1326 key
.objectid
= BTRFS_FS_TREE_OBJECTID
;
1327 key
.type
= BTRFS_ROOT_ITEM_KEY
;
1328 key
.offset
= (u64
)-1;
1329 fs_info
->fs_root
= btrfs_read_fs_root_no_cache(fs_info
, &key
);
1330 if (IS_ERR(fs_info
->fs_root
)) {
1331 fprintf(stderr
, "Couldn't read fs root: %ld\n",
1332 PTR_ERR(fs_info
->fs_root
));
1333 close_ctree(fs_info
->tree_root
);
1338 if (list_roots
&& do_list_roots(fs_info
->tree_root
)) {
1339 close_ctree(fs_info
->tree_root
);
1343 return fs_info
->fs_root
;
1346 static int find_first_dir(struct btrfs_root
*root
, u64
*objectid
)
1348 struct btrfs_path path
;
1349 struct btrfs_key found_key
;
1350 struct btrfs_key key
;
1354 btrfs_init_path(&path
);
1356 key
.type
= BTRFS_DIR_INDEX_KEY
;
1358 ret
= btrfs_search_slot(NULL
, root
, &key
, &path
, 0, 0);
1360 fprintf(stderr
, "Error searching %d\n", ret
);
1364 if (!path
.nodes
[0]) {
1365 fprintf(stderr
, "No leaf!\n");
1369 for (i
= path
.slots
[0];
1370 i
< btrfs_header_nritems(path
.nodes
[0]); i
++) {
1371 btrfs_item_key_to_cpu(path
.nodes
[0], &found_key
, i
);
1372 if (found_key
.type
!= key
.type
)
1375 printf("Using objectid %Lu for first dir\n",
1376 found_key
.objectid
);
1377 *objectid
= found_key
.objectid
;
1382 ret
= next_leaf(root
, &path
);
1384 fprintf(stderr
, "Error getting next leaf %d\n",
1387 } else if (ret
> 0) {
1388 fprintf(stderr
, "No more leaves\n");
1391 } while (!path
.nodes
[0]);
1394 printf("Couldn't find a dir index item\n");
1396 btrfs_release_path(&path
);
1400 const char * const cmd_restore_usage
[] = {
1401 "btrfs restore [options] <device> <path> | -l <device>",
1402 "Try to restore files from a damaged filesystem (unmounted)",
1404 "-s|--snapshots get snapshots",
1405 "-x|--xattr restore extended attributes",
1406 "-m|--metadata restore owner, mode and times",
1407 "-S|--symlink restore symbolic links",
1408 "-v|--verbose verbose",
1409 "-i|--ignore-errors ignore errors",
1410 "-o|--overwrite overwrite",
1411 "-t <bytenr> tree location",
1412 "-f <bytenr> filesystem location",
1413 "-u|--super <mirror> super mirror",
1414 "-r|--root <rootid> root objectid",
1416 "-l|--list-roots list tree roots",
1417 "-D|--dry-run dry run (only list files that would be recovered)",
1418 "--path-regex <regex>",
1419 " restore only filenames matching regex,",
1420 " you have to use following syntax (possibly quoted):",
1421 " ^/(|home(|/username(|/Desktop(|/.*))))$",
1422 "-c ignore case (--path-regex only)",
1426 int cmd_restore(int argc
, char **argv
)
1428 struct btrfs_root
*root
;
1429 struct btrfs_key key
;
1430 char dir_name
[PATH_MAX
];
1431 u64 tree_location
= 0;
1432 u64 fs_location
= 0;
1433 u64 root_objectid
= 0;
1436 int super_mirror
= 0;
1439 const char *match_regstr
= NULL
;
1440 int match_cflags
= REG_EXTENDED
| REG_NOSUB
| REG_NEWLINE
;
1441 regex_t match_reg
, *mreg
= NULL
;
1447 enum { GETOPT_VAL_PATH_REGEX
= 256 };
1448 static const struct option long_options
[] = {
1449 { "path-regex", required_argument
, NULL
,
1450 GETOPT_VAL_PATH_REGEX
},
1451 { "dry-run", no_argument
, NULL
, 'D'},
1452 { "metadata", no_argument
, NULL
, 'm'},
1453 { "symlinks", no_argument
, NULL
, 'S'},
1454 { "snapshots", no_argument
, NULL
, 's'},
1455 { "xattr", no_argument
, NULL
, 'x'},
1456 { "verbose", no_argument
, NULL
, 'v'},
1457 { "ignore-errors", no_argument
, NULL
, 'i'},
1458 { "overwrite", no_argument
, NULL
, 'o'},
1459 { "super", required_argument
, NULL
, 'u'},
1460 { "root", required_argument
, NULL
, 'r'},
1461 { "list-roots", no_argument
, NULL
, 'l'},
1465 opt
= getopt_long(argc
, argv
, "sSxviot:u:dmf:r:lDc", long_options
,
1484 tree_location
= arg_strtou64(optarg
);
1487 fs_location
= arg_strtou64(optarg
);
1490 super_mirror
= arg_strtou64(optarg
);
1491 if (super_mirror
>= BTRFS_SUPER_MIRROR_MAX
) {
1492 fprintf(stderr
, "Super mirror not "
1501 root_objectid
= arg_strtou64(optarg
);
1502 if (!is_fstree(root_objectid
)) {
1503 fprintf(stderr
, "objectid %llu is not a valid fs/file tree\n",
1512 restore_metadata
= 1;
1515 restore_symlinks
= 1;
1521 match_cflags
|= REG_ICASE
;
1523 case GETOPT_VAL_PATH_REGEX
:
1524 match_regstr
= optarg
;
1530 usage(cmd_restore_usage
);
1534 if (!list_roots
&& check_argc_min(argc
- optind
, 2))
1535 usage(cmd_restore_usage
);
1536 else if (list_roots
&& check_argc_min(argc
- optind
, 1))
1537 usage(cmd_restore_usage
);
1539 if (fs_location
&& root_objectid
) {
1540 fprintf(stderr
, "don't use -f and -r at the same time.\n");
1544 if ((ret
= check_mounted(argv
[optind
])) < 0) {
1545 fprintf(stderr
, "Could not check mount status: %s\n",
1549 fprintf(stderr
, "%s is currently mounted. Aborting.\n", argv
[optind
]);
1553 root
= open_fs(argv
[optind
], tree_location
, super_mirror
, list_roots
);
1560 if (fs_location
!= 0) {
1561 free_extent_buffer(root
->node
);
1562 root
->node
= read_tree_block(root
->fs_info
, fs_location
, 0);
1563 if (!extent_buffer_uptodate(root
->node
)) {
1564 fprintf(stderr
, "Failed to read fs location\n");
1570 memset(path_name
, 0, PATH_MAX
);
1572 if (strlen(argv
[optind
+ 1]) >= PATH_MAX
) {
1573 fprintf(stderr
, "ERROR: path too long\n");
1577 strncpy(dir_name
, argv
[optind
+ 1], sizeof dir_name
);
1578 dir_name
[sizeof dir_name
- 1] = 0;
1580 /* Strip the trailing / on the dir name */
1581 len
= strlen(dir_name
);
1582 while (len
&& dir_name
[--len
] == '/') {
1583 dir_name
[len
] = '\0';
1586 if (root_objectid
!= 0) {
1587 struct btrfs_root
*orig_root
= root
;
1589 key
.objectid
= root_objectid
;
1590 key
.type
= BTRFS_ROOT_ITEM_KEY
;
1591 key
.offset
= (u64
)-1;
1592 root
= btrfs_read_fs_root(orig_root
->fs_info
, &key
);
1594 fprintf(stderr
, "fail to read root %llu: %s\n",
1595 root_objectid
, strerror(-PTR_ERR(root
)));
1605 ret
= find_first_dir(root
, &key
.objectid
);
1609 key
.objectid
= BTRFS_FIRST_FREE_OBJECTID
;
1613 ret
= regcomp(&match_reg
, match_regstr
, match_cflags
);
1615 regerror(ret
, &match_reg
, reg_err
, sizeof(reg_err
));
1616 fprintf(stderr
, "Regex compile failed: %s\n", reg_err
);
1623 printf("This is a dry-run, no files are going to be restored\n");
1625 ret
= search_dir(root
, &key
, dir_name
, "", mreg
);