[thirdparty/e2fsprogs.git] / contrib / android / basefs_allocator.c

#include <limits.h>
#include <sys/types.h>
#include <sys/stat.h>
#include "basefs_allocator.h"
#include "block_range.h"
#include "hashmap.h"
#include "base_fs.h"

struct base_fs_allocator {
	struct ext2fs_hashmap *entries;
	struct basefs_entry *cur_entry;
	/* The next expected logical block to allocate for cur_entry. */
	blk64_t next_lblk;
	/* Blocks which are definitely owned by a single inode in BaseFS. */
	ext2fs_block_bitmap exclusive_block_map;
	/* Blocks which are available to the first inode that requests it. */
	ext2fs_block_bitmap dedup_block_map;
};

static errcode_t basefs_block_allocator(ext2_filsys, blk64_t, blk64_t *,
					struct blk_alloc_ctx *ctx);

/*
 * Free any reserved, but unconsumed block ranges in the allocator. This both
 * frees the block_range_list data structure and unreserves exclusive blocks
 * from the block map.
 */
static void fs_free_blocks_range(ext2_filsys fs,
				 struct base_fs_allocator *allocator,
				 struct block_range_list *list)
{
	ext2fs_block_bitmap exclusive_map = allocator->exclusive_block_map;

	blk64_t block;
	while (list->head) {
		block = consume_next_block(list);
		if (ext2fs_test_block_bitmap2(exclusive_map, block)) {
			ext2fs_unmark_block_bitmap2(fs->block_map, block);
			ext2fs_unmark_block_bitmap2(exclusive_map, block);
		}
	}
}

/*
 * Free any blocks in the bitmap that were reserved but never used. This is
 * needed to free dedup_block_map and ensure the free block bitmap is
 * internally consistent.
 */
static void fs_free_blocks_bitmap(ext2_filsys fs, ext2fs_block_bitmap bitmap)
{
	blk64_t block = 0;
	blk64_t start = fs->super->s_first_data_block;
	blk64_t end = ext2fs_blocks_count(fs->super) - 1;
	errcode_t retval;

	for (;;) {
		retval = ext2fs_find_first_set_block_bitmap2(bitmap, start, end,
			&block);
		if (retval)
			break;
		ext2fs_unmark_block_bitmap2(fs->block_map, block);
		start = block + 1;
	}
}

static void basefs_allocator_free(ext2_filsys fs,
				  struct base_fs_allocator *allocator)
{
	struct basefs_entry *e;
	struct ext2fs_hashmap_entry *it = NULL;
	struct ext2fs_hashmap *entries = allocator->entries;

	if (entries) {
		while ((e = ext2fs_hashmap_iter_in_order(entries, &it))) {
			fs_free_blocks_range(fs, allocator, &e->blocks);
			delete_block_ranges(&e->blocks);
		}
		ext2fs_hashmap_free(entries);
	}
	fs_free_blocks_bitmap(fs, allocator->dedup_block_map);
	ext2fs_free_block_bitmap(allocator->exclusive_block_map);
	ext2fs_free_block_bitmap(allocator->dedup_block_map);
	free(allocator);
}

/*
 * Build a bitmap of which blocks are definitely owned by exactly one file in
 * Base FS. Blocks which are not valid or are de-duplicated are skipped. This
 * is called during allocator initialization, to ensure that libext2fs does
 * not allocate which we want to re-use.
 *
 * If a block was allocated in the initial filesystem, it can never be re-used,
 * so it will appear in neither the exclusive or dedup set. If a block is used
 * by multiple files, it will be removed from the owned set and instead added
 * to the dedup set.
 *
 * The dedup set is not removed from fs->block_map. This allows us to re-use
 * dedup blocks separately and not have them be allocated outside of file data.
 */
static void fs_reserve_block(ext2_filsys fs,
			     struct base_fs_allocator *allocator,
			     blk64_t block)
{
	ext2fs_block_bitmap exclusive_map = allocator->exclusive_block_map;
	ext2fs_block_bitmap dedup_map = allocator->dedup_block_map;

	if (block >= ext2fs_blocks_count(fs->super))
		return;

	if (ext2fs_test_block_bitmap2(fs->block_map, block)) {
		if (!ext2fs_test_block_bitmap2(exclusive_map, block))
			return;
		ext2fs_unmark_block_bitmap2(exclusive_map, block);
		ext2fs_mark_block_bitmap2(dedup_map, block);
	} else {
		ext2fs_mark_block_bitmap2(fs->block_map, block);
		ext2fs_mark_block_bitmap2(exclusive_map, block);
	}
}

