[linux.git] / fs / xfs / xfs_trans_refcount.c

// SPDX-License-Identifier: GPL-2.0+
/*
 * Copyright (C) 2016 Oracle.  All Rights Reserved.
 * Author: Darrick J. Wong <[email protected]>
 */
#include "xfs.h"
#include "xfs_fs.h"
#include "xfs_shared.h"
#include "xfs_format.h"
#include "xfs_log_format.h"
#include "xfs_trans_resv.h"
#include "xfs_mount.h"
#include "xfs_defer.h"
#include "xfs_trans.h"
#include "xfs_trans_priv.h"
#include "xfs_refcount_item.h"
#include "xfs_alloc.h"
#include "xfs_refcount.h"

/*
 * This routine is called to allocate a "refcount update done"
 * log item.
 */
struct xfs_cud_log_item *
xfs_trans_get_cud(
	struct xfs_trans		*tp,
	struct xfs_cui_log_item		*cuip)
{
	struct xfs_cud_log_item		*cudp;

	cudp = xfs_cud_init(tp->t_mountp, cuip);
	xfs_trans_add_item(tp, &cudp->cud_item);
	return cudp;
}

/*
 * Finish an refcount update and log it to the CUD. Note that the
 * transaction is marked dirty regardless of whether the refcount
 * update succeeds or fails to support the CUI/CUD lifecycle rules.
 */
int
xfs_trans_log_finish_refcount_update(
	struct xfs_trans		*tp,
	struct xfs_cud_log_item		*cudp,
	enum xfs_refcount_intent_type	type,
	xfs_fsblock_t			startblock,
	xfs_extlen_t			blockcount,
	xfs_fsblock_t			*new_fsb,
	xfs_extlen_t			*new_len,
	struct xfs_btree_cur		**pcur)
{
	int				error;

	error = xfs_refcount_finish_one(tp, type, startblock,
			blockcount, new_fsb, new_len, pcur);

	/*
	 * Mark the transaction dirty, even on error. This ensures the
	 * transaction is aborted, which:
	 *
	 * 1.) releases the CUI and frees the CUD
	 * 2.) shuts down the filesystem
	 */
	tp->t_flags |= XFS_TRANS_DIRTY;
	set_bit(XFS_LI_DIRTY, &cudp->cud_item.li_flags);

	return error;
}

/* Sort refcount intents by AG. */
static int
xfs_refcount_update_diff_items(
	void				*priv,
	struct list_head		*a,
	struct list_head		*b)
{
	struct xfs_mount		*mp = priv;
	struct xfs_refcount_intent	*ra;
	struct xfs_refcount_intent	*rb;

	ra = container_of(a, struct xfs_refcount_intent, ri_list);
	rb = container_of(b, struct xfs_refcount_intent, ri_list);
	return  XFS_FSB_TO_AGNO(mp, ra->ri_startblock) -
		XFS_FSB_TO_AGNO(mp, rb->ri_startblock);
}

/* Get an CUI. */
STATIC void *
xfs_refcount_update_create_intent(
	struct xfs_trans		*tp,
	unsigned int			count)
{
	struct xfs_cui_log_item		*cuip;

	ASSERT(tp != NULL);
	ASSERT(count > 0);

	cuip = xfs_cui_init(tp->t_mountp, count);
	ASSERT(cuip != NULL);

	/*
	 * Get a log_item_desc to point at the new item.
	 */
	xfs_trans_add_item(tp, &cuip->cui_item);
	return cuip;
}

/* Set the phys extent flags for this reverse mapping. */
static void
xfs_trans_set_refcount_flags(
	struct xfs_phys_extent		*refc,
	enum xfs_refcount_intent_type	type)
{
	refc->pe_flags = 0;
	switch (type) {
	case XFS_REFCOUNT_INCREASE:
	case XFS_REFCOUNT_DECREASE:
	case XFS_REFCOUNT_ALLOC_COW:
	case XFS_REFCOUNT_FREE_COW:
		refc->pe_flags |= type;
		break;
	default:
		ASSERT(0);
	}
}

/* Log refcount updates in the intent item. */
STATIC void
xfs_refcount_update_log_item(
	struct xfs_trans		*tp,
	void				*intent,
	struct list_head		*item)
{
	struct xfs_cui_log_item		*cuip = intent;
	struct xfs_refcount_intent	*refc;
	uint				next_extent;
	struct xfs_phys_extent		*ext;

	refc = container_of(item, struct xfs_refcount_intent, ri_list);

