1 files changed, 188 insertions, 0 deletions
diff --git a/sys/gnu/fs/xfs/FreeBSD/xfs_buf.c b/sys/gnu/fs/xfs/FreeBSD/xfs_buf.c
new file mode 100644
index 0000000..ac300db
--- /dev/null
+++ b/sys/gnu/fs/xfs/FreeBSD/xfs_buf.c
@@ -0,0 +1,188 @@
+/*
+ *
+ *
+ */
+#include "xfs.h"
+#include "xfs_macros.h"
+#include "xfs_types.h"
+#include "xfs_inum.h"
+#include "xfs_log.h"
+#include "xfs_trans.h"
+#include "xfs_sb.h"
+#include "xfs_ag.h"
+#include "xfs_dir.h"
+#include "xfs_dir2.h"
+#include "xfs_dmapi.h"
+#include "xfs_mount.h"
+#include "xfs_clnt.h"
+#include "xfs_mountops.h"
+#include <geom/geom.h>
+
+xfs_buf_t *
+xfs_buf_read_flags(xfs_buftarg_t *target, xfs_daddr_t blkno, size_t len, int flags)
+{
+	struct buf *bp;
+	struct g_consumer *cp;
+
+	KASSERT((target != NULL), ("got NULL buftarg_t"));
+
+	cp = target->specvp->v_bufobj.bo_private;
+	if (cp == NULL) {
+		bp = NULL;
+		goto done;
+	}
+
+	/* This restriction is in GEOM's g_io_request() */
+	if ((BBTOB(len) % cp->provider->sectorsize) != 0) {
+		printf("Read request %ld does not align with sector size: %d\n",
+		    (long)BBTOB(len), cp->provider->sectorsize);
+		bp = NULL;
+		goto done;
+	}
+
+	if (bread(target->specvp, blkno, BBTOB(len), NOCRED, &bp)) {
+		printf("bread failed specvp %p blkno %qd BBTOB(len) %ld\n",
+		       target->specvp, blkno, (long)BBTOB(len));
+		bp = NULL;
+		goto done;
+	}
+	if (flags & B_MANAGED)
+		bp->b_flags |= B_MANAGED;
+	xfs_buf_set_target(bp, target);
+
+done:
+	return (bp);
+}
+
+xfs_buf_t *
+xfs_buf_get_flags(xfs_buftarg_t *target, xfs_daddr_t blkno, size_t len, int flags)
+{
+	struct buf *bp = NULL;
+	KASSERT((target != NULL), ("got NULL buftarg_t"));
+	bp = getblk(target->specvp, blkno, BBTOB(len), 0, 0, 0);
+	if (bp != NULL)
+		xfs_buf_set_target(bp, target);
+	return (bp);
+}
+
+xfs_buf_t*
+xfs_buf_get_empty(size_t size,  xfs_buftarg_t *target)
+{
+	struct buf *bp;
+
+	bp = geteblk(0);
+	if (bp != NULL) {
+		bp->b_bufsize = size;
+		bp->b_bcount = size;
+
+		KASSERT(BUF_REFCNT(bp) == 1,
+			("xfs_buf_get_empty: bp %p not locked",bp));
+
+		xfs_buf_set_target(bp, target);
+	}
+	return (bp);
+}
+
+xfs_buf_t*
+xfs_buf_get_noaddr(size_t len, xfs_buftarg_t *target)
+{
+	struct buf *bp;
+	if (len >= MAXPHYS)
+		return (NULL);
+
+	bp = geteblk(len);
+	if (bp != NULL) {
+		KASSERT(BUF_REFCNT(bp) == 1,
+			("xfs_buf_get_empty: bp %p not locked",bp));
+
+		xfs_buf_set_target(bp, target);
+	}
+
+	return (bp);
+}
+
+void
+xfs_buf_free(xfs_buf_t *bp)
+{
+	bp->b_flags |= B_INVAL;
+	BUF_KERNPROC(bp);			 /* ugly hack #1 */
+	if (bp->b_kvasize == 0) {
+		bp->b_saveaddr = bp->b_kvabase;  /* ugly hack #2 */
+		bp->b_data = bp->b_saveaddr;
+		bp->b_bcount  = 0;
+		bp->b_bufsize = 0;
+	}
+	brelse(bp);
+}
+
+void
+xfs_baread(xfs_buftarg_t *targp, xfs_daddr_t ioff, size_t isize)
+{
+	daddr_t rablkno;
+	int rabsize;
+
+	rablkno = ioff;
+	rabsize = BBTOB(isize);
+	breada(targp->specvp, &rablkno, &rabsize, 1, NOCRED);
+}
+
+void
+xfs_buf_set_target(xfs_buf_t *bp, xfs_buftarg_t *targ)
+{
+	bp->b_bufobj = &targ->specvp->v_bufobj;
+	bp->b_caller1 = targ;
+}
+
+xfs_buftarg_t *
+xfs_buf_get_target(xfs_buf_t *bp)
+{
+	return (xfs_buftarg_t *)bp->b_caller1;
+}
+
+int
+XFS_bwrite(xfs_buf_t *bp)
+{
+	int error;
+	if (bp->b_vp == NULL) {
+		error = xfs_buf_iorequest(bp);
+
+		if ((bp->b_flags & B_ASYNC) == 0) {
+			error = bufwait(bp);
+			if (BUF_REFCNT(bp) > 1)
+				BUF_UNLOCK(bp);
+			else
+				brelse(bp);
+		}
+		return (error);
+	}
+	error = bwrite(bp);
+	return (error);
+}
+
+void
+xfs_bpin(xfs_buf_t *bp)
+{
+	printf("xfs_bpin(%p)\n", bp);
+	bpin(bp);
+}
+
+void
+xfs_bunpin(xfs_buf_t *bp)
+{
+	printf("xfs_bunpin(%p)\n", bp);
+	bunpin(bp);
+}
+
+int
+xfs_ispin(xfs_buf_t *bp)
+{
+	printf("xfs_ispin(%p)\n", bp);
+	return bp->b_pin_count;
+}
+
+void
+xfs_bwait_unpin(xfs_buf_t *bp)
+{
+	printf("xfs_bwait_unpin(%p)\n", bp);
+	bunpin_wait(bp);
+}