Linux Audio

Check our new training course

Loading...
v3.5.6
 
  1/*
  2 * Copyright (c) 2000-2003 Silicon Graphics, Inc.
  3 * All Rights Reserved.
  4 *
  5 * This program is free software; you can redistribute it and/or
  6 * modify it under the terms of the GNU General Public License as
  7 * published by the Free Software Foundation.
  8 *
  9 * This program is distributed in the hope that it would be useful,
 10 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 11 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 12 * GNU General Public License for more details.
 13 *
 14 * You should have received a copy of the GNU General Public License
 15 * along with this program; if not, write the Free Software Foundation,
 16 * Inc.,  51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA
 17 */
 18#include "xfs.h"
 19#include "xfs_fs.h"
 20#include "xfs_log.h"
 21#include "xfs_trans.h"
 22#include "xfs_sb.h"
 23#include "xfs_ag.h"
 24#include "xfs_alloc.h"
 25#include "xfs_quota.h"
 26#include "xfs_mount.h"
 27#include "xfs_bmap_btree.h"
 28#include "xfs_inode.h"
 29#include "xfs_bmap.h"
 30#include "xfs_rtalloc.h"
 31#include "xfs_error.h"
 32#include "xfs_itable.h"
 33#include "xfs_attr.h"
 34#include "xfs_buf_item.h"
 35#include "xfs_trans_priv.h"
 36#include "xfs_qm.h"
 
 37
 38static inline struct xfs_dq_logitem *DQUOT_ITEM(struct xfs_log_item *lip)
 39{
 40	return container_of(lip, struct xfs_dq_logitem, qli_item);
 41}
 42
 43/*
 44 * returns the number of iovecs needed to log the given dquot item.
 45 */
 46STATIC uint
 47xfs_qm_dquot_logitem_size(
 48	struct xfs_log_item	*lip)
 
 
 49{
 50	/*
 51	 * we need only two iovecs, one for the format, one for the real thing
 52	 */
 53	return 2;
 54}
 55
 56/*
 57 * fills in the vector of log iovecs for the given dquot log item.
 58 */
 59STATIC void
 60xfs_qm_dquot_logitem_format(
 61	struct xfs_log_item	*lip,
 62	struct xfs_log_iovec	*logvec)
 63{
 64	struct xfs_dq_logitem	*qlip = DQUOT_ITEM(lip);
 
 
 65
 66	logvec->i_addr = &qlip->qli_format;
 67	logvec->i_len  = sizeof(xfs_dq_logformat_t);
 68	logvec->i_type = XLOG_REG_TYPE_QFORMAT;
 69	logvec++;
 70	logvec->i_addr = &qlip->qli_dquot->q_core;
 71	logvec->i_len  = sizeof(xfs_disk_dquot_t);
 72	logvec->i_type = XLOG_REG_TYPE_DQUOT;
 73
 74	qlip->qli_format.qlf_size = 2;
 75
 
 
 76}
 77
 78/*
 79 * Increment the pin count of the given dquot.
 80 */
 81STATIC void
 82xfs_qm_dquot_logitem_pin(
 83	struct xfs_log_item	*lip)
 84{
 85	struct xfs_dquot	*dqp = DQUOT_ITEM(lip)->qli_dquot;
 86
 87	ASSERT(XFS_DQ_IS_LOCKED(dqp));
 88	atomic_inc(&dqp->q_pincount);
 89}
 90
 91/*
 92 * Decrement the pin count of the given dquot, and wake up
 93 * anyone in xfs_dqwait_unpin() if the count goes to 0.	 The
 94 * dquot must have been previously pinned with a call to
 95 * xfs_qm_dquot_logitem_pin().
 96 */
 97STATIC void
 98xfs_qm_dquot_logitem_unpin(
 99	struct xfs_log_item	*lip,
100	int			remove)
101{
102	struct xfs_dquot	*dqp = DQUOT_ITEM(lip)->qli_dquot;
103
104	ASSERT(atomic_read(&dqp->q_pincount) > 0);
105	if (atomic_dec_and_test(&dqp->q_pincount))
106		wake_up(&dqp->q_pinwait);
107}
108
109STATIC xfs_lsn_t
110xfs_qm_dquot_logitem_committed(
111	struct xfs_log_item	*lip,
112	xfs_lsn_t		lsn)
113{
114	/*
115	 * We always re-log the entire dquot when it becomes dirty,
116	 * so, the latest copy _is_ the only one that matters.
117	 */
118	return lsn;
119}
120
121/*
122 * This is called to wait for the given dquot to be unpinned.
123 * Most of these pin/unpin routines are plagiarized from inode code.
124 */
125void
126xfs_qm_dqunpin_wait(
127	struct xfs_dquot	*dqp)
128{
129	ASSERT(XFS_DQ_IS_LOCKED(dqp));
130	if (atomic_read(&dqp->q_pincount) == 0)
131		return;
132
133	/*
134	 * Give the log a push so we don't wait here too long.
135	 */
136	xfs_log_force(dqp->q_mount, 0);
137	wait_event(dqp->q_pinwait, (atomic_read(&dqp->q_pincount) == 0));
138}
139
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
140STATIC uint
141xfs_qm_dquot_logitem_push(
142	struct xfs_log_item	*lip,
143	struct list_head	*buffer_list)
 
 
144{
145	struct xfs_dquot	*dqp = DQUOT_ITEM(lip)->qli_dquot;
146	struct xfs_buf		*bp = NULL;
147	uint			rval = XFS_ITEM_SUCCESS;
148	int			error;
149
150	if (atomic_read(&dqp->q_pincount) > 0)
151		return XFS_ITEM_PINNED;
152
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
153	if (!xfs_dqlock_nowait(dqp))
154		return XFS_ITEM_LOCKED;
155
156	/*
157	 * Re-check the pincount now that we stabilized the value by
158	 * taking the quota lock.
159	 */
160	if (atomic_read(&dqp->q_pincount) > 0) {
161		rval = XFS_ITEM_PINNED;
162		goto out_unlock;
163	}
164
165	/*
166	 * Someone else is already flushing the dquot.  Nothing we can do
167	 * here but wait for the flush to finish and remove the item from
168	 * the AIL.
169	 */
170	if (!xfs_dqflock_nowait(dqp)) {
171		rval = XFS_ITEM_FLUSHING;
172		goto out_unlock;
173	}
174
175	spin_unlock(&lip->li_ailp->xa_lock);
176
177	error = xfs_qm_dqflush(dqp, &bp);
178	if (error) {
179		xfs_warn(dqp->q_mount, "%s: push error %d on dqp %p",
180			__func__, error, dqp);
181	} else {
182		if (!xfs_buf_delwri_queue(bp, buffer_list))
183			rval = XFS_ITEM_FLUSHING;
184		xfs_buf_relse(bp);
185	}
186
187	spin_lock(&lip->li_ailp->xa_lock);
188out_unlock:
189	xfs_dqunlock(dqp);
190	return rval;
191}
192
193/*
194 * Unlock the dquot associated with the log item.
195 * Clear the fields of the dquot and dquot log item that
196 * are specific to the current transaction.  If the
197 * hold flags is set, do not unlock the dquot.
198 */
199STATIC void
200xfs_qm_dquot_logitem_unlock(
201	struct xfs_log_item	*lip)
202{
203	struct xfs_dquot	*dqp = DQUOT_ITEM(lip)->qli_dquot;
204
205	ASSERT(XFS_DQ_IS_LOCKED(dqp));
206
207	/*
208	 * Clear the transaction pointer in the dquot
209	 */
210	dqp->q_transp = NULL;
211
212	/*
213	 * dquots are never 'held' from getting unlocked at the end of
214	 * a transaction.  Their locking and unlocking is hidden inside the
215	 * transaction layer, within trans_commit. Hence, no LI_HOLD flag
216	 * for the logitem.
217	 */
218	xfs_dqunlock(dqp);
219}
220
221/*
222 * this needs to stamp an lsn into the dquot, I think.
223 * rpc's that look at user dquot's would then have to
224 * push on the dependency recorded in the dquot
225 */
226STATIC void
227xfs_qm_dquot_logitem_committing(
228	struct xfs_log_item	*lip,
229	xfs_lsn_t		lsn)
230{
 
231}
232
233/*
234 * This is the ops vector for dquots
235 */
236static const struct xfs_item_ops xfs_dquot_item_ops = {
237	.iop_size	= xfs_qm_dquot_logitem_size,
238	.iop_format	= xfs_qm_dquot_logitem_format,
239	.iop_pin	= xfs_qm_dquot_logitem_pin,
240	.iop_unpin	= xfs_qm_dquot_logitem_unpin,
241	.iop_unlock	= xfs_qm_dquot_logitem_unlock,
242	.iop_committed	= xfs_qm_dquot_logitem_committed,
243	.iop_push	= xfs_qm_dquot_logitem_push,
244	.iop_committing = xfs_qm_dquot_logitem_committing
245};
246
247/*
248 * Initialize the dquot log item for a newly allocated dquot.
249 * The dquot isn't locked at this point, but it isn't on any of the lists
250 * either, so we don't care.
251 */
252void
253xfs_qm_dquot_logitem_init(
254	struct xfs_dquot	*dqp)
255{
256	struct xfs_dq_logitem	*lp = &dqp->q_logitem;
257
258	xfs_log_item_init(dqp->q_mount, &lp->qli_item, XFS_LI_DQUOT,
259					&xfs_dquot_item_ops);
260	lp->qli_dquot = dqp;
261	lp->qli_format.qlf_type = XFS_LI_DQUOT;
262	lp->qli_format.qlf_id = be32_to_cpu(dqp->q_core.d_id);
263	lp->qli_format.qlf_blkno = dqp->q_blkno;
264	lp->qli_format.qlf_len = 1;
265	/*
266	 * This is just the offset of this dquot within its buffer
267	 * (which is currently 1 FSB and probably won't change).
268	 * Hence 32 bits for this offset should be just fine.
269	 * Alternatively, we can store (bufoffset / sizeof(xfs_dqblk_t))
270	 * here, and recompute it at recovery time.
271	 */
272	lp->qli_format.qlf_boffset = (__uint32_t)dqp->q_bufoffset;
273}
274
275/*------------------  QUOTAOFF LOG ITEMS  -------------------*/
276
277static inline struct xfs_qoff_logitem *QOFF_ITEM(struct xfs_log_item *lip)
278{
279	return container_of(lip, struct xfs_qoff_logitem, qql_item);
280}
281
282
283/*
284 * This returns the number of iovecs needed to log the given quotaoff item.
285 * We only need 1 iovec for an quotaoff item.  It just logs the
286 * quotaoff_log_format structure.
287 */
288STATIC uint
289xfs_qm_qoff_logitem_size(
290	struct xfs_log_item	*lip)
 
 
291{
292	return 1;
 
293}
294
295/*
296 * This is called to fill in the vector of log iovecs for the
297 * given quotaoff log item. We use only 1 iovec, and we point that
298 * at the quotaoff_log_format structure embedded in the quotaoff item.
299 * It is at this point that we assert that all of the extent
300 * slots in the quotaoff item have been filled.
301 */
302STATIC void
303xfs_qm_qoff_logitem_format(
304	struct xfs_log_item	*lip,
305	struct xfs_log_iovec	*log_vector)
306{
307	struct xfs_qoff_logitem	*qflip = QOFF_ITEM(lip);
 
 
308
309	ASSERT(qflip->qql_format.qf_type == XFS_LI_QUOTAOFF);
310
311	log_vector->i_addr = &qflip->qql_format;
312	log_vector->i_len = sizeof(xfs_qoff_logitem_t);
313	log_vector->i_type = XLOG_REG_TYPE_QUOTAOFF;
314	qflip->qql_format.qf_size = 1;
315}
316
317/*
318 * Pinning has no meaning for an quotaoff item, so just return.
319 */
320STATIC void
321xfs_qm_qoff_logitem_pin(
322	struct xfs_log_item	*lip)
323{
324}
325
326/*
327 * Since pinning has no meaning for an quotaoff item, unpinning does
328 * not either.
329 */
330STATIC void
331xfs_qm_qoff_logitem_unpin(
332	struct xfs_log_item	*lip,
333	int			remove)
334{
335}
336
337/*
338 * There isn't much you can do to push a quotaoff item.  It is simply
339 * stuck waiting for the log to be flushed to disk.
340 */
341STATIC uint
342xfs_qm_qoff_logitem_push(
343	struct xfs_log_item	*lip,
344	struct list_head	*buffer_list)
345{
346	return XFS_ITEM_LOCKED;
347}
348
349/*
350 * Quotaoff items have no locking or pushing, so return failure
351 * so that the caller doesn't bother with us.
352 */
353STATIC void
354xfs_qm_qoff_logitem_unlock(
355	struct xfs_log_item	*lip)
356{
357}
358
359/*
360 * The quotaoff-start-item is logged only once and cannot be moved in the log,
361 * so simply return the lsn at which it's been logged.
362 */
363STATIC xfs_lsn_t
364xfs_qm_qoff_logitem_committed(
365	struct xfs_log_item	*lip,
366	xfs_lsn_t		lsn)
367{
368	return lsn;
369}
370
371STATIC xfs_lsn_t
372xfs_qm_qoffend_logitem_committed(
373	struct xfs_log_item	*lip,
374	xfs_lsn_t		lsn)
375{
376	struct xfs_qoff_logitem	*qfe = QOFF_ITEM(lip);
377	struct xfs_qoff_logitem	*qfs = qfe->qql_start_lip;
378	struct xfs_ail		*ailp = qfs->qql_item.li_ailp;
379
380	/*
381	 * Delete the qoff-start logitem from the AIL.
382	 * xfs_trans_ail_delete() drops the AIL lock.
383	 */
384	spin_lock(&ailp->xa_lock);
385	xfs_trans_ail_delete(ailp, &qfs->qql_item, SHUTDOWN_LOG_IO_ERROR);
386
 
 
387	kmem_free(qfs);
388	kmem_free(qfe);
389	return (xfs_lsn_t)-1;
390}
391
392/*
393 * XXX rcc - don't know quite what to do with this.  I think we can
394 * just ignore it.  The only time that isn't the case is if we allow
395 * the client to somehow see that quotas have been turned off in which
396 * we can't allow that to get back until the quotaoff hits the disk.
397 * So how would that happen?  Also, do we need different routines for
398 * quotaoff start and quotaoff end?  I suspect the answer is yes but
399 * to be sure, I need to look at the recovery code and see how quota off
400 * recovery is handled (do we roll forward or back or do something else).
401 * If we roll forwards or backwards, then we need two separate routines,
402 * one that does nothing and one that stamps in the lsn that matters
403 * (truly makes the quotaoff irrevocable).  If we do something else,
404 * then maybe we don't need two.
405 */
406STATIC void
407xfs_qm_qoff_logitem_committing(
408	struct xfs_log_item	*lip,
409	xfs_lsn_t		commit_lsn)
410{
411}
412
413static const struct xfs_item_ops xfs_qm_qoffend_logitem_ops = {
414	.iop_size	= xfs_qm_qoff_logitem_size,
415	.iop_format	= xfs_qm_qoff_logitem_format,
416	.iop_pin	= xfs_qm_qoff_logitem_pin,
417	.iop_unpin	= xfs_qm_qoff_logitem_unpin,
418	.iop_unlock	= xfs_qm_qoff_logitem_unlock,
419	.iop_committed	= xfs_qm_qoffend_logitem_committed,
420	.iop_push	= xfs_qm_qoff_logitem_push,
421	.iop_committing = xfs_qm_qoff_logitem_committing
422};
423
424/*
425 * This is the ops vector shared by all quotaoff-start log items.
426 */
427static const struct xfs_item_ops xfs_qm_qoff_logitem_ops = {
428	.iop_size	= xfs_qm_qoff_logitem_size,
429	.iop_format	= xfs_qm_qoff_logitem_format,
430	.iop_pin	= xfs_qm_qoff_logitem_pin,
431	.iop_unpin	= xfs_qm_qoff_logitem_unpin,
432	.iop_unlock	= xfs_qm_qoff_logitem_unlock,
433	.iop_committed	= xfs_qm_qoff_logitem_committed,
434	.iop_push	= xfs_qm_qoff_logitem_push,
435	.iop_committing = xfs_qm_qoff_logitem_committing
436};
437
438/*
439 * Allocate and initialize an quotaoff item of the correct quota type(s).
440 */
441struct xfs_qoff_logitem *
442xfs_qm_qoff_logitem_init(
443	struct xfs_mount	*mp,
444	struct xfs_qoff_logitem	*start,
445	uint			flags)
446{
447	struct xfs_qoff_logitem	*qf;
448
449	qf = kmem_zalloc(sizeof(struct xfs_qoff_logitem), KM_SLEEP);
450
451	xfs_log_item_init(mp, &qf->qql_item, XFS_LI_QUOTAOFF, start ?
452			&xfs_qm_qoffend_logitem_ops : &xfs_qm_qoff_logitem_ops);
453	qf->qql_item.li_mountp = mp;
454	qf->qql_format.qf_type = XFS_LI_QUOTAOFF;
455	qf->qql_format.qf_flags = flags;
456	qf->qql_start_lip = start;
 
457	return qf;
458}
v5.4
  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
 21static 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 */
 29STATIC void
 30xfs_qm_dquot_logitem_size(
 31	struct xfs_log_item	*lip,
 32	int			*nvecs,
 33	int			*nbytes)
 34{
 35	*nvecs += 2;
 36	*nbytes += sizeof(struct xfs_dq_logformat) +
 37		   sizeof(struct xfs_disk_dquot);
 
 38}
 39
 40/*
 41 * fills in the vector of log iovecs for the given dquot log item.
 42 */
 43STATIC void
 44xfs_qm_dquot_logitem_format(
 45	struct xfs_log_item	*lip,
 46	struct xfs_log_vec	*lv)
 47{
 48	struct xfs_dq_logitem	*qlip = DQUOT_ITEM(lip);
 49	struct xfs_log_iovec	*vecp = NULL;
 50	struct xfs_dq_logformat	*qlf;
 51
 52	qlf = xlog_prepare_iovec(lv, &vecp, XLOG_REG_TYPE_QFORMAT);
 53	qlf->qlf_type = XFS_LI_DQUOT;
 54	qlf->qlf_size = 2;
 55	qlf->qlf_id = be32_to_cpu(qlip->qli_dquot->q_core.d_id);
 56	qlf->qlf_blkno = qlip->qli_dquot->q_blkno;
 57	qlf->qlf_len = 1;
 58	qlf->qlf_boffset = qlip->qli_dquot->q_bufoffset;
 59	xlog_finish_iovec(lv, vecp, sizeof(struct xfs_dq_logformat));
 60
 61	xlog_copy_iovec(lv, &vecp, XLOG_REG_TYPE_DQUOT,
 62			&qlip->qli_dquot->q_core,
 63			sizeof(struct xfs_disk_dquot));
 64}
 65
 66/*
 67 * Increment the pin count of the given dquot.
 68 */
 69STATIC void
 70xfs_qm_dquot_logitem_pin(
 71	struct xfs_log_item	*lip)
 72{
 73	struct xfs_dquot	*dqp = DQUOT_ITEM(lip)->qli_dquot;
 74
 75	ASSERT(XFS_DQ_IS_LOCKED(dqp));
 76	atomic_inc(&dqp->q_pincount);
 77}
 78
 79/*
 80 * Decrement the pin count of the given dquot, and wake up
 81 * anyone in xfs_dqwait_unpin() if the count goes to 0.	 The
 82 * dquot must have been previously pinned with a call to
 83 * xfs_qm_dquot_logitem_pin().
 84 */
 85STATIC void
 86xfs_qm_dquot_logitem_unpin(
 87	struct xfs_log_item	*lip,
 88	int			remove)
 89{
 90	struct xfs_dquot	*dqp = DQUOT_ITEM(lip)->qli_dquot;
 91
 92	ASSERT(atomic_read(&dqp->q_pincount) > 0);
 93	if (atomic_dec_and_test(&dqp->q_pincount))
 94		wake_up(&dqp->q_pinwait);
 95}
 96
 
 
 
 
 
 
 
 
 
 
 
 
 97/*
 98 * This is called to wait for the given dquot to be unpinned.
 99 * Most of these pin/unpin routines are plagiarized from inode code.
100 */
101void
102xfs_qm_dqunpin_wait(
103	struct xfs_dquot	*dqp)
104{
105	ASSERT(XFS_DQ_IS_LOCKED(dqp));
106	if (atomic_read(&dqp->q_pincount) == 0)
107		return;
108
109	/*
110	 * Give the log a push so we don't wait here too long.
111	 */
112	xfs_log_force(dqp->q_mount, 0);
113	wait_event(dqp->q_pinwait, (atomic_read(&dqp->q_pincount) == 0));
114}
115
116/*
117 * Callback used to mark a buffer with XFS_LI_FAILED when items in the buffer
118 * have been failed during writeback
119 *
120 * this informs the AIL that the dquot is already flush locked on the next push,
121 * and acquires a hold on the buffer to ensure that it isn't reclaimed before
122 * dirty data makes it to disk.
123 */
124STATIC void
125xfs_dquot_item_error(
126	struct xfs_log_item	*lip,
127	struct xfs_buf		*bp)
128{
129	ASSERT(!completion_done(&DQUOT_ITEM(lip)->qli_dquot->q_flush));
130	xfs_set_li_failed(lip, bp);
131}
132
133STATIC uint
134xfs_qm_dquot_logitem_push(
135	struct xfs_log_item	*lip,
136	struct list_head	*buffer_list)
137		__releases(&lip->li_ailp->ail_lock)
138		__acquires(&lip->li_ailp->ail_lock)
139{
140	struct xfs_dquot	*dqp = DQUOT_ITEM(lip)->qli_dquot;
141	struct xfs_buf		*bp = lip->li_buf;
142	uint			rval = XFS_ITEM_SUCCESS;
143	int			error;
144
145	if (atomic_read(&dqp->q_pincount) > 0)
146		return XFS_ITEM_PINNED;
147
148	/*
149	 * The buffer containing this item failed to be written back
150	 * previously. Resubmit the buffer for IO
151	 */
152	if (test_bit(XFS_LI_FAILED, &lip->li_flags)) {
153		if (!xfs_buf_trylock(bp))
154			return XFS_ITEM_LOCKED;
155
156		if (!xfs_buf_resubmit_failed_buffers(bp, buffer_list))
157			rval = XFS_ITEM_FLUSHING;
158
159		xfs_buf_unlock(bp);
160		return rval;
161	}
162
163	if (!xfs_dqlock_nowait(dqp))
164		return XFS_ITEM_LOCKED;
165
166	/*
167	 * Re-check the pincount now that we stabilized the value by
168	 * taking the quota lock.
169	 */
170	if (atomic_read(&dqp->q_pincount) > 0) {
171		rval = XFS_ITEM_PINNED;
172		goto out_unlock;
173	}
174
175	/*
176	 * Someone else is already flushing the dquot.  Nothing we can do
177	 * here but wait for the flush to finish and remove the item from
178	 * the AIL.
179	 */
180	if (!xfs_dqflock_nowait(dqp)) {
181		rval = XFS_ITEM_FLUSHING;
182		goto out_unlock;
183	}
184
185	spin_unlock(&lip->li_ailp->ail_lock);
186
187	error = xfs_qm_dqflush(dqp, &bp);
188	if (!error) {
 
 
 
189		if (!xfs_buf_delwri_queue(bp, buffer_list))
190			rval = XFS_ITEM_FLUSHING;
191		xfs_buf_relse(bp);
192	}
193
194	spin_lock(&lip->li_ailp->ail_lock);
195out_unlock:
196	xfs_dqunlock(dqp);
197	return rval;
198}
199
 
 
 
 
 
 
200STATIC void
201xfs_qm_dquot_logitem_release(
202	struct xfs_log_item	*lip)
203{
204	struct xfs_dquot	*dqp = DQUOT_ITEM(lip)->qli_dquot;
205
206	ASSERT(XFS_DQ_IS_LOCKED(dqp));
207
208	/*
 
 
 
 
 
209	 * dquots are never 'held' from getting unlocked at the end of
210	 * a transaction.  Their locking and unlocking is hidden inside the
211	 * transaction layer, within trans_commit. Hence, no LI_HOLD flag
212	 * for the logitem.
213	 */
214	xfs_dqunlock(dqp);
215}
216
 
 
 
 
 