static void fs_reserve_blocks_range(ext2_filsys fs,
				    struct base_fs_allocator *allocator,
				    struct block_range_list *list)
{
	blk64_t block;
	struct block_range *blocks = list->head;

	while (blocks) {
		for (block = blocks->start; block <= blocks->end; block++)
			fs_reserve_block(fs, allocator, block);
		blocks = blocks->next;
	}
}

/*
 * For each file in the base FS map, ensure that its blocks are reserved in
 * the actual block map. This prevents libext2fs from allocating them for
 * general purpose use, and ensures that if the file needs data blocks, they
 * can be re-acquired exclusively for that file.
 *
 * If a file in the base map is missing, or not a regular file in the new
 * filesystem, then it's skipped to ensure that its blocks are reusable.
 */
static errcode_t fs_reserve_blocks(ext2_filsys fs,
			      struct base_fs_allocator *allocator,
			      const char *src_dir)
{
	int nbytes;
	char full_path[PATH_MAX];
	const char *sep = "/";
	struct stat st;
	struct basefs_entry *e;
	struct ext2fs_hashmap_entry *it = NULL;
	struct ext2fs_hashmap *entries = allocator->entries;

	if (strlen(src_dir) && src_dir[strlen(src_dir) - 1] == '/')
		sep = "";

	while ((e = ext2fs_hashmap_iter_in_order(entries, &it))) {
		nbytes = snprintf(full_path, sizeof(full_path), "%s%s%s",
			src_dir, sep, e->path);
		if (nbytes >= sizeof(full_path))
			return ENAMETOOLONG;
		if (lstat(full_path, &st) || !S_ISREG(st.st_mode))
			continue;
		fs_reserve_blocks_range(fs, allocator, &e->blocks);
	}
	return 0;
}

errcode_t base_fs_alloc_load(ext2_filsys fs, const char *file,
			     const char *mountpoint, const char *src_dir)
{
	errcode_t retval = 0;
	struct base_fs_allocator *allocator;

	allocator = calloc(1, sizeof(*allocator));
	if (!allocator) {
		retval = ENOMEM;
		goto out;
	}

	retval = ext2fs_read_bitmaps(fs);
	if (retval)
		goto err_load;

	allocator->cur_entry = NULL;
	allocator->entries = basefs_parse(file, mountpoint);
	if (!allocator->entries) {
		retval = EIO;
		goto err_load;
	}
	retval = ext2fs_allocate_block_bitmap(fs, "exclusive map",
		&allocator->exclusive_block_map);
	if (retval)
		goto err_load;
	retval = ext2fs_allocate_block_bitmap(fs, "dedup map",
		&allocator->dedup_block_map);
	if (retval)
		goto err_load;

	retval = fs_reserve_blocks(fs, allocator, src_dir);
	if (retval)
		goto err_load;

	/* Override the default allocator */
	fs->get_alloc_block2 = basefs_block_allocator;
	fs->priv_data = allocator;

	goto out;

err_load:
	basefs_allocator_free(fs, allocator);
out:
	return retval;
}

/* Try and acquire the next usable block from the Base FS map. */
static int get_next_block(ext2_filsys fs, struct base_fs_allocator *allocator,
			  struct block_range_list* list, blk64_t *ret)
{
	blk64_t block;
	ext2fs_block_bitmap exclusive_map = allocator->exclusive_block_map;
	ext2fs_block_bitmap dedup_map = allocator->dedup_block_map;

	while (list->head) {
		block = consume_next_block(list);
		if (block >= ext2fs_blocks_count(fs->super))
			continue;
		if (ext2fs_test_block_bitmap2(exclusive_map, block)) {
			ext2fs_unmark_block_bitmap2(exclusive_map, block);
			*ret = block;
			return 0;
		}
		if (ext2fs_test_block_bitmap2(dedup_map, block)) {
			ext2fs_unmark_block_bitmap2(dedup_map, block);
			*ret = block;
			return 0;
		}
	}
	return -1;
}

