xfs: cleanup xfs_log_space_wake
authorChristoph Hellwig <hch@infradead.org>
Mon, 20 Feb 2012 02:31:23 +0000 (02:31 +0000)
committerBen Myers <bpm@sgi.com>
Thu, 23 Feb 2012 04:17:00 +0000 (22:17 -0600)
Remove the now unused opportunistic parameter, and use the the
xlog_writeq_wake and xlog_reserveq_wake helpers now that we don't have
to care about the opportunistic wakeups.

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>
fs/xfs/xfs_log.c
fs/xfs/xfs_log.h
fs/xfs/xfs_trans_ail.c

index 9161e8a76e777382933185a10b26dc991a3b5f52..2db39df5a57d9340322080f252bf28d2caeb29b9 100644 (file)
@@ -762,18 +762,13 @@ xfs_log_item_init(
 
 /*
  * Wake up processes waiting for log space after we have moved the log tail.
- *
- * If opportunistic is set wake up one waiter even if we do not have enough
- * free space by our strict accounting.
  */
 void
 xfs_log_space_wake(
-       struct xfs_mount        *mp,
-       bool                    opportunistic)
+       struct xfs_mount        *mp)
 {
-       struct xlog_ticket      *tic;
        struct log              *log = mp->m_log;
-       int                     need_bytes, free_bytes;
+       int                     free_bytes;
 
        if (XLOG_FORCED_SHUTDOWN(log))
                return;
@@ -783,16 +778,7 @@ xfs_log_space_wake(
 
                spin_lock(&log->l_grant_write_lock);
                free_bytes = xlog_space_left(log, &log->l_grant_write_head);
-               list_for_each_entry(tic, &log->l_writeq, t_queue) {
-                       ASSERT(tic->t_flags & XLOG_TIC_PERM_RESERV);
-
-                       if (free_bytes < tic->t_unit_res && !opportunistic)
-                               break;
-                       opportunistic = false;
-                       free_bytes -= tic->t_unit_res;
-                       trace_xfs_log_regrant_write_wake_up(log, tic);
-                       wake_up(&tic->t_wait);
-               }
+               xlog_writeq_wake(log, &free_bytes);
                spin_unlock(&log->l_grant_write_lock);
        }
 
@@ -801,18 +787,7 @@ xfs_log_space_wake(
 
                spin_lock(&log->l_grant_reserve_lock);
                free_bytes = xlog_space_left(log, &log->l_grant_reserve_head);
-               list_for_each_entry(tic, &log->l_reserveq, t_queue) {
-                       if (tic->t_flags & XLOG_TIC_PERM_RESERV)
-                               need_bytes = tic->t_unit_res*tic->t_cnt;
-                       else
-                               need_bytes = tic->t_unit_res;
-                       if (free_bytes < need_bytes && !opportunistic)
-                               break;
-                       opportunistic = false;
-                       free_bytes -= need_bytes;
-                       trace_xfs_log_grant_wake_up(log, tic);
-                       wake_up(&tic->t_wait);
-               }
+               xlog_reserveq_wake(log, &free_bytes);
                spin_unlock(&log->l_grant_reserve_lock);
        }
 }
@@ -2748,7 +2723,7 @@ xlog_ungrant_log_space(xlog_t          *log,
 
        trace_xfs_log_ungrant_exit(log, ticket);
 
-       xfs_log_space_wake(log->l_mp, false);
+       xfs_log_space_wake(log->l_mp);
 }
 
 /*
index 58d858074e6b4ae1a81e7c35795ec2c007260de3..fe32c692787723c2c3099c68790bd54622ec6db8 100644 (file)
@@ -161,8 +161,7 @@ int   xfs_log_mount(struct xfs_mount        *mp,
                        int                     num_bblocks);
 int      xfs_log_mount_finish(struct xfs_mount *mp);
 xfs_lsn_t xlog_assign_tail_lsn(struct xfs_mount *mp);
-void     xfs_log_space_wake(struct xfs_mount   *mp,
-                            bool               opportunistic);
+void     xfs_log_space_wake(struct xfs_mount *mp);
 int      xfs_log_notify(struct xfs_mount       *mp,
                         struct xlog_in_core    *iclog,
                         xfs_log_callback_t     *callback_entry);
index 9d5fc089ea2e22e10ca6476b724fbf88814a9ff4..1dead07f092c92afbea3ceeb22e0cf70430fa1fb 100644 (file)
@@ -671,7 +671,7 @@ xfs_trans_ail_update_bulk(
 
        if (mlip_changed && !XFS_FORCED_SHUTDOWN(ailp->xa_mount)) {
                xlog_assign_tail_lsn(ailp->xa_mount);
-               xfs_log_space_wake(ailp->xa_mount, false);
+               xfs_log_space_wake(ailp->xa_mount);
        }
 }
 
@@ -733,7 +733,7 @@ xfs_trans_ail_delete_bulk(
 
        if (mlip_changed && !XFS_FORCED_SHUTDOWN(ailp->xa_mount)) {
                xlog_assign_tail_lsn(ailp->xa_mount);
-               xfs_log_space_wake(ailp->xa_mount, false);
+               xfs_log_space_wake(ailp->xa_mount);
        }
 }