btrfs-progs: convert: move ext2 conversion out of main.c
[platform/upstream/btrfs-progs.git] / convert / source-ext2.c
1 /*
2  * This program is free software; you can redistribute it and/or
3  * modify it under the terms of the GNU General Public
4  * License v2 as published by the Free Software Foundation.
5  *
6  * This program is distributed in the hope that it will be useful,
7  * but WITHOUT ANY WARRANTY; without even the implied warranty of
8  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
9  * General Public License for more details.
10  *
11  * You should have received a copy of the GNU General Public
12  * License along with this program; if not, write to the
13  * Free Software Foundation, Inc., 59 Temple Place - Suite 330,
14  * Boston, MA 021110-1307, USA.
15  */
16
17 #if BTRFSCONVERT_EXT2
18
19 #include "kerncompat.h"
20 #include "disk-io.h"
21 #include "transaction.h"
22 #include "utils.h"
23 #include "convert/common.h"
24 #include "convert/source-ext2.h"
25
26 /*
27  * Open Ext2fs in readonly mode, read block allocation bitmap and
28  * inode bitmap into memory.
29  */
30 static int ext2_open_fs(struct btrfs_convert_context *cctx, const char *name)
31 {
32         errcode_t ret;
33         ext2_filsys ext2_fs;
34         ext2_ino_t ino;
35         u32 ro_feature;
36
37         ret = ext2fs_open(name, 0, 0, 0, unix_io_manager, &ext2_fs);
38         if (ret) {
39                 fprintf(stderr, "ext2fs_open: %s\n", error_message(ret));
40                 return -1;
41         }
42         /*
43          * We need to know exactly the used space, some RO compat flags like
44          * BIGALLOC will affect how used space is present.
45          * So we need manuall check any unsupported RO compat flags
46          */
47         ro_feature = ext2_fs->super->s_feature_ro_compat;
48         if (ro_feature & ~EXT2_LIB_FEATURE_RO_COMPAT_SUPP) {
49                 error(
50 "unsupported RO features detected: %x, abort convert to avoid possible corruption",
51                       ro_feature & ~EXT2_LIB_FEATURE_COMPAT_SUPP);
52                 goto fail;
53         }
54         ret = ext2fs_read_inode_bitmap(ext2_fs);
55         if (ret) {
56                 fprintf(stderr, "ext2fs_read_inode_bitmap: %s\n",
57                         error_message(ret));
58                 goto fail;
59         }
60         ret = ext2fs_read_block_bitmap(ext2_fs);
61         if (ret) {
62                 fprintf(stderr, "ext2fs_read_block_bitmap: %s\n",
63                         error_message(ret));
64                 goto fail;
65         }
66         /*
67          * search each block group for a free inode. this set up
68          * uninit block/inode bitmaps appropriately.
69          */
70         ino = 1;
71         while (ino <= ext2_fs->super->s_inodes_count) {
72                 ext2_ino_t foo;
73                 ext2fs_new_inode(ext2_fs, ino, 0, NULL, &foo);
74                 ino += EXT2_INODES_PER_GROUP(ext2_fs->super);
75         }
76
77         if (!(ext2_fs->super->s_feature_incompat &
78               EXT2_FEATURE_INCOMPAT_FILETYPE)) {
79                 error("filetype feature is missing");
80                 goto fail;
81         }
82
83         cctx->fs_data = ext2_fs;
84         cctx->blocksize = ext2_fs->blocksize;
85         cctx->block_count = ext2_fs->super->s_blocks_count;
86         cctx->total_bytes = ext2_fs->blocksize * ext2_fs->super->s_blocks_count;
87         cctx->volume_name = strndup(ext2_fs->super->s_volume_name, 16);
88         cctx->first_data_block = ext2_fs->super->s_first_data_block;
89         cctx->inodes_count = ext2_fs->super->s_inodes_count;
90         cctx->free_inodes_count = ext2_fs->super->s_free_inodes_count;
91         return 0;
92 fail:
93         ext2fs_close(ext2_fs);
94         return -1;
95 }
96
97 static int __ext2_add_one_block(ext2_filsys fs, char *bitmap,
98                                 unsigned long group_nr, struct cache_tree *used)
99 {
100         unsigned long offset;
101         unsigned i;
102         int ret = 0;
103
104         offset = fs->super->s_first_data_block;
105         offset /= EXT2FS_CLUSTER_RATIO(fs);
106         offset += group_nr * EXT2_CLUSTERS_PER_GROUP(fs->super);
107         for (i = 0; i < EXT2_CLUSTERS_PER_GROUP(fs->super); i++) {
108                 if ((i + offset) >= ext2fs_blocks_count(fs->super))
109                         break;
110
111                 if (ext2fs_test_bit(i, bitmap)) {
112                         u64 start;
113
114                         start = (i + offset) * EXT2FS_CLUSTER_RATIO(fs);
115                         start *= fs->blocksize;
116                         ret = add_merge_cache_extent(used, start,
117                                                      fs->blocksize);
118                         if (ret < 0)
119                                 break;
120                 }
121         }
122         return ret;
123 }
124
125 /*
126  * Read all used ext2 space into cctx->used cache tree
127  */
128 static int ext2_read_used_space(struct btrfs_convert_context *cctx)
129 {
130         ext2_filsys fs = (ext2_filsys)cctx->fs_data;
131         blk64_t blk_itr = EXT2FS_B2C(fs, fs->super->s_first_data_block);
132         struct cache_tree *used_tree = &cctx->used;
133         char *block_bitmap = NULL;
134         unsigned long i;
135         int block_nbytes;
136         int ret = 0;
137
138         block_nbytes = EXT2_CLUSTERS_PER_GROUP(fs->super) / 8;
139         /* Shouldn't happen */
140         BUG_ON(!fs->block_map);
141
142         block_bitmap = malloc(block_nbytes);
143         if (!block_bitmap)
144                 return -ENOMEM;
145
146         for (i = 0; i < fs->group_desc_count; i++) {
147                 ret = ext2fs_get_block_bitmap_range(fs->block_map, blk_itr,
148                                                 block_nbytes * 8, block_bitmap);
149                 if (ret) {
150                         error("fail to get bitmap from ext2, %s",
151                               strerror(-ret));
152                         break;
153                 }
154                 ret = __ext2_add_one_block(fs, block_bitmap, i, used_tree);
155                 if (ret < 0) {
156                         error("fail to build used space tree, %s",
157                               strerror(-ret));
158                         break;
159                 }
160                 blk_itr += EXT2_CLUSTERS_PER_GROUP(fs->super);
161         }
162
163         free(block_bitmap);
164         return ret;
165 }
166
167 static void ext2_close_fs(struct btrfs_convert_context *cctx)
168 {
169         if (cctx->volume_name) {
170                 free(cctx->volume_name);
171                 cctx->volume_name = NULL;
172         }
173         ext2fs_close(cctx->fs_data);
174 }
175
176 static u8 ext2_filetype_conversion_table[EXT2_FT_MAX] = {
177         [EXT2_FT_UNKNOWN]       = BTRFS_FT_UNKNOWN,
178         [EXT2_FT_REG_FILE]      = BTRFS_FT_REG_FILE,
179         [EXT2_FT_DIR]           = BTRFS_FT_DIR,
180         [EXT2_FT_CHRDEV]        = BTRFS_FT_CHRDEV,
181         [EXT2_FT_BLKDEV]        = BTRFS_FT_BLKDEV,
182         [EXT2_FT_FIFO]          = BTRFS_FT_FIFO,
183         [EXT2_FT_SOCK]          = BTRFS_FT_SOCK,
184         [EXT2_FT_SYMLINK]       = BTRFS_FT_SYMLINK,
185 };
186
187 static int ext2_dir_iterate_proc(ext2_ino_t dir, int entry,
188                             struct ext2_dir_entry *dirent,
189                             int offset, int blocksize,
190                             char *buf,void *priv_data)
191 {
192         int ret;
193         int file_type;
194         u64 objectid;
195         char dotdot[] = "..";
196         struct dir_iterate_data *idata = (struct dir_iterate_data *)priv_data;
197         int name_len;
198
199         name_len = dirent->name_len & 0xFF;
200
201         objectid = dirent->inode + INO_OFFSET;
202         if (!strncmp(dirent->name, dotdot, name_len)) {
203                 if (name_len == 2) {
204                         BUG_ON(idata->parent != 0);
205                         idata->parent = objectid;
206                 }
207                 return 0;
208         }
209         if (dirent->inode < EXT2_GOOD_OLD_FIRST_INO)
210                 return 0;
211
212         file_type = dirent->name_len >> 8;
213         BUG_ON(file_type > EXT2_FT_SYMLINK);
214
215         ret = convert_insert_dirent(idata->trans, idata->root, dirent->name,
216                                     name_len, idata->objectid, objectid,
217                                     ext2_filetype_conversion_table[file_type],
218                                     idata->index_cnt, idata->inode);
219         if (ret < 0) {
220                 idata->errcode = ret;
221                 return BLOCK_ABORT;
222         }
223
224         idata->index_cnt++;
225         return 0;
226 }
227
228 static int ext2_create_dir_entries(struct btrfs_trans_handle *trans,
229                               struct btrfs_root *root, u64 objectid,
230                               struct btrfs_inode_item *btrfs_inode,
231                               ext2_filsys ext2_fs, ext2_ino_t ext2_ino)
232 {
233         int ret;
234         errcode_t err;
235         struct dir_iterate_data data = {
236                 .trans          = trans,
237                 .root           = root,
238                 .inode          = btrfs_inode,
239                 .objectid       = objectid,
240                 .index_cnt      = 2,
241                 .parent         = 0,
242                 .errcode        = 0,
243         };
244
245         err = ext2fs_dir_iterate2(ext2_fs, ext2_ino, 0, NULL,
246                                   ext2_dir_iterate_proc, &data);
247         if (err)
248                 goto error;
249         ret = data.errcode;
250         if (ret == 0 && data.parent == objectid) {
251                 ret = btrfs_insert_inode_ref(trans, root, "..", 2,
252                                              objectid, objectid, 0);
253         }
254         return ret;
255 error:
256         fprintf(stderr, "ext2fs_dir_iterate2: %s\n", error_message(err));
257         return -1;
258 }
259
260 static int ext2_block_iterate_proc(ext2_filsys fs, blk_t *blocknr,
261                                 e2_blkcnt_t blockcnt, blk_t ref_block,
262                                 int ref_offset, void *priv_data)
263 {
264         int ret;
265         struct blk_iterate_data *idata;
266         idata = (struct blk_iterate_data *)priv_data;
267         ret = block_iterate_proc(*blocknr, blockcnt, idata);
268         if (ret) {
269                 idata->errcode = ret;
270                 return BLOCK_ABORT;
271         }
272         return 0;
273 }
274
275 /*
276  * traverse file's data blocks, record these data blocks as file extents.
277  */
278 static int ext2_create_file_extents(struct btrfs_trans_handle *trans,
279                                struct btrfs_root *root, u64 objectid,
280                                struct btrfs_inode_item *btrfs_inode,
281                                ext2_filsys ext2_fs, ext2_ino_t ext2_ino,
282                                int datacsum, int packing)
283 {
284         int ret;
285         char *buffer = NULL;
286         errcode_t err;
287         u32 last_block;
288         u32 sectorsize = root->sectorsize;
289         u64 inode_size = btrfs_stack_inode_size(btrfs_inode);
290         struct blk_iterate_data data;
291
292         init_blk_iterate_data(&data, trans, root, btrfs_inode, objectid,
293                               datacsum);
294
295         err = ext2fs_block_iterate2(ext2_fs, ext2_ino, BLOCK_FLAG_DATA_ONLY,
296                                     NULL, ext2_block_iterate_proc, &data);
297         if (err)
298                 goto error;
299         ret = data.errcode;
300         if (ret)
301                 goto fail;
302         if (packing && data.first_block == 0 && data.num_blocks > 0 &&
303             inode_size <= BTRFS_MAX_INLINE_DATA_SIZE(root)) {
304                 u64 num_bytes = data.num_blocks * sectorsize;
305                 u64 disk_bytenr = data.disk_block * sectorsize;
306                 u64 nbytes;
307
308                 buffer = malloc(num_bytes);
309                 if (!buffer)
310                         return -ENOMEM;
311                 ret = read_disk_extent(root, disk_bytenr, num_bytes, buffer);
312                 if (ret)
313                         goto fail;
314                 if (num_bytes > inode_size)
315                         num_bytes = inode_size;
316                 ret = btrfs_insert_inline_extent(trans, root, objectid,
317                                                  0, buffer, num_bytes);
318                 if (ret)
319                         goto fail;
320                 nbytes = btrfs_stack_inode_nbytes(btrfs_inode) + num_bytes;
321                 btrfs_set_stack_inode_nbytes(btrfs_inode, nbytes);
322         } else if (data.num_blocks > 0) {
323                 ret = record_file_blocks(&data, data.first_block,
324                                          data.disk_block, data.num_blocks);
325                 if (ret)
326                         goto fail;
327         }
328         data.first_block += data.num_blocks;
329         last_block = (inode_size + sectorsize - 1) / sectorsize;
330         if (last_block > data.first_block) {
331                 ret = record_file_blocks(&data, data.first_block, 0,
332                                          last_block - data.first_block);
333         }
334 fail:
335         free(buffer);
336         return ret;
337 error:
338         fprintf(stderr, "ext2fs_block_iterate2: %s\n", error_message(err));
339         return -1;
340 }
341
342 static int ext2_create_symbol_link(struct btrfs_trans_handle *trans,
343                               struct btrfs_root *root, u64 objectid,
344                               struct btrfs_inode_item *btrfs_inode,
345                               ext2_filsys ext2_fs, ext2_ino_t ext2_ino,
346                               struct ext2_inode *ext2_inode)
347 {
348         int ret;
349         char *pathname;
350         u64 inode_size = btrfs_stack_inode_size(btrfs_inode);
351         if (ext2fs_inode_data_blocks(ext2_fs, ext2_inode)) {
352                 btrfs_set_stack_inode_size(btrfs_inode, inode_size + 1);
353                 ret = ext2_create_file_extents(trans, root, objectid,
354                                 btrfs_inode, ext2_fs, ext2_ino, 1, 1);
355                 btrfs_set_stack_inode_size(btrfs_inode, inode_size);
356                 return ret;
357         }
358
359         pathname = (char *)&(ext2_inode->i_block[0]);
360         BUG_ON(pathname[inode_size] != 0);
361         ret = btrfs_insert_inline_extent(trans, root, objectid, 0,
362                                          pathname, inode_size + 1);
363         btrfs_set_stack_inode_nbytes(btrfs_inode, inode_size + 1);
364         return ret;
365 }
366
367 /*
368  * Following xattr/acl related codes are based on codes in
369  * fs/ext3/xattr.c and fs/ext3/acl.c
370  */
371 #define EXT2_XATTR_BHDR(ptr) ((struct ext2_ext_attr_header *)(ptr))
372 #define EXT2_XATTR_BFIRST(ptr) \
373         ((struct ext2_ext_attr_entry *)(EXT2_XATTR_BHDR(ptr) + 1))
374 #define EXT2_XATTR_IHDR(inode) \
375         ((struct ext2_ext_attr_header *) ((void *)(inode) + \
376                 EXT2_GOOD_OLD_INODE_SIZE + (inode)->i_extra_isize))
377 #define EXT2_XATTR_IFIRST(inode) \
378         ((struct ext2_ext_attr_entry *) ((void *)EXT2_XATTR_IHDR(inode) + \
379                 sizeof(EXT2_XATTR_IHDR(inode)->h_magic)))
380
381 static int ext2_xattr_check_names(struct ext2_ext_attr_entry *entry,
382                                   const void *end)
383 {
384         struct ext2_ext_attr_entry *next;
385
386         while (!EXT2_EXT_IS_LAST_ENTRY(entry)) {
387                 next = EXT2_EXT_ATTR_NEXT(entry);
388                 if ((void *)next >= end)
389                         return -EIO;
390                 entry = next;
391         }
392         return 0;
393 }
394
395 static int ext2_xattr_check_block(const char *buf, size_t size)
396 {
397         int error;
398         struct ext2_ext_attr_header *header = EXT2_XATTR_BHDR(buf);
399
400         if (header->h_magic != EXT2_EXT_ATTR_MAGIC ||
401             header->h_blocks != 1)
402                 return -EIO;
403         error = ext2_xattr_check_names(EXT2_XATTR_BFIRST(buf), buf + size);
404         return error;
405 }
406
407 static int ext2_xattr_check_entry(struct ext2_ext_attr_entry *entry,
408                                   size_t size)
409 {
410         size_t value_size = entry->e_value_size;
411
412         if (entry->e_value_block != 0 || value_size > size ||
413             entry->e_value_offs + value_size > size)
414                 return -EIO;
415         return 0;
416 }
417
418 static inline int ext2_acl_count(size_t size)
419 {
420         ssize_t s;
421         size -= sizeof(ext2_acl_header);
422         s = size - 4 * sizeof(ext2_acl_entry_short);
423         if (s < 0) {
424                 if (size % sizeof(ext2_acl_entry_short))
425                         return -1;
426                 return size / sizeof(ext2_acl_entry_short);
427         } else {
428                 if (s % sizeof(ext2_acl_entry))
429                         return -1;
430                 return s / sizeof(ext2_acl_entry) + 4;
431         }
432 }
433
434 static inline size_t acl_ea_size(int count)
435 {
436         return sizeof(acl_ea_header) + count * sizeof(acl_ea_entry);
437 }
438
439 static int ext2_acl_to_xattr(void *dst, const void *src,
440                              size_t dst_size, size_t src_size)
441 {
442         int i, count;
443         const void *end = src + src_size;
444         acl_ea_header *ext_acl = (acl_ea_header *)dst;
445         acl_ea_entry *dst_entry = ext_acl->a_entries;
446         ext2_acl_entry *src_entry;
447
448         if (src_size < sizeof(ext2_acl_header))
449                 goto fail;
450         if (((ext2_acl_header *)src)->a_version !=
451             cpu_to_le32(EXT2_ACL_VERSION))
452                 goto fail;
453         src += sizeof(ext2_acl_header);
454         count = ext2_acl_count(src_size);
455         if (count <= 0)
456                 goto fail;
457
458         BUG_ON(dst_size < acl_ea_size(count));
459         ext_acl->a_version = cpu_to_le32(ACL_EA_VERSION);
460         for (i = 0; i < count; i++, dst_entry++) {
461                 src_entry = (ext2_acl_entry *)src;
462                 if (src + sizeof(ext2_acl_entry_short) > end)
463                         goto fail;
464                 dst_entry->e_tag = src_entry->e_tag;
465                 dst_entry->e_perm = src_entry->e_perm;
466                 switch (le16_to_cpu(src_entry->e_tag)) {
467                 case ACL_USER_OBJ:
468                 case ACL_GROUP_OBJ:
469                 case ACL_MASK:
470                 case ACL_OTHER:
471                         src += sizeof(ext2_acl_entry_short);
472                         dst_entry->e_id = cpu_to_le32(ACL_UNDEFINED_ID);
473                         break;
474                 case ACL_USER:
475                 case ACL_GROUP:
476                         src += sizeof(ext2_acl_entry);
477                         if (src > end)
478                                 goto fail;
479                         dst_entry->e_id = src_entry->e_id;
480                         break;
481                 default:
482                         goto fail;
483                 }
484         }
485         if (src != end)
486                 goto fail;
487         return 0;
488 fail:
489         return -EINVAL;
490 }
491
492 static char *xattr_prefix_table[] = {
493         [1] =   "user.",
494         [2] =   "system.posix_acl_access",
495         [3] =   "system.posix_acl_default",
496         [4] =   "trusted.",
497         [6] =   "security.",
498 };
499
500 static int ext2_copy_single_xattr(struct btrfs_trans_handle *trans,
501                              struct btrfs_root *root, u64 objectid,
502                              struct ext2_ext_attr_entry *entry,
503                              const void *data, u32 datalen)
504 {
505         int ret = 0;
506         int name_len;
507         int name_index;
508         void *databuf = NULL;
509         char namebuf[XATTR_NAME_MAX + 1];
510
511         name_index = entry->e_name_index;
512         if (name_index >= ARRAY_SIZE(xattr_prefix_table) ||
513             xattr_prefix_table[name_index] == NULL)
514                 return -EOPNOTSUPP;
515         name_len = strlen(xattr_prefix_table[name_index]) +
516                    entry->e_name_len;
517         if (name_len >= sizeof(namebuf))
518                 return -ERANGE;
519
520         if (name_index == 2 || name_index == 3) {
521                 size_t bufsize = acl_ea_size(ext2_acl_count(datalen));
522                 databuf = malloc(bufsize);
523                 if (!databuf)
524                        return -ENOMEM;
525                 ret = ext2_acl_to_xattr(databuf, data, bufsize, datalen);
526                 if (ret)
527                         goto out;
528                 data = databuf;
529                 datalen = bufsize;
530         }
531         strncpy(namebuf, xattr_prefix_table[name_index], XATTR_NAME_MAX);
532         strncat(namebuf, EXT2_EXT_ATTR_NAME(entry), entry->e_name_len);
533         if (name_len + datalen > BTRFS_LEAF_DATA_SIZE(root) -
534             sizeof(struct btrfs_item) - sizeof(struct btrfs_dir_item)) {
535                 fprintf(stderr, "skip large xattr on inode %Lu name %.*s\n",
536                         objectid - INO_OFFSET, name_len, namebuf);
537                 goto out;
538         }
539         ret = btrfs_insert_xattr_item(trans, root, namebuf, name_len,
540                                       data, datalen, objectid);
541 out:
542         free(databuf);
543         return ret;
544 }
545
546 static int ext2_copy_extended_attrs(struct btrfs_trans_handle *trans,
547                                struct btrfs_root *root, u64 objectid,
548                                struct btrfs_inode_item *btrfs_inode,
549                                ext2_filsys ext2_fs, ext2_ino_t ext2_ino)
550 {
551         int ret = 0;
552         int inline_ea = 0;
553         errcode_t err;
554         u32 datalen;
555         u32 block_size = ext2_fs->blocksize;
556         u32 inode_size = EXT2_INODE_SIZE(ext2_fs->super);
557         struct ext2_inode_large *ext2_inode;
558         struct ext2_ext_attr_entry *entry;
559         void *data;
560         char *buffer = NULL;
561         char inode_buf[EXT2_GOOD_OLD_INODE_SIZE];
562
563         if (inode_size <= EXT2_GOOD_OLD_INODE_SIZE) {
564                 ext2_inode = (struct ext2_inode_large *)inode_buf;
565         } else {
566                 ext2_inode = (struct ext2_inode_large *)malloc(inode_size);
567                 if (!ext2_inode)
568                        return -ENOMEM;
569         }
570         err = ext2fs_read_inode_full(ext2_fs, ext2_ino, (void *)ext2_inode,
571                                      inode_size);
572         if (err) {
573                 fprintf(stderr, "ext2fs_read_inode_full: %s\n",
574                         error_message(err));
575                 ret = -1;
576                 goto out;
577         }
578
579         if (ext2_ino > ext2_fs->super->s_first_ino &&
580             inode_size > EXT2_GOOD_OLD_INODE_SIZE) {
581                 if (EXT2_GOOD_OLD_INODE_SIZE +
582                     ext2_inode->i_extra_isize > inode_size) {
583                         ret = -EIO;
584                         goto out;
585                 }
586                 if (ext2_inode->i_extra_isize != 0 &&
587                     EXT2_XATTR_IHDR(ext2_inode)->h_magic ==
588                     EXT2_EXT_ATTR_MAGIC) {
589                         inline_ea = 1;
590                 }
591         }
592         if (inline_ea) {
593                 int total;
594                 void *end = (void *)ext2_inode + inode_size;
595                 entry = EXT2_XATTR_IFIRST(ext2_inode);
596                 total = end - (void *)entry;
597                 ret = ext2_xattr_check_names(entry, end);
598                 if (ret)
599                         goto out;
600                 while (!EXT2_EXT_IS_LAST_ENTRY(entry)) {
601                         ret = ext2_xattr_check_entry(entry, total);
602                         if (ret)
603                                 goto out;
604                         data = (void *)EXT2_XATTR_IFIRST(ext2_inode) +
605                                 entry->e_value_offs;
606                         datalen = entry->e_value_size;
607                         ret = ext2_copy_single_xattr(trans, root, objectid,
608                                                 entry, data, datalen);
609                         if (ret)
610                                 goto out;
611                         entry = EXT2_EXT_ATTR_NEXT(entry);
612                 }
613         }
614
615         if (ext2_inode->i_file_acl == 0)
616                 goto out;
617
618         buffer = malloc(block_size);
619         if (!buffer) {
620                 ret = -ENOMEM;
621                 goto out;
622         }
623         err = ext2fs_read_ext_attr(ext2_fs, ext2_inode->i_file_acl, buffer);
624         if (err) {
625                 fprintf(stderr, "ext2fs_read_ext_attr: %s\n",
626                         error_message(err));
627                 ret = -1;
628                 goto out;
629         }
630         ret = ext2_xattr_check_block(buffer, block_size);
631         if (ret)
632                 goto out;
633
634         entry = EXT2_XATTR_BFIRST(buffer);
635         while (!EXT2_EXT_IS_LAST_ENTRY(entry)) {
636                 ret = ext2_xattr_check_entry(entry, block_size);
637                 if (ret)
638                         goto out;
639                 data = buffer + entry->e_value_offs;
640                 datalen = entry->e_value_size;
641                 ret = ext2_copy_single_xattr(trans, root, objectid,
642                                         entry, data, datalen);
643                 if (ret)
644                         goto out;
645                 entry = EXT2_EXT_ATTR_NEXT(entry);
646         }
647 out:
648         free(buffer);
649         if ((void *)ext2_inode != inode_buf)
650                 free(ext2_inode);
651         return ret;
652 }
653 #define MINORBITS       20
654 #define MKDEV(ma, mi)   (((ma) << MINORBITS) | (mi))
655
656 static inline dev_t old_decode_dev(u16 val)
657 {
658         return MKDEV((val >> 8) & 255, val & 255);
659 }
660
661 static inline dev_t new_decode_dev(u32 dev)
662 {
663         unsigned major = (dev & 0xfff00) >> 8;
664         unsigned minor = (dev & 0xff) | ((dev >> 12) & 0xfff00);
665         return MKDEV(major, minor);
666 }
667
668 static void ext2_copy_inode_item(struct btrfs_inode_item *dst,
669                            struct ext2_inode *src, u32 blocksize)
670 {
671         btrfs_set_stack_inode_generation(dst, 1);
672         btrfs_set_stack_inode_sequence(dst, 0);
673         btrfs_set_stack_inode_transid(dst, 1);
674         btrfs_set_stack_inode_size(dst, src->i_size);
675         btrfs_set_stack_inode_nbytes(dst, 0);
676         btrfs_set_stack_inode_block_group(dst, 0);
677         btrfs_set_stack_inode_nlink(dst, src->i_links_count);
678         btrfs_set_stack_inode_uid(dst, src->i_uid | (src->i_uid_high << 16));
679         btrfs_set_stack_inode_gid(dst, src->i_gid | (src->i_gid_high << 16));
680         btrfs_set_stack_inode_mode(dst, src->i_mode);
681         btrfs_set_stack_inode_rdev(dst, 0);
682         btrfs_set_stack_inode_flags(dst, 0);
683         btrfs_set_stack_timespec_sec(&dst->atime, src->i_atime);
684         btrfs_set_stack_timespec_nsec(&dst->atime, 0);
685         btrfs_set_stack_timespec_sec(&dst->ctime, src->i_ctime);
686         btrfs_set_stack_timespec_nsec(&dst->ctime, 0);
687         btrfs_set_stack_timespec_sec(&dst->mtime, src->i_mtime);
688         btrfs_set_stack_timespec_nsec(&dst->mtime, 0);
689         btrfs_set_stack_timespec_sec(&dst->otime, 0);
690         btrfs_set_stack_timespec_nsec(&dst->otime, 0);
691
692         if (S_ISDIR(src->i_mode)) {
693                 btrfs_set_stack_inode_size(dst, 0);
694                 btrfs_set_stack_inode_nlink(dst, 1);
695         }
696         if (S_ISREG(src->i_mode)) {
697                 btrfs_set_stack_inode_size(dst, (u64)src->i_size_high << 32 |
698                                            (u64)src->i_size);
699         }
700         if (!S_ISREG(src->i_mode) && !S_ISDIR(src->i_mode) &&
701             !S_ISLNK(src->i_mode)) {
702                 if (src->i_block[0]) {
703                         btrfs_set_stack_inode_rdev(dst,
704                                 old_decode_dev(src->i_block[0]));
705                 } else {
706                         btrfs_set_stack_inode_rdev(dst,
707                                 new_decode_dev(src->i_block[1]));
708                 }
709         }
710         memset(&dst->reserved, 0, sizeof(dst->reserved));
711 }
712 static int ext2_check_state(struct btrfs_convert_context *cctx)
713 {
714         ext2_filsys fs = cctx->fs_data;
715
716         if (!(fs->super->s_state & EXT2_VALID_FS))
717                 return 1;
718         else if (fs->super->s_state & EXT2_ERROR_FS)
719                 return 1;
720         else
721                 return 0;
722 }
723
724 /* EXT2_*_FL to BTRFS_INODE_FLAG_* stringification helper */
725 #define COPY_ONE_EXT2_FLAG(flags, ext2_inode, name) ({                  \
726         if (ext2_inode->i_flags & EXT2_##name##_FL)                     \
727                 flags |= BTRFS_INODE_##name;                            \
728 })
729
730 /*
731  * Convert EXT2_*_FL to corresponding BTRFS_INODE_* flags
732  *
733  * Only a subset of EXT_*_FL is supported in btrfs.
734  */
735 static void ext2_convert_inode_flags(struct btrfs_inode_item *dst,
736                                      struct ext2_inode *src)
737 {
738         u64 flags = 0;
739
740         COPY_ONE_EXT2_FLAG(flags, src, APPEND);
741         COPY_ONE_EXT2_FLAG(flags, src, SYNC);
742         COPY_ONE_EXT2_FLAG(flags, src, IMMUTABLE);
743         COPY_ONE_EXT2_FLAG(flags, src, NODUMP);
744         COPY_ONE_EXT2_FLAG(flags, src, NOATIME);
745         COPY_ONE_EXT2_FLAG(flags, src, DIRSYNC);
746         btrfs_set_stack_inode_flags(dst, flags);
747 }
748
749 /*
750  * copy a single inode. do all the required works, such as cloning
751  * inode item, creating file extents and creating directory entries.
752  */
753 static int ext2_copy_single_inode(struct btrfs_trans_handle *trans,
754                              struct btrfs_root *root, u64 objectid,
755                              ext2_filsys ext2_fs, ext2_ino_t ext2_ino,
756                              struct ext2_inode *ext2_inode,
757                              int datacsum, int packing, int noxattr)
758 {
759         int ret;
760         struct btrfs_inode_item btrfs_inode;
761
762         if (ext2_inode->i_links_count == 0)
763                 return 0;
764
765         ext2_copy_inode_item(&btrfs_inode, ext2_inode, ext2_fs->blocksize);
766         if (!datacsum && S_ISREG(ext2_inode->i_mode)) {
767                 u32 flags = btrfs_stack_inode_flags(&btrfs_inode) |
768                             BTRFS_INODE_NODATASUM;
769                 btrfs_set_stack_inode_flags(&btrfs_inode, flags);
770         }
771         ext2_convert_inode_flags(&btrfs_inode, ext2_inode);
772
773         switch (ext2_inode->i_mode & S_IFMT) {
774         case S_IFREG:
775                 ret = ext2_create_file_extents(trans, root, objectid,
776                         &btrfs_inode, ext2_fs, ext2_ino, datacsum, packing);
777                 break;
778         case S_IFDIR:
779                 ret = ext2_create_dir_entries(trans, root, objectid,
780                                 &btrfs_inode, ext2_fs, ext2_ino);
781                 break;
782         case S_IFLNK:
783                 ret = ext2_create_symbol_link(trans, root, objectid,
784                                 &btrfs_inode, ext2_fs, ext2_ino, ext2_inode);
785                 break;
786         default:
787                 ret = 0;
788                 break;
789         }
790         if (ret)
791                 return ret;
792
793         if (!noxattr) {
794                 ret = ext2_copy_extended_attrs(trans, root, objectid,
795                                 &btrfs_inode, ext2_fs, ext2_ino);
796                 if (ret)
797                         return ret;
798         }
799         return btrfs_insert_inode(trans, root, objectid, &btrfs_inode);
800 }
801
802 /*
803  * scan ext2's inode bitmap and copy all used inodes.
804  */
805 static int ext2_copy_inodes(struct btrfs_convert_context *cctx,
806                             struct btrfs_root *root,
807                             int datacsum, int packing, int noxattr, struct task_ctx *p)
808 {
809         ext2_filsys ext2_fs = cctx->fs_data;
810         int ret;
811         errcode_t err;
812         ext2_inode_scan ext2_scan;
813         struct ext2_inode ext2_inode;
814         ext2_ino_t ext2_ino;
815         u64 objectid;
816         struct btrfs_trans_handle *trans;
817
818         trans = btrfs_start_transaction(root, 1);
819         if (!trans)
820                 return -ENOMEM;
821         err = ext2fs_open_inode_scan(ext2_fs, 0, &ext2_scan);
822         if (err) {
823                 fprintf(stderr, "ext2fs_open_inode_scan: %s\n", error_message(err));
824                 return -1;
825         }
826         while (!(err = ext2fs_get_next_inode(ext2_scan, &ext2_ino,
827                                              &ext2_inode))) {
828                 /* no more inodes */
829                 if (ext2_ino == 0)
830                         break;
831                 /* skip special inode in ext2fs */
832                 if (ext2_ino < EXT2_GOOD_OLD_FIRST_INO &&
833                     ext2_ino != EXT2_ROOT_INO)
834                         continue;
835                 objectid = ext2_ino + INO_OFFSET;
836                 ret = ext2_copy_single_inode(trans, root,
837                                         objectid, ext2_fs, ext2_ino,
838                                         &ext2_inode, datacsum, packing,
839                                         noxattr);
840                 p->cur_copy_inodes++;
841                 if (ret)
842                         return ret;
843                 if (trans->blocks_used >= 4096) {
844                         ret = btrfs_commit_transaction(trans, root);
845                         BUG_ON(ret);
846                         trans = btrfs_start_transaction(root, 1);
847                         BUG_ON(!trans);
848                 }
849         }
850         if (err) {
851                 fprintf(stderr, "ext2fs_get_next_inode: %s\n", error_message(err));
852                 return -1;
853         }
854         ret = btrfs_commit_transaction(trans, root);
855         BUG_ON(ret);
856         ext2fs_close_inode_scan(ext2_scan);
857
858         return ret;
859 }
860
861 const struct btrfs_convert_operations ext2_convert_ops = {
862         .name                   = "ext2",
863         .open_fs                = ext2_open_fs,
864         .read_used_space        = ext2_read_used_space,
865         .copy_inodes            = ext2_copy_inodes,
866         .close_fs               = ext2_close_fs,
867         .check_state            = ext2_check_state,
868 };
869
870 #endif  /* BTRFSCONVERT_EXT2 */