	tp->t_flags |= XFS_TRANS_DIRTY;
	set_bit(XFS_LI_DIRTY, &cuip->cui_item.li_flags);

	/*
	 * atomic_inc_return gives us the value after the increment;
	 * we want to use it as an array index so we need to subtract 1 from
	 * it.
	 */
	next_extent = atomic_inc_return(&cuip->cui_next_extent) - 1;
	ASSERT(next_extent < cuip->cui_format.cui_nextents);
	ext = &cuip->cui_format.cui_extents[next_extent];
	ext->pe_startblock = refc->ri_startblock;
	ext->pe_len = refc->ri_blockcount;
	xfs_trans_set_refcount_flags(ext, refc->ri_type);
}

/* Get an CUD so we can process all the deferred refcount updates. */
STATIC void *
xfs_refcount_update_create_done(
	struct xfs_trans		*tp,
	void				*intent,
	unsigned int			count)
{
	return xfs_trans_get_cud(tp, intent);
}

/* Process a deferred refcount update. */
STATIC int
xfs_refcount_update_finish_item(
	struct xfs_trans		*tp,
	struct list_head		*item,
	void				*done_item,
	void				**state)
{
	struct xfs_refcount_intent	*refc;
	xfs_fsblock_t			new_fsb;
	xfs_extlen_t			new_aglen;
	int				error;

	refc = container_of(item, struct xfs_refcount_intent, ri_list);
	error = xfs_trans_log_finish_refcount_update(tp, done_item,
			refc->ri_type,
			refc->ri_startblock,
			refc->ri_blockcount,
			&new_fsb, &new_aglen,
			(struct xfs_btree_cur **)state);
	/* Did we run out of reservation?  Requeue what we didn't finish. */
	if (!error && new_aglen > 0) {
		ASSERT(refc->ri_type == XFS_REFCOUNT_INCREASE ||
		       refc->ri_type == XFS_REFCOUNT_DECREASE);
		refc->ri_startblock = new_fsb;
		refc->ri_blockcount = new_aglen;
		return -EAGAIN;
	}
	kmem_free(refc);
	return error;
}

/* Clean up after processing deferred refcounts. */
STATIC void
xfs_refcount_update_finish_cleanup(
	struct xfs_trans	*tp,
	void			*state,
	int			error)
{
	struct xfs_btree_cur	*rcur = state;

	xfs_refcount_finish_one_cleanup(tp, rcur, error);
}

/* Abort all pending CUIs. */
STATIC void
xfs_refcount_update_abort_intent(
	void				*intent)
{
	xfs_cui_release(intent);
}

/* Cancel a deferred refcount update. */
STATIC void
xfs_refcount_update_cancel_item(
	struct list_head		*item)
{
	struct xfs_refcount_intent	*refc;

	refc = container_of(item, struct xfs_refcount_intent, ri_list);
	kmem_free(refc);
}

static const struct xfs_defer_op_type xfs_refcount_update_defer_type = {
	.type		= XFS_DEFER_OPS_TYPE_REFCOUNT,
	.max_items	= XFS_CUI_MAX_FAST_EXTENTS,
	.diff_items	= xfs_refcount_update_diff_items,
	.create_intent	= xfs_refcount_update_create_intent,
	.abort_intent	= xfs_refcount_update_abort_intent,
	.log_item	= xfs_refcount_update_log_item,
	.create_done	= xfs_refcount_update_create_done,
	.finish_item	= xfs_refcount_update_finish_item,
	.finish_cleanup = xfs_refcount_update_finish_cleanup,
	.cancel_item	= xfs_refcount_update_cancel_item,
};

