/*
 * GPL HEADER START
 *
 * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
 *
 * This program is free software; you can redistribute it and/or modify
 * it under the terms of the GNU General Public License version 2 only,
 * as published by the Free Software Foundation.
 *
 * This program is distributed in the hope that it will be useful, but
 * WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
 * General Public License version 2 for more details (a copy is included
 * in the LICENSE file that accompanied this code).
 *
 * You should have received a copy of the GNU General Public License
 * version 2 along with this program; if not, write to the
 * Free Software Foundation, Inc., 59 Temple Place - Suite 330,
 * Boston, MA 021110-1307, USA
 *
 * GPL HEADER END
 */
/*
 * Copyright (c) 2011, 2012, Whamcloud, Inc.
 * Use is subject to license terms.
 *
 * Lustre administrative quota format.
 * from linux/fs/quota_v2.c
 */

#include "osd_internal.h"
#include "osd_quota_fmt.h"

typedef char *dqbuf_t;

static const union
{
	struct lustre_disk_dqblk_v2 r1;
} emptydquot = { .r1 = { 0 } };

static inline dqbuf_t getdqbuf(void)
{
	dqbuf_t buf = cfs_alloc(LUSTRE_DQBLKSIZE, CFS_ALLOC_IO);
	if (!buf)
		CWARN("Not enough memory for quota buffers.\n");
	return buf;
}

static inline void freedqbuf(dqbuf_t buf)
{
	cfs_free(buf);
}

/**
 * Read the \a blk into \a buf.
 */
static ssize_t quota_read_blk(const struct lu_env *env,
			      struct osd_object *obj,
			      int type, uint blk, dqbuf_t buf)
{
	ssize_t ret;
	struct super_block *sb = obj->oo_inode->i_sb;

	ENTRY;

	memset(buf, 0, LUSTRE_DQBLKSIZE);

#if LUSTRE_VERSION_CODE < OBD_OCD_VERSION(2,7,50,0)
	/* type is set as -1 when reading old admin quota file */
	if (type != USRQUOTA && type != GRPQUOTA) {
		struct lu_buf	lu_buffer;
		loff_t		pos;

		lu_buffer.lb_buf = buf;
		lu_buffer.lb_len = LUSTRE_DQBLKSIZE;
		pos = blk << LUSTRE_DQBLKSIZE_BITS;

		ret = dt_record_read(env, &obj->oo_dt, &lu_buffer, &pos);

		if (ret == 0)
			ret = LUSTRE_DQBLKSIZE;
		else if (ret == -EBADR || ret == -EFAULT)
			ret = 0;
		RETURN(ret);
	}
#else
#warning "remove old quota compatibility code"
#endif

	ret = sb->s_op->quota_read(sb, type, buf, LUSTRE_DQBLKSIZE,
				   blk << LUSTRE_DQBLKSIZE_BITS);

	/* Reading past EOF just returns a block of zeros */
	if (ret == -EBADR)
		ret = 0;

	RETURN(ret);
}

/**
 * Find entry in block by given \a dqid in the leaf block \a blk
 *
 * \retval +ve, the offset of the entry in file
 * \retval   0, entry not found
 * \retval -ve, unexpected failure
 */
static loff_t find_block_dqentry(const struct lu_env *env,
				 struct osd_object *obj, int type,
				 qid_t dqid, uint blk,
				 struct osd_it_quota *it)
{
	dqbuf_t				 buf = getdqbuf();
	loff_t				 ret;
	int				 i;
	struct lustre_disk_dqblk_v2	*ddquot;
	int				 dqblk_sz;

	ENTRY;

	ddquot = (struct lustre_disk_dqblk_v2 *)GETENTRIES(buf);
	dqblk_sz = sizeof(struct lustre_disk_dqblk_v2);
	if (!buf)
		RETURN(-ENOMEM);
	ret = quota_read_blk(env, obj, type, blk, buf);
	if (ret < 0) {
		CERROR("Can't read quota tree block %u.\n", blk);
		GOTO(out_buf, ret);
	}

	if (dqid) {
		for (i = 0; i < LUSTRE_DQSTRINBLK &&
			    le32_to_cpu(ddquot[i].dqb_id) != dqid; i++)
			continue;
	} else { /* ID 0 as a bit more complicated searching... */
		for (i = 0; i < LUSTRE_DQSTRINBLK; i++)
			if (!le32_to_cpu(ddquot[i].dqb_id) &&
			    memcmp((char *)&emptydquot, (char *)&ddquot[i],
				   dqblk_sz))
				break;
	}
	if (i == LUSTRE_DQSTRINBLK) {
		CDEBUG(D_QUOTA, "Quota for id %u not found.\n", dqid);
		ret = 0;
		GOTO(out_buf, ret);
	} else {
		ret = (blk << LUSTRE_DQBLKSIZE_BITS) +
		      sizeof(struct lustre_disk_dqdbheader) + i * dqblk_sz;

		if (it) {
			it->oiq_blk[LUSTRE_DQTREEDEPTH] = blk;
			it->oiq_offset = ret;
			it->oiq_id = dqid;
			it->oiq_index[LUSTRE_DQTREEDEPTH] = i;
		} else {
			ret = 0;
		}
	}
out_buf:
	freedqbuf(buf);
	RETURN(ret);
}