/*
 * BaseFS lists blocks in logical block order. However, the allocator hook is
 * only called if a block needs to be allocated. In the case of a deduplicated
 * block, or a hole, the hook is not invoked. This means the next block
 * allocation request will be out of sequence. For example, consider if BaseFS
 * specifies the following (0 being a hole):
 *     1 2 3 0 4 5
 *
 * If the new file has a hole at logical block 0, we could accidentally
 * shift the entire expected block list as follows:
 *     0 1 2 0 3 4
 *
 * To account for this, we track the next expected logical block in the
 * allocator. If the current request is for a later logical block, we skip and
 * free the intermediate physical blocks that would have been allocated. This
 * ensures the original block assignment is respected.
 */
static void skip_blocks(ext2_filsys fs, struct base_fs_allocator *allocator,
			struct blk_alloc_ctx *ctx)
{
	blk64_t block;
	struct block_range_list *list = &allocator->cur_entry->blocks;
	ext2fs_block_bitmap exclusive_map = allocator->exclusive_block_map;

	while (list->head && allocator->next_lblk < ctx->lblk) {
		block = consume_next_block(list);
		if (block >= ext2fs_blocks_count(fs->super))
			continue;
		if (ext2fs_test_block_bitmap2(exclusive_map, block)) {
			ext2fs_unmark_block_bitmap2(exclusive_map, block);
			ext2fs_unmark_block_bitmap2(fs->block_map, block);
		}
		allocator->next_lblk++;
	}
}

static errcode_t basefs_block_allocator(ext2_filsys fs, blk64_t goal,
					blk64_t *ret, struct blk_alloc_ctx *ctx)
{
	errcode_t retval;
	struct base_fs_allocator *allocator = fs->priv_data;
	struct basefs_entry *e = allocator->cur_entry;
	ext2fs_block_bitmap dedup_map = allocator->dedup_block_map;

	if (e && ctx && (ctx->flags & BLOCK_ALLOC_DATA)) {
		if (allocator->next_lblk < ctx->lblk)
			skip_blocks(fs, allocator, ctx);
		allocator->next_lblk = ctx->lblk + 1;

		if (!get_next_block(fs, allocator, &e->blocks, ret))
			return 0;
	}

	retval = ext2fs_new_block2(fs, goal, fs->block_map, ret);
	if (!retval) {
		ext2fs_mark_block_bitmap2(fs->block_map, *ret);
		return 0;
	}
	if (retval == EXT2_ET_BLOCK_ALLOC_FAIL) {
		/* Try to steal a block from the dedup pool. */
		retval = ext2fs_find_first_set_block_bitmap2(dedup_map,
			fs->super->s_first_data_block,
			ext2fs_blocks_count(fs->super) - 1, ret);
		if (!retval) {
			ext2fs_unmark_block_bitmap2(dedup_map, *ret);
			return 0;
		}
	}
	return retval;
}

void base_fs_alloc_cleanup(ext2_filsys fs)
{
	basefs_allocator_free(fs, fs->priv_data);
	fs->priv_data = NULL;
	fs->get_alloc_block2 = NULL;
}

errcode_t base_fs_alloc_set_target(ext2_filsys fs, const char *target_path,
	const char *name EXT2FS_ATTR((unused)),
	ext2_ino_t parent_ino EXT2FS_ATTR((unused)),
	ext2_ino_t root EXT2FS_ATTR((unused)), mode_t mode)
{
	struct base_fs_allocator *allocator = fs->priv_data;

	if (mode != S_IFREG)
		return 0;

	if (allocator) {
		allocator->cur_entry = ext2fs_hashmap_lookup(allocator->entries,
						      target_path,
						      strlen(target_path));
		allocator->next_lblk = 0;
	}
	return 0;
}

