]> bbs.cooldavid.org Git - net-next-2.6.git/blame - fs/xfs/xfs_iget.c
Merge git://git.infradead.org/users/cbou/battery-2.6.35
[net-next-2.6.git] / fs / xfs / xfs_iget.c
CommitLineData
1da177e4 1/*
7b718769
NS
2 * Copyright (c) 2000-2005 Silicon Graphics, Inc.
3 * All Rights Reserved.
1da177e4 4 *
7b718769
NS
5 * This program is free software; you can redistribute it and/or
6 * modify it under the terms of the GNU General Public License as
1da177e4
LT
7 * published by the Free Software Foundation.
8 *
7b718769
NS
9 * This program is distributed in the hope that it would be useful,
10 * but WITHOUT ANY WARRANTY; without even the implied warranty of
11 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
12 * GNU General Public License for more details.
1da177e4 13 *
7b718769
NS
14 * You should have received a copy of the GNU General Public License
15 * along with this program; if not, write the Free Software Foundation,
16 * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
1da177e4 17 */
1da177e4 18#include "xfs.h"
a844f451 19#include "xfs_fs.h"
1da177e4 20#include "xfs_types.h"
ef14f0c1 21#include "xfs_acl.h"
a844f451 22#include "xfs_bit.h"
1da177e4 23#include "xfs_log.h"
a844f451 24#include "xfs_inum.h"
1da177e4
LT
25#include "xfs_trans.h"
26#include "xfs_sb.h"
27#include "xfs_ag.h"
1da177e4
LT
28#include "xfs_dir2.h"
29#include "xfs_dmapi.h"
30#include "xfs_mount.h"
1da177e4 31#include "xfs_bmap_btree.h"
a844f451 32#include "xfs_alloc_btree.h"
1da177e4 33#include "xfs_ialloc_btree.h"
1da177e4 34#include "xfs_dir2_sf.h"
a844f451 35#include "xfs_attr_sf.h"
1da177e4
LT
36#include "xfs_dinode.h"
37#include "xfs_inode.h"
a844f451
NS
38#include "xfs_btree.h"
39#include "xfs_ialloc.h"
1da177e4
LT
40#include "xfs_quota.h"
41#include "xfs_utils.h"
783a2f65
DC
42#include "xfs_trans_priv.h"
43#include "xfs_inode_item.h"
24f211ba
CH
44#include "xfs_bmap.h"
45#include "xfs_btree_trace.h"
0b1b213f 46#include "xfs_trace.h"
24f211ba
CH
47
48
49/*
50 * Allocate and initialise an xfs_inode.
51 */
52STATIC struct xfs_inode *
53xfs_inode_alloc(
54 struct xfs_mount *mp,
55 xfs_ino_t ino)
56{
57 struct xfs_inode *ip;
58
59 /*
60 * if this didn't occur in transactions, we could use
61 * KM_MAYFAIL and return NULL here on ENOMEM. Set the
62 * code up to do this anyway.
63 */
64 ip = kmem_zone_alloc(xfs_inode_zone, KM_SLEEP);
65 if (!ip)
66 return NULL;
54e34621
CH
67 if (inode_init_always(mp->m_super, VFS_I(ip))) {
68 kmem_zone_free(xfs_inode_zone, ip);
69 return NULL;
70 }
24f211ba
CH
71
72 ASSERT(atomic_read(&ip->i_iocount) == 0);
73 ASSERT(atomic_read(&ip->i_pincount) == 0);
74 ASSERT(!spin_is_locked(&ip->i_flags_lock));
75 ASSERT(completion_done(&ip->i_flush));
033da48f
CH
76
77 mrlock_init(&ip->i_iolock, MRLOCK_BARRIER, "xfsio", ip->i_ino);
24f211ba 78
24f211ba
CH
79 /* initialise the xfs inode */
80 ip->i_ino = ino;
81 ip->i_mount = mp;
82 memset(&ip->i_imap, 0, sizeof(struct xfs_imap));
83 ip->i_afp = NULL;
84 memset(&ip->i_df, 0, sizeof(xfs_ifork_t));
85 ip->i_flags = 0;
86 ip->i_update_core = 0;
24f211ba
CH
87 ip->i_delayed_blks = 0;
88 memset(&ip->i_d, 0, sizeof(xfs_icdinode_t));
89 ip->i_size = 0;
90 ip->i_new_size = 0;
91
705db3fd 92 /* prevent anyone from using this yet */
eaff8079 93 VFS_I(ip)->i_state = I_NEW;
24f211ba
CH
94
95 return ip;
96}
1da177e4 97
b36ec042
CH
98STATIC void
99xfs_inode_free(
100 struct xfs_inode *ip)
101{
102 switch (ip->i_d.di_mode & S_IFMT) {
103 case S_IFREG:
104 case S_IFDIR:
105 case S_IFLNK:
106 xfs_idestroy_fork(ip, XFS_DATA_FORK);
107 break;
108 }
109
110 if (ip->i_afp)
111 xfs_idestroy_fork(ip, XFS_ATTR_FORK);
112
b36ec042
CH
113 if (ip->i_itemp) {
114 /*
115 * Only if we are shutting down the fs will we see an
116 * inode still in the AIL. If it is there, we should remove
117 * it to prevent a use-after-free from occurring.
118 */
119 xfs_log_item_t *lip = &ip->i_itemp->ili_item;
120 struct xfs_ail *ailp = lip->li_ailp;
121
122 ASSERT(((lip->li_flags & XFS_LI_IN_AIL) == 0) ||
123 XFS_FORCED_SHUTDOWN(ip->i_mount));
124 if (lip->li_flags & XFS_LI_IN_AIL) {
125 spin_lock(&ailp->xa_lock);
126 if (lip->li_flags & XFS_LI_IN_AIL)
127 xfs_trans_ail_delete(ailp, lip);
128 else
129 spin_unlock(&ailp->xa_lock);
130 }
131 xfs_inode_item_destroy(ip);
132 ip->i_itemp = NULL;
133 }
134
135 /* asserts to verify all state is correct here */
136 ASSERT(atomic_read(&ip->i_iocount) == 0);
137 ASSERT(atomic_read(&ip->i_pincount) == 0);
138 ASSERT(!spin_is_locked(&ip->i_flags_lock));
139 ASSERT(completion_done(&ip->i_flush));
140
141 kmem_zone_free(xfs_inode_zone, ip);
142}
143
1da177e4 144/*
6441e549 145 * Check the validity of the inode we just found it the cache
1da177e4 146 */
6441e549
DC
147static int
148xfs_iget_cache_hit(
6441e549
DC
149 struct xfs_perag *pag,
150 struct xfs_inode *ip,
151 int flags,
152 int lock_flags) __releases(pag->pag_ici_lock)
1da177e4 153{
bc990f5c 154 struct inode *inode = VFS_I(ip);
6441e549 155 struct xfs_mount *mp = ip->i_mount;
bc990f5c
CH
156 int error;
157
158 spin_lock(&ip->i_flags_lock);
da353b0d 159
6441e549 160 /*
bc990f5c
CH
161 * If we are racing with another cache hit that is currently
162 * instantiating this inode or currently recycling it out of
163 * reclaimabe state, wait for the initialisation to complete
164 * before continuing.
165 *
166 * XXX(hch): eventually we should do something equivalent to
167 * wait_on_inode to wait for these flags to be cleared
168 * instead of polling for it.
6441e549 169 */
bc990f5c 170 if (ip->i_flags & (XFS_INEW|XFS_IRECLAIM)) {
0b1b213f 171 trace_xfs_iget_skip(ip);
6441e549 172 XFS_STATS_INC(xs_ig_frecycle);
bc990f5c 173 error = EAGAIN;
6441e549
DC
174 goto out_error;
175 }
da353b0d 176
bc990f5c
CH
177 /*
178 * If lookup is racing with unlink return an error immediately.
179 */
180 if (ip->i_d.di_mode == 0 && !(flags & XFS_IGET_CREATE)) {
181 error = ENOENT;
182 goto out_error;
183 }
bf904248 184
bc990f5c
CH
185 /*
186 * If IRECLAIMABLE is set, we've torn down the VFS inode already.
187 * Need to carefully get it back into useable state.
188 */
189 if (ip->i_flags & XFS_IRECLAIMABLE) {
0b1b213f 190 trace_xfs_iget_reclaim(ip);
da353b0d 191
6441e549 192 /*
f1f724e4
CH
193 * We need to set XFS_IRECLAIM to prevent xfs_reclaim_inode
194 * from stomping over us while we recycle the inode. We can't
195 * clear the radix tree reclaimable tag yet as it requires
196 * pag_ici_lock to be held exclusive.
6441e549 197 */
f1f724e4 198 ip->i_flags |= XFS_IRECLAIM;
bc990f5c
CH
199
200 spin_unlock(&ip->i_flags_lock);
201 read_unlock(&pag->pag_ici_lock);
202
203 error = -inode_init_always(mp->m_super, inode);
204 if (error) {
205 /*
206 * Re-initializing the inode failed, and we are in deep
207 * trouble. Try to re-add it to the reclaim list.
208 */
209 read_lock(&pag->pag_ici_lock);
210 spin_lock(&ip->i_flags_lock);
211
212 ip->i_flags &= ~XFS_INEW;
213 ip->i_flags |= XFS_IRECLAIMABLE;
214 __xfs_inode_set_reclaim_tag(pag, ip);
0b1b213f 215 trace_xfs_iget_reclaim(ip);
6441e549 216 goto out_error;
da353b0d 217 }
f1f724e4
CH
218
219 write_lock(&pag->pag_ici_lock);
220 spin_lock(&ip->i_flags_lock);
221 ip->i_flags &= ~(XFS_IRECLAIMABLE | XFS_IRECLAIM);
222 ip->i_flags |= XFS_INEW;
223 __xfs_inode_clear_reclaim_tag(mp, pag, ip);
eaff8079 224 inode->i_state = I_NEW;
f1f724e4
CH
225 spin_unlock(&ip->i_flags_lock);
226 write_unlock(&pag->pag_ici_lock);
bc990f5c 227 } else {
bf904248 228 /* If the VFS inode is being torn down, pause and try again. */
bc990f5c
CH
229 if (!igrab(inode)) {
230 error = EAGAIN;
231 goto out_error;
232 }
1da177e4 233
bc990f5c
CH
234 /* We've got a live one. */
235 spin_unlock(&ip->i_flags_lock);
236 read_unlock(&pag->pag_ici_lock);
6441e549 237 }
da353b0d 238
6441e549
DC
239 if (lock_flags != 0)
240 xfs_ilock(ip, lock_flags);
da353b0d 241
6441e549 242 xfs_iflags_clear(ip, XFS_ISTALE);
6441e549 243 XFS_STATS_INC(xs_ig_found);
0b1b213f
CH
244
245 trace_xfs_iget_found(ip);
6441e549 246 return 0;
1da177e4 247
6441e549 248out_error:
bc990f5c 249 spin_unlock(&ip->i_flags_lock);
da353b0d 250 read_unlock(&pag->pag_ici_lock);
6441e549
DC
251 return error;
252}
253
254
255static int
256xfs_iget_cache_miss(
257 struct xfs_mount *mp,
258 struct xfs_perag *pag,
259 xfs_trans_t *tp,
260 xfs_ino_t ino,
261 struct xfs_inode **ipp,
6441e549 262 int flags,
0c3dc2b0 263 int lock_flags)
6441e549
DC
264{
265 struct xfs_inode *ip;
266 int error;
267 unsigned long first_index, mask;
268 xfs_agino_t agino = XFS_INO_TO_AGINO(mp, ino);
1da177e4 269
24f211ba
CH
270 ip = xfs_inode_alloc(mp, ino);
271 if (!ip)
272 return ENOMEM;
273
7b6259e7 274 error = xfs_iread(mp, tp, ip, flags);
6441e549 275 if (error)
24f211ba 276 goto out_destroy;
1da177e4 277
0b1b213f 278 xfs_itrace_entry(ip);
1da177e4 279
745b1f47 280 if ((ip->i_d.di_mode == 0) && !(flags & XFS_IGET_CREATE)) {
6441e549
DC
281 error = ENOENT;
282 goto out_destroy;
1da177e4
LT
283 }
284
285 /*
bad55843 286 * Preload the radix tree so we can insert safely under the
56e73ec4
DC
287 * write spinlock. Note that we cannot sleep inside the preload
288 * region.
1da177e4 289 */
da353b0d 290 if (radix_tree_preload(GFP_KERNEL)) {
6441e549 291 error = EAGAIN;
ed93ec39
CH
292 goto out_destroy;
293 }
294
295 /*
296 * Because the inode hasn't been added to the radix-tree yet it can't
297 * be found by another thread, so we can do the non-sleeping lock here.
298 */
299 if (lock_flags) {
300 if (!xfs_ilock_nowait(ip, lock_flags))
301 BUG();
da353b0d 302 }
f338f903 303
da353b0d
DC
304 mask = ~(((XFS_INODE_CLUSTER_SIZE(mp) >> mp->m_sb.sb_inodelog)) - 1);
305 first_index = agino & mask;
306 write_lock(&pag->pag_ici_lock);
6441e549
DC
307
308 /* insert the new inode */
da353b0d
DC
309 error = radix_tree_insert(&pag->pag_ici_root, agino, ip);
310 if (unlikely(error)) {
6441e549 311 WARN_ON(error != -EEXIST);
da353b0d 312 XFS_STATS_INC(xs_ig_dup);
6441e549 313 error = EAGAIN;
56e73ec4 314 goto out_preload_end;
1da177e4
LT
315 }
316
6441e549 317 /* These values _must_ be set before releasing the radix tree lock! */
1da177e4 318 ip->i_udquot = ip->i_gdquot = NULL;
7a18c386 319 xfs_iflags_set(ip, XFS_INEW);
1da177e4 320
da353b0d
DC
321 write_unlock(&pag->pag_ici_lock);
322 radix_tree_preload_end();
0b1b213f
CH
323
324 trace_xfs_iget_alloc(ip);
6441e549
DC
325 *ipp = ip;
326 return 0;
327
56e73ec4 328out_preload_end:
6441e549
DC
329 write_unlock(&pag->pag_ici_lock);
330 radix_tree_preload_end();
56e73ec4
DC
331 if (lock_flags)
332 xfs_iunlock(ip, lock_flags);
6441e549 333out_destroy:
b36ec042
CH
334 __destroy_inode(VFS_I(ip));
335 xfs_inode_free(ip);
6441e549
DC
336 return error;
337}
338
339/*
340 * Look up an inode by number in the given file system.
341 * The inode is looked up in the cache held in each AG.
bf904248
DC
342 * If the inode is found in the cache, initialise the vfs inode
343 * if necessary.
6441e549
DC
344 *
345 * If it is not in core, read it in from the file system's device,
bf904248 346 * add it to the cache and initialise the vfs inode.
6441e549
DC
347 *
348 * The inode is locked according to the value of the lock_flags parameter.
349 * This flag parameter indicates how and if the inode's IO lock and inode lock
350 * should be taken.
351 *
352 * mp -- the mount point structure for the current file system. It points
353 * to the inode hash table.
354 * tp -- a pointer to the current transaction if there is one. This is
355 * simply passed through to the xfs_iread() call.
356 * ino -- the number of the inode desired. This is the unique identifier
357 * within the file system for the inode being requested.
358 * lock_flags -- flags indicating how to lock the inode. See the comment
359 * for xfs_ilock() for a list of valid values.
6441e549 360 */
bf904248
DC
361int
362xfs_iget(
6441e549
DC
363 xfs_mount_t *mp,
364 xfs_trans_t *tp,
365 xfs_ino_t ino,
366 uint flags,
367 uint lock_flags,
7b6259e7 368 xfs_inode_t **ipp)
6441e549
DC
369{
370 xfs_inode_t *ip;
371 int error;
372 xfs_perag_t *pag;
373 xfs_agino_t agino;
374
375 /* the radix tree exists only in inode capable AGs */
376 if (XFS_INO_TO_AGNO(mp, ino) >= mp->m_maxagi)
377 return EINVAL;
378
379 /* get the perag structure and ensure that it's inode capable */
5017e97d 380 pag = xfs_perag_get(mp, XFS_INO_TO_AGNO(mp, ino));
6441e549
DC
381 agino = XFS_INO_TO_AGINO(mp, ino);
382
383again:
384 error = 0;
385 read_lock(&pag->pag_ici_lock);
386 ip = radix_tree_lookup(&pag->pag_ici_root, agino);
387
388 if (ip) {
bf904248 389 error = xfs_iget_cache_hit(pag, ip, flags, lock_flags);
6441e549
DC
390 if (error)
391 goto out_error_or_again;
392 } else {
393 read_unlock(&pag->pag_ici_lock);
394 XFS_STATS_INC(xs_ig_missed);
395
7b6259e7 396 error = xfs_iget_cache_miss(mp, pag, tp, ino, &ip,
6441e549
DC
397 flags, lock_flags);
398 if (error)
399 goto out_error_or_again;
400 }
5017e97d 401 xfs_perag_put(pag);
1da177e4 402
1da177e4
LT
403 *ipp = ip;
404
bf904248
DC
405 ASSERT(ip->i_df.if_ext_max ==
406 XFS_IFORK_DSIZE(ip) / sizeof(xfs_bmbt_rec_t));
1da177e4
LT
407 /*
408 * If we have a real type for an on-disk inode, we can set ops(&unlock)
409 * now. If it's a new inode being created, xfs_ialloc will handle it.
410 */
bf904248 411 if (xfs_iflags_test(ip, XFS_INEW) && ip->i_d.di_mode != 0)
41be8bed 412 xfs_setup_inode(ip);
1da177e4 413 return 0;
6441e549
DC
414
415out_error_or_again:
416 if (error == EAGAIN) {
417 delay(1);
418 goto again;
419 }
5017e97d 420 xfs_perag_put(pag);
6441e549 421 return error;
1da177e4
LT
422}
423
1da177e4
LT
424/*
425 * Decrement reference count of an inode structure and unlock it.
426 *
427 * ip -- the inode being released
428 * lock_flags -- this parameter indicates the inode's locks to be
429 * to be released. See the comment on xfs_iunlock() for a list
430 * of valid values.
431 */
432void
433xfs_iput(xfs_inode_t *ip,
434 uint lock_flags)
435{
cf441eeb 436 xfs_itrace_entry(ip);
1da177e4 437 xfs_iunlock(ip, lock_flags);
10090be2 438 IRELE(ip);
1da177e4
LT
439}
440
441/*
442 * Special iput for brand-new inodes that are still locked
443 */
444void
01651646
DC
445xfs_iput_new(
446 xfs_inode_t *ip,
447 uint lock_flags)
1da177e4 448{
01651646 449 struct inode *inode = VFS_I(ip);
1da177e4 450
cf441eeb 451 xfs_itrace_entry(ip);
1da177e4
LT
452
453 if ((ip->i_d.di_mode == 0)) {
7a18c386 454 ASSERT(!xfs_iflags_test(ip, XFS_IRECLAIMABLE));
10090be2 455 make_bad_inode(inode);
1da177e4
LT
456 }
457 if (inode->i_state & I_NEW)
458 unlock_new_inode(inode);
459 if (lock_flags)
460 xfs_iunlock(ip, lock_flags);
10090be2 461 IRELE(ip);
1da177e4
LT
462}
463
1da177e4 464/*
5cafdeb2
CH
465 * This is called free all the memory associated with an inode.
466 * It must free the inode itself and any buffers allocated for
467 * if_extents/if_data and if_broot. It must also free the lock
468 * associated with the inode.
469 *
470 * Note: because we don't initialise everything on reallocation out
471 * of the zone, we must ensure we nullify everything correctly before
472 * freeing the structure.
1da177e4
LT
473 */
474void
5cafdeb2
CH
475xfs_ireclaim(
476 struct xfs_inode *ip)
1da177e4 477{
5cafdeb2
CH
478 struct xfs_mount *mp = ip->i_mount;
479 struct xfs_perag *pag;
b44b1126 480 xfs_agino_t agino = XFS_INO_TO_AGINO(mp, ip->i_ino);
1da177e4 481
5cafdeb2 482 XFS_STATS_INC(xs_ig_reclaims);
1da177e4
LT
483
484 /*
b44b1126
CH
485 * Remove the inode from the per-AG radix tree.
486 *
487 * Because radix_tree_delete won't complain even if the item was never
488 * added to the tree assert that it's been there before to catch
489 * problems with the inode life time early on.
1da177e4 490 */
5017e97d 491 pag = xfs_perag_get(mp, XFS_INO_TO_AGNO(mp, ip->i_ino));
5cafdeb2 492 write_lock(&pag->pag_ici_lock);
b44b1126
CH
493 if (!radix_tree_delete(&pag->pag_ici_root, agino))
494 ASSERT(0);
5cafdeb2 495 write_unlock(&pag->pag_ici_lock);
5017e97d 496 xfs_perag_put(pag);
1da177e4
LT
497
498 /*
5cafdeb2
CH
499 * Here we do an (almost) spurious inode lock in order to coordinate
500 * with inode cache radix tree lookups. This is because the lookup
501 * can reference the inodes in the cache without taking references.
502 *
503 * We make that OK here by ensuring that we wait until the inode is
504 * unlocked after the lookup before we go ahead and free it. We get
505 * both the ilock and the iolock because the code may need to drop the
506 * ilock one but will still hold the iolock.
1da177e4 507 */
5cafdeb2 508 xfs_ilock(ip, XFS_ILOCK_EXCL | XFS_IOLOCK_EXCL);
7d095257 509 xfs_qm_dqdetach(ip);
439b8434 510 xfs_iunlock(ip, XFS_ILOCK_EXCL | XFS_IOLOCK_EXCL);
1da177e4 511
b36ec042 512 xfs_inode_free(ip);
1da177e4
LT
513}
514
515/*
516 * This is a wrapper routine around the xfs_ilock() routine
517 * used to centralize some grungy code. It is used in places
518 * that wish to lock the inode solely for reading the extents.
519 * The reason these places can't just call xfs_ilock(SHARED)
520 * is that the inode lock also guards to bringing in of the
521 * extents from disk for a file in b-tree format. If the inode
522 * is in b-tree format, then we need to lock the inode exclusively
523 * until the extents are read in. Locking it exclusively all
524 * the time would limit our parallelism unnecessarily, though.
525 * What we do instead is check to see if the extents have been
526 * read in yet, and only lock the inode exclusively if they
527 * have not.
528 *
529 * The function returns a value which should be given to the
530 * corresponding xfs_iunlock_map_shared(). This value is
531 * the mode in which the lock was actually taken.
532 */
533uint
534xfs_ilock_map_shared(
535 xfs_inode_t *ip)
536{
537 uint lock_mode;
538
539 if ((ip->i_d.di_format == XFS_DINODE_FMT_BTREE) &&
540 ((ip->i_df.if_flags & XFS_IFEXTENTS) == 0)) {
541 lock_mode = XFS_ILOCK_EXCL;
542 } else {
543 lock_mode = XFS_ILOCK_SHARED;
544 }
545
546 xfs_ilock(ip, lock_mode);
547
548 return lock_mode;
549}
550
551/*
552 * This is simply the unlock routine to go with xfs_ilock_map_shared().
553 * All it does is call xfs_iunlock() with the given lock_mode.
554 */
555void
556xfs_iunlock_map_shared(
557 xfs_inode_t *ip,
558 unsigned int lock_mode)
559{
560 xfs_iunlock(ip, lock_mode);
561}
562
563/*
564 * The xfs inode contains 2 locks: a multi-reader lock called the
565 * i_iolock and a multi-reader lock called the i_lock. This routine
566 * allows either or both of the locks to be obtained.
567 *
568 * The 2 locks should always be ordered so that the IO lock is
569 * obtained first in order to prevent deadlock.
570 *
571 * ip -- the inode being locked
572 * lock_flags -- this parameter indicates the inode's locks
573 * to be locked. It can be:
574 * XFS_IOLOCK_SHARED,
575 * XFS_IOLOCK_EXCL,
576 * XFS_ILOCK_SHARED,
577 * XFS_ILOCK_EXCL,
578 * XFS_IOLOCK_SHARED | XFS_ILOCK_SHARED,
579 * XFS_IOLOCK_SHARED | XFS_ILOCK_EXCL,
580 * XFS_IOLOCK_EXCL | XFS_ILOCK_SHARED,
581 * XFS_IOLOCK_EXCL | XFS_ILOCK_EXCL
582 */
583void
579aa9ca
CH
584xfs_ilock(
585 xfs_inode_t *ip,
586 uint lock_flags)
1da177e4
LT
587{
588 /*
589 * You can't set both SHARED and EXCL for the same lock,
590 * and only XFS_IOLOCK_SHARED, XFS_IOLOCK_EXCL, XFS_ILOCK_SHARED,
591 * and XFS_ILOCK_EXCL are valid values to set in lock_flags.
592 */
593 ASSERT((lock_flags & (XFS_IOLOCK_SHARED | XFS_IOLOCK_EXCL)) !=
594 (XFS_IOLOCK_SHARED | XFS_IOLOCK_EXCL));
595 ASSERT((lock_flags & (XFS_ILOCK_SHARED | XFS_ILOCK_EXCL)) !=
596 (XFS_ILOCK_SHARED | XFS_ILOCK_EXCL));
f7c66ce3 597 ASSERT((lock_flags & ~(XFS_LOCK_MASK | XFS_LOCK_DEP_MASK)) == 0);
1da177e4 598
579aa9ca 599 if (lock_flags & XFS_IOLOCK_EXCL)
f7c66ce3 600 mrupdate_nested(&ip->i_iolock, XFS_IOLOCK_DEP(lock_flags));
579aa9ca 601 else if (lock_flags & XFS_IOLOCK_SHARED)
f7c66ce3 602 mraccess_nested(&ip->i_iolock, XFS_IOLOCK_DEP(lock_flags));
579aa9ca
CH
603
604 if (lock_flags & XFS_ILOCK_EXCL)
f7c66ce3 605 mrupdate_nested(&ip->i_lock, XFS_ILOCK_DEP(lock_flags));
579aa9ca 606 else if (lock_flags & XFS_ILOCK_SHARED)
f7c66ce3 607 mraccess_nested(&ip->i_lock, XFS_ILOCK_DEP(lock_flags));
579aa9ca 608
0b1b213f 609 trace_xfs_ilock(ip, lock_flags, _RET_IP_);
1da177e4
LT
610}
611
612/*
613 * This is just like xfs_ilock(), except that the caller
614 * is guaranteed not to sleep. It returns 1 if it gets
615 * the requested locks and 0 otherwise. If the IO lock is
616 * obtained but the inode lock cannot be, then the IO lock
617 * is dropped before returning.
618 *
619 * ip -- the inode being locked
620 * lock_flags -- this parameter indicates the inode's locks to be
621 * to be locked. See the comment for xfs_ilock() for a list
622 * of valid values.
1da177e4
LT
623 */
624int
579aa9ca
CH
625xfs_ilock_nowait(
626 xfs_inode_t *ip,
627 uint lock_flags)
1da177e4 628{
1da177e4
LT
629 /*
630 * You can't set both SHARED and EXCL for the same lock,
631 * and only XFS_IOLOCK_SHARED, XFS_IOLOCK_EXCL, XFS_ILOCK_SHARED,
632 * and XFS_ILOCK_EXCL are valid values to set in lock_flags.
633 */
634 ASSERT((lock_flags & (XFS_IOLOCK_SHARED | XFS_IOLOCK_EXCL)) !=
635 (XFS_IOLOCK_SHARED | XFS_IOLOCK_EXCL));
636 ASSERT((lock_flags & (XFS_ILOCK_SHARED | XFS_ILOCK_EXCL)) !=
637 (XFS_ILOCK_SHARED | XFS_ILOCK_EXCL));
f7c66ce3 638 ASSERT((lock_flags & ~(XFS_LOCK_MASK | XFS_LOCK_DEP_MASK)) == 0);
1da177e4 639
1da177e4 640 if (lock_flags & XFS_IOLOCK_EXCL) {
579aa9ca
CH
641 if (!mrtryupdate(&ip->i_iolock))
642 goto out;
1da177e4 643 } else if (lock_flags & XFS_IOLOCK_SHARED) {
579aa9ca
CH
644 if (!mrtryaccess(&ip->i_iolock))
645 goto out;
1da177e4
LT
646 }
647 if (lock_flags & XFS_ILOCK_EXCL) {
579aa9ca
CH
648 if (!mrtryupdate(&ip->i_lock))
649 goto out_undo_iolock;
1da177e4 650 } else if (lock_flags & XFS_ILOCK_SHARED) {
579aa9ca
CH
651 if (!mrtryaccess(&ip->i_lock))
652 goto out_undo_iolock;
1da177e4 653 }
0b1b213f 654 trace_xfs_ilock_nowait(ip, lock_flags, _RET_IP_);
1da177e4 655 return 1;
579aa9ca
CH
656
657 out_undo_iolock:
658 if (lock_flags & XFS_IOLOCK_EXCL)
659 mrunlock_excl(&ip->i_iolock);
660 else if (lock_flags & XFS_IOLOCK_SHARED)
661 mrunlock_shared(&ip->i_iolock);
662 out:
663 return 0;
1da177e4
LT
664}
665
666/*
667 * xfs_iunlock() is used to drop the inode locks acquired with
668 * xfs_ilock() and xfs_ilock_nowait(). The caller must pass
669 * in the flags given to xfs_ilock() or xfs_ilock_nowait() so
670 * that we know which locks to drop.
671 *
672 * ip -- the inode being unlocked
673 * lock_flags -- this parameter indicates the inode's locks to be
674 * to be unlocked. See the comment for xfs_ilock() for a list
675 * of valid values for this parameter.
676 *
677 */
678void
579aa9ca
CH
679xfs_iunlock(
680 xfs_inode_t *ip,
681 uint lock_flags)
1da177e4
LT
682{
683 /*
684 * You can't set both SHARED and EXCL for the same lock,
685 * and only XFS_IOLOCK_SHARED, XFS_IOLOCK_EXCL, XFS_ILOCK_SHARED,
686 * and XFS_ILOCK_EXCL are valid values to set in lock_flags.
687 */
688 ASSERT((lock_flags & (XFS_IOLOCK_SHARED | XFS_IOLOCK_EXCL)) !=
689 (XFS_IOLOCK_SHARED | XFS_IOLOCK_EXCL));
690 ASSERT((lock_flags & (XFS_ILOCK_SHARED | XFS_ILOCK_EXCL)) !=
691 (XFS_ILOCK_SHARED | XFS_ILOCK_EXCL));
f7c66ce3
LM
692 ASSERT((lock_flags & ~(XFS_LOCK_MASK | XFS_IUNLOCK_NONOTIFY |
693 XFS_LOCK_DEP_MASK)) == 0);
1da177e4
LT
694 ASSERT(lock_flags != 0);
695
579aa9ca
CH
696 if (lock_flags & XFS_IOLOCK_EXCL)
697 mrunlock_excl(&ip->i_iolock);
698 else if (lock_flags & XFS_IOLOCK_SHARED)
699 mrunlock_shared(&ip->i_iolock);
1da177e4 700
579aa9ca
CH
701 if (lock_flags & XFS_ILOCK_EXCL)
702 mrunlock_excl(&ip->i_lock);
703 else if (lock_flags & XFS_ILOCK_SHARED)
704 mrunlock_shared(&ip->i_lock);
1da177e4 705
579aa9ca
CH
706 if ((lock_flags & (XFS_ILOCK_SHARED | XFS_ILOCK_EXCL)) &&
707 !(lock_flags & XFS_IUNLOCK_NONOTIFY) && ip->i_itemp) {
1da177e4
LT
708 /*
709 * Let the AIL know that this item has been unlocked in case
710 * it is in the AIL and anyone is waiting on it. Don't do
711 * this if the caller has asked us not to.
712 */
783a2f65 713 xfs_trans_unlocked_item(ip->i_itemp->ili_item.li_ailp,
579aa9ca 714 (xfs_log_item_t*)(ip->i_itemp));
1da177e4 715 }
0b1b213f 716 trace_xfs_iunlock(ip, lock_flags, _RET_IP_);
1da177e4
LT
717}
718
719/*
720 * give up write locks. the i/o lock cannot be held nested
721 * if it is being demoted.
722 */
723void
579aa9ca
CH
724xfs_ilock_demote(
725 xfs_inode_t *ip,
726 uint lock_flags)
1da177e4
LT
727{
728 ASSERT(lock_flags & (XFS_IOLOCK_EXCL|XFS_ILOCK_EXCL));
729 ASSERT((lock_flags & ~(XFS_IOLOCK_EXCL|XFS_ILOCK_EXCL)) == 0);
730
579aa9ca 731 if (lock_flags & XFS_ILOCK_EXCL)
1da177e4 732 mrdemote(&ip->i_lock);
579aa9ca 733 if (lock_flags & XFS_IOLOCK_EXCL)
1da177e4 734 mrdemote(&ip->i_iolock);
0b1b213f
CH
735
736 trace_xfs_ilock_demote(ip, lock_flags, _RET_IP_);
579aa9ca
CH
737}
738
739#ifdef DEBUG
579aa9ca
CH
740int
741xfs_isilocked(
742 xfs_inode_t *ip,
743 uint lock_flags)
744{
f9369729
CH
745 if (lock_flags & (XFS_ILOCK_EXCL|XFS_ILOCK_SHARED)) {
746 if (!(lock_flags & XFS_ILOCK_SHARED))
747 return !!ip->i_lock.mr_writer;
748 return rwsem_is_locked(&ip->i_lock.mr_lock);
1da177e4 749 }
579aa9ca 750
f9369729
CH
751 if (lock_flags & (XFS_IOLOCK_EXCL|XFS_IOLOCK_SHARED)) {
752 if (!(lock_flags & XFS_IOLOCK_SHARED))
753 return !!ip->i_iolock.mr_writer;
754 return rwsem_is_locked(&ip->i_iolock.mr_lock);
579aa9ca
CH
755 }
756
f9369729
CH
757 ASSERT(0);
758 return 0;
1da177e4 759}
579aa9ca 760#endif