/**
 * Find entry for given \a dqid in the tree block \a blk
 *
 * \retval +ve, the offset of the entry in file
 * \retval   0, entry not found
 * \retval -ve, unexpected failure
 */
loff_t find_tree_dqentry(const struct lu_env *env,
			 struct osd_object *obj, int type,
			 qid_t dqid, uint blk, int depth,
			 struct osd_it_quota *it)
{
	dqbuf_t	 buf = getdqbuf();
	loff_t	 ret;
	u32	*ref = (u32 *) buf;

	ENTRY;

	if (!buf)
		RETURN(-ENOMEM);
	ret = quota_read_blk(env, obj, 0, blk, buf);
	if (ret < 0) {
		CERROR("Can't read quota tree block %u.\n", blk);
		GOTO(out_buf, ret);
	}
	ret = 0;
	blk = le32_to_cpu(ref[GETIDINDEX(dqid, depth)]);
	if (!blk)               /* No reference? */
		GOTO(out_buf, ret);

	if (depth < LUSTRE_DQTREEDEPTH - 1)
		ret = find_tree_dqentry(env, obj, type, dqid, blk,
					depth + 1, it);
	else
		ret = find_block_dqentry(env, obj, type, dqid, blk, it);

	if (it && ret > 0) {
		it->oiq_blk[depth + 1] = blk;
		it->oiq_index[depth] = GETIDINDEX(dqid, depth);
	}

out_buf:
	freedqbuf(buf);
	RETURN(ret);
}

/**
 * Search from \a index within the leaf block \a blk, and fill the \a it with
 * the first valid entry.
 *
 * \retval +ve, no valid entry found
 * \retval   0, entry found
 * \retval -ve, unexpected failure
 */
int walk_block_dqentry(const struct lu_env *env, struct osd_object *obj,
		       int type, uint blk, uint index,
		       struct osd_it_quota *it)
{
	dqbuf_t				 buf = getdqbuf();
	loff_t				 ret = 0;
	struct lustre_disk_dqdbheader	*dqhead;
	int				 i, dqblk_sz;
	struct lustre_disk_dqblk_v2	*ddquot;
	struct osd_quota_leaf		*leaf;
	ENTRY;

	/* check if the leaf block has been processed before */
	cfs_list_for_each_entry(leaf, &it->oiq_list, oql_link) {
		if (leaf->oql_blk == blk)
			RETURN(1);
	}

	dqhead = (struct lustre_disk_dqdbheader *)buf;
	dqblk_sz = sizeof(struct lustre_disk_dqblk_v2);
	if (!buf)
		RETURN(-ENOMEM);
	ret = quota_read_blk(env, obj, type, blk, buf);
	if (ret < 0) {
		CERROR("Can't read quota tree block %u.\n", blk);
		GOTO(out_buf, ret);
	}
	ret = 1;

	if (!le32_to_cpu(dqhead->dqdh_entries))
		GOTO(out_buf, ret);

	ddquot = (struct lustre_disk_dqblk_v2 *)GETENTRIES(buf);
	LASSERT(index < LUSTRE_DQSTRINBLK);
	for (i = index; i < LUSTRE_DQSTRINBLK; i++) {
		/* skip empty entry */
		if (!memcmp((char *)&emptydquot,
			    (char *)&ddquot[i], dqblk_sz))
			continue;

		it->oiq_blk[LUSTRE_DQTREEDEPTH] = blk;
		it->oiq_id = le32_to_cpu(ddquot[i].dqb_id);
		it->oiq_offset = (blk << LUSTRE_DQBLKSIZE_BITS) +
				  sizeof(struct lustre_disk_dqdbheader) +
				  i * dqblk_sz;
		it->oiq_index[LUSTRE_DQTREEDEPTH] = i;
		ret = 0;
		break;
	}

out_buf:
	freedqbuf(buf);
	RETURN(ret);
}

/**
 * Search from \a index within the tree block \a blk, and fill the \a it
 * with the first valid entry.
 *
 * \retval +ve, no valid entry found
 * \retval   0, entry found
 * \retval -ve, unexpected failure
 */
int walk_tree_dqentry(const struct lu_env *env, struct osd_object *obj,
		      int type, uint blk, int depth, uint index,
		      struct osd_it_quota *it)
{
	dqbuf_t	 buf = getdqbuf();
	loff_t	 ret;
	u32	*ref = (u32 *) buf;

	ENTRY;

	if (!buf)
		RETURN(-ENOMEM);
	ret = quota_read_blk(env, obj, type, blk, buf);
	if (ret < 0) {
		CERROR("Can't read quota tree block %u.\n", blk);
		goto out_buf;
	}
	ret = 1;

	for (; index <= 0xff && ret > 0; index++) {
		blk = le32_to_cpu(ref[index]);
		if (!blk)       /* No reference */
			continue;

		if (depth < LUSTRE_DQTREEDEPTH - 1)
			ret = walk_tree_dqentry(env, obj, type, blk,
						depth + 1, 0, it);
		else
			ret = walk_block_dqentry(env, obj, type, blk, 0, it);
	}

	if (ret == 0) { /* Entry found */
		it->oiq_blk[depth + 1] = blk;
		it->oiq_index[depth] = index;
	}

out_buf:
	freedqbuf(buf);
	RETURN(ret);
}