errcode_t base_fs_alloc_unset_target(ext2_filsys fs,
        const char *target_path EXT2FS_ATTR((unused)),
	const char *name EXT2FS_ATTR((unused)),
	ext2_ino_t parent_ino EXT2FS_ATTR((unused)),
	ext2_ino_t root EXT2FS_ATTR((unused)), mode_t mode)
{
	struct base_fs_allocator *allocator = fs->priv_data;

	if (!allocator || !allocator->cur_entry || mode != S_IFREG)
		return 0;

	fs_free_blocks_range(fs, allocator, &allocator->cur_entry->blocks);
	delete_block_ranges(&allocator->cur_entry->blocks);
	return 0;
}
Commit	Line	Data
67467ea5	1	#include <limits.h>
d0ed0ab8 AS	2	#include <sys/types.h>
	3	#include <sys/stat.h>
	4	#include "basefs_allocator.h"
	5	#include "block_range.h"
	6	#include "hashmap.h"
	7	#include "base_fs.h"
	8
	9	struct base_fs_allocator {
555a0fce	10	struct ext2fs_hashmap *entries;
d0ed0ab8	11	struct basefs_entry *cur_entry;
58ecfa7f DA	12	/* The next expected logical block to allocate for cur_entry. */
58ecfa7f DA	13	blk64_t next_lblk;
af4d3f89 DA	14	/* Blocks which are definitely owned by a single inode in BaseFS. */
af4d3f89 DA	15	ext2fs_block_bitmap exclusive_block_map;
0f3291fd DA	16	/* Blocks which are available to the first inode that requests it. */
0f3291fd DA	17	ext2fs_block_bitmap dedup_block_map;
d0ed0ab8 AS	18	};
	19
	20	static errcode_t basefs_block_allocator(ext2_filsys, blk64_t, blk64_t *,
	21	struct blk_alloc_ctx *ctx);
	22
af4d3f89 DA	23	/*
	24	* Free any reserved, but unconsumed block ranges in the allocator. This both
	25	* frees the block_range_list data structure and unreserves exclusive blocks
	26	* from the block map.
	27	*/
269f4c1b	28	static void fs_free_blocks_range(ext2_filsys fs,
af4d3f89	29	struct base_fs_allocator *allocator,
269f4c1b	30	struct block_range_list *list)
d0ed0ab8	31	{
af4d3f89 DA	32	ext2fs_block_bitmap exclusive_map = allocator->exclusive_block_map;
	33
	34	blk64_t block;
	35	while (list->head) {
	36	block = consume_next_block(list);
	37	if (ext2fs_test_block_bitmap2(exclusive_map, block)) {
	38	ext2fs_unmark_block_bitmap2(fs->block_map, block);
	39	ext2fs_unmark_block_bitmap2(exclusive_map, block);
	40	}
d0ed0ab8 AS	41	}
	42	}
	43
c2481ace DA	44	/*
	45	* Free any blocks in the bitmap that were reserved but never used. This is
	46	* needed to free dedup_block_map and ensure the free block bitmap is
	47	* internally consistent.
	48	*/
	49	static void fs_free_blocks_bitmap(ext2_filsys fs, ext2fs_block_bitmap bitmap)
	50	{
	51	blk64_t block = 0;
	52	blk64_t start = fs->super->s_first_data_block;
	53	blk64_t end = ext2fs_blocks_count(fs->super) - 1;
	54	errcode_t retval;
	55
	56	for (;;) {
	57	retval = ext2fs_find_first_set_block_bitmap2(bitmap, start, end,
	58	&block);
	59	if (retval)
	60	break;
	61	ext2fs_unmark_block_bitmap2(fs->block_map, block);
	62	start = block + 1;
	63	}
	64	}
	65
dcbe79c4 DA	66	static void basefs_allocator_free(ext2_filsys fs,
	67	struct base_fs_allocator *allocator)
	68	{
	69	struct basefs_entry *e;
	70	struct ext2fs_hashmap_entry *it = NULL;
	71	struct ext2fs_hashmap *entries = allocator->entries;
	72
	73	if (entries) {
	74	while ((e = ext2fs_hashmap_iter_in_order(entries, &it))) {
af4d3f89	75	fs_free_blocks_range(fs, allocator, &e->blocks);
dcbe79c4 DA	76	delete_block_ranges(&e->blocks);
	77	}
	78	ext2fs_hashmap_free(entries);
	79	}
c2481ace	80	fs_free_blocks_bitmap(fs, allocator->dedup_block_map);
af4d3f89	81	ext2fs_free_block_bitmap(allocator->exclusive_block_map);
0f3291fd	82	ext2fs_free_block_bitmap(allocator->dedup_block_map);
dcbe79c4 DA	83	free(allocator);
	84	}
	85
