Blame view
fs/ocfs2/quota_global.c
26.7 KB
9e33d69f5 ocfs2: Implementa... |
1 2 3 |
/* * Implementation of operations over global quota file */ |
171bf93ce ocfs2: Periodic q... |
4 |
#include <linux/spinlock.h> |
9e33d69f5 ocfs2: Implementa... |
5 |
#include <linux/fs.h> |
5a0e3ad6a include cleanup: ... |
6 |
#include <linux/slab.h> |
9e33d69f5 ocfs2: Implementa... |
7 8 9 |
#include <linux/quota.h> #include <linux/quotaops.h> #include <linux/dqblk_qtree.h> |
171bf93ce ocfs2: Periodic q... |
10 11 12 |
#include <linux/jiffies.h> #include <linux/writeback.h> #include <linux/workqueue.h> |
9e33d69f5 ocfs2: Implementa... |
13 |
|
9e33d69f5 ocfs2: Implementa... |
14 15 16 17 18 |
#include <cluster/masklog.h> #include "ocfs2_fs.h" #include "ocfs2.h" #include "alloc.h" |
d6b32bbb3 ocfs2: block read... |
19 |
#include "blockcheck.h" |
9e33d69f5 ocfs2: Implementa... |
20 21 22 23 24 25 |
#include "inode.h" #include "journal.h" #include "file.h" #include "sysfile.h" #include "dlmglue.h" #include "uptodate.h" |
ada508274 ocfs2: Handle quo... |
26 |
#include "super.h" |
f64dd44eb ocfs2: Do not map... |
27 |
#include "buffer_head_io.h" |
9e33d69f5 ocfs2: Implementa... |
28 |
#include "quota.h" |
1db986a83 ocfs2: Remove mas... |
29 |
#include "ocfs2_trace.h" |
9e33d69f5 ocfs2: Implementa... |
30 |
|
fb8dd8d78 ocfs2: Fix quota ... |
31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 |
/* * Locking of quotas with OCFS2 is rather complex. Here are rules that * should be obeyed by all the functions: * - any write of quota structure (either to local or global file) is protected * by dqio_mutex or dquot->dq_lock. * - any modification of global quota file holds inode cluster lock, i_mutex, * and ip_alloc_sem of the global quota file (achieved by * ocfs2_lock_global_qf). It also has to hold qinfo_lock. * - an allocation of new blocks for local quota file is protected by * its ip_alloc_sem * * A rough sketch of locking dependencies (lf = local file, gf = global file): * Normal filesystem operation: * start_trans -> dqio_mutex -> write to lf * Syncing of local and global file: * ocfs2_lock_global_qf -> start_trans -> dqio_mutex -> qinfo_lock -> * write to gf * -> write to lf * Acquire dquot for the first time: * dq_lock -> ocfs2_lock_global_qf -> qinfo_lock -> read from gf * -> alloc space for gf * -> start_trans -> qinfo_lock -> write to gf * -> ip_alloc_sem of lf -> alloc space for lf * -> write to lf * Release last reference to dquot: * dq_lock -> ocfs2_lock_global_qf -> start_trans -> qinfo_lock -> write to gf * -> write to lf * Note that all the above operations also hold the inode cluster lock of lf. * Recovery: * inode cluster lock of recovered lf * -> read bitmaps -> ip_alloc_sem of lf * -> ocfs2_lock_global_qf -> start_trans -> dqio_mutex -> qinfo_lock -> * write to gf */ |
171bf93ce ocfs2: Periodic q... |
65 |
static void qsync_work_fn(struct work_struct *work); |
9e33d69f5 ocfs2: Implementa... |
66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 |
static void ocfs2_global_disk2memdqb(struct dquot *dquot, void *dp) { struct ocfs2_global_disk_dqblk *d = dp; struct mem_dqblk *m = &dquot->dq_dqb; /* Update from disk only entries not set by the admin */ if (!test_bit(DQ_LASTSET_B + QIF_ILIMITS_B, &dquot->dq_flags)) { m->dqb_ihardlimit = le64_to_cpu(d->dqb_ihardlimit); m->dqb_isoftlimit = le64_to_cpu(d->dqb_isoftlimit); } if (!test_bit(DQ_LASTSET_B + QIF_INODES_B, &dquot->dq_flags)) m->dqb_curinodes = le64_to_cpu(d->dqb_curinodes); if (!test_bit(DQ_LASTSET_B + QIF_BLIMITS_B, &dquot->dq_flags)) { m->dqb_bhardlimit = le64_to_cpu(d->dqb_bhardlimit); m->dqb_bsoftlimit = le64_to_cpu(d->dqb_bsoftlimit); } if (!test_bit(DQ_LASTSET_B + QIF_SPACE_B, &dquot->dq_flags)) m->dqb_curspace = le64_to_cpu(d->dqb_curspace); if (!test_bit(DQ_LASTSET_B + QIF_BTIME_B, &dquot->dq_flags)) m->dqb_btime = le64_to_cpu(d->dqb_btime); if (!test_bit(DQ_LASTSET_B + QIF_ITIME_B, &dquot->dq_flags)) m->dqb_itime = le64_to_cpu(d->dqb_itime); OCFS2_DQUOT(dquot)->dq_use_count = le32_to_cpu(d->dqb_use_count); } static void ocfs2_global_mem2diskdqb(void *dp, struct dquot *dquot) { struct ocfs2_global_disk_dqblk *d = dp; struct mem_dqblk *m = &dquot->dq_dqb; d->dqb_id = cpu_to_le32(dquot->dq_id); d->dqb_use_count = cpu_to_le32(OCFS2_DQUOT(dquot)->dq_use_count); d->dqb_ihardlimit = cpu_to_le64(m->dqb_ihardlimit); d->dqb_isoftlimit = cpu_to_le64(m->dqb_isoftlimit); d->dqb_curinodes = cpu_to_le64(m->dqb_curinodes); d->dqb_bhardlimit = cpu_to_le64(m->dqb_bhardlimit); d->dqb_bsoftlimit = cpu_to_le64(m->dqb_bsoftlimit); d->dqb_curspace = cpu_to_le64(m->dqb_curspace); d->dqb_btime = cpu_to_le64(m->dqb_btime); d->dqb_itime = cpu_to_le64(m->dqb_itime); |
7669f54c5 ocfs2: Zero out p... |
106 |
d->dqb_pad1 = d->dqb_pad2 = 0; |
9e33d69f5 ocfs2: Implementa... |
107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 |
} static int ocfs2_global_is_id(void *dp, struct dquot *dquot) { struct ocfs2_global_disk_dqblk *d = dp; struct ocfs2_mem_dqinfo *oinfo = sb_dqinfo(dquot->dq_sb, dquot->dq_type)->dqi_priv; if (qtree_entry_unused(&oinfo->dqi_gi, dp)) return 0; return le32_to_cpu(d->dqb_id) == dquot->dq_id; } struct qtree_fmt_operations ocfs2_global_ops = { .mem2disk_dqblk = ocfs2_global_mem2diskdqb, .disk2mem_dqblk = ocfs2_global_disk2memdqb, .is_id = ocfs2_global_is_id, }; |
fb8dd8d78 ocfs2: Fix quota ... |
125 |
int ocfs2_validate_quota_block(struct super_block *sb, struct buffer_head *bh) |
684ef2783 ocfs2: Add a vali... |
126 |
{ |
d6b32bbb3 ocfs2: block read... |
127 128 |
struct ocfs2_disk_dqtrailer *dqt = ocfs2_block_dqtrailer(sb->s_blocksize, bh->b_data); |
684ef2783 ocfs2: Add a vali... |
129 |
|
1db986a83 ocfs2: Remove mas... |
130 |
trace_ocfs2_validate_quota_block((unsigned long long)bh->b_blocknr); |
684ef2783 ocfs2: Add a vali... |
131 |
|
d6b32bbb3 ocfs2: block read... |
132 133 134 135 136 137 138 139 |
BUG_ON(!buffer_uptodate(bh)); /* * If the ecc fails, we return the error but otherwise * leave the filesystem running. We know any error is * local to this block. */ return ocfs2_validate_meta_ecc(sb, bh->b_data, &dqt->dq_check); |
684ef2783 ocfs2: Add a vali... |
140 |
} |
f64dd44eb ocfs2: Do not map... |
141 142 143 144 145 146 147 148 149 150 151 152 |
int ocfs2_read_quota_phys_block(struct inode *inode, u64 p_block, struct buffer_head **bhp) { int rc; *bhp = NULL; rc = ocfs2_read_blocks(INODE_CACHE(inode), p_block, 1, bhp, 0, ocfs2_validate_quota_block); if (rc) mlog_errno(rc); return rc; } |
9e33d69f5 ocfs2: Implementa... |
153 154 155 156 157 158 159 160 161 162 163 164 165 166 |
/* Read data from global quotafile - avoid pagecache and such because we cannot * afford acquiring the locks... We use quota cluster lock to serialize * operations. Caller is responsible for acquiring it. */ ssize_t ocfs2_quota_read(struct super_block *sb, int type, char *data, size_t len, loff_t off) { struct ocfs2_mem_dqinfo *oinfo = sb_dqinfo(sb, type)->dqi_priv; struct inode *gqinode = oinfo->dqi_gqinode; loff_t i_size = i_size_read(gqinode); int offset = off & (sb->s_blocksize - 1); sector_t blk = off >> sb->s_blocksize_bits; int err = 0; struct buffer_head *bh; size_t toread, tocopy; |
fb8dd8d78 ocfs2: Fix quota ... |
167 |
u64 pblock = 0, pcount = 0; |
9e33d69f5 ocfs2: Implementa... |
168 169 170 171 172 173 174 |
if (off > i_size) return 0; if (off + len > i_size) len = i_size - off; toread = len; while (toread > 0) { |
dad7d975e ocfs2: use min_t ... |
175 |
tocopy = min_t(size_t, (sb->s_blocksize - offset), toread); |
fb8dd8d78 ocfs2: Fix quota ... |
176 177 178 179 180 181 182 183 184 185 186 |
if (!pcount) { err = ocfs2_extent_map_get_blocks(gqinode, blk, &pblock, &pcount, NULL); if (err) { mlog_errno(err); return err; } } else { pcount--; pblock++; } |
85eb8b73d ocfs2: Fix ocfs2_... |
187 |
bh = NULL; |
fb8dd8d78 ocfs2: Fix quota ... |
188 |
err = ocfs2_read_quota_phys_block(gqinode, pblock, &bh); |
85eb8b73d ocfs2: Fix ocfs2_... |
189 |
if (err) { |
9e33d69f5 ocfs2: Implementa... |
190 191 192 193 194 195 196 197 198 199 200 201 202 203 204 205 206 207 208 209 210 211 212 |
mlog_errno(err); return err; } memcpy(data, bh->b_data + offset, tocopy); brelse(bh); offset = 0; toread -= tocopy; data += tocopy; blk++; } return len; } /* Write to quotafile (we know the transaction is already started and has * enough credits) */ ssize_t ocfs2_quota_write(struct super_block *sb, int type, const char *data, size_t len, loff_t off) { struct mem_dqinfo *info = sb_dqinfo(sb, type); struct ocfs2_mem_dqinfo *oinfo = info->dqi_priv; struct inode *gqinode = oinfo->dqi_gqinode; int offset = off & (sb->s_blocksize - 1); sector_t blk = off >> sb->s_blocksize_bits; |
af09e51b6 ocfs2: Fix oops w... |
213 |
int err = 0, new = 0, ja_type; |
85eb8b73d ocfs2: Fix ocfs2_... |
214 |
struct buffer_head *bh = NULL; |
9e33d69f5 ocfs2: Implementa... |
215 |
handle_t *handle = journal_current_handle(); |
fb8dd8d78 ocfs2: Fix quota ... |
216 |
u64 pblock, pcount; |
9e33d69f5 ocfs2: Implementa... |
217 218 219 220 221 222 223 224 225 226 227 228 |
if (!handle) { mlog(ML_ERROR, "Quota write (off=%llu, len=%llu) cancelled " "because transaction was not started. ", (unsigned long long)off, (unsigned long long)len); return -EIO; } if (len > sb->s_blocksize - OCFS2_QBLK_RESERVED_SPACE - offset) { WARN_ON(1); len = sb->s_blocksize - OCFS2_QBLK_RESERVED_SPACE - offset; } |
9e33d69f5 ocfs2: Implementa... |
229 |
if (gqinode->i_size < off + len) { |
b57ac2c43 ocfs2: Make globa... |
230 231 |
loff_t rounded_end = ocfs2_align_bytes_to_blocks(sb, off + len); |
fb8dd8d78 ocfs2: Fix quota ... |
232 |
/* Space is already allocated in ocfs2_acquire_dquot() */ |
9e33d69f5 ocfs2: Implementa... |
233 234 |
err = ocfs2_simple_size_update(gqinode, oinfo->dqi_gqi_bh, |
b57ac2c43 ocfs2: Make globa... |
235 |
rounded_end); |
9e33d69f5 ocfs2: Implementa... |
236 237 238 239 |
if (err < 0) goto out; new = 1; } |
fb8dd8d78 ocfs2: Fix quota ... |
240 241 242 243 244 |
err = ocfs2_extent_map_get_blocks(gqinode, blk, &pblock, &pcount, NULL); if (err) { mlog_errno(err); goto out; } |
9e33d69f5 ocfs2: Implementa... |
245 246 247 |
/* Not rewriting whole block? */ if ((offset || len < sb->s_blocksize - OCFS2_QBLK_RESERVED_SPACE) && !new) { |
fb8dd8d78 ocfs2: Fix quota ... |
248 |
err = ocfs2_read_quota_phys_block(gqinode, pblock, &bh); |
af09e51b6 ocfs2: Fix oops w... |
249 |
ja_type = OCFS2_JOURNAL_ACCESS_WRITE; |
9e33d69f5 ocfs2: Implementa... |
250 |
} else { |
fb8dd8d78 ocfs2: Fix quota ... |
251 252 253 |
bh = sb_getblk(sb, pblock); if (!bh) err = -ENOMEM; |
af09e51b6 ocfs2: Fix oops w... |
254 |
ja_type = OCFS2_JOURNAL_ACCESS_CREATE; |
9e33d69f5 ocfs2: Implementa... |
255 |
} |
af09e51b6 ocfs2: Fix oops w... |
256 257 |
if (err) { mlog_errno(err); |
e9956fae7 ocfs2/quota: Rele... |
258 |
goto out; |
9e33d69f5 ocfs2: Implementa... |
259 260 261 262 263 264 |
} lock_buffer(bh); if (new) memset(bh->b_data, 0, sb->s_blocksize); memcpy(bh->b_data + offset, data, len); flush_dcache_page(bh->b_page); |
af09e51b6 ocfs2: Fix oops w... |
265 |
set_buffer_uptodate(bh); |
9e33d69f5 ocfs2: Implementa... |
266 |
unlock_buffer(bh); |
8cb471e8f ocfs2: Take the i... |
267 |
ocfs2_set_buffer_uptodate(INODE_CACHE(gqinode), bh); |
0cf2f7632 ocfs2: Pass struc... |
268 269 |
err = ocfs2_journal_access_dq(handle, INODE_CACHE(gqinode), bh, ja_type); |
af09e51b6 ocfs2: Fix oops w... |
270 271 272 273 |
if (err < 0) { brelse(bh); goto out; } |
ec20cec7a ocfs2: Make ocfs2... |
274 |
ocfs2_journal_dirty(handle, bh); |
9e33d69f5 ocfs2: Implementa... |
275 |
brelse(bh); |
9e33d69f5 ocfs2: Implementa... |
276 277 |
out: if (err) { |
9e33d69f5 ocfs2: Implementa... |
278 279 280 281 282 |
mlog_errno(err); return err; } gqinode->i_version++; ocfs2_mark_inode_dirty(handle, gqinode, oinfo->dqi_gqi_bh); |
9e33d69f5 ocfs2: Implementa... |
283 284 285 286 287 288 289 290 291 292 293 294 295 296 297 298 299 |
return len; } int ocfs2_lock_global_qf(struct ocfs2_mem_dqinfo *oinfo, int ex) { int status; struct buffer_head *bh = NULL; status = ocfs2_inode_lock(oinfo->dqi_gqinode, &bh, ex); if (status < 0) return status; spin_lock(&dq_data_lock); if (!oinfo->dqi_gqi_count++) oinfo->dqi_gqi_bh = bh; else WARN_ON(bh != oinfo->dqi_gqi_bh); spin_unlock(&dq_data_lock); |
fb8dd8d78 ocfs2: Fix quota ... |
300 301 302 303 304 305 |
if (ex) { mutex_lock(&oinfo->dqi_gqinode->i_mutex); down_write(&OCFS2_I(oinfo->dqi_gqinode)->ip_alloc_sem); } else { down_read(&OCFS2_I(oinfo->dqi_gqinode)->ip_alloc_sem); } |
9e33d69f5 ocfs2: Implementa... |
306 307 308 309 310 |
return 0; } void ocfs2_unlock_global_qf(struct ocfs2_mem_dqinfo *oinfo, int ex) { |
fb8dd8d78 ocfs2: Fix quota ... |
311 312 313 314 315 316 |
if (ex) { up_write(&OCFS2_I(oinfo->dqi_gqinode)->ip_alloc_sem); mutex_unlock(&oinfo->dqi_gqinode->i_mutex); } else { up_read(&OCFS2_I(oinfo->dqi_gqinode)->ip_alloc_sem); } |
9e33d69f5 ocfs2: Implementa... |
317 318 319 320 321 322 323 324 325 326 327 328 329 330 331 332 333 |
ocfs2_inode_unlock(oinfo->dqi_gqinode, ex); brelse(oinfo->dqi_gqi_bh); spin_lock(&dq_data_lock); if (!--oinfo->dqi_gqi_count) oinfo->dqi_gqi_bh = NULL; spin_unlock(&dq_data_lock); } /* Read information header from global quota file */ int ocfs2_global_read_info(struct super_block *sb, int type) { struct inode *gqinode = NULL; unsigned int ino[MAXQUOTAS] = { USER_QUOTA_SYSTEM_INODE, GROUP_QUOTA_SYSTEM_INODE }; struct ocfs2_global_disk_dqinfo dinfo; struct mem_dqinfo *info = sb_dqinfo(sb, type); struct ocfs2_mem_dqinfo *oinfo = info->dqi_priv; |
ae4f6ef13 ocfs2: Avoid unne... |
334 |
u64 pcount; |
9e33d69f5 ocfs2: Implementa... |
335 |
int status; |
9e33d69f5 ocfs2: Implementa... |
336 337 338 339 340 341 342 343 344 345 346 347 348 349 350 351 352 353 354 355 356 357 358 |
/* Read global header */ gqinode = ocfs2_get_system_file_inode(OCFS2_SB(sb), ino[type], OCFS2_INVALID_SLOT); if (!gqinode) { mlog(ML_ERROR, "failed to get global quota inode (type=%d) ", type); status = -EINVAL; goto out_err; } oinfo->dqi_gi.dqi_sb = sb; oinfo->dqi_gi.dqi_type = type; ocfs2_qinfo_lock_res_init(&oinfo->dqi_gqlock, oinfo); oinfo->dqi_gi.dqi_entry_size = sizeof(struct ocfs2_global_disk_dqblk); oinfo->dqi_gi.dqi_ops = &ocfs2_global_ops; oinfo->dqi_gqi_bh = NULL; oinfo->dqi_gqi_count = 0; oinfo->dqi_gqinode = gqinode; status = ocfs2_lock_global_qf(oinfo, 0); if (status < 0) { mlog_errno(status); goto out_err; } |
ae4f6ef13 ocfs2: Avoid unne... |
359 360 361 362 363 364 365 366 367 |
status = ocfs2_extent_map_get_blocks(gqinode, 0, &oinfo->dqi_giblk, &pcount, NULL); if (status < 0) goto out_unlock; status = ocfs2_qinfo_lock(oinfo, 0); if (status < 0) goto out_unlock; |
9e33d69f5 ocfs2: Implementa... |
368 369 370 |
status = sb->s_op->quota_read(sb, type, (char *)&dinfo, sizeof(struct ocfs2_global_disk_dqinfo), OCFS2_GLOBAL_INFO_OFF); |
ae4f6ef13 ocfs2: Avoid unne... |
371 |
ocfs2_qinfo_unlock(oinfo, 0); |
9e33d69f5 ocfs2: Implementa... |
372 373 374 375 376 377 378 379 380 381 382 383 384 385 386 387 388 389 390 391 |
ocfs2_unlock_global_qf(oinfo, 0); if (status != sizeof(struct ocfs2_global_disk_dqinfo)) { mlog(ML_ERROR, "Cannot read global quota info (%d). ", status); if (status >= 0) status = -EIO; mlog_errno(status); goto out_err; } info->dqi_bgrace = le32_to_cpu(dinfo.dqi_bgrace); info->dqi_igrace = le32_to_cpu(dinfo.dqi_igrace); oinfo->dqi_syncms = le32_to_cpu(dinfo.dqi_syncms); oinfo->dqi_gi.dqi_blocks = le32_to_cpu(dinfo.dqi_blocks); oinfo->dqi_gi.dqi_free_blk = le32_to_cpu(dinfo.dqi_free_blk); oinfo->dqi_gi.dqi_free_entry = le32_to_cpu(dinfo.dqi_free_entry); oinfo->dqi_gi.dqi_blocksize_bits = sb->s_blocksize_bits; oinfo->dqi_gi.dqi_usable_bs = sb->s_blocksize - OCFS2_QBLK_RESERVED_SPACE; oinfo->dqi_gi.dqi_qtree_depth = qtree_depth(&oinfo->dqi_gi); |
171bf93ce ocfs2: Periodic q... |
392 |
INIT_DELAYED_WORK(&oinfo->dqi_sync_work, qsync_work_fn); |
316873c95 ocfs2: use system... |
393 394 |
schedule_delayed_work(&oinfo->dqi_sync_work, msecs_to_jiffies(oinfo->dqi_syncms)); |
171bf93ce ocfs2: Periodic q... |
395 |
|
9e33d69f5 ocfs2: Implementa... |
396 |
out_err: |
c1e8d35ef ocfs2: Remove EXI... |
397 398 |
if (status) mlog_errno(status); |
9e33d69f5 ocfs2: Implementa... |
399 |
return status; |
ae4f6ef13 ocfs2: Avoid unne... |
400 401 402 403 |
out_unlock: ocfs2_unlock_global_qf(oinfo, 0); mlog_errno(status); goto out_err; |
9e33d69f5 ocfs2: Implementa... |
404 405 406 407 408 409 410 411 412 413 414 415 416 417 418 419 420 421 422 423 424 425 426 427 428 429 430 431 432 433 434 435 436 437 438 439 440 441 442 443 444 445 446 447 448 |
} /* Write information to global quota file. Expects exlusive lock on quota * file inode and quota info */ static int __ocfs2_global_write_info(struct super_block *sb, int type) { struct mem_dqinfo *info = sb_dqinfo(sb, type); struct ocfs2_mem_dqinfo *oinfo = info->dqi_priv; struct ocfs2_global_disk_dqinfo dinfo; ssize_t size; spin_lock(&dq_data_lock); info->dqi_flags &= ~DQF_INFO_DIRTY; dinfo.dqi_bgrace = cpu_to_le32(info->dqi_bgrace); dinfo.dqi_igrace = cpu_to_le32(info->dqi_igrace); spin_unlock(&dq_data_lock); dinfo.dqi_syncms = cpu_to_le32(oinfo->dqi_syncms); dinfo.dqi_blocks = cpu_to_le32(oinfo->dqi_gi.dqi_blocks); dinfo.dqi_free_blk = cpu_to_le32(oinfo->dqi_gi.dqi_free_blk); dinfo.dqi_free_entry = cpu_to_le32(oinfo->dqi_gi.dqi_free_entry); size = sb->s_op->quota_write(sb, type, (char *)&dinfo, sizeof(struct ocfs2_global_disk_dqinfo), OCFS2_GLOBAL_INFO_OFF); if (size != sizeof(struct ocfs2_global_disk_dqinfo)) { mlog(ML_ERROR, "Cannot write global quota info structure "); if (size >= 0) size = -EIO; return size; } return 0; } int ocfs2_global_write_info(struct super_block *sb, int type) { int err; struct ocfs2_mem_dqinfo *info = sb_dqinfo(sb, type)->dqi_priv; err = ocfs2_qinfo_lock(info, 1); if (err < 0) return err; err = __ocfs2_global_write_info(sb, type); ocfs2_qinfo_unlock(info, 1); return err; } |
b409d7a0a ocfs2: Fix possib... |
449 450 451 452 453 454 455 456 457 458 459 460 461 |
static int ocfs2_global_qinit_alloc(struct super_block *sb, int type) { struct ocfs2_mem_dqinfo *oinfo = sb_dqinfo(sb, type)->dqi_priv; /* * We may need to allocate tree blocks and a leaf block but not the * root block */ return oinfo->dqi_gi.dqi_qtree_depth; } static int ocfs2_calc_global_qinit_credits(struct super_block *sb, int type) { |
832d09cf1 ocfs2: Fix estima... |
462 463 |
/* We modify all the allocated blocks, tree root, info block and * the inode */ |
b409d7a0a ocfs2: Fix possib... |
464 |
return (ocfs2_global_qinit_alloc(sb, type) + 2) * |
832d09cf1 ocfs2: Fix estima... |
465 |
OCFS2_QUOTA_BLOCK_UPDATE_CREDITS + 1; |
b409d7a0a ocfs2: Fix possib... |
466 |
} |
9e33d69f5 ocfs2: Implementa... |
467 468 469 470 471 472 473 474 475 476 477 478 479 480 481 482 483 484 485 486 487 488 489 490 491 492 493 494 495 496 497 498 499 500 501 502 503 |
/* Sync local information about quota modifications with global quota file. * Caller must have started the transaction and obtained exclusive lock for * global quota file inode */ int __ocfs2_sync_dquot(struct dquot *dquot, int freeing) { int err, err2; struct super_block *sb = dquot->dq_sb; int type = dquot->dq_type; struct ocfs2_mem_dqinfo *info = sb_dqinfo(sb, type)->dqi_priv; struct ocfs2_global_disk_dqblk dqblk; s64 spacechange, inodechange; time_t olditime, oldbtime; err = sb->s_op->quota_read(sb, type, (char *)&dqblk, sizeof(struct ocfs2_global_disk_dqblk), dquot->dq_off); if (err != sizeof(struct ocfs2_global_disk_dqblk)) { if (err >= 0) { mlog(ML_ERROR, "Short read from global quota file " "(%u read) ", err); err = -EIO; } goto out; } /* Update space and inode usage. Get also other information from * global quota file so that we don't overwrite any changes there. * We are */ spin_lock(&dq_data_lock); spacechange = dquot->dq_dqb.dqb_curspace - OCFS2_DQUOT(dquot)->dq_origspace; inodechange = dquot->dq_dqb.dqb_curinodes - OCFS2_DQUOT(dquot)->dq_originodes; olditime = dquot->dq_dqb.dqb_itime; oldbtime = dquot->dq_dqb.dqb_btime; ocfs2_global_disk2memdqb(dquot, &dqblk); |
1db986a83 ocfs2: Remove mas... |
504 505 506 507 |
trace_ocfs2_sync_dquot(dquot->dq_id, dquot->dq_dqb.dqb_curspace, (long long)spacechange, dquot->dq_dqb.dqb_curinodes, (long long)inodechange); |
9e33d69f5 ocfs2: Implementa... |
508 509 510 511 512 513 514 515 516 517 518 519 520 521 522 523 524 525 526 527 528 529 530 531 532 533 534 535 536 537 538 539 540 541 542 543 544 545 546 547 548 549 550 551 552 553 |
if (!test_bit(DQ_LASTSET_B + QIF_SPACE_B, &dquot->dq_flags)) dquot->dq_dqb.dqb_curspace += spacechange; if (!test_bit(DQ_LASTSET_B + QIF_INODES_B, &dquot->dq_flags)) dquot->dq_dqb.dqb_curinodes += inodechange; /* Set properly space grace time... */ if (dquot->dq_dqb.dqb_bsoftlimit && dquot->dq_dqb.dqb_curspace > dquot->dq_dqb.dqb_bsoftlimit) { if (!test_bit(DQ_LASTSET_B + QIF_BTIME_B, &dquot->dq_flags) && oldbtime > 0) { if (dquot->dq_dqb.dqb_btime > 0) dquot->dq_dqb.dqb_btime = min(dquot->dq_dqb.dqb_btime, oldbtime); else dquot->dq_dqb.dqb_btime = oldbtime; } } else { dquot->dq_dqb.dqb_btime = 0; clear_bit(DQ_BLKS_B, &dquot->dq_flags); } /* Set properly inode grace time... */ if (dquot->dq_dqb.dqb_isoftlimit && dquot->dq_dqb.dqb_curinodes > dquot->dq_dqb.dqb_isoftlimit) { if (!test_bit(DQ_LASTSET_B + QIF_ITIME_B, &dquot->dq_flags) && olditime > 0) { if (dquot->dq_dqb.dqb_itime > 0) dquot->dq_dqb.dqb_itime = min(dquot->dq_dqb.dqb_itime, olditime); else dquot->dq_dqb.dqb_itime = olditime; } } else { dquot->dq_dqb.dqb_itime = 0; clear_bit(DQ_INODES_B, &dquot->dq_flags); } /* All information is properly updated, clear the flags */ __clear_bit(DQ_LASTSET_B + QIF_SPACE_B, &dquot->dq_flags); __clear_bit(DQ_LASTSET_B + QIF_INODES_B, &dquot->dq_flags); __clear_bit(DQ_LASTSET_B + QIF_BLIMITS_B, &dquot->dq_flags); __clear_bit(DQ_LASTSET_B + QIF_ILIMITS_B, &dquot->dq_flags); __clear_bit(DQ_LASTSET_B + QIF_BTIME_B, &dquot->dq_flags); __clear_bit(DQ_LASTSET_B + QIF_ITIME_B, &dquot->dq_flags); OCFS2_DQUOT(dquot)->dq_origspace = dquot->dq_dqb.dqb_curspace; OCFS2_DQUOT(dquot)->dq_originodes = dquot->dq_dqb.dqb_curinodes; spin_unlock(&dq_data_lock); err = ocfs2_qinfo_lock(info, freeing); if (err < 0) { |
25985edce Fix common misspe... |
554 |
mlog(ML_ERROR, "Failed to lock quota info, losing quota write" |
9e33d69f5 ocfs2: Implementa... |
555 556 557 558 559 560 561 562 563 564 565 566 567 568 569 570 571 572 573 574 575 576 577 578 579 580 581 |
" (type=%d, id=%u) ", dquot->dq_type, (unsigned)dquot->dq_id); goto out; } if (freeing) OCFS2_DQUOT(dquot)->dq_use_count--; err = qtree_write_dquot(&info->dqi_gi, dquot); if (err < 0) goto out_qlock; if (freeing && !OCFS2_DQUOT(dquot)->dq_use_count) { err = qtree_release_dquot(&info->dqi_gi, dquot); if (info_dirty(sb_dqinfo(sb, type))) { err2 = __ocfs2_global_write_info(sb, type); if (!err) err = err2; } } out_qlock: ocfs2_qinfo_unlock(info, freeing); out: if (err < 0) mlog_errno(err); return err; } /* |
171bf93ce ocfs2: Periodic q... |
582 583 584 585 586 587 588 589 590 |
* Functions for periodic syncing of dquots with global file */ static int ocfs2_sync_dquot_helper(struct dquot *dquot, unsigned long type) { handle_t *handle; struct super_block *sb = dquot->dq_sb; struct ocfs2_mem_dqinfo *oinfo = sb_dqinfo(sb, type)->dqi_priv; struct ocfs2_super *osb = OCFS2_SB(sb); int status = 0; |
1db986a83 ocfs2: Remove mas... |
591 592 |
trace_ocfs2_sync_dquot_helper(dquot->dq_id, dquot->dq_type, type, sb->s_id); |
171bf93ce ocfs2: Periodic q... |
593 594 595 596 597 598 599 600 601 602 603 604 605 606 |
if (type != dquot->dq_type) goto out; status = ocfs2_lock_global_qf(oinfo, 1); if (status < 0) goto out; handle = ocfs2_start_trans(osb, OCFS2_QSYNC_CREDITS); if (IS_ERR(handle)) { status = PTR_ERR(handle); mlog_errno(status); goto out_ilock; } mutex_lock(&sb_dqopt(sb)->dqio_mutex); status = ocfs2_sync_dquot(dquot); |
171bf93ce ocfs2: Periodic q... |
607 608 609 |
if (status < 0) mlog_errno(status); /* We have to write local structure as well... */ |
741e12893 ocfs2: Fix NULL p... |
610 |
status = ocfs2_local_write_dquot(dquot); |
171bf93ce ocfs2: Periodic q... |
611 612 |
if (status < 0) mlog_errno(status); |
741e12893 ocfs2: Fix NULL p... |
613 |
mutex_unlock(&sb_dqopt(sb)->dqio_mutex); |
171bf93ce ocfs2: Periodic q... |
614 615 616 617 |
ocfs2_commit_trans(osb, handle); out_ilock: ocfs2_unlock_global_qf(oinfo, 1); out: |
171bf93ce ocfs2: Periodic q... |
618 619 620 621 622 623 624 625 626 627 628 |
return status; } static void qsync_work_fn(struct work_struct *work) { struct ocfs2_mem_dqinfo *oinfo = container_of(work, struct ocfs2_mem_dqinfo, dqi_sync_work.work); struct super_block *sb = oinfo->dqi_gqinode->i_sb; dquot_scan_active(sb, ocfs2_sync_dquot_helper, oinfo->dqi_type); |
316873c95 ocfs2: use system... |
629 630 |
schedule_delayed_work(&oinfo->dqi_sync_work, msecs_to_jiffies(oinfo->dqi_syncms)); |
171bf93ce ocfs2: Periodic q... |
631 632 633 |
} /* |
9e33d69f5 ocfs2: Implementa... |
634 635 636 637 638 639 640 641 |
* Wrappers for generic quota functions */ static int ocfs2_write_dquot(struct dquot *dquot) { handle_t *handle; struct ocfs2_super *osb = OCFS2_SB(dquot->dq_sb); int status = 0; |
1db986a83 ocfs2: Remove mas... |
642 |
trace_ocfs2_write_dquot(dquot->dq_id, dquot->dq_type); |
9e33d69f5 ocfs2: Implementa... |
643 644 645 646 647 648 649 |
handle = ocfs2_start_trans(osb, OCFS2_QWRITE_CREDITS); if (IS_ERR(handle)) { status = PTR_ERR(handle); mlog_errno(status); goto out; } |
741e12893 ocfs2: Fix NULL p... |
650 651 652 |
mutex_lock(&sb_dqopt(dquot->dq_sb)->dqio_mutex); status = ocfs2_local_write_dquot(dquot); mutex_unlock(&sb_dqopt(dquot->dq_sb)->dqio_mutex); |
9e33d69f5 ocfs2: Implementa... |
653 654 |
ocfs2_commit_trans(osb, handle); out: |
9e33d69f5 ocfs2: Implementa... |
655 656 |
return status; } |
b409d7a0a ocfs2: Fix possib... |
657 |
static int ocfs2_calc_qdel_credits(struct super_block *sb, int type) |
9e33d69f5 ocfs2: Implementa... |
658 |
{ |
b409d7a0a ocfs2: Fix possib... |
659 |
struct ocfs2_mem_dqinfo *oinfo = sb_dqinfo(sb, type)->dqi_priv; |
0584974a7 ocfs2: Define cre... |
660 661 662 663 664 |
/* * We modify tree, leaf block, global info, local chunk header, * global and local inode; OCFS2_QINFO_WRITE_CREDITS already * accounts for inode update */ |
b409d7a0a ocfs2: Fix possib... |
665 666 |
return (oinfo->dqi_gi.dqi_qtree_depth + 2) * OCFS2_QUOTA_BLOCK_UPDATE_CREDITS + |
0584974a7 ocfs2: Define cre... |
667 |
OCFS2_QINFO_WRITE_CREDITS + |
0584974a7 ocfs2: Define cre... |
668 |
OCFS2_INODE_UPDATE_CREDITS; |
9e33d69f5 ocfs2: Implementa... |
669 670 671 672 673 674 675 676 677 |
} static int ocfs2_release_dquot(struct dquot *dquot) { handle_t *handle; struct ocfs2_mem_dqinfo *oinfo = sb_dqinfo(dquot->dq_sb, dquot->dq_type)->dqi_priv; struct ocfs2_super *osb = OCFS2_SB(dquot->dq_sb); int status = 0; |
1db986a83 ocfs2: Remove mas... |
678 |
trace_ocfs2_release_dquot(dquot->dq_id, dquot->dq_type); |
9e33d69f5 ocfs2: Implementa... |
679 |
|
fb8dd8d78 ocfs2: Fix quota ... |
680 681 682 683 |
mutex_lock(&dquot->dq_lock); /* Check whether we are not racing with some other dqget() */ if (atomic_read(&dquot->dq_count) > 1) goto out; |
9e33d69f5 ocfs2: Implementa... |
684 685 686 687 688 689 690 691 692 693 |
status = ocfs2_lock_global_qf(oinfo, 1); if (status < 0) goto out; handle = ocfs2_start_trans(osb, ocfs2_calc_qdel_credits(dquot->dq_sb, dquot->dq_type)); if (IS_ERR(handle)) { status = PTR_ERR(handle); mlog_errno(status); goto out_ilock; } |
fb8dd8d78 ocfs2: Fix quota ... |
694 695 696 697 698 699 700 701 702 703 704 705 706 707 708 |
status = ocfs2_global_release_dquot(dquot); if (status < 0) { mlog_errno(status); goto out_trans; } status = ocfs2_local_release_dquot(handle, dquot); /* * If we fail here, we cannot do much as global structure is * already released. So just complain... */ if (status < 0) mlog_errno(status); clear_bit(DQ_ACTIVE_B, &dquot->dq_flags); out_trans: |
9e33d69f5 ocfs2: Implementa... |
709 710 711 712 |
ocfs2_commit_trans(osb, handle); out_ilock: ocfs2_unlock_global_qf(oinfo, 1); out: |
fb8dd8d78 ocfs2: Fix quota ... |
713 |
mutex_unlock(&dquot->dq_lock); |
c1e8d35ef ocfs2: Remove EXI... |
714 715 |
if (status) mlog_errno(status); |
9e33d69f5 ocfs2: Implementa... |
716 717 |
return status; } |
fb8dd8d78 ocfs2: Fix quota ... |
718 719 720 721 722 |
/* * Read global dquot structure from disk or create it if it does * not exist. Also update use count of the global structure and * create structure in node-local quota file. */ |
9e33d69f5 ocfs2: Implementa... |
723 724 |
static int ocfs2_acquire_dquot(struct dquot *dquot) { |
fb8dd8d78 ocfs2: Fix quota ... |
725 726 727 728 729 730 731 732 733 |
int status = 0, err; int ex = 0; struct super_block *sb = dquot->dq_sb; struct ocfs2_super *osb = OCFS2_SB(sb); int type = dquot->dq_type; struct ocfs2_mem_dqinfo *info = sb_dqinfo(sb, type)->dqi_priv; struct inode *gqinode = info->dqi_gqinode; int need_alloc = ocfs2_global_qinit_alloc(sb, type); handle_t *handle; |
9e33d69f5 ocfs2: Implementa... |
734 |
|
1db986a83 ocfs2: Remove mas... |
735 |
trace_ocfs2_acquire_dquot(dquot->dq_id, type); |
fb8dd8d78 ocfs2: Fix quota ... |
736 737 738 739 740 741 |
mutex_lock(&dquot->dq_lock); /* * We need an exclusive lock, because we're going to update use count * and instantiate possibly new dquot structure */ status = ocfs2_lock_global_qf(info, 1); |
9e33d69f5 ocfs2: Implementa... |
742 743 |
if (status < 0) goto out; |
fb8dd8d78 ocfs2: Fix quota ... |
744 745 746 747 748 749 750 751 752 753 754 755 756 757 758 759 760 761 762 763 764 |
if (!test_bit(DQ_READ_B, &dquot->dq_flags)) { status = ocfs2_qinfo_lock(info, 0); if (status < 0) goto out_dq; status = qtree_read_dquot(&info->dqi_gi, dquot); ocfs2_qinfo_unlock(info, 0); if (status < 0) goto out_dq; } set_bit(DQ_READ_B, &dquot->dq_flags); OCFS2_DQUOT(dquot)->dq_use_count++; OCFS2_DQUOT(dquot)->dq_origspace = dquot->dq_dqb.dqb_curspace; OCFS2_DQUOT(dquot)->dq_originodes = dquot->dq_dqb.dqb_curinodes; if (!dquot->dq_off) { /* No real quota entry? */ ex = 1; /* * Add blocks to quota file before we start a transaction since * locking allocators ranks above a transaction start */ WARN_ON(journal_current_handle()); |
5693486ba ocfs2: Zero the t... |
765 |
status = ocfs2_extend_no_holes(gqinode, NULL, |
fb8dd8d78 ocfs2: Fix quota ... |
766 767 768 769 770 771 772 773 774 775 776 777 778 779 780 781 782 783 784 785 786 787 788 789 790 791 792 793 794 795 796 797 798 |
gqinode->i_size + (need_alloc << sb->s_blocksize_bits), gqinode->i_size); if (status < 0) goto out_dq; } handle = ocfs2_start_trans(osb, ocfs2_calc_global_qinit_credits(sb, type)); if (IS_ERR(handle)) { status = PTR_ERR(handle); goto out_dq; } status = ocfs2_qinfo_lock(info, ex); if (status < 0) goto out_trans; status = qtree_write_dquot(&info->dqi_gi, dquot); if (ex && info_dirty(sb_dqinfo(sb, type))) { err = __ocfs2_global_write_info(sb, type); if (!status) status = err; } ocfs2_qinfo_unlock(info, ex); out_trans: ocfs2_commit_trans(osb, handle); out_dq: ocfs2_unlock_global_qf(info, 1); if (status < 0) goto out; status = ocfs2_create_local_dquot(dquot); if (status < 0) goto out; set_bit(DQ_ACTIVE_B, &dquot->dq_flags); |
9e33d69f5 ocfs2: Implementa... |
799 |
out: |
fb8dd8d78 ocfs2: Fix quota ... |
800 |
mutex_unlock(&dquot->dq_lock); |
c1e8d35ef ocfs2: Remove EXI... |
801 802 |
if (status) mlog_errno(status); |
9e33d69f5 ocfs2: Implementa... |
803 804 805 806 807 808 809 810 811 812 813 814 815 816 817 818 819 820 |
return status; } static int ocfs2_mark_dquot_dirty(struct dquot *dquot) { unsigned long mask = (1 << (DQ_LASTSET_B + QIF_ILIMITS_B)) | (1 << (DQ_LASTSET_B + QIF_BLIMITS_B)) | (1 << (DQ_LASTSET_B + QIF_INODES_B)) | (1 << (DQ_LASTSET_B + QIF_SPACE_B)) | (1 << (DQ_LASTSET_B + QIF_BTIME_B)) | (1 << (DQ_LASTSET_B + QIF_ITIME_B)); int sync = 0; int status; struct super_block *sb = dquot->dq_sb; int type = dquot->dq_type; struct ocfs2_mem_dqinfo *oinfo = sb_dqinfo(sb, type)->dqi_priv; handle_t *handle; struct ocfs2_super *osb = OCFS2_SB(sb); |
1db986a83 ocfs2: Remove mas... |
821 |
trace_ocfs2_mark_dquot_dirty(dquot->dq_id, type); |
9e33d69f5 ocfs2: Implementa... |
822 823 824 825 826 827 828 |
/* In case user set some limits, sync dquot immediately to global * quota file so that information propagates quicker */ spin_lock(&dq_data_lock); if (dquot->dq_flags & mask) sync = 1; spin_unlock(&dq_data_lock); |
f8afead71 ocfs2: Fix possib... |
829 830 831 |
/* This is a slight hack but we can't afford getting global quota * lock if we already have a transaction started. */ if (!sync || journal_current_handle()) { |
9e33d69f5 ocfs2: Implementa... |
832 833 834 835 836 837 838 839 840 841 842 843 |
status = ocfs2_write_dquot(dquot); goto out; } status = ocfs2_lock_global_qf(oinfo, 1); if (status < 0) goto out; handle = ocfs2_start_trans(osb, OCFS2_QSYNC_CREDITS); if (IS_ERR(handle)) { status = PTR_ERR(handle); mlog_errno(status); goto out_ilock; } |
fb8dd8d78 ocfs2: Fix quota ... |
844 |
mutex_lock(&sb_dqopt(sb)->dqio_mutex); |
9e33d69f5 ocfs2: Implementa... |
845 846 847 |
status = ocfs2_sync_dquot(dquot); if (status < 0) { mlog_errno(status); |
741e12893 ocfs2: Fix NULL p... |
848 |
goto out_dlock; |
9e33d69f5 ocfs2: Implementa... |
849 850 |
} /* Now write updated local dquot structure */ |
741e12893 ocfs2: Fix NULL p... |
851 852 853 |
status = ocfs2_local_write_dquot(dquot); out_dlock: mutex_unlock(&sb_dqopt(sb)->dqio_mutex); |
9e33d69f5 ocfs2: Implementa... |
854 855 856 857 |
ocfs2_commit_trans(osb, handle); out_ilock: ocfs2_unlock_global_qf(oinfo, 1); out: |
c1e8d35ef ocfs2: Remove EXI... |
858 859 |
if (status) mlog_errno(status); |
9e33d69f5 ocfs2: Implementa... |
860 861 862 863 864 865 866 867 868 |
return status; } /* This should happen only after set_dqinfo(). */ static int ocfs2_write_info(struct super_block *sb, int type) { handle_t *handle; int status = 0; struct ocfs2_mem_dqinfo *oinfo = sb_dqinfo(sb, type)->dqi_priv; |
9e33d69f5 ocfs2: Implementa... |
869 870 871 872 873 874 875 876 877 878 879 880 881 882 |
status = ocfs2_lock_global_qf(oinfo, 1); if (status < 0) goto out; handle = ocfs2_start_trans(OCFS2_SB(sb), OCFS2_QINFO_WRITE_CREDITS); if (IS_ERR(handle)) { status = PTR_ERR(handle); mlog_errno(status); goto out_ilock; } status = dquot_commit_info(sb, type); ocfs2_commit_trans(OCFS2_SB(sb), handle); out_ilock: ocfs2_unlock_global_qf(oinfo, 1); out: |
c1e8d35ef ocfs2: Remove EXI... |
883 884 |
if (status) mlog_errno(status); |
9e33d69f5 ocfs2: Implementa... |
885 886 |
return status; } |
9e33d69f5 ocfs2: Implementa... |
887 888 889 890 891 892 893 894 895 896 897 898 899 900 |
static struct dquot *ocfs2_alloc_dquot(struct super_block *sb, int type) { struct ocfs2_dquot *dquot = kmem_cache_zalloc(ocfs2_dquot_cachep, GFP_NOFS); if (!dquot) return NULL; return &dquot->dq_dquot; } static void ocfs2_destroy_dquot(struct dquot *dquot) { kmem_cache_free(ocfs2_dquot_cachep, dquot); } |
61e225dc3 const: make struc... |
901 |
const struct dquot_operations ocfs2_quota_operations = { |
741e12893 ocfs2: Fix NULL p... |
902 |
/* We never make dquot dirty so .write_dquot is never called */ |
9e33d69f5 ocfs2: Implementa... |
903 904 905 906 907 908 909 |
.acquire_dquot = ocfs2_acquire_dquot, .release_dquot = ocfs2_release_dquot, .mark_dirty = ocfs2_mark_dquot_dirty, .write_info = ocfs2_write_info, .alloc_dquot = ocfs2_alloc_dquot, .destroy_dquot = ocfs2_destroy_dquot, }; |