#include "clusterautoconfig.h"
	
	#include <stdio.h>
	#include <stdlib.h>
	#include <string.h>
	#include <stdint.h>
	#include <inttypes.h>
	#include <sys/types.h>
	#include <sys/stat.h>
	#include <fcntl.h>
	#include <unistd.h>
	#include <errno.h>
	
	#include "libgfs2.h"
	#include "rgrp.h"
	
	static __inline__ __be64 *metapointer(char *buf,
						unsigned int height,
						struct lgfs2_metapath *mp)
	{
		unsigned int head_size = (height > 0) ?
			sizeof(struct gfs2_meta_header) : sizeof(struct gfs2_dinode);
	
		return ((__be64 *)(buf + head_size)) + mp->mp_list[height];
	}
	
	/* Detect directory is a stuffed inode */
	static int inode_is_stuffed(const struct lgfs2_inode *ip)
	{
		return !ip->i_height;
	}
	
	struct lgfs2_inode *lgfs2_inode_get(struct lgfs2_sbd *sdp, struct lgfs2_buffer_head *bh)
	{
		struct lgfs2_inode *ip;
	
		ip = calloc(1, sizeof(struct lgfs2_inode));
		if (ip == NULL) {
			return NULL;
		}
		lgfs2_dinode_in(ip, bh->b_data);
		ip->i_bh = bh;
		ip->i_sbd = sdp;
		return ip;
	}
	
	struct lgfs2_inode *lgfs2_inode_read(struct lgfs2_sbd *sdp, uint64_t di_addr)
	{
		struct lgfs2_inode *ip;
		struct lgfs2_buffer_head *bh = lgfs2_bread(sdp, di_addr);
		if (bh == NULL) {
			return NULL;
		}
		ip = lgfs2_inode_get(sdp, bh);
		if (ip == NULL) {
			lgfs2_brelse(bh);
			return NULL;
		}
		ip->bh_owned = 1; /* We did the lgfs2_bread so we own the bh */
		return ip;
	}
	
	struct lgfs2_inode *lgfs2_is_system_inode(struct lgfs2_sbd *sdp, uint64_t block)
	{
		int j;
	
		if (sdp->md.inum && block == sdp->md.inum->i_num.in_addr)
			return sdp->md.inum;
		if (sdp->md.statfs && block == sdp->md.statfs->i_num.in_addr)
			return sdp->md.statfs;
		if (sdp->md.jiinode && block == sdp->md.jiinode->i_num.in_addr)
			return sdp->md.jiinode;
		if (sdp->md.riinode && block == sdp->md.riinode->i_num.in_addr)
			return sdp->md.riinode;

		if (sdp->md.qinode && block == sdp->md.qinode->i_num.in_addr)
			return sdp->md.qinode;
		if (sdp->md.pinode && block == sdp->md.pinode->i_num.in_addr)
			return sdp->md.pinode;
		if (sdp->md.rooti && block == sdp->md.rooti->i_num.in_addr)
			return sdp->md.rooti;
		if (sdp->master_dir && block == sdp->master_dir->i_num.in_addr)
			return sdp->master_dir;
		for (j = 0; j < sdp->md.journals; j++)
			if (sdp->md.journal && sdp->md.journal[j] &&
			    block == sdp->md.journal[j]->i_num.in_addr)
				return sdp->md.journal[j];
		return NULL;
	}
	
	void lgfs2_inode_put(struct lgfs2_inode **ip_in)
	{

		struct lgfs2_inode *ip = *ip_in;

		uint64_t block = ip->i_num.in_addr;
		struct lgfs2_sbd *sdp = ip->i_sbd;
	
		if (ip->i_bh != NULL) {
			if (ip->i_bh->b_modified) {
				lgfs2_dinode_out(ip, ip->i_bh->b_data);
				if (!ip->bh_owned && lgfs2_is_system_inode(sdp, block))
					fprintf(stderr, "Warning: Changes made to inode were discarded.\n");
			}
			if (ip->bh_owned)
				lgfs2_brelse(ip->i_bh);
			ip->i_bh = NULL;
		}
		free(ip);
		*ip_in = NULL; /* make sure the memory isn't accessed again */
	}
	
	/**
	 * Free an inode, discarding modifications.
	 * @ipp: A pointer to the inode.
	 */
	void lgfs2_inode_free(struct lgfs2_inode **ipp)
	{
		struct lgfs2_inode *ip = *ipp;
	
		free(ip->i_bh);
		free(ip);
		*ipp = NULL;
	}
	
	static uint64_t find_free_block(struct lgfs2_rgrp_tree *rgd)
	{
		unsigned bm;
		uint64_t blkno = 0;
	
		if (rgd == NULL || rgd->rt_free == 0) {
			errno = ENOSPC;
			return 0;
		}
	
		for (bm = 0; bm < rgd->rt_length; bm++) {
			unsigned long blk = 0;
			struct lgfs2_bitmap *bits = &rgd->rt_bits[bm];
	
			blk = lgfs2_bitfit((uint8_t *)bits->bi_data + bits->bi_offset,
			                  bits->bi_len, blk, GFS2_BLKST_FREE);
			if (blk != LGFS2_BFITNOENT) {
				blkno = blk + (bits->bi_start * GFS2_NBBY) + rgd->rt_data0;
				break;
			}
		}
		return blkno;
	}
	
	static int blk_alloc_in_rg(struct lgfs2_sbd *sdp, unsigned state, struct lgfs2_rgrp_tree *rgd, uint64_t blkno, int dinode)
	{
		if (blkno == 0)
			return -1;
	
		if (lgfs2_set_bitmap(rgd, blkno, state))
			return -1;
	
		if (state == GFS2_BLKST_DINODE) {
			if (dinode)
				rgd->rt_dinodes++;
		}
	
		rgd->rt_free--;
		lgfs2_rgrp_out(rgd, rgd->rt_bits[0].bi_data);
		rgd->rt_bits[0].bi_modified = 1;
		sdp->blks_alloced++;
		return 0;
	}
	
	/**
	 * Allocate a block in a bitmap. In order to plan ahead we look for a
	 * resource group with blksreq free blocks but only allocate the one block.
	 * Returns 0 on success with the allocated block number in *blkno or non-zero otherwise.
	 */
	static int block_alloc(struct lgfs2_sbd *sdp, const uint64_t blksreq, int state, uint64_t *blkno, int dinode)
	{
		int ret;
		int release = 0;
		struct lgfs2_rgrp_tree *rgt = NULL;
		struct osi_node *n = NULL;
		uint64_t bn = 0;
	
		for (n = osi_first(&sdp->rgtree); n; n = osi_next(n)) {
			rgt = (struct lgfs2_rgrp_tree *)n;
			if (rgt->rt_free >= blksreq)
				break;
		}
		if (n == NULL)
			return -1;
	
		if (rgt->rt_bits[0].bi_data == NULL) {
			if (lgfs2_rgrp_read(sdp, rgt))
				return -1;
			release = 1;
		}
	
		bn = find_free_block(rgt);
		ret = blk_alloc_in_rg(sdp, state, rgt, bn, dinode);
		if (release)
			lgfs2_rgrp_relse(sdp, rgt);
		*blkno = bn;
		return ret;
	}
	
	int lgfs2_dinode_alloc(struct lgfs2_sbd *sdp, const uint64_t blksreq, uint64_t *blkno)
	{
		int ret = block_alloc(sdp, blksreq, GFS2_BLKST_DINODE, blkno, 1);
		if (ret == 0)
			sdp->dinodes_alloced++;
		return ret;
	}
	
	int lgfs2_meta_alloc(struct lgfs2_inode *ip, uint64_t *blkno)
	{
		int ret = block_alloc(ip->i_sbd, 1, GFS2_BLKST_USED, blkno, 0);
		if (ret == 0) {
			ip->i_goal_meta = *blkno;
			lgfs2_bmodified(ip->i_bh);
		}
		return ret;
	}
	
	static __inline__ void buffer_clear_tail(struct lgfs2_sbd *sdp,
						 struct lgfs2_buffer_head *bh, int head)
	{
		memset(bh->b_data + head, 0, sdp->sd_bsize - head);
		lgfs2_bmodified(bh);
	}
	
	static __inline__ void
	buffer_copy_tail(struct lgfs2_sbd *sdp,
			 struct lgfs2_buffer_head *to_bh, int to_head,
			 struct lgfs2_buffer_head *from_bh, int from_head)
	{
		memcpy(to_bh->b_data + to_head, from_bh->b_data + from_head,
		       sdp->sd_bsize - from_head);
		memset(to_bh->b_data + sdp->sd_bsize + to_head - from_head, 0,
		       from_head - to_head);
		lgfs2_bmodified(to_bh);
	}
	
	int lgfs2_unstuff_dinode(struct lgfs2_inode *ip)
	{
		struct lgfs2_sbd *sdp = ip->i_sbd;
		struct lgfs2_buffer_head *bh;
		uint64_t block = 0;
		int isdir = S_ISDIR(ip->i_mode);
	
		if (ip->i_size) {
			if (lgfs2_meta_alloc(ip, &block))
				return -1;
			if (isdir) {
				struct gfs2_meta_header mh = {
					.mh_magic = cpu_to_be32(GFS2_MAGIC),
					.mh_type = cpu_to_be32(GFS2_METATYPE_JD),
					.mh_format = cpu_to_be32(GFS2_FORMAT_JD)
				};
	
				bh = lgfs2_bget(sdp, block);
				memcpy(bh->b_data, &mh, sizeof(mh));
				buffer_copy_tail(sdp, bh,
						 sizeof(struct gfs2_meta_header),
						 ip->i_bh, sizeof(struct gfs2_dinode));
	
				lgfs2_bmodified(bh);
				lgfs2_brelse(bh);
			} else {
				bh = lgfs2_bget(sdp, block);
	
				buffer_copy_tail(sdp, bh, 0,
						 ip->i_bh, sizeof(struct gfs2_dinode));
				lgfs2_brelse(bh);
			}
		}
	
		buffer_clear_tail(sdp, ip->i_bh, sizeof(struct gfs2_dinode));
	
		if (ip->i_size) {
			*(__be64 *)(ip->i_bh->b_data + sizeof(struct gfs2_dinode)) = cpu_to_be64(block);
			/* no need: lgfs2_bmodified(ip->i_bh); buffer_clear_tail does it */
			ip->i_blocks++;
		}
	
		ip->i_height = 1;
		return 0;
	}
	
	/**
	 * Calculate the total number of blocks required by a file containing 'bytes' bytes of data.
	 */
	uint64_t lgfs2_space_for_data(const struct lgfs2_sbd *sdp, const unsigned bsize, const uint64_t bytes)
	{
		uint64_t blks = (bytes + bsize - 1) / bsize;
		uint64_t ptrs = blks;
	
		if (bytes <= bsize - sizeof(struct gfs2_dinode))
			return 1;
	
		while (ptrs > sdp->sd_diptrs) {
			ptrs = (ptrs + sdp->sd_inptrs - 1) / sdp->sd_inptrs;
			blks += ptrs;
		}
		return blks + 1;
	}
	
	/**
	 * Allocate an extent for a file in a resource group's bitmaps.
	 * rg: The resource group in which to allocate the extent
	 * di_size: The size of the file in bytes
	 * ip: A pointer to the inode structure, whose fields will be set appropriately.
	 *     If ip->i_num.no_addr is not 0, the extent search will be skipped and
	 *     the file allocated from that address.
	 * flags: GFS2_DIF_* flags
	 * mode: File mode flags, see creat(2)
	 * Returns 0 on success with the contents of ip set accordingly, or non-zero
	 * with errno set on error. If errno is ENOSPC then rg does not contain a
	 * large enough free extent for the given di_size.
	 */
	int lgfs2_file_alloc(lgfs2_rgrp_t rg, uint64_t di_size, struct lgfs2_inode *ip, uint32_t flags, unsigned mode)
	{
		unsigned extlen;
		struct lgfs2_sbd *sdp = rg->rt_rgrps->rgs_sdp;
		struct lgfs2_rbm rbm = { .rgd = rg, .offset = 0, .bii = 0 };
		uint32_t blocks = lgfs2_space_for_data(sdp, sdp->sd_bsize, di_size);
	
		if (ip->i_num.in_addr != 0) {
			if (lgfs2_rbm_from_block(&rbm, ip->i_num.in_addr) != 0)
				return 1;
		} else if (lgfs2_rbm_find(&rbm, GFS2_BLKST_FREE, &blocks) != 0) {
			return 1;
		}
	
		extlen = lgfs2_alloc_extent(&rbm, GFS2_BLKST_DINODE, blocks);
		if (extlen < blocks) {
			errno = EINVAL;
			return 1;
		}
	
		ip->i_sbd = sdp;
	
		ip->i_magic = GFS2_MAGIC;
		ip->i_mh_type = GFS2_METATYPE_DI;
		ip->i_format = GFS2_FORMAT_DI;
		ip->i_size = di_size;
		ip->i_num.in_addr = lgfs2_rbm_to_block(&rbm);
		ip->i_num.in_formal_ino = sdp->md.next_inum++;
		ip->i_mode = mode;
		ip->i_nlink = 1;
		ip->i_blocks = blocks;
		ip->i_atime = ip->i_mtime = ip->i_ctime = sdp->sd_time;
		ip->i_goal_data = ip->i_num.in_addr + ip->i_blocks - 1;
		ip->i_goal_meta = ip->i_goal_data - ((di_size + sdp->sd_bsize - 1) / sdp->sd_bsize);
		ip->i_height = lgfs2_calc_tree_height(ip, di_size);
		ip->i_flags = flags;
	
		rg->rt_free -= blocks;
		rg->rt_dinodes += 1;
	
		sdp->dinodes_alloced++;
		sdp->blks_alloced += blocks;
	
		return 0;
	}
	
	unsigned int lgfs2_calc_tree_height(struct lgfs2_inode *ip, uint64_t size)
	{
		struct lgfs2_sbd *sdp = ip->i_sbd;
		uint64_t *arr;
		unsigned int max, height;
	
		if (ip->i_size > size)
			size = ip->i_size;
	
		if (S_ISDIR(ip->i_mode)) {
			arr = sdp->sd_jheightsize;
			max = sdp->sd_max_jheight;
		} else {
			arr = sdp->sd_heightsize;
			max = sdp->sd_max_height;
		}
	
		for (height = 0; height < max; height++)
			if (arr[height] >= size)
				break;
	
		return height;
	}
	
	int lgfs2_build_height(struct lgfs2_inode *ip, int height)
	{
		struct lgfs2_sbd *sdp = ip->i_sbd;
		struct lgfs2_buffer_head *bh;
		uint64_t block = 0, *bp;
		unsigned int x;
		int new_block;
	
		while (ip->i_height < height) {
			new_block = 0;
			bp = (uint64_t *)(ip->i_bh->b_data + sizeof(struct gfs2_dinode));
			for (x = 0; x < sdp->sd_diptrs; x++, bp++)
				if (*bp) {
					new_block = 1;
					break;
				}
	
			if (new_block) {
				struct gfs2_meta_header mh = {
					.mh_magic = cpu_to_be32(GFS2_MAGIC),
					.mh_type = cpu_to_be32(GFS2_METATYPE_IN),
					.mh_format = cpu_to_be32(GFS2_FORMAT_IN)
				};
	
				if (lgfs2_meta_alloc(ip, &block))
					return -1;
				bh = lgfs2_bget(sdp, block);
				memcpy(bh->b_data, &mh, sizeof(mh));
				buffer_copy_tail(sdp, bh,
						 sizeof(struct gfs2_meta_header),
						 ip->i_bh, sizeof(struct gfs2_dinode));
				lgfs2_bmodified(bh);
				lgfs2_brelse(bh);
			}
	
			buffer_clear_tail(sdp, ip->i_bh, sizeof(struct gfs2_dinode));
	
			if (new_block) {
				*(__be64 *)(ip->i_bh->b_data + sizeof(struct gfs2_dinode)) = cpu_to_be64(block);
				/* no need: lgfs2_bmodified(ip->i_bh);*/
				ip->i_blocks++;
			}
	
			ip->i_height++;
		}
		return 0;
	}
	
	void lgfs2_find_metapath(struct lgfs2_inode *ip, uint64_t block, struct lgfs2_metapath *mp)
	{
		const uint32_t inptrs = ip->i_sbd->sd_inptrs;
		unsigned int i = ip->i_height;
	
		memset(mp, 0, sizeof(struct lgfs2_metapath));
		while (i--) {
			mp->mp_list[i] = block % inptrs;
			block /= inptrs;
		}
	}
	
	void lgfs2_lookup_block(struct lgfs2_inode *ip, struct lgfs2_buffer_head *bh,
	                        unsigned int height, struct lgfs2_metapath *mp,
	                        int create, int *new, uint64_t *block)
	{
		__be64 *ptr = metapointer(bh->b_data, height, mp);
	
		if (*ptr) {
			*block = be64_to_cpu(*ptr);
			return;
		}
	
		*block = 0;
	
		if (!create)
			return;
	
		if (lgfs2_meta_alloc(ip, block))
			return;
		*ptr = cpu_to_be64(*block);
		lgfs2_bmodified(bh);
		ip->i_blocks++;
		lgfs2_bmodified(ip->i_bh);
	
		*new = 1;
	}
	
	int lgfs2_block_map(struct lgfs2_inode *ip, uint64_t lblock, int *new,
	                     uint64_t *dblock, uint32_t *extlen, int prealloc)
	{
		struct lgfs2_sbd *sdp = ip->i_sbd;
		struct lgfs2_buffer_head *bh;
		struct lgfs2_metapath mp;
		int create = *new;
		unsigned int bsize;
		unsigned int height;
		unsigned int end_of_metadata;
		unsigned int x;
	
		*new = 0;
		*dblock = 0;
		if (extlen)
			*extlen = 0;
	
		if (inode_is_stuffed(ip)) {
			if (!lblock) {
				*dblock = ip->i_num.in_addr;
				if (extlen)
					*extlen = 1;
			}
			return 0;
		}
	
		bsize = (S_ISDIR(ip->i_mode)) ? sdp->sd_jbsize : sdp->sd_bsize;
	
		height = lgfs2_calc_tree_height(ip, (lblock + 1) * bsize);
		if (ip->i_height < height) {
			if (!create)
				return 0;
	
			if (lgfs2_build_height(ip, height))
				return -1;
		}
	
		lgfs2_find_metapath(ip, lblock, &mp);
		end_of_metadata = ip->i_height - 1;
	
		bh = ip->i_bh;
	
		for (x = 0; x < end_of_metadata; x++) {
			lgfs2_lookup_block(ip, bh, x, &mp, create, new, dblock);
			if (bh != ip->i_bh)
				lgfs2_brelse(bh);
			if (!*dblock)
				return 0;
	
			if (*new) {
				struct gfs2_meta_header mh = {
					.mh_magic = cpu_to_be32(GFS2_MAGIC),
					.mh_type = cpu_to_be32(GFS2_METATYPE_IN),
					.mh_format = cpu_to_be32(GFS2_FORMAT_IN)
				};
				bh = lgfs2_bget(sdp, *dblock);
				memcpy(bh->b_data, &mh, sizeof(mh));
				lgfs2_bmodified(bh);
			} else {
				if (*dblock == ip->i_num.in_addr)
					bh = ip->i_bh;
				else
					bh = lgfs2_bread(sdp, *dblock);
			}
		}
	
		if (!prealloc)
			lgfs2_lookup_block(ip, bh, end_of_metadata, &mp, create, new, dblock);
	
		if (extlen && *dblock) {
			*extlen = 1;
	
			if (!*new) {
				uint64_t tmp_dblock;
				int tmp_new;
				unsigned int nptrs;
	
				nptrs = (end_of_metadata) ? sdp->sd_inptrs : sdp->sd_diptrs;
	
				while (++mp.mp_list[end_of_metadata] < nptrs) {
					lgfs2_lookup_block(ip, bh, end_of_metadata, &mp, 0, &tmp_new,
								 &tmp_dblock);
	
					if (*dblock + *extlen != tmp_dblock)
						break;
	
					(*extlen)++;
				}
			}
		}
	
		if (bh != ip->i_bh)
			lgfs2_brelse(bh);
		return 0;
	}
	
	static void
	copy2mem(struct lgfs2_buffer_head *bh, void **buf, unsigned int offset,
		 unsigned int size)
	{
		char **p = (char **)buf;
	
		if (bh)
			memcpy(*p, bh->b_data + offset, size);
		else
			memset(*p, 0, size);
	
		*p += size;
	}
	
	int lgfs2_readi(struct lgfs2_inode *ip, void *buf, uint64_t offset, unsigned int size)
	{
		struct lgfs2_sbd *sdp = ip->i_sbd;
		struct lgfs2_buffer_head *bh;
		uint64_t lblock, dblock;
		unsigned int o;
		uint32_t extlen = 0;
		unsigned int amount;
		int not_new = 0;
		int isdir = !!(S_ISDIR(ip->i_mode));
		int copied = 0;
	
		if (offset >= ip->i_size)
			return 0;
	
		if ((offset + size) > ip->i_size)
			size = ip->i_size - offset;
	
		if (!size)
			return 0;
	
		if (isdir) {
			lblock = offset;
			o = lblock % sdp->sd_jbsize;
			lblock /= sdp->sd_jbsize;
		} else {
			lblock = offset >> sdp->sd_bsize_shift;
			o = offset & (sdp->sd_bsize - 1);
		}
	
		if (inode_is_stuffed(ip))
			o += sizeof(struct gfs2_dinode);
		else if (isdir)
			o += sizeof(struct gfs2_meta_header);
	
		while (copied < size) {
			amount = size - copied;
			if (amount > sdp->sd_bsize - o)
				amount = sdp->sd_bsize - o;
	
			if (!extlen) {
				if (lgfs2_block_map(ip, lblock, &not_new, &dblock, &extlen, 0))
					return -1;
			}
	
			if (dblock) {
				if (dblock == ip->i_num.in_addr)
					bh = ip->i_bh;
				else
					bh = lgfs2_bread(sdp, dblock);
				dblock++;
				extlen--;
			} else
				bh = NULL;
	
			copy2mem(bh, &buf, o, amount);
			if (bh && bh != ip->i_bh)
				lgfs2_brelse(bh);
	
			copied += amount;
			lblock++;
			o = (isdir) ? sizeof(struct gfs2_meta_header) : 0;
		}
	
		return copied;
	}
	
	static void copy_from_mem(struct lgfs2_buffer_head *bh, void **buf,
				  unsigned int offset, unsigned int size)
	{
		char **p = (char **)buf;
	
		memcpy(bh->b_data + offset, *p, size);
		lgfs2_bmodified(bh);
		*p += size;
	}
	
	int __lgfs2_writei(struct lgfs2_inode *ip, void *buf,
			  uint64_t offset, unsigned int size, int resize)
	{
		struct lgfs2_sbd *sdp = ip->i_sbd;
		struct lgfs2_buffer_head *bh;
		uint64_t lblock, dblock;
		unsigned int o;
		uint32_t extlen = 0;
		unsigned int amount;
		int new;
		int isdir = !!(S_ISDIR(ip->i_mode));
		const uint64_t start = offset;
		int copied = 0;
	
		if (!size)
			return 0;
	
		if (inode_is_stuffed(ip) &&
		    ((start + size) > (sdp->sd_bsize - sizeof(struct gfs2_dinode))))
			if (lgfs2_unstuff_dinode(ip))
				return -1;
	
		if (isdir) {
			lblock = offset;
			o = lblock % sdp->sd_jbsize;
			lblock /= sdp->sd_jbsize;
		} else {
			lblock = offset >> sdp->sd_bsize_shift;
			o = offset & (sdp->sd_bsize - 1);
		}
	
		if (inode_is_stuffed(ip))
			o += sizeof(struct gfs2_dinode);
		else if (isdir)
			o += sizeof(struct gfs2_meta_header);
	
		while (copied < size) {
			amount = size - copied;
			if (amount > sdp->sd_bsize - o)
				amount = sdp->sd_bsize - o;
	
			if (!extlen) {
				new = 1;
				if (lgfs2_block_map(ip, lblock, &new, &dblock, &extlen, 0))
					return -1;
			}
	
			if (new) {
				bh = lgfs2_bget(sdp, dblock);
				if (isdir) {
					struct gfs2_meta_header mh = {
						.mh_magic = cpu_to_be32(GFS2_MAGIC),
						.mh_type = cpu_to_be32(GFS2_METATYPE_JD),
						.mh_format = cpu_to_be32(GFS2_FORMAT_JD),
					};
					memcpy(bh->b_data, &mh, sizeof(mh));
					lgfs2_bmodified(bh);
				}
			} else {
				if (dblock == ip->i_num.in_addr)
					bh = ip->i_bh;
				else
					bh = lgfs2_bread(sdp, dblock);
			}
			copy_from_mem(bh, &buf, o, amount);
			if (bh != ip->i_bh)
				lgfs2_brelse(bh);
	
			copied += amount;
			lblock++;
			dblock++;
			extlen--;
	
			o = (isdir) ? sizeof(struct gfs2_meta_header) : 0;
		}
	
		if (resize && ip->i_size < start + copied) {
			lgfs2_bmodified(ip->i_bh);
			ip->i_size = start + copied;
		}
	
		return copied;
	}
	
	int lgfs2_dirent_first(struct lgfs2_inode *dip, struct lgfs2_buffer_head *bh,
						  struct gfs2_dirent **dent)
	{
		struct gfs2_meta_header *h = (struct gfs2_meta_header *)bh->b_data;
	
		if (be32_to_cpu(h->mh_type) == GFS2_METATYPE_LF) {
			*dent = (struct gfs2_dirent *)(bh->b_data + sizeof(struct gfs2_leaf));
			return LGFS2_IS_LEAF;
		} else {
			*dent = (struct gfs2_dirent *)(bh->b_data + sizeof(struct gfs2_dinode));
			return LGFS2_IS_DINODE;
		}
	}
	
	int lgfs2_dirent_next(struct lgfs2_inode *dip, struct lgfs2_buffer_head *bh,
						 struct gfs2_dirent **dent)
	{
		char *bh_end;
		uint16_t cur_rec_len;
	
		bh_end = bh->b_data + dip->i_sbd->sd_bsize;
		cur_rec_len = be16_to_cpu((*dent)->de_rec_len);
	
		if (cur_rec_len == 0 || (char *)(*dent) + cur_rec_len >= bh_end)
			return -ENOENT;
	
		*dent = (struct gfs2_dirent *)((char *)(*dent) + cur_rec_len);
	
		return 0;
	}
	
	/**
	 * Allocate a gfs2 dirent
	 * Returns 0 on success, with *dent_out pointing to the new dirent,
	 * or -1 on failure, with errno set
	 */
	static int dirent_alloc(struct lgfs2_inode *dip, struct lgfs2_buffer_head *bh,
				int name_len, struct gfs2_dirent **dent_out)
	{
		struct gfs2_dirent *dent, *new;
		unsigned int rec_len = GFS2_DIRENT_SIZE(name_len);
		unsigned int entries = 0, offset = 0;
		int type;
	
		type = lgfs2_dirent_first(dip, bh, &dent);
	
		if (type == LGFS2_IS_LEAF) {
			struct gfs2_leaf *leaf = (struct gfs2_leaf *)bh->b_data;
			entries = be16_to_cpu(leaf->lf_entries);
			offset = sizeof(struct gfs2_leaf);
		} else {
			struct gfs2_dinode *dinode = (struct gfs2_dinode *)bh->b_data;
			entries = be32_to_cpu(dinode->di_entries);
			offset = sizeof(struct gfs2_dinode);
		}
	
		if (!entries) {
			dent->de_rec_len = cpu_to_be16(dip->i_sbd->sd_bsize - offset);
			dent->de_name_len = cpu_to_be16(name_len);
			lgfs2_bmodified(bh);
			*dent_out = dent;
			dip->i_entries++;
			lgfs2_bmodified(dip->i_bh);
			return 0;
		}
	
		do {
			uint16_t cur_rec_len;
			uint16_t cur_name_len;
			uint16_t new_rec_len;
	
			cur_rec_len = be16_to_cpu(dent->de_rec_len);
			cur_name_len = be16_to_cpu(dent->de_name_len);
	
			if ((!dent->de_inum.no_formal_ino && cur_rec_len >= rec_len) ||
			    (cur_rec_len >= GFS2_DIRENT_SIZE(cur_name_len) + rec_len)) {
	
				if (dent->de_inum.no_formal_ino) {
					new = (struct gfs2_dirent *)((char *)dent +
								    GFS2_DIRENT_SIZE(cur_name_len));
					memset(new, 0, sizeof(struct gfs2_dirent));
	
					new->de_rec_len = cpu_to_be16(cur_rec_len -
						  GFS2_DIRENT_SIZE(cur_name_len));
					new->de_name_len = cpu_to_be16(name_len);
	
					new_rec_len = be16_to_cpu(new->de_rec_len);
					dent->de_rec_len = cpu_to_be16(cur_rec_len - new_rec_len);
	
					*dent_out = new;
					lgfs2_bmodified(bh);
					dip->i_entries++;
					lgfs2_bmodified(dip->i_bh);
					return 0;
				}
	
				dent->de_name_len = cpu_to_be16(name_len);
	
				*dent_out = dent;
				lgfs2_bmodified(bh);
				dip->i_entries++;
				lgfs2_bmodified(dip->i_bh);
				return 0;
			}
		} while (lgfs2_dirent_next(dip, bh, &dent) == 0);
	
		errno = ENOSPC;
		return -1;
	}
	
	void lgfs2_dirent2_del(struct lgfs2_inode *dip, struct lgfs2_buffer_head *bh,
	                       struct gfs2_dirent *prev, struct gfs2_dirent *cur)
	{
		uint16_t cur_rec_len, prev_rec_len;
	
		lgfs2_bmodified(bh);
		if (lgfs2_check_meta(bh->b_data, GFS2_METATYPE_LF) == 0) {
			struct gfs2_leaf *lf = (struct gfs2_leaf *)bh->b_data;
			uint16_t entries;
	
			entries = be16_to_cpu(lf->lf_entries) - 1;
			lf->lf_entries = cpu_to_be16(entries);
		}
	
		if (dip->i_entries) {
			lgfs2_bmodified(dip->i_bh);
			dip->i_entries--;
		}
		if (!prev) {
			cur->de_inum.no_addr = 0;
			cur->de_inum.no_formal_ino = 0;
			return;
		}
	
		prev_rec_len = be16_to_cpu(prev->de_rec_len);
		cur_rec_len = be16_to_cpu(cur->de_rec_len);
	
		prev_rec_len += cur_rec_len;
		prev->de_rec_len = cpu_to_be16(prev_rec_len);
	}
	
	int lgfs2_get_leaf_ptr(struct lgfs2_inode *dip, const uint32_t lindex, uint64_t *ptr)
	{
		__be64 leaf_no;
		int count = lgfs2_readi(dip, (char *)&leaf_no, lindex * sizeof(__be64), sizeof(__be64));
		if (count != sizeof(__be64))
			return -1;
	
		*ptr = be64_to_cpu(leaf_no);
		return 0;
	}
	
	/**
	 * Split a directory leaf.
	 * Returns 0 on success and non-zero with errno set on failure.
	 */
	int lgfs2_dir_split_leaf(struct lgfs2_inode *dip, uint32_t start, uint64_t leaf_no,
	                         struct lgfs2_buffer_head *obh)
	{
		struct lgfs2_buffer_head *nbh;
		struct gfs2_leaf *nleaf, *oleaf;
		struct gfs2_dirent *dent, *prev = NULL, *next = NULL, *new;
		uint32_t len, half_len, divider;
		uint16_t depth;
		uint64_t bn;
		__be64 *lp;
		uint32_t name_len;
		int x, moved = 0;
		int count;
	
		if (lgfs2_meta_alloc(dip, &bn)) {
			errno = EIO;
			return -1;
		}
		nbh = lgfs2_bget(dip->i_sbd, bn);
		{
			struct gfs2_meta_header mh = {
				.mh_magic = cpu_to_be32(GFS2_MAGIC),
				.mh_type = cpu_to_be32(GFS2_METATYPE_LF),
				.mh_format = cpu_to_be32(GFS2_FORMAT_LF)
			};
			memcpy(nbh->b_data, &mh, sizeof(mh));
			lgfs2_bmodified(nbh);
			buffer_clear_tail(dip->i_sbd, nbh,
					  sizeof(struct gfs2_meta_header));
		}
	
		nleaf = (struct gfs2_leaf *)nbh->b_data;
		nleaf->lf_dirent_format = cpu_to_be32(GFS2_FORMAT_DE);
	
		oleaf = (struct gfs2_leaf *)obh->b_data;
	
		len = 1 << (dip->i_depth - be16_to_cpu(oleaf->lf_depth));
		half_len = len >> 1;
	
		lp = calloc(1, half_len * sizeof(__be64));
		if (lp == NULL) {
			lgfs2_bfree(&nbh);
			return -1;
		}
		for (x = 0; x < half_len; x++)
			lp[x] = cpu_to_be64(bn);
	
		count = lgfs2_writei(dip, (char *)lp, start * sizeof(uint64_t),
		                     half_len * sizeof(uint64_t));
		free(lp);
		if (count != half_len * sizeof(uint64_t)) {
			lgfs2_bfree(&nbh);
			errno = EINVAL;
			return -1;
		}
		divider = (start + half_len) << (32 - dip->i_depth);
	
		lgfs2_dirent_first(dip, obh, &dent);
	
		do {
			next = dent;
			if (lgfs2_dirent_next(dip, obh, &next))
				next = NULL;
	
			if (dent->de_inum.no_formal_ino &&
			    be32_to_cpu(dent->de_hash) < divider) {
				uint16_t entries;
	
				name_len = be16_to_cpu(dent->de_name_len);
	
				if (dirent_alloc(dip, nbh, name_len, &new)) {
					lgfs2_bfree(&nbh);
					errno = ENOSPC;
					return -1;
				}
	
				new->de_inum = dent->de_inum;
				new->de_hash = dent->de_hash;
				new->de_type = dent->de_type;
				memcpy((char *)(new + 1), (char *)(dent + 1), name_len);
	
				entries = be16_to_cpu(nleaf->lf_entries) + 1;
				nleaf->lf_entries = cpu_to_be16(entries);
	
				lgfs2_dirent2_del(dip, obh, prev, dent);
	
				if (!prev)
					prev = dent;
	
				moved = 1;
			} else
				prev = dent;
	
			dent = next;
		} while (dent);
	
		if (!moved) {
			if (dirent_alloc(dip, nbh, 0, &new)) {
				lgfs2_bfree(&nbh);
				errno = ENOSPC;
				return -1;
			}
			new->de_inum.no_formal_ino = 0;
			/* Don't count the sentinel dirent as an entry */
			dip->i_entries--;
		}
	
		depth = be16_to_cpu(oleaf->lf_depth) + 1;
		oleaf->lf_depth = cpu_to_be16(depth);
		nleaf->lf_depth = oleaf->lf_depth;
	
		nleaf->lf_inode = cpu_to_be64(dip->i_num.in_addr);
		dip->i_blocks++;
		lgfs2_bmodified(dip->i_bh);
	
		lgfs2_bmodified(obh); /* Need to do this in case nothing was moved */
		lgfs2_bmodified(nbh);
		lgfs2_brelse(nbh);
		return 0;
	}
	
	static int dir_double_exhash(struct lgfs2_inode *dip)
	{
		struct lgfs2_sbd *sdp = dip->i_sbd;
		uint64_t *buf;
		uint64_t *from, *to;
		uint64_t block;
		int x;
		int count;
	
		buf = calloc(1, 3 * sdp->sd_hash_bsize);
		if (buf == NULL)
			return -1;
	
		for (block = dip->i_size >> sdp->sd_hash_bsize_shift; block--;) {
			count = lgfs2_readi(dip, (char *)buf,
				      block * sdp->sd_hash_bsize,
				      sdp->sd_hash_bsize);
			if (count != sdp->sd_hash_bsize) {
				free(buf);
				return -1;
			}
			from = buf;
			to = (uint64_t *)((char *)buf + sdp->sd_hash_bsize);
	
			for (x = sdp->sd_hash_ptrs; x--; from++) {
				*to++ = *from;
				*to++ = *from;
			}
			count = lgfs2_writei(dip, (char *)buf + sdp->sd_hash_bsize,
			                     block * sdp->sd_bsize, sdp->sd_bsize);
			if (count != sdp->sd_bsize) {
				free(buf);
				return -1;
			}
		}
	
		free(buf);
	
		dip->i_depth++;
		lgfs2_bmodified(dip->i_bh);
		return 0;
	}
	
	/**
	 * get_leaf - Get leaf
	 * @dip:
	 * @leaf_no:
	 * @bh_out:
	 *
	 * Returns: 0 on success, error code otherwise
	 */
	
	int lgfs2_get_leaf(struct lgfs2_inode *dip, uint64_t leaf_no,
					  struct lgfs2_buffer_head **bhp)
	{
		int error = 0;
	
		*bhp = lgfs2_bread(dip->i_sbd, leaf_no);
		error = lgfs2_check_meta((*bhp)->b_data, GFS2_METATYPE_LF);
		if(error)
			lgfs2_brelse(*bhp);
		return error;
	}
	
	/**
	 * get_first_leaf - Get first leaf
	 * @dip: The GFS2 inode
	 * @index:
	 * @bh_out:
	 *
	 * Returns: 0 on success, error code otherwise
	 */
	
	static int get_first_leaf(struct lgfs2_inode *dip, uint32_t lindex, struct lgfs2_buffer_head **bh_out)
	{
		uint64_t leaf_no;
	
		if (lgfs2_get_leaf_ptr(dip, lindex, &leaf_no) != 0)
			return -1;
		*bh_out = lgfs2_bread(dip->i_sbd, leaf_no);
		if (*bh_out == NULL)
			return -1;
		return 0;
	}
	
	/**
	 * get_next_leaf - Get next leaf
	 * @dip: The GFS2 inode
	 * @bh_in: The buffer
	 * @bh_out:
	 *
	 * Returns: 0 on success, error code otherwise
	 */
	
	static int get_next_leaf(struct lgfs2_inode *dip,struct lgfs2_buffer_head *bh_in,
							 struct lgfs2_buffer_head **bh_out)
	{
		struct gfs2_leaf *leaf;
	
		leaf = (struct gfs2_leaf *)bh_in->b_data;
	
		if (!leaf->lf_next)
			return -1;
		/* Check for a leaf that points to itself as "next" */
		if (be64_to_cpu(leaf->lf_next) == bh_in->b_blocknr)
			return -1;
		*bh_out = lgfs2_bread(dip->i_sbd, be64_to_cpu(leaf->lf_next));
		if (*bh_out == NULL)
			return -ENOENT;
		/* Check for a leaf pointing to a non-leaf */
		if (lgfs2_check_meta((*bh_out)->b_data, GFS2_METATYPE_LF)) {
			lgfs2_brelse(*bh_out);
			*bh_out = NULL;
			return -ENOENT;
		}
		return 0;
	}
	
	static int dir_e_add(struct lgfs2_inode *dip, const char *filename, int len,
			      struct lgfs2_inum *inum, unsigned int type)
	{
		struct lgfs2_buffer_head *bh;
		struct gfs2_leaf *leaf, *nleaf;
		struct gfs2_dirent *dent;
		uint32_t lindex, llen;
		uint32_t hash;
		uint64_t leaf_no, bn;
		int err = 0;
	
		hash = lgfs2_disk_hash(filename, len);
	restart:
		/* (hash >> 32) is undefined behaviour */
		if (dip->i_depth)
			lindex = hash >> (32 - dip->i_depth);
		else
			lindex = 0;
	
		err = lgfs2_get_leaf_ptr(dip, lindex, &leaf_no);
		if (err)
			return err;
	
		for (;;) {
			uint16_t entries;
	
			bh = lgfs2_bread(dip->i_sbd, leaf_no);
			leaf = (struct gfs2_leaf *)bh->b_data;
	
			if (dirent_alloc(dip, bh, len, &dent)) {
	
				if (be16_to_cpu(leaf->lf_depth) < dip->i_depth) {
					llen = 1 << (dip->i_depth -
						     be16_to_cpu(leaf->lf_depth));
					if (lgfs2_dir_split_leaf(dip, lindex & ~(llen - 1), leaf_no, bh)) {
						lgfs2_brelse(bh);
						return -1;
					}
					lgfs2_brelse(bh);
					goto restart;
	
				} else if (dip->i_depth < GFS2_DIR_MAX_DEPTH) {
					lgfs2_brelse(bh);
					if (dir_double_exhash(dip))
						return -1;
					goto restart;
	
				} else if (leaf->lf_next) {
					leaf_no = be64_to_cpu(leaf->lf_next);
					lgfs2_brelse(bh);
					continue;
	
				} else {
					struct lgfs2_buffer_head *nbh;
					struct gfs2_meta_header mh = {
						.mh_magic = cpu_to_be32(GFS2_MAGIC),
						.mh_type = cpu_to_be32(GFS2_METATYPE_LF),
						.mh_format = cpu_to_be32(GFS2_FORMAT_LF)
					};
					if (lgfs2_meta_alloc(dip, &bn)) {
						lgfs2_bfree(&bh);
						return -1;
					}
					nbh = lgfs2_bget(dip->i_sbd, bn);
					memcpy(nbh->b_data, &mh, sizeof(mh));
					lgfs2_bmodified(nbh);
	
					leaf->lf_next = cpu_to_be64(bn);
	
					nleaf = (struct gfs2_leaf *)nbh->b_data;
					nleaf->lf_depth = leaf->lf_depth;
					nleaf->lf_dirent_format = cpu_to_be32(GFS2_FORMAT_DE);
					nleaf->lf_inode = cpu_to_be64(dip->i_num.in_addr);
					err = dirent_alloc(dip, nbh, len, &dent);
					if (err) {
						lgfs2_bfree(&nbh);
						lgfs2_bfree(&bh);
						return err;
					}
					dip->i_blocks++;
					lgfs2_bmodified(dip->i_bh);
					lgfs2_bmodified(bh);
					lgfs2_brelse(bh);
					bh = nbh;
					leaf = nleaf;
				}
			}
	
			lgfs2_inum_out(inum, &dent->de_inum);
			dent->de_hash = cpu_to_be32(hash);
			dent->de_type = cpu_to_be16(type);
			memcpy((char *)(dent + 1), filename, len);
	
			entries = be16_to_cpu(leaf->lf_entries) + 1;
			leaf->lf_entries = cpu_to_be16(entries);
	
			lgfs2_bmodified(bh);
			lgfs2_brelse(bh);
			return err;
		}
	}
	
	static int dir_make_exhash(struct lgfs2_inode *dip)
	{
		struct lgfs2_sbd *sdp = dip->i_sbd;
		struct gfs2_dirent *dent;
		struct lgfs2_buffer_head *bh;
		struct gfs2_leaf *leaf;
		uint16_t rec_len;
		int y;
		uint32_t x;
		uint64_t bn;
		__be64 *lp;
	
		if (lgfs2_meta_alloc(dip, &bn))
			return -1;
		bh = lgfs2_bget(sdp, bn);
		{
			struct gfs2_meta_header mh = {
				.mh_magic = cpu_to_be32(GFS2_MAGIC),
				.mh_type = cpu_to_be32(GFS2_METATYPE_LF),
				.mh_format = cpu_to_be32(GFS2_FORMAT_LF)
			};
			memcpy(bh->b_data, &mh, sizeof(mh));
			lgfs2_bmodified(bh);
		}
	
		leaf = (struct gfs2_leaf *)bh->b_data;
		leaf->lf_dirent_format = cpu_to_be32(GFS2_FORMAT_DE);
		leaf->lf_entries = cpu_to_be16(dip->i_entries);
		leaf->lf_inode = cpu_to_be64(dip->i_num.in_addr);
		buffer_copy_tail(sdp, bh, sizeof(struct gfs2_leaf),
				 dip->i_bh, sizeof(struct gfs2_dinode));
	
		x = 0;
		lgfs2_dirent_first(dip, bh, &dent);
	
		do {
			if (!dent->de_inum.no_formal_ino)
				continue;
			if (++x == dip->i_entries)
				break;
		} while (lgfs2_dirent_next(dip, bh, &dent) == 0);
	
		rec_len = be16_to_cpu(dent->de_rec_len) +
			sizeof(struct gfs2_dinode) - sizeof(struct gfs2_leaf);
		dent->de_rec_len = cpu_to_be16(rec_len);
	
		/* no need to: lgfs2_bmodified(bh); (buffer_copy_tail does it) */
		lgfs2_brelse(bh);
	
		buffer_clear_tail(sdp, dip->i_bh, sizeof(struct gfs2_dinode));
	
		lp = (__be64 *)(dip->i_bh->b_data + sizeof(struct gfs2_dinode));
	
		for (x = sdp->sd_hash_ptrs; x--; lp++)
			*lp = cpu_to_be64(bn);
	
		dip->i_size = sdp->sd_bsize / 2;
		dip->i_blocks++;
		dip->i_flags |= GFS2_DIF_EXHASH;
		dip->i_payload_format = 0;
		/* no need: lgfs2_bmodified(dip->i_bh); buffer_clear_tail does it. */
	
		for (x = sdp->sd_hash_ptrs, y = -1; x; x >>= 1, y++) ;
		dip->i_depth = y;
	
		lgfs2_dinode_out(dip, dip->i_bh->b_data);
		lgfs2_bwrite(dip->i_bh);
		return 0;
	}
	
	static int dir_l_add(struct lgfs2_inode *dip, const char *filename, int len,
			      struct lgfs2_inum *inum, unsigned int type)
	{
		struct gfs2_dirent *dent;
		uint32_t de_hash;
		int err = 0;
	
		if (dirent_alloc(dip, dip->i_bh, len, &dent)) {
			err = dir_make_exhash(dip);
			if (err != 0)
				return err;
			err = dir_e_add(dip, filename, len, inum, type);
			return err;
		}
	
		lgfs2_inum_out(inum, &dent->de_inum);
		de_hash = lgfs2_disk_hash(filename, len);
		dent->de_hash = cpu_to_be32(de_hash);
		dent->de_type = cpu_to_be16(type);
		memcpy((char *)(dent + 1), filename, len);
		lgfs2_bmodified(dip->i_bh);
		return err;
	}
	
	int lgfs2_dir_add(struct lgfs2_inode *dip, const char *filename, int len,
	                  struct lgfs2_inum *inum, unsigned int type)
	{
		int err = 0;
		if (dip->i_flags & GFS2_DIF_EXHASH)
			err = dir_e_add(dip, filename, len, inum, type);
		else
			err = dir_l_add(dip, filename, len, inum, type);
		return err;
	}
	
	static int __init_dinode(struct lgfs2_sbd *sdp, struct lgfs2_buffer_head **bhp, struct lgfs2_inum *inum,
	                         unsigned int mode, uint32_t flags, struct lgfs2_inum *parent)
	{
		struct lgfs2_buffer_head *bh;
		struct gfs2_dinode *di;
		int is_dir = S_ISDIR(mode);
	
		errno = EINVAL;
		if (bhp == NULL)
			return 1;
	
		if (*bhp == NULL) {
			*bhp = lgfs2_bget(sdp, inum->in_addr);
			if (*bhp == NULL)
				return 1;
		}
	
		bh = *bhp;
	
		di = (struct gfs2_dinode *)bh->b_data;
	
		di->di_header.mh_magic = cpu_to_be32(GFS2_MAGIC);
		di->di_header.mh_type = cpu_to_be32(GFS2_METATYPE_DI);
		di->di_header.mh_format = cpu_to_be32(GFS2_FORMAT_DI);
		di->di_num.no_formal_ino = cpu_to_be64(inum->in_formal_ino);
		di->di_num.no_addr = cpu_to_be64(inum->in_addr);
		di->di_mode = cpu_to_be32(mode);
		di->di_nlink = cpu_to_be32(1);
		di->di_blocks = cpu_to_be64(1);
		di->di_atime = di->di_mtime = di->di_ctime = cpu_to_be64(sdp->sd_time);
		di->di_goal_meta = di->di_goal_data = cpu_to_be64(bh->b_blocknr);
		di->di_flags = cpu_to_be32(flags);
	
		if (is_dir) {
			char *p = bh->b_data + sizeof(*di);
			struct gfs2_dirent de = {0};
			uint32_t hash;
			uint16_t len;
	
			hash = lgfs2_disk_hash(".", 1);
			len = GFS2_DIRENT_SIZE(1);
			de.de_inum = di->di_num;
			de.de_hash = cpu_to_be32(hash);
			de.de_rec_len = cpu_to_be16(len);
			de.de_name_len = cpu_to_be16(1);
			de.de_type = cpu_to_be16(IF2DT(S_IFDIR));
			memcpy(p, &de, sizeof(de));
			p[sizeof(de)] = '.';
			p += len;
	
			hash = lgfs2_disk_hash("..", 2);
			len = sdp->sd_bsize - (p - bh->b_data);
			de.de_inum.no_formal_ino = cpu_to_be64(parent->in_formal_ino);
			de.de_inum.no_addr = cpu_to_be64(parent->in_addr);
			de.de_hash = cpu_to_be32(hash);
			de.de_rec_len = cpu_to_be16(len);
			de.de_name_len = cpu_to_be16(2);
			de.de_type = cpu_to_be16(IF2DT(S_IFDIR));
			memcpy(p, &de, sizeof(de));
			p += sizeof(de);
			*p++ = '.';
			*p = '.';
	
			di->di_nlink = cpu_to_be32(2);
			di->di_size = cpu_to_be64(sdp->sd_bsize - sizeof(struct gfs2_dinode));
			di->di_flags = cpu_to_be32(flags | GFS2_DIF_JDATA);
			di->di_payload_format = cpu_to_be32(GFS2_FORMAT_DE);
			di->di_entries = cpu_to_be32(2);
		}
		lgfs2_bmodified(bh);
		return 0;
	}
	
	int lgfs2_init_dinode(struct lgfs2_sbd *sdp, struct lgfs2_buffer_head **bhp, struct lgfs2_inum *inum,
	                      unsigned int mode, uint32_t flags, struct lgfs2_inum *parent)
	{
		return __init_dinode(sdp, bhp, inum, mode, flags, parent);
	}
	
	static void lgfs2_fill_indir(char *start, char *end, uint64_t ptr0, unsigned n, unsigned *p)
	{
		char *bp;
		memset(start, 0, end - start);
		for (bp = start; bp < end && *p < n; bp += sizeof(uint64_t)) {
			uint64_t pn = ptr0 + *p;
			*(__be64 *)bp = cpu_to_be64(pn);
			(*p)++;
		}
	}
	
	/**
	 * Calculate and write the indirect blocks for a single-extent file of a given
	 * size.
	 * ip: The inode for which to write indirect blocks, with fields already set
	 *     appropriately (see lgfs2_file_alloc).
	 * Returns 0 on success or non-zero with errno set on failure.
	 */
	int lgfs2_write_filemeta(struct lgfs2_inode *ip)
	{
		unsigned height = 0;
		struct lgfs2_metapath mp;
		struct lgfs2_sbd *sdp = ip->i_sbd;
		uint64_t dblocks = (ip->i_size + sdp->sd_bsize - 1) / sdp->sd_bsize;
		uint64_t ptr0 = ip->i_num.in_addr + 1;
		unsigned ptrs = 1;
		struct gfs2_meta_header mh = {
			.mh_magic = cpu_to_be32(GFS2_MAGIC),
			.mh_type = cpu_to_be32(GFS2_METATYPE_IN),
			.mh_format = cpu_to_be32(GFS2_FORMAT_IN)
		};
		struct lgfs2_buffer_head *bh = lgfs2_bget(sdp, ip->i_num.in_addr);
		if (bh == NULL)
			return 1;
	
		/* Using lgfs2_find_metapath() to find the last data block in the file will
		   effectively give a remainder for the number of pointers at each
		   height. Just need to add 1 to convert ptr index to quantity later. */
		lgfs2_find_metapath(ip, dblocks - 1, &mp);
	
		for (height = 0; height < ip->i_height; height++) {
			unsigned p;
			/* The number of pointers in this height will be the number of
			   full indirect blocks pointed to by the previous height
			   multiplied by the pointer capacity of an indirect block,
			   plus the remainder which lgfs2_find_metapath() gave us. */
			ptrs = ((ptrs - 1) * sdp->sd_inptrs) + mp.mp_list[height] + 1;
	
			for (p = 0; p < ptrs; bh->b_blocknr++) {
				char *start = bh->b_data;
				if (height == 0) {
					start += sizeof(struct gfs2_dinode);
					lgfs2_dinode_out(ip, bh->b_data);
				} else {
					start += sizeof(struct gfs2_meta_header);
					memcpy(bh->b_data, &mh, sizeof(mh));
				}
				lgfs2_fill_indir(start, bh->b_data + sdp->sd_bsize, ptr0, ptrs, &p);
				if (lgfs2_bwrite(bh)) {
					free(bh);
					return 1;
				}
			}
			ptr0 += ptrs;
		}
		free(bh);
		return 0;
	}
	
	static struct lgfs2_inode *do_createi(struct lgfs2_inode *dip, const char *filename,
	                                      unsigned int mode, uint32_t flags)
	{
		struct lgfs2_inum parent = dip->i_num;
		struct lgfs2_sbd *sdp = dip->i_sbd;
		uint64_t bn;
		struct lgfs2_inum inum;
		struct lgfs2_buffer_head *bh = NULL;
		struct lgfs2_inode *ip;
		int err = 0;
		int is_dir;
	
		err = lgfs2_dinode_alloc(sdp, 1, &bn);
		if (err != 0)
			return NULL;
	
		inum.in_formal_ino = sdp->md.next_inum++;
		inum.in_addr = bn;
	
		err = lgfs2_dir_add(dip, filename, strlen(filename), &inum, IF2DT(mode));
		if (err)
			return NULL;
	
		is_dir = S_ISDIR(mode);
		if (is_dir) {
			lgfs2_bmodified(dip->i_bh);
			dip->i_nlink++;
		}
		err = __init_dinode(sdp, &bh, &inum, mode, flags, &parent);
		if (err != 0)
			return NULL;
	
		ip = lgfs2_inode_get(sdp, bh);
		if (ip == NULL)
			return NULL;
		lgfs2_bmodified(bh);
		ip->bh_owned = 1;
		return ip;
	}
	
	/**
	 * Create an inode and link it into a directory. If it already exists, return
	 * the existing inode. To create gfs1 inodes, dip->i_sbd->gfs1 must be set.
	 * @dip: The inode of the parent directory.
	 * @filename: The new inode's filename.
	 * @mode: The mode of the new inode.
	 * @flags: The flags of the new inode.
	 * Returns the new or existing inode on success or NULL on failure with errno set.
	 */
	struct lgfs2_inode *lgfs2_createi(struct lgfs2_inode *dip, const char *filename,
	                                 unsigned int mode, uint32_t flags)
	{
		struct lgfs2_inode *ip = lgfs2_lookupi(dip, filename, strlen(filename));
	
		if (ip != NULL) {
			ip->bh_owned = 1;
			return ip;
		}
		return do_createi(dip, filename, mode, flags);
	}
	
	/**
	 * gfs2_filecmp - Compare two filenames
	 * @file1: The first filename
	 * @file2: The second filename
	 * @len_of_file2: The length of the second file
	 *
	 * This routine compares two filenames and returns 1 if they are equal.
	 *
	 * Returns: 1 if the files are the same, otherwise 0.
	 */
	
	static int gfs2_filecmp(const char *file1, const char *file2, int len_of_file2)
	{
		if (strlen(file1) != len_of_file2)
			return 0;
		if (memcmp(file1, file2, len_of_file2))
			return 0;
		return 1;
	}
	
	/**
	 * leaf_search
	 * @bh:
	 * @id:
	 * @dent_out:
	 * @dent_prev:
	 *
	 * Returns:
	 */
	static int leaf_search(struct lgfs2_inode *dip, struct lgfs2_buffer_head *bh,
			       const char *filename, int len,
			       struct gfs2_dirent **dent_out,
			       struct gfs2_dirent **dent_prev)
	{
		uint32_t hash;
		struct gfs2_dirent *dent, *prev = NULL;
		unsigned int entries = 0, x = 0;
		int type;
	
		type = lgfs2_dirent_first(dip, bh, &dent);
	
		if (type == LGFS2_IS_LEAF){
			struct gfs2_leaf *leaf = (struct gfs2_leaf *)bh->b_data;
			entries = be16_to_cpu(leaf->lf_entries);
		} else if (type == LGFS2_IS_DINODE)
			entries = dip->i_entries;
		else
			return -1;
	
		hash = lgfs2_disk_hash(filename, len);
	
		do{
			if (!dent->de_inum.no_formal_ino){
				prev = dent;
				continue;
			}
	
			if (be32_to_cpu(dent->de_hash) == hash &&
				gfs2_filecmp(filename, (char *)(dent + 1),
					     be16_to_cpu(dent->de_name_len))) {
				*dent_out = dent;
				if (dent_prev)
					*dent_prev = prev;
				return 0;
			}
	
			if(x >= entries)
				return -1;
			x++;
			prev = dent;
		} while (lgfs2_dirent_next(dip, bh, &dent) == 0);
	
		return -ENOENT;
	}
	
	/**
	 * linked_leaf_search - Linked leaf search
	 * @dip: The GFS2 inode
	 * @id:
	 * @dent_out:
	 * @dent_prev:
	 * @bh_out:
	 *
	 * Returns: 0 on sucess, error code otherwise
	 */
	
	static int linked_leaf_search(struct lgfs2_inode *dip, const char *filename,
				      int len, struct gfs2_dirent **dent_out,
				      struct lgfs2_buffer_head **bh_out)
	{
		struct lgfs2_buffer_head *bh = NULL, *bh_next;
		uint32_t hsize, lindex;
		uint32_t hash;
		int error = 0;
	
		hsize = 1 << dip->i_depth;
		if(hsize * sizeof(uint64_t) != dip->i_size)
			return -1;
	
		/*  Figure out the address of the leaf node.  */
	
		hash = lgfs2_disk_hash(filename, len);
		lindex = hash >> (32 - dip->i_depth);
	
		error = get_first_leaf(dip, lindex, &bh_next);
		if (error)
			return error;
		if (bh_next == NULL)
			return errno;
	
		/*  Find the entry  */
		do{
			if (bh && bh != dip->i_bh)
				lgfs2_brelse(bh);
	
			bh = bh_next;
	
			error = leaf_search(dip, bh, filename, len, dent_out, NULL);
			switch (error){
			case 0:
				*bh_out = bh;
				return 0;
	
			case -ENOENT:
				break;
	
			default:
				if (bh && bh != dip->i_bh)
					lgfs2_brelse(bh);
				return error;
			}
	
			error = get_next_leaf(dip, bh, &bh_next);
		} while (!error && bh_next != NULL);
	
		if (bh && bh != dip->i_bh)
			lgfs2_brelse(bh);
	
		return error;
	}
	
	/**
	 * dir_e_search -
	 * @dip: The GFS2 inode
	 * @id:
	 * @inode:
	 *
	 * Returns:
	 */
	static int dir_e_search(struct lgfs2_inode *dip, const char *filename,
				int len, unsigned int *type, struct lgfs2_inum *inum)
	{
		struct lgfs2_buffer_head *bh = NULL;
		struct gfs2_dirent *dent;
		int error;
	
		error = linked_leaf_search(dip, filename, len, &dent, &bh);
		if (error)
			return error;
	
		lgfs2_inum_in(inum, &dent->de_inum);
		if (type)
			*type = be16_to_cpu(dent->de_type);
	
		lgfs2_brelse(bh);
	
		return 0;
	}
	
	
	/**
	 * dir_l_search -
	 * @dip: The GFS2 inode
	 * @id:
	 * @inode:
	 *
	 * Returns:
	 */
	static int dir_l_search(struct lgfs2_inode *dip, const char *filename,
				int len, unsigned int *type, struct lgfs2_inum *inum)
	{
		struct gfs2_dirent *dent;
		int error;
	
		if(!inode_is_stuffed(dip))
			return -1;
	
		error = leaf_search(dip, dip->i_bh, filename, len, &dent, NULL);
		if (!error) {
			lgfs2_inum_in(inum, &dent->de_inum);
			if(type)
				*type = be16_to_cpu(dent->de_type);
		}
		return error;
	}
	
	/**
	 * lgfs2_dir_search - Search a directory
	 * @dip: The GFS inode
	 * @id
	 * @type:
	 *
	 * This routine searches a directory for a file or another directory
	 * given its filename.  The component of the identifier that is
	 * not being used to search will be filled in and must be freed by
	 * the caller.
	 *
	 * Returns: 0 if found, -1 on failure, -ENOENT if not found.
	 */
	int lgfs2_dir_search(struct lgfs2_inode *dip, const char *filename, int len,
	                     unsigned int *type, struct lgfs2_inum *inum)
	{
		int error;
	
		if (!S_ISDIR(dip->i_mode))
			return -1;
	
		if (dip->i_flags & GFS2_DIF_EXHASH)
			error = dir_e_search(dip, filename, len, type, inum);
		else
			error = dir_l_search(dip, filename, len, type, inum);
	
		return error;
	}
	
	static int dir_e_del(struct lgfs2_inode *dip, const char *filename, int len)
	{
		int lindex;
		int error;
		int found = 0;
		uint64_t leaf_no;
		struct lgfs2_buffer_head *bh = NULL;
		struct gfs2_dirent *cur, *prev;
	
		lindex = (1 << (dip->i_depth))-1;
	
		for(; (lindex >= 0) && !found; lindex--){
			error = lgfs2_get_leaf_ptr(dip, lindex, &leaf_no);
			if (error)
				return error;
	
			while(leaf_no && !found){
				bh = lgfs2_bread(dip->i_sbd, leaf_no);
				error = leaf_search(dip, bh, filename, len, &cur, &prev);
				if (error) {
					if(error != -ENOENT){
						lgfs2_brelse(bh);
						return -1;
					}
					leaf_no = be64_to_cpu(((struct gfs2_leaf *)bh->b_data)->lf_next);
					lgfs2_brelse(bh);
				} else
					found = 1;
			}
		}
	
		if(!found)
			return 1;
	
		if (bh) {
			lgfs2_dirent2_del(dip, bh, prev, cur);
			lgfs2_brelse(bh);
		}
		return 0;
	}
	
	static int dir_l_del(struct lgfs2_inode *dip, const char *filename, int len)
	{
		int error=0;
		struct gfs2_dirent *cur, *prev;
	
		if(!inode_is_stuffed(dip))
			return -1;
	
		error = leaf_search(dip, dip->i_bh, filename, len, &cur, &prev);
		if (error) {
			if (error == -ENOENT)
				return 1;
			else
				return -1;
		}
	
		lgfs2_dirent2_del(dip, dip->i_bh, prev, cur);
		return 0;
	}
	
	
	/*
	 * lgfs2_dirent_del
	 * @dip
	 * filename
	 *
	 * Delete a directory entry from a directory.  This _only_
	 * removes the directory entry - leaving the dinode in
	 * place.  (Likely without a link.)
	 *
	 * Returns: 0 on success (or if it doesn't already exist), -1 on failure
	 */
	int lgfs2_dirent_del(struct lgfs2_inode *dip, const char *filename, int len)
	{
		int error;
	
		if(!S_ISDIR(dip->i_mode))
			return -1;
	
		if (dip->i_flags & GFS2_DIF_EXHASH)
			error = dir_e_del(dip, filename, len);
		else
			error = dir_l_del(dip, filename, len);
		lgfs2_bmodified(dip->i_bh);
		return error;
	}
	
	/**
	 * Look up a filename in a directory and return its inode, which can be the
	 * the directory inode when "." is looked up.
	 * @dip: The directory to search
	 * @name: The name of the inode to look for
	 * @len: The length of name
	 *
	 * Returns: The inode on success or NULL on failure with errno set.
	 */
	struct lgfs2_inode *lgfs2_lookupi(struct lgfs2_inode *dip, const char *filename, int len)
	{
		struct lgfs2_sbd *sdp;
		struct lgfs2_inum inum;
		int error = 0;
	
		errno = EINVAL;
		if (dip == NULL)
			return NULL;
		sdp = dip->i_sbd;
		errno = ENAMETOOLONG;
		if (!len || len > GFS2_FNAMESIZE)
			return NULL;
	
		if (gfs2_filecmp(filename, ".", 1))
			return dip;
	
		error = lgfs2_dir_search(dip, filename, len, NULL, &inum);
		if (error)
			return NULL;
		return lgfs2_inode_read(sdp, inum.in_addr);
	}
	
	/**
	 * lgfs2_free_block - free up a block given its block number
	 */
	void lgfs2_free_block(struct lgfs2_sbd *sdp, uint64_t block)
	{
		struct lgfs2_rgrp_tree *rgd;
	
		/* Adjust the free space count for the freed block */
		rgd = lgfs2_blk2rgrpd(sdp, block); /* find the rg for indir block */
		if (rgd) {
			lgfs2_set_bitmap(rgd, block, GFS2_BLKST_FREE);
			rgd->rt_free++; /* adjust the free count */
			lgfs2_rgrp_out(rgd, rgd->rt_bits[0].bi_data);
			rgd->rt_bits[0].bi_modified = 1;
			sdp->blks_alloced--;
		}
	}