af4d3f89 DA	86	/*
	87	* Build a bitmap of which blocks are definitely owned by exactly one file in
	88	* Base FS. Blocks which are not valid or are de-duplicated are skipped. This
	89	* is called during allocator initialization, to ensure that libext2fs does
	90	* not allocate which we want to re-use.
0f3291fd DA	91	*
	92	* If a block was allocated in the initial filesystem, it can never be re-used,
	93	* so it will appear in neither the exclusive or dedup set. If a block is used
	94	* by multiple files, it will be removed from the owned set and instead added
	95	* to the dedup set.
	96	*
	97	* The dedup set is not removed from fs->block_map. This allows us to re-use
	98	* dedup blocks separately and not have them be allocated outside of file data.
af4d3f89 DA	99	*/
	100	static void fs_reserve_block(ext2_filsys fs,
	101	struct base_fs_allocator *allocator,
	102	blk64_t block)
	103	{
	104	ext2fs_block_bitmap exclusive_map = allocator->exclusive_block_map;
0f3291fd	105	ext2fs_block_bitmap dedup_map = allocator->dedup_block_map;
af4d3f89 DA	106
	107	if (block >= ext2fs_blocks_count(fs->super))
	108	return;
	109
	110	if (ext2fs_test_block_bitmap2(fs->block_map, block)) {
0f3291fd DA	111	if (!ext2fs_test_block_bitmap2(exclusive_map, block))
0f3291fd DA	112	return;
af4d3f89	113	ext2fs_unmark_block_bitmap2(exclusive_map, block);
0f3291fd	114	ext2fs_mark_block_bitmap2(dedup_map, block);
af4d3f89 DA	115	} else {
	116	ext2fs_mark_block_bitmap2(fs->block_map, block);
	117	ext2fs_mark_block_bitmap2(exclusive_map, block);
	118	}
	119	}
	120
269f4c1b	121	static void fs_reserve_blocks_range(ext2_filsys fs,
af4d3f89	122	struct base_fs_allocator *allocator,
269f4c1b	123	struct block_range_list *list)
d0ed0ab8	124	{
af4d3f89	125	blk64_t block;
269f4c1b	126	struct block_range *blocks = list->head;
af4d3f89	127
d0ed0ab8	128	while (blocks) {
af4d3f89 DA	129	for (block = blocks->start; block <= blocks->end; block++)
af4d3f89 DA	130	fs_reserve_block(fs, allocator, block);
d0ed0ab8 AS	131	blocks = blocks->next;
	132	}
	133	}
	134
dcbe79c4 DA	135	/*
	136	* For each file in the base FS map, ensure that its blocks are reserved in
	137	* the actual block map. This prevents libext2fs from allocating them for
	138	* general purpose use, and ensures that if the file needs data blocks, they
	139	* can be re-acquired exclusively for that file.
67467ea5 DA	140	*
	141	* If a file in the base map is missing, or not a regular file in the new
	142	* filesystem, then it's skipped to ensure that its blocks are reusable.
dcbe79c4	143	*/
67467ea5 DA	144	static errcode_t fs_reserve_blocks(ext2_filsys fs,
	145	struct base_fs_allocator *allocator,
	146	const char *src_dir)
