summaryrefslogtreecommitdiffstats
path: root/fs/xfs/xfs_log.c
diff options
context:
space:
mode:
authorChristoph Hellwig2012-02-20 03:31:28 +0100
committerBen Myers2012-02-23 05:29:39 +0100
commit23ee3df349b8b8fd153bd02fccf08b31aec5bce3 (patch)
tree6ed2f0a4ab33da6b315a9c484e130849ebca8875 /fs/xfs/xfs_log.c
parentxfs: add xlog_grant_head_wake_all (diff)
downloadkernel-qcow2-linux-23ee3df349b8b8fd153bd02fccf08b31aec5bce3.tar.gz
kernel-qcow2-linux-23ee3df349b8b8fd153bd02fccf08b31aec5bce3.tar.xz
kernel-qcow2-linux-23ee3df349b8b8fd153bd02fccf08b31aec5bce3.zip
xfs: share code for grant head waiting
Reviewed-by: Mark Tinguely <tinguely@sgi.com> Signed-off-by: Christoph Hellwig <hch@lst.de> Reviewed-by: Dave Chinner <dchinner@redhat.com> Signed-off-by: Ben Myers <bpm@sgi.com>
Diffstat (limited to 'fs/xfs/xfs_log.c')
-rw-r--r--fs/xfs/xfs_log.c63
1 files changed, 18 insertions, 45 deletions
diff --git a/fs/xfs/xfs_log.c b/fs/xfs/xfs_log.c
index a0d1376b3d48..c2d13827582b 100644
--- a/fs/xfs/xfs_log.c
+++ b/fs/xfs/xfs_log.c
@@ -221,12 +221,13 @@ xlog_writeq_wake(
}
STATIC int
-xlog_reserveq_wait(
+xlog_grant_head_wait(
struct log *log,
+ struct xlog_grant_head *head,
struct xlog_ticket *tic,
int need_bytes)
{
- list_add_tail(&tic->t_queue, &log->l_reserve_head.waiters);
+ list_add_tail(&tic->t_queue, &head->waiters);
do {
if (XLOG_FORCED_SHUTDOWN(log))
@@ -234,7 +235,7 @@ xlog_reserveq_wait(
xlog_grant_push_ail(log, need_bytes);
__set_current_state(TASK_UNINTERRUPTIBLE);
- spin_unlock(&log->l_reserve_head.lock);
+ spin_unlock(&head->lock);
XFS_STATS_INC(xs_sleep_logspace);
@@ -242,44 +243,10 @@ xlog_reserveq_wait(
schedule();
trace_xfs_log_grant_wake(log, tic);
- spin_lock(&log->l_reserve_head.lock);
+ spin_lock(&head->lock);
if (XLOG_FORCED_SHUTDOWN(log))
goto shutdown;
- } while (xlog_space_left(log, &log->l_reserve_head.grant) < need_bytes);
-
- list_del_init(&tic->t_queue);
- return 0;
-shutdown:
- list_del_init(&tic->t_queue);
- return XFS_ERROR(EIO);
-}
-
-STATIC int
-xlog_writeq_wait(
- struct log *log,
- struct xlog_ticket *tic,
- int need_bytes)
-{
- list_add_tail(&tic->t_queue, &log->l_write_head.waiters);
-
- do {
- if (XLOG_FORCED_SHUTDOWN(log))
- goto shutdown;
- xlog_grant_push_ail(log, need_bytes);
-
- __set_current_state(TASK_UNINTERRUPTIBLE);
- spin_unlock(&log->l_write_head.lock);
-
- XFS_STATS_INC(xs_sleep_logspace);
-
- trace_xfs_log_regrant_write_sleep(log, tic);
- schedule();
- trace_xfs_log_regrant_write_wake(log, tic);
-
- spin_lock(&log->l_write_head.lock);
- if (XLOG_FORCED_SHUTDOWN(log))
- goto shutdown;
- } while (xlog_space_left(log, &log->l_write_head.grant) < need_bytes);
+ } while (xlog_space_left(log, &head->grant) < need_bytes);
list_del_init(&tic->t_queue);
return 0;
@@ -2596,12 +2563,15 @@ xlog_grant_log_space(
if (!list_empty_careful(&log->l_reserve_head.waiters)) {
spin_lock(&log->l_reserve_head.lock);
if (!xlog_reserveq_wake(log, &free_bytes) ||
- free_bytes < need_bytes)
- error = xlog_reserveq_wait(log, tic, need_bytes);
+ free_bytes < need_bytes) {
+ error = xlog_grant_head_wait(log, &log->l_reserve_head,
+ tic, need_bytes);
+ }
spin_unlock(&log->l_reserve_head.lock);
} else if (free_bytes < need_bytes) {
spin_lock(&log->l_reserve_head.lock);
- error = xlog_reserveq_wait(log, tic, need_bytes);
+ error = xlog_grant_head_wait(log, &log->l_reserve_head, tic,
+ need_bytes);
spin_unlock(&log->l_reserve_head.lock);
}
if (error)
@@ -2649,12 +2619,15 @@ xlog_regrant_write_log_space(
if (!list_empty_careful(&log->l_write_head.waiters)) {
spin_lock(&log->l_write_head.lock);
if (!xlog_writeq_wake(log, &free_bytes) ||
- free_bytes < need_bytes)
- error = xlog_writeq_wait(log, tic, need_bytes);
+ free_bytes < need_bytes) {
+ error = xlog_grant_head_wait(log, &log->l_write_head,
+ tic, need_bytes);
+ }
spin_unlock(&log->l_write_head.lock);
} else if (free_bytes < need_bytes) {
spin_lock(&log->l_write_head.lock);
- error = xlog_writeq_wait(log, tic, need_bytes);
+ error = xlog_grant_head_wait(log, &log->l_write_head, tic,
+ need_bytes);
spin_unlock(&log->l_write_head.lock);
}