2 * Copyright (c) 2001,2005 Russell Cattelan
5 * Redistribution and use in source and binary forms, with or without
6 * modification, are permitted provided that the following conditions
8 * 1. Redistributions of source code must retain the above copyright
9 * notice, this list of conditions and the following disclaimer.
10 * 2. Redistributions in binary form must reproduce the above copyright
11 * notice, this list of conditions and the following disclaimer in the
12 * documentation and/or other materials provided with the distribution.
14 * THIS SOFTWARE IS PROVIDED BY THE AUTHOR AND CONTRIBUTORS ``AS IS'' AND
15 * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
16 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
17 * ARE DISCLAIMED. IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS BE LIABLE
18 * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
19 * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
20 * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
21 * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
22 * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
23 * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
30 #include "xfs_types.h"
33 #include "xfs_trans.h"
38 #include "xfs_dmapi.h"
39 #include "xfs_mount.h"
41 #include "xfs_mountops.h"
43 #include <geom/geom.h>
44 #include <geom/geom_vfs.h>
47 xfs_buf_read_flags(xfs_buftarg_t *target, xfs_daddr_t blkno, size_t len, int flags)
50 KASSERT((target != NULL), ("got NULL buftarg_t"));
52 if (bread(target->specvp, blkno, BBTOB(len), NOCRED, &bp)) {
53 printf("bread failed specvp %p blkno %qd BBTOB(len) %ld\n",
54 target->specvp, blkno, (long)BBTOB(len));
58 /* not really sure what B_MANAGED really does for us
59 * maybe we should drop this and just stick with a locked buf
62 if (flags & B_MANAGED)
63 bp->b_flags |= B_MANAGED;
64 xfs_buf_set_target(bp, target);
69 xfs_buf_get_flags(xfs_buftarg_t *target, xfs_daddr_t blkno, size_t len, int flags)
71 struct buf *bp = NULL;
72 KASSERT((target != NULL), ("got NULL buftarg_t"));
73 bp = getblk(target->specvp, blkno, BBTOB(len), 0, 0, 0);
75 xfs_buf_set_target(bp, target);
80 xfs_buf_get_empty(size_t size, xfs_buftarg_t *target)
91 xfs_buf_set_target(bp, target);
97 xfs_buf_get_noaddr(size_t len, xfs_buftarg_t *target)
103 bp = geteblk(len, 0);
107 xfs_buf_set_target(bp, target);
113 xfs_buf_free(xfs_buf_t *bp)
115 bp->b_flags |= B_INVAL;
116 BUF_KERNPROC(bp); /* ugly hack #1 */
117 if (bp->b_kvasize == 0) {
118 bp->b_saveaddr = bp->b_kvabase; /* ugly hack #2 */
119 bp->b_data = bp->b_saveaddr;
128 xfs_buftarg_t *target,
131 xfs_buf_flags_t flags)
137 rabsize = BBTOB(isize);
138 breada(target->specvp, &rablkno, &rabsize, 1, NOCRED);
142 xfs_buf_set_target(xfs_buf_t *bp, xfs_buftarg_t *targ)
144 bp->b_bufobj = &targ->specvp->v_bufobj;
145 bp->b_caller1 = targ;
149 xfs_buf_get_target(xfs_buf_t *bp)
151 return (xfs_buftarg_t *)bp->b_caller1;
155 XFS_bwrite(xfs_buf_t *bp)
158 if (bp->b_vp == NULL) {
159 error = xfs_buf_iorequest(bp);
161 if ((bp->b_flags & B_ASYNC) == 0) {
164 if (BUF_LOCKRECURSED(bp))
178 xfs_buf_pin(xfs_buf_t *bp)
184 xfs_buf_unpin(xfs_buf_t *bp)
190 xfs_buf_ispin(xfs_buf_t *bp)
192 return bp->b_pin_count;
205 * Move data into or out of a buffer.
209 xfs_buf_t *bp, /* buffer to process */
210 size_t boff, /* starting buffer offset */
211 size_t bsize, /* length to copy */
212 caddr_t data, /* data address */
213 xfs_buf_rw_t mode) /* read/write/zero flag */
216 printf("xfs_buf_iomove NI\n");
218 size_t bend, cpoff, csize;
222 while (boff < bend) {
223 page = bp->b_pages[xfs_buf_btoct(boff + bp->b_offset)];
224 cpoff = xfs_buf_poff(boff + bp->b_offset);
225 csize = min_t(size_t,
226 PAGE_CACHE_SIZE-cpoff, bp->b_count_desired-boff);
228 ASSERT(((csize + cpoff) <= PAGE_CACHE_SIZE));
232 memset(page_address(page) + cpoff, 0, csize);
235 memcpy(data, page_address(page) + cpoff, csize);
238 memcpy(page_address(page) + cpoff, data, csize);
248 * Handling of buffer targets (buftargs).
252 * Wait for any bufs with callbacks that have been submitted but
253 * have not yet returned... walk the hash list for the target.
259 printf("xfs_wait_buftarg(%p) NI\n", bp);
269 error = vinvalbuf(btp->specvp, V_SAVE | V_NORMAL, 0, 0);
278 xfs_flush_buftarg(btp, /* wait */ 0);
279 kmem_free(btp, sizeof(*btp));
283 xfs_readonly_buftarg(
286 struct g_consumer *cp;
288 KASSERT(btp->specvp->v_bufobj.bo_ops == &xfs_bo_ops,
289 ("Bogus xfs_buftarg_t pointer"));
290 cp = btp->specvp->v_bufobj.bo_private;
291 return (cp->acw == 0);
299 printf("xfs_relse_buftargNI %p\n",btp);
307 struct g_consumer *cp;
308 cp = btp->specvp->v_bufobj.bo_private;
309 return (cp->provider->sectorsize);
315 unsigned int blocksize,
316 unsigned int sectorsize)
318 printf("xfs_setsize_buftarg NI %p\n",btp);
329 btp = kmem_zalloc(sizeof(*btp), KM_SLEEP);
331 btp->dev = bdev->v_rdev;