/* Register the deferred op type. */
void
xfs_refcount_update_init_defer_op(void)
{
	xfs_defer_init_op_type(&xfs_refcount_update_defer_type);
}
Commit	Line	Data
0b61f8a4	1	// SPDX-License-Identifier: GPL-2.0+
f997ee21 DW	2	/*
f997ee21 DW	3	* Copyright (C) 2016 Oracle. All Rights Reserved.
f997ee21	4	* Author: Darrick J. Wong <[email protected]>
f997ee21 DW	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_defer.h"
	14	#include "xfs_trans.h"
	15	#include "xfs_trans_priv.h"
	16	#include "xfs_refcount_item.h"
	17	#include "xfs_alloc.h"
	18	#include "xfs_refcount.h"
	19
	20	/*
	21	* This routine is called to allocate a "refcount update done"
	22	* log item.
	23	*/
	24	struct xfs_cud_log_item *
	25	xfs_trans_get_cud(
	26	struct xfs_trans *tp,
	27	struct xfs_cui_log_item *cuip)
	28	{
	29	struct xfs_cud_log_item *cudp;
	30
	31	cudp = xfs_cud_init(tp->t_mountp, cuip);
	32	xfs_trans_add_item(tp, &cudp->cud_item);
	33	return cudp;
	34	}
	35
	36	/*
	37	* Finish an refcount update and log it to the CUD. Note that the
	38	* transaction is marked dirty regardless of whether the refcount
	39	* update succeeds or fails to support the CUI/CUD lifecycle rules.
	40	*/
	41	int
	42	xfs_trans_log_finish_refcount_update(
	43	struct xfs_trans *tp,
	44	struct xfs_cud_log_item *cudp,
	45	enum xfs_refcount_intent_type type,
	46	xfs_fsblock_t startblock,
	47	xfs_extlen_t blockcount,
33ba6129 DW	48	xfs_fsblock_t *new_fsb,
33ba6129 DW	49	xfs_extlen_t *new_len,
f997ee21 DW	50	struct xfs_btree_cur **pcur)
	51	{
	52	int error;
	53
7dbddbac	54	error = xfs_refcount_finish_one(tp, type, startblock,
33ba6129	55	blockcount, new_fsb, new_len, pcur);
f997ee21 DW	56
	57	/*
	58	* Mark the transaction dirty, even on error. This ensures the
	59	* transaction is aborted, which:
	60	*
	61	* 1.) releases the CUI and frees the CUD
	62	* 2.) shuts down the filesystem
	63	*/
	64	tp->t_flags \|= XFS_TRANS_DIRTY;
e6631f85	65	set_bit(XFS_LI_DIRTY, &cudp->cud_item.li_flags);
f997ee21 DW	66
	67	return error;
	68	}
33ba6129 DW	69
	70	/* Sort refcount intents by AG. */
	71	static int
	72	xfs_refcount_update_diff_items(
	73	void *priv,
	74	struct list_head *a,
	75	struct list_head *b)
	76	{
	77	struct xfs_mount *mp = priv;
	78	struct xfs_refcount_intent *ra;
	79	struct xfs_refcount_intent *rb;
	80
	81	ra = container_of(a, struct xfs_refcount_intent, ri_list);
	82	rb = container_of(b, struct xfs_refcount_intent, ri_list);
	83	return XFS_FSB_TO_AGNO(mp, ra->ri_startblock) -
	84	XFS_FSB_TO_AGNO(mp, rb->ri_startblock);
	85	}
	86
	87	/* Get an CUI. */
	88	STATIC void *
	89	xfs_refcount_update_create_intent(
	90	struct xfs_trans *tp,
	91	unsigned int count)
	92	{
	93	struct xfs_cui_log_item *cuip;
	94
	95	ASSERT(tp != NULL);
	96	ASSERT(count > 0);
	97
	98	cuip = xfs_cui_init(tp->t_mountp, count);
	99	ASSERT(cuip != NULL);
	100
	101	/*
	102	* Get a log_item_desc to point at the new item.
	103	*/
	104	xfs_trans_add_item(tp, &cuip->cui_item);
	105	return cuip;
	106	}
	107
	108	/* Set the phys extent flags for this reverse mapping. */
	109	static void
	110	xfs_trans_set_refcount_flags(
	111	struct xfs_phys_extent *refc,
	112	enum xfs_refcount_intent_type type)
	113	{
	114	refc->pe_flags = 0;
	115	switch (type) {
	116	case XFS_REFCOUNT_INCREASE:
	117	case XFS_REFCOUNT_DECREASE:
	118	case XFS_REFCOUNT_ALLOC_COW:
	119	case XFS_REFCOUNT_FREE_COW:
	120	refc->pe_flags \|= type;
	121	break;
	122	default:
	123	ASSERT(0);
	124	}
	125	}
	126
	127	/* Log refcount updates in the intent item. */
	128	STATIC void
	129	xfs_refcount_update_log_item(
	130	struct xfs_trans *tp,
	131	void *intent,
	132	struct list_head *item)