217STATIC void
218xfs_qm_dquot_logitem_committing(
219	struct xfs_log_item	*lip,
220	xfs_lsn_t		commit_lsn)
221{
222	return xfs_qm_dquot_logitem_release(lip);
223}
224
 
 
 
225static const struct xfs_item_ops xfs_dquot_item_ops = {
226	.iop_size	= xfs_qm_dquot_logitem_size,
227	.iop_format	= xfs_qm_dquot_logitem_format,
228	.iop_pin	= xfs_qm_dquot_logitem_pin,
229	.iop_unpin	= xfs_qm_dquot_logitem_unpin,
230	.iop_release	= xfs_qm_dquot_logitem_release,
231	.iop_committing	= xfs_qm_dquot_logitem_committing,
232	.iop_push	= xfs_qm_dquot_logitem_push,
233	.iop_error	= xfs_dquot_item_error
234};
235
236/*
237 * Initialize the dquot log item for a newly allocated dquot.
238 * The dquot isn't locked at this point, but it isn't on any of the lists
239 * either, so we don't care.
240 */
241void
242xfs_qm_dquot_logitem_init(
243	struct xfs_dquot	*dqp)
244{
245	struct xfs_dq_logitem	*lp = &dqp->q_logitem;
246
247	xfs_log_item_init(dqp->q_mount, &lp->qli_item, XFS_LI_DQUOT,
248					&xfs_dquot_item_ops);
249	lp->qli_dquot = dqp;
 
 
 
 
 
 
 
 
 
 
 
 
250}
251
252/*------------------  QUOTAOFF LOG ITEMS  -------------------*/
253
254static inline struct xfs_qoff_logitem *QOFF_ITEM(struct xfs_log_item *lip)
255{
256	return container_of(lip, struct xfs_qoff_logitem, qql_item);
257}
258
259
260/*
261 * This returns the number of iovecs needed to log the given quotaoff item.
262 * We only need 1 iovec for an quotaoff item.  It just logs the
263 * quotaoff_log_format structure.
264 */
265STATIC void
266xfs_qm_qoff_logitem_size(
267	struct xfs_log_item	*lip,
268	int			*nvecs,
269	int			*nbytes)
270{
271	*nvecs += 1;
272	*nbytes += sizeof(struct xfs_qoff_logitem);
273}
274
 
 
 
 
 
 
 
