Commit 4a857b0e authored by Christoph Hellwig's avatar Christoph Hellwig

[XFS] Remove the lockable/not lockable buffer distinction.

All metadata buffers are lockable these days.

SGI Modid: xfs-linux:xfs-kern:166042a
parent cc537af9
...@@ -388,11 +388,10 @@ void ...@@ -388,11 +388,10 @@ void
pagebuf_free( pagebuf_free(
page_buf_t *pb) page_buf_t *pb)
{ {
PB_TRACE(pb, "free", 0);
if (pb->pb_flags & _PBF_LOCKABLE) {
pb_hash_t *hash = pb_hash(pb); pb_hash_t *hash = pb_hash(pb);
PB_TRACE(pb, "free", 0);
spin_lock(&hash->pb_hash_lock); spin_lock(&hash->pb_hash_lock);
/* /*
* Someone grabbed a reference while we weren't looking, * Someone grabbed a reference while we weren't looking,
...@@ -404,7 +403,6 @@ pagebuf_free( ...@@ -404,7 +403,6 @@ pagebuf_free(
} else if (!list_empty(&pb->pb_hash_list)) } else if (!list_empty(&pb->pb_hash_list))
list_del_init(&pb->pb_hash_list); list_del_init(&pb->pb_hash_list);
spin_unlock(&hash->pb_hash_lock); spin_unlock(&hash->pb_hash_lock);
}
/* release any virtual mapping */ ; /* release any virtual mapping */ ;
if (pb->pb_flags & _PBF_ADDR_ALLOCATED) { if (pb->pb_flags & _PBF_ADDR_ALLOCATED) {
...@@ -668,7 +666,7 @@ _pagebuf_find( /* find buffer for block */ ...@@ -668,7 +666,7 @@ _pagebuf_find( /* find buffer for block */
/* No match found */ /* No match found */
if (new_pb) { if (new_pb) {
_pagebuf_initialize(new_pb, target, range_base, _pagebuf_initialize(new_pb, target, range_base,
range_length, flags | _PBF_LOCKABLE); range_length, flags);
new_pb->pb_hash_index = hval; new_pb->pb_hash_index = hval;
list_add(&new_pb->pb_hash_list, &h->pb_hash); list_add(&new_pb->pb_hash_list, &h->pb_hash);
} else { } else {
...@@ -712,7 +710,6 @@ _pagebuf_find( /* find buffer for block */ ...@@ -712,7 +710,6 @@ _pagebuf_find( /* find buffer for block */
if (pb->pb_flags & PBF_STALE) if (pb->pb_flags & PBF_STALE)
pb->pb_flags &= PBF_MAPPABLE | \ pb->pb_flags &= PBF_MAPPABLE | \
PBF_MAPPED | \ PBF_MAPPED | \
_PBF_LOCKABLE | \
_PBF_ALL_PAGES_MAPPED | \ _PBF_ALL_PAGES_MAPPED | \
_PBF_ADDR_ALLOCATED | \ _PBF_ADDR_ALLOCATED | \
_PBF_MEM_ALLOCATED | \ _PBF_MEM_ALLOCATED | \
...@@ -870,9 +867,9 @@ pagebuf_get_empty( ...@@ -870,9 +867,9 @@ pagebuf_get_empty(
{ {
page_buf_t *pb; page_buf_t *pb;
pb = pagebuf_allocate(_PBF_LOCKABLE); pb = pagebuf_allocate(0);
if (pb) if (pb)
_pagebuf_initialize(pb, target, 0, len, _PBF_LOCKABLE); _pagebuf_initialize(pb, target, 0, len, 0);
return pb; return pb;
} }
...@@ -946,7 +943,7 @@ pagebuf_get_no_daddr( ...@@ -946,7 +943,7 @@ pagebuf_get_no_daddr(
{ {
int rval; int rval;
void *rmem = NULL; void *rmem = NULL;
page_buf_flags_t flags = _PBF_LOCKABLE | PBF_FORCEIO; page_buf_flags_t flags = PBF_FORCEIO;
page_buf_t *pb; page_buf_t *pb;
size_t tlen = 0; size_t tlen = 0;
...@@ -1066,7 +1063,6 @@ pagebuf_cond_lock( /* lock buffer, if not locked */ ...@@ -1066,7 +1063,6 @@ pagebuf_cond_lock( /* lock buffer, if not locked */
{ {
int locked; int locked;
ASSERT(pb->pb_flags & _PBF_LOCKABLE);
locked = down_trylock(&pb->pb_sema) == 0; locked = down_trylock(&pb->pb_sema) == 0;
if (locked) { if (locked) {
PB_SET_OWNER(pb); PB_SET_OWNER(pb);
...@@ -1084,7 +1080,6 @@ int ...@@ -1084,7 +1080,6 @@ int
pagebuf_lock_value( pagebuf_lock_value(
page_buf_t *pb) page_buf_t *pb)
{ {
ASSERT(pb->pb_flags & _PBF_LOCKABLE);
return(atomic_read(&pb->pb_sema.count)); return(atomic_read(&pb->pb_sema.count));
} }
...@@ -1100,8 +1095,6 @@ int ...@@ -1100,8 +1095,6 @@ int
pagebuf_lock( pagebuf_lock(
page_buf_t *pb) page_buf_t *pb)
{ {
ASSERT(pb->pb_flags & _PBF_LOCKABLE);
PB_TRACE(pb, "lock", 0); PB_TRACE(pb, "lock", 0);
if (atomic_read(&pb->pb_io_remaining)) if (atomic_read(&pb->pb_io_remaining))
blk_run_queues(); blk_run_queues();
...@@ -1122,7 +1115,6 @@ void ...@@ -1122,7 +1115,6 @@ void
pagebuf_unlock( /* unlock buffer */ pagebuf_unlock( /* unlock buffer */
page_buf_t *pb) /* buffer to unlock */ page_buf_t *pb) /* buffer to unlock */
{ {
ASSERT(pb->pb_flags & _PBF_LOCKABLE);
PB_CLEAR_OWNER(pb); PB_CLEAR_OWNER(pb);
up(&pb->pb_sema); up(&pb->pb_sema);
PB_TRACE(pb, "unlock", 0); PB_TRACE(pb, "unlock", 0);
...@@ -1231,7 +1223,7 @@ pagebuf_iodone_work( ...@@ -1231,7 +1223,7 @@ pagebuf_iodone_work(
} }
if (pb->pb_flags & PBF_ASYNC) { if (pb->pb_flags & PBF_ASYNC) {
if ((pb->pb_flags & _PBF_LOCKABLE) && !pb->pb_relse) if (!pb->pb_relse)
pagebuf_unlock(pb); pagebuf_unlock(pb);
pagebuf_rele(pb); pagebuf_rele(pb);
} }
...@@ -1344,7 +1336,7 @@ _pagebuf_iolocked( ...@@ -1344,7 +1336,7 @@ _pagebuf_iolocked(
ASSERT(pb->pb_flags & (PBF_READ|PBF_WRITE)); ASSERT(pb->pb_flags & (PBF_READ|PBF_WRITE));
if (pb->pb_flags & PBF_READ) if (pb->pb_flags & PBF_READ)
return pb->pb_locked; return pb->pb_locked;
return ((pb->pb_flags & _PBF_LOCKABLE) == 0); return 0;
} }
STATIC __inline__ void STATIC __inline__ void
...@@ -1670,9 +1662,8 @@ pagebuf_delwri_queue( ...@@ -1670,9 +1662,8 @@ pagebuf_delwri_queue(
pb->pb_flushtime = jiffies + pb_params.age_buffer.val; pb->pb_flushtime = jiffies + pb_params.age_buffer.val;
spin_unlock(&pbd_delwrite_lock); spin_unlock(&pbd_delwrite_lock);
if (unlock && (pb->pb_flags & _PBF_LOCKABLE)) { if (unlock)
pagebuf_unlock(pb); pagebuf_unlock(pb);
}
} }
void void
...@@ -1740,10 +1731,8 @@ pagebuf_daemon( ...@@ -1740,10 +1731,8 @@ pagebuf_daemon(
PB_TRACE(pb, "walkq1", (long)pagebuf_ispin(pb)); PB_TRACE(pb, "walkq1", (long)pagebuf_ispin(pb));
if ((pb->pb_flags & PBF_DELWRI) && !pagebuf_ispin(pb) && if ((pb->pb_flags & PBF_DELWRI) &&
(((pb->pb_flags & _PBF_LOCKABLE) == 0) || !pagebuf_ispin(pb) && !pagebuf_cond_lock(pb)) {
!pagebuf_cond_lock(pb))) {
if (!force_flush && if (!force_flush &&
time_before(jiffies, pb->pb_flushtime)) { time_before(jiffies, pb->pb_flushtime)) {
pagebuf_unlock(pb); pagebuf_unlock(pb);
......
...@@ -88,7 +88,6 @@ typedef enum page_buf_flags_e { /* pb_flags values */ ...@@ -88,7 +88,6 @@ typedef enum page_buf_flags_e { /* pb_flags values */
PBF_DONT_BLOCK = (1 << 15), /* do not block in current thread */ PBF_DONT_BLOCK = (1 << 15), /* do not block in current thread */
/* flags used only internally */ /* flags used only internally */
_PBF_LOCKABLE = (1 << 16), /* page_buf_t may be locked */
_PBF_ALL_PAGES_MAPPED = (1 << 18), /* all pages in range mapped */ _PBF_ALL_PAGES_MAPPED = (1 << 18), /* all pages in range mapped */
_PBF_ADDR_ALLOCATED = (1 << 19), /* pb_addr space was allocated */ _PBF_ADDR_ALLOCATED = (1 << 19), /* pb_addr space was allocated */
_PBF_MEM_ALLOCATED = (1 << 20), /* underlying pages are allocated */ _PBF_MEM_ALLOCATED = (1 << 20), /* underlying pages are allocated */
...@@ -197,7 +196,7 @@ extern page_buf_t *pagebuf_lookup( ...@@ -197,7 +196,7 @@ extern page_buf_t *pagebuf_lookup(
loff_t, /* starting offset of range */ loff_t, /* starting offset of range */
size_t, /* length of range */ size_t, /* length of range */
page_buf_flags_t); /* PBF_READ, PBF_WRITE, */ page_buf_flags_t); /* PBF_READ, PBF_WRITE, */
/* PBF_FORCEIO, _PBF_LOCKABLE */ /* PBF_FORCEIO, */
extern page_buf_t *pagebuf_get_empty( /* allocate pagebuf struct with */ extern page_buf_t *pagebuf_get_empty( /* allocate pagebuf struct with */
/* no memory or disk address */ /* no memory or disk address */
...@@ -531,7 +530,7 @@ static inline int xfs_bawrite(void *mp, page_buf_t *bp) ...@@ -531,7 +530,7 @@ static inline int xfs_bawrite(void *mp, page_buf_t *bp)
static inline void xfs_buf_relse(page_buf_t *bp) static inline void xfs_buf_relse(page_buf_t *bp)
{ {
if ((bp->pb_flags & _PBF_LOCKABLE) && !bp->pb_relse) if (!bp->pb_relse)
pagebuf_unlock(bp); pagebuf_unlock(bp);
pagebuf_rele(bp); pagebuf_rele(bp);
} }
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment