1328970deSThomas Gleixner // SPDX-License-Identifier: GPL-2.0-or-later 2ccd979bdSMark Fasheh /* -*- mode: c; c-basic-offset: 8; -*- 3ccd979bdSMark Fasheh * vim: noexpandtab sw=8 ts=8 sts=0: 4ccd979bdSMark Fasheh * 5ccd979bdSMark Fasheh * suballoc.c 6ccd979bdSMark Fasheh * 7ccd979bdSMark Fasheh * metadata alloc and free 8ccd979bdSMark Fasheh * Inspired by ext3 block groups. 9ccd979bdSMark Fasheh * 10ccd979bdSMark Fasheh * Copyright (C) 2002, 2004 Oracle. All rights reserved. 11ccd979bdSMark Fasheh */ 12ccd979bdSMark Fasheh 13ccd979bdSMark Fasheh #include <linux/fs.h> 14ccd979bdSMark Fasheh #include <linux/types.h> 15ccd979bdSMark Fasheh #include <linux/slab.h> 16ccd979bdSMark Fasheh #include <linux/highmem.h> 17ccd979bdSMark Fasheh 18ccd979bdSMark Fasheh #include <cluster/masklog.h> 19ccd979bdSMark Fasheh 20ccd979bdSMark Fasheh #include "ocfs2.h" 21ccd979bdSMark Fasheh 22ccd979bdSMark Fasheh #include "alloc.h" 23d6b32bbbSJoel Becker #include "blockcheck.h" 24ccd979bdSMark Fasheh #include "dlmglue.h" 25ccd979bdSMark Fasheh #include "inode.h" 26ccd979bdSMark Fasheh #include "journal.h" 27ccd979bdSMark Fasheh #include "localalloc.h" 28ccd979bdSMark Fasheh #include "suballoc.h" 29ccd979bdSMark Fasheh #include "super.h" 30ccd979bdSMark Fasheh #include "sysfile.h" 31ccd979bdSMark Fasheh #include "uptodate.h" 322f73e135STao Ma #include "ocfs2_trace.h" 33ccd979bdSMark Fasheh 34ccd979bdSMark Fasheh #include "buffer_head_io.h" 35ccd979bdSMark Fasheh 36ffda89a3STao Ma #define NOT_ALLOC_NEW_GROUP 0 3760ca81e8STao Ma #define ALLOC_NEW_GROUP 0x1 3860ca81e8STao Ma #define ALLOC_GROUPS_FROM_GLOBAL 0x2 39ffda89a3STao Ma 40b89c5428STiger Yang #define OCFS2_MAX_TO_STEAL 1024 414d0ddb2cSTao Ma 427d1fe093SJoel Becker struct ocfs2_suballoc_result { 432b6cb576SJoel Becker u64 sr_bg_blkno; /* The bg we allocated from. Set 442b6cb576SJoel Becker to 0 when a block group is 452b6cb576SJoel Becker contiguous. */ 46e49e2767SMark Fasheh u64 sr_bg_stable_blkno; /* 47e49e2767SMark Fasheh * Doesn't change, always 48e49e2767SMark Fasheh * set to target block 49e49e2767SMark Fasheh * group descriptor 50e49e2767SMark Fasheh * block. 51e49e2767SMark Fasheh */ 52ba206635SJoel Becker u64 sr_blkno; /* The first allocated block */ 537d1fe093SJoel Becker unsigned int sr_bit_offset; /* The bit in the bg */ 547d1fe093SJoel Becker unsigned int sr_bits; /* How many bits we claimed */ 557d1fe093SJoel Becker }; 567d1fe093SJoel Becker 57b2b6ebf5SMark Fasheh static u64 ocfs2_group_from_res(struct ocfs2_suballoc_result *res) 58b2b6ebf5SMark Fasheh { 59b2b6ebf5SMark Fasheh if (res->sr_blkno == 0) 60b2b6ebf5SMark Fasheh return 0; 61b2b6ebf5SMark Fasheh 62b2b6ebf5SMark Fasheh if (res->sr_bg_blkno) 63b2b6ebf5SMark Fasheh return res->sr_bg_blkno; 64b2b6ebf5SMark Fasheh 65b2b6ebf5SMark Fasheh return ocfs2_which_suballoc_group(res->sr_blkno, res->sr_bit_offset); 66b2b6ebf5SMark Fasheh } 67b2b6ebf5SMark Fasheh 68ccd979bdSMark Fasheh static inline u16 ocfs2_find_victim_chain(struct ocfs2_chain_list *cl); 691fabe148SMark Fasheh static int ocfs2_block_group_fill(handle_t *handle, 70ccd979bdSMark Fasheh struct inode *alloc_inode, 71ccd979bdSMark Fasheh struct buffer_head *bg_bh, 72ccd979bdSMark Fasheh u64 group_blkno, 73798db35fSJoel Becker unsigned int group_clusters, 74ccd979bdSMark Fasheh u16 my_chain, 75ccd979bdSMark Fasheh struct ocfs2_chain_list *cl); 76ccd979bdSMark Fasheh static int ocfs2_block_group_alloc(struct ocfs2_super *osb, 77ccd979bdSMark Fasheh struct inode *alloc_inode, 781187c968SJoel Becker struct buffer_head *bh, 7960ca81e8STao Ma u64 max_block, 80feb473a6STao Ma u64 *last_alloc_group, 8160ca81e8STao Ma int flags); 82ccd979bdSMark Fasheh 83ccd979bdSMark Fasheh static int ocfs2_cluster_group_search(struct inode *inode, 84ccd979bdSMark Fasheh struct buffer_head *group_bh, 85ccd979bdSMark Fasheh u32 bits_wanted, u32 min_bits, 861187c968SJoel Becker u64 max_block, 877d1fe093SJoel Becker struct ocfs2_suballoc_result *res); 88ccd979bdSMark Fasheh static int ocfs2_block_group_search(struct inode *inode, 89ccd979bdSMark Fasheh struct buffer_head *group_bh, 90ccd979bdSMark Fasheh u32 bits_wanted, u32 min_bits, 911187c968SJoel Becker u64 max_block, 927d1fe093SJoel Becker struct ocfs2_suballoc_result *res); 93aa8f8e93SJoel Becker static int ocfs2_claim_suballoc_bits(struct ocfs2_alloc_context *ac, 941fabe148SMark Fasheh handle_t *handle, 95ccd979bdSMark Fasheh u32 bits_wanted, 96ccd979bdSMark Fasheh u32 min_bits, 977d1fe093SJoel Becker struct ocfs2_suballoc_result *res); 98ccd979bdSMark Fasheh static int ocfs2_test_bg_bit_allocatable(struct buffer_head *bg_bh, 99ccd979bdSMark Fasheh int nr); 1001fabe148SMark Fasheh static int ocfs2_relink_block_group(handle_t *handle, 101ccd979bdSMark Fasheh struct inode *alloc_inode, 102ccd979bdSMark Fasheh struct buffer_head *fe_bh, 103ccd979bdSMark Fasheh struct buffer_head *bg_bh, 104ccd979bdSMark Fasheh struct buffer_head *prev_bg_bh, 105ccd979bdSMark Fasheh u16 chain); 106ccd979bdSMark Fasheh static inline int ocfs2_block_group_reasonably_empty(struct ocfs2_group_desc *bg, 107ccd979bdSMark Fasheh u32 wanted); 108ccd979bdSMark Fasheh static inline u32 ocfs2_desc_bitmap_to_cluster_off(struct inode *inode, 109ccd979bdSMark Fasheh u64 bg_blkno, 110ccd979bdSMark Fasheh u16 bg_bit_off); 111ccd979bdSMark Fasheh static inline void ocfs2_block_to_cluster_group(struct inode *inode, 112ccd979bdSMark Fasheh u64 data_blkno, 113ccd979bdSMark Fasheh u64 *bg_blkno, 114ccd979bdSMark Fasheh u16 *bg_bit_off); 1151187c968SJoel Becker static int ocfs2_reserve_clusters_with_limit(struct ocfs2_super *osb, 1161187c968SJoel Becker u32 bits_wanted, u64 max_block, 11760ca81e8STao Ma int flags, 1181187c968SJoel Becker struct ocfs2_alloc_context **ac); 119ccd979bdSMark Fasheh 1209c7af40bSMark Fasheh void ocfs2_free_ac_resource(struct ocfs2_alloc_context *ac) 121ccd979bdSMark Fasheh { 122da5cbf2fSMark Fasheh struct inode *inode = ac->ac_inode; 123da5cbf2fSMark Fasheh 124da5cbf2fSMark Fasheh if (inode) { 125da5cbf2fSMark Fasheh if (ac->ac_which != OCFS2_AC_USE_LOCAL) 126e63aecb6SMark Fasheh ocfs2_inode_unlock(inode, 1); 127da5cbf2fSMark Fasheh 1285955102cSAl Viro inode_unlock(inode); 129da5cbf2fSMark Fasheh 130da5cbf2fSMark Fasheh iput(inode); 1314d0ddb2cSTao Ma ac->ac_inode = NULL; 132da5cbf2fSMark Fasheh } 133ccd979bdSMark Fasheh brelse(ac->ac_bh); 1344d0ddb2cSTao Ma ac->ac_bh = NULL; 135e3b4a97dSMark Fasheh ac->ac_resv = NULL; 136e49e2767SMark Fasheh kfree(ac->ac_find_loc_priv); 137e49e2767SMark Fasheh ac->ac_find_loc_priv = NULL; 138e49e2767SMark Fasheh } 1394d0ddb2cSTao Ma 1404d0ddb2cSTao Ma void ocfs2_free_alloc_context(struct ocfs2_alloc_context *ac) 1414d0ddb2cSTao Ma { 1424d0ddb2cSTao Ma ocfs2_free_ac_resource(ac); 143ccd979bdSMark Fasheh kfree(ac); 144ccd979bdSMark Fasheh } 145ccd979bdSMark Fasheh 146ccd979bdSMark Fasheh static u32 ocfs2_bits_per_group(struct ocfs2_chain_list *cl) 147ccd979bdSMark Fasheh { 148ccd979bdSMark Fasheh return (u32)le16_to_cpu(cl->cl_cpg) * (u32)le16_to_cpu(cl->cl_bpc); 149ccd979bdSMark Fasheh } 150ccd979bdSMark Fasheh 15157e3e797SJoel Becker #define do_error(fmt, ...) \ 15257e3e797SJoel Becker do { \ 15378c37eb0STao Ma if (resize) \ 1547ecef14aSJoe Perches mlog(ML_ERROR, fmt, ##__VA_ARGS__); \ 15557e3e797SJoel Becker else \ 15617a5b9abSGoldwyn Rodrigues return ocfs2_error(sb, fmt, ##__VA_ARGS__); \ 15757e3e797SJoel Becker } while (0) 15857e3e797SJoel Becker 159970e4936SJoel Becker static int ocfs2_validate_gd_self(struct super_block *sb, 160970e4936SJoel Becker struct buffer_head *bh, 16178c37eb0STao Ma int resize) 162970e4936SJoel Becker { 163970e4936SJoel Becker struct ocfs2_group_desc *gd = (struct ocfs2_group_desc *)bh->b_data; 164970e4936SJoel Becker 1657bf72edeSMark Fasheh if (!OCFS2_IS_VALID_GROUP_DESC(gd)) { 1667ecef14aSJoe Perches do_error("Group descriptor #%llu has bad signature %.*s\n", 16768f64d47SJoel Becker (unsigned long long)bh->b_blocknr, 7, 16857e3e797SJoel Becker gd->bg_signature); 1697bf72edeSMark Fasheh } 1707bf72edeSMark Fasheh 17168f64d47SJoel Becker if (le64_to_cpu(gd->bg_blkno) != bh->b_blocknr) { 1727ecef14aSJoe Perches do_error("Group descriptor #%llu has an invalid bg_blkno of %llu\n", 17368f64d47SJoel Becker (unsigned long long)bh->b_blocknr, 17468f64d47SJoel Becker (unsigned long long)le64_to_cpu(gd->bg_blkno)); 17568f64d47SJoel Becker } 17668f64d47SJoel Becker 17768f64d47SJoel Becker if (le32_to_cpu(gd->bg_generation) != OCFS2_SB(sb)->fs_generation) { 1787ecef14aSJoe Perches do_error("Group descriptor #%llu has an invalid fs_generation of #%u\n", 17968f64d47SJoel Becker (unsigned long long)bh->b_blocknr, 18068f64d47SJoel Becker le32_to_cpu(gd->bg_generation)); 18168f64d47SJoel Becker } 18268f64d47SJoel Becker 183970e4936SJoel Becker if (le16_to_cpu(gd->bg_free_bits_count) > le16_to_cpu(gd->bg_bits)) { 1847ecef14aSJoe Perches do_error("Group descriptor #%llu has bit count %u but claims that %u are free\n", 185970e4936SJoel Becker (unsigned long long)bh->b_blocknr, 186970e4936SJoel Becker le16_to_cpu(gd->bg_bits), 187970e4936SJoel Becker le16_to_cpu(gd->bg_free_bits_count)); 188970e4936SJoel Becker } 189970e4936SJoel Becker 190970e4936SJoel Becker if (le16_to_cpu(gd->bg_bits) > (8 * le16_to_cpu(gd->bg_size))) { 1917ecef14aSJoe Perches do_error("Group descriptor #%llu has bit count %u but max bitmap bits of %u\n", 192970e4936SJoel Becker (unsigned long long)bh->b_blocknr, 193970e4936SJoel Becker le16_to_cpu(gd->bg_bits), 194970e4936SJoel Becker 8 * le16_to_cpu(gd->bg_size)); 195970e4936SJoel Becker } 196970e4936SJoel Becker 197970e4936SJoel Becker return 0; 198970e4936SJoel Becker } 199970e4936SJoel Becker 200970e4936SJoel Becker static int ocfs2_validate_gd_parent(struct super_block *sb, 201970e4936SJoel Becker struct ocfs2_dinode *di, 202970e4936SJoel Becker struct buffer_head *bh, 20378c37eb0STao Ma int resize) 204970e4936SJoel Becker { 205970e4936SJoel Becker unsigned int max_bits; 206970e4936SJoel Becker struct ocfs2_group_desc *gd = (struct ocfs2_group_desc *)bh->b_data; 207970e4936SJoel Becker 2087bf72edeSMark Fasheh if (di->i_blkno != gd->bg_parent_dinode) { 2097ecef14aSJoe Perches do_error("Group descriptor #%llu has bad parent pointer (%llu, expected %llu)\n", 21068f64d47SJoel Becker (unsigned long long)bh->b_blocknr, 2117bf72edeSMark Fasheh (unsigned long long)le64_to_cpu(gd->bg_parent_dinode), 2127bf72edeSMark Fasheh (unsigned long long)le64_to_cpu(di->i_blkno)); 2137bf72edeSMark Fasheh } 2147bf72edeSMark Fasheh 2157bf72edeSMark Fasheh max_bits = le16_to_cpu(di->id2.i_chain.cl_cpg) * le16_to_cpu(di->id2.i_chain.cl_bpc); 2167bf72edeSMark Fasheh if (le16_to_cpu(gd->bg_bits) > max_bits) { 2177ecef14aSJoe Perches do_error("Group descriptor #%llu has bit count of %u\n", 21868f64d47SJoel Becker (unsigned long long)bh->b_blocknr, 2197bf72edeSMark Fasheh le16_to_cpu(gd->bg_bits)); 2207bf72edeSMark Fasheh } 2217bf72edeSMark Fasheh 22278c37eb0STao Ma /* In resize, we may meet the case bg_chain == cl_next_free_rec. */ 22378c37eb0STao Ma if ((le16_to_cpu(gd->bg_chain) > 22478c37eb0STao Ma le16_to_cpu(di->id2.i_chain.cl_next_free_rec)) || 22578c37eb0STao Ma ((le16_to_cpu(gd->bg_chain) == 22678c37eb0STao Ma le16_to_cpu(di->id2.i_chain.cl_next_free_rec)) && !resize)) { 2277ecef14aSJoe Perches do_error("Group descriptor #%llu has bad chain %u\n", 22868f64d47SJoel Becker (unsigned long long)bh->b_blocknr, 2297bf72edeSMark Fasheh le16_to_cpu(gd->bg_chain)); 2307bf72edeSMark Fasheh } 2317bf72edeSMark Fasheh 232970e4936SJoel Becker return 0; 2337bf72edeSMark Fasheh } 2347bf72edeSMark Fasheh 23557e3e797SJoel Becker #undef do_error 2367bf72edeSMark Fasheh 237970e4936SJoel Becker /* 238970e4936SJoel Becker * This version only prints errors. It does not fail the filesystem, and 239970e4936SJoel Becker * exists only for resize. 240970e4936SJoel Becker */ 241970e4936SJoel Becker int ocfs2_check_group_descriptor(struct super_block *sb, 242970e4936SJoel Becker struct ocfs2_dinode *di, 243970e4936SJoel Becker struct buffer_head *bh) 244970e4936SJoel Becker { 245970e4936SJoel Becker int rc; 246d6b32bbbSJoel Becker struct ocfs2_group_desc *gd = (struct ocfs2_group_desc *)bh->b_data; 247970e4936SJoel Becker 248d6b32bbbSJoel Becker BUG_ON(!buffer_uptodate(bh)); 249d6b32bbbSJoel Becker 250d6b32bbbSJoel Becker /* 251d6b32bbbSJoel Becker * If the ecc fails, we return the error but otherwise 252d6b32bbbSJoel Becker * leave the filesystem running. We know any error is 253d6b32bbbSJoel Becker * local to this block. 254d6b32bbbSJoel Becker */ 255d6b32bbbSJoel Becker rc = ocfs2_validate_meta_ecc(sb, bh->b_data, &gd->bg_check); 25613723d00SJoel Becker if (rc) { 25713723d00SJoel Becker mlog(ML_ERROR, 25813723d00SJoel Becker "Checksum failed for group descriptor %llu\n", 25913723d00SJoel Becker (unsigned long long)bh->b_blocknr); 26013723d00SJoel Becker } else 261970e4936SJoel Becker rc = ocfs2_validate_gd_self(sb, bh, 1); 262970e4936SJoel Becker if (!rc) 263970e4936SJoel Becker rc = ocfs2_validate_gd_parent(sb, di, bh, 1); 264970e4936SJoel Becker 265970e4936SJoel Becker return rc; 266970e4936SJoel Becker } 267970e4936SJoel Becker 268970e4936SJoel Becker static int ocfs2_validate_group_descriptor(struct super_block *sb, 269970e4936SJoel Becker struct buffer_head *bh) 270970e4936SJoel Becker { 271d6b32bbbSJoel Becker int rc; 272d6b32bbbSJoel Becker struct ocfs2_group_desc *gd = (struct ocfs2_group_desc *)bh->b_data; 273d6b32bbbSJoel Becker 2742f73e135STao Ma trace_ocfs2_validate_group_descriptor( 275970e4936SJoel Becker (unsigned long long)bh->b_blocknr); 276970e4936SJoel Becker 277d6b32bbbSJoel Becker BUG_ON(!buffer_uptodate(bh)); 278d6b32bbbSJoel Becker 279d6b32bbbSJoel Becker /* 280d6b32bbbSJoel Becker * If the ecc fails, we return the error but otherwise 281d6b32bbbSJoel Becker * leave the filesystem running. We know any error is 282d6b32bbbSJoel Becker * local to this block. 283d6b32bbbSJoel Becker */ 284d6b32bbbSJoel Becker rc = ocfs2_validate_meta_ecc(sb, bh->b_data, &gd->bg_check); 285d6b32bbbSJoel Becker if (rc) 286d6b32bbbSJoel Becker return rc; 287d6b32bbbSJoel Becker 288d6b32bbbSJoel Becker /* 289d6b32bbbSJoel Becker * Errors after here are fatal. 290d6b32bbbSJoel Becker */ 291d6b32bbbSJoel Becker 292970e4936SJoel Becker return ocfs2_validate_gd_self(sb, bh, 0); 2937bf72edeSMark Fasheh } 2947bf72edeSMark Fasheh 29568f64d47SJoel Becker int ocfs2_read_group_descriptor(struct inode *inode, struct ocfs2_dinode *di, 29668f64d47SJoel Becker u64 gd_blkno, struct buffer_head **bh) 29768f64d47SJoel Becker { 29868f64d47SJoel Becker int rc; 29968f64d47SJoel Becker struct buffer_head *tmp = *bh; 30068f64d47SJoel Becker 3018cb471e8SJoel Becker rc = ocfs2_read_block(INODE_CACHE(inode), gd_blkno, &tmp, 302970e4936SJoel Becker ocfs2_validate_group_descriptor); 30368f64d47SJoel Becker if (rc) 30468f64d47SJoel Becker goto out; 30568f64d47SJoel Becker 306970e4936SJoel Becker rc = ocfs2_validate_gd_parent(inode->i_sb, di, tmp, 0); 30768f64d47SJoel Becker if (rc) { 30868f64d47SJoel Becker brelse(tmp); 30968f64d47SJoel Becker goto out; 31068f64d47SJoel Becker } 31168f64d47SJoel Becker 31268f64d47SJoel Becker /* If ocfs2_read_block() got us a new bh, pass it up. */ 31368f64d47SJoel Becker if (!*bh) 31468f64d47SJoel Becker *bh = tmp; 31568f64d47SJoel Becker 31668f64d47SJoel Becker out: 31768f64d47SJoel Becker return rc; 31868f64d47SJoel Becker } 31968f64d47SJoel Becker 320798db35fSJoel Becker static void ocfs2_bg_discontig_add_extent(struct ocfs2_super *osb, 321798db35fSJoel Becker struct ocfs2_group_desc *bg, 322798db35fSJoel Becker struct ocfs2_chain_list *cl, 32347dea423STao Ma u64 p_blkno, unsigned int clusters) 324798db35fSJoel Becker { 325798db35fSJoel Becker struct ocfs2_extent_list *el = &bg->bg_list; 326798db35fSJoel Becker struct ocfs2_extent_rec *rec; 327798db35fSJoel Becker 3284711954eSTao Ma BUG_ON(!ocfs2_supports_discontig_bg(osb)); 329798db35fSJoel Becker if (!el->l_next_free_rec) 330798db35fSJoel Becker el->l_count = cpu_to_le16(ocfs2_extent_recs_per_gd(osb->sb)); 331798db35fSJoel Becker rec = &el->l_recs[le16_to_cpu(el->l_next_free_rec)]; 3324711954eSTao Ma rec->e_blkno = cpu_to_le64(p_blkno); 333798db35fSJoel Becker rec->e_cpos = cpu_to_le32(le16_to_cpu(bg->bg_bits) / 334798db35fSJoel Becker le16_to_cpu(cl->cl_bpc)); 33547dea423STao Ma rec->e_leaf_clusters = cpu_to_le16(clusters); 336798db35fSJoel Becker le16_add_cpu(&bg->bg_bits, clusters * le16_to_cpu(cl->cl_bpc)); 3374711954eSTao Ma le16_add_cpu(&bg->bg_free_bits_count, 3384711954eSTao Ma clusters * le16_to_cpu(cl->cl_bpc)); 339798db35fSJoel Becker le16_add_cpu(&el->l_next_free_rec, 1); 340798db35fSJoel Becker } 341798db35fSJoel Becker 3421fabe148SMark Fasheh static int ocfs2_block_group_fill(handle_t *handle, 343ccd979bdSMark Fasheh struct inode *alloc_inode, 344ccd979bdSMark Fasheh struct buffer_head *bg_bh, 345ccd979bdSMark Fasheh u64 group_blkno, 346798db35fSJoel Becker unsigned int group_clusters, 347ccd979bdSMark Fasheh u16 my_chain, 348ccd979bdSMark Fasheh struct ocfs2_chain_list *cl) 349ccd979bdSMark Fasheh { 350ccd979bdSMark Fasheh int status = 0; 351798db35fSJoel Becker struct ocfs2_super *osb = OCFS2_SB(alloc_inode->i_sb); 352ccd979bdSMark Fasheh struct ocfs2_group_desc *bg = (struct ocfs2_group_desc *) bg_bh->b_data; 353ccd979bdSMark Fasheh struct super_block * sb = alloc_inode->i_sb; 354ccd979bdSMark Fasheh 355ccd979bdSMark Fasheh if (((unsigned long long) bg_bh->b_blocknr) != group_blkno) { 3567ecef14aSJoe Perches status = ocfs2_error(alloc_inode->i_sb, 3577ecef14aSJoe Perches "group block (%llu) != b_blocknr (%llu)\n", 358b0697053SMark Fasheh (unsigned long long)group_blkno, 359ccd979bdSMark Fasheh (unsigned long long) bg_bh->b_blocknr); 360ccd979bdSMark Fasheh goto bail; 361ccd979bdSMark Fasheh } 362ccd979bdSMark Fasheh 36313723d00SJoel Becker status = ocfs2_journal_access_gd(handle, 3640cf2f763SJoel Becker INODE_CACHE(alloc_inode), 365ccd979bdSMark Fasheh bg_bh, 366ccd979bdSMark Fasheh OCFS2_JOURNAL_ACCESS_CREATE); 367ccd979bdSMark Fasheh if (status < 0) { 368ccd979bdSMark Fasheh mlog_errno(status); 369ccd979bdSMark Fasheh goto bail; 370ccd979bdSMark Fasheh } 371ccd979bdSMark Fasheh 372ccd979bdSMark Fasheh memset(bg, 0, sb->s_blocksize); 373ccd979bdSMark Fasheh strcpy(bg->bg_signature, OCFS2_GROUP_DESC_SIGNATURE); 3741119d3c0Spiaojun bg->bg_generation = cpu_to_le32(osb->fs_generation); 3758571882cSTao Ma bg->bg_size = cpu_to_le16(ocfs2_group_bitmap_size(sb, 1, 3768571882cSTao Ma osb->s_feature_incompat)); 377ccd979bdSMark Fasheh bg->bg_chain = cpu_to_le16(my_chain); 378ccd979bdSMark Fasheh bg->bg_next_group = cl->cl_recs[my_chain].c_blkno; 379ccd979bdSMark Fasheh bg->bg_parent_dinode = cpu_to_le64(OCFS2_I(alloc_inode)->ip_blkno); 380ccd979bdSMark Fasheh bg->bg_blkno = cpu_to_le64(group_blkno); 381798db35fSJoel Becker if (group_clusters == le16_to_cpu(cl->cl_cpg)) 382798db35fSJoel Becker bg->bg_bits = cpu_to_le16(ocfs2_bits_per_group(cl)); 383798db35fSJoel Becker else 3844711954eSTao Ma ocfs2_bg_discontig_add_extent(osb, bg, cl, group_blkno, 385798db35fSJoel Becker group_clusters); 386798db35fSJoel Becker 387ccd979bdSMark Fasheh /* set the 1st bit in the bitmap to account for the descriptor block */ 388ccd979bdSMark Fasheh ocfs2_set_bit(0, (unsigned long *)bg->bg_bitmap); 389ccd979bdSMark Fasheh bg->bg_free_bits_count = cpu_to_le16(le16_to_cpu(bg->bg_bits) - 1); 390ccd979bdSMark Fasheh 391ec20cec7SJoel Becker ocfs2_journal_dirty(handle, bg_bh); 392ccd979bdSMark Fasheh 393ccd979bdSMark Fasheh /* There is no need to zero out or otherwise initialize the 394ccd979bdSMark Fasheh * other blocks in a group - All valid FS metadata in a block 395ccd979bdSMark Fasheh * group stores the superblock fs_generation value at 396ccd979bdSMark Fasheh * allocation time. */ 397ccd979bdSMark Fasheh 398ccd979bdSMark Fasheh bail: 399c1e8d35eSTao Ma if (status) 400c1e8d35eSTao Ma mlog_errno(status); 401ccd979bdSMark Fasheh return status; 402ccd979bdSMark Fasheh } 403ccd979bdSMark Fasheh 404ccd979bdSMark Fasheh static inline u16 ocfs2_find_smallest_chain(struct ocfs2_chain_list *cl) 405ccd979bdSMark Fasheh { 406ccd979bdSMark Fasheh u16 curr, best; 407ccd979bdSMark Fasheh 408ccd979bdSMark Fasheh best = curr = 0; 409ccd979bdSMark Fasheh while (curr < le16_to_cpu(cl->cl_count)) { 410ccd979bdSMark Fasheh if (le32_to_cpu(cl->cl_recs[best].c_total) > 411ccd979bdSMark Fasheh le32_to_cpu(cl->cl_recs[curr].c_total)) 412ccd979bdSMark Fasheh best = curr; 413ccd979bdSMark Fasheh curr++; 414ccd979bdSMark Fasheh } 415ccd979bdSMark Fasheh return best; 416ccd979bdSMark Fasheh } 417ccd979bdSMark Fasheh 418798db35fSJoel Becker static struct buffer_head * 419798db35fSJoel Becker ocfs2_block_group_alloc_contig(struct ocfs2_super *osb, handle_t *handle, 420798db35fSJoel Becker struct inode *alloc_inode, 421798db35fSJoel Becker struct ocfs2_alloc_context *ac, 422798db35fSJoel Becker struct ocfs2_chain_list *cl) 423798db35fSJoel Becker { 424798db35fSJoel Becker int status; 425798db35fSJoel Becker u32 bit_off, num_bits; 426798db35fSJoel Becker u64 bg_blkno; 427798db35fSJoel Becker struct buffer_head *bg_bh; 428798db35fSJoel Becker unsigned int alloc_rec = ocfs2_find_smallest_chain(cl); 429798db35fSJoel Becker 4301ed9b777SJoel Becker status = ocfs2_claim_clusters(handle, ac, 431798db35fSJoel Becker le16_to_cpu(cl->cl_cpg), &bit_off, 432798db35fSJoel Becker &num_bits); 433798db35fSJoel Becker if (status < 0) { 434798db35fSJoel Becker if (status != -ENOSPC) 435798db35fSJoel Becker mlog_errno(status); 436798db35fSJoel Becker goto bail; 437798db35fSJoel Becker } 438798db35fSJoel Becker 439798db35fSJoel Becker /* setup the group */ 440798db35fSJoel Becker bg_blkno = ocfs2_clusters_to_blocks(osb->sb, bit_off); 4412f73e135STao Ma trace_ocfs2_block_group_alloc_contig( 4422f73e135STao Ma (unsigned long long)bg_blkno, alloc_rec); 443798db35fSJoel Becker 444798db35fSJoel Becker bg_bh = sb_getblk(osb->sb, bg_blkno); 445798db35fSJoel Becker if (!bg_bh) { 4467391a294SRui Xiang status = -ENOMEM; 447798db35fSJoel Becker mlog_errno(status); 448798db35fSJoel Becker goto bail; 449798db35fSJoel Becker } 450798db35fSJoel Becker ocfs2_set_new_buffer_uptodate(INODE_CACHE(alloc_inode), bg_bh); 451798db35fSJoel Becker 452798db35fSJoel Becker status = ocfs2_block_group_fill(handle, alloc_inode, bg_bh, 453798db35fSJoel Becker bg_blkno, num_bits, alloc_rec, cl); 454798db35fSJoel Becker if (status < 0) { 455798db35fSJoel Becker brelse(bg_bh); 456798db35fSJoel Becker mlog_errno(status); 457798db35fSJoel Becker } 458798db35fSJoel Becker 459798db35fSJoel Becker bail: 460798db35fSJoel Becker return status ? ERR_PTR(status) : bg_bh; 461798db35fSJoel Becker } 462798db35fSJoel Becker 463798db35fSJoel Becker static int ocfs2_block_group_claim_bits(struct ocfs2_super *osb, 464798db35fSJoel Becker handle_t *handle, 465798db35fSJoel Becker struct ocfs2_alloc_context *ac, 466798db35fSJoel Becker unsigned int min_bits, 467798db35fSJoel Becker u32 *bit_off, u32 *num_bits) 468798db35fSJoel Becker { 46918d3a98fSJoel Becker int status = 0; 470798db35fSJoel Becker 471798db35fSJoel Becker while (min_bits) { 4721ed9b777SJoel Becker status = ocfs2_claim_clusters(handle, ac, min_bits, 473798db35fSJoel Becker bit_off, num_bits); 474798db35fSJoel Becker if (status != -ENOSPC) 475798db35fSJoel Becker break; 476798db35fSJoel Becker 477798db35fSJoel Becker min_bits >>= 1; 478798db35fSJoel Becker } 479798db35fSJoel Becker 480798db35fSJoel Becker return status; 481798db35fSJoel Becker } 482798db35fSJoel Becker 483798db35fSJoel Becker static int ocfs2_block_group_grow_discontig(handle_t *handle, 484798db35fSJoel Becker struct inode *alloc_inode, 485798db35fSJoel Becker struct buffer_head *bg_bh, 486798db35fSJoel Becker struct ocfs2_alloc_context *ac, 487798db35fSJoel Becker struct ocfs2_chain_list *cl, 488798db35fSJoel Becker unsigned int min_bits) 489798db35fSJoel Becker { 490798db35fSJoel Becker int status; 491798db35fSJoel Becker struct ocfs2_super *osb = OCFS2_SB(alloc_inode->i_sb); 492798db35fSJoel Becker struct ocfs2_group_desc *bg = 493798db35fSJoel Becker (struct ocfs2_group_desc *)bg_bh->b_data; 4944711954eSTao Ma unsigned int needed = le16_to_cpu(cl->cl_cpg) - 4954711954eSTao Ma le16_to_cpu(bg->bg_bits) / le16_to_cpu(cl->cl_bpc); 496798db35fSJoel Becker u32 p_cpos, clusters; 497798db35fSJoel Becker u64 p_blkno; 498798db35fSJoel Becker struct ocfs2_extent_list *el = &bg->bg_list; 499798db35fSJoel Becker 500798db35fSJoel Becker status = ocfs2_journal_access_gd(handle, 501798db35fSJoel Becker INODE_CACHE(alloc_inode), 502798db35fSJoel Becker bg_bh, 503798db35fSJoel Becker OCFS2_JOURNAL_ACCESS_CREATE); 504798db35fSJoel Becker if (status < 0) { 505798db35fSJoel Becker mlog_errno(status); 506798db35fSJoel Becker goto bail; 507798db35fSJoel Becker } 508798db35fSJoel Becker 509798db35fSJoel Becker while ((needed > 0) && (le16_to_cpu(el->l_next_free_rec) < 510798db35fSJoel Becker le16_to_cpu(el->l_count))) { 511798db35fSJoel Becker if (min_bits > needed) 512798db35fSJoel Becker min_bits = needed; 513798db35fSJoel Becker status = ocfs2_block_group_claim_bits(osb, handle, ac, 514798db35fSJoel Becker min_bits, &p_cpos, 515798db35fSJoel Becker &clusters); 516798db35fSJoel Becker if (status < 0) { 517798db35fSJoel Becker if (status != -ENOSPC) 518798db35fSJoel Becker mlog_errno(status); 519798db35fSJoel Becker goto bail; 520798db35fSJoel Becker } 521798db35fSJoel Becker p_blkno = ocfs2_clusters_to_blocks(osb->sb, p_cpos); 522798db35fSJoel Becker ocfs2_bg_discontig_add_extent(osb, bg, cl, p_blkno, 523798db35fSJoel Becker clusters); 524798db35fSJoel Becker 525798db35fSJoel Becker min_bits = clusters; 5264711954eSTao Ma needed = le16_to_cpu(cl->cl_cpg) - 5274711954eSTao Ma le16_to_cpu(bg->bg_bits) / le16_to_cpu(cl->cl_bpc); 528798db35fSJoel Becker } 529798db35fSJoel Becker 530798db35fSJoel Becker if (needed > 0) { 5314711954eSTao Ma /* 5324711954eSTao Ma * We have used up all the extent rec but can't fill up 5334711954eSTao Ma * the cpg. So bail out. 5344711954eSTao Ma */ 5354711954eSTao Ma status = -ENOSPC; 5364711954eSTao Ma goto bail; 537798db35fSJoel Becker } 538798db35fSJoel Becker 539798db35fSJoel Becker ocfs2_journal_dirty(handle, bg_bh); 540798db35fSJoel Becker 541798db35fSJoel Becker bail: 542798db35fSJoel Becker return status; 543798db35fSJoel Becker } 544798db35fSJoel Becker 5458b06bc59SJoel Becker static void ocfs2_bg_alloc_cleanup(handle_t *handle, 5468b06bc59SJoel Becker struct ocfs2_alloc_context *cluster_ac, 5478b06bc59SJoel Becker struct inode *alloc_inode, 5488b06bc59SJoel Becker struct buffer_head *bg_bh) 549798db35fSJoel Becker { 5508b06bc59SJoel Becker int i, ret; 551798db35fSJoel Becker struct ocfs2_group_desc *bg; 552798db35fSJoel Becker struct ocfs2_extent_list *el; 553798db35fSJoel Becker struct ocfs2_extent_rec *rec; 554798db35fSJoel Becker 555798db35fSJoel Becker if (!bg_bh) 556798db35fSJoel Becker return; 557798db35fSJoel Becker 558798db35fSJoel Becker bg = (struct ocfs2_group_desc *)bg_bh->b_data; 559798db35fSJoel Becker el = &bg->bg_list; 560798db35fSJoel Becker for (i = 0; i < le16_to_cpu(el->l_next_free_rec); i++) { 561798db35fSJoel Becker rec = &el->l_recs[i]; 5628b06bc59SJoel Becker ret = ocfs2_free_clusters(handle, cluster_ac->ac_inode, 5638b06bc59SJoel Becker cluster_ac->ac_bh, 564798db35fSJoel Becker le64_to_cpu(rec->e_blkno), 56572094e43SAl Viro le16_to_cpu(rec->e_leaf_clusters)); 5668b06bc59SJoel Becker if (ret) 5678b06bc59SJoel Becker mlog_errno(ret); 5688b06bc59SJoel Becker /* Try all the clusters to free */ 569798db35fSJoel Becker } 570798db35fSJoel Becker 571798db35fSJoel Becker ocfs2_remove_from_cache(INODE_CACHE(alloc_inode), bg_bh); 572798db35fSJoel Becker brelse(bg_bh); 573798db35fSJoel Becker } 574798db35fSJoel Becker 575798db35fSJoel Becker static struct buffer_head * 576798db35fSJoel Becker ocfs2_block_group_alloc_discontig(handle_t *handle, 577798db35fSJoel Becker struct inode *alloc_inode, 578798db35fSJoel Becker struct ocfs2_alloc_context *ac, 5798b06bc59SJoel Becker struct ocfs2_chain_list *cl) 580798db35fSJoel Becker { 581798db35fSJoel Becker int status; 582798db35fSJoel Becker u32 bit_off, num_bits; 583798db35fSJoel Becker u64 bg_blkno; 584798db35fSJoel Becker unsigned int min_bits = le16_to_cpu(cl->cl_cpg) >> 1; 585798db35fSJoel Becker struct buffer_head *bg_bh = NULL; 586798db35fSJoel Becker unsigned int alloc_rec = ocfs2_find_smallest_chain(cl); 587798db35fSJoel Becker struct ocfs2_super *osb = OCFS2_SB(alloc_inode->i_sb); 588798db35fSJoel Becker 5894711954eSTao Ma if (!ocfs2_supports_discontig_bg(osb)) { 590798db35fSJoel Becker status = -ENOSPC; 591798db35fSJoel Becker goto bail; 592798db35fSJoel Becker } 593798db35fSJoel Becker 5948b06bc59SJoel Becker status = ocfs2_extend_trans(handle, 5958b06bc59SJoel Becker ocfs2_calc_bg_discontig_credits(osb->sb)); 5968b06bc59SJoel Becker if (status) { 5978b06bc59SJoel Becker mlog_errno(status); 5988b06bc59SJoel Becker goto bail; 5998b06bc59SJoel Becker } 6008b06bc59SJoel Becker 60195ec0adfSJoel Becker /* 60295ec0adfSJoel Becker * We're going to be grabbing from multiple cluster groups. 60395ec0adfSJoel Becker * We don't have enough credits to relink them all, and the 60495ec0adfSJoel Becker * cluster groups will be staying in cache for the duration of 60595ec0adfSJoel Becker * this operation. 60695ec0adfSJoel Becker */ 607309a85b6SXiaowei.Hu ac->ac_disable_chain_relink = 1; 60895ec0adfSJoel Becker 609798db35fSJoel Becker /* Claim the first region */ 610798db35fSJoel Becker status = ocfs2_block_group_claim_bits(osb, handle, ac, min_bits, 611798db35fSJoel Becker &bit_off, &num_bits); 612798db35fSJoel Becker if (status < 0) { 613798db35fSJoel Becker if (status != -ENOSPC) 614798db35fSJoel Becker mlog_errno(status); 615798db35fSJoel Becker goto bail; 616798db35fSJoel Becker } 617798db35fSJoel Becker min_bits = num_bits; 618798db35fSJoel Becker 619798db35fSJoel Becker /* setup the group */ 620798db35fSJoel Becker bg_blkno = ocfs2_clusters_to_blocks(osb->sb, bit_off); 6212f73e135STao Ma trace_ocfs2_block_group_alloc_discontig( 6222f73e135STao Ma (unsigned long long)bg_blkno, alloc_rec); 623798db35fSJoel Becker 624798db35fSJoel Becker bg_bh = sb_getblk(osb->sb, bg_blkno); 625798db35fSJoel Becker if (!bg_bh) { 6267391a294SRui Xiang status = -ENOMEM; 627798db35fSJoel Becker mlog_errno(status); 628798db35fSJoel Becker goto bail; 629798db35fSJoel Becker } 630798db35fSJoel Becker ocfs2_set_new_buffer_uptodate(INODE_CACHE(alloc_inode), bg_bh); 631798db35fSJoel Becker 632798db35fSJoel Becker status = ocfs2_block_group_fill(handle, alloc_inode, bg_bh, 633798db35fSJoel Becker bg_blkno, num_bits, alloc_rec, cl); 634798db35fSJoel Becker if (status < 0) { 635798db35fSJoel Becker mlog_errno(status); 636798db35fSJoel Becker goto bail; 637798db35fSJoel Becker } 638798db35fSJoel Becker 639798db35fSJoel Becker status = ocfs2_block_group_grow_discontig(handle, alloc_inode, 640798db35fSJoel Becker bg_bh, ac, cl, min_bits); 641798db35fSJoel Becker if (status) 642798db35fSJoel Becker mlog_errno(status); 643798db35fSJoel Becker 644798db35fSJoel Becker bail: 645798db35fSJoel Becker if (status) 6468b06bc59SJoel Becker ocfs2_bg_alloc_cleanup(handle, ac, alloc_inode, bg_bh); 647798db35fSJoel Becker return status ? ERR_PTR(status) : bg_bh; 648798db35fSJoel Becker } 649798db35fSJoel Becker 650ccd979bdSMark Fasheh /* 651ccd979bdSMark Fasheh * We expect the block group allocator to already be locked. 652ccd979bdSMark Fasheh */ 653ccd979bdSMark Fasheh static int ocfs2_block_group_alloc(struct ocfs2_super *osb, 654ccd979bdSMark Fasheh struct inode *alloc_inode, 6551187c968SJoel Becker struct buffer_head *bh, 65660ca81e8STao Ma u64 max_block, 657feb473a6STao Ma u64 *last_alloc_group, 65860ca81e8STao Ma int flags) 659ccd979bdSMark Fasheh { 660ccd979bdSMark Fasheh int status, credits; 661ccd979bdSMark Fasheh struct ocfs2_dinode *fe = (struct ocfs2_dinode *) bh->b_data; 662ccd979bdSMark Fasheh struct ocfs2_chain_list *cl; 663ccd979bdSMark Fasheh struct ocfs2_alloc_context *ac = NULL; 6641fabe148SMark Fasheh handle_t *handle = NULL; 6654711954eSTao Ma u16 alloc_rec; 666ccd979bdSMark Fasheh struct buffer_head *bg_bh = NULL; 667ccd979bdSMark Fasheh struct ocfs2_group_desc *bg; 668ccd979bdSMark Fasheh 669ccd979bdSMark Fasheh BUG_ON(ocfs2_is_cluster_bitmap(alloc_inode)); 670ccd979bdSMark Fasheh 671ccd979bdSMark Fasheh cl = &fe->id2.i_chain; 6721187c968SJoel Becker status = ocfs2_reserve_clusters_with_limit(osb, 673ccd979bdSMark Fasheh le16_to_cpu(cl->cl_cpg), 67460ca81e8STao Ma max_block, flags, &ac); 675ccd979bdSMark Fasheh if (status < 0) { 676ccd979bdSMark Fasheh if (status != -ENOSPC) 677ccd979bdSMark Fasheh mlog_errno(status); 678ccd979bdSMark Fasheh goto bail; 679ccd979bdSMark Fasheh } 680ccd979bdSMark Fasheh 681ccd979bdSMark Fasheh credits = ocfs2_calc_group_alloc_credits(osb->sb, 682ccd979bdSMark Fasheh le16_to_cpu(cl->cl_cpg)); 68365eff9ccSMark Fasheh handle = ocfs2_start_trans(osb, credits); 684ccd979bdSMark Fasheh if (IS_ERR(handle)) { 685ccd979bdSMark Fasheh status = PTR_ERR(handle); 686ccd979bdSMark Fasheh handle = NULL; 687ccd979bdSMark Fasheh mlog_errno(status); 688ccd979bdSMark Fasheh goto bail; 689ccd979bdSMark Fasheh } 690ccd979bdSMark Fasheh 691feb473a6STao Ma if (last_alloc_group && *last_alloc_group != 0) { 6922f73e135STao Ma trace_ocfs2_block_group_alloc( 693feb473a6STao Ma (unsigned long long)*last_alloc_group); 694feb473a6STao Ma ac->ac_last_group = *last_alloc_group; 695feb473a6STao Ma } 696798db35fSJoel Becker 697798db35fSJoel Becker bg_bh = ocfs2_block_group_alloc_contig(osb, handle, alloc_inode, 698798db35fSJoel Becker ac, cl); 69945586c70SMasahiro Yamada if (PTR_ERR(bg_bh) == -ENOSPC) 700798db35fSJoel Becker bg_bh = ocfs2_block_group_alloc_discontig(handle, 701798db35fSJoel Becker alloc_inode, 7028b06bc59SJoel Becker ac, cl); 703798db35fSJoel Becker if (IS_ERR(bg_bh)) { 704798db35fSJoel Becker status = PTR_ERR(bg_bh); 705798db35fSJoel Becker bg_bh = NULL; 706ccd979bdSMark Fasheh if (status != -ENOSPC) 707ccd979bdSMark Fasheh mlog_errno(status); 708ccd979bdSMark Fasheh goto bail; 709ccd979bdSMark Fasheh } 710ccd979bdSMark Fasheh bg = (struct ocfs2_group_desc *) bg_bh->b_data; 711ccd979bdSMark Fasheh 7120cf2f763SJoel Becker status = ocfs2_journal_access_di(handle, INODE_CACHE(alloc_inode), 713ccd979bdSMark Fasheh bh, OCFS2_JOURNAL_ACCESS_WRITE); 714ccd979bdSMark Fasheh if (status < 0) { 715ccd979bdSMark Fasheh mlog_errno(status); 716ccd979bdSMark Fasheh goto bail; 717ccd979bdSMark Fasheh } 718ccd979bdSMark Fasheh 7194711954eSTao Ma alloc_rec = le16_to_cpu(bg->bg_chain); 7204711954eSTao Ma le32_add_cpu(&cl->cl_recs[alloc_rec].c_free, 721ccd979bdSMark Fasheh le16_to_cpu(bg->bg_free_bits_count)); 7224711954eSTao Ma le32_add_cpu(&cl->cl_recs[alloc_rec].c_total, 723798db35fSJoel Becker le16_to_cpu(bg->bg_bits)); 7240a463b74STao Ma cl->cl_recs[alloc_rec].c_blkno = bg->bg_blkno; 725ccd979bdSMark Fasheh if (le16_to_cpu(cl->cl_next_free_rec) < le16_to_cpu(cl->cl_count)) 726ccd979bdSMark Fasheh le16_add_cpu(&cl->cl_next_free_rec, 1); 727ccd979bdSMark Fasheh 728ccd979bdSMark Fasheh le32_add_cpu(&fe->id1.bitmap1.i_used, le16_to_cpu(bg->bg_bits) - 729ccd979bdSMark Fasheh le16_to_cpu(bg->bg_free_bits_count)); 730ccd979bdSMark Fasheh le32_add_cpu(&fe->id1.bitmap1.i_total, le16_to_cpu(bg->bg_bits)); 731ccd979bdSMark Fasheh le32_add_cpu(&fe->i_clusters, le16_to_cpu(cl->cl_cpg)); 732ccd979bdSMark Fasheh 733ec20cec7SJoel Becker ocfs2_journal_dirty(handle, bh); 734ccd979bdSMark Fasheh 735ccd979bdSMark Fasheh spin_lock(&OCFS2_I(alloc_inode)->ip_lock); 736ccd979bdSMark Fasheh OCFS2_I(alloc_inode)->ip_clusters = le32_to_cpu(fe->i_clusters); 737ccd979bdSMark Fasheh fe->i_size = cpu_to_le64(ocfs2_clusters_to_bytes(alloc_inode->i_sb, 738ccd979bdSMark Fasheh le32_to_cpu(fe->i_clusters))); 739ccd979bdSMark Fasheh spin_unlock(&OCFS2_I(alloc_inode)->ip_lock); 740ccd979bdSMark Fasheh i_size_write(alloc_inode, le64_to_cpu(fe->i_size)); 7418110b073SMark Fasheh alloc_inode->i_blocks = ocfs2_inode_sector_count(alloc_inode); 7426fdb702dSDarrick J. Wong ocfs2_update_inode_fsync_trans(handle, alloc_inode, 0); 743ccd979bdSMark Fasheh 744ccd979bdSMark Fasheh status = 0; 745feb473a6STao Ma 746feb473a6STao Ma /* save the new last alloc group so that the caller can cache it. */ 747feb473a6STao Ma if (last_alloc_group) 748feb473a6STao Ma *last_alloc_group = ac->ac_last_group; 749feb473a6STao Ma 750ccd979bdSMark Fasheh bail: 751ccd979bdSMark Fasheh if (handle) 75202dc1af4SMark Fasheh ocfs2_commit_trans(osb, handle); 753ccd979bdSMark Fasheh 754ccd979bdSMark Fasheh if (ac) 755ccd979bdSMark Fasheh ocfs2_free_alloc_context(ac); 756ccd979bdSMark Fasheh 757ccd979bdSMark Fasheh brelse(bg_bh); 758ccd979bdSMark Fasheh 759c1e8d35eSTao Ma if (status) 760c1e8d35eSTao Ma mlog_errno(status); 761ccd979bdSMark Fasheh return status; 762ccd979bdSMark Fasheh } 763ccd979bdSMark Fasheh 764ccd979bdSMark Fasheh static int ocfs2_reserve_suballoc_bits(struct ocfs2_super *osb, 765da5cbf2fSMark Fasheh struct ocfs2_alloc_context *ac, 766da5cbf2fSMark Fasheh int type, 767ffda89a3STao Ma u32 slot, 768feb473a6STao Ma u64 *last_alloc_group, 76960ca81e8STao Ma int flags) 770ccd979bdSMark Fasheh { 771ccd979bdSMark Fasheh int status; 772ccd979bdSMark Fasheh u32 bits_wanted = ac->ac_bits_wanted; 773da5cbf2fSMark Fasheh struct inode *alloc_inode; 774ccd979bdSMark Fasheh struct buffer_head *bh = NULL; 775ccd979bdSMark Fasheh struct ocfs2_dinode *fe; 776ccd979bdSMark Fasheh u32 free_bits; 777ccd979bdSMark Fasheh 778da5cbf2fSMark Fasheh alloc_inode = ocfs2_get_system_file_inode(osb, type, slot); 779da5cbf2fSMark Fasheh if (!alloc_inode) { 780da5cbf2fSMark Fasheh mlog_errno(-EINVAL); 781da5cbf2fSMark Fasheh return -EINVAL; 782ccd979bdSMark Fasheh } 783ccd979bdSMark Fasheh 7845955102cSAl Viro inode_lock(alloc_inode); 785da5cbf2fSMark Fasheh 786e63aecb6SMark Fasheh status = ocfs2_inode_lock(alloc_inode, &bh, 1); 787da5cbf2fSMark Fasheh if (status < 0) { 7885955102cSAl Viro inode_unlock(alloc_inode); 789da5cbf2fSMark Fasheh iput(alloc_inode); 790da5cbf2fSMark Fasheh 791da5cbf2fSMark Fasheh mlog_errno(status); 792da5cbf2fSMark Fasheh return status; 793da5cbf2fSMark Fasheh } 794da5cbf2fSMark Fasheh 795da5cbf2fSMark Fasheh ac->ac_inode = alloc_inode; 796a4a48911STao Ma ac->ac_alloc_slot = slot; 797da5cbf2fSMark Fasheh 798ccd979bdSMark Fasheh fe = (struct ocfs2_dinode *) bh->b_data; 79910995aa2SJoel Becker 80010995aa2SJoel Becker /* The bh was validated by the inode read inside 80110995aa2SJoel Becker * ocfs2_inode_lock(). Any corruption is a code bug. */ 80210995aa2SJoel Becker BUG_ON(!OCFS2_IS_VALID_DINODE(fe)); 80310995aa2SJoel Becker 804ccd979bdSMark Fasheh if (!(fe->i_flags & cpu_to_le32(OCFS2_CHAIN_FL))) { 8057ecef14aSJoe Perches status = ocfs2_error(alloc_inode->i_sb, 8067ecef14aSJoe Perches "Invalid chain allocator %llu\n", 807b0697053SMark Fasheh (unsigned long long)le64_to_cpu(fe->i_blkno)); 808ccd979bdSMark Fasheh goto bail; 809ccd979bdSMark Fasheh } 810ccd979bdSMark Fasheh 811ccd979bdSMark Fasheh free_bits = le32_to_cpu(fe->id1.bitmap1.i_total) - 812ccd979bdSMark Fasheh le32_to_cpu(fe->id1.bitmap1.i_used); 813ccd979bdSMark Fasheh 814ccd979bdSMark Fasheh if (bits_wanted > free_bits) { 815ccd979bdSMark Fasheh /* cluster bitmap never grows */ 816ccd979bdSMark Fasheh if (ocfs2_is_cluster_bitmap(alloc_inode)) { 8172f73e135STao Ma trace_ocfs2_reserve_suballoc_bits_nospc(bits_wanted, 8182f73e135STao Ma free_bits); 819ccd979bdSMark Fasheh status = -ENOSPC; 820ccd979bdSMark Fasheh goto bail; 821ccd979bdSMark Fasheh } 822ccd979bdSMark Fasheh 82360ca81e8STao Ma if (!(flags & ALLOC_NEW_GROUP)) { 8242f73e135STao Ma trace_ocfs2_reserve_suballoc_bits_no_new_group( 825ffda89a3STao Ma slot, bits_wanted, free_bits); 826ffda89a3STao Ma status = -ENOSPC; 827ffda89a3STao Ma goto bail; 828ffda89a3STao Ma } 829ffda89a3STao Ma 8301187c968SJoel Becker status = ocfs2_block_group_alloc(osb, alloc_inode, bh, 831feb473a6STao Ma ac->ac_max_block, 832feb473a6STao Ma last_alloc_group, flags); 833ccd979bdSMark Fasheh if (status < 0) { 834ccd979bdSMark Fasheh if (status != -ENOSPC) 835ccd979bdSMark Fasheh mlog_errno(status); 836ccd979bdSMark Fasheh goto bail; 837ccd979bdSMark Fasheh } 838ccd979bdSMark Fasheh atomic_inc(&osb->alloc_stats.bg_extends); 839ccd979bdSMark Fasheh 840ccd979bdSMark Fasheh /* You should never ask for this much metadata */ 841ccd979bdSMark Fasheh BUG_ON(bits_wanted > 842ccd979bdSMark Fasheh (le32_to_cpu(fe->id1.bitmap1.i_total) 843ccd979bdSMark Fasheh - le32_to_cpu(fe->id1.bitmap1.i_used))); 844ccd979bdSMark Fasheh } 845ccd979bdSMark Fasheh 846ccd979bdSMark Fasheh get_bh(bh); 847ccd979bdSMark Fasheh ac->ac_bh = bh; 848ccd979bdSMark Fasheh bail: 849ccd979bdSMark Fasheh brelse(bh); 850ccd979bdSMark Fasheh 851c1e8d35eSTao Ma if (status) 852c1e8d35eSTao Ma mlog_errno(status); 853ccd979bdSMark Fasheh return status; 854ccd979bdSMark Fasheh } 855ccd979bdSMark Fasheh 856b89c5428STiger Yang static void ocfs2_init_inode_steal_slot(struct ocfs2_super *osb) 857b89c5428STiger Yang { 858b89c5428STiger Yang spin_lock(&osb->osb_lock); 859b89c5428STiger Yang osb->s_inode_steal_slot = OCFS2_INVALID_SLOT; 860b89c5428STiger Yang spin_unlock(&osb->osb_lock); 861b89c5428STiger Yang atomic_set(&osb->s_num_inodes_stolen, 0); 862b89c5428STiger Yang } 863b89c5428STiger Yang 864b89c5428STiger Yang static void ocfs2_init_meta_steal_slot(struct ocfs2_super *osb) 865b89c5428STiger Yang { 866b89c5428STiger Yang spin_lock(&osb->osb_lock); 867b89c5428STiger Yang osb->s_meta_steal_slot = OCFS2_INVALID_SLOT; 868b89c5428STiger Yang spin_unlock(&osb->osb_lock); 869b89c5428STiger Yang atomic_set(&osb->s_num_meta_stolen, 0); 870b89c5428STiger Yang } 871b89c5428STiger Yang 872b89c5428STiger Yang void ocfs2_init_steal_slots(struct ocfs2_super *osb) 873b89c5428STiger Yang { 874b89c5428STiger Yang ocfs2_init_inode_steal_slot(osb); 875b89c5428STiger Yang ocfs2_init_meta_steal_slot(osb); 876b89c5428STiger Yang } 877b89c5428STiger Yang 878b89c5428STiger Yang static void __ocfs2_set_steal_slot(struct ocfs2_super *osb, int slot, int type) 879b89c5428STiger Yang { 880b89c5428STiger Yang spin_lock(&osb->osb_lock); 881b89c5428STiger Yang if (type == INODE_ALLOC_SYSTEM_INODE) 882b89c5428STiger Yang osb->s_inode_steal_slot = slot; 883b89c5428STiger Yang else if (type == EXTENT_ALLOC_SYSTEM_INODE) 884b89c5428STiger Yang osb->s_meta_steal_slot = slot; 885b89c5428STiger Yang spin_unlock(&osb->osb_lock); 886b89c5428STiger Yang } 887b89c5428STiger Yang 888b89c5428STiger Yang static int __ocfs2_get_steal_slot(struct ocfs2_super *osb, int type) 889b89c5428STiger Yang { 890b89c5428STiger Yang int slot = OCFS2_INVALID_SLOT; 891b89c5428STiger Yang 892b89c5428STiger Yang spin_lock(&osb->osb_lock); 893b89c5428STiger Yang if (type == INODE_ALLOC_SYSTEM_INODE) 894b89c5428STiger Yang slot = osb->s_inode_steal_slot; 895b89c5428STiger Yang else if (type == EXTENT_ALLOC_SYSTEM_INODE) 896b89c5428STiger Yang slot = osb->s_meta_steal_slot; 897b89c5428STiger Yang spin_unlock(&osb->osb_lock); 898b89c5428STiger Yang 899b89c5428STiger Yang return slot; 900b89c5428STiger Yang } 901b89c5428STiger Yang 902b89c5428STiger Yang static int ocfs2_get_inode_steal_slot(struct ocfs2_super *osb) 903b89c5428STiger Yang { 904b89c5428STiger Yang return __ocfs2_get_steal_slot(osb, INODE_ALLOC_SYSTEM_INODE); 905b89c5428STiger Yang } 906b89c5428STiger Yang 907b89c5428STiger Yang static int ocfs2_get_meta_steal_slot(struct ocfs2_super *osb) 908b89c5428STiger Yang { 909b89c5428STiger Yang return __ocfs2_get_steal_slot(osb, EXTENT_ALLOC_SYSTEM_INODE); 910b89c5428STiger Yang } 911b89c5428STiger Yang 912b89c5428STiger Yang static int ocfs2_steal_resource(struct ocfs2_super *osb, 913b89c5428STiger Yang struct ocfs2_alloc_context *ac, 914b89c5428STiger Yang int type) 915b89c5428STiger Yang { 916b89c5428STiger Yang int i, status = -ENOSPC; 917b89c5428STiger Yang int slot = __ocfs2_get_steal_slot(osb, type); 918b89c5428STiger Yang 919b89c5428STiger Yang /* Start to steal resource from the first slot after ours. */ 920b89c5428STiger Yang if (slot == OCFS2_INVALID_SLOT) 921b89c5428STiger Yang slot = osb->slot_num + 1; 922b89c5428STiger Yang 923b89c5428STiger Yang for (i = 0; i < osb->max_slots; i++, slot++) { 924b89c5428STiger Yang if (slot == osb->max_slots) 925b89c5428STiger Yang slot = 0; 926b89c5428STiger Yang 927b89c5428STiger Yang if (slot == osb->slot_num) 928b89c5428STiger Yang continue; 929b89c5428STiger Yang 930b89c5428STiger Yang status = ocfs2_reserve_suballoc_bits(osb, ac, 931b89c5428STiger Yang type, 932b89c5428STiger Yang (u32)slot, NULL, 933b89c5428STiger Yang NOT_ALLOC_NEW_GROUP); 934b89c5428STiger Yang if (status >= 0) { 935b89c5428STiger Yang __ocfs2_set_steal_slot(osb, slot, type); 936b89c5428STiger Yang break; 937b89c5428STiger Yang } 938b89c5428STiger Yang 939b89c5428STiger Yang ocfs2_free_ac_resource(ac); 940b89c5428STiger Yang } 941b89c5428STiger Yang 942b89c5428STiger Yang return status; 943b89c5428STiger Yang } 944b89c5428STiger Yang 945b89c5428STiger Yang static int ocfs2_steal_inode(struct ocfs2_super *osb, 946b89c5428STiger Yang struct ocfs2_alloc_context *ac) 947b89c5428STiger Yang { 948b89c5428STiger Yang return ocfs2_steal_resource(osb, ac, INODE_ALLOC_SYSTEM_INODE); 949b89c5428STiger Yang } 950b89c5428STiger Yang 951b89c5428STiger Yang static int ocfs2_steal_meta(struct ocfs2_super *osb, 952b89c5428STiger Yang struct ocfs2_alloc_context *ac) 953b89c5428STiger Yang { 954b89c5428STiger Yang return ocfs2_steal_resource(osb, ac, EXTENT_ALLOC_SYSTEM_INODE); 955b89c5428STiger Yang } 956b89c5428STiger Yang 957cf1d6c76STiger Yang int ocfs2_reserve_new_metadata_blocks(struct ocfs2_super *osb, 958cf1d6c76STiger Yang int blocks, 959ccd979bdSMark Fasheh struct ocfs2_alloc_context **ac) 960ccd979bdSMark Fasheh { 961ccd979bdSMark Fasheh int status; 962b89c5428STiger Yang int slot = ocfs2_get_meta_steal_slot(osb); 963ccd979bdSMark Fasheh 964cd861280SRobert P. J. Day *ac = kzalloc(sizeof(struct ocfs2_alloc_context), GFP_KERNEL); 965ccd979bdSMark Fasheh if (!(*ac)) { 966ccd979bdSMark Fasheh status = -ENOMEM; 967ccd979bdSMark Fasheh mlog_errno(status); 968ccd979bdSMark Fasheh goto bail; 969ccd979bdSMark Fasheh } 970ccd979bdSMark Fasheh 971cf1d6c76STiger Yang (*ac)->ac_bits_wanted = blocks; 972ccd979bdSMark Fasheh (*ac)->ac_which = OCFS2_AC_USE_META; 973ccd979bdSMark Fasheh (*ac)->ac_group_search = ocfs2_block_group_search; 974ccd979bdSMark Fasheh 975b89c5428STiger Yang if (slot != OCFS2_INVALID_SLOT && 976b89c5428STiger Yang atomic_read(&osb->s_num_meta_stolen) < OCFS2_MAX_TO_STEAL) 977b89c5428STiger Yang goto extent_steal; 978b89c5428STiger Yang 979b89c5428STiger Yang atomic_set(&osb->s_num_meta_stolen, 0); 980da5cbf2fSMark Fasheh status = ocfs2_reserve_suballoc_bits(osb, (*ac), 981ffda89a3STao Ma EXTENT_ALLOC_SYSTEM_INODE, 982b89c5428STiger Yang (u32)osb->slot_num, NULL, 98333d5d380SMark Fasheh ALLOC_GROUPS_FROM_GLOBAL|ALLOC_NEW_GROUP); 984b89c5428STiger Yang 985b89c5428STiger Yang 986b89c5428STiger Yang if (status >= 0) { 987b89c5428STiger Yang status = 0; 988b89c5428STiger Yang if (slot != OCFS2_INVALID_SLOT) 989b89c5428STiger Yang ocfs2_init_meta_steal_slot(osb); 990b89c5428STiger Yang goto bail; 991b89c5428STiger Yang } else if (status < 0 && status != -ENOSPC) { 992b89c5428STiger Yang mlog_errno(status); 993b89c5428STiger Yang goto bail; 994b89c5428STiger Yang } 995b89c5428STiger Yang 996b89c5428STiger Yang ocfs2_free_ac_resource(*ac); 997b89c5428STiger Yang 998b89c5428STiger Yang extent_steal: 999b89c5428STiger Yang status = ocfs2_steal_meta(osb, *ac); 1000b89c5428STiger Yang atomic_inc(&osb->s_num_meta_stolen); 1001ccd979bdSMark Fasheh if (status < 0) { 1002ccd979bdSMark Fasheh if (status != -ENOSPC) 1003ccd979bdSMark Fasheh mlog_errno(status); 1004ccd979bdSMark Fasheh goto bail; 1005ccd979bdSMark Fasheh } 1006ccd979bdSMark Fasheh 1007ccd979bdSMark Fasheh status = 0; 1008ccd979bdSMark Fasheh bail: 1009ccd979bdSMark Fasheh if ((status < 0) && *ac) { 1010ccd979bdSMark Fasheh ocfs2_free_alloc_context(*ac); 1011ccd979bdSMark Fasheh *ac = NULL; 1012ccd979bdSMark Fasheh } 1013ccd979bdSMark Fasheh 1014c1e8d35eSTao Ma if (status) 1015c1e8d35eSTao Ma mlog_errno(status); 1016ccd979bdSMark Fasheh return status; 1017ccd979bdSMark Fasheh } 1018ccd979bdSMark Fasheh 1019cf1d6c76STiger Yang int ocfs2_reserve_new_metadata(struct ocfs2_super *osb, 1020cf1d6c76STiger Yang struct ocfs2_extent_list *root_el, 1021cf1d6c76STiger Yang struct ocfs2_alloc_context **ac) 1022cf1d6c76STiger Yang { 1023cf1d6c76STiger Yang return ocfs2_reserve_new_metadata_blocks(osb, 1024cf1d6c76STiger Yang ocfs2_extend_meta_needed(root_el), 1025cf1d6c76STiger Yang ac); 1026cf1d6c76STiger Yang } 1027cf1d6c76STiger Yang 1028ccd979bdSMark Fasheh int ocfs2_reserve_new_inode(struct ocfs2_super *osb, 1029ccd979bdSMark Fasheh struct ocfs2_alloc_context **ac) 1030ccd979bdSMark Fasheh { 1031ccd979bdSMark Fasheh int status; 1032b89c5428STiger Yang int slot = ocfs2_get_inode_steal_slot(osb); 1033feb473a6STao Ma u64 alloc_group; 1034ccd979bdSMark Fasheh 1035cd861280SRobert P. J. Day *ac = kzalloc(sizeof(struct ocfs2_alloc_context), GFP_KERNEL); 1036ccd979bdSMark Fasheh if (!(*ac)) { 1037ccd979bdSMark Fasheh status = -ENOMEM; 1038ccd979bdSMark Fasheh mlog_errno(status); 1039ccd979bdSMark Fasheh goto bail; 1040ccd979bdSMark Fasheh } 1041ccd979bdSMark Fasheh 1042ccd979bdSMark Fasheh (*ac)->ac_bits_wanted = 1; 1043ccd979bdSMark Fasheh (*ac)->ac_which = OCFS2_AC_USE_INODE; 1044ccd979bdSMark Fasheh 1045ccd979bdSMark Fasheh (*ac)->ac_group_search = ocfs2_block_group_search; 1046ccd979bdSMark Fasheh 10474d0ddb2cSTao Ma /* 10481187c968SJoel Becker * stat(2) can't handle i_ino > 32bits, so we tell the 10491187c968SJoel Becker * lower levels not to allocate us a block group past that 105012462f1dSJoel Becker * limit. The 'inode64' mount option avoids this behavior. 10511187c968SJoel Becker */ 105212462f1dSJoel Becker if (!(osb->s_mount_opt & OCFS2_MOUNT_INODE64)) 10531187c968SJoel Becker (*ac)->ac_max_block = (u32)~0U; 10541187c968SJoel Becker 10551187c968SJoel Becker /* 10564d0ddb2cSTao Ma * slot is set when we successfully steal inode from other nodes. 10574d0ddb2cSTao Ma * It is reset in 3 places: 10584d0ddb2cSTao Ma * 1. when we flush the truncate log 10594d0ddb2cSTao Ma * 2. when we complete local alloc recovery. 10604d0ddb2cSTao Ma * 3. when we successfully allocate from our own slot. 10614d0ddb2cSTao Ma * After it is set, we will go on stealing inodes until we find the 10624d0ddb2cSTao Ma * need to check our slots to see whether there is some space for us. 10634d0ddb2cSTao Ma */ 10644d0ddb2cSTao Ma if (slot != OCFS2_INVALID_SLOT && 1065b89c5428STiger Yang atomic_read(&osb->s_num_inodes_stolen) < OCFS2_MAX_TO_STEAL) 10664d0ddb2cSTao Ma goto inode_steal; 10674d0ddb2cSTao Ma 10684d0ddb2cSTao Ma atomic_set(&osb->s_num_inodes_stolen, 0); 1069feb473a6STao Ma alloc_group = osb->osb_inode_alloc_group; 1070da5cbf2fSMark Fasheh status = ocfs2_reserve_suballoc_bits(osb, *ac, 1071da5cbf2fSMark Fasheh INODE_ALLOC_SYSTEM_INODE, 1072b89c5428STiger Yang (u32)osb->slot_num, 1073feb473a6STao Ma &alloc_group, 107460ca81e8STao Ma ALLOC_NEW_GROUP | 107560ca81e8STao Ma ALLOC_GROUPS_FROM_GLOBAL); 10764d0ddb2cSTao Ma if (status >= 0) { 10774d0ddb2cSTao Ma status = 0; 10784d0ddb2cSTao Ma 1079feb473a6STao Ma spin_lock(&osb->osb_lock); 1080feb473a6STao Ma osb->osb_inode_alloc_group = alloc_group; 1081feb473a6STao Ma spin_unlock(&osb->osb_lock); 10822f73e135STao Ma trace_ocfs2_reserve_new_inode_new_group( 10832f73e135STao Ma (unsigned long long)alloc_group); 1084feb473a6STao Ma 10854d0ddb2cSTao Ma /* 10864d0ddb2cSTao Ma * Some inodes must be freed by us, so try to allocate 10874d0ddb2cSTao Ma * from our own next time. 10884d0ddb2cSTao Ma */ 10894d0ddb2cSTao Ma if (slot != OCFS2_INVALID_SLOT) 10904d0ddb2cSTao Ma ocfs2_init_inode_steal_slot(osb); 10914d0ddb2cSTao Ma goto bail; 10924d0ddb2cSTao Ma } else if (status < 0 && status != -ENOSPC) { 10934d0ddb2cSTao Ma mlog_errno(status); 10944d0ddb2cSTao Ma goto bail; 10954d0ddb2cSTao Ma } 10964d0ddb2cSTao Ma 10974d0ddb2cSTao Ma ocfs2_free_ac_resource(*ac); 10984d0ddb2cSTao Ma 10994d0ddb2cSTao Ma inode_steal: 1100b89c5428STiger Yang status = ocfs2_steal_inode(osb, *ac); 11014d0ddb2cSTao Ma atomic_inc(&osb->s_num_inodes_stolen); 1102ccd979bdSMark Fasheh if (status < 0) { 1103ccd979bdSMark Fasheh if (status != -ENOSPC) 1104ccd979bdSMark Fasheh mlog_errno(status); 1105ccd979bdSMark Fasheh goto bail; 1106ccd979bdSMark Fasheh } 1107ccd979bdSMark Fasheh 1108ccd979bdSMark Fasheh status = 0; 1109ccd979bdSMark Fasheh bail: 1110ccd979bdSMark Fasheh if ((status < 0) && *ac) { 1111ccd979bdSMark Fasheh ocfs2_free_alloc_context(*ac); 1112ccd979bdSMark Fasheh *ac = NULL; 1113ccd979bdSMark Fasheh } 1114ccd979bdSMark Fasheh 1115c1e8d35eSTao Ma if (status) 1116c1e8d35eSTao Ma mlog_errno(status); 1117ccd979bdSMark Fasheh return status; 1118ccd979bdSMark Fasheh } 1119ccd979bdSMark Fasheh 1120ccd979bdSMark Fasheh /* local alloc code has to do the same thing, so rather than do this 1121ccd979bdSMark Fasheh * twice.. */ 1122ccd979bdSMark Fasheh int ocfs2_reserve_cluster_bitmap_bits(struct ocfs2_super *osb, 1123ccd979bdSMark Fasheh struct ocfs2_alloc_context *ac) 1124ccd979bdSMark Fasheh { 1125ccd979bdSMark Fasheh int status; 1126ccd979bdSMark Fasheh 1127ccd979bdSMark Fasheh ac->ac_which = OCFS2_AC_USE_MAIN; 1128ccd979bdSMark Fasheh ac->ac_group_search = ocfs2_cluster_group_search; 1129ccd979bdSMark Fasheh 1130da5cbf2fSMark Fasheh status = ocfs2_reserve_suballoc_bits(osb, ac, 1131da5cbf2fSMark Fasheh GLOBAL_BITMAP_SYSTEM_INODE, 1132feb473a6STao Ma OCFS2_INVALID_SLOT, NULL, 1133ffda89a3STao Ma ALLOC_NEW_GROUP); 113447ee9d89SGuozhonghua if (status < 0 && status != -ENOSPC) 1135ccd979bdSMark Fasheh mlog_errno(status); 1136da5cbf2fSMark Fasheh 1137ccd979bdSMark Fasheh return status; 1138ccd979bdSMark Fasheh } 1139ccd979bdSMark Fasheh 1140ccd979bdSMark Fasheh /* Callers don't need to care which bitmap (local alloc or main) to 1141ccd979bdSMark Fasheh * use so we figure it out for them, but unfortunately this clutters 1142ccd979bdSMark Fasheh * things a bit. */ 11431187c968SJoel Becker static int ocfs2_reserve_clusters_with_limit(struct ocfs2_super *osb, 11441187c968SJoel Becker u32 bits_wanted, u64 max_block, 114560ca81e8STao Ma int flags, 1146ccd979bdSMark Fasheh struct ocfs2_alloc_context **ac) 1147ccd979bdSMark Fasheh { 11482070ad1aSEric Ren int status, ret = 0; 11492070ad1aSEric Ren int retried = 0; 1150ccd979bdSMark Fasheh 1151cd861280SRobert P. J. Day *ac = kzalloc(sizeof(struct ocfs2_alloc_context), GFP_KERNEL); 1152ccd979bdSMark Fasheh if (!(*ac)) { 1153ccd979bdSMark Fasheh status = -ENOMEM; 1154ccd979bdSMark Fasheh mlog_errno(status); 1155ccd979bdSMark Fasheh goto bail; 1156ccd979bdSMark Fasheh } 1157ccd979bdSMark Fasheh 1158ccd979bdSMark Fasheh (*ac)->ac_bits_wanted = bits_wanted; 11591187c968SJoel Becker (*ac)->ac_max_block = max_block; 1160ccd979bdSMark Fasheh 1161ccd979bdSMark Fasheh status = -ENOSPC; 116260ca81e8STao Ma if (!(flags & ALLOC_GROUPS_FROM_GLOBAL) && 116360ca81e8STao Ma ocfs2_alloc_should_use_local(osb, bits_wanted)) { 1164ccd979bdSMark Fasheh status = ocfs2_reserve_local_alloc_bits(osb, 1165ccd979bdSMark Fasheh bits_wanted, 1166ccd979bdSMark Fasheh *ac); 1167a57c8fd2SMark Fasheh if ((status < 0) && (status != -ENOSPC)) { 1168ccd979bdSMark Fasheh mlog_errno(status); 1169ccd979bdSMark Fasheh goto bail; 1170ccd979bdSMark Fasheh } 1171ccd979bdSMark Fasheh } 1172ccd979bdSMark Fasheh 1173ccd979bdSMark Fasheh if (status == -ENOSPC) { 11742070ad1aSEric Ren retry: 1175ccd979bdSMark Fasheh status = ocfs2_reserve_cluster_bitmap_bits(osb, *ac); 11762070ad1aSEric Ren /* Retry if there is sufficient space cached in truncate log */ 11772070ad1aSEric Ren if (status == -ENOSPC && !retried) { 11782070ad1aSEric Ren retried = 1; 11792070ad1aSEric Ren ocfs2_inode_unlock((*ac)->ac_inode, 1); 11802070ad1aSEric Ren inode_unlock((*ac)->ac_inode); 11812070ad1aSEric Ren 11822070ad1aSEric Ren ret = ocfs2_try_to_free_truncate_log(osb, bits_wanted); 11833bb8b653SJoseph Qi if (ret == 1) { 11843bb8b653SJoseph Qi iput((*ac)->ac_inode); 11853bb8b653SJoseph Qi (*ac)->ac_inode = NULL; 11862070ad1aSEric Ren goto retry; 11873bb8b653SJoseph Qi } 11882070ad1aSEric Ren 11892070ad1aSEric Ren if (ret < 0) 11902070ad1aSEric Ren mlog_errno(ret); 11912070ad1aSEric Ren 11922070ad1aSEric Ren inode_lock((*ac)->ac_inode); 11933bb8b653SJoseph Qi ret = ocfs2_inode_lock((*ac)->ac_inode, NULL, 1); 11943bb8b653SJoseph Qi if (ret < 0) { 11953bb8b653SJoseph Qi mlog_errno(ret); 11963bb8b653SJoseph Qi inode_unlock((*ac)->ac_inode); 11973bb8b653SJoseph Qi iput((*ac)->ac_inode); 11983bb8b653SJoseph Qi (*ac)->ac_inode = NULL; 11993bb8b653SJoseph Qi goto bail; 12003bb8b653SJoseph Qi } 12012070ad1aSEric Ren } 1202ccd979bdSMark Fasheh if (status < 0) { 1203ccd979bdSMark Fasheh if (status != -ENOSPC) 1204ccd979bdSMark Fasheh mlog_errno(status); 1205ccd979bdSMark Fasheh goto bail; 1206ccd979bdSMark Fasheh } 1207ccd979bdSMark Fasheh } 1208ccd979bdSMark Fasheh 1209ccd979bdSMark Fasheh status = 0; 1210ccd979bdSMark Fasheh bail: 1211ccd979bdSMark Fasheh if ((status < 0) && *ac) { 1212ccd979bdSMark Fasheh ocfs2_free_alloc_context(*ac); 1213ccd979bdSMark Fasheh *ac = NULL; 1214ccd979bdSMark Fasheh } 1215ccd979bdSMark Fasheh 1216c1e8d35eSTao Ma if (status) 1217c1e8d35eSTao Ma mlog_errno(status); 1218ccd979bdSMark Fasheh return status; 1219ccd979bdSMark Fasheh } 1220ccd979bdSMark Fasheh 12211187c968SJoel Becker int ocfs2_reserve_clusters(struct ocfs2_super *osb, 12221187c968SJoel Becker u32 bits_wanted, 12231187c968SJoel Becker struct ocfs2_alloc_context **ac) 12241187c968SJoel Becker { 122560ca81e8STao Ma return ocfs2_reserve_clusters_with_limit(osb, bits_wanted, 0, 122660ca81e8STao Ma ALLOC_NEW_GROUP, ac); 12271187c968SJoel Becker } 12281187c968SJoel Becker 1229ccd979bdSMark Fasheh /* 1230ccd979bdSMark Fasheh * More or less lifted from ext3. I'll leave their description below: 1231ccd979bdSMark Fasheh * 1232ccd979bdSMark Fasheh * "For ext3 allocations, we must not reuse any blocks which are 1233ccd979bdSMark Fasheh * allocated in the bitmap buffer's "last committed data" copy. This 1234ccd979bdSMark Fasheh * prevents deletes from freeing up the page for reuse until we have 1235ccd979bdSMark Fasheh * committed the delete transaction. 1236ccd979bdSMark Fasheh * 1237ccd979bdSMark Fasheh * If we didn't do this, then deleting something and reallocating it as 1238ccd979bdSMark Fasheh * data would allow the old block to be overwritten before the 1239ccd979bdSMark Fasheh * transaction committed (because we force data to disk before commit). 1240ccd979bdSMark Fasheh * This would lead to corruption if we crashed between overwriting the 1241ccd979bdSMark Fasheh * data and committing the delete. 1242ccd979bdSMark Fasheh * 1243ccd979bdSMark Fasheh * @@@ We may want to make this allocation behaviour conditional on 1244ccd979bdSMark Fasheh * data-writes at some point, and disable it for metadata allocations or 1245ccd979bdSMark Fasheh * sync-data inodes." 1246ccd979bdSMark Fasheh * 1247ccd979bdSMark Fasheh * Note: OCFS2 already does this differently for metadata vs data 1248c78bad11SJoe Perches * allocations, as those bitmaps are separate and undo access is never 1249ccd979bdSMark Fasheh * called on a metadata group descriptor. 1250ccd979bdSMark Fasheh */ 1251ccd979bdSMark Fasheh static int ocfs2_test_bg_bit_allocatable(struct buffer_head *bg_bh, 1252ccd979bdSMark Fasheh int nr) 1253ccd979bdSMark Fasheh { 1254ccd979bdSMark Fasheh struct ocfs2_group_desc *bg = (struct ocfs2_group_desc *) bg_bh->b_data; 125546417064SThomas Gleixner struct journal_head *jh; 125694e41ecfSSunil Mushran int ret; 1257ccd979bdSMark Fasheh 1258ccd979bdSMark Fasheh if (ocfs2_test_bit(nr, (unsigned long *)bg->bg_bitmap)) 1259ccd979bdSMark Fasheh return 0; 126094e41ecfSSunil Mushran 126194e41ecfSSunil Mushran if (!buffer_jbd(bg_bh)) 1262ccd979bdSMark Fasheh return 1; 1263ccd979bdSMark Fasheh 126446417064SThomas Gleixner jh = bh2jh(bg_bh); 126546417064SThomas Gleixner spin_lock(&jh->b_state_lock); 126646417064SThomas Gleixner bg = (struct ocfs2_group_desc *) jh->b_committed_data; 126794e41ecfSSunil Mushran if (bg) 126894e41ecfSSunil Mushran ret = !ocfs2_test_bit(nr, (unsigned long *)bg->bg_bitmap); 126994e41ecfSSunil Mushran else 127094e41ecfSSunil Mushran ret = 1; 127146417064SThomas Gleixner spin_unlock(&jh->b_state_lock); 127294e41ecfSSunil Mushran 127394e41ecfSSunil Mushran return ret; 1274ccd979bdSMark Fasheh } 1275ccd979bdSMark Fasheh 1276ccd979bdSMark Fasheh static int ocfs2_block_group_find_clear_bits(struct ocfs2_super *osb, 1277ccd979bdSMark Fasheh struct buffer_head *bg_bh, 1278ccd979bdSMark Fasheh unsigned int bits_wanted, 12797bf72edeSMark Fasheh unsigned int total_bits, 12807d1fe093SJoel Becker struct ocfs2_suballoc_result *res) 1281ccd979bdSMark Fasheh { 1282ccd979bdSMark Fasheh void *bitmap; 1283ccd979bdSMark Fasheh u16 best_offset, best_size; 1284ccd979bdSMark Fasheh int offset, start, found, status = 0; 1285ccd979bdSMark Fasheh struct ocfs2_group_desc *bg = (struct ocfs2_group_desc *) bg_bh->b_data; 1286ccd979bdSMark Fasheh 128742035306SJoel Becker /* Callers got this descriptor from 128842035306SJoel Becker * ocfs2_read_group_descriptor(). Any corruption is a code bug. */ 128942035306SJoel Becker BUG_ON(!OCFS2_IS_VALID_GROUP_DESC(bg)); 1290ccd979bdSMark Fasheh 1291ccd979bdSMark Fasheh found = start = best_offset = best_size = 0; 1292ccd979bdSMark Fasheh bitmap = bg->bg_bitmap; 1293ccd979bdSMark Fasheh 12947bf72edeSMark Fasheh while((offset = ocfs2_find_next_zero_bit(bitmap, total_bits, start)) != -1) { 12957bf72edeSMark Fasheh if (offset == total_bits) 1296ccd979bdSMark Fasheh break; 1297ccd979bdSMark Fasheh 1298ccd979bdSMark Fasheh if (!ocfs2_test_bg_bit_allocatable(bg_bh, offset)) { 1299ccd979bdSMark Fasheh /* We found a zero, but we can't use it as it 1300ccd979bdSMark Fasheh * hasn't been put to disk yet! */ 1301ccd979bdSMark Fasheh found = 0; 1302ccd979bdSMark Fasheh start = offset + 1; 1303ccd979bdSMark Fasheh } else if (offset == start) { 1304ccd979bdSMark Fasheh /* we found a zero */ 1305ccd979bdSMark Fasheh found++; 1306ccd979bdSMark Fasheh /* move start to the next bit to test */ 1307ccd979bdSMark Fasheh start++; 1308ccd979bdSMark Fasheh } else { 1309ccd979bdSMark Fasheh /* got a zero after some ones */ 1310ccd979bdSMark Fasheh found = 1; 1311ccd979bdSMark Fasheh start = offset + 1; 1312ccd979bdSMark Fasheh } 1313ccd979bdSMark Fasheh if (found > best_size) { 1314ccd979bdSMark Fasheh best_size = found; 1315ccd979bdSMark Fasheh best_offset = start - found; 1316ccd979bdSMark Fasheh } 1317ccd979bdSMark Fasheh /* we got everything we needed */ 1318ccd979bdSMark Fasheh if (found == bits_wanted) { 1319ccd979bdSMark Fasheh /* mlog(0, "Found it all!\n"); */ 1320ccd979bdSMark Fasheh break; 1321ccd979bdSMark Fasheh } 1322ccd979bdSMark Fasheh } 1323ccd979bdSMark Fasheh 13247d1fe093SJoel Becker if (best_size) { 13257d1fe093SJoel Becker res->sr_bit_offset = best_offset; 13267d1fe093SJoel Becker res->sr_bits = best_size; 1327ccd979bdSMark Fasheh } else { 1328ccd979bdSMark Fasheh status = -ENOSPC; 1329ccd979bdSMark Fasheh /* No error log here -- see the comment above 1330ccd979bdSMark Fasheh * ocfs2_test_bg_bit_allocatable */ 1331ccd979bdSMark Fasheh } 1332ccd979bdSMark Fasheh 1333ccd979bdSMark Fasheh return status; 1334ccd979bdSMark Fasheh } 1335ccd979bdSMark Fasheh 13360a2fcd89SYounger Liu int ocfs2_block_group_set_bits(handle_t *handle, 1337ccd979bdSMark Fasheh struct inode *alloc_inode, 1338ccd979bdSMark Fasheh struct ocfs2_group_desc *bg, 1339ccd979bdSMark Fasheh struct buffer_head *group_bh, 1340ccd979bdSMark Fasheh unsigned int bit_off, 1341ccd979bdSMark Fasheh unsigned int num_bits) 1342ccd979bdSMark Fasheh { 1343ccd979bdSMark Fasheh int status; 1344ccd979bdSMark Fasheh void *bitmap = bg->bg_bitmap; 1345ccd979bdSMark Fasheh int journal_type = OCFS2_JOURNAL_ACCESS_WRITE; 1346ccd979bdSMark Fasheh 134742035306SJoel Becker /* All callers get the descriptor via 134842035306SJoel Becker * ocfs2_read_group_descriptor(). Any corruption is a code bug. */ 134942035306SJoel Becker BUG_ON(!OCFS2_IS_VALID_GROUP_DESC(bg)); 1350ccd979bdSMark Fasheh BUG_ON(le16_to_cpu(bg->bg_free_bits_count) < num_bits); 1351ccd979bdSMark Fasheh 13522f73e135STao Ma trace_ocfs2_block_group_set_bits(bit_off, num_bits); 1353ccd979bdSMark Fasheh 1354ccd979bdSMark Fasheh if (ocfs2_is_cluster_bitmap(alloc_inode)) 1355ccd979bdSMark Fasheh journal_type = OCFS2_JOURNAL_ACCESS_UNDO; 1356ccd979bdSMark Fasheh 135713723d00SJoel Becker status = ocfs2_journal_access_gd(handle, 13580cf2f763SJoel Becker INODE_CACHE(alloc_inode), 1359ccd979bdSMark Fasheh group_bh, 1360ccd979bdSMark Fasheh journal_type); 1361ccd979bdSMark Fasheh if (status < 0) { 1362ccd979bdSMark Fasheh mlog_errno(status); 1363ccd979bdSMark Fasheh goto bail; 1364ccd979bdSMark Fasheh } 1365ccd979bdSMark Fasheh 1366ccd979bdSMark Fasheh le16_add_cpu(&bg->bg_free_bits_count, -num_bits); 13679b5cd10eSSrinivas Eeda if (le16_to_cpu(bg->bg_free_bits_count) > le16_to_cpu(bg->bg_bits)) { 13687ecef14aSJoe Perches return ocfs2_error(alloc_inode->i_sb, "Group descriptor # %llu has bit count %u but claims %u are freed. num_bits %d\n", 13699b5cd10eSSrinivas Eeda (unsigned long long)le64_to_cpu(bg->bg_blkno), 13709b5cd10eSSrinivas Eeda le16_to_cpu(bg->bg_bits), 13717ecef14aSJoe Perches le16_to_cpu(bg->bg_free_bits_count), 13727ecef14aSJoe Perches num_bits); 13739b5cd10eSSrinivas Eeda } 1374ccd979bdSMark Fasheh while(num_bits--) 1375ccd979bdSMark Fasheh ocfs2_set_bit(bit_off++, bitmap); 1376ccd979bdSMark Fasheh 1377ec20cec7SJoel Becker ocfs2_journal_dirty(handle, group_bh); 1378ccd979bdSMark Fasheh 1379ccd979bdSMark Fasheh bail: 1380ccd979bdSMark Fasheh return status; 1381ccd979bdSMark Fasheh } 1382ccd979bdSMark Fasheh 1383ccd979bdSMark Fasheh /* find the one with the most empty bits */ 1384ccd979bdSMark Fasheh static inline u16 ocfs2_find_victim_chain(struct ocfs2_chain_list *cl) 1385ccd979bdSMark Fasheh { 1386ccd979bdSMark Fasheh u16 curr, best; 1387ccd979bdSMark Fasheh 1388ccd979bdSMark Fasheh BUG_ON(!cl->cl_next_free_rec); 1389ccd979bdSMark Fasheh 1390ccd979bdSMark Fasheh best = curr = 0; 1391ccd979bdSMark Fasheh while (curr < le16_to_cpu(cl->cl_next_free_rec)) { 1392ccd979bdSMark Fasheh if (le32_to_cpu(cl->cl_recs[curr].c_free) > 1393ccd979bdSMark Fasheh le32_to_cpu(cl->cl_recs[best].c_free)) 1394ccd979bdSMark Fasheh best = curr; 1395ccd979bdSMark Fasheh curr++; 1396ccd979bdSMark Fasheh } 1397ccd979bdSMark Fasheh 1398ccd979bdSMark Fasheh BUG_ON(best >= le16_to_cpu(cl->cl_next_free_rec)); 1399ccd979bdSMark Fasheh return best; 1400ccd979bdSMark Fasheh } 1401ccd979bdSMark Fasheh 14021fabe148SMark Fasheh static int ocfs2_relink_block_group(handle_t *handle, 1403ccd979bdSMark Fasheh struct inode *alloc_inode, 1404ccd979bdSMark Fasheh struct buffer_head *fe_bh, 1405ccd979bdSMark Fasheh struct buffer_head *bg_bh, 1406ccd979bdSMark Fasheh struct buffer_head *prev_bg_bh, 1407ccd979bdSMark Fasheh u16 chain) 1408ccd979bdSMark Fasheh { 1409ccd979bdSMark Fasheh int status; 1410ccd979bdSMark Fasheh /* there is a really tiny chance the journal calls could fail, 1411ccd979bdSMark Fasheh * but we wouldn't want inconsistent blocks in *any* case. */ 141249309841SJie Liu u64 bg_ptr, prev_bg_ptr; 1413ccd979bdSMark Fasheh struct ocfs2_dinode *fe = (struct ocfs2_dinode *) fe_bh->b_data; 1414ccd979bdSMark Fasheh struct ocfs2_group_desc *bg = (struct ocfs2_group_desc *) bg_bh->b_data; 1415ccd979bdSMark Fasheh struct ocfs2_group_desc *prev_bg = (struct ocfs2_group_desc *) prev_bg_bh->b_data; 1416ccd979bdSMark Fasheh 141742035306SJoel Becker /* The caller got these descriptors from 141842035306SJoel Becker * ocfs2_read_group_descriptor(). Any corruption is a code bug. */ 141942035306SJoel Becker BUG_ON(!OCFS2_IS_VALID_GROUP_DESC(bg)); 142042035306SJoel Becker BUG_ON(!OCFS2_IS_VALID_GROUP_DESC(prev_bg)); 1421ccd979bdSMark Fasheh 14222f73e135STao Ma trace_ocfs2_relink_block_group( 14231ca1a111SMark Fasheh (unsigned long long)le64_to_cpu(fe->i_blkno), chain, 14241ca1a111SMark Fasheh (unsigned long long)le64_to_cpu(bg->bg_blkno), 14251ca1a111SMark Fasheh (unsigned long long)le64_to_cpu(prev_bg->bg_blkno)); 1426ccd979bdSMark Fasheh 1427ccd979bdSMark Fasheh bg_ptr = le64_to_cpu(bg->bg_next_group); 1428ccd979bdSMark Fasheh prev_bg_ptr = le64_to_cpu(prev_bg->bg_next_group); 1429ccd979bdSMark Fasheh 14300cf2f763SJoel Becker status = ocfs2_journal_access_gd(handle, INODE_CACHE(alloc_inode), 14310cf2f763SJoel Becker prev_bg_bh, 1432ccd979bdSMark Fasheh OCFS2_JOURNAL_ACCESS_WRITE); 143325e28921SAndrew Morton if (status < 0) 143449309841SJie Liu goto out; 1435ccd979bdSMark Fasheh 1436ccd979bdSMark Fasheh prev_bg->bg_next_group = bg->bg_next_group; 1437ec20cec7SJoel Becker ocfs2_journal_dirty(handle, prev_bg_bh); 1438ccd979bdSMark Fasheh 14390cf2f763SJoel Becker status = ocfs2_journal_access_gd(handle, INODE_CACHE(alloc_inode), 14400cf2f763SJoel Becker bg_bh, OCFS2_JOURNAL_ACCESS_WRITE); 144125e28921SAndrew Morton if (status < 0) 144249309841SJie Liu goto out_rollback_prev_bg; 1443ccd979bdSMark Fasheh 1444ccd979bdSMark Fasheh bg->bg_next_group = fe->id2.i_chain.cl_recs[chain].c_blkno; 1445ec20cec7SJoel Becker ocfs2_journal_dirty(handle, bg_bh); 1446ccd979bdSMark Fasheh 14470cf2f763SJoel Becker status = ocfs2_journal_access_di(handle, INODE_CACHE(alloc_inode), 14480cf2f763SJoel Becker fe_bh, OCFS2_JOURNAL_ACCESS_WRITE); 144925e28921SAndrew Morton if (status < 0) 145049309841SJie Liu goto out_rollback_bg; 1451ccd979bdSMark Fasheh 1452ccd979bdSMark Fasheh fe->id2.i_chain.cl_recs[chain].c_blkno = bg->bg_blkno; 1453ec20cec7SJoel Becker ocfs2_journal_dirty(handle, fe_bh); 1454ccd979bdSMark Fasheh 145549309841SJie Liu out: 145625e28921SAndrew Morton if (status < 0) 145725e28921SAndrew Morton mlog_errno(status); 145849309841SJie Liu return status; 145942035306SJoel Becker 146049309841SJie Liu out_rollback_bg: 146149309841SJie Liu bg->bg_next_group = cpu_to_le64(bg_ptr); 146249309841SJie Liu out_rollback_prev_bg: 146349309841SJie Liu prev_bg->bg_next_group = cpu_to_le64(prev_bg_ptr); 146425e28921SAndrew Morton goto out; 1465ccd979bdSMark Fasheh } 1466ccd979bdSMark Fasheh 1467ccd979bdSMark Fasheh static inline int ocfs2_block_group_reasonably_empty(struct ocfs2_group_desc *bg, 1468ccd979bdSMark Fasheh u32 wanted) 1469ccd979bdSMark Fasheh { 1470ccd979bdSMark Fasheh return le16_to_cpu(bg->bg_free_bits_count) > wanted; 1471ccd979bdSMark Fasheh } 1472ccd979bdSMark Fasheh 1473ccd979bdSMark Fasheh /* return 0 on success, -ENOSPC to keep searching and any other < 0 1474ccd979bdSMark Fasheh * value on error. */ 1475ccd979bdSMark Fasheh static int ocfs2_cluster_group_search(struct inode *inode, 1476ccd979bdSMark Fasheh struct buffer_head *group_bh, 1477ccd979bdSMark Fasheh u32 bits_wanted, u32 min_bits, 14781187c968SJoel Becker u64 max_block, 14797d1fe093SJoel Becker struct ocfs2_suballoc_result *res) 1480ccd979bdSMark Fasheh { 1481ccd979bdSMark Fasheh int search = -ENOSPC; 1482ccd979bdSMark Fasheh int ret; 14831187c968SJoel Becker u64 blkoff; 14847bf72edeSMark Fasheh struct ocfs2_group_desc *gd = (struct ocfs2_group_desc *) group_bh->b_data; 14859c7af40bSMark Fasheh struct ocfs2_super *osb = OCFS2_SB(inode->i_sb); 14867bf72edeSMark Fasheh unsigned int max_bits, gd_cluster_off; 1487ccd979bdSMark Fasheh 1488ccd979bdSMark Fasheh BUG_ON(!ocfs2_is_cluster_bitmap(inode)); 1489ccd979bdSMark Fasheh 14907bf72edeSMark Fasheh if (gd->bg_free_bits_count) { 14917bf72edeSMark Fasheh max_bits = le16_to_cpu(gd->bg_bits); 14927bf72edeSMark Fasheh 14937bf72edeSMark Fasheh /* Tail groups in cluster bitmaps which aren't cpg 149425985edcSLucas De Marchi * aligned are prone to partial extension by a failed 14957bf72edeSMark Fasheh * fs resize. If the file system resize never got to 14967bf72edeSMark Fasheh * update the dinode cluster count, then we don't want 14977bf72edeSMark Fasheh * to trust any clusters past it, regardless of what 14987bf72edeSMark Fasheh * the group descriptor says. */ 14997bf72edeSMark Fasheh gd_cluster_off = ocfs2_blocks_to_clusters(inode->i_sb, 15007bf72edeSMark Fasheh le64_to_cpu(gd->bg_blkno)); 15017bf72edeSMark Fasheh if ((gd_cluster_off + max_bits) > 15027bf72edeSMark Fasheh OCFS2_I(inode)->ip_clusters) { 15037bf72edeSMark Fasheh max_bits = OCFS2_I(inode)->ip_clusters - gd_cluster_off; 15042f73e135STao Ma trace_ocfs2_cluster_group_search_wrong_max_bits( 15057bf72edeSMark Fasheh (unsigned long long)le64_to_cpu(gd->bg_blkno), 15067bf72edeSMark Fasheh le16_to_cpu(gd->bg_bits), 15077bf72edeSMark Fasheh OCFS2_I(inode)->ip_clusters, max_bits); 15087bf72edeSMark Fasheh } 15097bf72edeSMark Fasheh 15101119d3c0Spiaojun ret = ocfs2_block_group_find_clear_bits(osb, 1511ccd979bdSMark Fasheh group_bh, bits_wanted, 15127d1fe093SJoel Becker max_bits, res); 1513ccd979bdSMark Fasheh if (ret) 1514ccd979bdSMark Fasheh return ret; 1515ccd979bdSMark Fasheh 15161187c968SJoel Becker if (max_block) { 15171187c968SJoel Becker blkoff = ocfs2_clusters_to_blocks(inode->i_sb, 15181187c968SJoel Becker gd_cluster_off + 15197d1fe093SJoel Becker res->sr_bit_offset + 15207d1fe093SJoel Becker res->sr_bits); 15212f73e135STao Ma trace_ocfs2_cluster_group_search_max_block( 15221187c968SJoel Becker (unsigned long long)blkoff, 15231187c968SJoel Becker (unsigned long long)max_block); 15241187c968SJoel Becker if (blkoff > max_block) 15251187c968SJoel Becker return -ENOSPC; 15261187c968SJoel Becker } 15271187c968SJoel Becker 1528ccd979bdSMark Fasheh /* ocfs2_block_group_find_clear_bits() might 1529ccd979bdSMark Fasheh * return success, but we still want to return 1530ccd979bdSMark Fasheh * -ENOSPC unless it found the minimum number 1531ccd979bdSMark Fasheh * of bits. */ 15327d1fe093SJoel Becker if (min_bits <= res->sr_bits) 1533ccd979bdSMark Fasheh search = 0; /* success */ 15347d1fe093SJoel Becker else if (res->sr_bits) { 15359c7af40bSMark Fasheh /* 15369c7af40bSMark Fasheh * Don't show bits which we'll be returning 15379c7af40bSMark Fasheh * for allocation to the local alloc bitmap. 15389c7af40bSMark Fasheh */ 15397d1fe093SJoel Becker ocfs2_local_alloc_seen_free_bits(osb, res->sr_bits); 1540ccd979bdSMark Fasheh } 1541ccd979bdSMark Fasheh } 1542ccd979bdSMark Fasheh 1543ccd979bdSMark Fasheh return search; 1544ccd979bdSMark Fasheh } 1545ccd979bdSMark Fasheh 1546ccd979bdSMark Fasheh static int ocfs2_block_group_search(struct inode *inode, 1547ccd979bdSMark Fasheh struct buffer_head *group_bh, 1548ccd979bdSMark Fasheh u32 bits_wanted, u32 min_bits, 15491187c968SJoel Becker u64 max_block, 15507d1fe093SJoel Becker struct ocfs2_suballoc_result *res) 1551ccd979bdSMark Fasheh { 1552ccd979bdSMark Fasheh int ret = -ENOSPC; 15531187c968SJoel Becker u64 blkoff; 1554ccd979bdSMark Fasheh struct ocfs2_group_desc *bg = (struct ocfs2_group_desc *) group_bh->b_data; 1555ccd979bdSMark Fasheh 1556ccd979bdSMark Fasheh BUG_ON(min_bits != 1); 1557ccd979bdSMark Fasheh BUG_ON(ocfs2_is_cluster_bitmap(inode)); 1558ccd979bdSMark Fasheh 15591187c968SJoel Becker if (bg->bg_free_bits_count) { 1560ccd979bdSMark Fasheh ret = ocfs2_block_group_find_clear_bits(OCFS2_SB(inode->i_sb), 1561ccd979bdSMark Fasheh group_bh, bits_wanted, 15627bf72edeSMark Fasheh le16_to_cpu(bg->bg_bits), 15637d1fe093SJoel Becker res); 15641187c968SJoel Becker if (!ret && max_block) { 15657d1fe093SJoel Becker blkoff = le64_to_cpu(bg->bg_blkno) + 15667d1fe093SJoel Becker res->sr_bit_offset + res->sr_bits; 15672f73e135STao Ma trace_ocfs2_block_group_search_max_block( 15681187c968SJoel Becker (unsigned long long)blkoff, 15691187c968SJoel Becker (unsigned long long)max_block); 15701187c968SJoel Becker if (blkoff > max_block) 15711187c968SJoel Becker ret = -ENOSPC; 15721187c968SJoel Becker } 15731187c968SJoel Becker } 1574ccd979bdSMark Fasheh 1575ccd979bdSMark Fasheh return ret; 1576ccd979bdSMark Fasheh } 1577ccd979bdSMark Fasheh 15780a2fcd89SYounger Liu int ocfs2_alloc_dinode_update_counts(struct inode *inode, 15791fabe148SMark Fasheh handle_t *handle, 1580883d4caeSMark Fasheh struct buffer_head *di_bh, 1581883d4caeSMark Fasheh u32 num_bits, 1582883d4caeSMark Fasheh u16 chain) 1583883d4caeSMark Fasheh { 1584883d4caeSMark Fasheh int ret; 1585883d4caeSMark Fasheh u32 tmp_used; 1586883d4caeSMark Fasheh struct ocfs2_dinode *di = (struct ocfs2_dinode *) di_bh->b_data; 1587883d4caeSMark Fasheh struct ocfs2_chain_list *cl = (struct ocfs2_chain_list *) &di->id2.i_chain; 1588883d4caeSMark Fasheh 15890cf2f763SJoel Becker ret = ocfs2_journal_access_di(handle, INODE_CACHE(inode), di_bh, 1590883d4caeSMark Fasheh OCFS2_JOURNAL_ACCESS_WRITE); 1591883d4caeSMark Fasheh if (ret < 0) { 1592883d4caeSMark Fasheh mlog_errno(ret); 1593883d4caeSMark Fasheh goto out; 1594883d4caeSMark Fasheh } 1595883d4caeSMark Fasheh 1596883d4caeSMark Fasheh tmp_used = le32_to_cpu(di->id1.bitmap1.i_used); 1597883d4caeSMark Fasheh di->id1.bitmap1.i_used = cpu_to_le32(num_bits + tmp_used); 1598883d4caeSMark Fasheh le32_add_cpu(&cl->cl_recs[chain].c_free, -num_bits); 1599ec20cec7SJoel Becker ocfs2_journal_dirty(handle, di_bh); 1600883d4caeSMark Fasheh 1601883d4caeSMark Fasheh out: 1602883d4caeSMark Fasheh return ret; 1603883d4caeSMark Fasheh } 1604883d4caeSMark Fasheh 1605db66c715SYounger Liu void ocfs2_rollback_alloc_dinode_counts(struct inode *inode, 1606db66c715SYounger Liu struct buffer_head *di_bh, 1607db66c715SYounger Liu u32 num_bits, 1608db66c715SYounger Liu u16 chain) 1609db66c715SYounger Liu { 1610db66c715SYounger Liu u32 tmp_used; 1611db66c715SYounger Liu struct ocfs2_dinode *di = (struct ocfs2_dinode *) di_bh->b_data; 1612db66c715SYounger Liu struct ocfs2_chain_list *cl; 1613db66c715SYounger Liu 1614db66c715SYounger Liu cl = (struct ocfs2_chain_list *)&di->id2.i_chain; 1615db66c715SYounger Liu tmp_used = le32_to_cpu(di->id1.bitmap1.i_used); 1616db66c715SYounger Liu di->id1.bitmap1.i_used = cpu_to_le32(tmp_used - num_bits); 1617db66c715SYounger Liu le32_add_cpu(&cl->cl_recs[chain].c_free, num_bits); 1618db66c715SYounger Liu } 1619db66c715SYounger Liu 1620ba206635SJoel Becker static int ocfs2_bg_discontig_fix_by_rec(struct ocfs2_suballoc_result *res, 162113e434cfSJoel Becker struct ocfs2_extent_rec *rec, 162213e434cfSJoel Becker struct ocfs2_chain_list *cl) 162313e434cfSJoel Becker { 162413e434cfSJoel Becker unsigned int bpc = le16_to_cpu(cl->cl_bpc); 162513e434cfSJoel Becker unsigned int bitoff = le32_to_cpu(rec->e_cpos) * bpc; 162672094e43SAl Viro unsigned int bitcount = le16_to_cpu(rec->e_leaf_clusters) * bpc; 162713e434cfSJoel Becker 162813e434cfSJoel Becker if (res->sr_bit_offset < bitoff) 162913e434cfSJoel Becker return 0; 163013e434cfSJoel Becker if (res->sr_bit_offset >= (bitoff + bitcount)) 163113e434cfSJoel Becker return 0; 1632ba206635SJoel Becker res->sr_blkno = le64_to_cpu(rec->e_blkno) + 1633ba206635SJoel Becker (res->sr_bit_offset - bitoff); 163413e434cfSJoel Becker if ((res->sr_bit_offset + res->sr_bits) > (bitoff + bitcount)) 163513e434cfSJoel Becker res->sr_bits = (bitoff + bitcount) - res->sr_bit_offset; 163613e434cfSJoel Becker return 1; 163713e434cfSJoel Becker } 163813e434cfSJoel Becker 1639ba206635SJoel Becker static void ocfs2_bg_discontig_fix_result(struct ocfs2_alloc_context *ac, 164013e434cfSJoel Becker struct ocfs2_group_desc *bg, 164113e434cfSJoel Becker struct ocfs2_suballoc_result *res) 164213e434cfSJoel Becker { 164313e434cfSJoel Becker int i; 16442b6cb576SJoel Becker u64 bg_blkno = res->sr_bg_blkno; /* Save off */ 164513e434cfSJoel Becker struct ocfs2_extent_rec *rec; 164613e434cfSJoel Becker struct ocfs2_dinode *di = (struct ocfs2_dinode *)ac->ac_bh->b_data; 164713e434cfSJoel Becker struct ocfs2_chain_list *cl = &di->id2.i_chain; 164813e434cfSJoel Becker 1649ba206635SJoel Becker if (ocfs2_is_cluster_bitmap(ac->ac_inode)) { 1650ba206635SJoel Becker res->sr_blkno = 0; 165113e434cfSJoel Becker return; 1652ba206635SJoel Becker } 165313e434cfSJoel Becker 1654ba206635SJoel Becker res->sr_blkno = res->sr_bg_blkno + res->sr_bit_offset; 16552b6cb576SJoel Becker res->sr_bg_blkno = 0; /* Clear it for contig block groups */ 16564711954eSTao Ma if (!ocfs2_supports_discontig_bg(OCFS2_SB(ac->ac_inode->i_sb)) || 1657ba206635SJoel Becker !bg->bg_list.l_next_free_rec) 165813e434cfSJoel Becker return; 165913e434cfSJoel Becker 166013e434cfSJoel Becker for (i = 0; i < le16_to_cpu(bg->bg_list.l_next_free_rec); i++) { 166113e434cfSJoel Becker rec = &bg->bg_list.l_recs[i]; 16622b6cb576SJoel Becker if (ocfs2_bg_discontig_fix_by_rec(res, rec, cl)) { 16632b6cb576SJoel Becker res->sr_bg_blkno = bg_blkno; /* Restore */ 166413e434cfSJoel Becker break; 166513e434cfSJoel Becker } 166613e434cfSJoel Becker } 16672b6cb576SJoel Becker } 166813e434cfSJoel Becker 1669883d4caeSMark Fasheh static int ocfs2_search_one_group(struct ocfs2_alloc_context *ac, 16701fabe148SMark Fasheh handle_t *handle, 1671883d4caeSMark Fasheh u32 bits_wanted, 1672883d4caeSMark Fasheh u32 min_bits, 16737d1fe093SJoel Becker struct ocfs2_suballoc_result *res, 1674883d4caeSMark Fasheh u16 *bits_left) 1675883d4caeSMark Fasheh { 1676883d4caeSMark Fasheh int ret; 1677883d4caeSMark Fasheh struct buffer_head *group_bh = NULL; 1678883d4caeSMark Fasheh struct ocfs2_group_desc *gd; 167968f64d47SJoel Becker struct ocfs2_dinode *di = (struct ocfs2_dinode *)ac->ac_bh->b_data; 1680883d4caeSMark Fasheh struct inode *alloc_inode = ac->ac_inode; 1681883d4caeSMark Fasheh 16827d1fe093SJoel Becker ret = ocfs2_read_group_descriptor(alloc_inode, di, 16837d1fe093SJoel Becker res->sr_bg_blkno, &group_bh); 1684883d4caeSMark Fasheh if (ret < 0) { 1685883d4caeSMark Fasheh mlog_errno(ret); 1686883d4caeSMark Fasheh return ret; 1687883d4caeSMark Fasheh } 1688883d4caeSMark Fasheh 1689883d4caeSMark Fasheh gd = (struct ocfs2_group_desc *) group_bh->b_data; 1690883d4caeSMark Fasheh ret = ac->ac_group_search(alloc_inode, group_bh, bits_wanted, min_bits, 16917d1fe093SJoel Becker ac->ac_max_block, res); 1692883d4caeSMark Fasheh if (ret < 0) { 1693883d4caeSMark Fasheh if (ret != -ENOSPC) 1694883d4caeSMark Fasheh mlog_errno(ret); 1695883d4caeSMark Fasheh goto out; 1696883d4caeSMark Fasheh } 1697883d4caeSMark Fasheh 169813e434cfSJoel Becker if (!ret) 1699ba206635SJoel Becker ocfs2_bg_discontig_fix_result(ac, gd, res); 170013e434cfSJoel Becker 1701e49e2767SMark Fasheh /* 1702e49e2767SMark Fasheh * sr_bg_blkno might have been changed by 1703e49e2767SMark Fasheh * ocfs2_bg_discontig_fix_result 1704e49e2767SMark Fasheh */ 1705e49e2767SMark Fasheh res->sr_bg_stable_blkno = group_bh->b_blocknr; 1706e49e2767SMark Fasheh 1707e49e2767SMark Fasheh if (ac->ac_find_loc_only) 1708e49e2767SMark Fasheh goto out_loc_only; 1709e49e2767SMark Fasheh 1710883d4caeSMark Fasheh ret = ocfs2_alloc_dinode_update_counts(alloc_inode, handle, ac->ac_bh, 17117d1fe093SJoel Becker res->sr_bits, 1712883d4caeSMark Fasheh le16_to_cpu(gd->bg_chain)); 1713883d4caeSMark Fasheh if (ret < 0) { 1714883d4caeSMark Fasheh mlog_errno(ret); 1715883d4caeSMark Fasheh goto out; 1716883d4caeSMark Fasheh } 1717883d4caeSMark Fasheh 1718883d4caeSMark Fasheh ret = ocfs2_block_group_set_bits(handle, alloc_inode, gd, group_bh, 17197d1fe093SJoel Becker res->sr_bit_offset, res->sr_bits); 1720db66c715SYounger Liu if (ret < 0) { 1721db66c715SYounger Liu ocfs2_rollback_alloc_dinode_counts(alloc_inode, ac->ac_bh, 1722db66c715SYounger Liu res->sr_bits, 1723db66c715SYounger Liu le16_to_cpu(gd->bg_chain)); 1724883d4caeSMark Fasheh mlog_errno(ret); 1725db66c715SYounger Liu } 1726883d4caeSMark Fasheh 1727e49e2767SMark Fasheh out_loc_only: 1728883d4caeSMark Fasheh *bits_left = le16_to_cpu(gd->bg_free_bits_count); 1729883d4caeSMark Fasheh 1730883d4caeSMark Fasheh out: 1731883d4caeSMark Fasheh brelse(group_bh); 1732883d4caeSMark Fasheh 1733883d4caeSMark Fasheh return ret; 1734883d4caeSMark Fasheh } 1735883d4caeSMark Fasheh 1736ccd979bdSMark Fasheh static int ocfs2_search_chain(struct ocfs2_alloc_context *ac, 17371fabe148SMark Fasheh handle_t *handle, 1738ccd979bdSMark Fasheh u32 bits_wanted, 1739ccd979bdSMark Fasheh u32 min_bits, 17407d1fe093SJoel Becker struct ocfs2_suballoc_result *res, 1741883d4caeSMark Fasheh u16 *bits_left) 1742ccd979bdSMark Fasheh { 1743ccd979bdSMark Fasheh int status; 17447d1fe093SJoel Becker u16 chain; 1745ccd979bdSMark Fasheh u64 next_group; 1746ccd979bdSMark Fasheh struct inode *alloc_inode = ac->ac_inode; 1747ccd979bdSMark Fasheh struct buffer_head *group_bh = NULL; 1748ccd979bdSMark Fasheh struct buffer_head *prev_group_bh = NULL; 1749ccd979bdSMark Fasheh struct ocfs2_dinode *fe = (struct ocfs2_dinode *) ac->ac_bh->b_data; 1750ccd979bdSMark Fasheh struct ocfs2_chain_list *cl = (struct ocfs2_chain_list *) &fe->id2.i_chain; 1751ccd979bdSMark Fasheh struct ocfs2_group_desc *bg; 1752ccd979bdSMark Fasheh 1753ccd979bdSMark Fasheh chain = ac->ac_chain; 17542f73e135STao Ma trace_ocfs2_search_chain_begin( 17552f73e135STao Ma (unsigned long long)OCFS2_I(alloc_inode)->ip_blkno, 17562f73e135STao Ma bits_wanted, chain); 1757ccd979bdSMark Fasheh 175868f64d47SJoel Becker status = ocfs2_read_group_descriptor(alloc_inode, fe, 1759ccd979bdSMark Fasheh le64_to_cpu(cl->cl_recs[chain].c_blkno), 17600fcaa56aSJoel Becker &group_bh); 1761ccd979bdSMark Fasheh if (status < 0) { 1762ccd979bdSMark Fasheh mlog_errno(status); 1763ccd979bdSMark Fasheh goto bail; 1764ccd979bdSMark Fasheh } 1765ccd979bdSMark Fasheh bg = (struct ocfs2_group_desc *) group_bh->b_data; 1766ccd979bdSMark Fasheh 1767ccd979bdSMark Fasheh status = -ENOSPC; 1768ccd979bdSMark Fasheh /* for now, the chain search is a bit simplistic. We just use 1769ccd979bdSMark Fasheh * the 1st group with any empty bits. */ 17701187c968SJoel Becker while ((status = ac->ac_group_search(alloc_inode, group_bh, 17711187c968SJoel Becker bits_wanted, min_bits, 17727d1fe093SJoel Becker ac->ac_max_block, 17737d1fe093SJoel Becker res)) == -ENOSPC) { 1774ccd979bdSMark Fasheh if (!bg->bg_next_group) 1775ccd979bdSMark Fasheh break; 1776a81cb88bSMark Fasheh 1777ccd979bdSMark Fasheh brelse(prev_group_bh); 1778ccd979bdSMark Fasheh prev_group_bh = NULL; 1779a81cb88bSMark Fasheh 1780ccd979bdSMark Fasheh next_group = le64_to_cpu(bg->bg_next_group); 1781ccd979bdSMark Fasheh prev_group_bh = group_bh; 1782ccd979bdSMark Fasheh group_bh = NULL; 178368f64d47SJoel Becker status = ocfs2_read_group_descriptor(alloc_inode, fe, 17840fcaa56aSJoel Becker next_group, &group_bh); 1785ccd979bdSMark Fasheh if (status < 0) { 1786ccd979bdSMark Fasheh mlog_errno(status); 1787ccd979bdSMark Fasheh goto bail; 1788ccd979bdSMark Fasheh } 1789ccd979bdSMark Fasheh bg = (struct ocfs2_group_desc *) group_bh->b_data; 1790ccd979bdSMark Fasheh } 1791ccd979bdSMark Fasheh if (status < 0) { 1792ccd979bdSMark Fasheh if (status != -ENOSPC) 1793ccd979bdSMark Fasheh mlog_errno(status); 1794ccd979bdSMark Fasheh goto bail; 1795ccd979bdSMark Fasheh } 1796ccd979bdSMark Fasheh 17972f73e135STao Ma trace_ocfs2_search_chain_succ( 17982f73e135STao Ma (unsigned long long)le64_to_cpu(bg->bg_blkno), res->sr_bits); 1799ccd979bdSMark Fasheh 18007d1fe093SJoel Becker res->sr_bg_blkno = le64_to_cpu(bg->bg_blkno); 1801ccd979bdSMark Fasheh 18027d1fe093SJoel Becker BUG_ON(res->sr_bits == 0); 180313e434cfSJoel Becker if (!status) 1804ba206635SJoel Becker ocfs2_bg_discontig_fix_result(ac, bg, res); 180513e434cfSJoel Becker 1806e49e2767SMark Fasheh /* 1807e49e2767SMark Fasheh * sr_bg_blkno might have been changed by 1808e49e2767SMark Fasheh * ocfs2_bg_discontig_fix_result 1809e49e2767SMark Fasheh */ 1810e49e2767SMark Fasheh res->sr_bg_stable_blkno = group_bh->b_blocknr; 1811ccd979bdSMark Fasheh 1812ccd979bdSMark Fasheh /* 1813ccd979bdSMark Fasheh * Keep track of previous block descriptor read. When 1814ccd979bdSMark Fasheh * we find a target, if we have read more than X 1815ccd979bdSMark Fasheh * number of descriptors, and the target is reasonably 1816ccd979bdSMark Fasheh * empty, relink him to top of his chain. 1817ccd979bdSMark Fasheh * 1818ccd979bdSMark Fasheh * We've read 0 extra blocks and only send one more to 1819ccd979bdSMark Fasheh * the transaction, yet the next guy to search has a 1820ccd979bdSMark Fasheh * much easier time. 1821ccd979bdSMark Fasheh * 1822ccd979bdSMark Fasheh * Do this *after* figuring out how many bits we're taking out 1823ccd979bdSMark Fasheh * of our target group. 1824ccd979bdSMark Fasheh */ 1825309a85b6SXiaowei.Hu if (!ac->ac_disable_chain_relink && 1826ccd979bdSMark Fasheh (prev_group_bh) && 18277d1fe093SJoel Becker (ocfs2_block_group_reasonably_empty(bg, res->sr_bits))) { 1828ccd979bdSMark Fasheh status = ocfs2_relink_block_group(handle, alloc_inode, 1829ccd979bdSMark Fasheh ac->ac_bh, group_bh, 1830ccd979bdSMark Fasheh prev_group_bh, chain); 1831ccd979bdSMark Fasheh if (status < 0) { 1832ccd979bdSMark Fasheh mlog_errno(status); 1833ccd979bdSMark Fasheh goto bail; 1834ccd979bdSMark Fasheh } 1835ccd979bdSMark Fasheh } 1836ccd979bdSMark Fasheh 1837e49e2767SMark Fasheh if (ac->ac_find_loc_only) 1838e49e2767SMark Fasheh goto out_loc_only; 1839e49e2767SMark Fasheh 1840d5134982SMark Fasheh status = ocfs2_alloc_dinode_update_counts(alloc_inode, handle, 1841d5134982SMark Fasheh ac->ac_bh, res->sr_bits, 1842d5134982SMark Fasheh chain); 1843d5134982SMark Fasheh if (status) { 1844ccd979bdSMark Fasheh mlog_errno(status); 1845ccd979bdSMark Fasheh goto bail; 1846ccd979bdSMark Fasheh } 1847ccd979bdSMark Fasheh 1848ccd979bdSMark Fasheh status = ocfs2_block_group_set_bits(handle, 1849ccd979bdSMark Fasheh alloc_inode, 1850ccd979bdSMark Fasheh bg, 1851ccd979bdSMark Fasheh group_bh, 18527d1fe093SJoel Becker res->sr_bit_offset, 18537d1fe093SJoel Becker res->sr_bits); 1854ccd979bdSMark Fasheh if (status < 0) { 1855db66c715SYounger Liu ocfs2_rollback_alloc_dinode_counts(alloc_inode, 1856db66c715SYounger Liu ac->ac_bh, res->sr_bits, chain); 1857ccd979bdSMark Fasheh mlog_errno(status); 1858ccd979bdSMark Fasheh goto bail; 1859ccd979bdSMark Fasheh } 1860ccd979bdSMark Fasheh 18612f73e135STao Ma trace_ocfs2_search_chain_end( 18622f73e135STao Ma (unsigned long long)le64_to_cpu(fe->i_blkno), 18632f73e135STao Ma res->sr_bits); 1864ccd979bdSMark Fasheh 1865e49e2767SMark Fasheh out_loc_only: 1866883d4caeSMark Fasheh *bits_left = le16_to_cpu(bg->bg_free_bits_count); 1867ccd979bdSMark Fasheh bail: 1868ccd979bdSMark Fasheh brelse(group_bh); 1869ccd979bdSMark Fasheh brelse(prev_group_bh); 1870ccd979bdSMark Fasheh 1871c1e8d35eSTao Ma if (status) 1872c1e8d35eSTao Ma mlog_errno(status); 1873ccd979bdSMark Fasheh return status; 1874ccd979bdSMark Fasheh } 1875ccd979bdSMark Fasheh 1876ccd979bdSMark Fasheh /* will give out up to bits_wanted contiguous bits. */ 1877aa8f8e93SJoel Becker static int ocfs2_claim_suballoc_bits(struct ocfs2_alloc_context *ac, 18781fabe148SMark Fasheh handle_t *handle, 1879ccd979bdSMark Fasheh u32 bits_wanted, 1880ccd979bdSMark Fasheh u32 min_bits, 18817d1fe093SJoel Becker struct ocfs2_suballoc_result *res) 1882ccd979bdSMark Fasheh { 1883ccd979bdSMark Fasheh int status; 1884ccd979bdSMark Fasheh u16 victim, i; 1885883d4caeSMark Fasheh u16 bits_left = 0; 1886b2b6ebf5SMark Fasheh u64 hint = ac->ac_last_group; 1887ccd979bdSMark Fasheh struct ocfs2_chain_list *cl; 1888ccd979bdSMark Fasheh struct ocfs2_dinode *fe; 1889ccd979bdSMark Fasheh 1890ccd979bdSMark Fasheh BUG_ON(ac->ac_bits_given >= ac->ac_bits_wanted); 1891ccd979bdSMark Fasheh BUG_ON(bits_wanted > (ac->ac_bits_wanted - ac->ac_bits_given)); 1892ccd979bdSMark Fasheh BUG_ON(!ac->ac_bh); 1893ccd979bdSMark Fasheh 1894ccd979bdSMark Fasheh fe = (struct ocfs2_dinode *) ac->ac_bh->b_data; 189510995aa2SJoel Becker 189610995aa2SJoel Becker /* The bh was validated by the inode read during 189710995aa2SJoel Becker * ocfs2_reserve_suballoc_bits(). Any corruption is a code bug. */ 189810995aa2SJoel Becker BUG_ON(!OCFS2_IS_VALID_DINODE(fe)); 189910995aa2SJoel Becker 1900ccd979bdSMark Fasheh if (le32_to_cpu(fe->id1.bitmap1.i_used) >= 1901ccd979bdSMark Fasheh le32_to_cpu(fe->id1.bitmap1.i_total)) { 190217a5b9abSGoldwyn Rodrigues status = ocfs2_error(ac->ac_inode->i_sb, 19037ecef14aSJoe Perches "Chain allocator dinode %llu has %u used bits but only %u total\n", 1904b0697053SMark Fasheh (unsigned long long)le64_to_cpu(fe->i_blkno), 1905ccd979bdSMark Fasheh le32_to_cpu(fe->id1.bitmap1.i_used), 1906ccd979bdSMark Fasheh le32_to_cpu(fe->id1.bitmap1.i_total)); 1907ccd979bdSMark Fasheh goto bail; 1908ccd979bdSMark Fasheh } 1909ccd979bdSMark Fasheh 1910b2b6ebf5SMark Fasheh res->sr_bg_blkno = hint; 19117d1fe093SJoel Becker if (res->sr_bg_blkno) { 1912883d4caeSMark Fasheh /* Attempt to short-circuit the usual search mechanism 1913883d4caeSMark Fasheh * by jumping straight to the most recently used 1914b595076aSUwe Kleine-König * allocation group. This helps us maintain some 1915883d4caeSMark Fasheh * contiguousness across allocations. */ 1916da5cbf2fSMark Fasheh status = ocfs2_search_one_group(ac, handle, bits_wanted, 19177d1fe093SJoel Becker min_bits, res, &bits_left); 19187d1fe093SJoel Becker if (!status) 1919883d4caeSMark Fasheh goto set_hint; 1920883d4caeSMark Fasheh if (status < 0 && status != -ENOSPC) { 1921883d4caeSMark Fasheh mlog_errno(status); 1922883d4caeSMark Fasheh goto bail; 1923883d4caeSMark Fasheh } 1924883d4caeSMark Fasheh } 1925883d4caeSMark Fasheh 1926ccd979bdSMark Fasheh cl = (struct ocfs2_chain_list *) &fe->id2.i_chain; 1927ccd979bdSMark Fasheh 1928ccd979bdSMark Fasheh victim = ocfs2_find_victim_chain(cl); 1929ccd979bdSMark Fasheh ac->ac_chain = victim; 1930ccd979bdSMark Fasheh 19317d1fe093SJoel Becker status = ocfs2_search_chain(ac, handle, bits_wanted, min_bits, 19327d1fe093SJoel Becker res, &bits_left); 1933b2b6ebf5SMark Fasheh if (!status) { 19341d1aff8cSJoseph Qi if (ocfs2_is_cluster_bitmap(ac->ac_inode)) 19351d1aff8cSJoseph Qi hint = res->sr_bg_blkno; 19361d1aff8cSJoseph Qi else 1937b2b6ebf5SMark Fasheh hint = ocfs2_group_from_res(res); 1938883d4caeSMark Fasheh goto set_hint; 1939b2b6ebf5SMark Fasheh } 1940ccd979bdSMark Fasheh if (status < 0 && status != -ENOSPC) { 1941ccd979bdSMark Fasheh mlog_errno(status); 1942ccd979bdSMark Fasheh goto bail; 1943ccd979bdSMark Fasheh } 1944ccd979bdSMark Fasheh 19452f73e135STao Ma trace_ocfs2_claim_suballoc_bits(victim); 1946ccd979bdSMark Fasheh 1947ccd979bdSMark Fasheh /* If we didn't pick a good victim, then just default to 1948ccd979bdSMark Fasheh * searching each chain in order. Don't allow chain relinking 1949ccd979bdSMark Fasheh * because we only calculate enough journal credits for one 1950ccd979bdSMark Fasheh * relink per alloc. */ 1951309a85b6SXiaowei.Hu ac->ac_disable_chain_relink = 1; 1952ccd979bdSMark Fasheh for (i = 0; i < le16_to_cpu(cl->cl_next_free_rec); i ++) { 1953ccd979bdSMark Fasheh if (i == victim) 1954ccd979bdSMark Fasheh continue; 1955ccd979bdSMark Fasheh if (!cl->cl_recs[i].c_free) 1956ccd979bdSMark Fasheh continue; 1957ccd979bdSMark Fasheh 1958ccd979bdSMark Fasheh ac->ac_chain = i; 1959da5cbf2fSMark Fasheh status = ocfs2_search_chain(ac, handle, bits_wanted, min_bits, 19607d1fe093SJoel Becker res, &bits_left); 1961b2b6ebf5SMark Fasheh if (!status) { 1962b2b6ebf5SMark Fasheh hint = ocfs2_group_from_res(res); 1963ccd979bdSMark Fasheh break; 1964b2b6ebf5SMark Fasheh } 1965ccd979bdSMark Fasheh if (status < 0 && status != -ENOSPC) { 1966ccd979bdSMark Fasheh mlog_errno(status); 1967ccd979bdSMark Fasheh goto bail; 1968ccd979bdSMark Fasheh } 1969ccd979bdSMark Fasheh } 1970ccd979bdSMark Fasheh 1971883d4caeSMark Fasheh set_hint: 1972883d4caeSMark Fasheh if (status != -ENOSPC) { 1973883d4caeSMark Fasheh /* If the next search of this group is not likely to 1974883d4caeSMark Fasheh * yield a suitable extent, then we reset the last 1975883d4caeSMark Fasheh * group hint so as to not waste a disk read */ 1976883d4caeSMark Fasheh if (bits_left < min_bits) 1977883d4caeSMark Fasheh ac->ac_last_group = 0; 1978883d4caeSMark Fasheh else 1979b2b6ebf5SMark Fasheh ac->ac_last_group = hint; 1980883d4caeSMark Fasheh } 1981883d4caeSMark Fasheh 1982883d4caeSMark Fasheh bail: 1983c1e8d35eSTao Ma if (status) 1984c1e8d35eSTao Ma mlog_errno(status); 1985ccd979bdSMark Fasheh return status; 1986ccd979bdSMark Fasheh } 1987ccd979bdSMark Fasheh 19881ed9b777SJoel Becker int ocfs2_claim_metadata(handle_t *handle, 1989ccd979bdSMark Fasheh struct ocfs2_alloc_context *ac, 1990ccd979bdSMark Fasheh u32 bits_wanted, 19912b6cb576SJoel Becker u64 *suballoc_loc, 1992ccd979bdSMark Fasheh u16 *suballoc_bit_start, 1993ccd979bdSMark Fasheh unsigned int *num_bits, 1994ccd979bdSMark Fasheh u64 *blkno_start) 1995ccd979bdSMark Fasheh { 1996ccd979bdSMark Fasheh int status; 1997ba206635SJoel Becker struct ocfs2_suballoc_result res = { .sr_blkno = 0, }; 1998ccd979bdSMark Fasheh 1999ccd979bdSMark Fasheh BUG_ON(!ac); 2000ccd979bdSMark Fasheh BUG_ON(ac->ac_bits_wanted < (ac->ac_bits_given + bits_wanted)); 2001ccd979bdSMark Fasheh BUG_ON(ac->ac_which != OCFS2_AC_USE_META); 2002ccd979bdSMark Fasheh 2003aa8f8e93SJoel Becker status = ocfs2_claim_suballoc_bits(ac, 2004da5cbf2fSMark Fasheh handle, 2005ccd979bdSMark Fasheh bits_wanted, 2006ccd979bdSMark Fasheh 1, 20077d1fe093SJoel Becker &res); 2008ccd979bdSMark Fasheh if (status < 0) { 2009ccd979bdSMark Fasheh mlog_errno(status); 2010ccd979bdSMark Fasheh goto bail; 2011ccd979bdSMark Fasheh } 20121ed9b777SJoel Becker atomic_inc(&OCFS2_SB(ac->ac_inode->i_sb)->alloc_stats.bg_allocs); 2013ccd979bdSMark Fasheh 20142b6cb576SJoel Becker *suballoc_loc = res.sr_bg_blkno; 20157d1fe093SJoel Becker *suballoc_bit_start = res.sr_bit_offset; 2016ba206635SJoel Becker *blkno_start = res.sr_blkno; 20177d1fe093SJoel Becker ac->ac_bits_given += res.sr_bits; 20187d1fe093SJoel Becker *num_bits = res.sr_bits; 2019ccd979bdSMark Fasheh status = 0; 2020ccd979bdSMark Fasheh bail: 2021c1e8d35eSTao Ma if (status) 2022c1e8d35eSTao Ma mlog_errno(status); 2023ccd979bdSMark Fasheh return status; 2024ccd979bdSMark Fasheh } 2025ccd979bdSMark Fasheh 202613821151STao Ma static void ocfs2_init_inode_ac_group(struct inode *dir, 2027abf1b3cbSTao Ma struct buffer_head *parent_di_bh, 202813821151STao Ma struct ocfs2_alloc_context *ac) 202913821151STao Ma { 2030abf1b3cbSTao Ma struct ocfs2_dinode *di = (struct ocfs2_dinode *)parent_di_bh->b_data; 203113821151STao Ma /* 203213821151STao Ma * Try to allocate inodes from some specific group. 203313821151STao Ma * 203413821151STao Ma * If the parent dir has recorded the last group used in allocation, 203513821151STao Ma * cool, use it. Otherwise if we try to allocate new inode from the 203613821151STao Ma * same slot the parent dir belongs to, use the same chunk. 203713821151STao Ma * 203813821151STao Ma * We are very careful here to avoid the mistake of setting 203913821151STao Ma * ac_last_group to a group descriptor from a different (unlocked) slot. 204013821151STao Ma */ 204113821151STao Ma if (OCFS2_I(dir)->ip_last_used_group && 204213821151STao Ma OCFS2_I(dir)->ip_last_used_slot == ac->ac_alloc_slot) 204313821151STao Ma ac->ac_last_group = OCFS2_I(dir)->ip_last_used_group; 2044abf1b3cbSTao Ma else if (le16_to_cpu(di->i_suballoc_slot) == ac->ac_alloc_slot) { 2045abf1b3cbSTao Ma if (di->i_suballoc_loc) 2046abf1b3cbSTao Ma ac->ac_last_group = le64_to_cpu(di->i_suballoc_loc); 2047abf1b3cbSTao Ma else 204813821151STao Ma ac->ac_last_group = ocfs2_which_suballoc_group( 2049abf1b3cbSTao Ma le64_to_cpu(di->i_blkno), 2050abf1b3cbSTao Ma le16_to_cpu(di->i_suballoc_bit)); 2051abf1b3cbSTao Ma } 205213821151STao Ma } 205313821151STao Ma 205413821151STao Ma static inline void ocfs2_save_inode_ac_group(struct inode *dir, 205513821151STao Ma struct ocfs2_alloc_context *ac) 205613821151STao Ma { 205713821151STao Ma OCFS2_I(dir)->ip_last_used_group = ac->ac_last_group; 205813821151STao Ma OCFS2_I(dir)->ip_last_used_slot = ac->ac_alloc_slot; 205913821151STao Ma } 206013821151STao Ma 2061e49e2767SMark Fasheh int ocfs2_find_new_inode_loc(struct inode *dir, 2062e49e2767SMark Fasheh struct buffer_head *parent_fe_bh, 2063e49e2767SMark Fasheh struct ocfs2_alloc_context *ac, 2064e49e2767SMark Fasheh u64 *fe_blkno) 2065e49e2767SMark Fasheh { 2066e49e2767SMark Fasheh int ret; 2067e49e2767SMark Fasheh handle_t *handle = NULL; 2068e49e2767SMark Fasheh struct ocfs2_suballoc_result *res; 2069e49e2767SMark Fasheh 2070e49e2767SMark Fasheh BUG_ON(!ac); 2071e49e2767SMark Fasheh BUG_ON(ac->ac_bits_given != 0); 2072e49e2767SMark Fasheh BUG_ON(ac->ac_bits_wanted != 1); 2073e49e2767SMark Fasheh BUG_ON(ac->ac_which != OCFS2_AC_USE_INODE); 2074e49e2767SMark Fasheh 2075e49e2767SMark Fasheh res = kzalloc(sizeof(*res), GFP_NOFS); 2076e49e2767SMark Fasheh if (res == NULL) { 2077e49e2767SMark Fasheh ret = -ENOMEM; 2078e49e2767SMark Fasheh mlog_errno(ret); 2079e49e2767SMark Fasheh goto out; 2080e49e2767SMark Fasheh } 2081e49e2767SMark Fasheh 2082e49e2767SMark Fasheh ocfs2_init_inode_ac_group(dir, parent_fe_bh, ac); 2083e49e2767SMark Fasheh 2084e49e2767SMark Fasheh /* 2085e49e2767SMark Fasheh * The handle started here is for chain relink. Alternatively, 2086e49e2767SMark Fasheh * we could just disable relink for these calls. 2087e49e2767SMark Fasheh */ 2088e49e2767SMark Fasheh handle = ocfs2_start_trans(OCFS2_SB(dir->i_sb), OCFS2_SUBALLOC_ALLOC); 2089e49e2767SMark Fasheh if (IS_ERR(handle)) { 2090e49e2767SMark Fasheh ret = PTR_ERR(handle); 2091e49e2767SMark Fasheh handle = NULL; 2092e49e2767SMark Fasheh mlog_errno(ret); 2093e49e2767SMark Fasheh goto out; 2094e49e2767SMark Fasheh } 2095e49e2767SMark Fasheh 2096e49e2767SMark Fasheh /* 2097e49e2767SMark Fasheh * This will instruct ocfs2_claim_suballoc_bits and 2098e49e2767SMark Fasheh * ocfs2_search_one_group to search but save actual allocation 2099e49e2767SMark Fasheh * for later. 2100e49e2767SMark Fasheh */ 2101e49e2767SMark Fasheh ac->ac_find_loc_only = 1; 2102e49e2767SMark Fasheh 2103e49e2767SMark Fasheh ret = ocfs2_claim_suballoc_bits(ac, handle, 1, 1, res); 2104e49e2767SMark Fasheh if (ret < 0) { 2105e49e2767SMark Fasheh mlog_errno(ret); 2106e49e2767SMark Fasheh goto out; 2107e49e2767SMark Fasheh } 2108e49e2767SMark Fasheh 2109e49e2767SMark Fasheh ac->ac_find_loc_priv = res; 2110e49e2767SMark Fasheh *fe_blkno = res->sr_blkno; 21116fdb702dSDarrick J. Wong ocfs2_update_inode_fsync_trans(handle, dir, 0); 2112e49e2767SMark Fasheh out: 2113e49e2767SMark Fasheh if (handle) 2114e49e2767SMark Fasheh ocfs2_commit_trans(OCFS2_SB(dir->i_sb), handle); 2115e49e2767SMark Fasheh 2116e49e2767SMark Fasheh if (ret) 2117e49e2767SMark Fasheh kfree(res); 2118e49e2767SMark Fasheh 2119e49e2767SMark Fasheh return ret; 2120e49e2767SMark Fasheh } 2121e49e2767SMark Fasheh 2122e49e2767SMark Fasheh int ocfs2_claim_new_inode_at_loc(handle_t *handle, 2123e49e2767SMark Fasheh struct inode *dir, 2124e49e2767SMark Fasheh struct ocfs2_alloc_context *ac, 2125e49e2767SMark Fasheh u64 *suballoc_loc, 2126e49e2767SMark Fasheh u16 *suballoc_bit, 2127e49e2767SMark Fasheh u64 di_blkno) 2128e49e2767SMark Fasheh { 2129e49e2767SMark Fasheh int ret; 2130e49e2767SMark Fasheh u16 chain; 2131e49e2767SMark Fasheh struct ocfs2_suballoc_result *res = ac->ac_find_loc_priv; 2132e49e2767SMark Fasheh struct buffer_head *bg_bh = NULL; 2133e49e2767SMark Fasheh struct ocfs2_group_desc *bg; 2134e49e2767SMark Fasheh struct ocfs2_dinode *di = (struct ocfs2_dinode *) ac->ac_bh->b_data; 2135e49e2767SMark Fasheh 2136e49e2767SMark Fasheh /* 2137e49e2767SMark Fasheh * Since di_blkno is being passed back in, we check for any 2138e49e2767SMark Fasheh * inconsistencies which may have happened between 2139e49e2767SMark Fasheh * calls. These are code bugs as di_blkno is not expected to 2140e49e2767SMark Fasheh * change once returned from ocfs2_find_new_inode_loc() 2141e49e2767SMark Fasheh */ 2142e49e2767SMark Fasheh BUG_ON(res->sr_blkno != di_blkno); 2143e49e2767SMark Fasheh 2144e49e2767SMark Fasheh ret = ocfs2_read_group_descriptor(ac->ac_inode, di, 2145e49e2767SMark Fasheh res->sr_bg_stable_blkno, &bg_bh); 2146e49e2767SMark Fasheh if (ret) { 2147e49e2767SMark Fasheh mlog_errno(ret); 2148e49e2767SMark Fasheh goto out; 2149e49e2767SMark Fasheh } 2150e49e2767SMark Fasheh 2151e49e2767SMark Fasheh bg = (struct ocfs2_group_desc *) bg_bh->b_data; 2152e49e2767SMark Fasheh chain = le16_to_cpu(bg->bg_chain); 2153e49e2767SMark Fasheh 2154e49e2767SMark Fasheh ret = ocfs2_alloc_dinode_update_counts(ac->ac_inode, handle, 2155e49e2767SMark Fasheh ac->ac_bh, res->sr_bits, 2156e49e2767SMark Fasheh chain); 2157e49e2767SMark Fasheh if (ret) { 2158e49e2767SMark Fasheh mlog_errno(ret); 2159e49e2767SMark Fasheh goto out; 2160e49e2767SMark Fasheh } 2161e49e2767SMark Fasheh 2162e49e2767SMark Fasheh ret = ocfs2_block_group_set_bits(handle, 2163e49e2767SMark Fasheh ac->ac_inode, 2164e49e2767SMark Fasheh bg, 2165e49e2767SMark Fasheh bg_bh, 2166e49e2767SMark Fasheh res->sr_bit_offset, 2167e49e2767SMark Fasheh res->sr_bits); 2168e49e2767SMark Fasheh if (ret < 0) { 2169db66c715SYounger Liu ocfs2_rollback_alloc_dinode_counts(ac->ac_inode, 2170db66c715SYounger Liu ac->ac_bh, res->sr_bits, chain); 2171e49e2767SMark Fasheh mlog_errno(ret); 2172e49e2767SMark Fasheh goto out; 2173e49e2767SMark Fasheh } 2174e49e2767SMark Fasheh 21752f73e135STao Ma trace_ocfs2_claim_new_inode_at_loc((unsigned long long)di_blkno, 21762f73e135STao Ma res->sr_bits); 2177e49e2767SMark Fasheh 2178e49e2767SMark Fasheh atomic_inc(&OCFS2_SB(ac->ac_inode->i_sb)->alloc_stats.bg_allocs); 2179e49e2767SMark Fasheh 2180e49e2767SMark Fasheh BUG_ON(res->sr_bits != 1); 2181e49e2767SMark Fasheh 2182e49e2767SMark Fasheh *suballoc_loc = res->sr_bg_blkno; 2183e49e2767SMark Fasheh *suballoc_bit = res->sr_bit_offset; 2184e49e2767SMark Fasheh ac->ac_bits_given++; 2185e49e2767SMark Fasheh ocfs2_save_inode_ac_group(dir, ac); 2186e49e2767SMark Fasheh 2187e49e2767SMark Fasheh out: 2188e49e2767SMark Fasheh brelse(bg_bh); 2189e49e2767SMark Fasheh 2190e49e2767SMark Fasheh return ret; 2191e49e2767SMark Fasheh } 2192e49e2767SMark Fasheh 21931ed9b777SJoel Becker int ocfs2_claim_new_inode(handle_t *handle, 219413821151STao Ma struct inode *dir, 219513821151STao Ma struct buffer_head *parent_fe_bh, 2196ccd979bdSMark Fasheh struct ocfs2_alloc_context *ac, 21972b6cb576SJoel Becker u64 *suballoc_loc, 2198ccd979bdSMark Fasheh u16 *suballoc_bit, 2199ccd979bdSMark Fasheh u64 *fe_blkno) 2200ccd979bdSMark Fasheh { 2201ccd979bdSMark Fasheh int status; 22022b6cb576SJoel Becker struct ocfs2_suballoc_result res; 2203ccd979bdSMark Fasheh 2204ccd979bdSMark Fasheh BUG_ON(!ac); 2205ccd979bdSMark Fasheh BUG_ON(ac->ac_bits_given != 0); 2206ccd979bdSMark Fasheh BUG_ON(ac->ac_bits_wanted != 1); 2207ccd979bdSMark Fasheh BUG_ON(ac->ac_which != OCFS2_AC_USE_INODE); 2208ccd979bdSMark Fasheh 220913821151STao Ma ocfs2_init_inode_ac_group(dir, parent_fe_bh, ac); 221013821151STao Ma 2211aa8f8e93SJoel Becker status = ocfs2_claim_suballoc_bits(ac, 2212da5cbf2fSMark Fasheh handle, 2213ccd979bdSMark Fasheh 1, 2214ccd979bdSMark Fasheh 1, 22157d1fe093SJoel Becker &res); 2216ccd979bdSMark Fasheh if (status < 0) { 2217ccd979bdSMark Fasheh mlog_errno(status); 2218ccd979bdSMark Fasheh goto bail; 2219ccd979bdSMark Fasheh } 22201ed9b777SJoel Becker atomic_inc(&OCFS2_SB(ac->ac_inode->i_sb)->alloc_stats.bg_allocs); 2221ccd979bdSMark Fasheh 22227d1fe093SJoel Becker BUG_ON(res.sr_bits != 1); 2223ccd979bdSMark Fasheh 22242b6cb576SJoel Becker *suballoc_loc = res.sr_bg_blkno; 22257d1fe093SJoel Becker *suballoc_bit = res.sr_bit_offset; 2226ba206635SJoel Becker *fe_blkno = res.sr_blkno; 2227ccd979bdSMark Fasheh ac->ac_bits_given++; 222813821151STao Ma ocfs2_save_inode_ac_group(dir, ac); 2229ccd979bdSMark Fasheh status = 0; 2230ccd979bdSMark Fasheh bail: 2231c1e8d35eSTao Ma if (status) 2232c1e8d35eSTao Ma mlog_errno(status); 2233ccd979bdSMark Fasheh return status; 2234ccd979bdSMark Fasheh } 2235ccd979bdSMark Fasheh 2236ccd979bdSMark Fasheh /* translate a group desc. blkno and it's bitmap offset into 2237ccd979bdSMark Fasheh * disk cluster offset. */ 2238ccd979bdSMark Fasheh static inline u32 ocfs2_desc_bitmap_to_cluster_off(struct inode *inode, 2239ccd979bdSMark Fasheh u64 bg_blkno, 2240ccd979bdSMark Fasheh u16 bg_bit_off) 2241ccd979bdSMark Fasheh { 2242ccd979bdSMark Fasheh struct ocfs2_super *osb = OCFS2_SB(inode->i_sb); 2243ccd979bdSMark Fasheh u32 cluster = 0; 2244ccd979bdSMark Fasheh 2245ccd979bdSMark Fasheh BUG_ON(!ocfs2_is_cluster_bitmap(inode)); 2246ccd979bdSMark Fasheh 2247ccd979bdSMark Fasheh if (bg_blkno != osb->first_cluster_group_blkno) 2248ccd979bdSMark Fasheh cluster = ocfs2_blocks_to_clusters(inode->i_sb, bg_blkno); 2249ccd979bdSMark Fasheh cluster += (u32) bg_bit_off; 2250ccd979bdSMark Fasheh return cluster; 2251ccd979bdSMark Fasheh } 2252ccd979bdSMark Fasheh 2253ccd979bdSMark Fasheh /* given a cluster offset, calculate which block group it belongs to 2254ccd979bdSMark Fasheh * and return that block offset. */ 2255d659072fSTao Ma u64 ocfs2_which_cluster_group(struct inode *inode, u32 cluster) 2256ccd979bdSMark Fasheh { 2257ccd979bdSMark Fasheh struct ocfs2_super *osb = OCFS2_SB(inode->i_sb); 2258ccd979bdSMark Fasheh u32 group_no; 2259ccd979bdSMark Fasheh 2260ccd979bdSMark Fasheh BUG_ON(!ocfs2_is_cluster_bitmap(inode)); 2261ccd979bdSMark Fasheh 2262ccd979bdSMark Fasheh group_no = cluster / osb->bitmap_cpg; 2263ccd979bdSMark Fasheh if (!group_no) 2264ccd979bdSMark Fasheh return osb->first_cluster_group_blkno; 2265ccd979bdSMark Fasheh return ocfs2_clusters_to_blocks(inode->i_sb, 2266ccd979bdSMark Fasheh group_no * osb->bitmap_cpg); 2267ccd979bdSMark Fasheh } 2268ccd979bdSMark Fasheh 2269ccd979bdSMark Fasheh /* given the block number of a cluster start, calculate which cluster 2270ccd979bdSMark Fasheh * group and descriptor bitmap offset that corresponds to. */ 2271ccd979bdSMark Fasheh static inline void ocfs2_block_to_cluster_group(struct inode *inode, 2272ccd979bdSMark Fasheh u64 data_blkno, 2273ccd979bdSMark Fasheh u64 *bg_blkno, 2274ccd979bdSMark Fasheh u16 *bg_bit_off) 2275ccd979bdSMark Fasheh { 2276ccd979bdSMark Fasheh struct ocfs2_super *osb = OCFS2_SB(inode->i_sb); 2277ccd979bdSMark Fasheh u32 data_cluster = ocfs2_blocks_to_clusters(osb->sb, data_blkno); 2278ccd979bdSMark Fasheh 2279ccd979bdSMark Fasheh BUG_ON(!ocfs2_is_cluster_bitmap(inode)); 2280ccd979bdSMark Fasheh 2281ccd979bdSMark Fasheh *bg_blkno = ocfs2_which_cluster_group(inode, 2282ccd979bdSMark Fasheh data_cluster); 2283ccd979bdSMark Fasheh 2284ccd979bdSMark Fasheh if (*bg_blkno == osb->first_cluster_group_blkno) 2285ccd979bdSMark Fasheh *bg_bit_off = (u16) data_cluster; 2286ccd979bdSMark Fasheh else 2287ccd979bdSMark Fasheh *bg_bit_off = (u16) ocfs2_blocks_to_clusters(osb->sb, 2288ccd979bdSMark Fasheh data_blkno - *bg_blkno); 2289ccd979bdSMark Fasheh } 2290ccd979bdSMark Fasheh 2291ccd979bdSMark Fasheh /* 2292ccd979bdSMark Fasheh * min_bits - minimum contiguous chunk from this total allocation we 2293ccd979bdSMark Fasheh * can handle. set to what we asked for originally for a full 2294ccd979bdSMark Fasheh * contig. allocation, set to '1' to indicate we can deal with extents 2295ccd979bdSMark Fasheh * of any size. 2296ccd979bdSMark Fasheh */ 22971ed9b777SJoel Becker int __ocfs2_claim_clusters(handle_t *handle, 2298ccd979bdSMark Fasheh struct ocfs2_alloc_context *ac, 2299ccd979bdSMark Fasheh u32 min_clusters, 2300415cb800SMark Fasheh u32 max_clusters, 2301ccd979bdSMark Fasheh u32 *cluster_start, 2302ccd979bdSMark Fasheh u32 *num_clusters) 2303ccd979bdSMark Fasheh { 2304ccd979bdSMark Fasheh int status; 2305415cb800SMark Fasheh unsigned int bits_wanted = max_clusters; 2306ba206635SJoel Becker struct ocfs2_suballoc_result res = { .sr_blkno = 0, }; 23071ed9b777SJoel Becker struct ocfs2_super *osb = OCFS2_SB(ac->ac_inode->i_sb); 2308ccd979bdSMark Fasheh 2309ccd979bdSMark Fasheh BUG_ON(ac->ac_bits_given >= ac->ac_bits_wanted); 2310ccd979bdSMark Fasheh 2311ccd979bdSMark Fasheh BUG_ON(ac->ac_which != OCFS2_AC_USE_LOCAL 2312ccd979bdSMark Fasheh && ac->ac_which != OCFS2_AC_USE_MAIN); 2313ccd979bdSMark Fasheh 2314ccd979bdSMark Fasheh if (ac->ac_which == OCFS2_AC_USE_LOCAL) { 231533d5d380SMark Fasheh WARN_ON(min_clusters > 1); 231633d5d380SMark Fasheh 2317ccd979bdSMark Fasheh status = ocfs2_claim_local_alloc_bits(osb, 2318ccd979bdSMark Fasheh handle, 2319ccd979bdSMark Fasheh ac, 2320ccd979bdSMark Fasheh bits_wanted, 2321ccd979bdSMark Fasheh cluster_start, 2322ccd979bdSMark Fasheh num_clusters); 2323ccd979bdSMark Fasheh if (!status) 2324ccd979bdSMark Fasheh atomic_inc(&osb->alloc_stats.local_data); 2325ccd979bdSMark Fasheh } else { 2326ccd979bdSMark Fasheh if (min_clusters > (osb->bitmap_cpg - 1)) { 2327ccd979bdSMark Fasheh /* The only paths asking for contiguousness 2328ccd979bdSMark Fasheh * should know about this already. */ 23292fbe8d1eSSunil Mushran mlog(ML_ERROR, "minimum allocation requested %u exceeds " 23302fbe8d1eSSunil Mushran "group bitmap size %u!\n", min_clusters, 23312fbe8d1eSSunil Mushran osb->bitmap_cpg); 2332ccd979bdSMark Fasheh status = -ENOSPC; 2333ccd979bdSMark Fasheh goto bail; 2334ccd979bdSMark Fasheh } 2335ccd979bdSMark Fasheh /* clamp the current request down to a realistic size. */ 2336ccd979bdSMark Fasheh if (bits_wanted > (osb->bitmap_cpg - 1)) 2337ccd979bdSMark Fasheh bits_wanted = osb->bitmap_cpg - 1; 2338ccd979bdSMark Fasheh 2339aa8f8e93SJoel Becker status = ocfs2_claim_suballoc_bits(ac, 2340da5cbf2fSMark Fasheh handle, 2341ccd979bdSMark Fasheh bits_wanted, 2342ccd979bdSMark Fasheh min_clusters, 23437d1fe093SJoel Becker &res); 2344ccd979bdSMark Fasheh if (!status) { 2345ba206635SJoel Becker BUG_ON(res.sr_blkno); /* cluster alloc can't set */ 2346ccd979bdSMark Fasheh *cluster_start = 2347ccd979bdSMark Fasheh ocfs2_desc_bitmap_to_cluster_off(ac->ac_inode, 23487d1fe093SJoel Becker res.sr_bg_blkno, 23497d1fe093SJoel Becker res.sr_bit_offset); 2350ccd979bdSMark Fasheh atomic_inc(&osb->alloc_stats.bitmap_data); 23514711954eSTao Ma *num_clusters = res.sr_bits; 2352ccd979bdSMark Fasheh } 2353ccd979bdSMark Fasheh } 2354ccd979bdSMark Fasheh if (status < 0) { 2355ccd979bdSMark Fasheh if (status != -ENOSPC) 2356ccd979bdSMark Fasheh mlog_errno(status); 2357ccd979bdSMark Fasheh goto bail; 2358ccd979bdSMark Fasheh } 2359ccd979bdSMark Fasheh 23604711954eSTao Ma ac->ac_bits_given += *num_clusters; 2361ccd979bdSMark Fasheh 2362ccd979bdSMark Fasheh bail: 2363c1e8d35eSTao Ma if (status) 2364c1e8d35eSTao Ma mlog_errno(status); 2365ccd979bdSMark Fasheh return status; 2366ccd979bdSMark Fasheh } 2367ccd979bdSMark Fasheh 23681ed9b777SJoel Becker int ocfs2_claim_clusters(handle_t *handle, 2369415cb800SMark Fasheh struct ocfs2_alloc_context *ac, 2370415cb800SMark Fasheh u32 min_clusters, 2371415cb800SMark Fasheh u32 *cluster_start, 2372415cb800SMark Fasheh u32 *num_clusters) 2373415cb800SMark Fasheh { 2374415cb800SMark Fasheh unsigned int bits_wanted = ac->ac_bits_wanted - ac->ac_bits_given; 2375415cb800SMark Fasheh 23761ed9b777SJoel Becker return __ocfs2_claim_clusters(handle, ac, min_clusters, 2377415cb800SMark Fasheh bits_wanted, cluster_start, num_clusters); 2378415cb800SMark Fasheh } 2379415cb800SMark Fasheh 2380b4414eeaSMark Fasheh static int ocfs2_block_group_clear_bits(handle_t *handle, 2381ccd979bdSMark Fasheh struct inode *alloc_inode, 2382ccd979bdSMark Fasheh struct ocfs2_group_desc *bg, 2383ccd979bdSMark Fasheh struct buffer_head *group_bh, 2384ccd979bdSMark Fasheh unsigned int bit_off, 2385b4414eeaSMark Fasheh unsigned int num_bits, 2386b4414eeaSMark Fasheh void (*undo_fn)(unsigned int bit, 2387b4414eeaSMark Fasheh unsigned long *bmap)) 2388ccd979bdSMark Fasheh { 2389ccd979bdSMark Fasheh int status; 2390ccd979bdSMark Fasheh unsigned int tmp; 2391ccd979bdSMark Fasheh struct ocfs2_group_desc *undo_bg = NULL; 239246417064SThomas Gleixner struct journal_head *jh; 2393ccd979bdSMark Fasheh 239442035306SJoel Becker /* The caller got this descriptor from 239542035306SJoel Becker * ocfs2_read_group_descriptor(). Any corruption is a code bug. */ 239642035306SJoel Becker BUG_ON(!OCFS2_IS_VALID_GROUP_DESC(bg)); 2397ccd979bdSMark Fasheh 23982f73e135STao Ma trace_ocfs2_block_group_clear_bits(bit_off, num_bits); 2399ccd979bdSMark Fasheh 2400b4414eeaSMark Fasheh BUG_ON(undo_fn && !ocfs2_is_cluster_bitmap(alloc_inode)); 24010cf2f763SJoel Becker status = ocfs2_journal_access_gd(handle, INODE_CACHE(alloc_inode), 2402b4414eeaSMark Fasheh group_bh, 2403b4414eeaSMark Fasheh undo_fn ? 2404b4414eeaSMark Fasheh OCFS2_JOURNAL_ACCESS_UNDO : 2405b4414eeaSMark Fasheh OCFS2_JOURNAL_ACCESS_WRITE); 2406ccd979bdSMark Fasheh if (status < 0) { 2407ccd979bdSMark Fasheh mlog_errno(status); 2408ccd979bdSMark Fasheh goto bail; 2409ccd979bdSMark Fasheh } 2410ccd979bdSMark Fasheh 241146417064SThomas Gleixner jh = bh2jh(group_bh); 2412b4414eeaSMark Fasheh if (undo_fn) { 241346417064SThomas Gleixner spin_lock(&jh->b_state_lock); 241446417064SThomas Gleixner undo_bg = (struct ocfs2_group_desc *) jh->b_committed_data; 241594e41ecfSSunil Mushran BUG_ON(!undo_bg); 241694e41ecfSSunil Mushran } 2417ccd979bdSMark Fasheh 2418ccd979bdSMark Fasheh tmp = num_bits; 2419ccd979bdSMark Fasheh while(tmp--) { 2420ccd979bdSMark Fasheh ocfs2_clear_bit((bit_off + tmp), 2421ccd979bdSMark Fasheh (unsigned long *) bg->bg_bitmap); 2422b4414eeaSMark Fasheh if (undo_fn) 2423b4414eeaSMark Fasheh undo_fn(bit_off + tmp, 2424ccd979bdSMark Fasheh (unsigned long *) undo_bg->bg_bitmap); 2425ccd979bdSMark Fasheh } 2426ccd979bdSMark Fasheh le16_add_cpu(&bg->bg_free_bits_count, num_bits); 24279b5cd10eSSrinivas Eeda if (le16_to_cpu(bg->bg_free_bits_count) > le16_to_cpu(bg->bg_bits)) { 2428e75ed71bSChangwei Ge if (undo_fn) 242946417064SThomas Gleixner spin_unlock(&jh->b_state_lock); 24307ecef14aSJoe Perches return ocfs2_error(alloc_inode->i_sb, "Group descriptor # %llu has bit count %u but claims %u are freed. num_bits %d\n", 24319b5cd10eSSrinivas Eeda (unsigned long long)le64_to_cpu(bg->bg_blkno), 24329b5cd10eSSrinivas Eeda le16_to_cpu(bg->bg_bits), 24337ecef14aSJoe Perches le16_to_cpu(bg->bg_free_bits_count), 24347ecef14aSJoe Perches num_bits); 24359b5cd10eSSrinivas Eeda } 2436ccd979bdSMark Fasheh 2437b4414eeaSMark Fasheh if (undo_fn) 243846417064SThomas Gleixner spin_unlock(&jh->b_state_lock); 243994e41ecfSSunil Mushran 2440ec20cec7SJoel Becker ocfs2_journal_dirty(handle, group_bh); 2441ccd979bdSMark Fasheh bail: 2442ccd979bdSMark Fasheh return status; 2443ccd979bdSMark Fasheh } 2444ccd979bdSMark Fasheh 2445ccd979bdSMark Fasheh /* 2446ccd979bdSMark Fasheh * expects the suballoc inode to already be locked. 2447ccd979bdSMark Fasheh */ 2448b4414eeaSMark Fasheh static int _ocfs2_free_suballoc_bits(handle_t *handle, 2449ccd979bdSMark Fasheh struct inode *alloc_inode, 2450ccd979bdSMark Fasheh struct buffer_head *alloc_bh, 2451ccd979bdSMark Fasheh unsigned int start_bit, 2452ccd979bdSMark Fasheh u64 bg_blkno, 2453b4414eeaSMark Fasheh unsigned int count, 2454b4414eeaSMark Fasheh void (*undo_fn)(unsigned int bit, 2455b4414eeaSMark Fasheh unsigned long *bitmap)) 2456ccd979bdSMark Fasheh { 2457ccd979bdSMark Fasheh int status = 0; 2458ccd979bdSMark Fasheh u32 tmp_used; 2459ccd979bdSMark Fasheh struct ocfs2_dinode *fe = (struct ocfs2_dinode *) alloc_bh->b_data; 2460ccd979bdSMark Fasheh struct ocfs2_chain_list *cl = &fe->id2.i_chain; 2461ccd979bdSMark Fasheh struct buffer_head *group_bh = NULL; 2462ccd979bdSMark Fasheh struct ocfs2_group_desc *group; 2463ccd979bdSMark Fasheh 246410995aa2SJoel Becker /* The alloc_bh comes from ocfs2_free_dinode() or 246510995aa2SJoel Becker * ocfs2_free_clusters(). The callers have all locked the 246610995aa2SJoel Becker * allocator and gotten alloc_bh from the lock call. This 246725985edcSLucas De Marchi * validates the dinode buffer. Any corruption that has happened 246810995aa2SJoel Becker * is a code bug. */ 246910995aa2SJoel Becker BUG_ON(!OCFS2_IS_VALID_DINODE(fe)); 2470ccd979bdSMark Fasheh BUG_ON((count + start_bit) > ocfs2_bits_per_group(cl)); 2471ccd979bdSMark Fasheh 24722f73e135STao Ma trace_ocfs2_free_suballoc_bits( 24732f73e135STao Ma (unsigned long long)OCFS2_I(alloc_inode)->ip_blkno, 24742f73e135STao Ma (unsigned long long)bg_blkno, 24752f73e135STao Ma start_bit, count); 2476ccd979bdSMark Fasheh 247768f64d47SJoel Becker status = ocfs2_read_group_descriptor(alloc_inode, fe, bg_blkno, 247868f64d47SJoel Becker &group_bh); 2479ccd979bdSMark Fasheh if (status < 0) { 2480ccd979bdSMark Fasheh mlog_errno(status); 2481ccd979bdSMark Fasheh goto bail; 2482ccd979bdSMark Fasheh } 2483ccd979bdSMark Fasheh group = (struct ocfs2_group_desc *) group_bh->b_data; 248468f64d47SJoel Becker 2485ccd979bdSMark Fasheh BUG_ON((count + start_bit) > le16_to_cpu(group->bg_bits)); 2486ccd979bdSMark Fasheh 2487ccd979bdSMark Fasheh status = ocfs2_block_group_clear_bits(handle, alloc_inode, 2488ccd979bdSMark Fasheh group, group_bh, 2489b4414eeaSMark Fasheh start_bit, count, undo_fn); 2490ccd979bdSMark Fasheh if (status < 0) { 2491ccd979bdSMark Fasheh mlog_errno(status); 2492ccd979bdSMark Fasheh goto bail; 2493ccd979bdSMark Fasheh } 2494ccd979bdSMark Fasheh 24950cf2f763SJoel Becker status = ocfs2_journal_access_di(handle, INODE_CACHE(alloc_inode), 24960cf2f763SJoel Becker alloc_bh, OCFS2_JOURNAL_ACCESS_WRITE); 2497ccd979bdSMark Fasheh if (status < 0) { 2498ccd979bdSMark Fasheh mlog_errno(status); 2499a47726bcSJoseph Qi ocfs2_block_group_set_bits(handle, alloc_inode, group, group_bh, 2500a47726bcSJoseph Qi start_bit, count); 2501ccd979bdSMark Fasheh goto bail; 2502ccd979bdSMark Fasheh } 2503ccd979bdSMark Fasheh 2504ccd979bdSMark Fasheh le32_add_cpu(&cl->cl_recs[le16_to_cpu(group->bg_chain)].c_free, 2505ccd979bdSMark Fasheh count); 2506ccd979bdSMark Fasheh tmp_used = le32_to_cpu(fe->id1.bitmap1.i_used); 2507ccd979bdSMark Fasheh fe->id1.bitmap1.i_used = cpu_to_le32(tmp_used - count); 2508ec20cec7SJoel Becker ocfs2_journal_dirty(handle, alloc_bh); 2509ccd979bdSMark Fasheh 2510ccd979bdSMark Fasheh bail: 2511ccd979bdSMark Fasheh brelse(group_bh); 2512ccd979bdSMark Fasheh return status; 2513ccd979bdSMark Fasheh } 2514ccd979bdSMark Fasheh 2515b4414eeaSMark Fasheh int ocfs2_free_suballoc_bits(handle_t *handle, 2516b4414eeaSMark Fasheh struct inode *alloc_inode, 2517b4414eeaSMark Fasheh struct buffer_head *alloc_bh, 2518b4414eeaSMark Fasheh unsigned int start_bit, 2519b4414eeaSMark Fasheh u64 bg_blkno, 2520b4414eeaSMark Fasheh unsigned int count) 2521b4414eeaSMark Fasheh { 2522b4414eeaSMark Fasheh return _ocfs2_free_suballoc_bits(handle, alloc_inode, alloc_bh, 2523b4414eeaSMark Fasheh start_bit, bg_blkno, count, NULL); 2524b4414eeaSMark Fasheh } 2525b4414eeaSMark Fasheh 25261fabe148SMark Fasheh int ocfs2_free_dinode(handle_t *handle, 2527ccd979bdSMark Fasheh struct inode *inode_alloc_inode, 2528ccd979bdSMark Fasheh struct buffer_head *inode_alloc_bh, 2529ccd979bdSMark Fasheh struct ocfs2_dinode *di) 2530ccd979bdSMark Fasheh { 2531ccd979bdSMark Fasheh u64 blk = le64_to_cpu(di->i_blkno); 2532ccd979bdSMark Fasheh u16 bit = le16_to_cpu(di->i_suballoc_bit); 2533ccd979bdSMark Fasheh u64 bg_blkno = ocfs2_which_suballoc_group(blk, bit); 2534ccd979bdSMark Fasheh 253574380c47STao Ma if (di->i_suballoc_loc) 253674380c47STao Ma bg_blkno = le64_to_cpu(di->i_suballoc_loc); 2537ccd979bdSMark Fasheh return ocfs2_free_suballoc_bits(handle, inode_alloc_inode, 2538ccd979bdSMark Fasheh inode_alloc_bh, bit, bg_blkno, 1); 2539ccd979bdSMark Fasheh } 2540ccd979bdSMark Fasheh 2541b4414eeaSMark Fasheh static int _ocfs2_free_clusters(handle_t *handle, 2542ccd979bdSMark Fasheh struct inode *bitmap_inode, 2543ccd979bdSMark Fasheh struct buffer_head *bitmap_bh, 2544ccd979bdSMark Fasheh u64 start_blk, 2545b4414eeaSMark Fasheh unsigned int num_clusters, 2546b4414eeaSMark Fasheh void (*undo_fn)(unsigned int bit, 2547b4414eeaSMark Fasheh unsigned long *bitmap)) 2548ccd979bdSMark Fasheh { 2549ccd979bdSMark Fasheh int status; 2550ccd979bdSMark Fasheh u16 bg_start_bit; 2551ccd979bdSMark Fasheh u64 bg_blkno; 2552ccd979bdSMark Fasheh 2553ccd979bdSMark Fasheh /* You can't ever have a contiguous set of clusters 2554ccd979bdSMark Fasheh * bigger than a block group bitmap so we never have to worry 2555ef6b689bSTao Ma * about looping on them. 2556ef6b689bSTao Ma * This is expensive. We can safely remove once this stuff has 2557ccd979bdSMark Fasheh * gotten tested really well. */ 2558dd7b5f9dSChangwei Ge BUG_ON(start_blk != ocfs2_clusters_to_blocks(bitmap_inode->i_sb, 2559dd7b5f9dSChangwei Ge ocfs2_blocks_to_clusters(bitmap_inode->i_sb, 2560dd7b5f9dSChangwei Ge start_blk))); 2561ccd979bdSMark Fasheh 2562ccd979bdSMark Fasheh 2563ccd979bdSMark Fasheh ocfs2_block_to_cluster_group(bitmap_inode, start_blk, &bg_blkno, 2564ccd979bdSMark Fasheh &bg_start_bit); 2565ccd979bdSMark Fasheh 25662f73e135STao Ma trace_ocfs2_free_clusters((unsigned long long)bg_blkno, 25672f73e135STao Ma (unsigned long long)start_blk, 25682f73e135STao Ma bg_start_bit, num_clusters); 2569ccd979bdSMark Fasheh 2570b4414eeaSMark Fasheh status = _ocfs2_free_suballoc_bits(handle, bitmap_inode, bitmap_bh, 2571ccd979bdSMark Fasheh bg_start_bit, bg_blkno, 2572b4414eeaSMark Fasheh num_clusters, undo_fn); 25739c7af40bSMark Fasheh if (status < 0) { 2574ccd979bdSMark Fasheh mlog_errno(status); 25759c7af40bSMark Fasheh goto out; 25769c7af40bSMark Fasheh } 2577ccd979bdSMark Fasheh 25789c7af40bSMark Fasheh ocfs2_local_alloc_seen_free_bits(OCFS2_SB(bitmap_inode->i_sb), 25799c7af40bSMark Fasheh num_clusters); 25809c7af40bSMark Fasheh 25819c7af40bSMark Fasheh out: 2582ccd979bdSMark Fasheh return status; 2583ccd979bdSMark Fasheh } 2584ccd979bdSMark Fasheh 2585b4414eeaSMark Fasheh int ocfs2_free_clusters(handle_t *handle, 2586b4414eeaSMark Fasheh struct inode *bitmap_inode, 2587b4414eeaSMark Fasheh struct buffer_head *bitmap_bh, 2588b4414eeaSMark Fasheh u64 start_blk, 2589b4414eeaSMark Fasheh unsigned int num_clusters) 2590b4414eeaSMark Fasheh { 2591b4414eeaSMark Fasheh return _ocfs2_free_clusters(handle, bitmap_inode, bitmap_bh, 2592b4414eeaSMark Fasheh start_blk, num_clusters, 2593b4414eeaSMark Fasheh _ocfs2_set_bit); 2594b4414eeaSMark Fasheh } 2595b4414eeaSMark Fasheh 2596b4414eeaSMark Fasheh /* 2597b4414eeaSMark Fasheh * Give never-used clusters back to the global bitmap. We don't need 2598b4414eeaSMark Fasheh * to protect these bits in the undo buffer. 2599b4414eeaSMark Fasheh */ 2600b4414eeaSMark Fasheh int ocfs2_release_clusters(handle_t *handle, 2601b4414eeaSMark Fasheh struct inode *bitmap_inode, 2602b4414eeaSMark Fasheh struct buffer_head *bitmap_bh, 2603b4414eeaSMark Fasheh u64 start_blk, 2604b4414eeaSMark Fasheh unsigned int num_clusters) 2605b4414eeaSMark Fasheh { 2606b4414eeaSMark Fasheh return _ocfs2_free_clusters(handle, bitmap_inode, bitmap_bh, 2607b4414eeaSMark Fasheh start_blk, num_clusters, 2608b4414eeaSMark Fasheh _ocfs2_clear_bit); 2609b4414eeaSMark Fasheh } 2610b4414eeaSMark Fasheh 2611e7d4cb6bSTao Ma /* 2612e7d4cb6bSTao Ma * For a given allocation, determine which allocators will need to be 2613e7d4cb6bSTao Ma * accessed, and lock them, reserving the appropriate number of bits. 2614e7d4cb6bSTao Ma * 2615e7d4cb6bSTao Ma * Sparse file systems call this from ocfs2_write_begin_nolock() 2616e7d4cb6bSTao Ma * and ocfs2_allocate_unwritten_extents(). 2617e7d4cb6bSTao Ma * 2618e7d4cb6bSTao Ma * File systems which don't support holes call this from 2619e7d4cb6bSTao Ma * ocfs2_extend_allocation(). 2620e7d4cb6bSTao Ma */ 2621f99b9b7cSJoel Becker int ocfs2_lock_allocators(struct inode *inode, 2622f99b9b7cSJoel Becker struct ocfs2_extent_tree *et, 2623e7d4cb6bSTao Ma u32 clusters_to_add, u32 extents_to_split, 2624e7d4cb6bSTao Ma struct ocfs2_alloc_context **data_ac, 2625f99b9b7cSJoel Becker struct ocfs2_alloc_context **meta_ac) 2626e7d4cb6bSTao Ma { 2627e7d4cb6bSTao Ma int ret = 0, num_free_extents; 2628e7d4cb6bSTao Ma unsigned int max_recs_needed = clusters_to_add + 2 * extents_to_split; 2629e7d4cb6bSTao Ma struct ocfs2_super *osb = OCFS2_SB(inode->i_sb); 2630e7d4cb6bSTao Ma 2631e7d4cb6bSTao Ma *meta_ac = NULL; 2632e7d4cb6bSTao Ma if (data_ac) 2633e7d4cb6bSTao Ma *data_ac = NULL; 2634e7d4cb6bSTao Ma 2635e7d4cb6bSTao Ma BUG_ON(clusters_to_add != 0 && data_ac == NULL); 2636e7d4cb6bSTao Ma 2637964f14a0SJun Piao num_free_extents = ocfs2_num_free_extents(et); 2638e7d4cb6bSTao Ma if (num_free_extents < 0) { 2639e7d4cb6bSTao Ma ret = num_free_extents; 2640e7d4cb6bSTao Ma mlog_errno(ret); 2641e7d4cb6bSTao Ma goto out; 2642e7d4cb6bSTao Ma } 2643e7d4cb6bSTao Ma 2644e7d4cb6bSTao Ma /* 2645e7d4cb6bSTao Ma * Sparse allocation file systems need to be more conservative 2646e7d4cb6bSTao Ma * with reserving room for expansion - the actual allocation 2647e7d4cb6bSTao Ma * happens while we've got a journal handle open so re-taking 2648e7d4cb6bSTao Ma * a cluster lock (because we ran out of room for another 2649e7d4cb6bSTao Ma * extent) will violate ordering rules. 2650e7d4cb6bSTao Ma * 2651e7d4cb6bSTao Ma * Most of the time we'll only be seeing this 1 cluster at a time 2652e7d4cb6bSTao Ma * anyway. 2653e7d4cb6bSTao Ma * 2654e7d4cb6bSTao Ma * Always lock for any unwritten extents - we might want to 2655e7d4cb6bSTao Ma * add blocks during a split. 2656e7d4cb6bSTao Ma */ 2657e7d4cb6bSTao Ma if (!num_free_extents || 2658e7d4cb6bSTao Ma (ocfs2_sparse_alloc(osb) && num_free_extents < max_recs_needed)) { 2659f99b9b7cSJoel Becker ret = ocfs2_reserve_new_metadata(osb, et->et_root_el, meta_ac); 2660e7d4cb6bSTao Ma if (ret < 0) { 2661e7d4cb6bSTao Ma if (ret != -ENOSPC) 2662e7d4cb6bSTao Ma mlog_errno(ret); 2663e7d4cb6bSTao Ma goto out; 2664e7d4cb6bSTao Ma } 2665e7d4cb6bSTao Ma } 2666e7d4cb6bSTao Ma 2667e7d4cb6bSTao Ma if (clusters_to_add == 0) 2668e7d4cb6bSTao Ma goto out; 2669e7d4cb6bSTao Ma 2670e7d4cb6bSTao Ma ret = ocfs2_reserve_clusters(osb, clusters_to_add, data_ac); 2671e7d4cb6bSTao Ma if (ret < 0) { 2672e7d4cb6bSTao Ma if (ret != -ENOSPC) 2673e7d4cb6bSTao Ma mlog_errno(ret); 2674e7d4cb6bSTao Ma goto out; 2675e7d4cb6bSTao Ma } 2676e7d4cb6bSTao Ma 2677e7d4cb6bSTao Ma out: 2678e7d4cb6bSTao Ma if (ret) { 2679e7d4cb6bSTao Ma if (*meta_ac) { 2680e7d4cb6bSTao Ma ocfs2_free_alloc_context(*meta_ac); 2681e7d4cb6bSTao Ma *meta_ac = NULL; 2682e7d4cb6bSTao Ma } 2683e7d4cb6bSTao Ma 2684e7d4cb6bSTao Ma /* 2685e7d4cb6bSTao Ma * We cannot have an error and a non null *data_ac. 2686e7d4cb6bSTao Ma */ 2687e7d4cb6bSTao Ma } 2688e7d4cb6bSTao Ma 2689e7d4cb6bSTao Ma return ret; 2690e7d4cb6bSTao Ma } 26916ca497a8Swengang wang 26926ca497a8Swengang wang /* 26936ca497a8Swengang wang * Read the inode specified by blkno to get suballoc_slot and 26946ca497a8Swengang wang * suballoc_bit. 26956ca497a8Swengang wang */ 26966ca497a8Swengang wang static int ocfs2_get_suballoc_slot_bit(struct ocfs2_super *osb, u64 blkno, 2697889f004aSTao Ma u16 *suballoc_slot, u64 *group_blkno, 2698889f004aSTao Ma u16 *suballoc_bit) 26996ca497a8Swengang wang { 27006ca497a8Swengang wang int status; 27016ca497a8Swengang wang struct buffer_head *inode_bh = NULL; 27026ca497a8Swengang wang struct ocfs2_dinode *inode_fe; 27036ca497a8Swengang wang 27042f73e135STao Ma trace_ocfs2_get_suballoc_slot_bit((unsigned long long)blkno); 27056ca497a8Swengang wang 27066ca497a8Swengang wang /* dirty read disk */ 27076ca497a8Swengang wang status = ocfs2_read_blocks_sync(osb, blkno, 1, &inode_bh); 27086ca497a8Swengang wang if (status < 0) { 27095b09b507SJoel Becker mlog(ML_ERROR, "read block %llu failed %d\n", 27105b09b507SJoel Becker (unsigned long long)blkno, status); 27116ca497a8Swengang wang goto bail; 27126ca497a8Swengang wang } 27136ca497a8Swengang wang 27146ca497a8Swengang wang inode_fe = (struct ocfs2_dinode *) inode_bh->b_data; 27156ca497a8Swengang wang if (!OCFS2_IS_VALID_DINODE(inode_fe)) { 27165b09b507SJoel Becker mlog(ML_ERROR, "invalid inode %llu requested\n", 27175b09b507SJoel Becker (unsigned long long)blkno); 27186ca497a8Swengang wang status = -EINVAL; 27196ca497a8Swengang wang goto bail; 27206ca497a8Swengang wang } 27216ca497a8Swengang wang 27220fba8137STao Ma if (le16_to_cpu(inode_fe->i_suballoc_slot) != (u16)OCFS2_INVALID_SLOT && 27236ca497a8Swengang wang (u32)le16_to_cpu(inode_fe->i_suballoc_slot) > osb->max_slots - 1) { 27246ca497a8Swengang wang mlog(ML_ERROR, "inode %llu has invalid suballoc slot %u\n", 27255b09b507SJoel Becker (unsigned long long)blkno, 27265b09b507SJoel Becker (u32)le16_to_cpu(inode_fe->i_suballoc_slot)); 27276ca497a8Swengang wang status = -EINVAL; 27286ca497a8Swengang wang goto bail; 27296ca497a8Swengang wang } 27306ca497a8Swengang wang 27316ca497a8Swengang wang if (suballoc_slot) 27326ca497a8Swengang wang *suballoc_slot = le16_to_cpu(inode_fe->i_suballoc_slot); 27336ca497a8Swengang wang if (suballoc_bit) 27346ca497a8Swengang wang *suballoc_bit = le16_to_cpu(inode_fe->i_suballoc_bit); 2735889f004aSTao Ma if (group_blkno) 2736889f004aSTao Ma *group_blkno = le64_to_cpu(inode_fe->i_suballoc_loc); 27376ca497a8Swengang wang 27386ca497a8Swengang wang bail: 27396ca497a8Swengang wang brelse(inode_bh); 27406ca497a8Swengang wang 2741c1e8d35eSTao Ma if (status) 2742c1e8d35eSTao Ma mlog_errno(status); 27436ca497a8Swengang wang return status; 27446ca497a8Swengang wang } 27456ca497a8Swengang wang 27466ca497a8Swengang wang /* 27476ca497a8Swengang wang * test whether bit is SET in allocator bitmap or not. on success, 0 27486ca497a8Swengang wang * is returned and *res is 1 for SET; 0 otherwise. when fails, errno 27496ca497a8Swengang wang * is returned and *res is meaningless. Call this after you have 27506ca497a8Swengang wang * cluster locked against suballoc, or you may get a result based on 27516ca497a8Swengang wang * non-up2date contents 27526ca497a8Swengang wang */ 27536ca497a8Swengang wang static int ocfs2_test_suballoc_bit(struct ocfs2_super *osb, 27546ca497a8Swengang wang struct inode *suballoc, 2755889f004aSTao Ma struct buffer_head *alloc_bh, 2756889f004aSTao Ma u64 group_blkno, u64 blkno, 27576ca497a8Swengang wang u16 bit, int *res) 27586ca497a8Swengang wang { 2759abf1b3cbSTao Ma struct ocfs2_dinode *alloc_di; 27606ca497a8Swengang wang struct ocfs2_group_desc *group; 27616ca497a8Swengang wang struct buffer_head *group_bh = NULL; 27626ca497a8Swengang wang u64 bg_blkno; 27636ca497a8Swengang wang int status; 27646ca497a8Swengang wang 27652f73e135STao Ma trace_ocfs2_test_suballoc_bit((unsigned long long)blkno, 27665b09b507SJoel Becker (unsigned int)bit); 27676ca497a8Swengang wang 2768abf1b3cbSTao Ma alloc_di = (struct ocfs2_dinode *)alloc_bh->b_data; 2769abf1b3cbSTao Ma if ((bit + 1) > ocfs2_bits_per_group(&alloc_di->id2.i_chain)) { 27706ca497a8Swengang wang mlog(ML_ERROR, "suballoc bit %u out of range of %u\n", 27716ca497a8Swengang wang (unsigned int)bit, 2772abf1b3cbSTao Ma ocfs2_bits_per_group(&alloc_di->id2.i_chain)); 27736ca497a8Swengang wang status = -EINVAL; 27746ca497a8Swengang wang goto bail; 27756ca497a8Swengang wang } 27766ca497a8Swengang wang 2777889f004aSTao Ma bg_blkno = group_blkno ? group_blkno : 2778889f004aSTao Ma ocfs2_which_suballoc_group(blkno, bit); 2779abf1b3cbSTao Ma status = ocfs2_read_group_descriptor(suballoc, alloc_di, bg_blkno, 27806ca497a8Swengang wang &group_bh); 27816ca497a8Swengang wang if (status < 0) { 27825b09b507SJoel Becker mlog(ML_ERROR, "read group %llu failed %d\n", 27835b09b507SJoel Becker (unsigned long long)bg_blkno, status); 27846ca497a8Swengang wang goto bail; 27856ca497a8Swengang wang } 27866ca497a8Swengang wang 27876ca497a8Swengang wang group = (struct ocfs2_group_desc *) group_bh->b_data; 27886ca497a8Swengang wang *res = ocfs2_test_bit(bit, (unsigned long *)group->bg_bitmap); 27896ca497a8Swengang wang 27906ca497a8Swengang wang bail: 27916ca497a8Swengang wang brelse(group_bh); 27926ca497a8Swengang wang 2793c1e8d35eSTao Ma if (status) 2794c1e8d35eSTao Ma mlog_errno(status); 27956ca497a8Swengang wang return status; 27966ca497a8Swengang wang } 27976ca497a8Swengang wang 27986ca497a8Swengang wang /* 27996ca497a8Swengang wang * Test if the bit representing this inode (blkno) is set in the 28006ca497a8Swengang wang * suballocator. 28016ca497a8Swengang wang * 28026ca497a8Swengang wang * On success, 0 is returned and *res is 1 for SET; 0 otherwise. 28036ca497a8Swengang wang * 28046ca497a8Swengang wang * In the event of failure, a negative value is returned and *res is 28056ca497a8Swengang wang * meaningless. 28066ca497a8Swengang wang * 28076ca497a8Swengang wang * Callers must make sure to hold nfs_sync_lock to prevent 28086ca497a8Swengang wang * ocfs2_delete_inode() on another node from accessing the same 28096ca497a8Swengang wang * suballocator concurrently. 28106ca497a8Swengang wang */ 28116ca497a8Swengang wang int ocfs2_test_inode_bit(struct ocfs2_super *osb, u64 blkno, int *res) 28126ca497a8Swengang wang { 28136ca497a8Swengang wang int status; 2814889f004aSTao Ma u64 group_blkno = 0; 28156ca497a8Swengang wang u16 suballoc_bit = 0, suballoc_slot = 0; 28166ca497a8Swengang wang struct inode *inode_alloc_inode; 28176ca497a8Swengang wang struct buffer_head *alloc_bh = NULL; 28186ca497a8Swengang wang 28192f73e135STao Ma trace_ocfs2_test_inode_bit((unsigned long long)blkno); 28206ca497a8Swengang wang 28216ca497a8Swengang wang status = ocfs2_get_suballoc_slot_bit(osb, blkno, &suballoc_slot, 2822889f004aSTao Ma &group_blkno, &suballoc_bit); 28236ca497a8Swengang wang if (status < 0) { 28246ca497a8Swengang wang mlog(ML_ERROR, "get alloc slot and bit failed %d\n", status); 28256ca497a8Swengang wang goto bail; 28266ca497a8Swengang wang } 28276ca497a8Swengang wang 2828*e5a15e17SJunxiao Bi if (suballoc_slot == (u16)OCFS2_INVALID_SLOT) 2829*e5a15e17SJunxiao Bi inode_alloc_inode = ocfs2_get_system_file_inode(osb, 2830*e5a15e17SJunxiao Bi GLOBAL_INODE_ALLOC_SYSTEM_INODE, suballoc_slot); 2831*e5a15e17SJunxiao Bi else 2832*e5a15e17SJunxiao Bi inode_alloc_inode = ocfs2_get_system_file_inode(osb, 2833*e5a15e17SJunxiao Bi INODE_ALLOC_SYSTEM_INODE, suballoc_slot); 28346ca497a8Swengang wang if (!inode_alloc_inode) { 28356ca497a8Swengang wang /* the error code could be inaccurate, but we are not able to 28366ca497a8Swengang wang * get the correct one. */ 28376ca497a8Swengang wang status = -EINVAL; 28386ca497a8Swengang wang mlog(ML_ERROR, "unable to get alloc inode in slot %u\n", 28396ca497a8Swengang wang (u32)suballoc_slot); 28406ca497a8Swengang wang goto bail; 28416ca497a8Swengang wang } 28426ca497a8Swengang wang 28435955102cSAl Viro inode_lock(inode_alloc_inode); 28446ca497a8Swengang wang status = ocfs2_inode_lock(inode_alloc_inode, &alloc_bh, 0); 28456ca497a8Swengang wang if (status < 0) { 28465955102cSAl Viro inode_unlock(inode_alloc_inode); 28477dc3e839Sjiangyiwen iput(inode_alloc_inode); 28486ca497a8Swengang wang mlog(ML_ERROR, "lock on alloc inode on slot %u failed %d\n", 28496ca497a8Swengang wang (u32)suballoc_slot, status); 28506ca497a8Swengang wang goto bail; 28516ca497a8Swengang wang } 28526ca497a8Swengang wang 28536ca497a8Swengang wang status = ocfs2_test_suballoc_bit(osb, inode_alloc_inode, alloc_bh, 2854889f004aSTao Ma group_blkno, blkno, suballoc_bit, res); 28556ca497a8Swengang wang if (status < 0) 28566ca497a8Swengang wang mlog(ML_ERROR, "test suballoc bit failed %d\n", status); 28576ca497a8Swengang wang 28586ca497a8Swengang wang ocfs2_inode_unlock(inode_alloc_inode, 0); 28595955102cSAl Viro inode_unlock(inode_alloc_inode); 28606ca497a8Swengang wang 28616ca497a8Swengang wang iput(inode_alloc_inode); 28626ca497a8Swengang wang brelse(alloc_bh); 28636ca497a8Swengang wang bail: 2864c1e8d35eSTao Ma if (status) 2865c1e8d35eSTao Ma mlog_errno(status); 28666ca497a8Swengang wang return status; 28676ca497a8Swengang wang } 2868