Line data    Source code

       1             : // SPDX-License-Identifier: GPL-2.0
       2             : /*
       3             :  * Copyright (c) 2000-2003 Silicon Graphics, Inc.
       4             :  * All Rights Reserved.
       5             :  */
       6             : #include "xfs.h"
       7             : #include "xfs_fs.h"
       8             : #include "xfs_shared.h"
       9             : #include "xfs_format.h"
      10             : #include "xfs_log_format.h"
      11             : #include "xfs_trans_resv.h"
      12             : #include "xfs_mount.h"
      13             : #include "xfs_inode.h"
      14             : #include "xfs_quota.h"
      15             : #include "xfs_trans.h"
      16             : #include "xfs_buf_item.h"
      17             : #include "xfs_trans_priv.h"
      18             : #include "xfs_qm.h"
      19             : #include "xfs_log.h"
      20             : 
      21             : static inline struct xfs_dq_logitem *DQUOT_ITEM(struct xfs_log_item *lip)
      22             : {
      23             :         return container_of(lip, struct xfs_dq_logitem, qli_item);
      24             : }
      25             : 
      26             : /*
      27             :  * returns the number of iovecs needed to log the given dquot item.
      28             :  */
      29             : STATIC void
      30  4570946817 : xfs_qm_dquot_logitem_size(
      31             :         struct xfs_log_item     *lip,
      32             :         int                     *nvecs,
      33             :         int                     *nbytes)
      34             : {
      35  4570946817 :         *nvecs += 2;
      36  4570946817 :         *nbytes += sizeof(struct xfs_dq_logformat) +
      37             :                    sizeof(struct xfs_disk_dquot);
      38  4570946817 : }
      39             : 
      40             : /*
      41             :  * fills in the vector of log iovecs for the given dquot log item.
      42             :  */
      43             : STATIC void
      44  4570945813 : xfs_qm_dquot_logitem_format(
      45             :         struct xfs_log_item     *lip,
      46             :         struct xfs_log_vec      *lv)
      47             : {
      48  4570945813 :         struct xfs_disk_dquot   ddq;
      49  4570945813 :         struct xfs_dq_logitem   *qlip = DQUOT_ITEM(lip);
      50  4570945813 :         struct xfs_log_iovec    *vecp = NULL;
      51  4570945813 :         struct xfs_dq_logformat *qlf;
      52             : 
      53  4570945813 :         qlf = xlog_prepare_iovec(lv, &vecp, XLOG_REG_TYPE_QFORMAT);
      54  4570955845 :         qlf->qlf_type = XFS_LI_DQUOT;
      55  4570955845 :         qlf->qlf_size = 2;
      56  4570955845 :         qlf->qlf_id = qlip->qli_dquot->q_id;
      57  4570955845 :         qlf->qlf_blkno = qlip->qli_dquot->q_blkno;
      58  4570955845 :         qlf->qlf_len = 1;
      59  4570955845 :         qlf->qlf_boffset = qlip->qli_dquot->q_bufoffset;
      60  4570955845 :         xlog_finish_iovec(lv, vecp, sizeof(struct xfs_dq_logformat));
      61             : 
      62  4570961238 :         xfs_dquot_to_disk(&ddq, qlip->qli_dquot);
      63             : 
      64  4570951343 :         xlog_copy_iovec(lv, &vecp, XLOG_REG_TYPE_DQUOT, &ddq,
      65             :                         sizeof(struct xfs_disk_dquot));
      66  4570961617 : }
      67             : 
      68             : /*
      69             :  * Increment the pin count of the given dquot.
      70             :  */
      71             : STATIC void
      72    55526169 : xfs_qm_dquot_logitem_pin(
      73             :         struct xfs_log_item     *lip)
      74             : {
      75    55526169 :         struct xfs_dquot        *dqp = DQUOT_ITEM(lip)->qli_dquot;
      76             : 
      77    55526169 :         ASSERT(XFS_DQ_IS_LOCKED(dqp));
      78    55526182 :         atomic_inc(&dqp->q_pincount);
      79    55526202 : }
      80             : 
      81             : /*
      82             :  * Decrement the pin count of the given dquot, and wake up
      83             :  * anyone in xfs_dqwait_unpin() if the count goes to 0.  The
      84             :  * dquot must have been previously pinned with a call to
      85             :  * xfs_qm_dquot_logitem_pin().
      86             :  */
      87             : STATIC void
      88    55526550 : xfs_qm_dquot_logitem_unpin(
      89             :         struct xfs_log_item     *lip,
      90             :         int                     remove)
      91             : {
      92    55526550 :         struct xfs_dquot        *dqp = DQUOT_ITEM(lip)->qli_dquot;
      93             : 
      94    55526550 :         ASSERT(atomic_read(&dqp->q_pincount) > 0);
      95   111053100 :         if (atomic_dec_and_test(&dqp->q_pincount))
      96    48689528 :                 wake_up(&dqp->q_pinwait);
      97    55526550 : }
      98             : 
      99             : /*
     100             :  * This is called to wait for the given dquot to be unpinned.
     101             :  * Most of these pin/unpin routines are plagiarized from inode code.
     102             :  */
     103             : void
     104    26497346 : xfs_qm_dqunpin_wait(
     105             :         struct xfs_dquot        *dqp)
     106             : {
     107    26497346 :         ASSERT(XFS_DQ_IS_LOCKED(dqp));
     108    26497347 :         if (atomic_read(&dqp->q_pincount) == 0)
     109             :                 return;
     110             : 
     111             :         /*
     112             :          * Give the log a push so we don't wait here too long.
     113             :          */
     114         983 :         xfs_log_force(dqp->q_mount, 0);
     115        1905 :         wait_event(dqp->q_pinwait, (atomic_read(&dqp->q_pincount) == 0));
     116             : }
     117             : 
     118             : STATIC uint
     119    26797398 : xfs_qm_dquot_logitem_push(
     120             :         struct xfs_log_item     *lip,
     121             :         struct list_head        *buffer_list)
     122             :                 __releases(&lip->li_ailp->ail_lock)
     123             :                 __acquires(&lip->li_ailp->ail_lock)
     124             : {
     125    26797398 :         struct xfs_dquot        *dqp = DQUOT_ITEM(lip)->qli_dquot;
     126    26797398 :         struct xfs_buf          *bp = lip->li_buf;
     127    26797398 :         uint                    rval = XFS_ITEM_SUCCESS;
     128    26797398 :         int                     error;
     129             : 
     130    26797398 :         if (atomic_read(&dqp->q_pincount) > 0)
     131             :                 return XFS_ITEM_PINNED;
     132             : 
     133    26430975 :         if (!xfs_dqlock_nowait(dqp))
     134             :                 return XFS_ITEM_LOCKED;
     135             : 
     136             :         /*
     137             :          * Re-check the pincount now that we stabilized the value by
     138             :          * taking the quota lock.
     139             :          */
     140    26429730 :         if (atomic_read(&dqp->q_pincount) > 0) {
     141           0 :                 rval = XFS_ITEM_PINNED;
     142           0 :                 goto out_unlock;
     143             :         }
     144             : 
     145             :         /*
     146             :          * Someone else is already flushing the dquot.  Nothing we can do
     147             :          * here but wait for the flush to finish and remove the item from
     148             :          * the AIL.
     149             :          */
     150    26429730 :         if (!xfs_dqflock_nowait(dqp)) {
     151       80144 :                 rval = XFS_ITEM_FLUSHING;
     152       80144 :                 goto out_unlock;
     153             :         }
     154             : 
     155    26349586 :         spin_unlock(&lip->li_ailp->ail_lock);
     156             : 
     157    26349586 :         error = xfs_qm_dqflush(dqp, &bp);
     158    26349586 :         if (!error) {
     159    24938965 :                 if (!xfs_buf_delwri_queue(bp, buffer_list))
     160     7746413 :                         rval = XFS_ITEM_FLUSHING;
     161    24938965 :                 xfs_buf_relse(bp);
     162     1410621 :         } else if (error == -EAGAIN)
     163        2753 :                 rval = XFS_ITEM_LOCKED;
     164             : 
     165    26349586 :         spin_lock(&lip->li_ailp->ail_lock);
     166    26429730 : out_unlock:
     167    26429730 :         xfs_dqunlock(dqp);
     168    26429730 :         return rval;
     169             : }
     170             : 
     171             : STATIC void
     172  4573458362 : xfs_qm_dquot_logitem_release(
     173             :         struct xfs_log_item     *lip)
     174             : {
     175  4573458362 :         struct xfs_dquot        *dqp = DQUOT_ITEM(lip)->qli_dquot;
     176             : 
     177  4573458362 :         ASSERT(XFS_DQ_IS_LOCKED(dqp));
     178             : 
     179             :         /*
     180             :          * dquots are never 'held' from getting unlocked at the end of
     181             :          * a transaction.  Their locking and unlocking is hidden inside the
     182             :          * transaction layer, within trans_commit. Hence, no LI_HOLD flag
     183             :          * for the logitem.
     184             :          */
     185  4573460448 :         xfs_dqunlock(dqp);
     186  4573444766 : }
     187             : 
     188             : STATIC void
     189  4570962199 : xfs_qm_dquot_logitem_committing(
     190             :         struct xfs_log_item     *lip,
     191             :         xfs_csn_t               seq)
     192             : {
     193  4570962199 :         return xfs_qm_dquot_logitem_release(lip);
     194             : }
     195             : 
     196             : static const struct xfs_item_ops xfs_dquot_item_ops = {
     197             :         .iop_size       = xfs_qm_dquot_logitem_size,
     198             :         .iop_format     = xfs_qm_dquot_logitem_format,
     199             :         .iop_pin        = xfs_qm_dquot_logitem_pin,
     200             :         .iop_unpin      = xfs_qm_dquot_logitem_unpin,
     201             :         .iop_release    = xfs_qm_dquot_logitem_release,
     202             :         .iop_committing = xfs_qm_dquot_logitem_committing,
     203             :         .iop_push       = xfs_qm_dquot_logitem_push,
     204             : };
     205             : 
     206             : /*
     207             :  * Initialize the dquot log item for a newly allocated dquot.
     208             :  * The dquot isn't locked at this point, but it isn't on any of the lists
     209             :  * either, so we don't care.
     210             :  */
     211             : void
     212    17057293 : xfs_qm_dquot_logitem_init(
     213             :         struct xfs_dquot        *dqp)
     214             : {
     215    17057293 :         struct xfs_dq_logitem   *lp = &dqp->q_logitem;
     216             : 
     217    17057293 :         xfs_log_item_init(dqp->q_mount, &lp->qli_item, XFS_LI_DQUOT,
     218             :                                         &xfs_dquot_item_ops);
     219    17057341 :         lp->qli_dquot = dqp;
     220    17057341 : }