puffs_msgif.c revision 1.10.2.2
1 1.10.2.2 yamt /* $NetBSD: puffs_msgif.c,v 1.10.2.2 2006/12/10 07:18:38 yamt Exp $ */ 2 1.10.2.2 yamt 3 1.10.2.2 yamt /* 4 1.10.2.2 yamt * Copyright (c) 2005, 2006 Antti Kantee. All Rights Reserved. 5 1.10.2.2 yamt * 6 1.10.2.2 yamt * Development of this software was supported by the 7 1.10.2.2 yamt * Google Summer of Code program and the Ulla Tuominen Foundation. 8 1.10.2.2 yamt * The Google SoC project was mentored by Bill Studenmund. 9 1.10.2.2 yamt * 10 1.10.2.2 yamt * Redistribution and use in source and binary forms, with or without 11 1.10.2.2 yamt * modification, are permitted provided that the following conditions 12 1.10.2.2 yamt * are met: 13 1.10.2.2 yamt * 1. Redistributions of source code must retain the above copyright 14 1.10.2.2 yamt * notice, this list of conditions and the following disclaimer. 15 1.10.2.2 yamt * 2. Redistributions in binary form must reproduce the above copyright 16 1.10.2.2 yamt * notice, this list of conditions and the following disclaimer in the 17 1.10.2.2 yamt * documentation and/or other materials provided with the distribution. 18 1.10.2.2 yamt * 3. The name of the company nor the name of the author may be used to 19 1.10.2.2 yamt * endorse or promote products derived from this software without specific 20 1.10.2.2 yamt * prior written permission. 21 1.10.2.2 yamt * 22 1.10.2.2 yamt * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS 23 1.10.2.2 yamt * OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED 24 1.10.2.2 yamt * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE 25 1.10.2.2 yamt * DISCLAIMED. IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS BE LIABLE 26 1.10.2.2 yamt * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL 27 1.10.2.2 yamt * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR 28 1.10.2.2 yamt * SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) 29 1.10.2.2 yamt * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT 30 1.10.2.2 yamt * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY 31 1.10.2.2 yamt * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF 32 1.10.2.2 yamt * SUCH DAMAGE. 33 1.10.2.2 yamt */ 34 1.10.2.2 yamt 35 1.10.2.2 yamt #include <sys/cdefs.h> 36 1.10.2.2 yamt __KERNEL_RCSID(0, "$NetBSD: puffs_msgif.c,v 1.10.2.2 2006/12/10 07:18:38 yamt Exp $"); 37 1.10.2.2 yamt 38 1.10.2.2 yamt #include <sys/param.h> 39 1.10.2.2 yamt #include <sys/malloc.h> 40 1.10.2.2 yamt #include <sys/mount.h> 41 1.10.2.2 yamt #include <sys/vnode.h> 42 1.10.2.2 yamt #include <sys/lock.h> 43 1.10.2.2 yamt 44 1.10.2.2 yamt #include <fs/puffs/puffs_msgif.h> 45 1.10.2.2 yamt #include <fs/puffs/puffs_sys.h> 46 1.10.2.2 yamt 47 1.10.2.2 yamt 48 1.10.2.2 yamt /* 49 1.10.2.2 yamt * kernel-user-kernel waitqueues 50 1.10.2.2 yamt */ 51 1.10.2.2 yamt 52 1.10.2.2 yamt static int touser(struct puffs_mount *, struct puffs_park *, uint64_t, 53 1.10.2.2 yamt struct vnode *, struct vnode *); 54 1.10.2.2 yamt 55 1.10.2.2 yamt uint64_t 56 1.10.2.2 yamt puffs_getreqid(struct puffs_mount *pmp) 57 1.10.2.2 yamt { 58 1.10.2.2 yamt unsigned int rv; 59 1.10.2.2 yamt 60 1.10.2.2 yamt simple_lock(&pmp->pmp_lock); 61 1.10.2.2 yamt rv = pmp->pmp_nextreq++; 62 1.10.2.2 yamt simple_unlock(&pmp->pmp_lock); 63 1.10.2.2 yamt 64 1.10.2.2 yamt return rv; 65 1.10.2.2 yamt } 66 1.10.2.2 yamt 67 1.10.2.2 yamt /* vfs request */ 68 1.10.2.2 yamt int 69 1.10.2.2 yamt puffs_vfstouser(struct puffs_mount *pmp, int optype, void *kbuf, size_t buflen) 70 1.10.2.2 yamt { 71 1.10.2.2 yamt struct puffs_park park; 72 1.10.2.2 yamt 73 1.10.2.2 yamt park.park_preq = kbuf; 74 1.10.2.2 yamt 75 1.10.2.2 yamt park.park_preq->preq_opclass = PUFFSOP_VFS; 76 1.10.2.2 yamt park.park_preq->preq_optype = optype; 77 1.10.2.2 yamt 78 1.10.2.2 yamt park.park_maxlen = park.park_copylen = buflen; 79 1.10.2.2 yamt 80 1.10.2.2 yamt return touser(pmp, &park, puffs_getreqid(pmp), NULL, NULL); 81 1.10.2.2 yamt } 82 1.10.2.2 yamt 83 1.10.2.2 yamt /* 84 1.10.2.2 yamt * vnode level request 85 1.10.2.2 yamt */ 86 1.10.2.2 yamt int 87 1.10.2.2 yamt puffs_vntouser(struct puffs_mount *pmp, int optype, 88 1.10.2.2 yamt void *kbuf, size_t buflen, void *cookie, 89 1.10.2.2 yamt struct vnode *vp1, struct vnode *vp2) 90 1.10.2.2 yamt { 91 1.10.2.2 yamt struct puffs_park park; 92 1.10.2.2 yamt 93 1.10.2.2 yamt park.park_preq = kbuf; 94 1.10.2.2 yamt 95 1.10.2.2 yamt park.park_preq->preq_opclass = PUFFSOP_VN; 96 1.10.2.2 yamt park.park_preq->preq_optype = optype; 97 1.10.2.2 yamt park.park_preq->preq_cookie = cookie; 98 1.10.2.2 yamt 99 1.10.2.2 yamt park.park_maxlen = park.park_copylen = buflen; 100 1.10.2.2 yamt 101 1.10.2.2 yamt return touser(pmp, &park, puffs_getreqid(pmp), vp1, vp2); 102 1.10.2.2 yamt } 103 1.10.2.2 yamt 104 1.10.2.2 yamt /* 105 1.10.2.2 yamt * vnode level request, caller-controller req id 106 1.10.2.2 yamt */ 107 1.10.2.2 yamt int 108 1.10.2.2 yamt puffs_vntouser_req(struct puffs_mount *pmp, int optype, 109 1.10.2.2 yamt void *kbuf, size_t buflen, void *cookie, uint64_t reqid, 110 1.10.2.2 yamt struct vnode *vp1, struct vnode *vp2) 111 1.10.2.2 yamt { 112 1.10.2.2 yamt struct puffs_park park; 113 1.10.2.2 yamt 114 1.10.2.2 yamt park.park_preq = kbuf; 115 1.10.2.2 yamt 116 1.10.2.2 yamt park.park_preq->preq_opclass = PUFFSOP_VN; 117 1.10.2.2 yamt park.park_preq->preq_optype = optype; 118 1.10.2.2 yamt park.park_preq->preq_cookie = cookie; 119 1.10.2.2 yamt 120 1.10.2.2 yamt park.park_maxlen = park.park_copylen = buflen; 121 1.10.2.2 yamt 122 1.10.2.2 yamt return touser(pmp, &park, reqid, vp1, vp2); 123 1.10.2.2 yamt } 124 1.10.2.2 yamt 125 1.10.2.2 yamt /* 126 1.10.2.2 yamt * vnode level request, copy routines can adjust "kernbuf". 127 1.10.2.2 yamt * We overload park_copylen != park_maxlen to signal that the park 128 1.10.2.2 yamt * in question is of adjusting type. 129 1.10.2.2 yamt */ 130 1.10.2.2 yamt int 131 1.10.2.2 yamt puffs_vntouser_adjbuf(struct puffs_mount *pmp, int optype, 132 1.10.2.2 yamt void **kbuf, size_t *buflen, size_t maxdelta, 133 1.10.2.2 yamt void *cookie, struct vnode *vp1, struct vnode *vp2) 134 1.10.2.2 yamt { 135 1.10.2.2 yamt struct puffs_park park; 136 1.10.2.2 yamt int error; 137 1.10.2.2 yamt 138 1.10.2.2 yamt park.park_preq = *kbuf; 139 1.10.2.2 yamt 140 1.10.2.2 yamt park.park_preq->preq_opclass = PUFFSOP_VN; 141 1.10.2.2 yamt park.park_preq->preq_optype = optype; 142 1.10.2.2 yamt park.park_preq->preq_cookie = cookie; 143 1.10.2.2 yamt 144 1.10.2.2 yamt park.park_copylen = *buflen; 145 1.10.2.2 yamt park.park_maxlen = maxdelta + *buflen; 146 1.10.2.2 yamt 147 1.10.2.2 yamt error = touser(pmp, &park, puffs_getreqid(pmp), vp1, vp2); 148 1.10.2.2 yamt 149 1.10.2.2 yamt *kbuf = park.park_preq; 150 1.10.2.2 yamt *buflen = park.park_copylen; 151 1.10.2.2 yamt 152 1.10.2.2 yamt return error; 153 1.10.2.2 yamt } 154 1.10.2.2 yamt 155 1.10.2.2 yamt /* 156 1.10.2.2 yamt * Notice: kbuf will be free'd later. I must be allocated from the 157 1.10.2.2 yamt * kernel heap and it's ownership is shifted to this function from 158 1.10.2.2 yamt * now on, i.e. the caller is not allowed to use it anymore! 159 1.10.2.2 yamt */ 160 1.10.2.2 yamt void 161 1.10.2.2 yamt puffs_vntouser_faf(struct puffs_mount *pmp, int optype, 162 1.10.2.2 yamt void *kbuf, size_t buflen, void *cookie) 163 1.10.2.2 yamt { 164 1.10.2.2 yamt struct puffs_park *ppark; 165 1.10.2.2 yamt 166 1.10.2.2 yamt /* XXX: is it allowable to sleep here? */ 167 1.10.2.2 yamt ppark = malloc(sizeof(struct puffs_park), M_PUFFS, M_NOWAIT | M_ZERO); 168 1.10.2.2 yamt if (ppark == NULL) 169 1.10.2.2 yamt return; /* 2bad */ 170 1.10.2.2 yamt 171 1.10.2.2 yamt ppark->park_preq = kbuf; 172 1.10.2.2 yamt 173 1.10.2.2 yamt ppark->park_preq->preq_opclass = PUFFSOP_VN | PUFFSOPFLAG_FAF; 174 1.10.2.2 yamt ppark->park_preq->preq_optype = optype; 175 1.10.2.2 yamt ppark->park_preq->preq_cookie = cookie; 176 1.10.2.2 yamt 177 1.10.2.2 yamt ppark->park_maxlen = ppark->park_copylen = buflen; 178 1.10.2.2 yamt 179 1.10.2.2 yamt (void)touser(pmp, ppark, 0, NULL, NULL); 180 1.10.2.2 yamt } 181 1.10.2.2 yamt 182 1.10.2.2 yamt /* 183 1.10.2.2 yamt * Wait for the userspace ping-pong game in calling process context. 184 1.10.2.2 yamt * 185 1.10.2.2 yamt * This unlocks vnodes if they are supplied. vp1 is the vnode 186 1.10.2.2 yamt * before in the locking order, i.e. the one which must be locked 187 1.10.2.2 yamt * before accessing vp2. This is done here so that operations are 188 1.10.2.2 yamt * already ordered in the queue when vnodes are unlocked (I'm not 189 1.10.2.2 yamt * sure if that's really necessary, but it can't hurt). Okok, maybe 190 1.10.2.2 yamt * there's a slight ugly-factor also, but let's not worry about that. 191 1.10.2.2 yamt */ 192 1.10.2.2 yamt static int 193 1.10.2.2 yamt touser(struct puffs_mount *pmp, struct puffs_park *ppark, uint64_t reqid, 194 1.10.2.2 yamt struct vnode *vp1, struct vnode *vp2) 195 1.10.2.2 yamt { 196 1.10.2.2 yamt struct puffs_req *preq; 197 1.10.2.2 yamt 198 1.10.2.2 yamt simple_lock(&pmp->pmp_lock); 199 1.10.2.2 yamt if (pmp->pmp_status != PUFFSTAT_RUNNING 200 1.10.2.2 yamt && pmp->pmp_status != PUFFSTAT_MOUNTING) { 201 1.10.2.2 yamt simple_unlock(&pmp->pmp_lock); 202 1.10.2.2 yamt return ENXIO; 203 1.10.2.2 yamt } 204 1.10.2.2 yamt 205 1.10.2.2 yamt preq = ppark->park_preq; 206 1.10.2.2 yamt preq->preq_id = reqid; 207 1.10.2.2 yamt preq->preq_buflen = ALIGN(ppark->park_maxlen); 208 1.10.2.2 yamt 209 1.10.2.2 yamt TAILQ_INSERT_TAIL(&pmp->pmp_req_touser, ppark, park_entries); 210 1.10.2.2 yamt pmp->pmp_req_touser_waiters++; 211 1.10.2.2 yamt 212 1.10.2.2 yamt /* 213 1.10.2.2 yamt * Don't do unlock-relock dance yet. There are a couple of 214 1.10.2.2 yamt * unsolved issues with it. If we don't unlock, we can have 215 1.10.2.2 yamt * processes wanting vn_lock in case userspace hangs. But 216 1.10.2.2 yamt * that can be "solved" by killing the userspace process. It 217 1.10.2.2 yamt * would of course be nicer to have antilocking in the userspace 218 1.10.2.2 yamt * interface protocol itself.. your patience will be rewarded. 219 1.10.2.2 yamt */ 220 1.10.2.2 yamt #if 0 221 1.10.2.2 yamt /* unlock */ 222 1.10.2.2 yamt if (vp2) 223 1.10.2.2 yamt VOP_UNLOCK(vp2, 0); 224 1.10.2.2 yamt if (vp1) 225 1.10.2.2 yamt VOP_UNLOCK(vp1, 0); 226 1.10.2.2 yamt #endif 227 1.10.2.2 yamt 228 1.10.2.2 yamt /* 229 1.10.2.2 yamt * XXX: does releasing the lock here cause trouble? Can't hold 230 1.10.2.2 yamt * it, because otherwise the below would cause locking against 231 1.10.2.2 yamt * oneself-problems in the kqueue stuff. yes, it is a 232 1.10.2.2 yamt * theoretical race, so it must be solved 233 1.10.2.2 yamt */ 234 1.10.2.2 yamt simple_unlock(&pmp->pmp_lock); 235 1.10.2.2 yamt 236 1.10.2.2 yamt wakeup(&pmp->pmp_req_touser); 237 1.10.2.2 yamt selnotify(pmp->pmp_sel, 0); 238 1.10.2.2 yamt 239 1.10.2.2 yamt if (PUFFSOP_WANTREPLY(ppark->park_preq->preq_opclass)) 240 1.10.2.2 yamt ltsleep(ppark, PUSER, "puffs1", 0, NULL); 241 1.10.2.2 yamt 242 1.10.2.2 yamt #if 0 243 1.10.2.2 yamt /* relock */ 244 1.10.2.2 yamt if (vp1) 245 1.10.2.2 yamt KASSERT(vn_lock(vp1, LK_EXCLUSIVE | LK_RETRY) == 0); 246 1.10.2.2 yamt if (vp2) 247 1.10.2.2 yamt KASSERT(vn_lock(vp2, LK_EXCLUSIVE | LK_RETRY) == 0); 248 1.10.2.2 yamt #endif 249 1.10.2.2 yamt 250 1.10.2.2 yamt return ppark->park_preq->preq_rv; 251 1.10.2.2 yamt } 252 1.10.2.2 yamt 253 1.10.2.2 yamt 254 1.10.2.2 yamt /* 255 1.10.2.2 yamt * getop: scan through queued requests until: 256 1.10.2.2 yamt * 1) max number of requests satisfied 257 1.10.2.2 yamt * OR 258 1.10.2.2 yamt * 2) buffer runs out of space 259 1.10.2.2 yamt * OR 260 1.10.2.2 yamt * 3) nonblocking is set AND there are no operations available 261 1.10.2.2 yamt * OR 262 1.10.2.2 yamt * 4) at least one operation was transferred AND there are no more waiting 263 1.10.2.2 yamt */ 264 1.10.2.2 yamt int 265 1.10.2.2 yamt puffs_getop(struct puffs_mount *pmp, struct puffs_reqh_get *phg, int nonblock) 266 1.10.2.2 yamt { 267 1.10.2.2 yamt struct puffs_park *park; 268 1.10.2.2 yamt struct puffs_req *preq; 269 1.10.2.2 yamt uint8_t *bufpos; 270 1.10.2.2 yamt int error, donesome; 271 1.10.2.2 yamt 272 1.10.2.2 yamt donesome = error = 0; 273 1.10.2.2 yamt bufpos = phg->phg_buf; 274 1.10.2.2 yamt 275 1.10.2.2 yamt simple_lock(&pmp->pmp_lock); 276 1.10.2.2 yamt while (phg->phg_nops == 0 || donesome != phg->phg_nops) { 277 1.10.2.2 yamt again: 278 1.10.2.2 yamt if (pmp->pmp_status != PUFFSTAT_RUNNING) { 279 1.10.2.2 yamt /* if we got some, they don't really matter anymore */ 280 1.10.2.2 yamt error = ENXIO; 281 1.10.2.2 yamt goto out; 282 1.10.2.2 yamt } 283 1.10.2.2 yamt if (TAILQ_EMPTY(&pmp->pmp_req_touser)) { 284 1.10.2.2 yamt if (nonblock || donesome) { 285 1.10.2.2 yamt if (nonblock) 286 1.10.2.2 yamt error = EWOULDBLOCK; 287 1.10.2.2 yamt goto out; 288 1.10.2.2 yamt } 289 1.10.2.2 yamt 290 1.10.2.2 yamt ltsleep(&pmp->pmp_req_touser, PUSER, "puffs2", 0, 291 1.10.2.2 yamt &pmp->pmp_lock); 292 1.10.2.2 yamt goto again; 293 1.10.2.2 yamt } 294 1.10.2.2 yamt 295 1.10.2.2 yamt park = TAILQ_FIRST(&pmp->pmp_req_touser); 296 1.10.2.2 yamt preq = park->park_preq; 297 1.10.2.2 yamt 298 1.10.2.2 yamt if (phg->phg_buflen < preq->preq_buflen) { 299 1.10.2.2 yamt if (!donesome) 300 1.10.2.2 yamt error = E2BIG; 301 1.10.2.2 yamt goto out; 302 1.10.2.2 yamt } 303 1.10.2.2 yamt TAILQ_REMOVE(&pmp->pmp_req_touser, park, park_entries); 304 1.10.2.2 yamt 305 1.10.2.2 yamt simple_unlock(&pmp->pmp_lock); 306 1.10.2.2 yamt DPRINTF(("puffsgetop: get op %" PRIu64 " (%d.), from %p " 307 1.10.2.2 yamt "len %zu (buflen %zu), target %p\n", preq->preq_id, 308 1.10.2.2 yamt donesome, preq, park->park_copylen, preq->preq_buflen, 309 1.10.2.2 yamt bufpos)); 310 1.10.2.2 yamt 311 1.10.2.2 yamt if ((error = copyout(preq, bufpos, park->park_copylen)) != 0) { 312 1.10.2.2 yamt DPRINTF((" FAILED %d\n", error)); 313 1.10.2.2 yamt /* 314 1.10.2.2 yamt * ok, user server is probably trying to cheat. 315 1.10.2.2 yamt * stuff op back & return error to user 316 1.10.2.2 yamt */ 317 1.10.2.2 yamt simple_lock(&pmp->pmp_lock); 318 1.10.2.2 yamt TAILQ_INSERT_HEAD(&pmp->pmp_req_touser, park, 319 1.10.2.2 yamt park_entries); 320 1.10.2.2 yamt 321 1.10.2.2 yamt if (donesome) 322 1.10.2.2 yamt error = 0; 323 1.10.2.2 yamt goto out; 324 1.10.2.2 yamt } 325 1.10.2.2 yamt bufpos += preq->preq_buflen; 326 1.10.2.2 yamt phg->phg_buflen -= preq->preq_buflen; 327 1.10.2.2 yamt donesome++; 328 1.10.2.2 yamt 329 1.10.2.2 yamt simple_lock(&pmp->pmp_lock); 330 1.10.2.2 yamt pmp->pmp_req_touser_waiters--; 331 1.10.2.2 yamt 332 1.10.2.2 yamt if (PUFFSOP_WANTREPLY(preq->preq_opclass)) { 333 1.10.2.2 yamt TAILQ_INSERT_TAIL(&pmp->pmp_req_replywait, park, 334 1.10.2.2 yamt park_entries); 335 1.10.2.2 yamt } else { 336 1.10.2.2 yamt simple_unlock(&pmp->pmp_lock); 337 1.10.2.2 yamt free(preq, M_PUFFS); 338 1.10.2.2 yamt free(park, M_PUFFS); 339 1.10.2.2 yamt simple_lock(&pmp->pmp_lock); 340 1.10.2.2 yamt } 341 1.10.2.2 yamt } 342 1.10.2.2 yamt 343 1.10.2.2 yamt out: 344 1.10.2.2 yamt phg->phg_more = pmp->pmp_req_touser_waiters; 345 1.10.2.2 yamt simple_unlock(&pmp->pmp_lock); 346 1.10.2.2 yamt 347 1.10.2.2 yamt phg->phg_nops = donesome; 348 1.10.2.2 yamt 349 1.10.2.2 yamt return error; 350 1.10.2.2 yamt } 351 1.10.2.2 yamt 352 1.10.2.2 yamt int 353 1.10.2.2 yamt puffs_putop(struct puffs_mount *pmp, struct puffs_reqh_put *php) 354 1.10.2.2 yamt { 355 1.10.2.2 yamt struct puffs_park *park; 356 1.10.2.2 yamt void *userbuf; 357 1.10.2.2 yamt uint64_t id; 358 1.10.2.2 yamt size_t reqlen; 359 1.10.2.2 yamt int error; 360 1.10.2.2 yamt int donesome; 361 1.10.2.2 yamt 362 1.10.2.2 yamt donesome = error = 0; 363 1.10.2.2 yamt 364 1.10.2.2 yamt id = php->php_id; 365 1.10.2.2 yamt userbuf = php->php_buf; 366 1.10.2.2 yamt reqlen = php->php_buflen; 367 1.10.2.2 yamt 368 1.10.2.2 yamt simple_lock(&pmp->pmp_lock); 369 1.10.2.2 yamt while (donesome != php->php_nops) { 370 1.10.2.2 yamt #ifdef DEBUG 371 1.10.2.2 yamt simple_unlock(&pmp->pmp_lock); 372 1.10.2.2 yamt DPRINTF(("puffsputop: searching for %" PRIu64 ", ubuf: %p, " 373 1.10.2.2 yamt "len %zu\n", id, userbuf, reqlen)); 374 1.10.2.2 yamt simple_lock(&pmp->pmp_lock); 375 1.10.2.2 yamt #endif 376 1.10.2.2 yamt TAILQ_FOREACH(park, &pmp->pmp_req_replywait, park_entries) { 377 1.10.2.2 yamt if (park->park_preq->preq_id == id) 378 1.10.2.2 yamt break; 379 1.10.2.2 yamt } 380 1.10.2.2 yamt 381 1.10.2.2 yamt if (park == NULL) { 382 1.10.2.2 yamt error = EINVAL; 383 1.10.2.2 yamt break; 384 1.10.2.2 yamt } 385 1.10.2.2 yamt TAILQ_REMOVE(&pmp->pmp_req_replywait, park, park_entries); 386 1.10.2.2 yamt simple_unlock(&pmp->pmp_lock); 387 1.10.2.2 yamt 388 1.10.2.2 yamt if (park->park_maxlen != park->park_copylen) { 389 1.10.2.2 yamt /* sanitycheck size of incoming transmission. */ 390 1.10.2.2 yamt if (reqlen > pmp->pmp_req_maxsize) { 391 1.10.2.2 yamt DPRINTF(("puffsputop: outrageous user buf " 392 1.10.2.2 yamt "size: %zu\n", reqlen)); 393 1.10.2.2 yamt error = EINVAL; 394 1.10.2.2 yamt goto loopout; 395 1.10.2.2 yamt } 396 1.10.2.2 yamt 397 1.10.2.2 yamt if (reqlen > park->park_copylen) { 398 1.10.2.2 yamt if (reqlen > park->park_maxlen) { 399 1.10.2.2 yamt DPRINTF(("puffsputop: adj copysize " 400 1.10.2.2 yamt "> max size, %zu vs %zu\n", 401 1.10.2.2 yamt reqlen, park->park_maxlen)); 402 1.10.2.2 yamt error = EINVAL; 403 1.10.2.2 yamt goto loopout; 404 1.10.2.2 yamt } 405 1.10.2.2 yamt free(park->park_preq, M_PUFFS); 406 1.10.2.2 yamt park->park_preq = malloc(reqlen, 407 1.10.2.2 yamt M_PUFFS, M_WAITOK); 408 1.10.2.2 yamt 409 1.10.2.2 yamt park->park_copylen = reqlen; 410 1.10.2.2 yamt DPRINTF(("puffsputop: adjbuf, new addr %p, " 411 1.10.2.2 yamt "len %zu\n", park->park_preq, reqlen)); 412 1.10.2.2 yamt } 413 1.10.2.2 yamt } else { 414 1.10.2.2 yamt if (reqlen == 0 || reqlen > park->park_copylen) { 415 1.10.2.2 yamt reqlen = park->park_copylen; 416 1.10.2.2 yamt DPRINTF(("puffsputop: kernel bufsize override: " 417 1.10.2.2 yamt "%zu\n", reqlen)); 418 1.10.2.2 yamt } 419 1.10.2.2 yamt } 420 1.10.2.2 yamt 421 1.10.2.2 yamt DPRINTF(("puffsputpop: copyin from %p to %p, len %zu\n", 422 1.10.2.2 yamt userbuf, park->park_preq, reqlen)); 423 1.10.2.2 yamt error = copyin(userbuf, park->park_preq, reqlen); 424 1.10.2.2 yamt if (error) 425 1.10.2.2 yamt goto loopout; 426 1.10.2.2 yamt 427 1.10.2.2 yamt /* all's well, prepare for next op */ 428 1.10.2.2 yamt id = park->park_preq->preq_id; 429 1.10.2.2 yamt reqlen = park->park_preq->preq_buflen; 430 1.10.2.2 yamt userbuf = park->park_preq->preq_nextbuf; 431 1.10.2.2 yamt donesome++; 432 1.10.2.2 yamt 433 1.10.2.2 yamt loopout: 434 1.10.2.2 yamt if (error) 435 1.10.2.2 yamt park->park_preq->preq_rv = error; 436 1.10.2.2 yamt wakeup(park); 437 1.10.2.2 yamt 438 1.10.2.2 yamt simple_lock(&pmp->pmp_lock); 439 1.10.2.2 yamt if (error) 440 1.10.2.2 yamt break; 441 1.10.2.2 yamt } 442 1.10.2.2 yamt 443 1.10.2.2 yamt simple_unlock(&pmp->pmp_lock); 444 1.10.2.2 yamt php->php_nops -= donesome; 445 1.10.2.2 yamt 446 1.10.2.2 yamt return error; 447 1.10.2.2 yamt } 448 1.10.2.2 yamt 449 1.10.2.2 yamt /* this is probably going to die away at some point? */ 450 1.10.2.2 yamt /* 451 1.10.2.2 yamt * XXX: currently bitrotted 452 1.10.2.2 yamt */ 453 1.10.2.2 yamt #if 0 454 1.10.2.2 yamt static int 455 1.10.2.2 yamt puffssizeop(struct puffs_mount *pmp, struct puffs_sizeop *psop_user) 456 1.10.2.2 yamt { 457 1.10.2.2 yamt struct puffs_sizepark *pspark; 458 1.10.2.2 yamt void *kernbuf; 459 1.10.2.2 yamt size_t copylen; 460 1.10.2.2 yamt int error; 461 1.10.2.2 yamt 462 1.10.2.2 yamt /* locate correct op */ 463 1.10.2.2 yamt simple_lock(&pmp->pmp_lock); 464 1.10.2.2 yamt TAILQ_FOREACH(pspark, &pmp->pmp_req_sizepark, pkso_entries) { 465 1.10.2.2 yamt if (pspark->pkso_reqid == psop_user->pso_reqid) { 466 1.10.2.2 yamt TAILQ_REMOVE(&pmp->pmp_req_sizepark, pspark, 467 1.10.2.2 yamt pkso_entries); 468 1.10.2.2 yamt break; 469 1.10.2.2 yamt } 470 1.10.2.2 yamt } 471 1.10.2.2 yamt simple_unlock(&pmp->pmp_lock); 472 1.10.2.2 yamt 473 1.10.2.2 yamt if (pspark == NULL) 474 1.10.2.2 yamt return EINVAL; 475 1.10.2.2 yamt 476 1.10.2.2 yamt error = 0; 477 1.10.2.2 yamt copylen = MIN(pspark->pkso_bufsize, psop_user->pso_bufsize); 478 1.10.2.2 yamt 479 1.10.2.2 yamt /* 480 1.10.2.2 yamt * XXX: uvm stuff to avoid bouncy-bouncy copying? 481 1.10.2.2 yamt */ 482 1.10.2.2 yamt if (PUFFS_SIZEOP_UIO(pspark->pkso_reqtype)) { 483 1.10.2.2 yamt kernbuf = malloc(copylen, M_PUFFS, M_WAITOK | M_ZERO); 484 1.10.2.2 yamt if (pspark->pkso_reqtype == PUFFS_SIZEOPREQ_UIO_IN) { 485 1.10.2.2 yamt error = copyin(psop_user->pso_userbuf, 486 1.10.2.2 yamt kernbuf, copylen); 487 1.10.2.2 yamt if (error) { 488 1.10.2.2 yamt printf("psop ERROR1 %d\n", error); 489 1.10.2.2 yamt goto escape; 490 1.10.2.2 yamt } 491 1.10.2.2 yamt } 492 1.10.2.2 yamt error = uiomove(kernbuf, copylen, pspark->pkso_uio); 493 1.10.2.2 yamt if (error) { 494 1.10.2.2 yamt printf("uiomove from kernel %p, len %d failed: %d\n", 495 1.10.2.2 yamt kernbuf, (int)copylen, error); 496 1.10.2.2 yamt goto escape; 497 1.10.2.2 yamt } 498 1.10.2.2 yamt 499 1.10.2.2 yamt if (pspark->pkso_reqtype == PUFFS_SIZEOPREQ_UIO_OUT) { 500 1.10.2.2 yamt error = copyout(kernbuf, 501 1.10.2.2 yamt psop_user->pso_userbuf, copylen); 502 1.10.2.2 yamt if (error) { 503 1.10.2.2 yamt printf("psop ERROR2 %d\n", error); 504 1.10.2.2 yamt goto escape; 505 1.10.2.2 yamt } 506 1.10.2.2 yamt } 507 1.10.2.2 yamt escape: 508 1.10.2.2 yamt free(kernbuf, M_PUFFS); 509 1.10.2.2 yamt } else if (PUFFS_SIZEOP_BUF(pspark->pkso_reqtype)) { 510 1.10.2.2 yamt copylen = MAX(pspark->pkso_bufsize, psop_user->pso_bufsize); 511 1.10.2.2 yamt if (pspark->pkso_reqtype == PUFFS_SIZEOPREQ_BUF_IN) { 512 1.10.2.2 yamt error = copyin(psop_user->pso_userbuf, 513 1.10.2.2 yamt pspark->pkso_copybuf, copylen); 514 1.10.2.2 yamt } else { 515 1.10.2.2 yamt error = copyout(pspark->pkso_copybuf, 516 1.10.2.2 yamt psop_user->pso_userbuf, copylen); 517 1.10.2.2 yamt } 518 1.10.2.2 yamt } 519 1.10.2.2 yamt #ifdef DIAGNOSTIC 520 1.10.2.2 yamt else 521 1.10.2.2 yamt panic("puffssizeop: invalid reqtype %d\n", 522 1.10.2.2 yamt pspark->pkso_reqtype); 523 1.10.2.2 yamt #endif /* DIAGNOSTIC */ 524 1.10.2.2 yamt 525 1.10.2.2 yamt return error; 526 1.10.2.2 yamt } 527 1.10.2.2 yamt #endif 528
Indexes created Tue Oct 28 02:10:10 GMT 2025