]> err.no Git - linux-2.6/blob - fs/gfs2/inode.c
[GFS2] Fixes to scanning of glocks (again)
[linux-2.6] / fs / gfs2 / inode.c
1 /*
2  * Copyright (C) Sistina Software, Inc.  1997-2003 All rights reserved.
3  * Copyright (C) 2004-2006 Red Hat, Inc.  All rights reserved.
4  *
5  * This copyrighted material is made available to anyone wishing to use,
6  * modify, copy, or redistribute it subject to the terms and conditions
7  * of the GNU General Public License v.2.
8  */
9
10 #include <linux/sched.h>
11 #include <linux/slab.h>
12 #include <linux/spinlock.h>
13 #include <linux/completion.h>
14 #include <linux/buffer_head.h>
15 #include <linux/posix_acl.h>
16 #include <linux/sort.h>
17 #include <linux/gfs2_ondisk.h>
18 #include <linux/crc32.h>
19
20 #include "gfs2.h"
21 #include "lm_interface.h"
22 #include "incore.h"
23 #include "acl.h"
24 #include "bmap.h"
25 #include "dir.h"
26 #include "eattr.h"
27 #include "glock.h"
28 #include "glops.h"
29 #include "inode.h"
30 #include "log.h"
31 #include "meta_io.h"
32 #include "ops_address.h"
33 #include "ops_file.h"
34 #include "ops_inode.h"
35 #include "quota.h"
36 #include "rgrp.h"
37 #include "trans.h"
38 #include "util.h"
39
40 /**
41  * inode_attr_in - Copy attributes from the dinode into the VFS inode
42  * @ip: The GFS2 inode (with embedded disk inode data)
43  * @inode:  The Linux VFS inode
44  *
45  */
46
47 static void inode_attr_in(struct gfs2_inode *ip, struct inode *inode)
48 {
49         inode->i_ino = ip->i_num.no_formal_ino;
50
51         switch (ip->i_di.di_mode & S_IFMT) {
52         case S_IFBLK:
53         case S_IFCHR:
54                 inode->i_rdev = MKDEV(ip->i_di.di_major, ip->i_di.di_minor);
55                 break;
56         default:
57                 inode->i_rdev = 0;
58                 break;
59         };
60
61         inode->i_mode = ip->i_di.di_mode;
62         inode->i_nlink = ip->i_di.di_nlink;
63         inode->i_uid = ip->i_di.di_uid;
64         inode->i_gid = ip->i_di.di_gid;
65         i_size_write(inode, ip->i_di.di_size);
66         inode->i_atime.tv_sec = ip->i_di.di_atime;
67         inode->i_mtime.tv_sec = ip->i_di.di_mtime;
68         inode->i_ctime.tv_sec = ip->i_di.di_ctime;
69         inode->i_atime.tv_nsec = 0;
70         inode->i_mtime.tv_nsec = 0;
71         inode->i_ctime.tv_nsec = 0;
72         inode->i_blksize = PAGE_SIZE;
73         inode->i_blocks = ip->i_di.di_blocks <<
74                 (GFS2_SB(inode)->sd_sb.sb_bsize_shift - GFS2_BASIC_BLOCK_SHIFT);
75
76         if (ip->i_di.di_flags & GFS2_DIF_IMMUTABLE)
77                 inode->i_flags |= S_IMMUTABLE;
78         else
79                 inode->i_flags &= ~S_IMMUTABLE;
80
81         if (ip->i_di.di_flags & GFS2_DIF_APPENDONLY)
82                 inode->i_flags |= S_APPEND;
83         else
84                 inode->i_flags &= ~S_APPEND;
85 }
86
87 /**
88  * gfs2_inode_attr_in - Copy attributes from the dinode into the VFS inode
89  * @ip: The GFS2 inode (with embedded disk inode data)
90  *
91  */
92
93 void gfs2_inode_attr_in(struct gfs2_inode *ip)
94 {
95         struct inode *inode = &ip->i_inode;
96         inode_attr_in(ip, inode);
97 }
98
99 /**
100  * gfs2_inode_attr_out - Copy attributes from VFS inode into the dinode
101  * @ip: The GFS2 inode
102  *
103  * Only copy out the attributes that we want the VFS layer
104  * to be able to modify.
105  */
106
107 void gfs2_inode_attr_out(struct gfs2_inode *ip)
108 {
109         struct inode *inode = &ip->i_inode;
110
111         gfs2_assert_withdraw(GFS2_SB(inode),
112                 (ip->i_di.di_mode & S_IFMT) == (inode->i_mode & S_IFMT));
113         ip->i_di.di_mode = inode->i_mode;
114         ip->i_di.di_uid = inode->i_uid;
115         ip->i_di.di_gid = inode->i_gid;
116         ip->i_di.di_atime = inode->i_atime.tv_sec;
117         ip->i_di.di_mtime = inode->i_mtime.tv_sec;
118         ip->i_di.di_ctime = inode->i_ctime.tv_sec;
119 }
120
121 static int iget_test(struct inode *inode, void *opaque)
122 {
123         struct gfs2_inode *ip = GFS2_I(inode);
124         struct gfs2_inum *inum = opaque;
125
126         if (ip && ip->i_num.no_addr == inum->no_addr)
127                 return 1;
128
129         return 0;
130 }
131
132 static int iget_set(struct inode *inode, void *opaque)
133 {
134         struct gfs2_inode *ip = GFS2_I(inode);
135         struct gfs2_inum *inum = opaque;
136
137         ip->i_num = *inum;
138         return 0;
139 }
140
141 struct inode *gfs2_ilookup(struct super_block *sb, struct gfs2_inum *inum)
142 {
143         return ilookup5(sb, (unsigned long)inum->no_formal_ino,
144                         iget_test, inum);
145 }
146
147 static struct inode *gfs2_iget(struct super_block *sb, struct gfs2_inum *inum)
148 {
149         return iget5_locked(sb, (unsigned long)inum->no_formal_ino,
150                      iget_test, iget_set, inum);
151 }
152
153 /**
154  * gfs2_inode_lookup - Lookup an inode
155  * @sb: The super block
156  * @inum: The inode number
157  * @type: The type of the inode
158  *
159  * Returns: A VFS inode, or an error
160  */
161
162 struct inode *gfs2_inode_lookup(struct super_block *sb, struct gfs2_inum *inum, unsigned int type)
163 {
164         struct inode *inode = gfs2_iget(sb, inum);
165         struct gfs2_inode *ip = GFS2_I(inode);
166         struct gfs2_glock *io_gl;
167         int error;
168
169         if (inode->i_state & I_NEW) {
170                 struct gfs2_sbd *sdp = GFS2_SB(inode);
171                 umode_t mode = DT2IF(type);
172                 inode->u.generic_ip = ip;
173                 inode->i_mode = mode;
174
175                 if (S_ISREG(mode)) {
176                         inode->i_op = &gfs2_file_iops;
177                         inode->i_fop = &gfs2_file_fops;
178                         inode->i_mapping->a_ops = &gfs2_file_aops;
179                 } else if (S_ISDIR(mode)) {
180                         inode->i_op = &gfs2_dir_iops;
181                         inode->i_fop = &gfs2_dir_fops;
182                 } else if (S_ISLNK(mode)) {
183                         inode->i_op = &gfs2_symlink_iops;
184                 } else {
185                         inode->i_op = &gfs2_dev_iops;
186                 }
187
188                 error = gfs2_glock_get(sdp, inum->no_addr, &gfs2_inode_glops, CREATE, &ip->i_gl);
189                 if (unlikely(error))
190                         goto fail;
191                 ip->i_gl->gl_object = ip;
192
193                 error = gfs2_glock_get(sdp, inum->no_addr, &gfs2_iopen_glops, CREATE, &io_gl);
194                 if (unlikely(error))
195                         goto fail_put;
196
197                 ip->i_vn = ip->i_gl->gl_vn - 1;
198                 error = gfs2_glock_nq_init(io_gl, LM_ST_SHARED, GL_EXACT, &ip->i_iopen_gh);
199                 if (unlikely(error))
200                         goto fail_iopen;
201
202                 gfs2_glock_put(io_gl);
203                 unlock_new_inode(inode);
204         }
205
206         return inode;
207 fail_iopen:
208         gfs2_glock_put(io_gl);
209 fail_put:
210         ip->i_gl->gl_object = NULL;
211         gfs2_glock_put(ip->i_gl);
212 fail:
213         iput(inode);
214         return ERR_PTR(error);
215 }
216
217 /**
218  * gfs2_inode_refresh - Refresh the incore copy of the dinode
219  * @ip: The GFS2 inode
220  *
221  * Returns: errno
222  */
223
224 int gfs2_inode_refresh(struct gfs2_inode *ip)
225 {
226         struct buffer_head *dibh;
227         int error;
228
229         error = gfs2_meta_inode_buffer(ip, &dibh);
230         if (error)
231                 return error;
232
233         if (gfs2_metatype_check(GFS2_SB(&ip->i_inode), dibh, GFS2_METATYPE_DI)) {
234                 brelse(dibh);
235                 return -EIO;
236         }
237
238         gfs2_dinode_in(&ip->i_di, dibh->b_data);
239
240         brelse(dibh);
241
242         if (ip->i_num.no_addr != ip->i_di.di_num.no_addr) {
243                 if (gfs2_consist_inode(ip))
244                         gfs2_dinode_print(&ip->i_di);
245                 return -EIO;
246         }
247         if (ip->i_num.no_formal_ino != ip->i_di.di_num.no_formal_ino)
248                 return -ESTALE;
249
250         ip->i_vn = ip->i_gl->gl_vn;
251
252         return 0;
253 }
254
255 int gfs2_dinode_dealloc(struct gfs2_inode *ip)
256 {
257         struct gfs2_sbd *sdp = GFS2_SB(&ip->i_inode);
258         struct gfs2_alloc *al;
259         struct gfs2_rgrpd *rgd;
260         int error;
261
262         if (ip->i_di.di_blocks != 1) {
263                 if (gfs2_consist_inode(ip))
264                         gfs2_dinode_print(&ip->i_di);
265                 return -EIO;
266         }
267
268         al = gfs2_alloc_get(ip);
269
270         error = gfs2_quota_hold(ip, NO_QUOTA_CHANGE, NO_QUOTA_CHANGE);
271         if (error)
272                 goto out;
273
274         error = gfs2_rindex_hold(sdp, &al->al_ri_gh);
275         if (error)
276                 goto out_qs;
277
278         rgd = gfs2_blk2rgrpd(sdp, ip->i_num.no_addr);
279         if (!rgd) {
280                 gfs2_consist_inode(ip);
281                 error = -EIO;
282                 goto out_rindex_relse;
283         }
284
285         error = gfs2_glock_nq_init(rgd->rd_gl, LM_ST_EXCLUSIVE, 0,
286                                    &al->al_rgd_gh);
287         if (error)
288                 goto out_rindex_relse;
289
290         error = gfs2_trans_begin(sdp, RES_RG_BIT + 
291                                  RES_STATFS + RES_QUOTA, 1);
292         if (error)
293                 goto out_rg_gunlock;
294
295         gfs2_trans_add_gl(ip->i_gl);
296
297         gfs2_free_di(rgd, ip);
298
299         gfs2_trans_end(sdp);
300         clear_bit(GLF_STICKY, &ip->i_gl->gl_flags);
301
302 out_rg_gunlock:
303         gfs2_glock_dq_uninit(&al->al_rgd_gh);
304 out_rindex_relse:
305         gfs2_glock_dq_uninit(&al->al_ri_gh);
306 out_qs:
307         gfs2_quota_unhold(ip);
308 out:
309         gfs2_alloc_put(ip);
310         return error;
311 }
312
313 /**
314  * gfs2_change_nlink - Change nlink count on inode
315  * @ip: The GFS2 inode
316  * @diff: The change in the nlink count required
317  *
318  * Returns: errno
319  */
320
321 int gfs2_change_nlink(struct gfs2_inode *ip, int diff)
322 {
323         struct gfs2_sbd *sdp = ip->i_inode.i_sb->s_fs_info;
324         struct buffer_head *dibh;
325         uint32_t nlink;
326         int error;
327
328         BUG_ON(ip->i_di.di_nlink != ip->i_inode.i_nlink);
329         nlink = ip->i_di.di_nlink + diff;
330
331         /* If we are reducing the nlink count, but the new value ends up being
332            bigger than the old one, we must have underflowed. */
333         if (diff < 0 && nlink > ip->i_di.di_nlink) {
334                 if (gfs2_consist_inode(ip))
335                         gfs2_dinode_print(&ip->i_di);
336                 return -EIO;
337         }
338
339         error = gfs2_meta_inode_buffer(ip, &dibh);
340         if (error)
341                 return error;
342
343         ip->i_di.di_nlink = nlink;
344         ip->i_di.di_ctime = get_seconds();
345         ip->i_inode.i_nlink = nlink;
346
347         gfs2_trans_add_bh(ip->i_gl, dibh, 1);
348         gfs2_dinode_out(&ip->i_di, dibh->b_data);
349         brelse(dibh);
350         mark_inode_dirty(&ip->i_inode);
351
352         if (ip->i_di.di_nlink == 0) {
353                 struct gfs2_rgrpd *rgd;
354                 struct gfs2_holder ri_gh, rg_gh;
355
356                 error = gfs2_rindex_hold(sdp, &ri_gh);
357                 if (error)
358                         goto out;
359                 error = -EIO;
360                 rgd = gfs2_blk2rgrpd(sdp, ip->i_num.no_addr);
361                 if (!rgd)
362                         goto out_norgrp;
363                 error = gfs2_glock_nq_init(rgd->rd_gl, LM_ST_EXCLUSIVE, 0, &rg_gh);
364                 if (error)
365                         goto out_norgrp;
366
367                 gfs2_unlink_di(&ip->i_inode); /* mark inode unlinked */
368                 gfs2_glock_dq_uninit(&rg_gh);
369 out_norgrp:
370                 gfs2_glock_dq_uninit(&ri_gh);
371         }
372 out:
373         return error;
374 }
375
376 struct inode *gfs2_lookup_simple(struct inode *dip, const char *name)
377 {
378         struct qstr qstr;
379         gfs2_str2qstr(&qstr, name);
380         return gfs2_lookupi(dip, &qstr, 1, NULL);
381 }
382
383
384 /**
385  * gfs2_lookupi - Look up a filename in a directory and return its inode
386  * @d_gh: An initialized holder for the directory glock
387  * @name: The name of the inode to look for
388  * @is_root: If 1, ignore the caller's permissions
389  * @i_gh: An uninitialized holder for the new inode glock
390  *
391  * There will always be a vnode (Linux VFS inode) for the d_gh inode unless
392  * @is_root is true.
393  *
394  * Returns: errno
395  */
396
397 struct inode *gfs2_lookupi(struct inode *dir, const struct qstr *name,
398                            int is_root, struct nameidata *nd)
399                  
400 {
401         struct super_block *sb = dir->i_sb;
402         struct gfs2_inode *dip = GFS2_I(dir);
403         struct gfs2_holder d_gh;
404         struct gfs2_inum inum;
405         unsigned int type;
406         int error = 0;
407         struct inode *inode = NULL;
408
409         if (!name->len || name->len > GFS2_FNAMESIZE)
410                 return ERR_PTR(-ENAMETOOLONG);
411
412         if ((name->len == 1 && memcmp(name->name, ".", 1) == 0) ||
413             (name->len == 2 && memcmp(name->name, "..", 2) == 0 &&
414              dir == sb->s_root->d_inode)) {
415                 igrab(dir);
416                 return dir;
417         }
418
419         error = gfs2_glock_nq_init(dip->i_gl, LM_ST_SHARED, 0, &d_gh);
420         if (error)
421                 return ERR_PTR(error);
422
423         if (!is_root) {
424                 error = permission(dir, MAY_EXEC, NULL);
425                 if (error)
426                         goto out;
427         }
428
429         error = gfs2_dir_search(dir, name, &inum, &type);
430         if (error)
431                 goto out;
432
433         inode = gfs2_inode_lookup(sb, &inum, type);
434
435 out:
436         gfs2_glock_dq_uninit(&d_gh);
437         if (error == -ENOENT)
438                 return NULL;
439         return inode;
440 }
441
442 static int pick_formal_ino_1(struct gfs2_sbd *sdp, uint64_t *formal_ino)
443 {
444         struct gfs2_inode *ip = GFS2_I(sdp->sd_ir_inode);
445         struct buffer_head *bh;
446         struct gfs2_inum_range ir;
447         int error;
448
449         error = gfs2_trans_begin(sdp, RES_DINODE, 0);
450         if (error)
451                 return error;
452         mutex_lock(&sdp->sd_inum_mutex);
453
454         error = gfs2_meta_inode_buffer(ip, &bh);
455         if (error) {
456                 mutex_unlock(&sdp->sd_inum_mutex);
457                 gfs2_trans_end(sdp);
458                 return error;
459         }
460
461         gfs2_inum_range_in(&ir, bh->b_data + sizeof(struct gfs2_dinode));
462
463         if (ir.ir_length) {
464                 *formal_ino = ir.ir_start++;
465                 ir.ir_length--;
466                 gfs2_trans_add_bh(ip->i_gl, bh, 1);
467                 gfs2_inum_range_out(&ir,
468                                     bh->b_data + sizeof(struct gfs2_dinode));
469                 brelse(bh);
470                 mutex_unlock(&sdp->sd_inum_mutex);
471                 gfs2_trans_end(sdp);
472                 return 0;
473         }
474
475         brelse(bh);
476
477         mutex_unlock(&sdp->sd_inum_mutex);
478         gfs2_trans_end(sdp);
479
480         return 1;
481 }
482
483 static int pick_formal_ino_2(struct gfs2_sbd *sdp, uint64_t *formal_ino)
484 {
485         struct gfs2_inode *ip = GFS2_I(sdp->sd_ir_inode);
486         struct gfs2_inode *m_ip = GFS2_I(sdp->sd_inum_inode);
487         struct gfs2_holder gh;
488         struct buffer_head *bh;
489         struct gfs2_inum_range ir;
490         int error;
491
492         error = gfs2_glock_nq_init(m_ip->i_gl, LM_ST_EXCLUSIVE, 0, &gh);
493         if (error)
494                 return error;
495
496         error = gfs2_trans_begin(sdp, 2 * RES_DINODE, 0);
497         if (error)
498                 goto out;
499         mutex_lock(&sdp->sd_inum_mutex);
500
501         error = gfs2_meta_inode_buffer(ip, &bh);
502         if (error)
503                 goto out_end_trans;
504         
505         gfs2_inum_range_in(&ir, bh->b_data + sizeof(struct gfs2_dinode));
506
507         if (!ir.ir_length) {
508                 struct buffer_head *m_bh;
509                 uint64_t x, y;
510
511                 error = gfs2_meta_inode_buffer(m_ip, &m_bh);
512                 if (error)
513                         goto out_brelse;
514
515                 x = *(uint64_t *)(m_bh->b_data + sizeof(struct gfs2_dinode));
516                 x = y = be64_to_cpu(x);
517                 ir.ir_start = x;
518                 ir.ir_length = GFS2_INUM_QUANTUM;
519                 x += GFS2_INUM_QUANTUM;
520                 if (x < y)
521                         gfs2_consist_inode(m_ip);
522                 x = cpu_to_be64(x);
523                 gfs2_trans_add_bh(m_ip->i_gl, m_bh, 1);
524                 *(uint64_t *)(m_bh->b_data + sizeof(struct gfs2_dinode)) = x;
525
526                 brelse(m_bh);
527         }
528
529         *formal_ino = ir.ir_start++;
530         ir.ir_length--;
531
532         gfs2_trans_add_bh(ip->i_gl, bh, 1);
533         gfs2_inum_range_out(&ir, bh->b_data + sizeof(struct gfs2_dinode));
534
535  out_brelse:
536         brelse(bh);
537
538  out_end_trans:
539         mutex_unlock(&sdp->sd_inum_mutex);
540         gfs2_trans_end(sdp);
541
542  out:
543         gfs2_glock_dq_uninit(&gh);
544
545         return error;
546 }
547
548 static int pick_formal_ino(struct gfs2_sbd *sdp, uint64_t *inum)
549 {
550         int error;
551
552         error = pick_formal_ino_1(sdp, inum);
553         if (error <= 0)
554                 return error;
555
556         error = pick_formal_ino_2(sdp, inum);
557
558         return error;
559 }
560
561 /**
562  * create_ok - OK to create a new on-disk inode here?
563  * @dip:  Directory in which dinode is to be created
564  * @name:  Name of new dinode
565  * @mode:
566  *
567  * Returns: errno
568  */
569
570 static int create_ok(struct gfs2_inode *dip, const struct qstr *name,
571                      unsigned int mode)
572 {
573         int error;
574
575         error = permission(&dip->i_inode, MAY_WRITE | MAY_EXEC, NULL);
576         if (error)
577                 return error;
578
579         /*  Don't create entries in an unlinked directory  */
580         if (!dip->i_di.di_nlink)
581                 return -EPERM;
582
583         error = gfs2_dir_search(&dip->i_inode, name, NULL, NULL);
584         switch (error) {
585         case -ENOENT:
586                 error = 0;
587                 break;
588         case 0:
589                 return -EEXIST;
590         default:
591                 return error;
592         }
593
594         if (dip->i_di.di_entries == (uint32_t)-1)
595                 return -EFBIG;
596         if (S_ISDIR(mode) && dip->i_di.di_nlink == (uint32_t)-1)
597                 return -EMLINK;
598
599         return 0;
600 }
601
602 static void munge_mode_uid_gid(struct gfs2_inode *dip, unsigned int *mode,
603                                unsigned int *uid, unsigned int *gid)
604 {
605         if (GFS2_SB(&dip->i_inode)->sd_args.ar_suiddir &&
606             (dip->i_di.di_mode & S_ISUID) &&
607             dip->i_di.di_uid) {
608                 if (S_ISDIR(*mode))
609                         *mode |= S_ISUID;
610                 else if (dip->i_di.di_uid != current->fsuid)
611                         *mode &= ~07111;
612                 *uid = dip->i_di.di_uid;
613         } else
614                 *uid = current->fsuid;
615
616         if (dip->i_di.di_mode & S_ISGID) {
617                 if (S_ISDIR(*mode))
618                         *mode |= S_ISGID;
619                 *gid = dip->i_di.di_gid;
620         } else
621                 *gid = current->fsgid;
622 }
623
624 static int alloc_dinode(struct gfs2_inode *dip, struct gfs2_inum *inum)
625 {
626         struct gfs2_sbd *sdp = GFS2_SB(&dip->i_inode);
627         int error;
628
629         gfs2_alloc_get(dip);
630
631         dip->i_alloc.al_requested = RES_DINODE;
632         error = gfs2_inplace_reserve(dip);
633         if (error)
634                 goto out;
635
636         error = gfs2_trans_begin(sdp, RES_RG_BIT + RES_STATFS, 0);
637         if (error)
638                 goto out_ipreserv;
639
640         inum->no_addr = gfs2_alloc_di(dip);
641
642         gfs2_trans_end(sdp);
643
644  out_ipreserv:
645         gfs2_inplace_release(dip);
646
647  out:
648         gfs2_alloc_put(dip);
649
650         return error;
651 }
652
653 /**
654  * init_dinode - Fill in a new dinode structure
655  * @dip: the directory this inode is being created in
656  * @gl: The glock covering the new inode
657  * @inum: the inode number
658  * @mode: the file permissions
659  * @uid:
660  * @gid:
661  *
662  */
663
664 static void init_dinode(struct gfs2_inode *dip, struct gfs2_glock *gl,
665                         struct gfs2_inum *inum, unsigned int mode,
666                         unsigned int uid, unsigned int gid)
667 {
668         struct gfs2_sbd *sdp = GFS2_SB(&dip->i_inode);
669         struct gfs2_dinode *di;
670         struct buffer_head *dibh;
671
672         dibh = gfs2_meta_new(gl, inum->no_addr);
673         gfs2_trans_add_bh(gl, dibh, 1);
674         gfs2_metatype_set(dibh, GFS2_METATYPE_DI, GFS2_FORMAT_DI);
675         gfs2_buffer_clear_tail(dibh, sizeof(struct gfs2_dinode));
676         di = (struct gfs2_dinode *)dibh->b_data;
677
678         di->di_num.no_formal_ino = cpu_to_be64(inum->no_formal_ino);
679         di->di_num.no_addr = cpu_to_be64(inum->no_addr);
680         di->di_mode = cpu_to_be32(mode);
681         di->di_uid = cpu_to_be32(uid);
682         di->di_gid = cpu_to_be32(gid);
683         di->di_nlink = cpu_to_be32(0);
684         di->di_size = cpu_to_be64(0);
685         di->di_blocks = cpu_to_be64(1);
686         di->di_atime = di->di_mtime = di->di_ctime = cpu_to_be64(get_seconds());
687         di->di_major = di->di_minor = cpu_to_be32(0);
688         di->di_goal_meta = di->di_goal_data = cpu_to_be64(inum->no_addr);
689         di->__pad[0] = di->__pad[1] = 0;
690         di->di_flags = cpu_to_be32(0);
691
692         if (S_ISREG(mode)) {
693                 if ((dip->i_di.di_flags & GFS2_DIF_INHERIT_JDATA) ||
694                     gfs2_tune_get(sdp, gt_new_files_jdata))
695                         di->di_flags |= cpu_to_be32(GFS2_DIF_JDATA);
696                 if ((dip->i_di.di_flags & GFS2_DIF_INHERIT_DIRECTIO) ||
697                     gfs2_tune_get(sdp, gt_new_files_directio))
698                         di->di_flags |= cpu_to_be32(GFS2_DIF_DIRECTIO);
699         } else if (S_ISDIR(mode)) {
700                 di->di_flags |= cpu_to_be32(dip->i_di.di_flags &
701                                             GFS2_DIF_INHERIT_DIRECTIO);
702                 di->di_flags |= cpu_to_be32(dip->i_di.di_flags &
703                                             GFS2_DIF_INHERIT_JDATA);
704         }
705
706         di->__pad1 = 0;
707         di->di_height = cpu_to_be32(0);
708         di->__pad2 = 0;
709         di->__pad3 = 0;
710         di->di_depth = cpu_to_be16(0);
711         di->di_entries = cpu_to_be32(0);
712         memset(&di->__pad4, 0, sizeof(di->__pad4));
713         di->di_eattr = cpu_to_be64(0);
714         memset(&di->di_reserved, 0, sizeof(di->di_reserved));
715
716         brelse(dibh);
717 }
718
719 static int make_dinode(struct gfs2_inode *dip, struct gfs2_glock *gl,
720                        unsigned int mode, struct gfs2_inum *inum)
721 {
722         struct gfs2_sbd *sdp = GFS2_SB(&dip->i_inode);
723         unsigned int uid, gid;
724         int error;
725
726         munge_mode_uid_gid(dip, &mode, &uid, &gid);
727         gfs2_alloc_get(dip);
728
729         error = gfs2_quota_lock(dip, uid, gid);
730         if (error)
731                 goto out;
732
733         error = gfs2_quota_check(dip, uid, gid);
734         if (error)
735                 goto out_quota;
736
737         error = gfs2_trans_begin(sdp, RES_DINODE + RES_QUOTA, 0);
738         if (error)
739                 goto out_quota;
740
741         init_dinode(dip, gl, inum, mode, uid, gid);
742         gfs2_quota_change(dip, +1, uid, gid);
743         gfs2_trans_end(sdp);
744
745 out_quota:
746         gfs2_quota_unlock(dip);
747 out:
748         gfs2_alloc_put(dip);
749         return error;
750 }
751
752 static int link_dinode(struct gfs2_inode *dip, const struct qstr *name,
753                        struct gfs2_inode *ip)
754 {
755         struct gfs2_sbd *sdp = GFS2_SB(&dip->i_inode);
756         struct gfs2_alloc *al;
757         int alloc_required;
758         struct buffer_head *dibh;
759         int error;
760
761         al = gfs2_alloc_get(dip);
762
763         error = gfs2_quota_lock(dip, NO_QUOTA_CHANGE, NO_QUOTA_CHANGE);
764         if (error)
765                 goto fail;
766
767         error = alloc_required = gfs2_diradd_alloc_required(&dip->i_inode, name);
768         if (alloc_required < 0)
769                 goto fail;
770         if (alloc_required) {
771                 error = gfs2_quota_check(dip, dip->i_di.di_uid,
772                                          dip->i_di.di_gid);
773                 if (error)
774                         goto fail_quota_locks;
775
776                 al->al_requested = sdp->sd_max_dirres;
777
778                 error = gfs2_inplace_reserve(dip);
779                 if (error)
780                         goto fail_quota_locks;
781
782                 error = gfs2_trans_begin(sdp, sdp->sd_max_dirres +
783                                          al->al_rgd->rd_ri.ri_length +
784                                          2 * RES_DINODE + 
785                                          RES_STATFS + RES_QUOTA, 0);
786                 if (error)
787                         goto fail_ipreserv;
788         } else {
789                 error = gfs2_trans_begin(sdp, RES_LEAF + 2 * RES_DINODE, 0);
790                 if (error)
791                         goto fail_quota_locks;
792         }
793
794         error = gfs2_dir_add(&dip->i_inode, name, &ip->i_num, IF2DT(ip->i_di.di_mode));
795         if (error)
796                 goto fail_end_trans;
797
798         error = gfs2_meta_inode_buffer(ip, &dibh);
799         if (error)
800                 goto fail_end_trans;
801         ip->i_di.di_nlink = 1;
802         gfs2_trans_add_bh(ip->i_gl, dibh, 1);
803         gfs2_dinode_out(&ip->i_di, dibh->b_data);
804         brelse(dibh);
805         return 0;
806
807 fail_end_trans:
808         gfs2_trans_end(sdp);
809
810 fail_ipreserv:
811         if (dip->i_alloc.al_rgd)
812                 gfs2_inplace_release(dip);
813
814 fail_quota_locks:
815         gfs2_quota_unlock(dip);
816
817 fail:
818         gfs2_alloc_put(dip);
819         return error;
820 }
821
822 /**
823  * gfs2_createi - Create a new inode
824  * @ghs: An array of two holders
825  * @name: The name of the new file
826  * @mode: the permissions on the new inode
827  *
828  * @ghs[0] is an initialized holder for the directory
829  * @ghs[1] is the holder for the inode lock
830  *
831  * If the return value is not NULL, the glocks on both the directory and the new
832  * file are held.  A transaction has been started and an inplace reservation
833  * is held, as well.
834  *
835  * Returns: An inode
836  */
837
838 struct inode *gfs2_createi(struct gfs2_holder *ghs, const struct qstr *name,
839                            unsigned int mode)
840 {
841         struct inode *inode;
842         struct gfs2_inode *dip = ghs->gh_gl->gl_object;
843         struct inode *dir = &dip->i_inode;
844         struct gfs2_sbd *sdp = GFS2_SB(&dip->i_inode);
845         struct gfs2_inum inum;
846         int error;
847
848         if (!name->len || name->len > GFS2_FNAMESIZE)
849                 return ERR_PTR(-ENAMETOOLONG);
850
851         gfs2_holder_reinit(LM_ST_EXCLUSIVE, 0, ghs);
852         error = gfs2_glock_nq(ghs);
853         if (error)
854                 goto fail;
855
856         error = create_ok(dip, name, mode);
857         if (error)
858                 goto fail_gunlock;
859
860         error = pick_formal_ino(sdp, &inum.no_formal_ino);
861         if (error)
862                 goto fail_gunlock;
863
864         error = alloc_dinode(dip, &inum);
865         if (error)
866                 goto fail_gunlock;
867
868         if (inum.no_addr < dip->i_num.no_addr) {
869                 gfs2_glock_dq(ghs);
870
871                 error = gfs2_glock_nq_num(sdp, inum.no_addr,
872                                           &gfs2_inode_glops, LM_ST_EXCLUSIVE,
873                                           GL_SKIP, ghs + 1);
874                 if (error) {
875                         return ERR_PTR(error);
876                 }
877
878                 gfs2_holder_reinit(LM_ST_EXCLUSIVE, 0, ghs);
879                 error = gfs2_glock_nq(ghs);
880                 if (error) {
881                         gfs2_glock_dq_uninit(ghs + 1);
882                         return ERR_PTR(error);
883                 }
884
885                 error = create_ok(dip, name, mode);
886                 if (error)
887                         goto fail_gunlock2;
888         } else {
889                 error = gfs2_glock_nq_num(sdp, inum.no_addr,
890                                           &gfs2_inode_glops, LM_ST_EXCLUSIVE,
891                                           GL_SKIP, ghs + 1);
892                 if (error)
893                         goto fail_gunlock;
894         }
895
896         error = make_dinode(dip, ghs[1].gh_gl, mode, &inum);
897         if (error)
898                 goto fail_gunlock2;
899
900         inode = gfs2_inode_lookup(dir->i_sb, &inum, IF2DT(mode));
901         if (IS_ERR(inode))
902                 goto fail_gunlock2;
903
904         error = gfs2_inode_refresh(GFS2_I(inode));
905         if (error)
906                 goto fail_iput;
907
908         error = gfs2_acl_create(dip, GFS2_I(inode));
909         if (error)
910                 goto fail_iput;
911
912         error = link_dinode(dip, name, GFS2_I(inode));
913         if (error)
914                 goto fail_iput;
915
916         if (!inode)
917                 return ERR_PTR(-ENOMEM);
918         return inode;
919
920 fail_iput:
921         iput(inode);
922 fail_gunlock2:
923         gfs2_glock_dq_uninit(ghs + 1);
924 fail_gunlock:
925         gfs2_glock_dq(ghs);
926 fail:
927         return ERR_PTR(error);
928 }
929
930 /**
931  * gfs2_rmdiri - Remove a directory
932  * @dip: The parent directory of the directory to be removed
933  * @name: The name of the directory to be removed
934  * @ip: The GFS2 inode of the directory to be removed
935  *
936  * Assumes Glocks on dip and ip are held
937  *
938  * Returns: errno
939  */
940
941 int gfs2_rmdiri(struct gfs2_inode *dip, const struct qstr *name,
942                 struct gfs2_inode *ip)
943 {
944         struct qstr dotname;
945         int error;
946
947         if (ip->i_di.di_entries != 2) {
948                 if (gfs2_consist_inode(ip))
949                         gfs2_dinode_print(&ip->i_di);
950                 return -EIO;
951         }
952
953         error = gfs2_dir_del(dip, name);
954         if (error)
955                 return error;
956
957         error = gfs2_change_nlink(dip, -1);
958         if (error)
959                 return error;
960
961         gfs2_str2qstr(&dotname, ".");
962         error = gfs2_dir_del(ip, &dotname);
963         if (error)
964                 return error;
965
966         gfs2_str2qstr(&dotname, "..");
967         error = gfs2_dir_del(ip, &dotname);
968         if (error)
969                 return error;
970
971         error = gfs2_change_nlink(ip, -2);
972         if (error)
973                 return error;
974
975         return error;
976 }
977
978 /*
979  * gfs2_unlink_ok - check to see that a inode is still in a directory
980  * @dip: the directory
981  * @name: the name of the file
982  * @ip: the inode
983  *
984  * Assumes that the lock on (at least) @dip is held.
985  *
986  * Returns: 0 if the parent/child relationship is correct, errno if it isn't
987  */
988
989 int gfs2_unlink_ok(struct gfs2_inode *dip, const struct qstr *name,
990                    struct gfs2_inode *ip)
991 {
992         struct gfs2_inum inum;
993         unsigned int type;
994         int error;
995
996         if (IS_IMMUTABLE(&ip->i_inode) || IS_APPEND(&ip->i_inode))
997                 return -EPERM;
998
999         if ((dip->i_di.di_mode & S_ISVTX) &&
1000             dip->i_di.di_uid != current->fsuid &&
1001             ip->i_di.di_uid != current->fsuid && !capable(CAP_FOWNER))
1002                 return -EPERM;
1003
1004         if (IS_APPEND(&dip->i_inode))
1005                 return -EPERM;
1006
1007         error = permission(&dip->i_inode, MAY_WRITE | MAY_EXEC, NULL);
1008         if (error)
1009                 return error;
1010
1011         error = gfs2_dir_search(&dip->i_inode, name, &inum, &type);
1012         if (error)
1013                 return error;
1014
1015         if (!gfs2_inum_equal(&inum, &ip->i_num))
1016                 return -ENOENT;
1017
1018         if (IF2DT(ip->i_di.di_mode) != type) {
1019                 gfs2_consist_inode(dip);
1020                 return -EIO;
1021         }
1022
1023         return 0;
1024 }
1025
1026 /*
1027  * gfs2_ok_to_move - check if it's ok to move a directory to another directory
1028  * @this: move this
1029  * @to: to here
1030  *
1031  * Follow @to back to the root and make sure we don't encounter @this
1032  * Assumes we already hold the rename lock.
1033  *
1034  * Returns: errno
1035  */
1036
1037 int gfs2_ok_to_move(struct gfs2_inode *this, struct gfs2_inode *to)
1038 {
1039         struct inode *dir = &to->i_inode;
1040         struct super_block *sb = dir->i_sb;
1041         struct inode *tmp;
1042         struct qstr dotdot;
1043         int error = 0;
1044
1045         gfs2_str2qstr(&dotdot, "..");
1046
1047         igrab(dir);
1048
1049         for (;;) {
1050                 if (dir == &this->i_inode) {
1051                         error = -EINVAL;
1052                         break;
1053                 }
1054                 if (dir == sb->s_root->d_inode) {
1055                         error = 0;
1056                         break;
1057                 }
1058
1059                 tmp = gfs2_lookupi(dir, &dotdot, 1, NULL);
1060                 if (IS_ERR(tmp)) {
1061                         error = PTR_ERR(tmp);
1062                         break;
1063                 }
1064
1065                 iput(dir);
1066                 dir = tmp;
1067         }
1068
1069         iput(dir);
1070
1071         return error;
1072 }
1073
1074 /**
1075  * gfs2_readlinki - return the contents of a symlink
1076  * @ip: the symlink's inode
1077  * @buf: a pointer to the buffer to be filled
1078  * @len: a pointer to the length of @buf
1079  *
1080  * If @buf is too small, a piece of memory is kmalloc()ed and needs
1081  * to be freed by the caller.
1082  *
1083  * Returns: errno
1084  */
1085
1086 int gfs2_readlinki(struct gfs2_inode *ip, char **buf, unsigned int *len)
1087 {
1088         struct gfs2_holder i_gh;
1089         struct buffer_head *dibh;
1090         unsigned int x;
1091         int error;
1092
1093         gfs2_holder_init(ip->i_gl, LM_ST_SHARED, GL_ATIME, &i_gh);
1094         error = gfs2_glock_nq_atime(&i_gh);
1095         if (error) {
1096                 gfs2_holder_uninit(&i_gh);
1097                 return error;
1098         }
1099
1100         if (!ip->i_di.di_size) {
1101                 gfs2_consist_inode(ip);
1102                 error = -EIO;
1103                 goto out;
1104         }
1105
1106         error = gfs2_meta_inode_buffer(ip, &dibh);
1107         if (error)
1108                 goto out;
1109
1110         x = ip->i_di.di_size + 1;
1111         if (x > *len) {
1112                 *buf = kmalloc(x, GFP_KERNEL);
1113                 if (!*buf) {
1114                         error = -ENOMEM;
1115                         goto out_brelse;
1116                 }
1117         }
1118
1119         memcpy(*buf, dibh->b_data + sizeof(struct gfs2_dinode), x);
1120         *len = x;
1121
1122 out_brelse:
1123         brelse(dibh);
1124 out:
1125         gfs2_glock_dq_uninit(&i_gh);
1126         return error;
1127 }
1128
1129 /**
1130  * gfs2_glock_nq_atime - Acquire a hold on an inode's glock, and
1131  *       conditionally update the inode's atime
1132  * @gh: the holder to acquire
1133  *
1134  * Tests atime (access time) for gfs2_read, gfs2_readdir and gfs2_mmap
1135  * Update if the difference between the current time and the inode's current
1136  * atime is greater than an interval specified at mount.
1137  *
1138  * Returns: errno
1139  */
1140
1141 int gfs2_glock_nq_atime(struct gfs2_holder *gh)
1142 {
1143         struct gfs2_glock *gl = gh->gh_gl;
1144         struct gfs2_sbd *sdp = gl->gl_sbd;
1145         struct gfs2_inode *ip = gl->gl_object;
1146         int64_t curtime, quantum = gfs2_tune_get(sdp, gt_atime_quantum);
1147         unsigned int state;
1148         int flags;
1149         int error;
1150
1151         if (gfs2_assert_warn(sdp, gh->gh_flags & GL_ATIME) ||
1152             gfs2_assert_warn(sdp, !(gh->gh_flags & GL_ASYNC)) ||
1153             gfs2_assert_warn(sdp, gl->gl_ops == &gfs2_inode_glops))
1154                 return -EINVAL;
1155
1156         state = gh->gh_state;
1157         flags = gh->gh_flags;
1158
1159         error = gfs2_glock_nq(gh);
1160         if (error)
1161                 return error;
1162
1163         if (test_bit(SDF_NOATIME, &sdp->sd_flags) ||
1164             (sdp->sd_vfs->s_flags & MS_RDONLY))
1165                 return 0;
1166
1167         curtime = get_seconds();
1168         if (curtime - ip->i_di.di_atime >= quantum) {
1169                 gfs2_glock_dq(gh);
1170                 gfs2_holder_reinit(LM_ST_EXCLUSIVE, gh->gh_flags & ~LM_FLAG_ANY,
1171                                    gh);
1172                 error = gfs2_glock_nq(gh);
1173                 if (error)
1174                         return error;
1175
1176                 /* Verify that atime hasn't been updated while we were
1177                    trying to get exclusive lock. */
1178
1179                 curtime = get_seconds();
1180                 if (curtime - ip->i_di.di_atime >= quantum) {
1181                         struct buffer_head *dibh;
1182
1183                         error = gfs2_trans_begin(sdp, RES_DINODE, 0);
1184                         if (error == -EROFS)
1185                                 return 0;
1186                         if (error)
1187                                 goto fail;
1188
1189                         error = gfs2_meta_inode_buffer(ip, &dibh);
1190                         if (error)
1191                                 goto fail_end_trans;
1192
1193                         ip->i_di.di_atime = curtime;
1194
1195                         gfs2_trans_add_bh(ip->i_gl, dibh, 1);
1196                         gfs2_dinode_out(&ip->i_di, dibh->b_data);
1197                         brelse(dibh);
1198
1199                         gfs2_trans_end(sdp);
1200                 }
1201
1202                 /* If someone else has asked for the glock,
1203                    unlock and let them have it. Then reacquire
1204                    in the original state. */
1205                 if (gfs2_glock_is_blocking(gl)) {
1206                         gfs2_glock_dq(gh);
1207                         gfs2_holder_reinit(state, flags, gh);
1208                         return gfs2_glock_nq(gh);
1209                 }
1210         }
1211
1212         return 0;
1213
1214 fail_end_trans:
1215         gfs2_trans_end(sdp);
1216 fail:
1217         gfs2_glock_dq(gh);
1218         return error;
1219 }
1220
1221 /**
1222  * glock_compare_atime - Compare two struct gfs2_glock structures for sort
1223  * @arg_a: the first structure
1224  * @arg_b: the second structure
1225  *
1226  * Returns: 1 if A > B
1227  *         -1 if A < B
1228  *          0 if A = B
1229  */
1230
1231 static int glock_compare_atime(const void *arg_a, const void *arg_b)
1232 {
1233         struct gfs2_holder *gh_a = *(struct gfs2_holder **)arg_a;
1234         struct gfs2_holder *gh_b = *(struct gfs2_holder **)arg_b;
1235         struct lm_lockname *a = &gh_a->gh_gl->gl_name;
1236         struct lm_lockname *b = &gh_b->gh_gl->gl_name;
1237         int ret = 0;
1238
1239         if (a->ln_number > b->ln_number)
1240                 ret = 1;
1241         else if (a->ln_number < b->ln_number)
1242                 ret = -1;
1243         else {
1244                 if (gh_a->gh_state == LM_ST_SHARED &&
1245                     gh_b->gh_state == LM_ST_EXCLUSIVE)
1246                         ret = 1;
1247                 else if (gh_a->gh_state == LM_ST_SHARED &&
1248                          (gh_b->gh_flags & GL_ATIME))
1249                         ret = 1;
1250         }
1251
1252         return ret;
1253 }
1254
1255 /**
1256  * gfs2_glock_nq_m_atime - acquire multiple glocks where one may need an
1257  *      atime update
1258  * @num_gh: the number of structures
1259  * @ghs: an array of struct gfs2_holder structures
1260  *
1261  * Returns: 0 on success (all glocks acquired),
1262  *          errno on failure (no glocks acquired)
1263  */
1264
1265 int gfs2_glock_nq_m_atime(unsigned int num_gh, struct gfs2_holder *ghs)
1266 {
1267         struct gfs2_holder **p;
1268         unsigned int x;
1269         int error = 0;
1270
1271         if (!num_gh)
1272                 return 0;
1273
1274         if (num_gh == 1) {
1275                 ghs->gh_flags &= ~(LM_FLAG_TRY | GL_ASYNC);
1276                 if (ghs->gh_flags & GL_ATIME)
1277                         error = gfs2_glock_nq_atime(ghs);
1278                 else
1279                         error = gfs2_glock_nq(ghs);
1280                 return error;
1281         }
1282
1283         p = kcalloc(num_gh, sizeof(struct gfs2_holder *), GFP_KERNEL);
1284         if (!p)
1285                 return -ENOMEM;
1286
1287         for (x = 0; x < num_gh; x++)
1288                 p[x] = &ghs[x];
1289
1290         sort(p, num_gh, sizeof(struct gfs2_holder *), glock_compare_atime,NULL);
1291
1292         for (x = 0; x < num_gh; x++) {
1293                 p[x]->gh_flags &= ~(LM_FLAG_TRY | GL_ASYNC);
1294
1295                 if (p[x]->gh_flags & GL_ATIME)
1296                         error = gfs2_glock_nq_atime(p[x]);
1297                 else
1298                         error = gfs2_glock_nq(p[x]);
1299
1300                 if (error) {
1301                         while (x--)
1302                                 gfs2_glock_dq(p[x]);
1303                         break;
1304                 }
1305         }
1306
1307         kfree(p);
1308
1309         return error;
1310 }
1311
1312
1313 static int
1314 __gfs2_setattr_simple(struct gfs2_inode *ip, struct iattr *attr)
1315 {
1316         struct buffer_head *dibh;
1317         int error;
1318
1319         error = gfs2_meta_inode_buffer(ip, &dibh);
1320         if (!error) {
1321                 error = inode_setattr(&ip->i_inode, attr);
1322                 gfs2_assert_warn(GFS2_SB(&ip->i_inode), !error);
1323                 gfs2_inode_attr_out(ip);
1324
1325                 gfs2_trans_add_bh(ip->i_gl, dibh, 1);
1326                 gfs2_dinode_out(&ip->i_di, dibh->b_data);
1327                 brelse(dibh);
1328         }
1329         return error;
1330 }
1331
1332 /**
1333  * gfs2_setattr_simple -
1334  * @ip:
1335  * @attr:
1336  *
1337  * Called with a reference on the vnode.
1338  *
1339  * Returns: errno
1340  */
1341
1342 int gfs2_setattr_simple(struct gfs2_inode *ip, struct iattr *attr)
1343 {
1344         int error;
1345
1346         if (current->journal_info)
1347                 return __gfs2_setattr_simple(ip, attr);
1348
1349         error = gfs2_trans_begin(GFS2_SB(&ip->i_inode), RES_DINODE, 0);
1350         if (error)
1351                 return error;
1352
1353         error = __gfs2_setattr_simple(ip, attr);
1354
1355         gfs2_trans_end(GFS2_SB(&ip->i_inode));
1356
1357         return error;
1358 }
1359