1ccd979bdSMark Fasheh /* -*- mode: c; c-basic-offset: 8; -*- 2ccd979bdSMark Fasheh * vim: noexpandtab sw=8 ts=8 sts=0: 3ccd979bdSMark Fasheh * 4ccd979bdSMark Fasheh * suballoc.c 5ccd979bdSMark Fasheh * 6ccd979bdSMark Fasheh * metadata alloc and free 7ccd979bdSMark Fasheh * Inspired by ext3 block groups. 8ccd979bdSMark Fasheh * 9ccd979bdSMark Fasheh * Copyright (C) 2002, 2004 Oracle. All rights reserved. 10ccd979bdSMark Fasheh * 11ccd979bdSMark Fasheh * This program is free software; you can redistribute it and/or 12ccd979bdSMark Fasheh * modify it under the terms of the GNU General Public 13ccd979bdSMark Fasheh * License as published by the Free Software Foundation; either 14ccd979bdSMark Fasheh * version 2 of the License, or (at your option) any later version. 15ccd979bdSMark Fasheh * 16ccd979bdSMark Fasheh * This program is distributed in the hope that it will be useful, 17ccd979bdSMark Fasheh * but WITHOUT ANY WARRANTY; without even the implied warranty of 18ccd979bdSMark Fasheh * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU 19ccd979bdSMark Fasheh * General Public License for more details. 20ccd979bdSMark Fasheh * 21ccd979bdSMark Fasheh * You should have received a copy of the GNU General Public 22ccd979bdSMark Fasheh * License along with this program; if not, write to the 23ccd979bdSMark Fasheh * Free Software Foundation, Inc., 59 Temple Place - Suite 330, 24ccd979bdSMark Fasheh * Boston, MA 021110-1307, USA. 25ccd979bdSMark Fasheh */ 26ccd979bdSMark Fasheh 27ccd979bdSMark Fasheh #include <linux/fs.h> 28ccd979bdSMark Fasheh #include <linux/types.h> 29ccd979bdSMark Fasheh #include <linux/slab.h> 30ccd979bdSMark Fasheh #include <linux/highmem.h> 31ccd979bdSMark Fasheh 32ccd979bdSMark Fasheh #include <cluster/masklog.h> 33ccd979bdSMark Fasheh 34ccd979bdSMark Fasheh #include "ocfs2.h" 35ccd979bdSMark Fasheh 36ccd979bdSMark Fasheh #include "alloc.h" 37d6b32bbbSJoel Becker #include "blockcheck.h" 38ccd979bdSMark Fasheh #include "dlmglue.h" 39ccd979bdSMark Fasheh #include "inode.h" 40ccd979bdSMark Fasheh #include "journal.h" 41ccd979bdSMark Fasheh #include "localalloc.h" 42ccd979bdSMark Fasheh #include "suballoc.h" 43ccd979bdSMark Fasheh #include "super.h" 44ccd979bdSMark Fasheh #include "sysfile.h" 45ccd979bdSMark Fasheh #include "uptodate.h" 462f73e135STao Ma #include "ocfs2_trace.h" 47ccd979bdSMark Fasheh 48ccd979bdSMark Fasheh #include "buffer_head_io.h" 49ccd979bdSMark Fasheh 50ffda89a3STao Ma #define NOT_ALLOC_NEW_GROUP 0 5160ca81e8STao Ma #define ALLOC_NEW_GROUP 0x1 5260ca81e8STao Ma #define ALLOC_GROUPS_FROM_GLOBAL 0x2 53ffda89a3STao Ma 54b89c5428STiger Yang #define OCFS2_MAX_TO_STEAL 1024 554d0ddb2cSTao Ma 567d1fe093SJoel Becker struct ocfs2_suballoc_result { 572b6cb576SJoel Becker u64 sr_bg_blkno; /* The bg we allocated from. Set 582b6cb576SJoel Becker to 0 when a block group is 592b6cb576SJoel Becker contiguous. */ 60e49e2767SMark Fasheh u64 sr_bg_stable_blkno; /* 61e49e2767SMark Fasheh * Doesn't change, always 62e49e2767SMark Fasheh * set to target block 63e49e2767SMark Fasheh * group descriptor 64e49e2767SMark Fasheh * block. 65e49e2767SMark Fasheh */ 66ba206635SJoel Becker u64 sr_blkno; /* The first allocated block */ 677d1fe093SJoel Becker unsigned int sr_bit_offset; /* The bit in the bg */ 687d1fe093SJoel Becker unsigned int sr_bits; /* How many bits we claimed */ 697d1fe093SJoel Becker }; 707d1fe093SJoel Becker 71b2b6ebf5SMark Fasheh static u64 ocfs2_group_from_res(struct ocfs2_suballoc_result *res) 72b2b6ebf5SMark Fasheh { 73b2b6ebf5SMark Fasheh if (res->sr_blkno == 0) 74b2b6ebf5SMark Fasheh return 0; 75b2b6ebf5SMark Fasheh 76b2b6ebf5SMark Fasheh if (res->sr_bg_blkno) 77b2b6ebf5SMark Fasheh return res->sr_bg_blkno; 78b2b6ebf5SMark Fasheh 79b2b6ebf5SMark Fasheh return ocfs2_which_suballoc_group(res->sr_blkno, res->sr_bit_offset); 80b2b6ebf5SMark Fasheh } 81b2b6ebf5SMark Fasheh 82ccd979bdSMark Fasheh static inline void ocfs2_debug_bg(struct ocfs2_group_desc *bg); 83ccd979bdSMark Fasheh static inline void ocfs2_debug_suballoc_inode(struct ocfs2_dinode *fe); 84ccd979bdSMark Fasheh static inline u16 ocfs2_find_victim_chain(struct ocfs2_chain_list *cl); 851fabe148SMark Fasheh static int ocfs2_block_group_fill(handle_t *handle, 86ccd979bdSMark Fasheh struct inode *alloc_inode, 87ccd979bdSMark Fasheh struct buffer_head *bg_bh, 88ccd979bdSMark Fasheh u64 group_blkno, 89798db35fSJoel Becker unsigned int group_clusters, 90ccd979bdSMark Fasheh u16 my_chain, 91ccd979bdSMark Fasheh struct ocfs2_chain_list *cl); 92ccd979bdSMark Fasheh static int ocfs2_block_group_alloc(struct ocfs2_super *osb, 93ccd979bdSMark Fasheh struct inode *alloc_inode, 941187c968SJoel Becker struct buffer_head *bh, 9560ca81e8STao Ma u64 max_block, 96feb473a6STao Ma u64 *last_alloc_group, 9760ca81e8STao Ma int flags); 98ccd979bdSMark Fasheh 99ccd979bdSMark Fasheh static int ocfs2_cluster_group_search(struct inode *inode, 100ccd979bdSMark Fasheh struct buffer_head *group_bh, 101ccd979bdSMark Fasheh u32 bits_wanted, u32 min_bits, 1021187c968SJoel Becker u64 max_block, 1037d1fe093SJoel Becker struct ocfs2_suballoc_result *res); 104ccd979bdSMark Fasheh static int ocfs2_block_group_search(struct inode *inode, 105ccd979bdSMark Fasheh struct buffer_head *group_bh, 106ccd979bdSMark Fasheh u32 bits_wanted, u32 min_bits, 1071187c968SJoel Becker u64 max_block, 1087d1fe093SJoel Becker struct ocfs2_suballoc_result *res); 109aa8f8e93SJoel Becker static int ocfs2_claim_suballoc_bits(struct ocfs2_alloc_context *ac, 1101fabe148SMark Fasheh handle_t *handle, 111ccd979bdSMark Fasheh u32 bits_wanted, 112ccd979bdSMark Fasheh u32 min_bits, 1137d1fe093SJoel Becker struct ocfs2_suballoc_result *res); 114ccd979bdSMark Fasheh static int ocfs2_test_bg_bit_allocatable(struct buffer_head *bg_bh, 115ccd979bdSMark Fasheh int nr); 1161fabe148SMark Fasheh static inline int ocfs2_block_group_set_bits(handle_t *handle, 117ccd979bdSMark Fasheh struct inode *alloc_inode, 118ccd979bdSMark Fasheh struct ocfs2_group_desc *bg, 119ccd979bdSMark Fasheh struct buffer_head *group_bh, 120ccd979bdSMark Fasheh unsigned int bit_off, 121ccd979bdSMark Fasheh unsigned int num_bits); 1221fabe148SMark Fasheh static int ocfs2_relink_block_group(handle_t *handle, 123ccd979bdSMark Fasheh struct inode *alloc_inode, 124ccd979bdSMark Fasheh struct buffer_head *fe_bh, 125ccd979bdSMark Fasheh struct buffer_head *bg_bh, 126ccd979bdSMark Fasheh struct buffer_head *prev_bg_bh, 127ccd979bdSMark Fasheh u16 chain); 128ccd979bdSMark Fasheh static inline int ocfs2_block_group_reasonably_empty(struct ocfs2_group_desc *bg, 129ccd979bdSMark Fasheh u32 wanted); 130ccd979bdSMark Fasheh static inline u32 ocfs2_desc_bitmap_to_cluster_off(struct inode *inode, 131ccd979bdSMark Fasheh u64 bg_blkno, 132ccd979bdSMark Fasheh u16 bg_bit_off); 133ccd979bdSMark Fasheh static inline void ocfs2_block_to_cluster_group(struct inode *inode, 134ccd979bdSMark Fasheh u64 data_blkno, 135ccd979bdSMark Fasheh u64 *bg_blkno, 136ccd979bdSMark Fasheh u16 *bg_bit_off); 1371187c968SJoel Becker static int ocfs2_reserve_clusters_with_limit(struct ocfs2_super *osb, 1381187c968SJoel Becker u32 bits_wanted, u64 max_block, 13960ca81e8STao Ma int flags, 1401187c968SJoel Becker struct ocfs2_alloc_context **ac); 141ccd979bdSMark Fasheh 1429c7af40bSMark Fasheh void ocfs2_free_ac_resource(struct ocfs2_alloc_context *ac) 143ccd979bdSMark Fasheh { 144da5cbf2fSMark Fasheh struct inode *inode = ac->ac_inode; 145da5cbf2fSMark Fasheh 146da5cbf2fSMark Fasheh if (inode) { 147da5cbf2fSMark Fasheh if (ac->ac_which != OCFS2_AC_USE_LOCAL) 148e63aecb6SMark Fasheh ocfs2_inode_unlock(inode, 1); 149da5cbf2fSMark Fasheh 150da5cbf2fSMark Fasheh mutex_unlock(&inode->i_mutex); 151da5cbf2fSMark Fasheh 152da5cbf2fSMark Fasheh iput(inode); 1534d0ddb2cSTao Ma ac->ac_inode = NULL; 154da5cbf2fSMark Fasheh } 155ccd979bdSMark Fasheh brelse(ac->ac_bh); 1564d0ddb2cSTao Ma ac->ac_bh = NULL; 157e3b4a97dSMark Fasheh ac->ac_resv = NULL; 158e49e2767SMark Fasheh if (ac->ac_find_loc_priv) { 159e49e2767SMark Fasheh kfree(ac->ac_find_loc_priv); 160e49e2767SMark Fasheh ac->ac_find_loc_priv = NULL; 161e49e2767SMark Fasheh } 1624d0ddb2cSTao Ma } 1634d0ddb2cSTao Ma 1644d0ddb2cSTao Ma void ocfs2_free_alloc_context(struct ocfs2_alloc_context *ac) 1654d0ddb2cSTao Ma { 1664d0ddb2cSTao Ma ocfs2_free_ac_resource(ac); 167ccd979bdSMark Fasheh kfree(ac); 168ccd979bdSMark Fasheh } 169ccd979bdSMark Fasheh 170ccd979bdSMark Fasheh static u32 ocfs2_bits_per_group(struct ocfs2_chain_list *cl) 171ccd979bdSMark Fasheh { 172ccd979bdSMark Fasheh return (u32)le16_to_cpu(cl->cl_cpg) * (u32)le16_to_cpu(cl->cl_bpc); 173ccd979bdSMark Fasheh } 174ccd979bdSMark Fasheh 17557e3e797SJoel Becker #define do_error(fmt, ...) \ 17657e3e797SJoel Becker do{ \ 17778c37eb0STao Ma if (resize) \ 17857e3e797SJoel Becker mlog(ML_ERROR, fmt "\n", ##__VA_ARGS__); \ 17957e3e797SJoel Becker else \ 18057e3e797SJoel Becker ocfs2_error(sb, fmt, ##__VA_ARGS__); \ 18157e3e797SJoel Becker } while (0) 18257e3e797SJoel Becker 183970e4936SJoel Becker static int ocfs2_validate_gd_self(struct super_block *sb, 184970e4936SJoel Becker struct buffer_head *bh, 18578c37eb0STao Ma int resize) 186970e4936SJoel Becker { 187970e4936SJoel Becker struct ocfs2_group_desc *gd = (struct ocfs2_group_desc *)bh->b_data; 188970e4936SJoel Becker 1897bf72edeSMark Fasheh if (!OCFS2_IS_VALID_GROUP_DESC(gd)) { 19068f64d47SJoel Becker do_error("Group descriptor #%llu has bad signature %.*s", 19168f64d47SJoel Becker (unsigned long long)bh->b_blocknr, 7, 19257e3e797SJoel Becker gd->bg_signature); 19357e3e797SJoel Becker return -EINVAL; 1947bf72edeSMark Fasheh } 1957bf72edeSMark Fasheh 19668f64d47SJoel Becker if (le64_to_cpu(gd->bg_blkno) != bh->b_blocknr) { 19768f64d47SJoel Becker do_error("Group descriptor #%llu has an invalid bg_blkno " 19868f64d47SJoel Becker "of %llu", 19968f64d47SJoel Becker (unsigned long long)bh->b_blocknr, 20068f64d47SJoel Becker (unsigned long long)le64_to_cpu(gd->bg_blkno)); 20168f64d47SJoel Becker return -EINVAL; 20268f64d47SJoel Becker } 20368f64d47SJoel Becker 20468f64d47SJoel Becker if (le32_to_cpu(gd->bg_generation) != OCFS2_SB(sb)->fs_generation) { 20568f64d47SJoel Becker do_error("Group descriptor #%llu has an invalid " 20668f64d47SJoel Becker "fs_generation of #%u", 20768f64d47SJoel Becker (unsigned long long)bh->b_blocknr, 20868f64d47SJoel Becker le32_to_cpu(gd->bg_generation)); 20968f64d47SJoel Becker return -EINVAL; 21068f64d47SJoel Becker } 21168f64d47SJoel Becker 212970e4936SJoel Becker if (le16_to_cpu(gd->bg_free_bits_count) > le16_to_cpu(gd->bg_bits)) { 213970e4936SJoel Becker do_error("Group descriptor #%llu has bit count %u but " 214970e4936SJoel Becker "claims that %u are free", 215970e4936SJoel Becker (unsigned long long)bh->b_blocknr, 216970e4936SJoel Becker le16_to_cpu(gd->bg_bits), 217970e4936SJoel Becker le16_to_cpu(gd->bg_free_bits_count)); 218970e4936SJoel Becker return -EINVAL; 219970e4936SJoel Becker } 220970e4936SJoel Becker 221970e4936SJoel Becker if (le16_to_cpu(gd->bg_bits) > (8 * le16_to_cpu(gd->bg_size))) { 222970e4936SJoel Becker do_error("Group descriptor #%llu has bit count %u but " 223970e4936SJoel Becker "max bitmap bits of %u", 224970e4936SJoel Becker (unsigned long long)bh->b_blocknr, 225970e4936SJoel Becker le16_to_cpu(gd->bg_bits), 226970e4936SJoel Becker 8 * le16_to_cpu(gd->bg_size)); 227970e4936SJoel Becker return -EINVAL; 228970e4936SJoel Becker } 229970e4936SJoel Becker 230970e4936SJoel Becker return 0; 231970e4936SJoel Becker } 232970e4936SJoel Becker 233970e4936SJoel Becker static int ocfs2_validate_gd_parent(struct super_block *sb, 234970e4936SJoel Becker struct ocfs2_dinode *di, 235970e4936SJoel Becker struct buffer_head *bh, 23678c37eb0STao Ma int resize) 237970e4936SJoel Becker { 238970e4936SJoel Becker unsigned int max_bits; 239970e4936SJoel Becker struct ocfs2_group_desc *gd = (struct ocfs2_group_desc *)bh->b_data; 240970e4936SJoel Becker 2417bf72edeSMark Fasheh if (di->i_blkno != gd->bg_parent_dinode) { 24257e3e797SJoel Becker do_error("Group descriptor #%llu has bad parent " 2437bf72edeSMark Fasheh "pointer (%llu, expected %llu)", 24468f64d47SJoel Becker (unsigned long long)bh->b_blocknr, 2457bf72edeSMark Fasheh (unsigned long long)le64_to_cpu(gd->bg_parent_dinode), 2467bf72edeSMark Fasheh (unsigned long long)le64_to_cpu(di->i_blkno)); 24757e3e797SJoel Becker return -EINVAL; 2487bf72edeSMark Fasheh } 2497bf72edeSMark Fasheh 2507bf72edeSMark Fasheh max_bits = le16_to_cpu(di->id2.i_chain.cl_cpg) * le16_to_cpu(di->id2.i_chain.cl_bpc); 2517bf72edeSMark Fasheh if (le16_to_cpu(gd->bg_bits) > max_bits) { 25257e3e797SJoel Becker do_error("Group descriptor #%llu has bit count of %u", 25368f64d47SJoel Becker (unsigned long long)bh->b_blocknr, 2547bf72edeSMark Fasheh le16_to_cpu(gd->bg_bits)); 25557e3e797SJoel Becker return -EINVAL; 2567bf72edeSMark Fasheh } 2577bf72edeSMark Fasheh 25878c37eb0STao Ma /* In resize, we may meet the case bg_chain == cl_next_free_rec. */ 25978c37eb0STao Ma if ((le16_to_cpu(gd->bg_chain) > 26078c37eb0STao Ma le16_to_cpu(di->id2.i_chain.cl_next_free_rec)) || 26178c37eb0STao Ma ((le16_to_cpu(gd->bg_chain) == 26278c37eb0STao Ma le16_to_cpu(di->id2.i_chain.cl_next_free_rec)) && !resize)) { 26357e3e797SJoel Becker do_error("Group descriptor #%llu has bad chain %u", 26468f64d47SJoel Becker (unsigned long long)bh->b_blocknr, 2657bf72edeSMark Fasheh le16_to_cpu(gd->bg_chain)); 26657e3e797SJoel Becker return -EINVAL; 2677bf72edeSMark Fasheh } 2687bf72edeSMark Fasheh 269970e4936SJoel Becker return 0; 2707bf72edeSMark Fasheh } 2717bf72edeSMark Fasheh 27257e3e797SJoel Becker #undef do_error 2737bf72edeSMark Fasheh 274970e4936SJoel Becker /* 275970e4936SJoel Becker * This version only prints errors. It does not fail the filesystem, and 276970e4936SJoel Becker * exists only for resize. 277970e4936SJoel Becker */ 278970e4936SJoel Becker int ocfs2_check_group_descriptor(struct super_block *sb, 279970e4936SJoel Becker struct ocfs2_dinode *di, 280970e4936SJoel Becker struct buffer_head *bh) 281970e4936SJoel Becker { 282970e4936SJoel Becker int rc; 283d6b32bbbSJoel Becker struct ocfs2_group_desc *gd = (struct ocfs2_group_desc *)bh->b_data; 284970e4936SJoel Becker 285d6b32bbbSJoel Becker BUG_ON(!buffer_uptodate(bh)); 286d6b32bbbSJoel Becker 287d6b32bbbSJoel Becker /* 288d6b32bbbSJoel Becker * If the ecc fails, we return the error but otherwise 289d6b32bbbSJoel Becker * leave the filesystem running. We know any error is 290d6b32bbbSJoel Becker * local to this block. 291d6b32bbbSJoel Becker */ 292d6b32bbbSJoel Becker rc = ocfs2_validate_meta_ecc(sb, bh->b_data, &gd->bg_check); 29313723d00SJoel Becker if (rc) { 29413723d00SJoel Becker mlog(ML_ERROR, 29513723d00SJoel Becker "Checksum failed for group descriptor %llu\n", 29613723d00SJoel Becker (unsigned long long)bh->b_blocknr); 29713723d00SJoel Becker } else 298970e4936SJoel Becker rc = ocfs2_validate_gd_self(sb, bh, 1); 299970e4936SJoel Becker if (!rc) 300970e4936SJoel Becker rc = ocfs2_validate_gd_parent(sb, di, bh, 1); 301970e4936SJoel Becker 302970e4936SJoel Becker return rc; 303970e4936SJoel Becker } 304970e4936SJoel Becker 305970e4936SJoel Becker static int ocfs2_validate_group_descriptor(struct super_block *sb, 306970e4936SJoel Becker struct buffer_head *bh) 307970e4936SJoel Becker { 308d6b32bbbSJoel Becker int rc; 309d6b32bbbSJoel Becker struct ocfs2_group_desc *gd = (struct ocfs2_group_desc *)bh->b_data; 310d6b32bbbSJoel Becker 3112f73e135STao Ma trace_ocfs2_validate_group_descriptor( 312970e4936SJoel Becker (unsigned long long)bh->b_blocknr); 313970e4936SJoel Becker 314d6b32bbbSJoel Becker BUG_ON(!buffer_uptodate(bh)); 315d6b32bbbSJoel Becker 316d6b32bbbSJoel Becker /* 317d6b32bbbSJoel Becker * If the ecc fails, we return the error but otherwise 318d6b32bbbSJoel Becker * leave the filesystem running. We know any error is 319d6b32bbbSJoel Becker * local to this block. 320d6b32bbbSJoel Becker */ 321d6b32bbbSJoel Becker rc = ocfs2_validate_meta_ecc(sb, bh->b_data, &gd->bg_check); 322d6b32bbbSJoel Becker if (rc) 323d6b32bbbSJoel Becker return rc; 324d6b32bbbSJoel Becker 325d6b32bbbSJoel Becker /* 326d6b32bbbSJoel Becker * Errors after here are fatal. 327d6b32bbbSJoel Becker */ 328d6b32bbbSJoel Becker 329970e4936SJoel Becker return ocfs2_validate_gd_self(sb, bh, 0); 3307bf72edeSMark Fasheh } 3317bf72edeSMark Fasheh 33268f64d47SJoel Becker int ocfs2_read_group_descriptor(struct inode *inode, struct ocfs2_dinode *di, 33368f64d47SJoel Becker u64 gd_blkno, struct buffer_head **bh) 33468f64d47SJoel Becker { 33568f64d47SJoel Becker int rc; 33668f64d47SJoel Becker struct buffer_head *tmp = *bh; 33768f64d47SJoel Becker 3388cb471e8SJoel Becker rc = ocfs2_read_block(INODE_CACHE(inode), gd_blkno, &tmp, 339970e4936SJoel Becker ocfs2_validate_group_descriptor); 34068f64d47SJoel Becker if (rc) 34168f64d47SJoel Becker goto out; 34268f64d47SJoel Becker 343970e4936SJoel Becker rc = ocfs2_validate_gd_parent(inode->i_sb, di, tmp, 0); 34468f64d47SJoel Becker if (rc) { 34568f64d47SJoel Becker brelse(tmp); 34668f64d47SJoel Becker goto out; 34768f64d47SJoel Becker } 34868f64d47SJoel Becker 34968f64d47SJoel Becker /* If ocfs2_read_block() got us a new bh, pass it up. */ 35068f64d47SJoel Becker if (!*bh) 35168f64d47SJoel Becker *bh = tmp; 35268f64d47SJoel Becker 35368f64d47SJoel Becker out: 35468f64d47SJoel Becker return rc; 35568f64d47SJoel Becker } 35668f64d47SJoel Becker 357798db35fSJoel Becker static void ocfs2_bg_discontig_add_extent(struct ocfs2_super *osb, 358798db35fSJoel Becker struct ocfs2_group_desc *bg, 359798db35fSJoel Becker struct ocfs2_chain_list *cl, 36047dea423STao Ma u64 p_blkno, unsigned int clusters) 361798db35fSJoel Becker { 362798db35fSJoel Becker struct ocfs2_extent_list *el = &bg->bg_list; 363798db35fSJoel Becker struct ocfs2_extent_rec *rec; 364798db35fSJoel Becker 3654711954eSTao Ma BUG_ON(!ocfs2_supports_discontig_bg(osb)); 366798db35fSJoel Becker if (!el->l_next_free_rec) 367798db35fSJoel Becker el->l_count = cpu_to_le16(ocfs2_extent_recs_per_gd(osb->sb)); 368798db35fSJoel Becker rec = &el->l_recs[le16_to_cpu(el->l_next_free_rec)]; 3694711954eSTao Ma rec->e_blkno = cpu_to_le64(p_blkno); 370798db35fSJoel Becker rec->e_cpos = cpu_to_le32(le16_to_cpu(bg->bg_bits) / 371798db35fSJoel Becker le16_to_cpu(cl->cl_bpc)); 37247dea423STao Ma rec->e_leaf_clusters = cpu_to_le16(clusters); 373798db35fSJoel Becker le16_add_cpu(&bg->bg_bits, clusters * le16_to_cpu(cl->cl_bpc)); 3744711954eSTao Ma le16_add_cpu(&bg->bg_free_bits_count, 3754711954eSTao Ma clusters * le16_to_cpu(cl->cl_bpc)); 376798db35fSJoel Becker le16_add_cpu(&el->l_next_free_rec, 1); 377798db35fSJoel Becker } 378798db35fSJoel Becker 3791fabe148SMark Fasheh static int ocfs2_block_group_fill(handle_t *handle, 380ccd979bdSMark Fasheh struct inode *alloc_inode, 381ccd979bdSMark Fasheh struct buffer_head *bg_bh, 382ccd979bdSMark Fasheh u64 group_blkno, 383798db35fSJoel Becker unsigned int group_clusters, 384ccd979bdSMark Fasheh u16 my_chain, 385ccd979bdSMark Fasheh struct ocfs2_chain_list *cl) 386ccd979bdSMark Fasheh { 387ccd979bdSMark Fasheh int status = 0; 388798db35fSJoel Becker struct ocfs2_super *osb = OCFS2_SB(alloc_inode->i_sb); 389ccd979bdSMark Fasheh struct ocfs2_group_desc *bg = (struct ocfs2_group_desc *) bg_bh->b_data; 390ccd979bdSMark Fasheh struct super_block * sb = alloc_inode->i_sb; 391ccd979bdSMark Fasheh 392ccd979bdSMark Fasheh if (((unsigned long long) bg_bh->b_blocknr) != group_blkno) { 393b0697053SMark Fasheh ocfs2_error(alloc_inode->i_sb, "group block (%llu) != " 394b0697053SMark Fasheh "b_blocknr (%llu)", 395b0697053SMark Fasheh (unsigned long long)group_blkno, 396ccd979bdSMark Fasheh (unsigned long long) bg_bh->b_blocknr); 397ccd979bdSMark Fasheh status = -EIO; 398ccd979bdSMark Fasheh goto bail; 399ccd979bdSMark Fasheh } 400ccd979bdSMark Fasheh 40113723d00SJoel Becker status = ocfs2_journal_access_gd(handle, 4020cf2f763SJoel Becker INODE_CACHE(alloc_inode), 403ccd979bdSMark Fasheh bg_bh, 404ccd979bdSMark Fasheh OCFS2_JOURNAL_ACCESS_CREATE); 405ccd979bdSMark Fasheh if (status < 0) { 406ccd979bdSMark Fasheh mlog_errno(status); 407ccd979bdSMark Fasheh goto bail; 408ccd979bdSMark Fasheh } 409ccd979bdSMark Fasheh 410ccd979bdSMark Fasheh memset(bg, 0, sb->s_blocksize); 411ccd979bdSMark Fasheh strcpy(bg->bg_signature, OCFS2_GROUP_DESC_SIGNATURE); 412ccd979bdSMark Fasheh bg->bg_generation = cpu_to_le32(OCFS2_SB(sb)->fs_generation); 4138571882cSTao Ma bg->bg_size = cpu_to_le16(ocfs2_group_bitmap_size(sb, 1, 4148571882cSTao Ma osb->s_feature_incompat)); 415ccd979bdSMark Fasheh bg->bg_chain = cpu_to_le16(my_chain); 416ccd979bdSMark Fasheh bg->bg_next_group = cl->cl_recs[my_chain].c_blkno; 417ccd979bdSMark Fasheh bg->bg_parent_dinode = cpu_to_le64(OCFS2_I(alloc_inode)->ip_blkno); 418ccd979bdSMark Fasheh bg->bg_blkno = cpu_to_le64(group_blkno); 419798db35fSJoel Becker if (group_clusters == le16_to_cpu(cl->cl_cpg)) 420798db35fSJoel Becker bg->bg_bits = cpu_to_le16(ocfs2_bits_per_group(cl)); 421798db35fSJoel Becker else 4224711954eSTao Ma ocfs2_bg_discontig_add_extent(osb, bg, cl, group_blkno, 423798db35fSJoel Becker group_clusters); 424798db35fSJoel Becker 425ccd979bdSMark Fasheh /* set the 1st bit in the bitmap to account for the descriptor block */ 426ccd979bdSMark Fasheh ocfs2_set_bit(0, (unsigned long *)bg->bg_bitmap); 427ccd979bdSMark Fasheh bg->bg_free_bits_count = cpu_to_le16(le16_to_cpu(bg->bg_bits) - 1); 428ccd979bdSMark Fasheh 429ec20cec7SJoel Becker ocfs2_journal_dirty(handle, bg_bh); 430ccd979bdSMark Fasheh 431ccd979bdSMark Fasheh /* There is no need to zero out or otherwise initialize the 432ccd979bdSMark Fasheh * other blocks in a group - All valid FS metadata in a block 433ccd979bdSMark Fasheh * group stores the superblock fs_generation value at 434ccd979bdSMark Fasheh * allocation time. */ 435ccd979bdSMark Fasheh 436ccd979bdSMark Fasheh bail: 437c1e8d35eSTao Ma if (status) 438c1e8d35eSTao Ma mlog_errno(status); 439ccd979bdSMark Fasheh return status; 440ccd979bdSMark Fasheh } 441ccd979bdSMark Fasheh 442ccd979bdSMark Fasheh static inline u16 ocfs2_find_smallest_chain(struct ocfs2_chain_list *cl) 443ccd979bdSMark Fasheh { 444ccd979bdSMark Fasheh u16 curr, best; 445ccd979bdSMark Fasheh 446ccd979bdSMark Fasheh best = curr = 0; 447ccd979bdSMark Fasheh while (curr < le16_to_cpu(cl->cl_count)) { 448ccd979bdSMark Fasheh if (le32_to_cpu(cl->cl_recs[best].c_total) > 449ccd979bdSMark Fasheh le32_to_cpu(cl->cl_recs[curr].c_total)) 450ccd979bdSMark Fasheh best = curr; 451ccd979bdSMark Fasheh curr++; 452ccd979bdSMark Fasheh } 453ccd979bdSMark Fasheh return best; 454ccd979bdSMark Fasheh } 455ccd979bdSMark Fasheh 456798db35fSJoel Becker static struct buffer_head * 457798db35fSJoel Becker ocfs2_block_group_alloc_contig(struct ocfs2_super *osb, handle_t *handle, 458798db35fSJoel Becker struct inode *alloc_inode, 459798db35fSJoel Becker struct ocfs2_alloc_context *ac, 460798db35fSJoel Becker struct ocfs2_chain_list *cl) 461798db35fSJoel Becker { 462798db35fSJoel Becker int status; 463798db35fSJoel Becker u32 bit_off, num_bits; 464798db35fSJoel Becker u64 bg_blkno; 465798db35fSJoel Becker struct buffer_head *bg_bh; 466798db35fSJoel Becker unsigned int alloc_rec = ocfs2_find_smallest_chain(cl); 467798db35fSJoel Becker 4681ed9b777SJoel Becker status = ocfs2_claim_clusters(handle, ac, 469798db35fSJoel Becker le16_to_cpu(cl->cl_cpg), &bit_off, 470798db35fSJoel Becker &num_bits); 471798db35fSJoel Becker if (status < 0) { 472798db35fSJoel Becker if (status != -ENOSPC) 473798db35fSJoel Becker mlog_errno(status); 474798db35fSJoel Becker goto bail; 475798db35fSJoel Becker } 476798db35fSJoel Becker 477798db35fSJoel Becker /* setup the group */ 478798db35fSJoel Becker bg_blkno = ocfs2_clusters_to_blocks(osb->sb, bit_off); 4792f73e135STao Ma trace_ocfs2_block_group_alloc_contig( 4802f73e135STao Ma (unsigned long long)bg_blkno, alloc_rec); 481798db35fSJoel Becker 482798db35fSJoel Becker bg_bh = sb_getblk(osb->sb, bg_blkno); 483798db35fSJoel Becker if (!bg_bh) { 484*7391a294SRui Xiang status = -ENOMEM; 485798db35fSJoel Becker mlog_errno(status); 486798db35fSJoel Becker goto bail; 487798db35fSJoel Becker } 488798db35fSJoel Becker ocfs2_set_new_buffer_uptodate(INODE_CACHE(alloc_inode), bg_bh); 489798db35fSJoel Becker 490798db35fSJoel Becker status = ocfs2_block_group_fill(handle, alloc_inode, bg_bh, 491798db35fSJoel Becker bg_blkno, num_bits, alloc_rec, cl); 492798db35fSJoel Becker if (status < 0) { 493798db35fSJoel Becker brelse(bg_bh); 494798db35fSJoel Becker mlog_errno(status); 495798db35fSJoel Becker } 496798db35fSJoel Becker 497798db35fSJoel Becker bail: 498798db35fSJoel Becker return status ? ERR_PTR(status) : bg_bh; 499798db35fSJoel Becker } 500798db35fSJoel Becker 501798db35fSJoel Becker static int ocfs2_block_group_claim_bits(struct ocfs2_super *osb, 502798db35fSJoel Becker handle_t *handle, 503798db35fSJoel Becker struct ocfs2_alloc_context *ac, 504798db35fSJoel Becker unsigned int min_bits, 505798db35fSJoel Becker u32 *bit_off, u32 *num_bits) 506798db35fSJoel Becker { 50718d3a98fSJoel Becker int status = 0; 508798db35fSJoel Becker 509798db35fSJoel Becker while (min_bits) { 5101ed9b777SJoel Becker status = ocfs2_claim_clusters(handle, ac, min_bits, 511798db35fSJoel Becker bit_off, num_bits); 512798db35fSJoel Becker if (status != -ENOSPC) 513798db35fSJoel Becker break; 514798db35fSJoel Becker 515798db35fSJoel Becker min_bits >>= 1; 516798db35fSJoel Becker } 517798db35fSJoel Becker 518798db35fSJoel Becker return status; 519798db35fSJoel Becker } 520798db35fSJoel Becker 521798db35fSJoel Becker static int ocfs2_block_group_grow_discontig(handle_t *handle, 522798db35fSJoel Becker struct inode *alloc_inode, 523798db35fSJoel Becker struct buffer_head *bg_bh, 524798db35fSJoel Becker struct ocfs2_alloc_context *ac, 525798db35fSJoel Becker struct ocfs2_chain_list *cl, 526798db35fSJoel Becker unsigned int min_bits) 527798db35fSJoel Becker { 528798db35fSJoel Becker int status; 529798db35fSJoel Becker struct ocfs2_super *osb = OCFS2_SB(alloc_inode->i_sb); 530798db35fSJoel Becker struct ocfs2_group_desc *bg = 531798db35fSJoel Becker (struct ocfs2_group_desc *)bg_bh->b_data; 5324711954eSTao Ma unsigned int needed = le16_to_cpu(cl->cl_cpg) - 5334711954eSTao Ma le16_to_cpu(bg->bg_bits) / le16_to_cpu(cl->cl_bpc); 534798db35fSJoel Becker u32 p_cpos, clusters; 535798db35fSJoel Becker u64 p_blkno; 536798db35fSJoel Becker struct ocfs2_extent_list *el = &bg->bg_list; 537798db35fSJoel Becker 538798db35fSJoel Becker status = ocfs2_journal_access_gd(handle, 539798db35fSJoel Becker INODE_CACHE(alloc_inode), 540798db35fSJoel Becker bg_bh, 541798db35fSJoel Becker OCFS2_JOURNAL_ACCESS_CREATE); 542798db35fSJoel Becker if (status < 0) { 543798db35fSJoel Becker mlog_errno(status); 544798db35fSJoel Becker goto bail; 545798db35fSJoel Becker } 546798db35fSJoel Becker 547798db35fSJoel Becker while ((needed > 0) && (le16_to_cpu(el->l_next_free_rec) < 548798db35fSJoel Becker le16_to_cpu(el->l_count))) { 549798db35fSJoel Becker if (min_bits > needed) 550798db35fSJoel Becker min_bits = needed; 551798db35fSJoel Becker status = ocfs2_block_group_claim_bits(osb, handle, ac, 552798db35fSJoel Becker min_bits, &p_cpos, 553798db35fSJoel Becker &clusters); 554798db35fSJoel Becker if (status < 0) { 555798db35fSJoel Becker if (status != -ENOSPC) 556798db35fSJoel Becker mlog_errno(status); 557798db35fSJoel Becker goto bail; 558798db35fSJoel Becker } 559798db35fSJoel Becker p_blkno = ocfs2_clusters_to_blocks(osb->sb, p_cpos); 560798db35fSJoel Becker ocfs2_bg_discontig_add_extent(osb, bg, cl, p_blkno, 561798db35fSJoel Becker clusters); 562798db35fSJoel Becker 563798db35fSJoel Becker min_bits = clusters; 5644711954eSTao Ma needed = le16_to_cpu(cl->cl_cpg) - 5654711954eSTao Ma le16_to_cpu(bg->bg_bits) / le16_to_cpu(cl->cl_bpc); 566798db35fSJoel Becker } 567798db35fSJoel Becker 568798db35fSJoel Becker if (needed > 0) { 5694711954eSTao Ma /* 5704711954eSTao Ma * We have used up all the extent rec but can't fill up 5714711954eSTao Ma * the cpg. So bail out. 5724711954eSTao Ma */ 5734711954eSTao Ma status = -ENOSPC; 5744711954eSTao Ma goto bail; 575798db35fSJoel Becker } 576798db35fSJoel Becker 577798db35fSJoel Becker ocfs2_journal_dirty(handle, bg_bh); 578798db35fSJoel Becker 579798db35fSJoel Becker bail: 580798db35fSJoel Becker return status; 581798db35fSJoel Becker } 582798db35fSJoel Becker 5838b06bc59SJoel Becker static void ocfs2_bg_alloc_cleanup(handle_t *handle, 5848b06bc59SJoel Becker struct ocfs2_alloc_context *cluster_ac, 5858b06bc59SJoel Becker struct inode *alloc_inode, 5868b06bc59SJoel Becker struct buffer_head *bg_bh) 587798db35fSJoel Becker { 5888b06bc59SJoel Becker int i, ret; 589798db35fSJoel Becker struct ocfs2_group_desc *bg; 590798db35fSJoel Becker struct ocfs2_extent_list *el; 591798db35fSJoel Becker struct ocfs2_extent_rec *rec; 592798db35fSJoel Becker 593798db35fSJoel Becker if (!bg_bh) 594798db35fSJoel Becker return; 595798db35fSJoel Becker 596798db35fSJoel Becker bg = (struct ocfs2_group_desc *)bg_bh->b_data; 597798db35fSJoel Becker el = &bg->bg_list; 598798db35fSJoel Becker for (i = 0; i < le16_to_cpu(el->l_next_free_rec); i++) { 599798db35fSJoel Becker rec = &el->l_recs[i]; 6008b06bc59SJoel Becker ret = ocfs2_free_clusters(handle, cluster_ac->ac_inode, 6018b06bc59SJoel Becker cluster_ac->ac_bh, 602798db35fSJoel Becker le64_to_cpu(rec->e_blkno), 60372094e43SAl Viro le16_to_cpu(rec->e_leaf_clusters)); 6048b06bc59SJoel Becker if (ret) 6058b06bc59SJoel Becker mlog_errno(ret); 6068b06bc59SJoel Becker /* Try all the clusters to free */ 607798db35fSJoel Becker } 608798db35fSJoel Becker 609798db35fSJoel Becker ocfs2_remove_from_cache(INODE_CACHE(alloc_inode), bg_bh); 610798db35fSJoel Becker brelse(bg_bh); 611798db35fSJoel Becker } 612798db35fSJoel Becker 613798db35fSJoel Becker static struct buffer_head * 614798db35fSJoel Becker ocfs2_block_group_alloc_discontig(handle_t *handle, 615798db35fSJoel Becker struct inode *alloc_inode, 616798db35fSJoel Becker struct ocfs2_alloc_context *ac, 6178b06bc59SJoel Becker struct ocfs2_chain_list *cl) 618798db35fSJoel Becker { 619798db35fSJoel Becker int status; 620798db35fSJoel Becker u32 bit_off, num_bits; 621798db35fSJoel Becker u64 bg_blkno; 622798db35fSJoel Becker unsigned int min_bits = le16_to_cpu(cl->cl_cpg) >> 1; 623798db35fSJoel Becker struct buffer_head *bg_bh = NULL; 624798db35fSJoel Becker unsigned int alloc_rec = ocfs2_find_smallest_chain(cl); 625798db35fSJoel Becker struct ocfs2_super *osb = OCFS2_SB(alloc_inode->i_sb); 626798db35fSJoel Becker 6274711954eSTao Ma if (!ocfs2_supports_discontig_bg(osb)) { 628798db35fSJoel Becker status = -ENOSPC; 629798db35fSJoel Becker goto bail; 630798db35fSJoel Becker } 631798db35fSJoel Becker 6328b06bc59SJoel Becker status = ocfs2_extend_trans(handle, 6338b06bc59SJoel Becker ocfs2_calc_bg_discontig_credits(osb->sb)); 6348b06bc59SJoel Becker if (status) { 6358b06bc59SJoel Becker mlog_errno(status); 6368b06bc59SJoel Becker goto bail; 6378b06bc59SJoel Becker } 6388b06bc59SJoel Becker 63995ec0adfSJoel Becker /* 64095ec0adfSJoel Becker * We're going to be grabbing from multiple cluster groups. 64195ec0adfSJoel Becker * We don't have enough credits to relink them all, and the 64295ec0adfSJoel Becker * cluster groups will be staying in cache for the duration of 64395ec0adfSJoel Becker * this operation. 64495ec0adfSJoel Becker */ 645309a85b6SXiaowei.Hu ac->ac_disable_chain_relink = 1; 64695ec0adfSJoel Becker 647798db35fSJoel Becker /* Claim the first region */ 648798db35fSJoel Becker status = ocfs2_block_group_claim_bits(osb, handle, ac, min_bits, 649798db35fSJoel Becker &bit_off, &num_bits); 650798db35fSJoel Becker if (status < 0) { 651798db35fSJoel Becker if (status != -ENOSPC) 652798db35fSJoel Becker mlog_errno(status); 653798db35fSJoel Becker goto bail; 654798db35fSJoel Becker } 655798db35fSJoel Becker min_bits = num_bits; 656798db35fSJoel Becker 657798db35fSJoel Becker /* setup the group */ 658798db35fSJoel Becker bg_blkno = ocfs2_clusters_to_blocks(osb->sb, bit_off); 6592f73e135STao Ma trace_ocfs2_block_group_alloc_discontig( 6602f73e135STao Ma (unsigned long long)bg_blkno, alloc_rec); 661798db35fSJoel Becker 662798db35fSJoel Becker bg_bh = sb_getblk(osb->sb, bg_blkno); 663798db35fSJoel Becker if (!bg_bh) { 664*7391a294SRui Xiang status = -ENOMEM; 665798db35fSJoel Becker mlog_errno(status); 666798db35fSJoel Becker goto bail; 667798db35fSJoel Becker } 668798db35fSJoel Becker ocfs2_set_new_buffer_uptodate(INODE_CACHE(alloc_inode), bg_bh); 669798db35fSJoel Becker 670798db35fSJoel Becker status = ocfs2_block_group_fill(handle, alloc_inode, bg_bh, 671798db35fSJoel Becker bg_blkno, num_bits, alloc_rec, cl); 672798db35fSJoel Becker if (status < 0) { 673798db35fSJoel Becker mlog_errno(status); 674798db35fSJoel Becker goto bail; 675798db35fSJoel Becker } 676798db35fSJoel Becker 677798db35fSJoel Becker status = ocfs2_block_group_grow_discontig(handle, alloc_inode, 678798db35fSJoel Becker bg_bh, ac, cl, min_bits); 679798db35fSJoel Becker if (status) 680798db35fSJoel Becker mlog_errno(status); 681798db35fSJoel Becker 682798db35fSJoel Becker bail: 683798db35fSJoel Becker if (status) 6848b06bc59SJoel Becker ocfs2_bg_alloc_cleanup(handle, ac, alloc_inode, bg_bh); 685798db35fSJoel Becker return status ? ERR_PTR(status) : bg_bh; 686798db35fSJoel Becker } 687798db35fSJoel Becker 688ccd979bdSMark Fasheh /* 689ccd979bdSMark Fasheh * We expect the block group allocator to already be locked. 690ccd979bdSMark Fasheh */ 691ccd979bdSMark Fasheh static int ocfs2_block_group_alloc(struct ocfs2_super *osb, 692ccd979bdSMark Fasheh struct inode *alloc_inode, 6931187c968SJoel Becker struct buffer_head *bh, 69460ca81e8STao Ma u64 max_block, 695feb473a6STao Ma u64 *last_alloc_group, 69660ca81e8STao Ma int flags) 697ccd979bdSMark Fasheh { 698ccd979bdSMark Fasheh int status, credits; 699ccd979bdSMark Fasheh struct ocfs2_dinode *fe = (struct ocfs2_dinode *) bh->b_data; 700ccd979bdSMark Fasheh struct ocfs2_chain_list *cl; 701ccd979bdSMark Fasheh struct ocfs2_alloc_context *ac = NULL; 7021fabe148SMark Fasheh handle_t *handle = NULL; 7034711954eSTao Ma u16 alloc_rec; 704ccd979bdSMark Fasheh struct buffer_head *bg_bh = NULL; 705ccd979bdSMark Fasheh struct ocfs2_group_desc *bg; 706ccd979bdSMark Fasheh 707ccd979bdSMark Fasheh BUG_ON(ocfs2_is_cluster_bitmap(alloc_inode)); 708ccd979bdSMark Fasheh 709ccd979bdSMark Fasheh cl = &fe->id2.i_chain; 7101187c968SJoel Becker status = ocfs2_reserve_clusters_with_limit(osb, 711ccd979bdSMark Fasheh le16_to_cpu(cl->cl_cpg), 71260ca81e8STao Ma max_block, flags, &ac); 713ccd979bdSMark Fasheh if (status < 0) { 714ccd979bdSMark Fasheh if (status != -ENOSPC) 715ccd979bdSMark Fasheh mlog_errno(status); 716ccd979bdSMark Fasheh goto bail; 717ccd979bdSMark Fasheh } 718ccd979bdSMark Fasheh 719ccd979bdSMark Fasheh credits = ocfs2_calc_group_alloc_credits(osb->sb, 720ccd979bdSMark Fasheh le16_to_cpu(cl->cl_cpg)); 72165eff9ccSMark Fasheh handle = ocfs2_start_trans(osb, credits); 722ccd979bdSMark Fasheh if (IS_ERR(handle)) { 723ccd979bdSMark Fasheh status = PTR_ERR(handle); 724ccd979bdSMark Fasheh handle = NULL; 725ccd979bdSMark Fasheh mlog_errno(status); 726ccd979bdSMark Fasheh goto bail; 727ccd979bdSMark Fasheh } 728ccd979bdSMark Fasheh 729feb473a6STao Ma if (last_alloc_group && *last_alloc_group != 0) { 7302f73e135STao Ma trace_ocfs2_block_group_alloc( 731feb473a6STao Ma (unsigned long long)*last_alloc_group); 732feb473a6STao Ma ac->ac_last_group = *last_alloc_group; 733feb473a6STao Ma } 734798db35fSJoel Becker 735798db35fSJoel Becker bg_bh = ocfs2_block_group_alloc_contig(osb, handle, alloc_inode, 736798db35fSJoel Becker ac, cl); 737798db35fSJoel Becker if (IS_ERR(bg_bh) && (PTR_ERR(bg_bh) == -ENOSPC)) 738798db35fSJoel Becker bg_bh = ocfs2_block_group_alloc_discontig(handle, 739798db35fSJoel Becker alloc_inode, 7408b06bc59SJoel Becker ac, cl); 741798db35fSJoel Becker if (IS_ERR(bg_bh)) { 742798db35fSJoel Becker status = PTR_ERR(bg_bh); 743798db35fSJoel Becker bg_bh = NULL; 744ccd979bdSMark Fasheh if (status != -ENOSPC) 745ccd979bdSMark Fasheh mlog_errno(status); 746ccd979bdSMark Fasheh goto bail; 747ccd979bdSMark Fasheh } 748ccd979bdSMark Fasheh bg = (struct ocfs2_group_desc *) bg_bh->b_data; 749ccd979bdSMark Fasheh 7500cf2f763SJoel Becker status = ocfs2_journal_access_di(handle, INODE_CACHE(alloc_inode), 751ccd979bdSMark Fasheh bh, OCFS2_JOURNAL_ACCESS_WRITE); 752ccd979bdSMark Fasheh if (status < 0) { 753ccd979bdSMark Fasheh mlog_errno(status); 754ccd979bdSMark Fasheh goto bail; 755ccd979bdSMark Fasheh } 756ccd979bdSMark Fasheh 7574711954eSTao Ma alloc_rec = le16_to_cpu(bg->bg_chain); 7584711954eSTao Ma le32_add_cpu(&cl->cl_recs[alloc_rec].c_free, 759ccd979bdSMark Fasheh le16_to_cpu(bg->bg_free_bits_count)); 7604711954eSTao Ma le32_add_cpu(&cl->cl_recs[alloc_rec].c_total, 761798db35fSJoel Becker le16_to_cpu(bg->bg_bits)); 7620a463b74STao Ma cl->cl_recs[alloc_rec].c_blkno = bg->bg_blkno; 763ccd979bdSMark Fasheh if (le16_to_cpu(cl->cl_next_free_rec) < le16_to_cpu(cl->cl_count)) 764ccd979bdSMark Fasheh le16_add_cpu(&cl->cl_next_free_rec, 1); 765ccd979bdSMark Fasheh 766ccd979bdSMark Fasheh le32_add_cpu(&fe->id1.bitmap1.i_used, le16_to_cpu(bg->bg_bits) - 767ccd979bdSMark Fasheh le16_to_cpu(bg->bg_free_bits_count)); 768ccd979bdSMark Fasheh le32_add_cpu(&fe->id1.bitmap1.i_total, le16_to_cpu(bg->bg_bits)); 769ccd979bdSMark Fasheh le32_add_cpu(&fe->i_clusters, le16_to_cpu(cl->cl_cpg)); 770ccd979bdSMark Fasheh 771ec20cec7SJoel Becker ocfs2_journal_dirty(handle, bh); 772ccd979bdSMark Fasheh 773ccd979bdSMark Fasheh spin_lock(&OCFS2_I(alloc_inode)->ip_lock); 774ccd979bdSMark Fasheh OCFS2_I(alloc_inode)->ip_clusters = le32_to_cpu(fe->i_clusters); 775ccd979bdSMark Fasheh fe->i_size = cpu_to_le64(ocfs2_clusters_to_bytes(alloc_inode->i_sb, 776ccd979bdSMark Fasheh le32_to_cpu(fe->i_clusters))); 777ccd979bdSMark Fasheh spin_unlock(&OCFS2_I(alloc_inode)->ip_lock); 778ccd979bdSMark Fasheh i_size_write(alloc_inode, le64_to_cpu(fe->i_size)); 7798110b073SMark Fasheh alloc_inode->i_blocks = ocfs2_inode_sector_count(alloc_inode); 780ccd979bdSMark Fasheh 781ccd979bdSMark Fasheh status = 0; 782feb473a6STao Ma 783feb473a6STao Ma /* save the new last alloc group so that the caller can cache it. */ 784feb473a6STao Ma if (last_alloc_group) 785feb473a6STao Ma *last_alloc_group = ac->ac_last_group; 786feb473a6STao Ma 787ccd979bdSMark Fasheh bail: 788ccd979bdSMark Fasheh if (handle) 78902dc1af4SMark Fasheh ocfs2_commit_trans(osb, handle); 790ccd979bdSMark Fasheh 791ccd979bdSMark Fasheh if (ac) 792ccd979bdSMark Fasheh ocfs2_free_alloc_context(ac); 793ccd979bdSMark Fasheh 794ccd979bdSMark Fasheh brelse(bg_bh); 795ccd979bdSMark Fasheh 796c1e8d35eSTao Ma if (status) 797c1e8d35eSTao Ma mlog_errno(status); 798ccd979bdSMark Fasheh return status; 799ccd979bdSMark Fasheh } 800ccd979bdSMark Fasheh 801ccd979bdSMark Fasheh static int ocfs2_reserve_suballoc_bits(struct ocfs2_super *osb, 802da5cbf2fSMark Fasheh struct ocfs2_alloc_context *ac, 803da5cbf2fSMark Fasheh int type, 804ffda89a3STao Ma u32 slot, 805feb473a6STao Ma u64 *last_alloc_group, 80660ca81e8STao Ma int flags) 807ccd979bdSMark Fasheh { 808ccd979bdSMark Fasheh int status; 809ccd979bdSMark Fasheh u32 bits_wanted = ac->ac_bits_wanted; 810da5cbf2fSMark Fasheh struct inode *alloc_inode; 811ccd979bdSMark Fasheh struct buffer_head *bh = NULL; 812ccd979bdSMark Fasheh struct ocfs2_dinode *fe; 813ccd979bdSMark Fasheh u32 free_bits; 814ccd979bdSMark Fasheh 815da5cbf2fSMark Fasheh alloc_inode = ocfs2_get_system_file_inode(osb, type, slot); 816da5cbf2fSMark Fasheh if (!alloc_inode) { 817da5cbf2fSMark Fasheh mlog_errno(-EINVAL); 818da5cbf2fSMark Fasheh return -EINVAL; 819ccd979bdSMark Fasheh } 820ccd979bdSMark Fasheh 821da5cbf2fSMark Fasheh mutex_lock(&alloc_inode->i_mutex); 822da5cbf2fSMark Fasheh 823e63aecb6SMark Fasheh status = ocfs2_inode_lock(alloc_inode, &bh, 1); 824da5cbf2fSMark Fasheh if (status < 0) { 825da5cbf2fSMark Fasheh mutex_unlock(&alloc_inode->i_mutex); 826da5cbf2fSMark Fasheh iput(alloc_inode); 827da5cbf2fSMark Fasheh 828da5cbf2fSMark Fasheh mlog_errno(status); 829da5cbf2fSMark Fasheh return status; 830da5cbf2fSMark Fasheh } 831da5cbf2fSMark Fasheh 832da5cbf2fSMark Fasheh ac->ac_inode = alloc_inode; 833a4a48911STao Ma ac->ac_alloc_slot = slot; 834da5cbf2fSMark Fasheh 835ccd979bdSMark Fasheh fe = (struct ocfs2_dinode *) bh->b_data; 83610995aa2SJoel Becker 83710995aa2SJoel Becker /* The bh was validated by the inode read inside 83810995aa2SJoel Becker * ocfs2_inode_lock(). Any corruption is a code bug. */ 83910995aa2SJoel Becker BUG_ON(!OCFS2_IS_VALID_DINODE(fe)); 84010995aa2SJoel Becker 841ccd979bdSMark Fasheh if (!(fe->i_flags & cpu_to_le32(OCFS2_CHAIN_FL))) { 842b0697053SMark Fasheh ocfs2_error(alloc_inode->i_sb, "Invalid chain allocator %llu", 843b0697053SMark Fasheh (unsigned long long)le64_to_cpu(fe->i_blkno)); 844ccd979bdSMark Fasheh status = -EIO; 845ccd979bdSMark Fasheh goto bail; 846ccd979bdSMark Fasheh } 847ccd979bdSMark Fasheh 848ccd979bdSMark Fasheh free_bits = le32_to_cpu(fe->id1.bitmap1.i_total) - 849ccd979bdSMark Fasheh le32_to_cpu(fe->id1.bitmap1.i_used); 850ccd979bdSMark Fasheh 851ccd979bdSMark Fasheh if (bits_wanted > free_bits) { 852ccd979bdSMark Fasheh /* cluster bitmap never grows */ 853ccd979bdSMark Fasheh if (ocfs2_is_cluster_bitmap(alloc_inode)) { 8542f73e135STao Ma trace_ocfs2_reserve_suballoc_bits_nospc(bits_wanted, 8552f73e135STao Ma free_bits); 856ccd979bdSMark Fasheh status = -ENOSPC; 857ccd979bdSMark Fasheh goto bail; 858ccd979bdSMark Fasheh } 859ccd979bdSMark Fasheh 86060ca81e8STao Ma if (!(flags & ALLOC_NEW_GROUP)) { 8612f73e135STao Ma trace_ocfs2_reserve_suballoc_bits_no_new_group( 862ffda89a3STao Ma slot, bits_wanted, free_bits); 863ffda89a3STao Ma status = -ENOSPC; 864ffda89a3STao Ma goto bail; 865ffda89a3STao Ma } 866ffda89a3STao Ma 8671187c968SJoel Becker status = ocfs2_block_group_alloc(osb, alloc_inode, bh, 868feb473a6STao Ma ac->ac_max_block, 869feb473a6STao Ma last_alloc_group, flags); 870ccd979bdSMark Fasheh if (status < 0) { 871ccd979bdSMark Fasheh if (status != -ENOSPC) 872ccd979bdSMark Fasheh mlog_errno(status); 873ccd979bdSMark Fasheh goto bail; 874ccd979bdSMark Fasheh } 875ccd979bdSMark Fasheh atomic_inc(&osb->alloc_stats.bg_extends); 876ccd979bdSMark Fasheh 877ccd979bdSMark Fasheh /* You should never ask for this much metadata */ 878ccd979bdSMark Fasheh BUG_ON(bits_wanted > 879ccd979bdSMark Fasheh (le32_to_cpu(fe->id1.bitmap1.i_total) 880ccd979bdSMark Fasheh - le32_to_cpu(fe->id1.bitmap1.i_used))); 881ccd979bdSMark Fasheh } 882ccd979bdSMark Fasheh 883ccd979bdSMark Fasheh get_bh(bh); 884ccd979bdSMark Fasheh ac->ac_bh = bh; 885ccd979bdSMark Fasheh bail: 886ccd979bdSMark Fasheh brelse(bh); 887ccd979bdSMark Fasheh 888c1e8d35eSTao Ma if (status) 889c1e8d35eSTao Ma mlog_errno(status); 890ccd979bdSMark Fasheh return status; 891ccd979bdSMark Fasheh } 892ccd979bdSMark Fasheh 893b89c5428STiger Yang static void ocfs2_init_inode_steal_slot(struct ocfs2_super *osb) 894b89c5428STiger Yang { 895b89c5428STiger Yang spin_lock(&osb->osb_lock); 896b89c5428STiger Yang osb->s_inode_steal_slot = OCFS2_INVALID_SLOT; 897b89c5428STiger Yang spin_unlock(&osb->osb_lock); 898b89c5428STiger Yang atomic_set(&osb->s_num_inodes_stolen, 0); 899b89c5428STiger Yang } 900b89c5428STiger Yang 901b89c5428STiger Yang static void ocfs2_init_meta_steal_slot(struct ocfs2_super *osb) 902b89c5428STiger Yang { 903b89c5428STiger Yang spin_lock(&osb->osb_lock); 904b89c5428STiger Yang osb->s_meta_steal_slot = OCFS2_INVALID_SLOT; 905b89c5428STiger Yang spin_unlock(&osb->osb_lock); 906b89c5428STiger Yang atomic_set(&osb->s_num_meta_stolen, 0); 907b89c5428STiger Yang } 908b89c5428STiger Yang 909b89c5428STiger Yang void ocfs2_init_steal_slots(struct ocfs2_super *osb) 910b89c5428STiger Yang { 911b89c5428STiger Yang ocfs2_init_inode_steal_slot(osb); 912b89c5428STiger Yang ocfs2_init_meta_steal_slot(osb); 913b89c5428STiger Yang } 914b89c5428STiger Yang 915b89c5428STiger Yang static void __ocfs2_set_steal_slot(struct ocfs2_super *osb, int slot, int type) 916b89c5428STiger Yang { 917b89c5428STiger Yang spin_lock(&osb->osb_lock); 918b89c5428STiger Yang if (type == INODE_ALLOC_SYSTEM_INODE) 919b89c5428STiger Yang osb->s_inode_steal_slot = slot; 920b89c5428STiger Yang else if (type == EXTENT_ALLOC_SYSTEM_INODE) 921b89c5428STiger Yang osb->s_meta_steal_slot = slot; 922b89c5428STiger Yang spin_unlock(&osb->osb_lock); 923b89c5428STiger Yang } 924b89c5428STiger Yang 925b89c5428STiger Yang static int __ocfs2_get_steal_slot(struct ocfs2_super *osb, int type) 926b89c5428STiger Yang { 927b89c5428STiger Yang int slot = OCFS2_INVALID_SLOT; 928b89c5428STiger Yang 929b89c5428STiger Yang spin_lock(&osb->osb_lock); 930b89c5428STiger Yang if (type == INODE_ALLOC_SYSTEM_INODE) 931b89c5428STiger Yang slot = osb->s_inode_steal_slot; 932b89c5428STiger Yang else if (type == EXTENT_ALLOC_SYSTEM_INODE) 933b89c5428STiger Yang slot = osb->s_meta_steal_slot; 934b89c5428STiger Yang spin_unlock(&osb->osb_lock); 935b89c5428STiger Yang 936b89c5428STiger Yang return slot; 937b89c5428STiger Yang } 938b89c5428STiger Yang 939b89c5428STiger Yang static int ocfs2_get_inode_steal_slot(struct ocfs2_super *osb) 940b89c5428STiger Yang { 941b89c5428STiger Yang return __ocfs2_get_steal_slot(osb, INODE_ALLOC_SYSTEM_INODE); 942b89c5428STiger Yang } 943b89c5428STiger Yang 944b89c5428STiger Yang static int ocfs2_get_meta_steal_slot(struct ocfs2_super *osb) 945b89c5428STiger Yang { 946b89c5428STiger Yang return __ocfs2_get_steal_slot(osb, EXTENT_ALLOC_SYSTEM_INODE); 947b89c5428STiger Yang } 948b89c5428STiger Yang 949b89c5428STiger Yang static int ocfs2_steal_resource(struct ocfs2_super *osb, 950b89c5428STiger Yang struct ocfs2_alloc_context *ac, 951b89c5428STiger Yang int type) 952b89c5428STiger Yang { 953b89c5428STiger Yang int i, status = -ENOSPC; 954b89c5428STiger Yang int slot = __ocfs2_get_steal_slot(osb, type); 955b89c5428STiger Yang 956b89c5428STiger Yang /* Start to steal resource from the first slot after ours. */ 957b89c5428STiger Yang if (slot == OCFS2_INVALID_SLOT) 958b89c5428STiger Yang slot = osb->slot_num + 1; 959b89c5428STiger Yang 960b89c5428STiger Yang for (i = 0; i < osb->max_slots; i++, slot++) { 961b89c5428STiger Yang if (slot == osb->max_slots) 962b89c5428STiger Yang slot = 0; 963b89c5428STiger Yang 964b89c5428STiger Yang if (slot == osb->slot_num) 965b89c5428STiger Yang continue; 966b89c5428STiger Yang 967b89c5428STiger Yang status = ocfs2_reserve_suballoc_bits(osb, ac, 968b89c5428STiger Yang type, 969b89c5428STiger Yang (u32)slot, NULL, 970b89c5428STiger Yang NOT_ALLOC_NEW_GROUP); 971b89c5428STiger Yang if (status >= 0) { 972b89c5428STiger Yang __ocfs2_set_steal_slot(osb, slot, type); 973b89c5428STiger Yang break; 974b89c5428STiger Yang } 975b89c5428STiger Yang 976b89c5428STiger Yang ocfs2_free_ac_resource(ac); 977b89c5428STiger Yang } 978b89c5428STiger Yang 979b89c5428STiger Yang return status; 980b89c5428STiger Yang } 981b89c5428STiger Yang 982b89c5428STiger Yang static int ocfs2_steal_inode(struct ocfs2_super *osb, 983b89c5428STiger Yang struct ocfs2_alloc_context *ac) 984b89c5428STiger Yang { 985b89c5428STiger Yang return ocfs2_steal_resource(osb, ac, INODE_ALLOC_SYSTEM_INODE); 986b89c5428STiger Yang } 987b89c5428STiger Yang 988b89c5428STiger Yang static int ocfs2_steal_meta(struct ocfs2_super *osb, 989b89c5428STiger Yang struct ocfs2_alloc_context *ac) 990b89c5428STiger Yang { 991b89c5428STiger Yang return ocfs2_steal_resource(osb, ac, EXTENT_ALLOC_SYSTEM_INODE); 992b89c5428STiger Yang } 993b89c5428STiger Yang 994cf1d6c76STiger Yang int ocfs2_reserve_new_metadata_blocks(struct ocfs2_super *osb, 995cf1d6c76STiger Yang int blocks, 996ccd979bdSMark Fasheh struct ocfs2_alloc_context **ac) 997ccd979bdSMark Fasheh { 998ccd979bdSMark Fasheh int status; 999b89c5428STiger Yang int slot = ocfs2_get_meta_steal_slot(osb); 1000ccd979bdSMark Fasheh 1001cd861280SRobert P. J. Day *ac = kzalloc(sizeof(struct ocfs2_alloc_context), GFP_KERNEL); 1002ccd979bdSMark Fasheh if (!(*ac)) { 1003ccd979bdSMark Fasheh status = -ENOMEM; 1004ccd979bdSMark Fasheh mlog_errno(status); 1005ccd979bdSMark Fasheh goto bail; 1006ccd979bdSMark Fasheh } 1007ccd979bdSMark Fasheh 1008cf1d6c76STiger Yang (*ac)->ac_bits_wanted = blocks; 1009ccd979bdSMark Fasheh (*ac)->ac_which = OCFS2_AC_USE_META; 1010ccd979bdSMark Fasheh (*ac)->ac_group_search = ocfs2_block_group_search; 1011ccd979bdSMark Fasheh 1012b89c5428STiger Yang if (slot != OCFS2_INVALID_SLOT && 1013b89c5428STiger Yang atomic_read(&osb->s_num_meta_stolen) < OCFS2_MAX_TO_STEAL) 1014b89c5428STiger Yang goto extent_steal; 1015b89c5428STiger Yang 1016b89c5428STiger Yang atomic_set(&osb->s_num_meta_stolen, 0); 1017da5cbf2fSMark Fasheh status = ocfs2_reserve_suballoc_bits(osb, (*ac), 1018ffda89a3STao Ma EXTENT_ALLOC_SYSTEM_INODE, 1019b89c5428STiger Yang (u32)osb->slot_num, NULL, 102033d5d380SMark Fasheh ALLOC_GROUPS_FROM_GLOBAL|ALLOC_NEW_GROUP); 1021b89c5428STiger Yang 1022b89c5428STiger Yang 1023b89c5428STiger Yang if (status >= 0) { 1024b89c5428STiger Yang status = 0; 1025b89c5428STiger Yang if (slot != OCFS2_INVALID_SLOT) 1026b89c5428STiger Yang ocfs2_init_meta_steal_slot(osb); 1027b89c5428STiger Yang goto bail; 1028b89c5428STiger Yang } else if (status < 0 && status != -ENOSPC) { 1029b89c5428STiger Yang mlog_errno(status); 1030b89c5428STiger Yang goto bail; 1031b89c5428STiger Yang } 1032b89c5428STiger Yang 1033b89c5428STiger Yang ocfs2_free_ac_resource(*ac); 1034b89c5428STiger Yang 1035b89c5428STiger Yang extent_steal: 1036b89c5428STiger Yang status = ocfs2_steal_meta(osb, *ac); 1037b89c5428STiger Yang atomic_inc(&osb->s_num_meta_stolen); 1038ccd979bdSMark Fasheh if (status < 0) { 1039ccd979bdSMark Fasheh if (status != -ENOSPC) 1040ccd979bdSMark Fasheh mlog_errno(status); 1041ccd979bdSMark Fasheh goto bail; 1042ccd979bdSMark Fasheh } 1043ccd979bdSMark Fasheh 1044ccd979bdSMark Fasheh status = 0; 1045ccd979bdSMark Fasheh bail: 1046ccd979bdSMark Fasheh if ((status < 0) && *ac) { 1047ccd979bdSMark Fasheh ocfs2_free_alloc_context(*ac); 1048ccd979bdSMark Fasheh *ac = NULL; 1049ccd979bdSMark Fasheh } 1050ccd979bdSMark Fasheh 1051c1e8d35eSTao Ma if (status) 1052c1e8d35eSTao Ma mlog_errno(status); 1053ccd979bdSMark Fasheh return status; 1054ccd979bdSMark Fasheh } 1055ccd979bdSMark Fasheh 1056cf1d6c76STiger Yang int ocfs2_reserve_new_metadata(struct ocfs2_super *osb, 1057cf1d6c76STiger Yang struct ocfs2_extent_list *root_el, 1058cf1d6c76STiger Yang struct ocfs2_alloc_context **ac) 1059cf1d6c76STiger Yang { 1060cf1d6c76STiger Yang return ocfs2_reserve_new_metadata_blocks(osb, 1061cf1d6c76STiger Yang ocfs2_extend_meta_needed(root_el), 1062cf1d6c76STiger Yang ac); 1063cf1d6c76STiger Yang } 1064cf1d6c76STiger Yang 1065ccd979bdSMark Fasheh int ocfs2_reserve_new_inode(struct ocfs2_super *osb, 1066ccd979bdSMark Fasheh struct ocfs2_alloc_context **ac) 1067ccd979bdSMark Fasheh { 1068ccd979bdSMark Fasheh int status; 1069b89c5428STiger Yang int slot = ocfs2_get_inode_steal_slot(osb); 1070feb473a6STao Ma u64 alloc_group; 1071ccd979bdSMark Fasheh 1072cd861280SRobert P. J. Day *ac = kzalloc(sizeof(struct ocfs2_alloc_context), GFP_KERNEL); 1073ccd979bdSMark Fasheh if (!(*ac)) { 1074ccd979bdSMark Fasheh status = -ENOMEM; 1075ccd979bdSMark Fasheh mlog_errno(status); 1076ccd979bdSMark Fasheh goto bail; 1077ccd979bdSMark Fasheh } 1078ccd979bdSMark Fasheh 1079ccd979bdSMark Fasheh (*ac)->ac_bits_wanted = 1; 1080ccd979bdSMark Fasheh (*ac)->ac_which = OCFS2_AC_USE_INODE; 1081ccd979bdSMark Fasheh 1082ccd979bdSMark Fasheh (*ac)->ac_group_search = ocfs2_block_group_search; 1083ccd979bdSMark Fasheh 10844d0ddb2cSTao Ma /* 10851187c968SJoel Becker * stat(2) can't handle i_ino > 32bits, so we tell the 10861187c968SJoel Becker * lower levels not to allocate us a block group past that 108712462f1dSJoel Becker * limit. The 'inode64' mount option avoids this behavior. 10881187c968SJoel Becker */ 108912462f1dSJoel Becker if (!(osb->s_mount_opt & OCFS2_MOUNT_INODE64)) 10901187c968SJoel Becker (*ac)->ac_max_block = (u32)~0U; 10911187c968SJoel Becker 10921187c968SJoel Becker /* 10934d0ddb2cSTao Ma * slot is set when we successfully steal inode from other nodes. 10944d0ddb2cSTao Ma * It is reset in 3 places: 10954d0ddb2cSTao Ma * 1. when we flush the truncate log 10964d0ddb2cSTao Ma * 2. when we complete local alloc recovery. 10974d0ddb2cSTao Ma * 3. when we successfully allocate from our own slot. 10984d0ddb2cSTao Ma * After it is set, we will go on stealing inodes until we find the 10994d0ddb2cSTao Ma * need to check our slots to see whether there is some space for us. 11004d0ddb2cSTao Ma */ 11014d0ddb2cSTao Ma if (slot != OCFS2_INVALID_SLOT && 1102b89c5428STiger Yang atomic_read(&osb->s_num_inodes_stolen) < OCFS2_MAX_TO_STEAL) 11034d0ddb2cSTao Ma goto inode_steal; 11044d0ddb2cSTao Ma 11054d0ddb2cSTao Ma atomic_set(&osb->s_num_inodes_stolen, 0); 1106feb473a6STao Ma alloc_group = osb->osb_inode_alloc_group; 1107da5cbf2fSMark Fasheh status = ocfs2_reserve_suballoc_bits(osb, *ac, 1108da5cbf2fSMark Fasheh INODE_ALLOC_SYSTEM_INODE, 1109b89c5428STiger Yang (u32)osb->slot_num, 1110feb473a6STao Ma &alloc_group, 111160ca81e8STao Ma ALLOC_NEW_GROUP | 111260ca81e8STao Ma ALLOC_GROUPS_FROM_GLOBAL); 11134d0ddb2cSTao Ma if (status >= 0) { 11144d0ddb2cSTao Ma status = 0; 11154d0ddb2cSTao Ma 1116feb473a6STao Ma spin_lock(&osb->osb_lock); 1117feb473a6STao Ma osb->osb_inode_alloc_group = alloc_group; 1118feb473a6STao Ma spin_unlock(&osb->osb_lock); 11192f73e135STao Ma trace_ocfs2_reserve_new_inode_new_group( 11202f73e135STao Ma (unsigned long long)alloc_group); 1121feb473a6STao Ma 11224d0ddb2cSTao Ma /* 11234d0ddb2cSTao Ma * Some inodes must be freed by us, so try to allocate 11244d0ddb2cSTao Ma * from our own next time. 11254d0ddb2cSTao Ma */ 11264d0ddb2cSTao Ma if (slot != OCFS2_INVALID_SLOT) 11274d0ddb2cSTao Ma ocfs2_init_inode_steal_slot(osb); 11284d0ddb2cSTao Ma goto bail; 11294d0ddb2cSTao Ma } else if (status < 0 && status != -ENOSPC) { 11304d0ddb2cSTao Ma mlog_errno(status); 11314d0ddb2cSTao Ma goto bail; 11324d0ddb2cSTao Ma } 11334d0ddb2cSTao Ma 11344d0ddb2cSTao Ma ocfs2_free_ac_resource(*ac); 11354d0ddb2cSTao Ma 11364d0ddb2cSTao Ma inode_steal: 1137b89c5428STiger Yang status = ocfs2_steal_inode(osb, *ac); 11384d0ddb2cSTao Ma atomic_inc(&osb->s_num_inodes_stolen); 1139ccd979bdSMark Fasheh if (status < 0) { 1140ccd979bdSMark Fasheh if (status != -ENOSPC) 1141ccd979bdSMark Fasheh mlog_errno(status); 1142ccd979bdSMark Fasheh goto bail; 1143ccd979bdSMark Fasheh } 1144ccd979bdSMark Fasheh 1145ccd979bdSMark Fasheh status = 0; 1146ccd979bdSMark Fasheh bail: 1147ccd979bdSMark Fasheh if ((status < 0) && *ac) { 1148ccd979bdSMark Fasheh ocfs2_free_alloc_context(*ac); 1149ccd979bdSMark Fasheh *ac = NULL; 1150ccd979bdSMark Fasheh } 1151ccd979bdSMark Fasheh 1152c1e8d35eSTao Ma if (status) 1153c1e8d35eSTao Ma mlog_errno(status); 1154ccd979bdSMark Fasheh return status; 1155ccd979bdSMark Fasheh } 1156ccd979bdSMark Fasheh 1157ccd979bdSMark Fasheh /* local alloc code has to do the same thing, so rather than do this 1158ccd979bdSMark Fasheh * twice.. */ 1159ccd979bdSMark Fasheh int ocfs2_reserve_cluster_bitmap_bits(struct ocfs2_super *osb, 1160ccd979bdSMark Fasheh struct ocfs2_alloc_context *ac) 1161ccd979bdSMark Fasheh { 1162ccd979bdSMark Fasheh int status; 1163ccd979bdSMark Fasheh 1164ccd979bdSMark Fasheh ac->ac_which = OCFS2_AC_USE_MAIN; 1165ccd979bdSMark Fasheh ac->ac_group_search = ocfs2_cluster_group_search; 1166ccd979bdSMark Fasheh 1167da5cbf2fSMark Fasheh status = ocfs2_reserve_suballoc_bits(osb, ac, 1168da5cbf2fSMark Fasheh GLOBAL_BITMAP_SYSTEM_INODE, 1169feb473a6STao Ma OCFS2_INVALID_SLOT, NULL, 1170ffda89a3STao Ma ALLOC_NEW_GROUP); 1171da5cbf2fSMark Fasheh if (status < 0 && status != -ENOSPC) { 1172ccd979bdSMark Fasheh mlog_errno(status); 1173da5cbf2fSMark Fasheh goto bail; 1174da5cbf2fSMark Fasheh } 1175da5cbf2fSMark Fasheh 1176ccd979bdSMark Fasheh bail: 1177ccd979bdSMark Fasheh return status; 1178ccd979bdSMark Fasheh } 1179ccd979bdSMark Fasheh 1180ccd979bdSMark Fasheh /* Callers don't need to care which bitmap (local alloc or main) to 1181ccd979bdSMark Fasheh * use so we figure it out for them, but unfortunately this clutters 1182ccd979bdSMark Fasheh * things a bit. */ 11831187c968SJoel Becker static int ocfs2_reserve_clusters_with_limit(struct ocfs2_super *osb, 11841187c968SJoel Becker u32 bits_wanted, u64 max_block, 118560ca81e8STao Ma int flags, 1186ccd979bdSMark Fasheh struct ocfs2_alloc_context **ac) 1187ccd979bdSMark Fasheh { 1188ccd979bdSMark Fasheh int status; 1189ccd979bdSMark Fasheh 1190cd861280SRobert P. J. Day *ac = kzalloc(sizeof(struct ocfs2_alloc_context), GFP_KERNEL); 1191ccd979bdSMark Fasheh if (!(*ac)) { 1192ccd979bdSMark Fasheh status = -ENOMEM; 1193ccd979bdSMark Fasheh mlog_errno(status); 1194ccd979bdSMark Fasheh goto bail; 1195ccd979bdSMark Fasheh } 1196ccd979bdSMark Fasheh 1197ccd979bdSMark Fasheh (*ac)->ac_bits_wanted = bits_wanted; 11981187c968SJoel Becker (*ac)->ac_max_block = max_block; 1199ccd979bdSMark Fasheh 1200ccd979bdSMark Fasheh status = -ENOSPC; 120160ca81e8STao Ma if (!(flags & ALLOC_GROUPS_FROM_GLOBAL) && 120260ca81e8STao Ma ocfs2_alloc_should_use_local(osb, bits_wanted)) { 1203ccd979bdSMark Fasheh status = ocfs2_reserve_local_alloc_bits(osb, 1204ccd979bdSMark Fasheh bits_wanted, 1205ccd979bdSMark Fasheh *ac); 1206a57c8fd2SMark Fasheh if ((status < 0) && (status != -ENOSPC)) { 1207ccd979bdSMark Fasheh mlog_errno(status); 1208ccd979bdSMark Fasheh goto bail; 1209ccd979bdSMark Fasheh } 1210ccd979bdSMark Fasheh } 1211ccd979bdSMark Fasheh 1212ccd979bdSMark Fasheh if (status == -ENOSPC) { 1213ccd979bdSMark Fasheh status = ocfs2_reserve_cluster_bitmap_bits(osb, *ac); 1214ccd979bdSMark Fasheh if (status < 0) { 1215ccd979bdSMark Fasheh if (status != -ENOSPC) 1216ccd979bdSMark Fasheh mlog_errno(status); 1217ccd979bdSMark Fasheh goto bail; 1218ccd979bdSMark Fasheh } 1219ccd979bdSMark Fasheh } 1220ccd979bdSMark Fasheh 1221ccd979bdSMark Fasheh status = 0; 1222ccd979bdSMark Fasheh bail: 1223ccd979bdSMark Fasheh if ((status < 0) && *ac) { 1224ccd979bdSMark Fasheh ocfs2_free_alloc_context(*ac); 1225ccd979bdSMark Fasheh *ac = NULL; 1226ccd979bdSMark Fasheh } 1227ccd979bdSMark Fasheh 1228c1e8d35eSTao Ma if (status) 1229c1e8d35eSTao Ma mlog_errno(status); 1230ccd979bdSMark Fasheh return status; 1231ccd979bdSMark Fasheh } 1232ccd979bdSMark Fasheh 12331187c968SJoel Becker int ocfs2_reserve_clusters(struct ocfs2_super *osb, 12341187c968SJoel Becker u32 bits_wanted, 12351187c968SJoel Becker struct ocfs2_alloc_context **ac) 12361187c968SJoel Becker { 123760ca81e8STao Ma return ocfs2_reserve_clusters_with_limit(osb, bits_wanted, 0, 123860ca81e8STao Ma ALLOC_NEW_GROUP, ac); 12391187c968SJoel Becker } 12401187c968SJoel Becker 1241ccd979bdSMark Fasheh /* 1242ccd979bdSMark Fasheh * More or less lifted from ext3. I'll leave their description below: 1243ccd979bdSMark Fasheh * 1244ccd979bdSMark Fasheh * "For ext3 allocations, we must not reuse any blocks which are 1245ccd979bdSMark Fasheh * allocated in the bitmap buffer's "last committed data" copy. This 1246ccd979bdSMark Fasheh * prevents deletes from freeing up the page for reuse until we have 1247ccd979bdSMark Fasheh * committed the delete transaction. 1248ccd979bdSMark Fasheh * 1249ccd979bdSMark Fasheh * If we didn't do this, then deleting something and reallocating it as 1250ccd979bdSMark Fasheh * data would allow the old block to be overwritten before the 1251ccd979bdSMark Fasheh * transaction committed (because we force data to disk before commit). 1252ccd979bdSMark Fasheh * This would lead to corruption if we crashed between overwriting the 1253ccd979bdSMark Fasheh * data and committing the delete. 1254ccd979bdSMark Fasheh * 1255ccd979bdSMark Fasheh * @@@ We may want to make this allocation behaviour conditional on 1256ccd979bdSMark Fasheh * data-writes at some point, and disable it for metadata allocations or 1257ccd979bdSMark Fasheh * sync-data inodes." 1258ccd979bdSMark Fasheh * 1259ccd979bdSMark Fasheh * Note: OCFS2 already does this differently for metadata vs data 1260c78bad11SJoe Perches * allocations, as those bitmaps are separate and undo access is never 1261ccd979bdSMark Fasheh * called on a metadata group descriptor. 1262ccd979bdSMark Fasheh */ 1263ccd979bdSMark Fasheh static int ocfs2_test_bg_bit_allocatable(struct buffer_head *bg_bh, 1264ccd979bdSMark Fasheh int nr) 1265ccd979bdSMark Fasheh { 1266ccd979bdSMark Fasheh struct ocfs2_group_desc *bg = (struct ocfs2_group_desc *) bg_bh->b_data; 126794e41ecfSSunil Mushran int ret; 1268ccd979bdSMark Fasheh 1269ccd979bdSMark Fasheh if (ocfs2_test_bit(nr, (unsigned long *)bg->bg_bitmap)) 1270ccd979bdSMark Fasheh return 0; 127194e41ecfSSunil Mushran 127294e41ecfSSunil Mushran if (!buffer_jbd(bg_bh)) 1273ccd979bdSMark Fasheh return 1; 1274ccd979bdSMark Fasheh 127594e41ecfSSunil Mushran jbd_lock_bh_state(bg_bh); 1276ccd979bdSMark Fasheh bg = (struct ocfs2_group_desc *) bh2jh(bg_bh)->b_committed_data; 127794e41ecfSSunil Mushran if (bg) 127894e41ecfSSunil Mushran ret = !ocfs2_test_bit(nr, (unsigned long *)bg->bg_bitmap); 127994e41ecfSSunil Mushran else 128094e41ecfSSunil Mushran ret = 1; 128194e41ecfSSunil Mushran jbd_unlock_bh_state(bg_bh); 128294e41ecfSSunil Mushran 128394e41ecfSSunil Mushran return ret; 1284ccd979bdSMark Fasheh } 1285ccd979bdSMark Fasheh 1286ccd979bdSMark Fasheh static int ocfs2_block_group_find_clear_bits(struct ocfs2_super *osb, 1287ccd979bdSMark Fasheh struct buffer_head *bg_bh, 1288ccd979bdSMark Fasheh unsigned int bits_wanted, 12897bf72edeSMark Fasheh unsigned int total_bits, 12907d1fe093SJoel Becker struct ocfs2_suballoc_result *res) 1291ccd979bdSMark Fasheh { 1292ccd979bdSMark Fasheh void *bitmap; 1293ccd979bdSMark Fasheh u16 best_offset, best_size; 1294ccd979bdSMark Fasheh int offset, start, found, status = 0; 1295ccd979bdSMark Fasheh struct ocfs2_group_desc *bg = (struct ocfs2_group_desc *) bg_bh->b_data; 1296ccd979bdSMark Fasheh 129742035306SJoel Becker /* Callers got this descriptor from 129842035306SJoel Becker * ocfs2_read_group_descriptor(). Any corruption is a code bug. */ 129942035306SJoel Becker BUG_ON(!OCFS2_IS_VALID_GROUP_DESC(bg)); 1300ccd979bdSMark Fasheh 1301ccd979bdSMark Fasheh found = start = best_offset = best_size = 0; 1302ccd979bdSMark Fasheh bitmap = bg->bg_bitmap; 1303ccd979bdSMark Fasheh 13047bf72edeSMark Fasheh while((offset = ocfs2_find_next_zero_bit(bitmap, total_bits, start)) != -1) { 13057bf72edeSMark Fasheh if (offset == total_bits) 1306ccd979bdSMark Fasheh break; 1307ccd979bdSMark Fasheh 1308ccd979bdSMark Fasheh if (!ocfs2_test_bg_bit_allocatable(bg_bh, offset)) { 1309ccd979bdSMark Fasheh /* We found a zero, but we can't use it as it 1310ccd979bdSMark Fasheh * hasn't been put to disk yet! */ 1311ccd979bdSMark Fasheh found = 0; 1312ccd979bdSMark Fasheh start = offset + 1; 1313ccd979bdSMark Fasheh } else if (offset == start) { 1314ccd979bdSMark Fasheh /* we found a zero */ 1315ccd979bdSMark Fasheh found++; 1316ccd979bdSMark Fasheh /* move start to the next bit to test */ 1317ccd979bdSMark Fasheh start++; 1318ccd979bdSMark Fasheh } else { 1319ccd979bdSMark Fasheh /* got a zero after some ones */ 1320ccd979bdSMark Fasheh found = 1; 1321ccd979bdSMark Fasheh start = offset + 1; 1322ccd979bdSMark Fasheh } 1323ccd979bdSMark Fasheh if (found > best_size) { 1324ccd979bdSMark Fasheh best_size = found; 1325ccd979bdSMark Fasheh best_offset = start - found; 1326ccd979bdSMark Fasheh } 1327ccd979bdSMark Fasheh /* we got everything we needed */ 1328ccd979bdSMark Fasheh if (found == bits_wanted) { 1329ccd979bdSMark Fasheh /* mlog(0, "Found it all!\n"); */ 1330ccd979bdSMark Fasheh break; 1331ccd979bdSMark Fasheh } 1332ccd979bdSMark Fasheh } 1333ccd979bdSMark Fasheh 13347d1fe093SJoel Becker if (best_size) { 13357d1fe093SJoel Becker res->sr_bit_offset = best_offset; 13367d1fe093SJoel Becker res->sr_bits = best_size; 1337ccd979bdSMark Fasheh } else { 1338ccd979bdSMark Fasheh status = -ENOSPC; 1339ccd979bdSMark Fasheh /* No error log here -- see the comment above 1340ccd979bdSMark Fasheh * ocfs2_test_bg_bit_allocatable */ 1341ccd979bdSMark Fasheh } 1342ccd979bdSMark Fasheh 1343ccd979bdSMark Fasheh return status; 1344ccd979bdSMark Fasheh } 1345ccd979bdSMark Fasheh 13461fabe148SMark Fasheh static inline int ocfs2_block_group_set_bits(handle_t *handle, 1347ccd979bdSMark Fasheh struct inode *alloc_inode, 1348ccd979bdSMark Fasheh struct ocfs2_group_desc *bg, 1349ccd979bdSMark Fasheh struct buffer_head *group_bh, 1350ccd979bdSMark Fasheh unsigned int bit_off, 1351ccd979bdSMark Fasheh unsigned int num_bits) 1352ccd979bdSMark Fasheh { 1353ccd979bdSMark Fasheh int status; 1354ccd979bdSMark Fasheh void *bitmap = bg->bg_bitmap; 1355ccd979bdSMark Fasheh int journal_type = OCFS2_JOURNAL_ACCESS_WRITE; 1356ccd979bdSMark Fasheh 135742035306SJoel Becker /* All callers get the descriptor via 135842035306SJoel Becker * ocfs2_read_group_descriptor(). Any corruption is a code bug. */ 135942035306SJoel Becker BUG_ON(!OCFS2_IS_VALID_GROUP_DESC(bg)); 1360ccd979bdSMark Fasheh BUG_ON(le16_to_cpu(bg->bg_free_bits_count) < num_bits); 1361ccd979bdSMark Fasheh 13622f73e135STao Ma trace_ocfs2_block_group_set_bits(bit_off, num_bits); 1363ccd979bdSMark Fasheh 1364ccd979bdSMark Fasheh if (ocfs2_is_cluster_bitmap(alloc_inode)) 1365ccd979bdSMark Fasheh journal_type = OCFS2_JOURNAL_ACCESS_UNDO; 1366ccd979bdSMark Fasheh 136713723d00SJoel Becker status = ocfs2_journal_access_gd(handle, 13680cf2f763SJoel Becker INODE_CACHE(alloc_inode), 1369ccd979bdSMark Fasheh group_bh, 1370ccd979bdSMark Fasheh journal_type); 1371ccd979bdSMark Fasheh if (status < 0) { 1372ccd979bdSMark Fasheh mlog_errno(status); 1373ccd979bdSMark Fasheh goto bail; 1374ccd979bdSMark Fasheh } 1375ccd979bdSMark Fasheh 1376ccd979bdSMark Fasheh le16_add_cpu(&bg->bg_free_bits_count, -num_bits); 13779b5cd10eSSrinivas Eeda if (le16_to_cpu(bg->bg_free_bits_count) > le16_to_cpu(bg->bg_bits)) { 13789b5cd10eSSrinivas Eeda ocfs2_error(alloc_inode->i_sb, "Group descriptor # %llu has bit" 13799b5cd10eSSrinivas Eeda " count %u but claims %u are freed. num_bits %d", 13809b5cd10eSSrinivas Eeda (unsigned long long)le64_to_cpu(bg->bg_blkno), 13819b5cd10eSSrinivas Eeda le16_to_cpu(bg->bg_bits), 13829b5cd10eSSrinivas Eeda le16_to_cpu(bg->bg_free_bits_count), num_bits); 13839b5cd10eSSrinivas Eeda return -EROFS; 13849b5cd10eSSrinivas Eeda } 1385ccd979bdSMark Fasheh while(num_bits--) 1386ccd979bdSMark Fasheh ocfs2_set_bit(bit_off++, bitmap); 1387ccd979bdSMark Fasheh 1388ec20cec7SJoel Becker ocfs2_journal_dirty(handle, group_bh); 1389ccd979bdSMark Fasheh 1390ccd979bdSMark Fasheh bail: 1391c1e8d35eSTao Ma if (status) 1392c1e8d35eSTao Ma mlog_errno(status); 1393ccd979bdSMark Fasheh return status; 1394ccd979bdSMark Fasheh } 1395ccd979bdSMark Fasheh 1396ccd979bdSMark Fasheh /* find the one with the most empty bits */ 1397ccd979bdSMark Fasheh static inline u16 ocfs2_find_victim_chain(struct ocfs2_chain_list *cl) 1398ccd979bdSMark Fasheh { 1399ccd979bdSMark Fasheh u16 curr, best; 1400ccd979bdSMark Fasheh 1401ccd979bdSMark Fasheh BUG_ON(!cl->cl_next_free_rec); 1402ccd979bdSMark Fasheh 1403ccd979bdSMark Fasheh best = curr = 0; 1404ccd979bdSMark Fasheh while (curr < le16_to_cpu(cl->cl_next_free_rec)) { 1405ccd979bdSMark Fasheh if (le32_to_cpu(cl->cl_recs[curr].c_free) > 1406ccd979bdSMark Fasheh le32_to_cpu(cl->cl_recs[best].c_free)) 1407ccd979bdSMark Fasheh best = curr; 1408ccd979bdSMark Fasheh curr++; 1409ccd979bdSMark Fasheh } 1410ccd979bdSMark Fasheh 1411ccd979bdSMark Fasheh BUG_ON(best >= le16_to_cpu(cl->cl_next_free_rec)); 1412ccd979bdSMark Fasheh return best; 1413ccd979bdSMark Fasheh } 1414ccd979bdSMark Fasheh 14151fabe148SMark Fasheh static int ocfs2_relink_block_group(handle_t *handle, 1416ccd979bdSMark Fasheh struct inode *alloc_inode, 1417ccd979bdSMark Fasheh struct buffer_head *fe_bh, 1418ccd979bdSMark Fasheh struct buffer_head *bg_bh, 1419ccd979bdSMark Fasheh struct buffer_head *prev_bg_bh, 1420ccd979bdSMark Fasheh u16 chain) 1421ccd979bdSMark Fasheh { 1422ccd979bdSMark Fasheh int status; 1423ccd979bdSMark Fasheh /* there is a really tiny chance the journal calls could fail, 1424ccd979bdSMark Fasheh * but we wouldn't want inconsistent blocks in *any* case. */ 142549309841SJie Liu u64 bg_ptr, prev_bg_ptr; 1426ccd979bdSMark Fasheh struct ocfs2_dinode *fe = (struct ocfs2_dinode *) fe_bh->b_data; 1427ccd979bdSMark Fasheh struct ocfs2_group_desc *bg = (struct ocfs2_group_desc *) bg_bh->b_data; 1428ccd979bdSMark Fasheh struct ocfs2_group_desc *prev_bg = (struct ocfs2_group_desc *) prev_bg_bh->b_data; 1429ccd979bdSMark Fasheh 143042035306SJoel Becker /* The caller got these descriptors from 143142035306SJoel Becker * ocfs2_read_group_descriptor(). Any corruption is a code bug. */ 143242035306SJoel Becker BUG_ON(!OCFS2_IS_VALID_GROUP_DESC(bg)); 143342035306SJoel Becker BUG_ON(!OCFS2_IS_VALID_GROUP_DESC(prev_bg)); 1434ccd979bdSMark Fasheh 14352f73e135STao Ma trace_ocfs2_relink_block_group( 14361ca1a111SMark Fasheh (unsigned long long)le64_to_cpu(fe->i_blkno), chain, 14371ca1a111SMark Fasheh (unsigned long long)le64_to_cpu(bg->bg_blkno), 14381ca1a111SMark Fasheh (unsigned long long)le64_to_cpu(prev_bg->bg_blkno)); 1439ccd979bdSMark Fasheh 1440ccd979bdSMark Fasheh bg_ptr = le64_to_cpu(bg->bg_next_group); 1441ccd979bdSMark Fasheh prev_bg_ptr = le64_to_cpu(prev_bg->bg_next_group); 1442ccd979bdSMark Fasheh 14430cf2f763SJoel Becker status = ocfs2_journal_access_gd(handle, INODE_CACHE(alloc_inode), 14440cf2f763SJoel Becker prev_bg_bh, 1445ccd979bdSMark Fasheh OCFS2_JOURNAL_ACCESS_WRITE); 144625e28921SAndrew Morton if (status < 0) 144749309841SJie Liu goto out; 1448ccd979bdSMark Fasheh 1449ccd979bdSMark Fasheh prev_bg->bg_next_group = bg->bg_next_group; 1450ec20cec7SJoel Becker ocfs2_journal_dirty(handle, prev_bg_bh); 1451ccd979bdSMark Fasheh 14520cf2f763SJoel Becker status = ocfs2_journal_access_gd(handle, INODE_CACHE(alloc_inode), 14530cf2f763SJoel Becker bg_bh, OCFS2_JOURNAL_ACCESS_WRITE); 145425e28921SAndrew Morton if (status < 0) 145549309841SJie Liu goto out_rollback_prev_bg; 1456ccd979bdSMark Fasheh 1457ccd979bdSMark Fasheh bg->bg_next_group = fe->id2.i_chain.cl_recs[chain].c_blkno; 1458ec20cec7SJoel Becker ocfs2_journal_dirty(handle, bg_bh); 1459ccd979bdSMark Fasheh 14600cf2f763SJoel Becker status = ocfs2_journal_access_di(handle, INODE_CACHE(alloc_inode), 14610cf2f763SJoel Becker fe_bh, OCFS2_JOURNAL_ACCESS_WRITE); 146225e28921SAndrew Morton if (status < 0) 146349309841SJie Liu goto out_rollback_bg; 1464ccd979bdSMark Fasheh 1465ccd979bdSMark Fasheh fe->id2.i_chain.cl_recs[chain].c_blkno = bg->bg_blkno; 1466ec20cec7SJoel Becker ocfs2_journal_dirty(handle, fe_bh); 1467ccd979bdSMark Fasheh 146849309841SJie Liu out: 146925e28921SAndrew Morton if (status < 0) 147025e28921SAndrew Morton mlog_errno(status); 147149309841SJie Liu return status; 147242035306SJoel Becker 147349309841SJie Liu out_rollback_bg: 147449309841SJie Liu bg->bg_next_group = cpu_to_le64(bg_ptr); 147549309841SJie Liu out_rollback_prev_bg: 147649309841SJie Liu prev_bg->bg_next_group = cpu_to_le64(prev_bg_ptr); 147725e28921SAndrew Morton goto out; 1478ccd979bdSMark Fasheh } 1479ccd979bdSMark Fasheh 1480ccd979bdSMark Fasheh static inline int ocfs2_block_group_reasonably_empty(struct ocfs2_group_desc *bg, 1481ccd979bdSMark Fasheh u32 wanted) 1482ccd979bdSMark Fasheh { 1483ccd979bdSMark Fasheh return le16_to_cpu(bg->bg_free_bits_count) > wanted; 1484ccd979bdSMark Fasheh } 1485ccd979bdSMark Fasheh 1486ccd979bdSMark Fasheh /* return 0 on success, -ENOSPC to keep searching and any other < 0 1487ccd979bdSMark Fasheh * value on error. */ 1488ccd979bdSMark Fasheh static int ocfs2_cluster_group_search(struct inode *inode, 1489ccd979bdSMark Fasheh struct buffer_head *group_bh, 1490ccd979bdSMark Fasheh u32 bits_wanted, u32 min_bits, 14911187c968SJoel Becker u64 max_block, 14927d1fe093SJoel Becker struct ocfs2_suballoc_result *res) 1493ccd979bdSMark Fasheh { 1494ccd979bdSMark Fasheh int search = -ENOSPC; 1495ccd979bdSMark Fasheh int ret; 14961187c968SJoel Becker u64 blkoff; 14977bf72edeSMark Fasheh struct ocfs2_group_desc *gd = (struct ocfs2_group_desc *) group_bh->b_data; 14989c7af40bSMark Fasheh struct ocfs2_super *osb = OCFS2_SB(inode->i_sb); 14997bf72edeSMark Fasheh unsigned int max_bits, gd_cluster_off; 1500ccd979bdSMark Fasheh 1501ccd979bdSMark Fasheh BUG_ON(!ocfs2_is_cluster_bitmap(inode)); 1502ccd979bdSMark Fasheh 15037bf72edeSMark Fasheh if (gd->bg_free_bits_count) { 15047bf72edeSMark Fasheh max_bits = le16_to_cpu(gd->bg_bits); 15057bf72edeSMark Fasheh 15067bf72edeSMark Fasheh /* Tail groups in cluster bitmaps which aren't cpg 150725985edcSLucas De Marchi * aligned are prone to partial extension by a failed 15087bf72edeSMark Fasheh * fs resize. If the file system resize never got to 15097bf72edeSMark Fasheh * update the dinode cluster count, then we don't want 15107bf72edeSMark Fasheh * to trust any clusters past it, regardless of what 15117bf72edeSMark Fasheh * the group descriptor says. */ 15127bf72edeSMark Fasheh gd_cluster_off = ocfs2_blocks_to_clusters(inode->i_sb, 15137bf72edeSMark Fasheh le64_to_cpu(gd->bg_blkno)); 15147bf72edeSMark Fasheh if ((gd_cluster_off + max_bits) > 15157bf72edeSMark Fasheh OCFS2_I(inode)->ip_clusters) { 15167bf72edeSMark Fasheh max_bits = OCFS2_I(inode)->ip_clusters - gd_cluster_off; 15172f73e135STao Ma trace_ocfs2_cluster_group_search_wrong_max_bits( 15187bf72edeSMark Fasheh (unsigned long long)le64_to_cpu(gd->bg_blkno), 15197bf72edeSMark Fasheh le16_to_cpu(gd->bg_bits), 15207bf72edeSMark Fasheh OCFS2_I(inode)->ip_clusters, max_bits); 15217bf72edeSMark Fasheh } 15227bf72edeSMark Fasheh 1523ccd979bdSMark Fasheh ret = ocfs2_block_group_find_clear_bits(OCFS2_SB(inode->i_sb), 1524ccd979bdSMark Fasheh group_bh, bits_wanted, 15257d1fe093SJoel Becker max_bits, res); 1526ccd979bdSMark Fasheh if (ret) 1527ccd979bdSMark Fasheh return ret; 1528ccd979bdSMark Fasheh 15291187c968SJoel Becker if (max_block) { 15301187c968SJoel Becker blkoff = ocfs2_clusters_to_blocks(inode->i_sb, 15311187c968SJoel Becker gd_cluster_off + 15327d1fe093SJoel Becker res->sr_bit_offset + 15337d1fe093SJoel Becker res->sr_bits); 15342f73e135STao Ma trace_ocfs2_cluster_group_search_max_block( 15351187c968SJoel Becker (unsigned long long)blkoff, 15361187c968SJoel Becker (unsigned long long)max_block); 15371187c968SJoel Becker if (blkoff > max_block) 15381187c968SJoel Becker return -ENOSPC; 15391187c968SJoel Becker } 15401187c968SJoel Becker 1541ccd979bdSMark Fasheh /* ocfs2_block_group_find_clear_bits() might 1542ccd979bdSMark Fasheh * return success, but we still want to return 1543ccd979bdSMark Fasheh * -ENOSPC unless it found the minimum number 1544ccd979bdSMark Fasheh * of bits. */ 15457d1fe093SJoel Becker if (min_bits <= res->sr_bits) 1546ccd979bdSMark Fasheh search = 0; /* success */ 15477d1fe093SJoel Becker else if (res->sr_bits) { 15489c7af40bSMark Fasheh /* 15499c7af40bSMark Fasheh * Don't show bits which we'll be returning 15509c7af40bSMark Fasheh * for allocation to the local alloc bitmap. 15519c7af40bSMark Fasheh */ 15527d1fe093SJoel Becker ocfs2_local_alloc_seen_free_bits(osb, res->sr_bits); 1553ccd979bdSMark Fasheh } 1554ccd979bdSMark Fasheh } 1555ccd979bdSMark Fasheh 1556ccd979bdSMark Fasheh return search; 1557ccd979bdSMark Fasheh } 1558ccd979bdSMark Fasheh 1559ccd979bdSMark Fasheh static int ocfs2_block_group_search(struct inode *inode, 1560ccd979bdSMark Fasheh struct buffer_head *group_bh, 1561ccd979bdSMark Fasheh u32 bits_wanted, u32 min_bits, 15621187c968SJoel Becker u64 max_block, 15637d1fe093SJoel Becker struct ocfs2_suballoc_result *res) 1564ccd979bdSMark Fasheh { 1565ccd979bdSMark Fasheh int ret = -ENOSPC; 15661187c968SJoel Becker u64 blkoff; 1567ccd979bdSMark Fasheh struct ocfs2_group_desc *bg = (struct ocfs2_group_desc *) group_bh->b_data; 1568ccd979bdSMark Fasheh 1569ccd979bdSMark Fasheh BUG_ON(min_bits != 1); 1570ccd979bdSMark Fasheh BUG_ON(ocfs2_is_cluster_bitmap(inode)); 1571ccd979bdSMark Fasheh 15721187c968SJoel Becker if (bg->bg_free_bits_count) { 1573ccd979bdSMark Fasheh ret = ocfs2_block_group_find_clear_bits(OCFS2_SB(inode->i_sb), 1574ccd979bdSMark Fasheh group_bh, bits_wanted, 15757bf72edeSMark Fasheh le16_to_cpu(bg->bg_bits), 15767d1fe093SJoel Becker res); 15771187c968SJoel Becker if (!ret && max_block) { 15787d1fe093SJoel Becker blkoff = le64_to_cpu(bg->bg_blkno) + 15797d1fe093SJoel Becker res->sr_bit_offset + res->sr_bits; 15802f73e135STao Ma trace_ocfs2_block_group_search_max_block( 15811187c968SJoel Becker (unsigned long long)blkoff, 15821187c968SJoel Becker (unsigned long long)max_block); 15831187c968SJoel Becker if (blkoff > max_block) 15841187c968SJoel Becker ret = -ENOSPC; 15851187c968SJoel Becker } 15861187c968SJoel Becker } 1587ccd979bdSMark Fasheh 1588ccd979bdSMark Fasheh return ret; 1589ccd979bdSMark Fasheh } 1590ccd979bdSMark Fasheh 1591883d4caeSMark Fasheh static int ocfs2_alloc_dinode_update_counts(struct inode *inode, 15921fabe148SMark Fasheh handle_t *handle, 1593883d4caeSMark Fasheh struct buffer_head *di_bh, 1594883d4caeSMark Fasheh u32 num_bits, 1595883d4caeSMark Fasheh u16 chain) 1596883d4caeSMark Fasheh { 1597883d4caeSMark Fasheh int ret; 1598883d4caeSMark Fasheh u32 tmp_used; 1599883d4caeSMark Fasheh struct ocfs2_dinode *di = (struct ocfs2_dinode *) di_bh->b_data; 1600883d4caeSMark Fasheh struct ocfs2_chain_list *cl = (struct ocfs2_chain_list *) &di->id2.i_chain; 1601883d4caeSMark Fasheh 16020cf2f763SJoel Becker ret = ocfs2_journal_access_di(handle, INODE_CACHE(inode), di_bh, 1603883d4caeSMark Fasheh OCFS2_JOURNAL_ACCESS_WRITE); 1604883d4caeSMark Fasheh if (ret < 0) { 1605883d4caeSMark Fasheh mlog_errno(ret); 1606883d4caeSMark Fasheh goto out; 1607883d4caeSMark Fasheh } 1608883d4caeSMark Fasheh 1609883d4caeSMark Fasheh tmp_used = le32_to_cpu(di->id1.bitmap1.i_used); 1610883d4caeSMark Fasheh di->id1.bitmap1.i_used = cpu_to_le32(num_bits + tmp_used); 1611883d4caeSMark Fasheh le32_add_cpu(&cl->cl_recs[chain].c_free, -num_bits); 1612ec20cec7SJoel Becker ocfs2_journal_dirty(handle, di_bh); 1613883d4caeSMark Fasheh 1614883d4caeSMark Fasheh out: 1615883d4caeSMark Fasheh return ret; 1616883d4caeSMark Fasheh } 1617883d4caeSMark Fasheh 1618ba206635SJoel Becker static int ocfs2_bg_discontig_fix_by_rec(struct ocfs2_suballoc_result *res, 161913e434cfSJoel Becker struct ocfs2_extent_rec *rec, 162013e434cfSJoel Becker struct ocfs2_chain_list *cl) 162113e434cfSJoel Becker { 162213e434cfSJoel Becker unsigned int bpc = le16_to_cpu(cl->cl_bpc); 162313e434cfSJoel Becker unsigned int bitoff = le32_to_cpu(rec->e_cpos) * bpc; 162472094e43SAl Viro unsigned int bitcount = le16_to_cpu(rec->e_leaf_clusters) * bpc; 162513e434cfSJoel Becker 162613e434cfSJoel Becker if (res->sr_bit_offset < bitoff) 162713e434cfSJoel Becker return 0; 162813e434cfSJoel Becker if (res->sr_bit_offset >= (bitoff + bitcount)) 162913e434cfSJoel Becker return 0; 1630ba206635SJoel Becker res->sr_blkno = le64_to_cpu(rec->e_blkno) + 1631ba206635SJoel Becker (res->sr_bit_offset - bitoff); 163213e434cfSJoel Becker if ((res->sr_bit_offset + res->sr_bits) > (bitoff + bitcount)) 163313e434cfSJoel Becker res->sr_bits = (bitoff + bitcount) - res->sr_bit_offset; 163413e434cfSJoel Becker return 1; 163513e434cfSJoel Becker } 163613e434cfSJoel Becker 1637ba206635SJoel Becker static void ocfs2_bg_discontig_fix_result(struct ocfs2_alloc_context *ac, 163813e434cfSJoel Becker struct ocfs2_group_desc *bg, 163913e434cfSJoel Becker struct ocfs2_suballoc_result *res) 164013e434cfSJoel Becker { 164113e434cfSJoel Becker int i; 16422b6cb576SJoel Becker u64 bg_blkno = res->sr_bg_blkno; /* Save off */ 164313e434cfSJoel Becker struct ocfs2_extent_rec *rec; 164413e434cfSJoel Becker struct ocfs2_dinode *di = (struct ocfs2_dinode *)ac->ac_bh->b_data; 164513e434cfSJoel Becker struct ocfs2_chain_list *cl = &di->id2.i_chain; 164613e434cfSJoel Becker 1647ba206635SJoel Becker if (ocfs2_is_cluster_bitmap(ac->ac_inode)) { 1648ba206635SJoel Becker res->sr_blkno = 0; 164913e434cfSJoel Becker return; 1650ba206635SJoel Becker } 165113e434cfSJoel Becker 1652ba206635SJoel Becker res->sr_blkno = res->sr_bg_blkno + res->sr_bit_offset; 16532b6cb576SJoel Becker res->sr_bg_blkno = 0; /* Clear it for contig block groups */ 16544711954eSTao Ma if (!ocfs2_supports_discontig_bg(OCFS2_SB(ac->ac_inode->i_sb)) || 1655ba206635SJoel Becker !bg->bg_list.l_next_free_rec) 165613e434cfSJoel Becker return; 165713e434cfSJoel Becker 165813e434cfSJoel Becker for (i = 0; i < le16_to_cpu(bg->bg_list.l_next_free_rec); i++) { 165913e434cfSJoel Becker rec = &bg->bg_list.l_recs[i]; 16602b6cb576SJoel Becker if (ocfs2_bg_discontig_fix_by_rec(res, rec, cl)) { 16612b6cb576SJoel Becker res->sr_bg_blkno = bg_blkno; /* Restore */ 166213e434cfSJoel Becker break; 166313e434cfSJoel Becker } 166413e434cfSJoel Becker } 16652b6cb576SJoel Becker } 166613e434cfSJoel Becker 1667883d4caeSMark Fasheh static int ocfs2_search_one_group(struct ocfs2_alloc_context *ac, 16681fabe148SMark Fasheh handle_t *handle, 1669883d4caeSMark Fasheh u32 bits_wanted, 1670883d4caeSMark Fasheh u32 min_bits, 16717d1fe093SJoel Becker struct ocfs2_suballoc_result *res, 1672883d4caeSMark Fasheh u16 *bits_left) 1673883d4caeSMark Fasheh { 1674883d4caeSMark Fasheh int ret; 1675883d4caeSMark Fasheh struct buffer_head *group_bh = NULL; 1676883d4caeSMark Fasheh struct ocfs2_group_desc *gd; 167768f64d47SJoel Becker struct ocfs2_dinode *di = (struct ocfs2_dinode *)ac->ac_bh->b_data; 1678883d4caeSMark Fasheh struct inode *alloc_inode = ac->ac_inode; 1679883d4caeSMark Fasheh 16807d1fe093SJoel Becker ret = ocfs2_read_group_descriptor(alloc_inode, di, 16817d1fe093SJoel Becker res->sr_bg_blkno, &group_bh); 1682883d4caeSMark Fasheh if (ret < 0) { 1683883d4caeSMark Fasheh mlog_errno(ret); 1684883d4caeSMark Fasheh return ret; 1685883d4caeSMark Fasheh } 1686883d4caeSMark Fasheh 1687883d4caeSMark Fasheh gd = (struct ocfs2_group_desc *) group_bh->b_data; 1688883d4caeSMark Fasheh ret = ac->ac_group_search(alloc_inode, group_bh, bits_wanted, min_bits, 16897d1fe093SJoel Becker ac->ac_max_block, res); 1690883d4caeSMark Fasheh if (ret < 0) { 1691883d4caeSMark Fasheh if (ret != -ENOSPC) 1692883d4caeSMark Fasheh mlog_errno(ret); 1693883d4caeSMark Fasheh goto out; 1694883d4caeSMark Fasheh } 1695883d4caeSMark Fasheh 169613e434cfSJoel Becker if (!ret) 1697ba206635SJoel Becker ocfs2_bg_discontig_fix_result(ac, gd, res); 169813e434cfSJoel Becker 1699e49e2767SMark Fasheh /* 1700e49e2767SMark Fasheh * sr_bg_blkno might have been changed by 1701e49e2767SMark Fasheh * ocfs2_bg_discontig_fix_result 1702e49e2767SMark Fasheh */ 1703e49e2767SMark Fasheh res->sr_bg_stable_blkno = group_bh->b_blocknr; 1704e49e2767SMark Fasheh 1705e49e2767SMark Fasheh if (ac->ac_find_loc_only) 1706e49e2767SMark Fasheh goto out_loc_only; 1707e49e2767SMark Fasheh 1708883d4caeSMark Fasheh ret = ocfs2_alloc_dinode_update_counts(alloc_inode, handle, ac->ac_bh, 17097d1fe093SJoel Becker res->sr_bits, 1710883d4caeSMark Fasheh le16_to_cpu(gd->bg_chain)); 1711883d4caeSMark Fasheh if (ret < 0) { 1712883d4caeSMark Fasheh mlog_errno(ret); 1713883d4caeSMark Fasheh goto out; 1714883d4caeSMark Fasheh } 1715883d4caeSMark Fasheh 1716883d4caeSMark Fasheh ret = ocfs2_block_group_set_bits(handle, alloc_inode, gd, group_bh, 17177d1fe093SJoel Becker res->sr_bit_offset, res->sr_bits); 1718883d4caeSMark Fasheh if (ret < 0) 1719883d4caeSMark Fasheh mlog_errno(ret); 1720883d4caeSMark Fasheh 1721e49e2767SMark Fasheh out_loc_only: 1722883d4caeSMark Fasheh *bits_left = le16_to_cpu(gd->bg_free_bits_count); 1723883d4caeSMark Fasheh 1724883d4caeSMark Fasheh out: 1725883d4caeSMark Fasheh brelse(group_bh); 1726883d4caeSMark Fasheh 1727883d4caeSMark Fasheh return ret; 1728883d4caeSMark Fasheh } 1729883d4caeSMark Fasheh 1730ccd979bdSMark Fasheh static int ocfs2_search_chain(struct ocfs2_alloc_context *ac, 17311fabe148SMark Fasheh handle_t *handle, 1732ccd979bdSMark Fasheh u32 bits_wanted, 1733ccd979bdSMark Fasheh u32 min_bits, 17347d1fe093SJoel Becker struct ocfs2_suballoc_result *res, 1735883d4caeSMark Fasheh u16 *bits_left) 1736ccd979bdSMark Fasheh { 1737ccd979bdSMark Fasheh int status; 17387d1fe093SJoel Becker u16 chain; 1739ccd979bdSMark Fasheh u64 next_group; 1740ccd979bdSMark Fasheh struct inode *alloc_inode = ac->ac_inode; 1741ccd979bdSMark Fasheh struct buffer_head *group_bh = NULL; 1742ccd979bdSMark Fasheh struct buffer_head *prev_group_bh = NULL; 1743ccd979bdSMark Fasheh struct ocfs2_dinode *fe = (struct ocfs2_dinode *) ac->ac_bh->b_data; 1744ccd979bdSMark Fasheh struct ocfs2_chain_list *cl = (struct ocfs2_chain_list *) &fe->id2.i_chain; 1745ccd979bdSMark Fasheh struct ocfs2_group_desc *bg; 1746ccd979bdSMark Fasheh 1747ccd979bdSMark Fasheh chain = ac->ac_chain; 17482f73e135STao Ma trace_ocfs2_search_chain_begin( 17492f73e135STao Ma (unsigned long long)OCFS2_I(alloc_inode)->ip_blkno, 17502f73e135STao Ma bits_wanted, chain); 1751ccd979bdSMark Fasheh 175268f64d47SJoel Becker status = ocfs2_read_group_descriptor(alloc_inode, fe, 1753ccd979bdSMark Fasheh le64_to_cpu(cl->cl_recs[chain].c_blkno), 17540fcaa56aSJoel Becker &group_bh); 1755ccd979bdSMark Fasheh if (status < 0) { 1756ccd979bdSMark Fasheh mlog_errno(status); 1757ccd979bdSMark Fasheh goto bail; 1758ccd979bdSMark Fasheh } 1759ccd979bdSMark Fasheh bg = (struct ocfs2_group_desc *) group_bh->b_data; 1760ccd979bdSMark Fasheh 1761ccd979bdSMark Fasheh status = -ENOSPC; 1762ccd979bdSMark Fasheh /* for now, the chain search is a bit simplistic. We just use 1763ccd979bdSMark Fasheh * the 1st group with any empty bits. */ 17641187c968SJoel Becker while ((status = ac->ac_group_search(alloc_inode, group_bh, 17651187c968SJoel Becker bits_wanted, min_bits, 17667d1fe093SJoel Becker ac->ac_max_block, 17677d1fe093SJoel Becker res)) == -ENOSPC) { 1768ccd979bdSMark Fasheh if (!bg->bg_next_group) 1769ccd979bdSMark Fasheh break; 1770a81cb88bSMark Fasheh 1771ccd979bdSMark Fasheh brelse(prev_group_bh); 1772ccd979bdSMark Fasheh prev_group_bh = NULL; 1773a81cb88bSMark Fasheh 1774ccd979bdSMark Fasheh next_group = le64_to_cpu(bg->bg_next_group); 1775ccd979bdSMark Fasheh prev_group_bh = group_bh; 1776ccd979bdSMark Fasheh group_bh = NULL; 177768f64d47SJoel Becker status = ocfs2_read_group_descriptor(alloc_inode, fe, 17780fcaa56aSJoel Becker next_group, &group_bh); 1779ccd979bdSMark Fasheh if (status < 0) { 1780ccd979bdSMark Fasheh mlog_errno(status); 1781ccd979bdSMark Fasheh goto bail; 1782ccd979bdSMark Fasheh } 1783ccd979bdSMark Fasheh bg = (struct ocfs2_group_desc *) group_bh->b_data; 1784ccd979bdSMark Fasheh } 1785ccd979bdSMark Fasheh if (status < 0) { 1786ccd979bdSMark Fasheh if (status != -ENOSPC) 1787ccd979bdSMark Fasheh mlog_errno(status); 1788ccd979bdSMark Fasheh goto bail; 1789ccd979bdSMark Fasheh } 1790ccd979bdSMark Fasheh 17912f73e135STao Ma trace_ocfs2_search_chain_succ( 17922f73e135STao Ma (unsigned long long)le64_to_cpu(bg->bg_blkno), res->sr_bits); 1793ccd979bdSMark Fasheh 17947d1fe093SJoel Becker res->sr_bg_blkno = le64_to_cpu(bg->bg_blkno); 1795ccd979bdSMark Fasheh 17967d1fe093SJoel Becker BUG_ON(res->sr_bits == 0); 179713e434cfSJoel Becker if (!status) 1798ba206635SJoel Becker ocfs2_bg_discontig_fix_result(ac, bg, res); 179913e434cfSJoel Becker 1800e49e2767SMark Fasheh /* 1801e49e2767SMark Fasheh * sr_bg_blkno might have been changed by 1802e49e2767SMark Fasheh * ocfs2_bg_discontig_fix_result 1803e49e2767SMark Fasheh */ 1804e49e2767SMark Fasheh res->sr_bg_stable_blkno = group_bh->b_blocknr; 1805ccd979bdSMark Fasheh 1806ccd979bdSMark Fasheh /* 1807ccd979bdSMark Fasheh * Keep track of previous block descriptor read. When 1808ccd979bdSMark Fasheh * we find a target, if we have read more than X 1809ccd979bdSMark Fasheh * number of descriptors, and the target is reasonably 1810ccd979bdSMark Fasheh * empty, relink him to top of his chain. 1811ccd979bdSMark Fasheh * 1812ccd979bdSMark Fasheh * We've read 0 extra blocks and only send one more to 1813ccd979bdSMark Fasheh * the transaction, yet the next guy to search has a 1814ccd979bdSMark Fasheh * much easier time. 1815ccd979bdSMark Fasheh * 1816ccd979bdSMark Fasheh * Do this *after* figuring out how many bits we're taking out 1817ccd979bdSMark Fasheh * of our target group. 1818ccd979bdSMark Fasheh */ 1819309a85b6SXiaowei.Hu if (!ac->ac_disable_chain_relink && 1820ccd979bdSMark Fasheh (prev_group_bh) && 18217d1fe093SJoel Becker (ocfs2_block_group_reasonably_empty(bg, res->sr_bits))) { 1822ccd979bdSMark Fasheh status = ocfs2_relink_block_group(handle, alloc_inode, 1823ccd979bdSMark Fasheh ac->ac_bh, group_bh, 1824ccd979bdSMark Fasheh prev_group_bh, chain); 1825ccd979bdSMark Fasheh if (status < 0) { 1826ccd979bdSMark Fasheh mlog_errno(status); 1827ccd979bdSMark Fasheh goto bail; 1828ccd979bdSMark Fasheh } 1829ccd979bdSMark Fasheh } 1830ccd979bdSMark Fasheh 1831e49e2767SMark Fasheh if (ac->ac_find_loc_only) 1832e49e2767SMark Fasheh goto out_loc_only; 1833e49e2767SMark Fasheh 1834d5134982SMark Fasheh status = ocfs2_alloc_dinode_update_counts(alloc_inode, handle, 1835d5134982SMark Fasheh ac->ac_bh, res->sr_bits, 1836d5134982SMark Fasheh chain); 1837d5134982SMark Fasheh if (status) { 1838ccd979bdSMark Fasheh mlog_errno(status); 1839ccd979bdSMark Fasheh goto bail; 1840ccd979bdSMark Fasheh } 1841ccd979bdSMark Fasheh 1842ccd979bdSMark Fasheh status = ocfs2_block_group_set_bits(handle, 1843ccd979bdSMark Fasheh alloc_inode, 1844ccd979bdSMark Fasheh bg, 1845ccd979bdSMark Fasheh group_bh, 18467d1fe093SJoel Becker res->sr_bit_offset, 18477d1fe093SJoel Becker res->sr_bits); 1848ccd979bdSMark Fasheh if (status < 0) { 1849ccd979bdSMark Fasheh mlog_errno(status); 1850ccd979bdSMark Fasheh goto bail; 1851ccd979bdSMark Fasheh } 1852ccd979bdSMark Fasheh 18532f73e135STao Ma trace_ocfs2_search_chain_end( 18542f73e135STao Ma (unsigned long long)le64_to_cpu(fe->i_blkno), 18552f73e135STao Ma res->sr_bits); 1856ccd979bdSMark Fasheh 1857e49e2767SMark Fasheh out_loc_only: 1858883d4caeSMark Fasheh *bits_left = le16_to_cpu(bg->bg_free_bits_count); 1859ccd979bdSMark Fasheh bail: 1860ccd979bdSMark Fasheh brelse(group_bh); 1861ccd979bdSMark Fasheh brelse(prev_group_bh); 1862ccd979bdSMark Fasheh 1863c1e8d35eSTao Ma if (status) 1864c1e8d35eSTao Ma mlog_errno(status); 1865ccd979bdSMark Fasheh return status; 1866ccd979bdSMark Fasheh } 1867ccd979bdSMark Fasheh 1868ccd979bdSMark Fasheh /* will give out up to bits_wanted contiguous bits. */ 1869aa8f8e93SJoel Becker static int ocfs2_claim_suballoc_bits(struct ocfs2_alloc_context *ac, 18701fabe148SMark Fasheh handle_t *handle, 1871ccd979bdSMark Fasheh u32 bits_wanted, 1872ccd979bdSMark Fasheh u32 min_bits, 18737d1fe093SJoel Becker struct ocfs2_suballoc_result *res) 1874ccd979bdSMark Fasheh { 1875ccd979bdSMark Fasheh int status; 1876ccd979bdSMark Fasheh u16 victim, i; 1877883d4caeSMark Fasheh u16 bits_left = 0; 1878b2b6ebf5SMark Fasheh u64 hint = ac->ac_last_group; 1879ccd979bdSMark Fasheh struct ocfs2_chain_list *cl; 1880ccd979bdSMark Fasheh struct ocfs2_dinode *fe; 1881ccd979bdSMark Fasheh 1882ccd979bdSMark Fasheh BUG_ON(ac->ac_bits_given >= ac->ac_bits_wanted); 1883ccd979bdSMark Fasheh BUG_ON(bits_wanted > (ac->ac_bits_wanted - ac->ac_bits_given)); 1884ccd979bdSMark Fasheh BUG_ON(!ac->ac_bh); 1885ccd979bdSMark Fasheh 1886ccd979bdSMark Fasheh fe = (struct ocfs2_dinode *) ac->ac_bh->b_data; 188710995aa2SJoel Becker 188810995aa2SJoel Becker /* The bh was validated by the inode read during 188910995aa2SJoel Becker * ocfs2_reserve_suballoc_bits(). Any corruption is a code bug. */ 189010995aa2SJoel Becker BUG_ON(!OCFS2_IS_VALID_DINODE(fe)); 189110995aa2SJoel Becker 1892ccd979bdSMark Fasheh if (le32_to_cpu(fe->id1.bitmap1.i_used) >= 1893ccd979bdSMark Fasheh le32_to_cpu(fe->id1.bitmap1.i_total)) { 1894aa8f8e93SJoel Becker ocfs2_error(ac->ac_inode->i_sb, 1895aa8f8e93SJoel Becker "Chain allocator dinode %llu has %u used " 1896b0697053SMark Fasheh "bits but only %u total.", 1897b0697053SMark Fasheh (unsigned long long)le64_to_cpu(fe->i_blkno), 1898ccd979bdSMark Fasheh le32_to_cpu(fe->id1.bitmap1.i_used), 1899ccd979bdSMark Fasheh le32_to_cpu(fe->id1.bitmap1.i_total)); 1900ccd979bdSMark Fasheh status = -EIO; 1901ccd979bdSMark Fasheh goto bail; 1902ccd979bdSMark Fasheh } 1903ccd979bdSMark Fasheh 1904b2b6ebf5SMark Fasheh res->sr_bg_blkno = hint; 19057d1fe093SJoel Becker if (res->sr_bg_blkno) { 1906883d4caeSMark Fasheh /* Attempt to short-circuit the usual search mechanism 1907883d4caeSMark Fasheh * by jumping straight to the most recently used 1908b595076aSUwe Kleine-König * allocation group. This helps us maintain some 1909883d4caeSMark Fasheh * contiguousness across allocations. */ 1910da5cbf2fSMark Fasheh status = ocfs2_search_one_group(ac, handle, bits_wanted, 19117d1fe093SJoel Becker min_bits, res, &bits_left); 19127d1fe093SJoel Becker if (!status) 1913883d4caeSMark Fasheh goto set_hint; 1914883d4caeSMark Fasheh if (status < 0 && status != -ENOSPC) { 1915883d4caeSMark Fasheh mlog_errno(status); 1916883d4caeSMark Fasheh goto bail; 1917883d4caeSMark Fasheh } 1918883d4caeSMark Fasheh } 1919883d4caeSMark Fasheh 1920ccd979bdSMark Fasheh cl = (struct ocfs2_chain_list *) &fe->id2.i_chain; 1921ccd979bdSMark Fasheh 1922ccd979bdSMark Fasheh victim = ocfs2_find_victim_chain(cl); 1923ccd979bdSMark Fasheh ac->ac_chain = victim; 1924ccd979bdSMark Fasheh 19257d1fe093SJoel Becker status = ocfs2_search_chain(ac, handle, bits_wanted, min_bits, 19267d1fe093SJoel Becker res, &bits_left); 1927b2b6ebf5SMark Fasheh if (!status) { 1928b2b6ebf5SMark Fasheh hint = ocfs2_group_from_res(res); 1929883d4caeSMark Fasheh goto set_hint; 1930b2b6ebf5SMark Fasheh } 1931ccd979bdSMark Fasheh if (status < 0 && status != -ENOSPC) { 1932ccd979bdSMark Fasheh mlog_errno(status); 1933ccd979bdSMark Fasheh goto bail; 1934ccd979bdSMark Fasheh } 1935ccd979bdSMark Fasheh 19362f73e135STao Ma trace_ocfs2_claim_suballoc_bits(victim); 1937ccd979bdSMark Fasheh 1938ccd979bdSMark Fasheh /* If we didn't pick a good victim, then just default to 1939ccd979bdSMark Fasheh * searching each chain in order. Don't allow chain relinking 1940ccd979bdSMark Fasheh * because we only calculate enough journal credits for one 1941ccd979bdSMark Fasheh * relink per alloc. */ 1942309a85b6SXiaowei.Hu ac->ac_disable_chain_relink = 1; 1943ccd979bdSMark Fasheh for (i = 0; i < le16_to_cpu(cl->cl_next_free_rec); i ++) { 1944ccd979bdSMark Fasheh if (i == victim) 1945ccd979bdSMark Fasheh continue; 1946ccd979bdSMark Fasheh if (!cl->cl_recs[i].c_free) 1947ccd979bdSMark Fasheh continue; 1948ccd979bdSMark Fasheh 1949ccd979bdSMark Fasheh ac->ac_chain = i; 1950da5cbf2fSMark Fasheh status = ocfs2_search_chain(ac, handle, bits_wanted, min_bits, 19517d1fe093SJoel Becker res, &bits_left); 1952b2b6ebf5SMark Fasheh if (!status) { 1953b2b6ebf5SMark Fasheh hint = ocfs2_group_from_res(res); 1954ccd979bdSMark Fasheh break; 1955b2b6ebf5SMark Fasheh } 1956ccd979bdSMark Fasheh if (status < 0 && status != -ENOSPC) { 1957ccd979bdSMark Fasheh mlog_errno(status); 1958ccd979bdSMark Fasheh goto bail; 1959ccd979bdSMark Fasheh } 1960ccd979bdSMark Fasheh } 1961ccd979bdSMark Fasheh 1962883d4caeSMark Fasheh set_hint: 1963883d4caeSMark Fasheh if (status != -ENOSPC) { 1964883d4caeSMark Fasheh /* If the next search of this group is not likely to 1965883d4caeSMark Fasheh * yield a suitable extent, then we reset the last 1966883d4caeSMark Fasheh * group hint so as to not waste a disk read */ 1967883d4caeSMark Fasheh if (bits_left < min_bits) 1968883d4caeSMark Fasheh ac->ac_last_group = 0; 1969883d4caeSMark Fasheh else 1970b2b6ebf5SMark Fasheh ac->ac_last_group = hint; 1971883d4caeSMark Fasheh } 1972883d4caeSMark Fasheh 1973883d4caeSMark Fasheh bail: 1974c1e8d35eSTao Ma if (status) 1975c1e8d35eSTao Ma mlog_errno(status); 1976ccd979bdSMark Fasheh return status; 1977ccd979bdSMark Fasheh } 1978ccd979bdSMark Fasheh 19791ed9b777SJoel Becker int ocfs2_claim_metadata(handle_t *handle, 1980ccd979bdSMark Fasheh struct ocfs2_alloc_context *ac, 1981ccd979bdSMark Fasheh u32 bits_wanted, 19822b6cb576SJoel Becker u64 *suballoc_loc, 1983ccd979bdSMark Fasheh u16 *suballoc_bit_start, 1984ccd979bdSMark Fasheh unsigned int *num_bits, 1985ccd979bdSMark Fasheh u64 *blkno_start) 1986ccd979bdSMark Fasheh { 1987ccd979bdSMark Fasheh int status; 1988ba206635SJoel Becker struct ocfs2_suballoc_result res = { .sr_blkno = 0, }; 1989ccd979bdSMark Fasheh 1990ccd979bdSMark Fasheh BUG_ON(!ac); 1991ccd979bdSMark Fasheh BUG_ON(ac->ac_bits_wanted < (ac->ac_bits_given + bits_wanted)); 1992ccd979bdSMark Fasheh BUG_ON(ac->ac_which != OCFS2_AC_USE_META); 1993ccd979bdSMark Fasheh 1994aa8f8e93SJoel Becker status = ocfs2_claim_suballoc_bits(ac, 1995da5cbf2fSMark Fasheh handle, 1996ccd979bdSMark Fasheh bits_wanted, 1997ccd979bdSMark Fasheh 1, 19987d1fe093SJoel Becker &res); 1999ccd979bdSMark Fasheh if (status < 0) { 2000ccd979bdSMark Fasheh mlog_errno(status); 2001ccd979bdSMark Fasheh goto bail; 2002ccd979bdSMark Fasheh } 20031ed9b777SJoel Becker atomic_inc(&OCFS2_SB(ac->ac_inode->i_sb)->alloc_stats.bg_allocs); 2004ccd979bdSMark Fasheh 20052b6cb576SJoel Becker *suballoc_loc = res.sr_bg_blkno; 20067d1fe093SJoel Becker *suballoc_bit_start = res.sr_bit_offset; 2007ba206635SJoel Becker *blkno_start = res.sr_blkno; 20087d1fe093SJoel Becker ac->ac_bits_given += res.sr_bits; 20097d1fe093SJoel Becker *num_bits = res.sr_bits; 2010ccd979bdSMark Fasheh status = 0; 2011ccd979bdSMark Fasheh bail: 2012c1e8d35eSTao Ma if (status) 2013c1e8d35eSTao Ma mlog_errno(status); 2014ccd979bdSMark Fasheh return status; 2015ccd979bdSMark Fasheh } 2016ccd979bdSMark Fasheh 201713821151STao Ma static void ocfs2_init_inode_ac_group(struct inode *dir, 2018abf1b3cbSTao Ma struct buffer_head *parent_di_bh, 201913821151STao Ma struct ocfs2_alloc_context *ac) 202013821151STao Ma { 2021abf1b3cbSTao Ma struct ocfs2_dinode *di = (struct ocfs2_dinode *)parent_di_bh->b_data; 202213821151STao Ma /* 202313821151STao Ma * Try to allocate inodes from some specific group. 202413821151STao Ma * 202513821151STao Ma * If the parent dir has recorded the last group used in allocation, 202613821151STao Ma * cool, use it. Otherwise if we try to allocate new inode from the 202713821151STao Ma * same slot the parent dir belongs to, use the same chunk. 202813821151STao Ma * 202913821151STao Ma * We are very careful here to avoid the mistake of setting 203013821151STao Ma * ac_last_group to a group descriptor from a different (unlocked) slot. 203113821151STao Ma */ 203213821151STao Ma if (OCFS2_I(dir)->ip_last_used_group && 203313821151STao Ma OCFS2_I(dir)->ip_last_used_slot == ac->ac_alloc_slot) 203413821151STao Ma ac->ac_last_group = OCFS2_I(dir)->ip_last_used_group; 2035abf1b3cbSTao Ma else if (le16_to_cpu(di->i_suballoc_slot) == ac->ac_alloc_slot) { 2036abf1b3cbSTao Ma if (di->i_suballoc_loc) 2037abf1b3cbSTao Ma ac->ac_last_group = le64_to_cpu(di->i_suballoc_loc); 2038abf1b3cbSTao Ma else 203913821151STao Ma ac->ac_last_group = ocfs2_which_suballoc_group( 2040abf1b3cbSTao Ma le64_to_cpu(di->i_blkno), 2041abf1b3cbSTao Ma le16_to_cpu(di->i_suballoc_bit)); 2042abf1b3cbSTao Ma } 204313821151STao Ma } 204413821151STao Ma 204513821151STao Ma static inline void ocfs2_save_inode_ac_group(struct inode *dir, 204613821151STao Ma struct ocfs2_alloc_context *ac) 204713821151STao Ma { 204813821151STao Ma OCFS2_I(dir)->ip_last_used_group = ac->ac_last_group; 204913821151STao Ma OCFS2_I(dir)->ip_last_used_slot = ac->ac_alloc_slot; 205013821151STao Ma } 205113821151STao Ma 2052e49e2767SMark Fasheh int ocfs2_find_new_inode_loc(struct inode *dir, 2053e49e2767SMark Fasheh struct buffer_head *parent_fe_bh, 2054e49e2767SMark Fasheh struct ocfs2_alloc_context *ac, 2055e49e2767SMark Fasheh u64 *fe_blkno) 2056e49e2767SMark Fasheh { 2057e49e2767SMark Fasheh int ret; 2058e49e2767SMark Fasheh handle_t *handle = NULL; 2059e49e2767SMark Fasheh struct ocfs2_suballoc_result *res; 2060e49e2767SMark Fasheh 2061e49e2767SMark Fasheh BUG_ON(!ac); 2062e49e2767SMark Fasheh BUG_ON(ac->ac_bits_given != 0); 2063e49e2767SMark Fasheh BUG_ON(ac->ac_bits_wanted != 1); 2064e49e2767SMark Fasheh BUG_ON(ac->ac_which != OCFS2_AC_USE_INODE); 2065e49e2767SMark Fasheh 2066e49e2767SMark Fasheh res = kzalloc(sizeof(*res), GFP_NOFS); 2067e49e2767SMark Fasheh if (res == NULL) { 2068e49e2767SMark Fasheh ret = -ENOMEM; 2069e49e2767SMark Fasheh mlog_errno(ret); 2070e49e2767SMark Fasheh goto out; 2071e49e2767SMark Fasheh } 2072e49e2767SMark Fasheh 2073e49e2767SMark Fasheh ocfs2_init_inode_ac_group(dir, parent_fe_bh, ac); 2074e49e2767SMark Fasheh 2075e49e2767SMark Fasheh /* 2076e49e2767SMark Fasheh * The handle started here is for chain relink. Alternatively, 2077e49e2767SMark Fasheh * we could just disable relink for these calls. 2078e49e2767SMark Fasheh */ 2079e49e2767SMark Fasheh handle = ocfs2_start_trans(OCFS2_SB(dir->i_sb), OCFS2_SUBALLOC_ALLOC); 2080e49e2767SMark Fasheh if (IS_ERR(handle)) { 2081e49e2767SMark Fasheh ret = PTR_ERR(handle); 2082e49e2767SMark Fasheh handle = NULL; 2083e49e2767SMark Fasheh mlog_errno(ret); 2084e49e2767SMark Fasheh goto out; 2085e49e2767SMark Fasheh } 2086e49e2767SMark Fasheh 2087e49e2767SMark Fasheh /* 2088e49e2767SMark Fasheh * This will instruct ocfs2_claim_suballoc_bits and 2089e49e2767SMark Fasheh * ocfs2_search_one_group to search but save actual allocation 2090e49e2767SMark Fasheh * for later. 2091e49e2767SMark Fasheh */ 2092e49e2767SMark Fasheh ac->ac_find_loc_only = 1; 2093e49e2767SMark Fasheh 2094e49e2767SMark Fasheh ret = ocfs2_claim_suballoc_bits(ac, handle, 1, 1, res); 2095e49e2767SMark Fasheh if (ret < 0) { 2096e49e2767SMark Fasheh mlog_errno(ret); 2097e49e2767SMark Fasheh goto out; 2098e49e2767SMark Fasheh } 2099e49e2767SMark Fasheh 2100e49e2767SMark Fasheh ac->ac_find_loc_priv = res; 2101e49e2767SMark Fasheh *fe_blkno = res->sr_blkno; 2102e49e2767SMark Fasheh 2103e49e2767SMark Fasheh out: 2104e49e2767SMark Fasheh if (handle) 2105e49e2767SMark Fasheh ocfs2_commit_trans(OCFS2_SB(dir->i_sb), handle); 2106e49e2767SMark Fasheh 2107e49e2767SMark Fasheh if (ret) 2108e49e2767SMark Fasheh kfree(res); 2109e49e2767SMark Fasheh 2110e49e2767SMark Fasheh return ret; 2111e49e2767SMark Fasheh } 2112e49e2767SMark Fasheh 2113e49e2767SMark Fasheh int ocfs2_claim_new_inode_at_loc(handle_t *handle, 2114e49e2767SMark Fasheh struct inode *dir, 2115e49e2767SMark Fasheh struct ocfs2_alloc_context *ac, 2116e49e2767SMark Fasheh u64 *suballoc_loc, 2117e49e2767SMark Fasheh u16 *suballoc_bit, 2118e49e2767SMark Fasheh u64 di_blkno) 2119e49e2767SMark Fasheh { 2120e49e2767SMark Fasheh int ret; 2121e49e2767SMark Fasheh u16 chain; 2122e49e2767SMark Fasheh struct ocfs2_suballoc_result *res = ac->ac_find_loc_priv; 2123e49e2767SMark Fasheh struct buffer_head *bg_bh = NULL; 2124e49e2767SMark Fasheh struct ocfs2_group_desc *bg; 2125e49e2767SMark Fasheh struct ocfs2_dinode *di = (struct ocfs2_dinode *) ac->ac_bh->b_data; 2126e49e2767SMark Fasheh 2127e49e2767SMark Fasheh /* 2128e49e2767SMark Fasheh * Since di_blkno is being passed back in, we check for any 2129e49e2767SMark Fasheh * inconsistencies which may have happened between 2130e49e2767SMark Fasheh * calls. These are code bugs as di_blkno is not expected to 2131e49e2767SMark Fasheh * change once returned from ocfs2_find_new_inode_loc() 2132e49e2767SMark Fasheh */ 2133e49e2767SMark Fasheh BUG_ON(res->sr_blkno != di_blkno); 2134e49e2767SMark Fasheh 2135e49e2767SMark Fasheh ret = ocfs2_read_group_descriptor(ac->ac_inode, di, 2136e49e2767SMark Fasheh res->sr_bg_stable_blkno, &bg_bh); 2137e49e2767SMark Fasheh if (ret) { 2138e49e2767SMark Fasheh mlog_errno(ret); 2139e49e2767SMark Fasheh goto out; 2140e49e2767SMark Fasheh } 2141e49e2767SMark Fasheh 2142e49e2767SMark Fasheh bg = (struct ocfs2_group_desc *) bg_bh->b_data; 2143e49e2767SMark Fasheh chain = le16_to_cpu(bg->bg_chain); 2144e49e2767SMark Fasheh 2145e49e2767SMark Fasheh ret = ocfs2_alloc_dinode_update_counts(ac->ac_inode, handle, 2146e49e2767SMark Fasheh ac->ac_bh, res->sr_bits, 2147e49e2767SMark Fasheh chain); 2148e49e2767SMark Fasheh if (ret) { 2149e49e2767SMark Fasheh mlog_errno(ret); 2150e49e2767SMark Fasheh goto out; 2151e49e2767SMark Fasheh } 2152e49e2767SMark Fasheh 2153e49e2767SMark Fasheh ret = ocfs2_block_group_set_bits(handle, 2154e49e2767SMark Fasheh ac->ac_inode, 2155e49e2767SMark Fasheh bg, 2156e49e2767SMark Fasheh bg_bh, 2157e49e2767SMark Fasheh res->sr_bit_offset, 2158e49e2767SMark Fasheh res->sr_bits); 2159e49e2767SMark Fasheh if (ret < 0) { 2160e49e2767SMark Fasheh mlog_errno(ret); 2161e49e2767SMark Fasheh goto out; 2162e49e2767SMark Fasheh } 2163e49e2767SMark Fasheh 21642f73e135STao Ma trace_ocfs2_claim_new_inode_at_loc((unsigned long long)di_blkno, 21652f73e135STao Ma res->sr_bits); 2166e49e2767SMark Fasheh 2167e49e2767SMark Fasheh atomic_inc(&OCFS2_SB(ac->ac_inode->i_sb)->alloc_stats.bg_allocs); 2168e49e2767SMark Fasheh 2169e49e2767SMark Fasheh BUG_ON(res->sr_bits != 1); 2170e49e2767SMark Fasheh 2171e49e2767SMark Fasheh *suballoc_loc = res->sr_bg_blkno; 2172e49e2767SMark Fasheh *suballoc_bit = res->sr_bit_offset; 2173e49e2767SMark Fasheh ac->ac_bits_given++; 2174e49e2767SMark Fasheh ocfs2_save_inode_ac_group(dir, ac); 2175e49e2767SMark Fasheh 2176e49e2767SMark Fasheh out: 2177e49e2767SMark Fasheh brelse(bg_bh); 2178e49e2767SMark Fasheh 2179e49e2767SMark Fasheh return ret; 2180e49e2767SMark Fasheh } 2181e49e2767SMark Fasheh 21821ed9b777SJoel Becker int ocfs2_claim_new_inode(handle_t *handle, 218313821151STao Ma struct inode *dir, 218413821151STao Ma struct buffer_head *parent_fe_bh, 2185ccd979bdSMark Fasheh struct ocfs2_alloc_context *ac, 21862b6cb576SJoel Becker u64 *suballoc_loc, 2187ccd979bdSMark Fasheh u16 *suballoc_bit, 2188ccd979bdSMark Fasheh u64 *fe_blkno) 2189ccd979bdSMark Fasheh { 2190ccd979bdSMark Fasheh int status; 21912b6cb576SJoel Becker struct ocfs2_suballoc_result res; 2192ccd979bdSMark Fasheh 2193ccd979bdSMark Fasheh BUG_ON(!ac); 2194ccd979bdSMark Fasheh BUG_ON(ac->ac_bits_given != 0); 2195ccd979bdSMark Fasheh BUG_ON(ac->ac_bits_wanted != 1); 2196ccd979bdSMark Fasheh BUG_ON(ac->ac_which != OCFS2_AC_USE_INODE); 2197ccd979bdSMark Fasheh 219813821151STao Ma ocfs2_init_inode_ac_group(dir, parent_fe_bh, ac); 219913821151STao Ma 2200aa8f8e93SJoel Becker status = ocfs2_claim_suballoc_bits(ac, 2201da5cbf2fSMark Fasheh handle, 2202ccd979bdSMark Fasheh 1, 2203ccd979bdSMark Fasheh 1, 22047d1fe093SJoel Becker &res); 2205ccd979bdSMark Fasheh if (status < 0) { 2206ccd979bdSMark Fasheh mlog_errno(status); 2207ccd979bdSMark Fasheh goto bail; 2208ccd979bdSMark Fasheh } 22091ed9b777SJoel Becker atomic_inc(&OCFS2_SB(ac->ac_inode->i_sb)->alloc_stats.bg_allocs); 2210ccd979bdSMark Fasheh 22117d1fe093SJoel Becker BUG_ON(res.sr_bits != 1); 2212ccd979bdSMark Fasheh 22132b6cb576SJoel Becker *suballoc_loc = res.sr_bg_blkno; 22147d1fe093SJoel Becker *suballoc_bit = res.sr_bit_offset; 2215ba206635SJoel Becker *fe_blkno = res.sr_blkno; 2216ccd979bdSMark Fasheh ac->ac_bits_given++; 221713821151STao Ma ocfs2_save_inode_ac_group(dir, ac); 2218ccd979bdSMark Fasheh status = 0; 2219ccd979bdSMark Fasheh bail: 2220c1e8d35eSTao Ma if (status) 2221c1e8d35eSTao Ma mlog_errno(status); 2222ccd979bdSMark Fasheh return status; 2223ccd979bdSMark Fasheh } 2224ccd979bdSMark Fasheh 2225ccd979bdSMark Fasheh /* translate a group desc. blkno and it's bitmap offset into 2226ccd979bdSMark Fasheh * disk cluster offset. */ 2227ccd979bdSMark Fasheh static inline u32 ocfs2_desc_bitmap_to_cluster_off(struct inode *inode, 2228ccd979bdSMark Fasheh u64 bg_blkno, 2229ccd979bdSMark Fasheh u16 bg_bit_off) 2230ccd979bdSMark Fasheh { 2231ccd979bdSMark Fasheh struct ocfs2_super *osb = OCFS2_SB(inode->i_sb); 2232ccd979bdSMark Fasheh u32 cluster = 0; 2233ccd979bdSMark Fasheh 2234ccd979bdSMark Fasheh BUG_ON(!ocfs2_is_cluster_bitmap(inode)); 2235ccd979bdSMark Fasheh 2236ccd979bdSMark Fasheh if (bg_blkno != osb->first_cluster_group_blkno) 2237ccd979bdSMark Fasheh cluster = ocfs2_blocks_to_clusters(inode->i_sb, bg_blkno); 2238ccd979bdSMark Fasheh cluster += (u32) bg_bit_off; 2239ccd979bdSMark Fasheh return cluster; 2240ccd979bdSMark Fasheh } 2241ccd979bdSMark Fasheh 2242ccd979bdSMark Fasheh /* given a cluster offset, calculate which block group it belongs to 2243ccd979bdSMark Fasheh * and return that block offset. */ 2244d659072fSTao Ma u64 ocfs2_which_cluster_group(struct inode *inode, u32 cluster) 2245ccd979bdSMark Fasheh { 2246ccd979bdSMark Fasheh struct ocfs2_super *osb = OCFS2_SB(inode->i_sb); 2247ccd979bdSMark Fasheh u32 group_no; 2248ccd979bdSMark Fasheh 2249ccd979bdSMark Fasheh BUG_ON(!ocfs2_is_cluster_bitmap(inode)); 2250ccd979bdSMark Fasheh 2251ccd979bdSMark Fasheh group_no = cluster / osb->bitmap_cpg; 2252ccd979bdSMark Fasheh if (!group_no) 2253ccd979bdSMark Fasheh return osb->first_cluster_group_blkno; 2254ccd979bdSMark Fasheh return ocfs2_clusters_to_blocks(inode->i_sb, 2255ccd979bdSMark Fasheh group_no * osb->bitmap_cpg); 2256ccd979bdSMark Fasheh } 2257ccd979bdSMark Fasheh 2258ccd979bdSMark Fasheh /* given the block number of a cluster start, calculate which cluster 2259ccd979bdSMark Fasheh * group and descriptor bitmap offset that corresponds to. */ 2260ccd979bdSMark Fasheh static inline void ocfs2_block_to_cluster_group(struct inode *inode, 2261ccd979bdSMark Fasheh u64 data_blkno, 2262ccd979bdSMark Fasheh u64 *bg_blkno, 2263ccd979bdSMark Fasheh u16 *bg_bit_off) 2264ccd979bdSMark Fasheh { 2265ccd979bdSMark Fasheh struct ocfs2_super *osb = OCFS2_SB(inode->i_sb); 2266ccd979bdSMark Fasheh u32 data_cluster = ocfs2_blocks_to_clusters(osb->sb, data_blkno); 2267ccd979bdSMark Fasheh 2268ccd979bdSMark Fasheh BUG_ON(!ocfs2_is_cluster_bitmap(inode)); 2269ccd979bdSMark Fasheh 2270ccd979bdSMark Fasheh *bg_blkno = ocfs2_which_cluster_group(inode, 2271ccd979bdSMark Fasheh data_cluster); 2272ccd979bdSMark Fasheh 2273ccd979bdSMark Fasheh if (*bg_blkno == osb->first_cluster_group_blkno) 2274ccd979bdSMark Fasheh *bg_bit_off = (u16) data_cluster; 2275ccd979bdSMark Fasheh else 2276ccd979bdSMark Fasheh *bg_bit_off = (u16) ocfs2_blocks_to_clusters(osb->sb, 2277ccd979bdSMark Fasheh data_blkno - *bg_blkno); 2278ccd979bdSMark Fasheh } 2279ccd979bdSMark Fasheh 2280ccd979bdSMark Fasheh /* 2281ccd979bdSMark Fasheh * min_bits - minimum contiguous chunk from this total allocation we 2282ccd979bdSMark Fasheh * can handle. set to what we asked for originally for a full 2283ccd979bdSMark Fasheh * contig. allocation, set to '1' to indicate we can deal with extents 2284ccd979bdSMark Fasheh * of any size. 2285ccd979bdSMark Fasheh */ 22861ed9b777SJoel Becker int __ocfs2_claim_clusters(handle_t *handle, 2287ccd979bdSMark Fasheh struct ocfs2_alloc_context *ac, 2288ccd979bdSMark Fasheh u32 min_clusters, 2289415cb800SMark Fasheh u32 max_clusters, 2290ccd979bdSMark Fasheh u32 *cluster_start, 2291ccd979bdSMark Fasheh u32 *num_clusters) 2292ccd979bdSMark Fasheh { 2293ccd979bdSMark Fasheh int status; 2294415cb800SMark Fasheh unsigned int bits_wanted = max_clusters; 2295ba206635SJoel Becker struct ocfs2_suballoc_result res = { .sr_blkno = 0, }; 22961ed9b777SJoel Becker struct ocfs2_super *osb = OCFS2_SB(ac->ac_inode->i_sb); 2297ccd979bdSMark Fasheh 2298ccd979bdSMark Fasheh BUG_ON(ac->ac_bits_given >= ac->ac_bits_wanted); 2299ccd979bdSMark Fasheh 2300ccd979bdSMark Fasheh BUG_ON(ac->ac_which != OCFS2_AC_USE_LOCAL 2301ccd979bdSMark Fasheh && ac->ac_which != OCFS2_AC_USE_MAIN); 2302ccd979bdSMark Fasheh 2303ccd979bdSMark Fasheh if (ac->ac_which == OCFS2_AC_USE_LOCAL) { 230433d5d380SMark Fasheh WARN_ON(min_clusters > 1); 230533d5d380SMark Fasheh 2306ccd979bdSMark Fasheh status = ocfs2_claim_local_alloc_bits(osb, 2307ccd979bdSMark Fasheh handle, 2308ccd979bdSMark Fasheh ac, 2309ccd979bdSMark Fasheh bits_wanted, 2310ccd979bdSMark Fasheh cluster_start, 2311ccd979bdSMark Fasheh num_clusters); 2312ccd979bdSMark Fasheh if (!status) 2313ccd979bdSMark Fasheh atomic_inc(&osb->alloc_stats.local_data); 2314ccd979bdSMark Fasheh } else { 2315ccd979bdSMark Fasheh if (min_clusters > (osb->bitmap_cpg - 1)) { 2316ccd979bdSMark Fasheh /* The only paths asking for contiguousness 2317ccd979bdSMark Fasheh * should know about this already. */ 23182fbe8d1eSSunil Mushran mlog(ML_ERROR, "minimum allocation requested %u exceeds " 23192fbe8d1eSSunil Mushran "group bitmap size %u!\n", min_clusters, 23202fbe8d1eSSunil Mushran osb->bitmap_cpg); 2321ccd979bdSMark Fasheh status = -ENOSPC; 2322ccd979bdSMark Fasheh goto bail; 2323ccd979bdSMark Fasheh } 2324ccd979bdSMark Fasheh /* clamp the current request down to a realistic size. */ 2325ccd979bdSMark Fasheh if (bits_wanted > (osb->bitmap_cpg - 1)) 2326ccd979bdSMark Fasheh bits_wanted = osb->bitmap_cpg - 1; 2327ccd979bdSMark Fasheh 2328aa8f8e93SJoel Becker status = ocfs2_claim_suballoc_bits(ac, 2329da5cbf2fSMark Fasheh handle, 2330ccd979bdSMark Fasheh bits_wanted, 2331ccd979bdSMark Fasheh min_clusters, 23327d1fe093SJoel Becker &res); 2333ccd979bdSMark Fasheh if (!status) { 2334ba206635SJoel Becker BUG_ON(res.sr_blkno); /* cluster alloc can't set */ 2335ccd979bdSMark Fasheh *cluster_start = 2336ccd979bdSMark Fasheh ocfs2_desc_bitmap_to_cluster_off(ac->ac_inode, 23377d1fe093SJoel Becker res.sr_bg_blkno, 23387d1fe093SJoel Becker res.sr_bit_offset); 2339ccd979bdSMark Fasheh atomic_inc(&osb->alloc_stats.bitmap_data); 23404711954eSTao Ma *num_clusters = res.sr_bits; 2341ccd979bdSMark Fasheh } 2342ccd979bdSMark Fasheh } 2343ccd979bdSMark Fasheh if (status < 0) { 2344ccd979bdSMark Fasheh if (status != -ENOSPC) 2345ccd979bdSMark Fasheh mlog_errno(status); 2346ccd979bdSMark Fasheh goto bail; 2347ccd979bdSMark Fasheh } 2348ccd979bdSMark Fasheh 23494711954eSTao Ma ac->ac_bits_given += *num_clusters; 2350ccd979bdSMark Fasheh 2351ccd979bdSMark Fasheh bail: 2352c1e8d35eSTao Ma if (status) 2353c1e8d35eSTao Ma mlog_errno(status); 2354ccd979bdSMark Fasheh return status; 2355ccd979bdSMark Fasheh } 2356ccd979bdSMark Fasheh 23571ed9b777SJoel Becker int ocfs2_claim_clusters(handle_t *handle, 2358415cb800SMark Fasheh struct ocfs2_alloc_context *ac, 2359415cb800SMark Fasheh u32 min_clusters, 2360415cb800SMark Fasheh u32 *cluster_start, 2361415cb800SMark Fasheh u32 *num_clusters) 2362415cb800SMark Fasheh { 2363415cb800SMark Fasheh unsigned int bits_wanted = ac->ac_bits_wanted - ac->ac_bits_given; 2364415cb800SMark Fasheh 23651ed9b777SJoel Becker return __ocfs2_claim_clusters(handle, ac, min_clusters, 2366415cb800SMark Fasheh bits_wanted, cluster_start, num_clusters); 2367415cb800SMark Fasheh } 2368415cb800SMark Fasheh 2369b4414eeaSMark Fasheh static int ocfs2_block_group_clear_bits(handle_t *handle, 2370ccd979bdSMark Fasheh struct inode *alloc_inode, 2371ccd979bdSMark Fasheh struct ocfs2_group_desc *bg, 2372ccd979bdSMark Fasheh struct buffer_head *group_bh, 2373ccd979bdSMark Fasheh unsigned int bit_off, 2374b4414eeaSMark Fasheh unsigned int num_bits, 2375b4414eeaSMark Fasheh void (*undo_fn)(unsigned int bit, 2376b4414eeaSMark Fasheh unsigned long *bmap)) 2377ccd979bdSMark Fasheh { 2378ccd979bdSMark Fasheh int status; 2379ccd979bdSMark Fasheh unsigned int tmp; 2380ccd979bdSMark Fasheh struct ocfs2_group_desc *undo_bg = NULL; 2381ccd979bdSMark Fasheh 238242035306SJoel Becker /* The caller got this descriptor from 238342035306SJoel Becker * ocfs2_read_group_descriptor(). Any corruption is a code bug. */ 238442035306SJoel Becker BUG_ON(!OCFS2_IS_VALID_GROUP_DESC(bg)); 2385ccd979bdSMark Fasheh 23862f73e135STao Ma trace_ocfs2_block_group_clear_bits(bit_off, num_bits); 2387ccd979bdSMark Fasheh 2388b4414eeaSMark Fasheh BUG_ON(undo_fn && !ocfs2_is_cluster_bitmap(alloc_inode)); 23890cf2f763SJoel Becker status = ocfs2_journal_access_gd(handle, INODE_CACHE(alloc_inode), 2390b4414eeaSMark Fasheh group_bh, 2391b4414eeaSMark Fasheh undo_fn ? 2392b4414eeaSMark Fasheh OCFS2_JOURNAL_ACCESS_UNDO : 2393b4414eeaSMark Fasheh OCFS2_JOURNAL_ACCESS_WRITE); 2394ccd979bdSMark Fasheh if (status < 0) { 2395ccd979bdSMark Fasheh mlog_errno(status); 2396ccd979bdSMark Fasheh goto bail; 2397ccd979bdSMark Fasheh } 2398ccd979bdSMark Fasheh 2399b4414eeaSMark Fasheh if (undo_fn) { 240094e41ecfSSunil Mushran jbd_lock_bh_state(group_bh); 240194e41ecfSSunil Mushran undo_bg = (struct ocfs2_group_desc *) 240294e41ecfSSunil Mushran bh2jh(group_bh)->b_committed_data; 240394e41ecfSSunil Mushran BUG_ON(!undo_bg); 240494e41ecfSSunil Mushran } 2405ccd979bdSMark Fasheh 2406ccd979bdSMark Fasheh tmp = num_bits; 2407ccd979bdSMark Fasheh while(tmp--) { 2408ccd979bdSMark Fasheh ocfs2_clear_bit((bit_off + tmp), 2409ccd979bdSMark Fasheh (unsigned long *) bg->bg_bitmap); 2410b4414eeaSMark Fasheh if (undo_fn) 2411b4414eeaSMark Fasheh undo_fn(bit_off + tmp, 2412ccd979bdSMark Fasheh (unsigned long *) undo_bg->bg_bitmap); 2413ccd979bdSMark Fasheh } 2414ccd979bdSMark Fasheh le16_add_cpu(&bg->bg_free_bits_count, num_bits); 24159b5cd10eSSrinivas Eeda if (le16_to_cpu(bg->bg_free_bits_count) > le16_to_cpu(bg->bg_bits)) { 24169b5cd10eSSrinivas Eeda ocfs2_error(alloc_inode->i_sb, "Group descriptor # %llu has bit" 24179b5cd10eSSrinivas Eeda " count %u but claims %u are freed. num_bits %d", 24189b5cd10eSSrinivas Eeda (unsigned long long)le64_to_cpu(bg->bg_blkno), 24199b5cd10eSSrinivas Eeda le16_to_cpu(bg->bg_bits), 24209b5cd10eSSrinivas Eeda le16_to_cpu(bg->bg_free_bits_count), num_bits); 24219b5cd10eSSrinivas Eeda return -EROFS; 24229b5cd10eSSrinivas Eeda } 2423ccd979bdSMark Fasheh 2424b4414eeaSMark Fasheh if (undo_fn) 242594e41ecfSSunil Mushran jbd_unlock_bh_state(group_bh); 242694e41ecfSSunil Mushran 2427ec20cec7SJoel Becker ocfs2_journal_dirty(handle, group_bh); 2428ccd979bdSMark Fasheh bail: 2429ccd979bdSMark Fasheh return status; 2430ccd979bdSMark Fasheh } 2431ccd979bdSMark Fasheh 2432ccd979bdSMark Fasheh /* 2433ccd979bdSMark Fasheh * expects the suballoc inode to already be locked. 2434ccd979bdSMark Fasheh */ 2435b4414eeaSMark Fasheh static int _ocfs2_free_suballoc_bits(handle_t *handle, 2436ccd979bdSMark Fasheh struct inode *alloc_inode, 2437ccd979bdSMark Fasheh struct buffer_head *alloc_bh, 2438ccd979bdSMark Fasheh unsigned int start_bit, 2439ccd979bdSMark Fasheh u64 bg_blkno, 2440b4414eeaSMark Fasheh unsigned int count, 2441b4414eeaSMark Fasheh void (*undo_fn)(unsigned int bit, 2442b4414eeaSMark Fasheh unsigned long *bitmap)) 2443ccd979bdSMark Fasheh { 2444ccd979bdSMark Fasheh int status = 0; 2445ccd979bdSMark Fasheh u32 tmp_used; 2446ccd979bdSMark Fasheh struct ocfs2_dinode *fe = (struct ocfs2_dinode *) alloc_bh->b_data; 2447ccd979bdSMark Fasheh struct ocfs2_chain_list *cl = &fe->id2.i_chain; 2448ccd979bdSMark Fasheh struct buffer_head *group_bh = NULL; 2449ccd979bdSMark Fasheh struct ocfs2_group_desc *group; 2450ccd979bdSMark Fasheh 245110995aa2SJoel Becker /* The alloc_bh comes from ocfs2_free_dinode() or 245210995aa2SJoel Becker * ocfs2_free_clusters(). The callers have all locked the 245310995aa2SJoel Becker * allocator and gotten alloc_bh from the lock call. This 245425985edcSLucas De Marchi * validates the dinode buffer. Any corruption that has happened 245510995aa2SJoel Becker * is a code bug. */ 245610995aa2SJoel Becker BUG_ON(!OCFS2_IS_VALID_DINODE(fe)); 2457ccd979bdSMark Fasheh BUG_ON((count + start_bit) > ocfs2_bits_per_group(cl)); 2458ccd979bdSMark Fasheh 24592f73e135STao Ma trace_ocfs2_free_suballoc_bits( 24602f73e135STao Ma (unsigned long long)OCFS2_I(alloc_inode)->ip_blkno, 24612f73e135STao Ma (unsigned long long)bg_blkno, 24622f73e135STao Ma start_bit, count); 2463ccd979bdSMark Fasheh 246468f64d47SJoel Becker status = ocfs2_read_group_descriptor(alloc_inode, fe, bg_blkno, 246568f64d47SJoel Becker &group_bh); 2466ccd979bdSMark Fasheh if (status < 0) { 2467ccd979bdSMark Fasheh mlog_errno(status); 2468ccd979bdSMark Fasheh goto bail; 2469ccd979bdSMark Fasheh } 2470ccd979bdSMark Fasheh group = (struct ocfs2_group_desc *) group_bh->b_data; 247168f64d47SJoel Becker 2472ccd979bdSMark Fasheh BUG_ON((count + start_bit) > le16_to_cpu(group->bg_bits)); 2473ccd979bdSMark Fasheh 2474ccd979bdSMark Fasheh status = ocfs2_block_group_clear_bits(handle, alloc_inode, 2475ccd979bdSMark Fasheh group, group_bh, 2476b4414eeaSMark Fasheh start_bit, count, undo_fn); 2477ccd979bdSMark Fasheh if (status < 0) { 2478ccd979bdSMark Fasheh mlog_errno(status); 2479ccd979bdSMark Fasheh goto bail; 2480ccd979bdSMark Fasheh } 2481ccd979bdSMark Fasheh 24820cf2f763SJoel Becker status = ocfs2_journal_access_di(handle, INODE_CACHE(alloc_inode), 24830cf2f763SJoel Becker alloc_bh, OCFS2_JOURNAL_ACCESS_WRITE); 2484ccd979bdSMark Fasheh if (status < 0) { 2485ccd979bdSMark Fasheh mlog_errno(status); 2486ccd979bdSMark Fasheh goto bail; 2487ccd979bdSMark Fasheh } 2488ccd979bdSMark Fasheh 2489ccd979bdSMark Fasheh le32_add_cpu(&cl->cl_recs[le16_to_cpu(group->bg_chain)].c_free, 2490ccd979bdSMark Fasheh count); 2491ccd979bdSMark Fasheh tmp_used = le32_to_cpu(fe->id1.bitmap1.i_used); 2492ccd979bdSMark Fasheh fe->id1.bitmap1.i_used = cpu_to_le32(tmp_used - count); 2493ec20cec7SJoel Becker ocfs2_journal_dirty(handle, alloc_bh); 2494ccd979bdSMark Fasheh 2495ccd979bdSMark Fasheh bail: 2496ccd979bdSMark Fasheh brelse(group_bh); 2497ccd979bdSMark Fasheh 2498c1e8d35eSTao Ma if (status) 2499c1e8d35eSTao Ma mlog_errno(status); 2500ccd979bdSMark Fasheh return status; 2501ccd979bdSMark Fasheh } 2502ccd979bdSMark Fasheh 2503b4414eeaSMark Fasheh int ocfs2_free_suballoc_bits(handle_t *handle, 2504b4414eeaSMark Fasheh struct inode *alloc_inode, 2505b4414eeaSMark Fasheh struct buffer_head *alloc_bh, 2506b4414eeaSMark Fasheh unsigned int start_bit, 2507b4414eeaSMark Fasheh u64 bg_blkno, 2508b4414eeaSMark Fasheh unsigned int count) 2509b4414eeaSMark Fasheh { 2510b4414eeaSMark Fasheh return _ocfs2_free_suballoc_bits(handle, alloc_inode, alloc_bh, 2511b4414eeaSMark Fasheh start_bit, bg_blkno, count, NULL); 2512b4414eeaSMark Fasheh } 2513b4414eeaSMark Fasheh 25141fabe148SMark Fasheh int ocfs2_free_dinode(handle_t *handle, 2515ccd979bdSMark Fasheh struct inode *inode_alloc_inode, 2516ccd979bdSMark Fasheh struct buffer_head *inode_alloc_bh, 2517ccd979bdSMark Fasheh struct ocfs2_dinode *di) 2518ccd979bdSMark Fasheh { 2519ccd979bdSMark Fasheh u64 blk = le64_to_cpu(di->i_blkno); 2520ccd979bdSMark Fasheh u16 bit = le16_to_cpu(di->i_suballoc_bit); 2521ccd979bdSMark Fasheh u64 bg_blkno = ocfs2_which_suballoc_group(blk, bit); 2522ccd979bdSMark Fasheh 252374380c47STao Ma if (di->i_suballoc_loc) 252474380c47STao Ma bg_blkno = le64_to_cpu(di->i_suballoc_loc); 2525ccd979bdSMark Fasheh return ocfs2_free_suballoc_bits(handle, inode_alloc_inode, 2526ccd979bdSMark Fasheh inode_alloc_bh, bit, bg_blkno, 1); 2527ccd979bdSMark Fasheh } 2528ccd979bdSMark Fasheh 2529b4414eeaSMark Fasheh static int _ocfs2_free_clusters(handle_t *handle, 2530ccd979bdSMark Fasheh struct inode *bitmap_inode, 2531ccd979bdSMark Fasheh struct buffer_head *bitmap_bh, 2532ccd979bdSMark Fasheh u64 start_blk, 2533b4414eeaSMark Fasheh unsigned int num_clusters, 2534b4414eeaSMark Fasheh void (*undo_fn)(unsigned int bit, 2535b4414eeaSMark Fasheh unsigned long *bitmap)) 2536ccd979bdSMark Fasheh { 2537ccd979bdSMark Fasheh int status; 2538ccd979bdSMark Fasheh u16 bg_start_bit; 2539ccd979bdSMark Fasheh u64 bg_blkno; 2540ccd979bdSMark Fasheh struct ocfs2_dinode *fe; 2541ccd979bdSMark Fasheh 2542ccd979bdSMark Fasheh /* You can't ever have a contiguous set of clusters 2543ccd979bdSMark Fasheh * bigger than a block group bitmap so we never have to worry 2544ef6b689bSTao Ma * about looping on them. 2545ef6b689bSTao Ma * This is expensive. We can safely remove once this stuff has 2546ccd979bdSMark Fasheh * gotten tested really well. */ 2547ccd979bdSMark Fasheh BUG_ON(start_blk != ocfs2_clusters_to_blocks(bitmap_inode->i_sb, ocfs2_blocks_to_clusters(bitmap_inode->i_sb, start_blk))); 2548ccd979bdSMark Fasheh 2549ccd979bdSMark Fasheh fe = (struct ocfs2_dinode *) bitmap_bh->b_data; 2550ccd979bdSMark Fasheh 2551ccd979bdSMark Fasheh ocfs2_block_to_cluster_group(bitmap_inode, start_blk, &bg_blkno, 2552ccd979bdSMark Fasheh &bg_start_bit); 2553ccd979bdSMark Fasheh 25542f73e135STao Ma trace_ocfs2_free_clusters((unsigned long long)bg_blkno, 25552f73e135STao Ma (unsigned long long)start_blk, 25562f73e135STao Ma bg_start_bit, num_clusters); 2557ccd979bdSMark Fasheh 2558b4414eeaSMark Fasheh status = _ocfs2_free_suballoc_bits(handle, bitmap_inode, bitmap_bh, 2559ccd979bdSMark Fasheh bg_start_bit, bg_blkno, 2560b4414eeaSMark Fasheh num_clusters, undo_fn); 25619c7af40bSMark Fasheh if (status < 0) { 2562ccd979bdSMark Fasheh mlog_errno(status); 25639c7af40bSMark Fasheh goto out; 25649c7af40bSMark Fasheh } 2565ccd979bdSMark Fasheh 25669c7af40bSMark Fasheh ocfs2_local_alloc_seen_free_bits(OCFS2_SB(bitmap_inode->i_sb), 25679c7af40bSMark Fasheh num_clusters); 25689c7af40bSMark Fasheh 25699c7af40bSMark Fasheh out: 2570c1e8d35eSTao Ma if (status) 2571c1e8d35eSTao Ma mlog_errno(status); 2572ccd979bdSMark Fasheh return status; 2573ccd979bdSMark Fasheh } 2574ccd979bdSMark Fasheh 2575b4414eeaSMark Fasheh int ocfs2_free_clusters(handle_t *handle, 2576b4414eeaSMark Fasheh struct inode *bitmap_inode, 2577b4414eeaSMark Fasheh struct buffer_head *bitmap_bh, 2578b4414eeaSMark Fasheh u64 start_blk, 2579b4414eeaSMark Fasheh unsigned int num_clusters) 2580b4414eeaSMark Fasheh { 2581b4414eeaSMark Fasheh return _ocfs2_free_clusters(handle, bitmap_inode, bitmap_bh, 2582b4414eeaSMark Fasheh start_blk, num_clusters, 2583b4414eeaSMark Fasheh _ocfs2_set_bit); 2584b4414eeaSMark Fasheh } 2585b4414eeaSMark Fasheh 2586b4414eeaSMark Fasheh /* 2587b4414eeaSMark Fasheh * Give never-used clusters back to the global bitmap. We don't need 2588b4414eeaSMark Fasheh * to protect these bits in the undo buffer. 2589b4414eeaSMark Fasheh */ 2590b4414eeaSMark Fasheh int ocfs2_release_clusters(handle_t *handle, 2591b4414eeaSMark Fasheh struct inode *bitmap_inode, 2592b4414eeaSMark Fasheh struct buffer_head *bitmap_bh, 2593b4414eeaSMark Fasheh u64 start_blk, 2594b4414eeaSMark Fasheh unsigned int num_clusters) 2595b4414eeaSMark Fasheh { 2596b4414eeaSMark Fasheh return _ocfs2_free_clusters(handle, bitmap_inode, bitmap_bh, 2597b4414eeaSMark Fasheh start_blk, num_clusters, 2598b4414eeaSMark Fasheh _ocfs2_clear_bit); 2599b4414eeaSMark Fasheh } 2600b4414eeaSMark Fasheh 2601ccd979bdSMark Fasheh static inline void ocfs2_debug_bg(struct ocfs2_group_desc *bg) 2602ccd979bdSMark Fasheh { 2603ccd979bdSMark Fasheh printk("Block Group:\n"); 2604ccd979bdSMark Fasheh printk("bg_signature: %s\n", bg->bg_signature); 2605ccd979bdSMark Fasheh printk("bg_size: %u\n", bg->bg_size); 2606ccd979bdSMark Fasheh printk("bg_bits: %u\n", bg->bg_bits); 2607ccd979bdSMark Fasheh printk("bg_free_bits_count: %u\n", bg->bg_free_bits_count); 2608ccd979bdSMark Fasheh printk("bg_chain: %u\n", bg->bg_chain); 2609ccd979bdSMark Fasheh printk("bg_generation: %u\n", le32_to_cpu(bg->bg_generation)); 2610b0697053SMark Fasheh printk("bg_next_group: %llu\n", 2611b0697053SMark Fasheh (unsigned long long)bg->bg_next_group); 2612b0697053SMark Fasheh printk("bg_parent_dinode: %llu\n", 2613b0697053SMark Fasheh (unsigned long long)bg->bg_parent_dinode); 2614b0697053SMark Fasheh printk("bg_blkno: %llu\n", 2615b0697053SMark Fasheh (unsigned long long)bg->bg_blkno); 2616ccd979bdSMark Fasheh } 2617ccd979bdSMark Fasheh 2618ccd979bdSMark Fasheh static inline void ocfs2_debug_suballoc_inode(struct ocfs2_dinode *fe) 2619ccd979bdSMark Fasheh { 2620ccd979bdSMark Fasheh int i; 2621ccd979bdSMark Fasheh 2622b0697053SMark Fasheh printk("Suballoc Inode %llu:\n", (unsigned long long)fe->i_blkno); 2623ccd979bdSMark Fasheh printk("i_signature: %s\n", fe->i_signature); 2624b0697053SMark Fasheh printk("i_size: %llu\n", 2625b0697053SMark Fasheh (unsigned long long)fe->i_size); 2626ccd979bdSMark Fasheh printk("i_clusters: %u\n", fe->i_clusters); 2627ccd979bdSMark Fasheh printk("i_generation: %u\n", 2628ccd979bdSMark Fasheh le32_to_cpu(fe->i_generation)); 2629ccd979bdSMark Fasheh printk("id1.bitmap1.i_used: %u\n", 2630ccd979bdSMark Fasheh le32_to_cpu(fe->id1.bitmap1.i_used)); 2631ccd979bdSMark Fasheh printk("id1.bitmap1.i_total: %u\n", 2632ccd979bdSMark Fasheh le32_to_cpu(fe->id1.bitmap1.i_total)); 2633ccd979bdSMark Fasheh printk("id2.i_chain.cl_cpg: %u\n", fe->id2.i_chain.cl_cpg); 2634ccd979bdSMark Fasheh printk("id2.i_chain.cl_bpc: %u\n", fe->id2.i_chain.cl_bpc); 2635ccd979bdSMark Fasheh printk("id2.i_chain.cl_count: %u\n", fe->id2.i_chain.cl_count); 2636ccd979bdSMark Fasheh printk("id2.i_chain.cl_next_free_rec: %u\n", 2637ccd979bdSMark Fasheh fe->id2.i_chain.cl_next_free_rec); 2638ccd979bdSMark Fasheh for(i = 0; i < fe->id2.i_chain.cl_next_free_rec; i++) { 2639ccd979bdSMark Fasheh printk("fe->id2.i_chain.cl_recs[%d].c_free: %u\n", i, 2640ccd979bdSMark Fasheh fe->id2.i_chain.cl_recs[i].c_free); 2641ccd979bdSMark Fasheh printk("fe->id2.i_chain.cl_recs[%d].c_total: %u\n", i, 2642ccd979bdSMark Fasheh fe->id2.i_chain.cl_recs[i].c_total); 2643b0697053SMark Fasheh printk("fe->id2.i_chain.cl_recs[%d].c_blkno: %llu\n", i, 2644b0697053SMark Fasheh (unsigned long long)fe->id2.i_chain.cl_recs[i].c_blkno); 2645ccd979bdSMark Fasheh } 2646ccd979bdSMark Fasheh } 2647e7d4cb6bSTao Ma 2648e7d4cb6bSTao Ma /* 2649e7d4cb6bSTao Ma * For a given allocation, determine which allocators will need to be 2650e7d4cb6bSTao Ma * accessed, and lock them, reserving the appropriate number of bits. 2651e7d4cb6bSTao Ma * 2652e7d4cb6bSTao Ma * Sparse file systems call this from ocfs2_write_begin_nolock() 2653e7d4cb6bSTao Ma * and ocfs2_allocate_unwritten_extents(). 2654e7d4cb6bSTao Ma * 2655e7d4cb6bSTao Ma * File systems which don't support holes call this from 2656e7d4cb6bSTao Ma * ocfs2_extend_allocation(). 2657e7d4cb6bSTao Ma */ 2658f99b9b7cSJoel Becker int ocfs2_lock_allocators(struct inode *inode, 2659f99b9b7cSJoel Becker struct ocfs2_extent_tree *et, 2660e7d4cb6bSTao Ma u32 clusters_to_add, u32 extents_to_split, 2661e7d4cb6bSTao Ma struct ocfs2_alloc_context **data_ac, 2662f99b9b7cSJoel Becker struct ocfs2_alloc_context **meta_ac) 2663e7d4cb6bSTao Ma { 2664e7d4cb6bSTao Ma int ret = 0, num_free_extents; 2665e7d4cb6bSTao Ma unsigned int max_recs_needed = clusters_to_add + 2 * extents_to_split; 2666e7d4cb6bSTao Ma struct ocfs2_super *osb = OCFS2_SB(inode->i_sb); 2667e7d4cb6bSTao Ma 2668e7d4cb6bSTao Ma *meta_ac = NULL; 2669e7d4cb6bSTao Ma if (data_ac) 2670e7d4cb6bSTao Ma *data_ac = NULL; 2671e7d4cb6bSTao Ma 2672e7d4cb6bSTao Ma BUG_ON(clusters_to_add != 0 && data_ac == NULL); 2673e7d4cb6bSTao Ma 26743d03a305SJoel Becker num_free_extents = ocfs2_num_free_extents(osb, et); 2675e7d4cb6bSTao Ma if (num_free_extents < 0) { 2676e7d4cb6bSTao Ma ret = num_free_extents; 2677e7d4cb6bSTao Ma mlog_errno(ret); 2678e7d4cb6bSTao Ma goto out; 2679e7d4cb6bSTao Ma } 2680e7d4cb6bSTao Ma 2681e7d4cb6bSTao Ma /* 2682e7d4cb6bSTao Ma * Sparse allocation file systems need to be more conservative 2683e7d4cb6bSTao Ma * with reserving room for expansion - the actual allocation 2684e7d4cb6bSTao Ma * happens while we've got a journal handle open so re-taking 2685e7d4cb6bSTao Ma * a cluster lock (because we ran out of room for another 2686e7d4cb6bSTao Ma * extent) will violate ordering rules. 2687e7d4cb6bSTao Ma * 2688e7d4cb6bSTao Ma * Most of the time we'll only be seeing this 1 cluster at a time 2689e7d4cb6bSTao Ma * anyway. 2690e7d4cb6bSTao Ma * 2691e7d4cb6bSTao Ma * Always lock for any unwritten extents - we might want to 2692e7d4cb6bSTao Ma * add blocks during a split. 2693e7d4cb6bSTao Ma */ 2694e7d4cb6bSTao Ma if (!num_free_extents || 2695e7d4cb6bSTao Ma (ocfs2_sparse_alloc(osb) && num_free_extents < max_recs_needed)) { 2696f99b9b7cSJoel Becker ret = ocfs2_reserve_new_metadata(osb, et->et_root_el, meta_ac); 2697e7d4cb6bSTao Ma if (ret < 0) { 2698e7d4cb6bSTao Ma if (ret != -ENOSPC) 2699e7d4cb6bSTao Ma mlog_errno(ret); 2700e7d4cb6bSTao Ma goto out; 2701e7d4cb6bSTao Ma } 2702e7d4cb6bSTao Ma } 2703e7d4cb6bSTao Ma 2704e7d4cb6bSTao Ma if (clusters_to_add == 0) 2705e7d4cb6bSTao Ma goto out; 2706e7d4cb6bSTao Ma 2707e7d4cb6bSTao Ma ret = ocfs2_reserve_clusters(osb, clusters_to_add, data_ac); 2708e7d4cb6bSTao Ma if (ret < 0) { 2709e7d4cb6bSTao Ma if (ret != -ENOSPC) 2710e7d4cb6bSTao Ma mlog_errno(ret); 2711e7d4cb6bSTao Ma goto out; 2712e7d4cb6bSTao Ma } 2713e7d4cb6bSTao Ma 2714e7d4cb6bSTao Ma out: 2715e7d4cb6bSTao Ma if (ret) { 2716e7d4cb6bSTao Ma if (*meta_ac) { 2717e7d4cb6bSTao Ma ocfs2_free_alloc_context(*meta_ac); 2718e7d4cb6bSTao Ma *meta_ac = NULL; 2719e7d4cb6bSTao Ma } 2720e7d4cb6bSTao Ma 2721e7d4cb6bSTao Ma /* 2722e7d4cb6bSTao Ma * We cannot have an error and a non null *data_ac. 2723e7d4cb6bSTao Ma */ 2724e7d4cb6bSTao Ma } 2725e7d4cb6bSTao Ma 2726e7d4cb6bSTao Ma return ret; 2727e7d4cb6bSTao Ma } 27286ca497a8Swengang wang 27296ca497a8Swengang wang /* 27306ca497a8Swengang wang * Read the inode specified by blkno to get suballoc_slot and 27316ca497a8Swengang wang * suballoc_bit. 27326ca497a8Swengang wang */ 27336ca497a8Swengang wang static int ocfs2_get_suballoc_slot_bit(struct ocfs2_super *osb, u64 blkno, 2734889f004aSTao Ma u16 *suballoc_slot, u64 *group_blkno, 2735889f004aSTao Ma u16 *suballoc_bit) 27366ca497a8Swengang wang { 27376ca497a8Swengang wang int status; 27386ca497a8Swengang wang struct buffer_head *inode_bh = NULL; 27396ca497a8Swengang wang struct ocfs2_dinode *inode_fe; 27406ca497a8Swengang wang 27412f73e135STao Ma trace_ocfs2_get_suballoc_slot_bit((unsigned long long)blkno); 27426ca497a8Swengang wang 27436ca497a8Swengang wang /* dirty read disk */ 27446ca497a8Swengang wang status = ocfs2_read_blocks_sync(osb, blkno, 1, &inode_bh); 27456ca497a8Swengang wang if (status < 0) { 27465b09b507SJoel Becker mlog(ML_ERROR, "read block %llu failed %d\n", 27475b09b507SJoel Becker (unsigned long long)blkno, status); 27486ca497a8Swengang wang goto bail; 27496ca497a8Swengang wang } 27506ca497a8Swengang wang 27516ca497a8Swengang wang inode_fe = (struct ocfs2_dinode *) inode_bh->b_data; 27526ca497a8Swengang wang if (!OCFS2_IS_VALID_DINODE(inode_fe)) { 27535b09b507SJoel Becker mlog(ML_ERROR, "invalid inode %llu requested\n", 27545b09b507SJoel Becker (unsigned long long)blkno); 27556ca497a8Swengang wang status = -EINVAL; 27566ca497a8Swengang wang goto bail; 27576ca497a8Swengang wang } 27586ca497a8Swengang wang 27590fba8137STao Ma if (le16_to_cpu(inode_fe->i_suballoc_slot) != (u16)OCFS2_INVALID_SLOT && 27606ca497a8Swengang wang (u32)le16_to_cpu(inode_fe->i_suballoc_slot) > osb->max_slots - 1) { 27616ca497a8Swengang wang mlog(ML_ERROR, "inode %llu has invalid suballoc slot %u\n", 27625b09b507SJoel Becker (unsigned long long)blkno, 27635b09b507SJoel Becker (u32)le16_to_cpu(inode_fe->i_suballoc_slot)); 27646ca497a8Swengang wang status = -EINVAL; 27656ca497a8Swengang wang goto bail; 27666ca497a8Swengang wang } 27676ca497a8Swengang wang 27686ca497a8Swengang wang if (suballoc_slot) 27696ca497a8Swengang wang *suballoc_slot = le16_to_cpu(inode_fe->i_suballoc_slot); 27706ca497a8Swengang wang if (suballoc_bit) 27716ca497a8Swengang wang *suballoc_bit = le16_to_cpu(inode_fe->i_suballoc_bit); 2772889f004aSTao Ma if (group_blkno) 2773889f004aSTao Ma *group_blkno = le64_to_cpu(inode_fe->i_suballoc_loc); 27746ca497a8Swengang wang 27756ca497a8Swengang wang bail: 27766ca497a8Swengang wang brelse(inode_bh); 27776ca497a8Swengang wang 2778c1e8d35eSTao Ma if (status) 2779c1e8d35eSTao Ma mlog_errno(status); 27806ca497a8Swengang wang return status; 27816ca497a8Swengang wang } 27826ca497a8Swengang wang 27836ca497a8Swengang wang /* 27846ca497a8Swengang wang * test whether bit is SET in allocator bitmap or not. on success, 0 27856ca497a8Swengang wang * is returned and *res is 1 for SET; 0 otherwise. when fails, errno 27866ca497a8Swengang wang * is returned and *res is meaningless. Call this after you have 27876ca497a8Swengang wang * cluster locked against suballoc, or you may get a result based on 27886ca497a8Swengang wang * non-up2date contents 27896ca497a8Swengang wang */ 27906ca497a8Swengang wang static int ocfs2_test_suballoc_bit(struct ocfs2_super *osb, 27916ca497a8Swengang wang struct inode *suballoc, 2792889f004aSTao Ma struct buffer_head *alloc_bh, 2793889f004aSTao Ma u64 group_blkno, u64 blkno, 27946ca497a8Swengang wang u16 bit, int *res) 27956ca497a8Swengang wang { 2796abf1b3cbSTao Ma struct ocfs2_dinode *alloc_di; 27976ca497a8Swengang wang struct ocfs2_group_desc *group; 27986ca497a8Swengang wang struct buffer_head *group_bh = NULL; 27996ca497a8Swengang wang u64 bg_blkno; 28006ca497a8Swengang wang int status; 28016ca497a8Swengang wang 28022f73e135STao Ma trace_ocfs2_test_suballoc_bit((unsigned long long)blkno, 28035b09b507SJoel Becker (unsigned int)bit); 28046ca497a8Swengang wang 2805abf1b3cbSTao Ma alloc_di = (struct ocfs2_dinode *)alloc_bh->b_data; 2806abf1b3cbSTao Ma if ((bit + 1) > ocfs2_bits_per_group(&alloc_di->id2.i_chain)) { 28076ca497a8Swengang wang mlog(ML_ERROR, "suballoc bit %u out of range of %u\n", 28086ca497a8Swengang wang (unsigned int)bit, 2809abf1b3cbSTao Ma ocfs2_bits_per_group(&alloc_di->id2.i_chain)); 28106ca497a8Swengang wang status = -EINVAL; 28116ca497a8Swengang wang goto bail; 28126ca497a8Swengang wang } 28136ca497a8Swengang wang 2814889f004aSTao Ma bg_blkno = group_blkno ? group_blkno : 2815889f004aSTao Ma ocfs2_which_suballoc_group(blkno, bit); 2816abf1b3cbSTao Ma status = ocfs2_read_group_descriptor(suballoc, alloc_di, bg_blkno, 28176ca497a8Swengang wang &group_bh); 28186ca497a8Swengang wang if (status < 0) { 28195b09b507SJoel Becker mlog(ML_ERROR, "read group %llu failed %d\n", 28205b09b507SJoel Becker (unsigned long long)bg_blkno, status); 28216ca497a8Swengang wang goto bail; 28226ca497a8Swengang wang } 28236ca497a8Swengang wang 28246ca497a8Swengang wang group = (struct ocfs2_group_desc *) group_bh->b_data; 28256ca497a8Swengang wang *res = ocfs2_test_bit(bit, (unsigned long *)group->bg_bitmap); 28266ca497a8Swengang wang 28276ca497a8Swengang wang bail: 28286ca497a8Swengang wang brelse(group_bh); 28296ca497a8Swengang wang 2830c1e8d35eSTao Ma if (status) 2831c1e8d35eSTao Ma mlog_errno(status); 28326ca497a8Swengang wang return status; 28336ca497a8Swengang wang } 28346ca497a8Swengang wang 28356ca497a8Swengang wang /* 28366ca497a8Swengang wang * Test if the bit representing this inode (blkno) is set in the 28376ca497a8Swengang wang * suballocator. 28386ca497a8Swengang wang * 28396ca497a8Swengang wang * On success, 0 is returned and *res is 1 for SET; 0 otherwise. 28406ca497a8Swengang wang * 28416ca497a8Swengang wang * In the event of failure, a negative value is returned and *res is 28426ca497a8Swengang wang * meaningless. 28436ca497a8Swengang wang * 28446ca497a8Swengang wang * Callers must make sure to hold nfs_sync_lock to prevent 28456ca497a8Swengang wang * ocfs2_delete_inode() on another node from accessing the same 28466ca497a8Swengang wang * suballocator concurrently. 28476ca497a8Swengang wang */ 28486ca497a8Swengang wang int ocfs2_test_inode_bit(struct ocfs2_super *osb, u64 blkno, int *res) 28496ca497a8Swengang wang { 28506ca497a8Swengang wang int status; 2851889f004aSTao Ma u64 group_blkno = 0; 28526ca497a8Swengang wang u16 suballoc_bit = 0, suballoc_slot = 0; 28536ca497a8Swengang wang struct inode *inode_alloc_inode; 28546ca497a8Swengang wang struct buffer_head *alloc_bh = NULL; 28556ca497a8Swengang wang 28562f73e135STao Ma trace_ocfs2_test_inode_bit((unsigned long long)blkno); 28576ca497a8Swengang wang 28586ca497a8Swengang wang status = ocfs2_get_suballoc_slot_bit(osb, blkno, &suballoc_slot, 2859889f004aSTao Ma &group_blkno, &suballoc_bit); 28606ca497a8Swengang wang if (status < 0) { 28616ca497a8Swengang wang mlog(ML_ERROR, "get alloc slot and bit failed %d\n", status); 28626ca497a8Swengang wang goto bail; 28636ca497a8Swengang wang } 28646ca497a8Swengang wang 28656ca497a8Swengang wang inode_alloc_inode = 28666ca497a8Swengang wang ocfs2_get_system_file_inode(osb, INODE_ALLOC_SYSTEM_INODE, 28676ca497a8Swengang wang suballoc_slot); 28686ca497a8Swengang wang if (!inode_alloc_inode) { 28696ca497a8Swengang wang /* the error code could be inaccurate, but we are not able to 28706ca497a8Swengang wang * get the correct one. */ 28716ca497a8Swengang wang status = -EINVAL; 28726ca497a8Swengang wang mlog(ML_ERROR, "unable to get alloc inode in slot %u\n", 28736ca497a8Swengang wang (u32)suballoc_slot); 28746ca497a8Swengang wang goto bail; 28756ca497a8Swengang wang } 28766ca497a8Swengang wang 28776ca497a8Swengang wang mutex_lock(&inode_alloc_inode->i_mutex); 28786ca497a8Swengang wang status = ocfs2_inode_lock(inode_alloc_inode, &alloc_bh, 0); 28796ca497a8Swengang wang if (status < 0) { 28806ca497a8Swengang wang mutex_unlock(&inode_alloc_inode->i_mutex); 28816ca497a8Swengang wang mlog(ML_ERROR, "lock on alloc inode on slot %u failed %d\n", 28826ca497a8Swengang wang (u32)suballoc_slot, status); 28836ca497a8Swengang wang goto bail; 28846ca497a8Swengang wang } 28856ca497a8Swengang wang 28866ca497a8Swengang wang status = ocfs2_test_suballoc_bit(osb, inode_alloc_inode, alloc_bh, 2887889f004aSTao Ma group_blkno, blkno, suballoc_bit, res); 28886ca497a8Swengang wang if (status < 0) 28896ca497a8Swengang wang mlog(ML_ERROR, "test suballoc bit failed %d\n", status); 28906ca497a8Swengang wang 28916ca497a8Swengang wang ocfs2_inode_unlock(inode_alloc_inode, 0); 28926ca497a8Swengang wang mutex_unlock(&inode_alloc_inode->i_mutex); 28936ca497a8Swengang wang 28946ca497a8Swengang wang iput(inode_alloc_inode); 28956ca497a8Swengang wang brelse(alloc_bh); 28966ca497a8Swengang wang bail: 2897c1e8d35eSTao Ma if (status) 2898c1e8d35eSTao Ma mlog_errno(status); 28996ca497a8Swengang wang return status; 29006ca497a8Swengang wang } 2901