275STATIC void
276xfs_qm_qoff_logitem_format(
277	struct xfs_log_item	*lip,
278	struct xfs_log_vec	*lv)
279{
280	struct xfs_qoff_logitem	*qflip = QOFF_ITEM(lip);
281	struct xfs_log_iovec	*vecp = NULL;
282	struct xfs_qoff_logformat *qlf;
283
284	qlf = xlog_prepare_iovec(lv, &vecp, XLOG_REG_TYPE_QUOTAOFF);
285	qlf->qf_type = XFS_LI_QUOTAOFF;
286	qlf->qf_size = 1;
287	qlf->qf_flags = qflip->qql_flags;
288	xlog_finish_iovec(lv, vecp, sizeof(struct xfs_qoff_logitem));
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
289}
290
291/*
292 * There isn't much you can do to push a quotaoff item.  It is simply
293 * stuck waiting for the log to be flushed to disk.
294 */
295STATIC uint
296xfs_qm_qoff_logitem_push(
297	struct xfs_log_item	*lip,
298	struct list_head	*buffer_list)
299{
300	return XFS_ITEM_LOCKED;
301}
302
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
303STATIC xfs_lsn_t
304xfs_qm_qoffend_logitem_committed(
305	struct xfs_log_item	*lip,
306	xfs_lsn_t		lsn)
307{
308	struct xfs_qoff_logitem	*qfe = QOFF_ITEM(lip);
309	struct xfs_qoff_logitem	*qfs = qfe->qql_start_lip;
310	struct xfs_ail		*ailp = qfs->qql_item.li_ailp;
311
312	/*
313	 * Delete the qoff-start logitem from the AIL.
314	 * xfs_trans_ail_delete() drops the AIL lock.
315	 */
316	spin_lock(&ailp->ail_lock);
317	xfs_trans_ail_delete(ailp, &qfs->qql_item, SHUTDOWN_LOG_IO_ERROR);
318
319	kmem_free(qfs->qql_item.li_lv_shadow);
320	kmem_free(lip->li_lv_shadow);
321	kmem_free(qfs);
322	kmem_free(qfe);
323	return (xfs_lsn_t)-1;
324}
325
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
326static const struct xfs_item_ops xfs_qm_qoffend_logitem_ops = {
327	.iop_size	= xfs_qm_qoff_logitem_size,
328	.iop_format	= xfs_qm_qoff_logitem_format,
 
 
 
329	.iop_committed	= xfs_qm_qoffend_logitem_committed,
330	.iop_push	= xfs_qm_qoff_logitem_push,
 
331};
332
 
 
 
333static const struct xfs_item_ops xfs_qm_qoff_logitem_ops = {
334	.iop_size	= xfs_qm_qoff_logitem_size,
335	.iop_format	= xfs_qm_qoff_logitem_format,
 
 
 
 
336	.iop_push	= xfs_qm_qoff_logitem_push,
 
337};
338
339/*
340 * Allocate and initialize an quotaoff item of the correct quota type(s).
341 */
342struct xfs_qoff_logitem *
343xfs_qm_qoff_logitem_init(
344	struct xfs_mount	*mp,
345	struct xfs_qoff_logitem	*start,
346	uint			flags)
347{
348	struct xfs_qoff_logitem	*qf;
349
350	qf = kmem_zalloc(sizeof(struct xfs_qoff_logitem), 0);
351
352	xfs_log_item_init(mp, &qf->qql_item, XFS_LI_QUOTAOFF, start ?
353			&xfs_qm_qoffend_logitem_ops : &xfs_qm_qoff_logitem_ops);
354	qf->qql_item.li_mountp = mp;
 
 
355	qf->qql_start_lip = start;
356	qf->qql_flags = flags;
357	return qf;
358}