Commit | Line | Data |
---|---|---|
0b61f8a4 | 1 | // SPDX-License-Identifier: GPL-2.0 |
1da177e4 | 2 | /* |
4ce3121f NS |
3 | * Copyright (c) 2000-2003 Silicon Graphics, Inc. |
4 | * All Rights Reserved. | |
1da177e4 | 5 | */ |
1da177e4 LT |
6 | #include "xfs.h" |
7 | #include "xfs_fs.h" | |
5467b34b | 8 | #include "xfs_shared.h" |
6ca1c906 | 9 | #include "xfs_format.h" |
239880ef DC |
10 | #include "xfs_log_format.h" |
11 | #include "xfs_trans_resv.h" | |
1da177e4 | 12 | #include "xfs_mount.h" |
1da177e4 | 13 | #include "xfs_inode.h" |
a4fbe6ab | 14 | #include "xfs_quota.h" |
239880ef | 15 | #include "xfs_trans.h" |
1da177e4 LT |
16 | #include "xfs_buf_item.h" |
17 | #include "xfs_trans_priv.h" | |
1da177e4 | 18 | #include "xfs_qm.h" |
239880ef | 19 | #include "xfs_log.h" |
1da177e4 | 20 | |
7bfa31d8 CH |
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 | ||
1da177e4 LT |
26 | /* |
27 | * returns the number of iovecs needed to log the given dquot item. | |
28 | */ | |
166d1368 | 29 | STATIC void |
1da177e4 | 30 | xfs_qm_dquot_logitem_size( |
166d1368 DC |
31 | struct xfs_log_item *lip, |
32 | int *nvecs, | |
33 | int *nbytes) | |
1da177e4 | 34 | { |
166d1368 DC |
35 | *nvecs += 2; |
36 | *nbytes += sizeof(struct xfs_dq_logformat) + | |
37 | sizeof(struct xfs_disk_dquot); | |
1da177e4 LT |
38 | } |
39 | ||
40 | /* | |
41 | * fills in the vector of log iovecs for the given dquot log item. | |
42 | */ | |
43 | STATIC void | |
44 | xfs_qm_dquot_logitem_format( | |
7bfa31d8 | 45 | struct xfs_log_item *lip, |
bde7cff6 | 46 | struct xfs_log_vec *lv) |
1da177e4 | 47 | { |
0b0fa1d1 | 48 | struct xfs_disk_dquot ddq; |
7bfa31d8 | 49 | struct xfs_dq_logitem *qlip = DQUOT_ITEM(lip); |
bde7cff6 | 50 | struct xfs_log_iovec *vecp = NULL; |
ce8e9629 | 51 | struct xfs_dq_logformat *qlf; |
1da177e4 | 52 | |
ce8e9629 CH |
53 | qlf = xlog_prepare_iovec(lv, &vecp, XLOG_REG_TYPE_QFORMAT); |
54 | qlf->qlf_type = XFS_LI_DQUOT; | |
55 | qlf->qlf_size = 2; | |
c51df733 | 56 | qlf->qlf_id = qlip->qli_dquot->q_id; |
ce8e9629 CH |
57 | qlf->qlf_blkno = qlip->qli_dquot->q_blkno; |
58 | qlf->qlf_len = 1; | |
59 | qlf->qlf_boffset = qlip->qli_dquot->q_bufoffset; | |
60 | xlog_finish_iovec(lv, vecp, sizeof(struct xfs_dq_logformat)); | |
bde7cff6 | 61 | |
0b0fa1d1 DW |
62 | xfs_dquot_to_disk(&ddq, qlip->qli_dquot); |
63 | ||
64 | xlog_copy_iovec(lv, &vecp, XLOG_REG_TYPE_DQUOT, &ddq, | |
1234351c | 65 | sizeof(struct xfs_disk_dquot)); |
1da177e4 LT |
66 | } |
67 | ||
68 | /* | |
69 | * Increment the pin count of the given dquot. | |
1da177e4 LT |
70 | */ |
71 | STATIC void | |
72 | xfs_qm_dquot_logitem_pin( | |
7bfa31d8 | 73 | struct xfs_log_item *lip) |
1da177e4 | 74 | { |
7bfa31d8 | 75 | struct xfs_dquot *dqp = DQUOT_ITEM(lip)->qli_dquot; |
1da177e4 | 76 | |
1da177e4 | 77 | ASSERT(XFS_DQ_IS_LOCKED(dqp)); |
d1de8021 | 78 | atomic_inc(&dqp->q_pincount); |
1da177e4 LT |
79 | } |
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 | |
bc3048e3 PL |
84 | * dquot must have been previously pinned with a call to |
85 | * xfs_qm_dquot_logitem_pin(). | |
1da177e4 | 86 | */ |
1da177e4 LT |
87 | STATIC void |
88 | xfs_qm_dquot_logitem_unpin( | |
7bfa31d8 | 89 | struct xfs_log_item *lip, |
9412e318 | 90 | int remove) |
1da177e4 | 91 | { |
7bfa31d8 | 92 | struct xfs_dquot *dqp = DQUOT_ITEM(lip)->qli_dquot; |
1da177e4 | 93 | |
bc3048e3 PL |
94 | ASSERT(atomic_read(&dqp->q_pincount) > 0); |
95 | if (atomic_dec_and_test(&dqp->q_pincount)) | |
96 | wake_up(&dqp->q_pinwait); | |
1da177e4 LT |
97 | } |
98 | ||
1da177e4 LT |
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 | xfs_qm_dqunpin_wait( | |
7bfa31d8 | 105 | struct xfs_dquot *dqp) |
1da177e4 | 106 | { |
1da177e4 | 107 | ASSERT(XFS_DQ_IS_LOCKED(dqp)); |
bc3048e3 | 108 | if (atomic_read(&dqp->q_pincount) == 0) |
1da177e4 | 109 | return; |
1da177e4 LT |
110 | |
111 | /* | |
112 | * Give the log a push so we don't wait here too long. | |
113 | */ | |
a14a348b | 114 | xfs_log_force(dqp->q_mount, 0); |
bc3048e3 | 115 | wait_event(dqp->q_pinwait, (atomic_read(&dqp->q_pincount) == 0)); |
1da177e4 LT |
116 | } |
117 | ||
1da177e4 | 118 | STATIC uint |
43ff2122 CH |
119 | xfs_qm_dquot_logitem_push( |
120 | struct xfs_log_item *lip, | |
57e80956 MW |
121 | struct list_head *buffer_list) |
122 | __releases(&lip->li_ailp->ail_lock) | |
123 | __acquires(&lip->li_ailp->ail_lock) | |
1da177e4 | 124 | { |
7bfa31d8 | 125 | struct xfs_dquot *dqp = DQUOT_ITEM(lip)->qli_dquot; |
373b0589 | 126 | struct xfs_buf *bp = lip->li_buf; |
43ff2122 CH |
127 | uint rval = XFS_ITEM_SUCCESS; |
128 | int error; | |
1da177e4 | 129 | |
bc3048e3 | 130 | if (atomic_read(&dqp->q_pincount) > 0) |
d808f617 | 131 | return XFS_ITEM_PINNED; |
1da177e4 | 132 | |
800b484e | 133 | if (!xfs_dqlock_nowait(dqp)) |
d808f617 | 134 | return XFS_ITEM_LOCKED; |
1da177e4 | 135 | |
fe7257fd CH |
136 | /* |
137 | * Re-check the pincount now that we stabilized the value by | |
138 | * taking the quota lock. | |
139 | */ | |
140 | if (atomic_read(&dqp->q_pincount) > 0) { | |
43ff2122 CH |
141 | rval = XFS_ITEM_PINNED; |
142 | goto out_unlock; | |
fe7257fd CH |
143 | } |
144 | ||
43ff2122 CH |
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 | */ | |
e1f49cf2 | 150 | if (!xfs_dqflock_nowait(dqp)) { |
43ff2122 CH |
151 | rval = XFS_ITEM_FLUSHING; |
152 | goto out_unlock; | |
153 | } | |
154 | ||
57e80956 | 155 | spin_unlock(&lip->li_ailp->ail_lock); |
43ff2122 CH |
156 | |
157 | error = xfs_qm_dqflush(dqp, &bp); | |
609001bc | 158 | if (!error) { |
43ff2122 CH |
159 | if (!xfs_buf_delwri_queue(bp, buffer_list)) |
160 | rval = XFS_ITEM_FLUSHING; | |
161 | xfs_buf_relse(bp); | |
8d3d7e2b BF |
162 | } else if (error == -EAGAIN) |
163 | rval = XFS_ITEM_LOCKED; | |
1da177e4 | 164 | |
57e80956 | 165 | spin_lock(&lip->li_ailp->ail_lock); |
43ff2122 CH |
166 | out_unlock: |
167 | xfs_dqunlock(dqp); | |
168 | return rval; | |
1da177e4 LT |
169 | } |
170 | ||
1da177e4 | 171 | STATIC void |
ddf92053 | 172 | xfs_qm_dquot_logitem_release( |
7bfa31d8 | 173 | struct xfs_log_item *lip) |
1da177e4 | 174 | { |
7bfa31d8 | 175 | struct xfs_dquot *dqp = DQUOT_ITEM(lip)->qli_dquot; |
1da177e4 | 176 | |
1da177e4 LT |
177 | ASSERT(XFS_DQ_IS_LOCKED(dqp)); |
178 | ||
1da177e4 LT |
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 | xfs_dqunlock(dqp); | |
186 | } | |
187 | ||
ddf92053 CH |
188 | STATIC void |
189 | xfs_qm_dquot_logitem_committing( | |
190 | struct xfs_log_item *lip, | |
5f9b4b0d | 191 | xfs_csn_t seq) |
ddf92053 CH |
192 | { |
193 | return xfs_qm_dquot_logitem_release(lip); | |
194 | } | |
195 | ||
272e42b2 | 196 | static const struct xfs_item_ops xfs_dquot_item_ops = { |
7bfa31d8 CH |
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, | |
ddf92053 CH |
201 | .iop_release = xfs_qm_dquot_logitem_release, |
202 | .iop_committing = xfs_qm_dquot_logitem_committing, | |
7bfa31d8 | 203 | .iop_push = xfs_qm_dquot_logitem_push, |
1da177e4 LT |
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 | xfs_qm_dquot_logitem_init( | |
7bfa31d8 | 213 | struct xfs_dquot *dqp) |
1da177e4 | 214 | { |
7bfa31d8 | 215 | struct xfs_dq_logitem *lp = &dqp->q_logitem; |
1da177e4 | 216 | |
43f5efc5 DC |
217 | xfs_log_item_init(dqp->q_mount, &lp->qli_item, XFS_LI_DQUOT, |
218 | &xfs_dquot_item_ops); | |
1da177e4 | 219 | lp->qli_dquot = dqp; |
1da177e4 | 220 | } |