Loading...
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 194 195 196 197 198 199 200 201 202 203 204 205 206 207 208 209 210 211 212 213 214 215 216 217 218 219 220 221 222 223 224 225 226 227 228 229 230 231 232 233 234 235 236 237 238 239 240 241 242 243 244 245 246 247 248 249 250 251 252 253 254 255 256 257 258 259 260 261 262 263 264 265 266 267 268 269 270 271 272 273 274 275 276 277 278 279 280 281 282 283 284 285 286 287 288 289 290 291 292 293 294 295 296 297 298 299 300 301 302 303 304 305 306 307 308 309 310 311 312 313 314 315 316 317 318 319 320 321 322 | /* * Copyright (c) 2000-2002 Silicon Graphics, Inc. All Rights Reserved. * * This program is free software; you can redistribute it and/or modify it * under the terms of version 2 of the GNU General Public License as * published by the Free Software Foundation. * * This program is distributed in the hope that it would be useful, but * WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. * * Further, this software is distributed without any warranty that it is * free of the rightful claim of any third person regarding infringement * or the like. Any license provided herein, whether implied or * otherwise, applies only to this software file. Patent licenses, if * any, provided herein do not apply to combinations of this program with * other software, or any other product whatsoever. * * You should have received a copy of the GNU General Public License along * with this program; if not, write the Free Software Foundation, Inc., 59 * Temple Place - Suite 330, Boston MA 02111-1307, USA. * * Contact information: Silicon Graphics, Inc., 1600 Amphitheatre Pkwy, * Mountain View, CA 94043, or: * * http://www.sgi.com * * For further information regarding this notice, see: * * http://oss.sgi.com/projects/GenInfo/SGIGPLNoticeExplan/ */ #ifndef __XFS_BUF_H__ #define __XFS_BUF_H__ /* These are just for xfs_syncsub... it sets an internal variable * then passes it to VOP_FLUSH_PAGES or adds the flags to a newly gotten buf_t */ #define XFS_B_ASYNC PBF_ASYNC #define XFS_B_DELWRI PBF_DELWRI #define XFS_B_READ PBF_READ #define XFS_B_WRITE PBF_WRITE #define XFS_B_STALE PBF_STALE #define XFS_BUF_TRYLOCK PBF_TRYLOCK #define XFS_INCORE_TRYLOCK PBF_TRYLOCK #define XFS_BUF_LOCK PBF_LOCK #define XFS_BUF_MAPPED PBF_MAPPED #define BUF_BUSY PBF_DONT_BLOCK #define XFS_BUF_BFLAGS(x) ((x)->pb_flags) #define XFS_BUF_ZEROFLAGS(x) \ ((x)->pb_flags &= ~(PBF_READ|PBF_WRITE|PBF_ASYNC|PBF_SYNC|PBF_DELWRI)) #define XFS_BUF_STALE(x) ((x)->pb_flags |= XFS_B_STALE) #define XFS_BUF_UNSTALE(x) ((x)->pb_flags &= ~XFS_B_STALE) #define XFS_BUF_ISSTALE(x) ((x)->pb_flags & XFS_B_STALE) #define XFS_BUF_SUPER_STALE(x) do { \ XFS_BUF_STALE(x); \ xfs_buf_undelay(x); \ XFS_BUF_DONE(x); \ } while (0) #define XFS_BUF_MANAGE PBF_FS_MANAGED #define XFS_BUF_UNMANAGE(x) ((x)->pb_flags &= ~PBF_FS_MANAGED) static inline void xfs_buf_undelay(page_buf_t *pb) { if (pb->pb_flags & PBF_DELWRI) { if (pb->pb_list.next != &pb->pb_list) { pagebuf_delwri_dequeue(pb); pagebuf_rele(pb); } else { pb->pb_flags &= ~PBF_DELWRI; } } } #define XFS_BUF_DELAYWRITE(x) ((x)->pb_flags |= PBF_DELWRI) #define XFS_BUF_UNDELAYWRITE(x) xfs_buf_undelay(x) #define XFS_BUF_ISDELAYWRITE(x) ((x)->pb_flags & PBF_DELWRI) #define XFS_BUF_ERROR(x,no) pagebuf_ioerror(x,no) #define XFS_BUF_GETERROR(x) pagebuf_geterror(x) #define XFS_BUF_ISERROR(x) (pagebuf_geterror(x)?1:0) #define XFS_BUF_DONE(x) ((x)->pb_flags &= ~(PBF_PARTIAL|PBF_NONE)) #define XFS_BUF_UNDONE(x) ((x)->pb_flags |= PBF_PARTIAL|PBF_NONE) #define XFS_BUF_ISDONE(x) (!(PBF_NOT_DONE(x))) #define XFS_BUF_BUSY(x) ((x)->pb_flags |= PBF_FORCEIO) #define XFS_BUF_UNBUSY(x) ((x)->pb_flags &= ~PBF_FORCEIO) #define XFS_BUF_ISBUSY(x) (1) #define XFS_BUF_ASYNC(x) ((x)->pb_flags |= PBF_ASYNC) #define XFS_BUF_UNASYNC(x) ((x)->pb_flags &= ~PBF_ASYNC) #define XFS_BUF_ISASYNC(x) ((x)->pb_flags & PBF_ASYNC) #define XFS_BUF_FLUSH(x) ((x)->pb_flags |= PBF_FLUSH) #define XFS_BUF_UNFLUSH(x) ((x)->pb_flags &= ~PBF_FLUSH) #define XFS_BUF_ISFLUSH(x) ((x)->pb_flags & PBF_FLUSH) #define XFS_BUF_SHUT(x) printk("XFS_BUF_SHUT not implemented yet\n") #define XFS_BUF_UNSHUT(x) printk("XFS_BUF_UNSHUT not implemented yet\n") #define XFS_BUF_ISSHUT(x) (0) #define XFS_BUF_HOLD(x) pagebuf_hold(x) #define XFS_BUF_READ(x) ((x)->pb_flags |= PBF_READ) #define XFS_BUF_UNREAD(x) ((x)->pb_flags &= ~PBF_READ) #define XFS_BUF_ISREAD(x) ((x)->pb_flags & PBF_READ) #define XFS_BUF_WRITE(x) ((x)->pb_flags |= PBF_WRITE) #define XFS_BUF_UNWRITE(x) ((x)->pb_flags &= ~PBF_WRITE) #define XFS_BUF_ISWRITE(x) ((x)->pb_flags & PBF_WRITE) #define XFS_BUF_ISUNINITIAL(x) (0) #define XFS_BUF_UNUNINITIAL(x) (0) #define XFS_BUF_BP_ISMAPPED(bp) 1 typedef struct page_buf_s xfs_buf_t; #define xfs_buf page_buf_s typedef struct pb_target xfs_buftarg_t; #define xfs_buftarg pb_target #define XFS_BUF_IODONE_FUNC(buf) (buf)->pb_iodone #define XFS_BUF_SET_IODONE_FUNC(buf, func) \ (buf)->pb_iodone = (func) #define XFS_BUF_CLR_IODONE_FUNC(buf) \ (buf)->pb_iodone = NULL #define XFS_BUF_SET_BDSTRAT_FUNC(buf, func) \ (buf)->pb_strat = (func) #define XFS_BUF_CLR_BDSTRAT_FUNC(buf) \ (buf)->pb_strat = NULL #define XFS_BUF_FSPRIVATE(buf, type) \ ((type)(buf)->pb_fspriv) #define XFS_BUF_SET_FSPRIVATE(buf, value) \ (buf)->pb_fspriv = (void *)(value) #define XFS_BUF_FSPRIVATE2(buf, type) \ ((type)(buf)->pb_fspriv2) #define XFS_BUF_SET_FSPRIVATE2(buf, value) \ (buf)->pb_fspriv2 = (void *)(value) #define XFS_BUF_FSPRIVATE3(buf, type) \ ((type)(buf)->pb_fspriv3) #define XFS_BUF_SET_FSPRIVATE3(buf, value) \ (buf)->pb_fspriv3 = (void *)(value) #define XFS_BUF_SET_START(buf) #define XFS_BUF_SET_BRELSE_FUNC(buf, value) \ (buf)->pb_relse = (value) #define XFS_BUF_PTR(bp) (xfs_caddr_t)((bp)->pb_addr) extern inline xfs_caddr_t xfs_buf_offset(page_buf_t *bp, off_t offset) { if (bp->pb_flags & PBF_MAPPED) return XFS_BUF_PTR(bp) + offset; return (xfs_caddr_t) pagebuf_offset(bp, offset); } #define XFS_BUF_SET_PTR(bp, val, count) \ pagebuf_associate_memory(bp, val, count) #define XFS_BUF_ADDR(bp) ((bp)->pb_bn) #define XFS_BUF_OFFSET(bp) ((bp)->pb_file_offset >> 9) #define XFS_BUF_SET_ADDR(bp, blk) \ ((bp)->pb_bn = (page_buf_daddr_t)(blk)) #define XFS_BUF_COUNT(bp) ((bp)->pb_count_desired) #define XFS_BUF_SET_COUNT(bp, cnt) \ ((bp)->pb_count_desired = cnt) #define XFS_BUF_SIZE(bp) ((bp)->pb_buffer_length) #define XFS_BUF_SET_SIZE(bp, cnt) \ ((bp)->pb_buffer_length = cnt) #define XFS_BUF_SET_VTYPE_REF(bp, type, ref) #define XFS_BUF_SET_VTYPE(bp, type) #define XFS_BUF_SET_REF(bp, ref) #define XFS_BUF_ISPINNED(bp) pagebuf_ispin(bp) #define XFS_BUF_VALUSEMA(bp) pagebuf_lock_value(bp) #define XFS_BUF_CPSEMA(bp) (pagebuf_cond_lock(bp) == 0) #define XFS_BUF_VSEMA(bp) pagebuf_unlock(bp) #define XFS_BUF_PSEMA(bp,x) pagebuf_lock(bp) #define XFS_BUF_V_IODONESEMA(bp) up(&bp->pb_iodonesema); /* setup the buffer target from a buftarg structure */ #define XFS_BUF_SET_TARGET(bp, target) \ (bp)->pb_target = (target) #define XFS_BUF_TARGET(bp) ((bp)->pb_target) #define XFS_BUF_TARGET_DEV(bp) ((bp)->pb_target->pbr_dev) #define XFS_BUF_SET_VTYPE_REF(bp, type, ref) #define XFS_BUF_SET_VTYPE(bp, type) #define XFS_BUF_SET_REF(bp, ref) #define xfs_buf_read(target, blkno, len, flags) \ pagebuf_get((target), (blkno), (len), \ PBF_LOCK | PBF_READ | PBF_MAPPED | PBF_MAPPABLE) #define xfs_buf_get(target, blkno, len, flags) \ pagebuf_get((target), (blkno), (len), \ PBF_LOCK | PBF_MAPPED | PBF_MAPPABLE) #define xfs_buf_read_flags(target, blkno, len, flags) \ pagebuf_get((target), (blkno), (len), \ PBF_READ | PBF_MAPPABLE | flags) #define xfs_buf_get_flags(target, blkno, len, flags) \ pagebuf_get((target), (blkno), (len), \ PBF_MAPPABLE | flags) static inline int xfs_bawrite(void *mp, page_buf_t *bp) { int ret; bp->pb_fspriv3 = mp; bp->pb_strat = xfs_bdstrat_cb; xfs_buf_undelay(bp); if ((ret = pagebuf_iostart(bp, PBF_WRITE | PBF_ASYNC)) == 0) pagebuf_run_queues(bp); return ret; } static inline void xfs_buf_relse(page_buf_t *bp) { if ((bp->pb_flags & _PBF_LOCKABLE) && !bp->pb_relse) pagebuf_unlock(bp); pagebuf_rele(bp); } #define xfs_bpin(bp) pagebuf_pin(bp) #define xfs_bunpin(bp) pagebuf_unpin(bp) #ifdef PAGEBUF_TRACE # define PB_DEFINE_TRACES # include <pagebuf/page_buf_trace.h> # define xfs_buftrace(id, bp) PB_TRACE(bp, PB_TRACE_REC(external), (void *)id) #else # define xfs_buftrace(id, bp) do { } while (0) #endif #define xfs_biodone(pb) \ pagebuf_iodone(pb, 0) #define xfs_incore(buftarg,blkno,len,lockit) \ pagebuf_find(buftarg, blkno ,len, lockit) #define xfs_biomove(pb, off, len, data, rw) \ pagebuf_iomove((pb), (off), (len), (data), \ ((rw) == XFS_B_WRITE) ? PBRW_WRITE : PBRW_READ) #define xfs_biozero(pb, off, len) \ pagebuf_iomove((pb), (off), (len), NULL, PBRW_ZERO) static inline int XFS_bwrite(page_buf_t *pb) { int sync = (pb->pb_flags & PBF_ASYNC) == 0; int error; pb->pb_flags |= PBF_SYNC; xfs_buf_undelay(pb); __pagebuf_iorequest(pb); if (sync) { error = pagebuf_iowait(pb); xfs_buf_relse(pb); } else { pagebuf_run_queues(pb); error = 0; } return error; } #define XFS_bdwrite(pb) \ pagebuf_iostart(pb, PBF_DELWRI | PBF_ASYNC) static inline int xfs_bdwrite(void *mp, page_buf_t *bp) { bp->pb_strat = xfs_bdstrat_cb; bp->pb_fspriv3 = mp; return pagebuf_iostart(bp, PBF_DELWRI | PBF_ASYNC); } #define XFS_bdstrat(bp) pagebuf_iorequest(bp) #define xfs_iowait(pb) pagebuf_iowait(pb) /* * Go through all incore buffers, and release buffers * if they belong to the given device. This is used in * filesystem error handling to preserve the consistency * of its metadata. */ extern void XFS_bflush(xfs_buftarg_t *); #define xfs_binval(buftarg) XFS_bflush(buftarg) #define xfs_incore_relse(buftarg,delwri_only,wait) \ xfs_relse_buftarg(buftarg) #define xfs_baread(target, rablkno, ralen) \ pagebuf_readahead((target), (rablkno), \ (ralen), PBF_DONT_BLOCK) #define XFS_getrbuf(sleep,mp) \ pagebuf_get_empty((mp)->m_ddev_targp) #define XFS_ngetrbuf(len,mp) \ pagebuf_get_no_daddr(len,(mp)->m_ddev_targp) #define XFS_freerbuf(bp) pagebuf_free(bp) #define XFS_nfreerbuf(bp) pagebuf_free(bp) #endif |