#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 <sys/time.h>
#include <fcntl.h>
#include <unistd.h>
#include <errno.h>
#include <linux/types.h>

#include "libgfs2.h"

#ifndef IOV_MAX
  #ifdef UIO_MAXIOV
    #define IOV_MAX UIO_MAXIOV
  #else
    #define IOV_MAX (1024)
  #endif
#endif

struct gfs2_buffer_head *bget(struct gfs2_sbd *sdp, uint64_t num)
{
	struct gfs2_buffer_head *bh;

	bh = calloc(1, sizeof(struct gfs2_buffer_head) + sdp->bsize);
	if (bh == NULL)
		return NULL;

	bh->b_blocknr = num;
	bh->sdp = sdp;
	bh->iov.iov_base = (char *)bh + sizeof(struct gfs2_buffer_head);
	bh->iov.iov_len = sdp->bsize;

	return bh;
}

int __breadm(struct gfs2_sbd *sdp, struct gfs2_buffer_head **bhs, size_t n,
	     uint64_t block, int line, const char *caller)
{
	size_t v = (n < IOV_MAX) ? n : IOV_MAX;
	struct iovec *iov = alloca(v * sizeof(struct iovec));
	struct iovec *iovbase = iov;
	size_t i = 0;

	while (i < n) {
		int j;
		ssize_t ret;
		ssize_t size = 0;

		for (j = 0; (i + j < n) && (j < IOV_MAX); j++) {
			bhs[i + j] = bget(sdp, block + i + j);
			if (bhs[i + j] == NULL)
				return -1;
			iov[j] = bhs[i + j]->iov;
			size += bhs[i + j]->iov.iov_len;
		}

		ret = preadv(sdp->device_fd, iovbase, j, (block + i) * sdp->bsize);
		if (ret != size) {
			fprintf(stderr, "bad read: %s from %s:%d: block %llu (0x%llx) "
					"count: %d size: %zd ret: %zd\n", strerror(errno),
					caller, line, (unsigned long long)block,
					(unsigned long long)block, j, size, ret);
			exit(-1);
		}
		i += j;
	}
	return 0;
}

struct gfs2_buffer_head *__bread(struct gfs2_sbd *sdp, uint64_t num, int line,
				 const char *caller)
{
	struct gfs2_buffer_head *bh;
	int ret;

	ret = __breadm(sdp, &bh, 1, num, line, caller);
	if (ret >= 0)
		return bh;
	return NULL;
}

int bwrite(struct gfs2_buffer_head *bh)
{
	struct gfs2_sbd *sdp = bh->sdp;

	if (pwritev(sdp->device_fd, &bh->iov, 1, bh->b_blocknr * sdp->bsize) != bh->iov.iov_len)
		return -1;
	bh->b_modified = 0;
	return 0;
}

int brelse(struct gfs2_buffer_head *bh)
{
	int error = 0;

	if (bh->b_blocknr == -1)
		printf("Double free!\n");
	if (bh->b_modified)
		error = bwrite(bh);
	bh->b_blocknr = -1;
	if (bh->b_altlist.next && !osi_list_empty(&bh->b_altlist))
		osi_list_del(&bh->b_altlist);
	free(bh);
	return error;
}

uint32_t lgfs2_get_block_type(const struct gfs2_buffer_head *lbh)
{
	const struct gfs2_meta_header *mh = lbh->iov.iov_base;

	if (be32_to_cpu(mh->mh_magic) == GFS2_MAGIC)
		return be32_to_cpu(mh->mh_type);

	return 0;
}