d0ed0ab8	147	{
67467ea5 DA	148	int nbytes;
	149	char full_path[PATH_MAX];
	150	const char *sep = "/";
	151	struct stat st;
d0ed0ab8	152	struct basefs_entry *e;
555a0fce	153	struct ext2fs_hashmap_entry *it = NULL;
dcbe79c4 DA	154	struct ext2fs_hashmap *entries = allocator->entries;
dcbe79c4 DA	155
67467ea5 DA	156	if (strlen(src_dir) && src_dir[strlen(src_dir) - 1] == '/')
	157	sep = "";
	158
	159	while ((e = ext2fs_hashmap_iter_in_order(entries, &it))) {
	160	nbytes = snprintf(full_path, sizeof(full_path), "%s%s%s",
	161	src_dir, sep, e->path);
	162	if (nbytes >= sizeof(full_path))
	163	return ENAMETOOLONG;
	164	if (lstat(full_path, &st) \|\| !S_ISREG(st.st_mode))
	165	continue;
af4d3f89	166	fs_reserve_blocks_range(fs, allocator, &e->blocks);
67467ea5 DA	167	}
67467ea5 DA	168	return 0;
dcbe79c4 DA	169	}
	170
	171	errcode_t base_fs_alloc_load(ext2_filsys fs, const char *file,
67467ea5	172	const char mountpoint, const char src_dir)
dcbe79c4 DA	173	{
dcbe79c4 DA	174	errcode_t retval = 0;
d0ed0ab8	175	struct base_fs_allocator *allocator;
d0ed0ab8	176
dcbe79c4 DA	177	allocator = calloc(1, sizeof(*allocator));
	178	if (!allocator) {
	179	retval = ENOMEM;
	180	goto out;
	181	}
d0ed0ab8 AS	182
	183	retval = ext2fs_read_bitmaps(fs);
	184	if (retval)
af4d3f89	185	goto err_load;
d0ed0ab8 AS	186
d0ed0ab8 AS	187	allocator->cur_entry = NULL;
dcbe79c4 DA	188	allocator->entries = basefs_parse(file, mountpoint);
	189	if (!allocator->entries) {
	190	retval = EIO;
af4d3f89	191	goto err_load;
dcbe79c4	192	}
af4d3f89 DA	193	retval = ext2fs_allocate_block_bitmap(fs, "exclusive map",
	194	&allocator->exclusive_block_map);
	195	if (retval)
	196	goto err_load;
0f3291fd DA	197	retval = ext2fs_allocate_block_bitmap(fs, "dedup map",
	198	&allocator->dedup_block_map);
	199	if (retval)
	200	goto err_load;
dcbe79c4	201
67467ea5 DA	202	retval = fs_reserve_blocks(fs, allocator, src_dir);
	203	if (retval)
	204	goto err_load;
d0ed0ab8	205
70964797	206	/* Override the default allocator */
d0ed0ab8 AS	207	fs->get_alloc_block2 = basefs_block_allocator;
	208	fs->priv_data = allocator;
	209
dcbe79c4	210	goto out;
d0ed0ab8	211
af4d3f89	212	err_load:
dcbe79c4 DA	213	basefs_allocator_free(fs, allocator);
	214	out:
	215	return retval;
d0ed0ab8 AS	216	}
d0ed0ab8 AS	217
af4d3f89 DA	218	/* Try and acquire the next usable block from the Base FS map. */
	219	static int get_next_block(ext2_filsys fs, struct base_fs_allocator *allocator,
	220	struct block_range_list* list, blk64_t *ret)
	221	{
	222	blk64_t block;
	223	ext2fs_block_bitmap exclusive_map = allocator->exclusive_block_map;
0f3291fd	224	ext2fs_block_bitmap dedup_map = allocator->dedup_block_map;
af4d3f89 DA	225
	226	while (list->head) {
	227	block = consume_next_block(list);
	228	if (block >= ext2fs_blocks_count(fs->super))
	229	continue;
	230	if (ext2fs_test_block_bitmap2(exclusive_map, block)) {
	231	ext2fs_unmark_block_bitmap2(exclusive_map, block);
	232	*ret = block;
	233	return 0;
	234	}
0f3291fd DA	235	if (ext2fs_test_block_bitmap2(dedup_map, block)) {
	236	ext2fs_unmark_block_bitmap2(dedup_map, block);
	237	*ret = block;
	238	return 0;
	239	}
af4d3f89 DA	240	}
	241	return -1;
	242	}
	243
58ecfa7f DA	244	/*
	245	* BaseFS lists blocks in logical block order. However, the allocator hook is
	246	* only called if a block needs to be allocated. In the case of a deduplicated
	247	* block, or a hole, the hook is not invoked. This means the next block
	248	* allocation request will be out of sequence. For example, consider if BaseFS
	249	* specifies the following (0 being a hole):
	250	* 1 2 3 0 4 5
	251	*
	252	* If the new file has a hole at logical block 0, we could accidentally
	253	* shift the entire expected block list as follows:
	254	* 0 1 2 0 3 4
	255	*
	256	* To account for this, we track the next expected logical block in the
	257	* allocator. If the current request is for a later logical block, we skip and
	258	* free the intermediate physical blocks that would have been allocated. This
	259	* ensures the original block assignment is respected.
	260	*/
	261	static void skip_blocks(ext2_filsys fs, struct base_fs_allocator *allocator,
	262	struct blk_alloc_ctx *ctx)
	263	{
	264	blk64_t block;
	265	struct block_range_list *list = &allocator->cur_entry->blocks;
	266	ext2fs_block_bitmap exclusive_map = allocator->exclusive_block_map;
	267
	268	while (list->head && allocator->next_lblk < ctx->lblk) {
	269	block = consume_next_block(list);
	270	if (block >= ext2fs_blocks_count(fs->super))
	271	continue;
	272	if (ext2fs_test_block_bitmap2(exclusive_map, block)) {
	273	ext2fs_unmark_block_bitmap2(exclusive_map, block);
	274	ext2fs_unmark_block_bitmap2(fs->block_map, block);
	275	}
	276	allocator->next_lblk++;
	277	}
	278	}
	279
