1 /* $NetBSD: puffs_sys.h,v 1.70 2008/01/28 21:06:37 pooka Exp $ */ 2 3 /* 4 * Copyright (c) 2005, 2006 Antti Kantee. All Rights Reserved. 5 * 6 * Development of this software was supported by the 7 * Google Summer of Code program and the Ulla Tuominen Foundation. 8 * The Google SoC project was mentored by Bill Studenmund. 9 * 10 * Redistribution and use in source and binary forms, with or without 11 * modification, are permitted provided that the following conditions 12 * are met: 13 * 1. Redistributions of source code must retain the above copyright 14 * notice, this list of conditions and the following disclaimer. 15 * 2. Redistributions in binary form must reproduce the above copyright 16 * notice, this list of conditions and the following disclaimer in the 17 * documentation and/or other materials provided with the distribution. 18 * 19 * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS 20 * OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED 21 * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE 22 * DISCLAIMED. IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS BE LIABLE 23 * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL 24 * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR 25 * SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) 26 * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT 27 * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY 28 * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF 29 * SUCH DAMAGE. 30 */ 31 32 #ifndef _PUFFS_SYS_H_ 33 #define _PUFFS_SYS_H_ 34 35 #include <sys/param.h> 36 #include <sys/select.h> 37 #include <sys/kauth.h> 38 #include <sys/mutex.h> 39 #include <sys/queue.h> 40 #include <sys/pool.h> 41 42 #include <fs/puffs/puffs_msgif.h> 43 44 #include <miscfs/genfs/genfs_node.h> 45 46 extern int (**puffs_vnodeop_p)(void *); 47 extern int (**puffs_specop_p)(void *); 48 extern int (**puffs_fifoop_p)(void *); 49 50 extern const struct vnodeopv_desc puffs_vnodeop_opv_desc; 51 extern const struct vnodeopv_desc puffs_specop_opv_desc; 52 extern const struct vnodeopv_desc puffs_fifoop_opv_desc; 53 extern const struct vnodeopv_desc puffs_msgop_opv_desc; 54 55 extern struct pool puffs_pnpool; 56 57 #ifdef DEBUG 58 #ifndef PUFFSDEBUG 59 #define PUFFSDEBUG 60 #endif 61 #endif 62 63 #ifdef PUFFSDEBUG 64 extern int puffsdebug; /* puffs_subr.c */ 65 #define DPRINTF(x) if (puffsdebug > 0) printf x 66 #define DPRINTF_VERBOSE(x) if (puffsdebug > 1) printf x 67 #else 68 #define DPRINTF(x) 69 #define DPRINTF_VERBOSE(x) 70 #endif 71 72 #define MPTOPUFFSMP(mp) ((struct puffs_mount *)((mp)->mnt_data)) 73 #define PMPTOMP(pmp) (pmp->pmp_mp) 74 #define VPTOPP(vp) ((struct puffs_node *)(vp)->v_data) 75 #define VPTOPNC(vp) (((struct puffs_node *)(vp)->v_data)->pn_cookie) 76 #define VPTOPUFFSMP(vp) ((struct puffs_mount*)((struct puffs_node*)vp->v_data)) 77 78 /* we don't pass the kernel overlay to userspace */ 79 #define PUFFS_TOFHSIZE(s) ((s)==0 ? (s) : (s)+4) 80 #define PUFFS_FROMFHSIZE(s) ((s)==0 ? (s) : (s)-4) 81 82 #define ALLOPS(pmp) (pmp->pmp_flags & PUFFS_KFLAG_ALLOPS) 83 #define EXISTSOP(pmp, op) \ 84 (ALLOPS(pmp) || ((pmp)->pmp_vnopmask[PUFFS_VN_##op])) 85 86 #define PUFFS_USE_NAMECACHE(pmp) \ 87 (((pmp)->pmp_flags & PUFFS_KFLAG_NOCACHE_NAME) == 0) 88 #define PUFFS_USE_PAGECACHE(pmp) \ 89 (((pmp)->pmp_flags & PUFFS_KFLAG_NOCACHE_PAGE) == 0) 90 #define PUFFS_USE_FULLPNBUF(pmp) \ 91 ((pmp)->pmp_flags & PUFFS_KFLAG_LOOKUP_FULLPNBUF) 92 93 #define PUFFS_WCACHEINFO(pmp) 0 94 95 struct puffs_newcookie { 96 puffs_cookie_t pnc_cookie; 97 98 LIST_ENTRY(puffs_newcookie) pnc_entries; 99 }; 100 101 TAILQ_HEAD(puffs_wq, puffs_msgpark); 102 LIST_HEAD(puffs_node_hashlist, puffs_node); 103 struct puffs_mount { 104 kmutex_t pmp_lock; 105 106 struct puffs_kargs pmp_args; 107 #define pmp_flags pmp_args.pa_flags 108 #define pmp_vnopmask pmp_args.pa_vnopmask 109 110 struct puffs_wq pmp_msg_touser; 111 int pmp_msg_touser_count; 112 kcondvar_t pmp_msg_waiter_cv; 113 size_t pmp_msg_maxsize; 114 115 struct puffs_wq pmp_msg_replywait; 116 117 struct puffs_node_hashlist *pmp_pnodehash; 118 int pmp_npnodehash; 119 120 LIST_HEAD(, puffs_newcookie) pmp_newcookie; 121 122 struct mount *pmp_mp; 123 124 struct vnode *pmp_root; 125 puffs_cookie_t pmp_root_cookie; 126 enum vtype pmp_root_vtype; 127 vsize_t pmp_root_vsize; 128 dev_t pmp_root_rdev; 129 130 struct putter_instance *pmp_pi; 131 132 unsigned int pmp_refcount; 133 kcondvar_t pmp_refcount_cv; 134 135 kcondvar_t pmp_unmounting_cv; 136 uint8_t pmp_unmounting; 137 138 uint8_t pmp_status; 139 uint8_t pmp_suspend; 140 141 uint8_t *pmp_curput; 142 size_t pmp_curres; 143 void *pmp_curopaq; 144 145 uint64_t pmp_nextmsgid; 146 }; 147 148 #define PUFFSTAT_BEFOREINIT 0 149 #define PUFFSTAT_MOUNTING 1 150 #define PUFFSTAT_RUNNING 2 151 #define PUFFSTAT_DYING 3 /* Do you want your possessions identified? */ 152 153 154 #define PNODE_NOREFS 0x01 /* no backend reference */ 155 #define PNODE_SUSPEND 0x04 /* issue all operations as FAF */ 156 #define PNODE_DOINACT 0x08 /* if inactive-on-demand, call inactive */ 157 158 #define PNODE_METACACHE_ATIME 0x10 /* cache atime metadata */ 159 #define PNODE_METACACHE_CTIME 0x20 /* cache atime metadata */ 160 #define PNODE_METACACHE_MTIME 0x40 /* cache atime metadata */ 161 #define PNODE_METACACHE_SIZE 0x80 /* cache atime metadata */ 162 #define PNODE_METACACHE_MASK 0xf0 163 164 struct puffs_node { 165 struct genfs_node pn_gnode; /* genfs glue */ 166 167 kmutex_t pn_mtx; 168 int pn_refcount; 169 170 puffs_cookie_t pn_cookie; /* userspace pnode cookie */ 171 struct vnode *pn_vp; /* backpointer to vnode */ 172 uint32_t pn_stat; /* node status */ 173 174 struct selinfo pn_sel; /* for selecting on the node */ 175 short pn_revents; /* available events */ 176 177 /* metacache */ 178 struct timespec pn_mc_atime; 179 struct timespec pn_mc_ctime; 180 struct timespec pn_mc_mtime; 181 u_quad_t pn_mc_size; 182 183 voff_t pn_serversize; 184 185 LIST_ENTRY(puffs_node) pn_hashent; 186 }; 187 188 typedef void (*parkdone_fn)(struct puffs_mount *, struct puffs_req *, void *); 189 190 struct puffs_msgpark; 191 void puffs_msgif_init(void); 192 void puffs_msgif_destroy(void); 193 int puffs_msgmem_alloc(size_t, struct puffs_msgpark **, void **, int); 194 void puffs_msgmem_release(struct puffs_msgpark *); 195 196 void puffs_msg_setfaf(struct puffs_msgpark *); 197 void puffs_msg_setdelta(struct puffs_msgpark *, size_t); 198 void puffs_msg_setinfo(struct puffs_msgpark *, int, int, puffs_cookie_t); 199 void puffs_msg_setcall(struct puffs_msgpark *, parkdone_fn, void *); 200 201 void puffs_msg_enqueue(struct puffs_mount *, struct puffs_msgpark *); 202 int puffs_msg_wait(struct puffs_mount *, struct puffs_msgpark *); 203 int puffs_msg_wait2(struct puffs_mount *, struct puffs_msgpark *, 204 struct puffs_node *, struct puffs_node *); 205 206 void puffs_msg_sendresp(struct puffs_mount *, struct puffs_req *, int); 207 208 int puffs_getvnode(struct mount *, puffs_cookie_t, enum vtype, 209 voff_t, dev_t, struct vnode **); 210 int puffs_newnode(struct mount *, struct vnode *, struct vnode **, 211 puffs_cookie_t, struct componentname *, 212 enum vtype, dev_t); 213 void puffs_putvnode(struct vnode *); 214 215 void puffs_releasenode(struct puffs_node *); 216 void puffs_referencenode(struct puffs_node *); 217 218 #define PUFFS_NOSUCHCOOKIE (-1) 219 int puffs_cookie2vnode(struct puffs_mount *, puffs_cookie_t, int, int, 220 struct vnode **); 221 void puffs_makecn(struct puffs_kcn *, struct puffs_kcred *, 222 const struct componentname *, int); 223 void puffs_credcvt(struct puffs_kcred *, kauth_cred_t); 224 225 void puffs_parkdone_asyncbioread(struct puffs_mount *, 226 struct puffs_req *, void *); 227 void puffs_parkdone_asyncbiowrite(struct puffs_mount *, 228 struct puffs_req *, void *); 229 void puffs_parkdone_poll(struct puffs_mount *, struct puffs_req *, void *); 230 231 void puffs_mp_reference(struct puffs_mount *); 232 void puffs_mp_release(struct puffs_mount *); 233 234 void puffs_gop_size(struct vnode *, off_t, off_t *, int); 235 void puffs_gop_markupdate(struct vnode *, int); 236 237 void puffs_senderr(struct puffs_mount *, int, int, const char *, 238 puffs_cookie_t); 239 240 void puffs_updatenode(struct puffs_node *, int, voff_t); 241 #define PUFFS_UPDATEATIME 0x01 242 #define PUFFS_UPDATECTIME 0x02 243 #define PUFFS_UPDATEMTIME 0x04 244 #define PUFFS_UPDATESIZE 0x08 245 246 void puffs_userdead(struct puffs_mount *); 247 248 extern int (**puffs_vnodeop_p)(void *); 249 250 /* for putter */ 251 int puffs_msgif_getout(void *, size_t, int, uint8_t **, size_t *, void **); 252 void puffs_msgif_releaseout(void *, void *, int); 253 int puffs_msgif_dispatch(void *, struct putter_hdr *); 254 size_t puffs_msgif_waitcount(void *); 255 int puffs_msgif_close(void *); 256 257 static __inline int 258 checkerr(struct puffs_mount *pmp, int error, const char *str) 259 { 260 261 if (error < 0 || error > ELAST) { 262 puffs_senderr(pmp, PUFFS_ERR_ERROR, error, str, NULL); 263 error = EPROTO; 264 } 265 266 return error; 267 } 268 269 #define PUFFS_MSG_VARS(type, a) \ 270 struct puffs_##type##msg_##a *a##_msg; \ 271 struct puffs_msgpark *park_##a = NULL 272 273 #define PUFFS_MSG_ALLOC(type, a) \ 274 puffs_msgmem_alloc(sizeof(struct puffs_##type##msg_##a), \ 275 &park_##a, (void *)& a##_msg, 1) 276 277 #define PUFFS_MSG_RELEASE(a) \ 278 do { \ 279 if (park_##a) puffs_msgmem_release(park_##a); \ 280 } while (/*CONSTCOND*/0) 281 282 #define PUFFS_MSG_ENQUEUEWAIT(pmp, park, var) \ 283 do { \ 284 puffs_msg_enqueue(pmp, park); \ 285 var = puffs_msg_wait(pmp, park); \ 286 } while (/*CONSTCOND*/0) 287 288 #define PUFFS_MSG_ENQUEUEWAIT2(pmp, park, vp1, vp2, var) \ 289 do { \ 290 puffs_msg_enqueue(pmp, park); \ 291 var = puffs_msg_wait2(pmp, park, vp1, vp2); \ 292 } while (/*CONSTCOND*/0) 293 294 #endif /* _PUFFS_SYS_H_ */ 295