ext4_mkfs: add journal node creation support
[lwext4.git] / src / ext4_mkfs.c
index c32193ad713fb35cdf3a59955a15a4ad880471fe..81867d6af237b41416cd85e0296d16aa473265d1 100644 (file)
@@ -55,7 +55,7 @@
 
 struct fs_aux_info {
        struct ext4_sblock *sb;
-       struct ext4_bgroup *bg_desc;
+       uint8_t *bg_desc_blk;
        struct xattr_list_element *xattrs;
        uint32_t first_data_block;
        uint64_t len_blocks;
@@ -176,12 +176,12 @@ static int create_fs_aux_info(struct fs_aux_info *aux_info,
                aux_info->len_blocks -= last_group_size;
        }
 
-       aux_info->sb = calloc(1, EXT4_SUPERBLOCK_SIZE);
+       aux_info->sb = ext4_calloc(1, EXT4_SUPERBLOCK_SIZE);
        if (!aux_info->sb)
                return ENOMEM;
 
-       aux_info->bg_desc = calloc(1, sizeof(struct ext4_bgroup));
-       if (!aux_info->bg_desc)
+       aux_info->bg_desc_blk = ext4_calloc(1, info->block_size);
+       if (!aux_info->bg_desc_blk)
                return ENOMEM;
 
        aux_info->xattrs = NULL;
@@ -213,14 +213,14 @@ static int create_fs_aux_info(struct fs_aux_info *aux_info,
 static void release_fs_aux_info(struct fs_aux_info *aux_info)
 {
        if (aux_info->sb)
-               free(aux_info->sb);
-       if (aux_info->bg_desc)
-               free(aux_info->bg_desc);
+               ext4_free(aux_info->sb);
+       if (aux_info->bg_desc_blk)
+               ext4_free(aux_info->bg_desc_blk);
 }
 
 
 /* Fill in the superblock memory buffer based on the filesystem parameters */
-static void fill_in_sb(struct fs_aux_info *aux_info, struct ext4_mkfs_info *info)
+static void fill_sb(struct fs_aux_info *aux_info, struct ext4_mkfs_info *info)
 {
        struct ext4_sblock *sb = aux_info->sb;
 
@@ -273,6 +273,8 @@ static void fill_in_sb(struct fs_aux_info *aux_info, struct ext4_mkfs_info *info
 
        if (info->feat_compat & EXT4_FCOM_HAS_JOURNAL)
                sb->journal_inode_number = to_le32(EXT4_JOURNAL_INO);
+
+       sb->journal_backup_type = 1;
        sb->journal_dev = to_le32(0);
        sb->last_orphan = to_le32(0);
        sb->hash_seed[0] = to_le32(0x11111111);
@@ -295,23 +297,67 @@ static void fill_in_sb(struct fs_aux_info *aux_info, struct ext4_mkfs_info *info
 }
 
 
+static int write_bgroup_block(struct ext4_blockdev *bd,
+                             struct fs_aux_info *aux_info,
+                             struct ext4_mkfs_info *info,
+                             uint32_t blk)
+{
+       int r = EOK;
+       uint32_t j;
+       struct ext4_block b;
+
+       uint32_t block_size = ext4_sb_get_block_size(aux_info->sb);
+
+       for (j = 0; j < aux_info->groups; j++) {
+               uint64_t bg_start_block = aux_info->first_data_block +
+                                         j * info->blocks_per_group;
+               uint32_t blk_off = 0;
+
+               blk_off += aux_info->bg_desc_blocks;
+               if (has_superblock(info, j)) {
+                       bg_start_block++;
+                       blk_off += info->bg_desc_reserve_blocks;
+               }
+
+               uint64_t dsc_blk = bg_start_block + blk;
+
+               r = ext4_block_get_noread(bd, &b, dsc_blk);
+               if (r != EOK)
+                       return r;
+
+               memcpy(b.data, aux_info->bg_desc_blk, block_size);
+
+               ext4_bcache_set_dirty(b.buf);
+               r = ext4_block_set(bd, &b);
+               if (r != EOK)
+                       return r;
+       }
+
+       return r;
+}
 
 static int write_bgroups(struct ext4_blockdev *bd, struct fs_aux_info *aux_info,
                         struct ext4_mkfs_info *info)
 {
        int r = EOK;
-       uint32_t i, j;
-       uint32_t bg_free_blk = 0;
-       uint64_t sb_free_blk = 0;
+
        struct ext4_block b;
+       struct ext4_bgroup *bg_desc;
 
+       uint32_t i;
+       uint32_t bg_free_blk = 0;
+       uint64_t sb_free_blk = 0;
        uint32_t block_size = ext4_sb_get_block_size(aux_info->sb);
+       uint32_t dsc_size = ext4_sb_get_desc_size(aux_info->sb);
+       uint32_t dsc_per_block = block_size / dsc_size;
+       uint32_t k = 0;
 
        for (i = 0; i < aux_info->groups; i++) {
                uint64_t bg_start_block = aux_info->first_data_block +
                        aux_info->first_data_block + i * info->blocks_per_group;
                uint32_t blk_off = 0;
 
+               bg_desc = (void *)(aux_info->bg_desc_blk + k * dsc_size);
                bg_free_blk = info->blocks_per_group -
                                aux_info->inode_table_blocks;
 
@@ -328,65 +374,30 @@ static int write_bgroups(struct ext4_blockdev *bd, struct fs_aux_info *aux_info,
                        bg_free_blk -= aux_info->bg_desc_blocks;
                }
 
-               ext4_bg_set_block_bitmap(aux_info->bg_desc, aux_info->sb,
-                               bg_start_block + blk_off + 1);
+               ext4_bg_set_block_bitmap(bg_desc, aux_info->sb,
+                                        bg_start_block + blk_off + 1);
 
-               ext4_bg_set_inode_bitmap(aux_info->bg_desc, aux_info->sb,
-                               bg_start_block + blk_off + 2);
+               ext4_bg_set_inode_bitmap(bg_desc, aux_info->sb,
+                                        bg_start_block + blk_off + 2);
 
-               ext4_bg_set_inode_table_first_block(aux_info->bg_desc,
-                               aux_info->sb,
-                               bg_start_block + blk_off + 3);
+               ext4_bg_set_inode_table_first_block(bg_desc,
+                                               aux_info->sb,
+                                               bg_start_block + blk_off + 3);
 
-               ext4_bg_set_free_blocks_count(aux_info->bg_desc,
-                               aux_info->sb, bg_free_blk);
+               ext4_bg_set_free_blocks_count(bg_desc, aux_info->sb,
+                                             bg_free_blk);
 
-               ext4_bg_set_free_inodes_count(aux_info->bg_desc,
+               ext4_bg_set_free_inodes_count(bg_desc,
                                aux_info->sb, aux_info->sb->inodes_per_group);
 
-               ext4_bg_set_used_dirs_count(aux_info->bg_desc, aux_info->sb,
-                                           0);
+               ext4_bg_set_used_dirs_count(bg_desc, aux_info->sb, 0);
 
-               ext4_bg_set_flag(aux_info->bg_desc,
-                               EXT4_BLOCK_GROUP_BLOCK_UNINIT |
-                               EXT4_BLOCK_GROUP_INODE_UNINIT);
+               ext4_bg_set_flag(bg_desc,
+                                EXT4_BLOCK_GROUP_BLOCK_UNINIT |
+                                EXT4_BLOCK_GROUP_INODE_UNINIT);
 
                sb_free_blk += bg_free_blk;
 
-
-               for (j = 0; j < aux_info->groups; j++) {
-                       uint64_t bg_start_block = aux_info->first_data_block +
-                                                 j * info->blocks_per_group;
-                       uint32_t blk_off = 0;
-
-                       blk_off += aux_info->bg_desc_blocks;
-                       if (has_superblock(info, j)) {
-                               bg_start_block++;
-                               blk_off += info->bg_desc_reserve_blocks;
-                       }
-
-
-                       uint32_t dsc_pos = 0;
-                       uint32_t dsc_size = ext4_sb_get_desc_size(aux_info->sb);
-                       uint64_t dsc_blk = bg_start_block +
-                                          i * dsc_size / block_size;
-
-                       r = ext4_block_get(bd, &b, dsc_blk);
-                       if (r != EOK)
-                               return r;
-
-                       dsc_pos = (i * dsc_size) % block_size;
-                       memcpy(b.data + dsc_pos,
-                                       aux_info->bg_desc,
-                                       dsc_size);
-
-
-                       ext4_bcache_set_dirty(b.buf);
-                       r = ext4_block_set(bd, &b);
-                       if (r != EOK)
-                               return r;
-               }
-
                r = ext4_block_get_noread(bd, &b, bg_start_block + blk_off + 1);
                if (r != EOK)
                        return r;
@@ -403,8 +414,21 @@ static int write_bgroups(struct ext4_blockdev *bd, struct fs_aux_info *aux_info,
                r = ext4_block_set(bd, &b);
                if (r != EOK)
                        return r;
+
+               if (++k != dsc_per_block)
+                       continue;
+
+               k = 0;
+               r = write_bgroup_block(bd, aux_info, info, i / dsc_per_block);
+               if (r != EOK)
+                       return r;
+
        }
 
+       r = write_bgroup_block(bd, aux_info, info, i / dsc_per_block);
+       if (r != EOK)
+               return r;
+
        ext4_sb_set_free_blocks_cnt(aux_info->sb, sb_free_blk);
        return r;
 }
@@ -445,7 +469,7 @@ int ext4_mkfs_read_info(struct ext4_blockdev *bd, struct ext4_mkfs_info *info)
        if (r != EOK)
                return r;
 
-       sb = malloc(EXT4_SUPERBLOCK_SIZE);
+       sb = ext4_malloc(EXT4_SUPERBLOCK_SIZE);
        if (!sb)
                goto Finish;
 
@@ -458,12 +482,12 @@ int ext4_mkfs_read_info(struct ext4_blockdev *bd, struct ext4_mkfs_info *info)
 
 Finish:
        if (sb)
-               free(sb);
+               ext4_free(sb);
        ext4_block_fini(bd);
        return r;
 }
 
-static int mkfs_initial(struct ext4_blockdev *bd, struct ext4_mkfs_info *info)
+static int mkfs_init(struct ext4_blockdev *bd, struct ext4_mkfs_info *info)
 {
        int r;
        struct fs_aux_info aux_info;
@@ -473,7 +497,7 @@ static int mkfs_initial(struct ext4_blockdev *bd, struct ext4_mkfs_info *info)
        if (r != EOK)
                goto Finish;
 
-       fill_in_sb(&aux_info, info);
+       fill_sb(&aux_info, info);
 
        r = write_bgroups(bd, &aux_info, info);
        if (r != EOK)
@@ -519,6 +543,8 @@ static int alloc_inodes(struct ext4_fs *fs)
                case EXT4_GOOD_OLD_FIRST_INO:
                        filetype = EXT4_DE_DIR;
                        break;
+               default:
+                       break;
                }
 
                r = ext4_fs_alloc_inode(fs, &inode_ref, filetype);
@@ -526,6 +552,14 @@ static int alloc_inodes(struct ext4_fs *fs)
                        return r;
 
                ext4_inode_set_mode(&fs->sb, inode_ref.inode, 0);
+
+               switch (i) {
+               case EXT4_ROOT_INO:
+               case EXT4_JOURNAL_INO:
+                       ext4_fs_inode_blocks_init(fs, &inode_ref);
+                       break;
+               }
+
                ext4_fs_put_inode_ref(&inode_ref);
        }
 
@@ -599,6 +633,70 @@ static int create_dirs(struct ext4_fs *fs)
        return r;
 }
 
+static int create_journal_inode(struct ext4_fs *fs,
+                               struct ext4_mkfs_info *info)
+{
+       int ret;
+       struct ext4_inode_ref inode_ref;
+       uint64_t blocks_count;
+
+       if (!info->journal)
+               return EOK;
+
+       ret = ext4_fs_get_inode_ref(fs, EXT4_JOURNAL_INO, &inode_ref);
+       if (ret != EOK)
+               return ret;
+
+       struct ext4_inode *inode = inode_ref.inode;
+
+       ext4_inode_set_mode(&fs->sb, inode, EXT4_INODE_MODE_FILE | 0600);
+       ext4_inode_set_links_cnt(inode, 1);
+
+       blocks_count = ext4_inode_get_blocks_count(&fs->sb, inode);
+
+       while (blocks_count++ < info->journal_blocks)
+       {
+               ext4_fsblk_t fblock;
+               ext4_lblk_t iblock;
+               struct ext4_block blk;
+
+               ret = ext4_fs_append_inode_dblk(&inode_ref, &fblock, &iblock);
+               if (ret != EOK)
+                       goto Finish;
+
+               if (iblock != 0)
+                       continue;
+
+               ret = ext4_block_get(fs->bdev, &blk, fblock);
+               if (ret != EOK)
+                       goto Finish;
+
+
+               struct jbd_sb * jbd_sb = (struct jbd_sb * )blk.data;
+               memset(jbd_sb, 0, sizeof(struct jbd_sb));
+
+               jbd_sb->header.magic = to_be32(JBD_MAGIC_NUMBER);
+               jbd_sb->header.blocktype = to_be32(JBD_SUPERBLOCK_V2);
+               jbd_sb->blocksize = to_be32(info->block_size);
+               jbd_sb->maxlen = to_be32(info->journal_blocks);
+               jbd_sb->nr_users = to_be32(1);
+               jbd_sb->first = to_be32(1);
+               jbd_sb->sequence = to_be32(1);
+
+               ext4_bcache_set_dirty(blk.buf);
+               ret = ext4_block_set(fs->bdev, &blk);
+               if (ret != EOK)
+                       goto Finish;
+       }
+
+       memcpy(fs->sb.journal_blocks, inode->blocks, sizeof(inode->blocks));
+
+       Finish:
+       ext4_fs_put_inode_ref(&inode_ref);
+
+       return ret;
+}
+
 int ext4_mkfs(struct ext4_fs *fs, struct ext4_blockdev *bd,
              struct ext4_mkfs_info *info, int fs_type)
 {
@@ -654,14 +752,19 @@ int ext4_mkfs(struct ext4_fs *fs, struct ext4_blockdev *bd,
                break;
        }
 
-       /*TODO: handle this features*/
+       /*TODO: handle this features some day...*/
        info->feat_incompat &= ~EXT4_FINCOM_META_BG;
        info->feat_incompat &= ~EXT4_FINCOM_FLEX_BG;
+       info->feat_incompat &= ~EXT4_FINCOM_64BIT;
+
        info->feat_ro_compat &= ~EXT4_FRO_COM_METADATA_CSUM;
+       info->feat_ro_compat &= ~EXT4_FRO_COM_GDT_CSUM;
+       info->feat_ro_compat &= ~EXT4_FRO_COM_DIR_NLINK;
+       info->feat_ro_compat &= ~EXT4_FRO_COM_EXTRA_ISIZE;
+       info->feat_ro_compat &= ~EXT4_FRO_COM_HUGE_FILE;
 
-       /*TODO: handle journal feature & inode*/
-       if (info->journal == 0)
-               info->feat_compat |= 0;
+       if (info->journal)
+               info->feat_compat |= EXT4_FCOM_HAS_JOURNAL;
 
        if (info->dsc_size == 0) {
 
@@ -701,8 +804,10 @@ int ext4_mkfs(struct ext4_fs *fs, struct ext4_blockdev *bd,
        ext4_dbg(DEBUG_MKFS, DBG_NONE "Label: %s\n", info->label);
 
        struct ext4_bcache bc;
+
        memset(&bc, 0, sizeof(struct ext4_bcache));
        ext4_block_set_lb_size(bd, info->block_size);
+
        r = ext4_bcache_init_dynamic(&bc, CONFIG_BLOCK_DEV_CACHE_SIZE,
                                      info->block_size);
        if (r != EOK)
@@ -717,7 +822,7 @@ int ext4_mkfs(struct ext4_fs *fs, struct ext4_blockdev *bd,
        if (r != EOK)
                goto cache_fini;
 
-       r = mkfs_initial(bd, info);
+       r = mkfs_init(bd, info);
        if (r != EOK)
                goto cache_fini;
 
@@ -737,6 +842,10 @@ int ext4_mkfs(struct ext4_fs *fs, struct ext4_blockdev *bd,
        if (r != EOK)
                goto fs_fini;
 
+       r = create_journal_inode(fs, info);
+       if (r != EOK)
+               goto fs_fini;
+
        fs_fini:
        ext4_fs_fini(fs);