133	{
134	struct xfs_cui_log_item *cuip = intent;
135	struct xfs_refcount_intent *refc;
136	uint next_extent;
137	struct xfs_phys_extent *ext;
138
139	refc = container_of(item, struct xfs_refcount_intent, ri_list);
140
141	tp->t_flags \|= XFS_TRANS_DIRTY;
e6631f85	142	set_bit(XFS_LI_DIRTY, &cuip->cui_item.li_flags);
33ba6129 DW	143
	144	/*
	145	* atomic_inc_return gives us the value after the increment;
	146	* we want to use it as an array index so we need to subtract 1 from
	147	* it.
	148	*/
	149	next_extent = atomic_inc_return(&cuip->cui_next_extent) - 1;
	150	ASSERT(next_extent < cuip->cui_format.cui_nextents);
	151	ext = &cuip->cui_format.cui_extents[next_extent];
	152	ext->pe_startblock = refc->ri_startblock;
	153	ext->pe_len = refc->ri_blockcount;
	154	xfs_trans_set_refcount_flags(ext, refc->ri_type);
	155	}
	156
	157	/* Get an CUD so we can process all the deferred refcount updates. */
	158	STATIC void *
	159	xfs_refcount_update_create_done(
	160	struct xfs_trans *tp,
	161	void *intent,
	162	unsigned int count)
	163	{
	164	return xfs_trans_get_cud(tp, intent);
	165	}
	166
	167	/* Process a deferred refcount update. */
	168	STATIC int
	169	xfs_refcount_update_finish_item(
	170	struct xfs_trans *tp,
33ba6129 DW	171	struct list_head *item,
	172	void *done_item,
	173	void **state)
	174	{
	175	struct xfs_refcount_intent *refc;
	176	xfs_fsblock_t new_fsb;
	177	xfs_extlen_t new_aglen;
	178	int error;
	179
	180	refc = container_of(item, struct xfs_refcount_intent, ri_list);
7dbddbac	181	error = xfs_trans_log_finish_refcount_update(tp, done_item,
33ba6129 DW	182	refc->ri_type,
	183	refc->ri_startblock,
	184	refc->ri_blockcount,
	185	&new_fsb, &new_aglen,
	186	(struct xfs_btree_cur **)state);
	187	/* Did we run out of reservation? Requeue what we didn't finish. */
	188	if (!error && new_aglen > 0) {
	189	ASSERT(refc->ri_type == XFS_REFCOUNT_INCREASE \|\|
	190	refc->ri_type == XFS_REFCOUNT_DECREASE);
	191	refc->ri_startblock = new_fsb;
	192	refc->ri_blockcount = new_aglen;
	193	return -EAGAIN;
	194	}
	195	kmem_free(refc);
	196	return error;
	197	}
	198
	199	/* Clean up after processing deferred refcounts. */
	200	STATIC void
	201	xfs_refcount_update_finish_cleanup(
	202	struct xfs_trans *tp,
	203	void *state,
	204	int error)
	205	{
	206	struct xfs_btree_cur *rcur = state;
	207
	208	xfs_refcount_finish_one_cleanup(tp, rcur, error);
	209	}
	210
	211	/* Abort all pending CUIs. */
	212	STATIC void
	213	xfs_refcount_update_abort_intent(
	214	void *intent)
	215	{
	216	xfs_cui_release(intent);
	217	}
	218
	219	/* Cancel a deferred refcount update. */
	220	STATIC void
	221	xfs_refcount_update_cancel_item(
	222	struct list_head *item)
	223	{
	224	struct xfs_refcount_intent *refc;
	225
	226	refc = container_of(item, struct xfs_refcount_intent, ri_list);
	227	kmem_free(refc);
	228	}
	229
	230	static const struct xfs_defer_op_type xfs_refcount_update_defer_type = {
	231	.type = XFS_DEFER_OPS_TYPE_REFCOUNT,
	232	.max_items = XFS_CUI_MAX_FAST_EXTENTS,
	233	.diff_items = xfs_refcount_update_diff_items,
	234	.create_intent = xfs_refcount_update_create_intent,
	235	.abort_intent = xfs_refcount_update_abort_intent,
	236	.log_item = xfs_refcount_update_log_item,
	237	.create_done = xfs_refcount_update_create_done,
	238	.finish_item = xfs_refcount_update_finish_item,
	239	.finish_cleanup = xfs_refcount_update_finish_cleanup,
	240	.cancel_item = xfs_refcount_update_cancel_item,
	241	};
	242
	243	/* Register the deferred op type. */
	244	void
	245	xfs_refcount_update_init_defer_op(void)
246	{
247	xfs_defer_init_op_type(&xfs_refcount_update_defer_type);
248	}