]> bbs.cooldavid.org Git - net-next-2.6.git/blame - fs/xfs/xfs_iget.c
xfs: improve xfs_isilocked
[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,
262 xfs_daddr_t bno,
263 int flags,
0c3dc2b0 264 int lock_flags)
6441e549
DC
265{
266 struct xfs_inode *ip;
267 int error;
268 unsigned long first_index, mask;
269 xfs_agino_t agino = XFS_INO_TO_AGINO(mp, ino);
1da177e4 270
24f211ba
CH
271 ip = xfs_inode_alloc(mp, ino);
272 if (!ip)
273 return ENOMEM;
274
275 error = xfs_iread(mp, tp, ip, bno, flags);
6441e549 276 if (error)
24f211ba 277 goto out_destroy;
1da177e4 278
0b1b213f 279 xfs_itrace_entry(ip);
1da177e4 280
745b1f47 281 if ((ip->i_d.di_mode == 0) && !(flags & XFS_IGET_CREATE)) {
6441e549
DC
282 error = ENOENT;
283 goto out_destroy;
1da177e4
LT
284 }
285
286 /*
bad55843 287 * Preload the radix tree so we can insert safely under the
56e73ec4
DC
288 * write spinlock. Note that we cannot sleep inside the preload
289 * region.
1da177e4 290 */
da353b0d 291 if (radix_tree_preload(GFP_KERNEL)) {
6441e549 292 error = EAGAIN;
ed93ec39
CH
293 goto out_destroy;
294 }
295
296 /*
297 * Because the inode hasn't been added to the radix-tree yet it can't
298 * be found by another thread, so we can do the non-sleeping lock here.
299 */
300 if (lock_flags) {
301 if (!xfs_ilock_nowait(ip, lock_flags))
302 BUG();
da353b0d 303 }
f338f903 304
da353b0d
DC
305 mask = ~(((XFS_INODE_CLUSTER_SIZE(mp) >> mp->m_sb.sb_inodelog)) - 1);
306 first_index = agino & mask;
307 write_lock(&pag->pag_ici_lock);
6441e549
DC
308
309 /* insert the new inode */
da353b0d
DC
310 error = radix_tree_insert(&pag->pag_ici_root, agino, ip);
311 if (unlikely(error)) {
6441e549 312 WARN_ON(error != -EEXIST);
da353b0d 313 XFS_STATS_INC(xs_ig_dup);
6441e549 314 error = EAGAIN;
56e73ec4 315 goto out_preload_end;
1da177e4
LT
316 }
317
6441e549 318 /* These values _must_ be set before releasing the radix tree lock! */
1da177e4 319 ip->i_udquot = ip->i_gdquot = NULL;
7a18c386 320 xfs_iflags_set(ip, XFS_INEW);
1da177e4 321
da353b0d
DC
322 write_unlock(&pag->pag_ici_lock);
323 radix_tree_preload_end();
0b1b213f
CH
324
325 trace_xfs_iget_alloc(ip);
6441e549
DC
326 *ipp = ip;
327 return 0;
328
56e73ec4 329out_preload_end:
6441e549
DC
330 write_unlock(&pag->pag_ici_lock);
331 radix_tree_preload_end();
56e73ec4
DC
332 if (lock_flags)
333 xfs_iunlock(ip, lock_flags);
6441e549 334out_destroy:
b36ec042
CH
335 __destroy_inode(VFS_I(ip));
336 xfs_inode_free(ip);
6441e549
DC
337 return error;
338}
339
340/*
341 * Look up an inode by number in the given file system.
342 * The inode is looked up in the cache held in each AG.
bf904248
DC
343 * If the inode is found in the cache, initialise the vfs inode
344 * if necessary.
6441e549
DC
345 *
346 * If it is not in core, read it in from the file system's device,
bf904248 347 * add it to the cache and initialise the vfs inode.
6441e549
DC
348 *
349 * The inode is locked according to the value of the lock_flags parameter.
350 * This flag parameter indicates how and if the inode's IO lock and inode lock
351 * should be taken.
352 *
353 * mp -- the mount point structure for the current file system. It points
354 * to the inode hash table.
355 * tp -- a pointer to the current transaction if there is one. This is
356 * simply passed through to the xfs_iread() call.
357 * ino -- the number of the inode desired. This is the unique identifier
358 * within the file system for the inode being requested.
359 * lock_flags -- flags indicating how to lock the inode. See the comment
360 * for xfs_ilock() for a list of valid values.
361 * bno -- the block number starting the buffer containing the inode,
362 * if known (as by bulkstat), else 0.
363 */
bf904248
DC
364int
365xfs_iget(
6441e549
DC
366 xfs_mount_t *mp,
367 xfs_trans_t *tp,
368 xfs_ino_t ino,
369 uint flags,
370 uint lock_flags,
371 xfs_inode_t **ipp,
372 xfs_daddr_t bno)
373{
374 xfs_inode_t *ip;
375 int error;
376 xfs_perag_t *pag;
377 xfs_agino_t agino;
378
379 /* the radix tree exists only in inode capable AGs */
380 if (XFS_INO_TO_AGNO(mp, ino) >= mp->m_maxagi)
381 return EINVAL;
382
383 /* get the perag structure and ensure that it's inode capable */
5017e97d 384 pag = xfs_perag_get(mp, XFS_INO_TO_AGNO(mp, ino));
6441e549
DC
385 agino = XFS_INO_TO_AGINO(mp, ino);
386
387again:
388 error = 0;
389 read_lock(&pag->pag_ici_lock);
390 ip = radix_tree_lookup(&pag->pag_ici_root, agino);
391
392 if (ip) {
bf904248 393 error = xfs_iget_cache_hit(pag, ip, flags, lock_flags);
6441e549
DC
394 if (error)
395 goto out_error_or_again;
396 } else {
397 read_unlock(&pag->pag_ici_lock);
398 XFS_STATS_INC(xs_ig_missed);
399
400 error = xfs_iget_cache_miss(mp, pag, tp, ino, &ip, bno,
401 flags, lock_flags);
402 if (error)
403 goto out_error_or_again;
404 }
5017e97d 405 xfs_perag_put(pag);
1da177e4 406
1da177e4
LT
407 *ipp = ip;
408
bf904248
DC
409 ASSERT(ip->i_df.if_ext_max ==
410 XFS_IFORK_DSIZE(ip) / sizeof(xfs_bmbt_rec_t));
1da177e4
LT
411 /*
412 * If we have a real type for an on-disk inode, we can set ops(&unlock)
413 * now. If it's a new inode being created, xfs_ialloc will handle it.
414 */
bf904248 415 if (xfs_iflags_test(ip, XFS_INEW) && ip->i_d.di_mode != 0)
41be8bed 416 xfs_setup_inode(ip);
1da177e4 417 return 0;
6441e549
DC
418
419out_error_or_again:
420 if (error == EAGAIN) {
421 delay(1);
422 goto again;
423 }
5017e97d 424 xfs_perag_put(pag);
6441e549 425 return error;
1da177e4
LT
426}
427
1da177e4
LT
428/*
429 * Decrement reference count of an inode structure and unlock it.
430 *
431 * ip -- the inode being released
432 * lock_flags -- this parameter indicates the inode's locks to be
433 * to be released. See the comment on xfs_iunlock() for a list
434 * of valid values.
435 */
436void
437xfs_iput(xfs_inode_t *ip,
438 uint lock_flags)
439{
cf441eeb 440 xfs_itrace_entry(ip);
1da177e4 441 xfs_iunlock(ip, lock_flags);
10090be2 442 IRELE(ip);
1da177e4
LT
443}
444
445/*
446 * Special iput for brand-new inodes that are still locked
447 */
448void
01651646
DC
449xfs_iput_new(
450 xfs_inode_t *ip,
451 uint lock_flags)
1da177e4 452{
01651646 453 struct inode *inode = VFS_I(ip);
1da177e4 454
cf441eeb 455 xfs_itrace_entry(ip);
1da177e4
LT
456
457 if ((ip->i_d.di_mode == 0)) {
7a18c386 458 ASSERT(!xfs_iflags_test(ip, XFS_IRECLAIMABLE));
10090be2 459 make_bad_inode(inode);
1da177e4
LT
460 }
461 if (inode->i_state & I_NEW)
462 unlock_new_inode(inode);
463 if (lock_flags)
464 xfs_iunlock(ip, lock_flags);
10090be2 465 IRELE(ip);
1da177e4
LT
466}
467
1da177e4 468/*
5cafdeb2
CH
469 * This is called free all the memory associated with an inode.
470 * It must free the inode itself and any buffers allocated for
471 * if_extents/if_data and if_broot. It must also free the lock
472 * associated with the inode.
473 *
474 * Note: because we don't initialise everything on reallocation out
475 * of the zone, we must ensure we nullify everything correctly before
476 * freeing the structure.
1da177e4
LT
477 */
478void
5cafdeb2
CH
479xfs_ireclaim(
480 struct xfs_inode *ip)
1da177e4 481{
5cafdeb2
CH
482 struct xfs_mount *mp = ip->i_mount;
483 struct xfs_perag *pag;
b44b1126 484 xfs_agino_t agino = XFS_INO_TO_AGINO(mp, ip->i_ino);
1da177e4 485
5cafdeb2 486 XFS_STATS_INC(xs_ig_reclaims);
1da177e4
LT
487
488 /*
b44b1126
CH
489 * Remove the inode from the per-AG radix tree.
490 *
491 * Because radix_tree_delete won't complain even if the item was never
492 * added to the tree assert that it's been there before to catch
493 * problems with the inode life time early on.
1da177e4 494 */
5017e97d 495 pag = xfs_perag_get(mp, XFS_INO_TO_AGNO(mp, ip->i_ino));
5cafdeb2 496 write_lock(&pag->pag_ici_lock);
b44b1126
CH
497 if (!radix_tree_delete(&pag->pag_ici_root, agino))
498 ASSERT(0);
5cafdeb2 499 write_unlock(&pag->pag_ici_lock);
5017e97d 500 xfs_perag_put(pag);
1da177e4
LT
501
502 /*
5cafdeb2
CH
503 * Here we do an (almost) spurious inode lock in order to coordinate
504 * with inode cache radix tree lookups. This is because the lookup
505 * can reference the inodes in the cache without taking references.
506 *
507 * We make that OK here by ensuring that we wait until the inode is
508 * unlocked after the lookup before we go ahead and free it. We get
509 * both the ilock and the iolock because the code may need to drop the
510 * ilock one but will still hold the iolock.
1da177e4 511 */
5cafdeb2 512 xfs_ilock(ip, XFS_ILOCK_EXCL | XFS_IOLOCK_EXCL);
7d095257 513 xfs_qm_dqdetach(ip);
439b8434 514 xfs_iunlock(ip, XFS_ILOCK_EXCL | XFS_IOLOCK_EXCL);
1da177e4 515
b36ec042 516 xfs_inode_free(ip);
1da177e4
LT
517}
518
519/*
520 * This is a wrapper routine around the xfs_ilock() routine
521 * used to centralize some grungy code. It is used in places
522 * that wish to lock the inode solely for reading the extents.
523 * The reason these places can't just call xfs_ilock(SHARED)
524 * is that the inode lock also guards to bringing in of the
525 * extents from disk for a file in b-tree format. If the inode
526 * is in b-tree format, then we need to lock the inode exclusively
527 * until the extents are read in. Locking it exclusively all
528 * the time would limit our parallelism unnecessarily, though.
529 * What we do instead is check to see if the extents have been
530 * read in yet, and only lock the inode exclusively if they
531 * have not.
532 *
533 * The function returns a value which should be given to the
534 * corresponding xfs_iunlock_map_shared(). This value is
535 * the mode in which the lock was actually taken.
536 */
537uint
538xfs_ilock_map_shared(
539 xfs_inode_t *ip)
540{
541 uint lock_mode;
542
543 if ((ip->i_d.di_format == XFS_DINODE_FMT_BTREE) &&
544 ((ip->i_df.if_flags & XFS_IFEXTENTS) == 0)) {
545 lock_mode = XFS_ILOCK_EXCL;
546 } else {
547 lock_mode = XFS_ILOCK_SHARED;
548 }
549
550 xfs_ilock(ip, lock_mode);
551
552 return lock_mode;
553}
554
555/*
556 * This is simply the unlock routine to go with xfs_ilock_map_shared().
557 * All it does is call xfs_iunlock() with the given lock_mode.
558 */
559void
560xfs_iunlock_map_shared(
561 xfs_inode_t *ip,
562 unsigned int lock_mode)
563{
564 xfs_iunlock(ip, lock_mode);
565}
566
567/*
568 * The xfs inode contains 2 locks: a multi-reader lock called the
569 * i_iolock and a multi-reader lock called the i_lock. This routine
570 * allows either or both of the locks to be obtained.
571 *
572 * The 2 locks should always be ordered so that the IO lock is
573 * obtained first in order to prevent deadlock.
574 *
575 * ip -- the inode being locked
576 * lock_flags -- this parameter indicates the inode's locks
577 * to be locked. It can be:
578 * XFS_IOLOCK_SHARED,
579 * XFS_IOLOCK_EXCL,
580 * XFS_ILOCK_SHARED,
581 * XFS_ILOCK_EXCL,
582 * XFS_IOLOCK_SHARED | XFS_ILOCK_SHARED,
583 * XFS_IOLOCK_SHARED | XFS_ILOCK_EXCL,
584 * XFS_IOLOCK_EXCL | XFS_ILOCK_SHARED,
585 * XFS_IOLOCK_EXCL | XFS_ILOCK_EXCL
586 */
587void
579aa9ca
CH
588xfs_ilock(
589 xfs_inode_t *ip,
590 uint lock_flags)
1da177e4
LT
591{
592 /*
593 * You can't set both SHARED and EXCL for the same lock,
594 * and only XFS_IOLOCK_SHARED, XFS_IOLOCK_EXCL, XFS_ILOCK_SHARED,
595 * and XFS_ILOCK_EXCL are valid values to set in lock_flags.
596 */
597 ASSERT((lock_flags & (XFS_IOLOCK_SHARED | XFS_IOLOCK_EXCL)) !=
598 (XFS_IOLOCK_SHARED | XFS_IOLOCK_EXCL));
599 ASSERT((lock_flags & (XFS_ILOCK_SHARED | XFS_ILOCK_EXCL)) !=
600 (XFS_ILOCK_SHARED | XFS_ILOCK_EXCL));
f7c66ce3 601 ASSERT((lock_flags & ~(XFS_LOCK_MASK | XFS_LOCK_DEP_MASK)) == 0);
1da177e4 602
579aa9ca 603 if (lock_flags & XFS_IOLOCK_EXCL)
f7c66ce3 604 mrupdate_nested(&ip->i_iolock, XFS_IOLOCK_DEP(lock_flags));
579aa9ca 605 else if (lock_flags & XFS_IOLOCK_SHARED)
f7c66ce3 606 mraccess_nested(&ip->i_iolock, XFS_IOLOCK_DEP(lock_flags));
579aa9ca
CH
607
608 if (lock_flags & XFS_ILOCK_EXCL)
f7c66ce3 609 mrupdate_nested(&ip->i_lock, XFS_ILOCK_DEP(lock_flags));
579aa9ca 610 else if (lock_flags & XFS_ILOCK_SHARED)
f7c66ce3 611 mraccess_nested(&ip->i_lock, XFS_ILOCK_DEP(lock_flags));
579aa9ca 612
0b1b213f 613 trace_xfs_ilock(ip, lock_flags, _RET_IP_);
1da177e4
LT
614}
615
616/*
617 * This is just like xfs_ilock(), except that the caller
618 * is guaranteed not to sleep. It returns 1 if it gets
619 * the requested locks and 0 otherwise. If the IO lock is
620 * obtained but the inode lock cannot be, then the IO lock
621 * is dropped before returning.
622 *
623 * ip -- the inode being locked
624 * lock_flags -- this parameter indicates the inode's locks to be
625 * to be locked. See the comment for xfs_ilock() for a list
626 * of valid values.
1da177e4
LT
627 */
628int
579aa9ca
CH
629xfs_ilock_nowait(
630 xfs_inode_t *ip,
631 uint lock_flags)
1da177e4 632{
1da177e4
LT
633 /*
634 * You can't set both SHARED and EXCL for the same lock,
635 * and only XFS_IOLOCK_SHARED, XFS_IOLOCK_EXCL, XFS_ILOCK_SHARED,
636 * and XFS_ILOCK_EXCL are valid values to set in lock_flags.
637 */
638 ASSERT((lock_flags & (XFS_IOLOCK_SHARED | XFS_IOLOCK_EXCL)) !=
639 (XFS_IOLOCK_SHARED | XFS_IOLOCK_EXCL));
640 ASSERT((lock_flags & (XFS_ILOCK_SHARED | XFS_ILOCK_EXCL)) !=
641 (XFS_ILOCK_SHARED | XFS_ILOCK_EXCL));
f7c66ce3 642 ASSERT((lock_flags & ~(XFS_LOCK_MASK | XFS_LOCK_DEP_MASK)) == 0);
1da177e4 643
1da177e4 644 if (lock_flags & XFS_IOLOCK_EXCL) {
579aa9ca
CH
645 if (!mrtryupdate(&ip->i_iolock))
646 goto out;
1da177e4 647 } else if (lock_flags & XFS_IOLOCK_SHARED) {
579aa9ca
CH
648 if (!mrtryaccess(&ip->i_iolock))
649 goto out;
1da177e4
LT
650 }
651 if (lock_flags & XFS_ILOCK_EXCL) {
579aa9ca
CH
652 if (!mrtryupdate(&ip->i_lock))
653 goto out_undo_iolock;
1da177e4 654 } else if (lock_flags & XFS_ILOCK_SHARED) {
579aa9ca
CH
655 if (!mrtryaccess(&ip->i_lock))
656 goto out_undo_iolock;
1da177e4 657 }
0b1b213f 658 trace_xfs_ilock_nowait(ip, lock_flags, _RET_IP_);
1da177e4 659 return 1;
579aa9ca
CH
660
661 out_undo_iolock:
662 if (lock_flags & XFS_IOLOCK_EXCL)
663 mrunlock_excl(&ip->i_iolock);
664 else if (lock_flags & XFS_IOLOCK_SHARED)
665 mrunlock_shared(&ip->i_iolock);
666 out:
667 return 0;
1da177e4
LT
668}
669
670/*
671 * xfs_iunlock() is used to drop the inode locks acquired with
672 * xfs_ilock() and xfs_ilock_nowait(). The caller must pass
673 * in the flags given to xfs_ilock() or xfs_ilock_nowait() so
674 * that we know which locks to drop.
675 *
676 * ip -- the inode being unlocked
677 * lock_flags -- this parameter indicates the inode's locks to be
678 * to be unlocked. See the comment for xfs_ilock() for a list
679 * of valid values for this parameter.
680 *
681 */
682void
579aa9ca
CH
683xfs_iunlock(
684 xfs_inode_t *ip,
685 uint lock_flags)
1da177e4
LT
686{
687 /*
688 * You can't set both SHARED and EXCL for the same lock,
689 * and only XFS_IOLOCK_SHARED, XFS_IOLOCK_EXCL, XFS_ILOCK_SHARED,
690 * and XFS_ILOCK_EXCL are valid values to set in lock_flags.
691 */
692 ASSERT((lock_flags & (XFS_IOLOCK_SHARED | XFS_IOLOCK_EXCL)) !=
693 (XFS_IOLOCK_SHARED | XFS_IOLOCK_EXCL));
694 ASSERT((lock_flags & (XFS_ILOCK_SHARED | XFS_ILOCK_EXCL)) !=
695 (XFS_ILOCK_SHARED | XFS_ILOCK_EXCL));
f7c66ce3
LM
696 ASSERT((lock_flags & ~(XFS_LOCK_MASK | XFS_IUNLOCK_NONOTIFY |
697 XFS_LOCK_DEP_MASK)) == 0);
1da177e4
LT
698 ASSERT(lock_flags != 0);
699
579aa9ca
CH
700 if (lock_flags & XFS_IOLOCK_EXCL)
701 mrunlock_excl(&ip->i_iolock);
702 else if (lock_flags & XFS_IOLOCK_SHARED)
703 mrunlock_shared(&ip->i_iolock);
1da177e4 704
579aa9ca
CH
705 if (lock_flags & XFS_ILOCK_EXCL)
706 mrunlock_excl(&ip->i_lock);
707 else if (lock_flags & XFS_ILOCK_SHARED)
708 mrunlock_shared(&ip->i_lock);
1da177e4 709
579aa9ca
CH
710 if ((lock_flags & (XFS_ILOCK_SHARED | XFS_ILOCK_EXCL)) &&
711 !(lock_flags & XFS_IUNLOCK_NONOTIFY) && ip->i_itemp) {
1da177e4
LT
712 /*
713 * Let the AIL know that this item has been unlocked in case
714 * it is in the AIL and anyone is waiting on it. Don't do
715 * this if the caller has asked us not to.
716 */
783a2f65 717 xfs_trans_unlocked_item(ip->i_itemp->ili_item.li_ailp,
579aa9ca 718 (xfs_log_item_t*)(ip->i_itemp));
1da177e4 719 }
0b1b213f 720 trace_xfs_iunlock(ip, lock_flags, _RET_IP_);
1da177e4
LT
721}
722
723/*
724 * give up write locks. the i/o lock cannot be held nested
725 * if it is being demoted.
726 */
727void
579aa9ca
CH
728xfs_ilock_demote(
729 xfs_inode_t *ip,
730 uint lock_flags)
1da177e4
LT
731{
732 ASSERT(lock_flags & (XFS_IOLOCK_EXCL|XFS_ILOCK_EXCL));
733 ASSERT((lock_flags & ~(XFS_IOLOCK_EXCL|XFS_ILOCK_EXCL)) == 0);
734
579aa9ca 735 if (lock_flags & XFS_ILOCK_EXCL)
1da177e4 736 mrdemote(&ip->i_lock);
579aa9ca 737 if (lock_flags & XFS_IOLOCK_EXCL)
1da177e4 738 mrdemote(&ip->i_iolock);
0b1b213f
CH
739
740 trace_xfs_ilock_demote(ip, lock_flags, _RET_IP_);
579aa9ca
CH
741}
742
743#ifdef DEBUG
579aa9ca
CH
744int
745xfs_isilocked(
746 xfs_inode_t *ip,
747 uint lock_flags)
748{
f9369729
CH
749 if (lock_flags & (XFS_ILOCK_EXCL|XFS_ILOCK_SHARED)) {
750 if (!(lock_flags & XFS_ILOCK_SHARED))
751 return !!ip->i_lock.mr_writer;
752 return rwsem_is_locked(&ip->i_lock.mr_lock);
1da177e4 753 }
579aa9ca 754
f9369729
CH
755 if (lock_flags & (XFS_IOLOCK_EXCL|XFS_IOLOCK_SHARED)) {
756 if (!(lock_flags & XFS_IOLOCK_SHARED))
757 return !!ip->i_iolock.mr_writer;
758 return rwsem_is_locked(&ip->i_iolock.mr_lock);
579aa9ca
CH
759 }
760
f9369729
CH
761 ASSERT(0);
762 return 0;
1da177e4 763}
579aa9ca 764#endif