d0ed0ab8 AS	280	static errcode_t basefs_block_allocator(ext2_filsys fs, blk64_t goal,
	281	blk64_t ret, struct blk_alloc_ctx ctx)
	282	{
	283	errcode_t retval;
d0ed0ab8 AS	284	struct base_fs_allocator *allocator = fs->priv_data;
d0ed0ab8 AS	285	struct basefs_entry *e = allocator->cur_entry;
67467ea5	286	ext2fs_block_bitmap dedup_map = allocator->dedup_block_map;
d0ed0ab8	287
af4d3f89	288	if (e && ctx && (ctx->flags & BLOCK_ALLOC_DATA)) {
58ecfa7f DA	289	if (allocator->next_lblk < ctx->lblk)
	290	skip_blocks(fs, allocator, ctx);
	291	allocator->next_lblk = ctx->lblk + 1;
	292
af4d3f89 DA	293	if (!get_next_block(fs, allocator, &e->blocks, ret))
af4d3f89 DA	294	return 0;
d0ed0ab8	295	}
af4d3f89 DA	296
af4d3f89 DA	297	retval = ext2fs_new_block2(fs, goal, fs->block_map, ret);
67467ea5 DA	298	if (!retval) {
	299	ext2fs_mark_block_bitmap2(fs->block_map, *ret);
	300	return 0;
	301	}
	302	if (retval == EXT2_ET_BLOCK_ALLOC_FAIL) {
	303	/* Try to steal a block from the dedup pool. */
	304	retval = ext2fs_find_first_set_block_bitmap2(dedup_map,
	305	fs->super->s_first_data_block,
	306	ext2fs_blocks_count(fs->super) - 1, ret);
	307	if (!retval) {
	308	ext2fs_unmark_block_bitmap2(dedup_map, *ret);
	309	return 0;
	310	}
	311	}
	312	return retval;
d0ed0ab8 AS	313	}
	314
	315	void base_fs_alloc_cleanup(ext2_filsys fs)
	316	{
dcbe79c4	317	basefs_allocator_free(fs, fs->priv_data);
d0ed0ab8 AS	318	fs->priv_data = NULL;
d0ed0ab8 AS	319	fs->get_alloc_block2 = NULL;
d0ed0ab8 AS	320	}
	321
	322	errcode_t base_fs_alloc_set_target(ext2_filsys fs, const char *target_path,
	323	const char *name EXT2FS_ATTR((unused)),
	324	ext2_ino_t parent_ino EXT2FS_ATTR((unused)),
	325	ext2_ino_t root EXT2FS_ATTR((unused)), mode_t mode)
	326	{
	327	struct base_fs_allocator *allocator = fs->priv_data;
	328
	329	if (mode != S_IFREG)
	330	return 0;
	331
58ecfa7f	332	if (allocator) {
555a0fce JQ	333	allocator->cur_entry = ext2fs_hashmap_lookup(allocator->entries,
	334	target_path,
	335	strlen(target_path));
58ecfa7f DA	336	allocator->next_lblk = 0;
58ecfa7f DA	337	}
d0ed0ab8 AS	338	return 0;
	339	}
	340
	341	errcode_t base_fs_alloc_unset_target(ext2_filsys fs,
	342	const char *target_path EXT2FS_ATTR((unused)),
	343	const char *name EXT2FS_ATTR((unused)),
	344	ext2_ino_t parent_ino EXT2FS_ATTR((unused)),
	345	ext2_ino_t root EXT2FS_ATTR((unused)), mode_t mode)
	346	{
	347	struct base_fs_allocator *allocator = fs->priv_data;
	348
	349	if (!allocator \|\| !allocator->cur_entry \|\| mode != S_IFREG)
	350	return 0;
	351
af4d3f89	352	fs_free_blocks_range(fs, allocator, &allocator->cur_entry->blocks);
269f4c1b	353	delete_block_ranges(&allocator->cur_entry->blocks);
d0ed0ab8 AS	354	return 0;
d0ed0ab8 AS	355	}