Lines Matching refs:pu
131 perfuse_node_close_common(struct puffs_usermount *pu, puffs_cookie_t opc, in perfuse_node_close_common() argument
143 ps = puffs_getspecific(pu); in perfuse_node_close_common()
173 pm = ps->ps_new_msg(pu, opc, op, sizeof(*fri), NULL); in perfuse_node_close_common()
187 if ((error = xchg_msg(pu, opc, pm, in perfuse_node_close_common()
198 xchg_msg(struct puffs_usermount *pu, puffs_cookie_t opc, perfuse_msg_t *pm, in xchg_msg() argument
206 ps = puffs_getspecific(pu); in xchg_msg()
231 if ((error = ps->ps_xchg_msg(pu, pm, len, wait)) != 0) in xchg_msg()
388 node_lookup_common(struct puffs_usermount *pu, puffs_cookie_t opc, in node_lookup_common() argument
409 ps = puffs_getspecific(pu); in node_lookup_common()
432 pm = ps->ps_new_msg(pu, opc, FUSE_LOOKUP, len, pcr); in node_lookup_common()
435 if ((error = xchg_msg(pu, opc, pm, sizeof(*feo), wait_reply)) != 0) in node_lookup_common()
465 pn = perfuse_new_pn(pu, path, opc); in node_lookup_common()
520 node_mk_common(struct puffs_usermount *pu, puffs_cookie_t opc, in node_mk_common() argument
529 ps = puffs_getspecific(pu); in node_mk_common()
531 if ((error = xchg_msg(pu, opc, pm, sizeof(*feo), wait_reply)) != 0) in node_mk_common()
538 pn = perfuse_new_pn(pu, pcn->pcn_name, opc); in node_mk_common()
591 fuse_to_dirent(struct puffs_usermount *pu, puffs_cookie_t opc, in fuse_to_dirent() argument
668 error = node_lookup_common(pu, opc, NULL, in fuse_to_dirent()
675 (void)perfuse_node_reclaim2(pu, pn, 1); in fuse_to_dirent()
815 requeue_request(struct puffs_usermount *pu, puffs_cookie_t opc, in requeue_request() argument
823 pcq.pcq_cc = puffs_cc_getcc(pu); in requeue_request()
880 perfuse_fs_init(struct puffs_usermount *pu) in perfuse_fs_init() argument
888 ps = puffs_getspecific(pu); in perfuse_fs_init()
890 if (puffs_mount(pu, ps->ps_target, ps->ps_mountflags, ps->ps_root) != 0) in perfuse_fs_init()
903 pm = ps->ps_new_msg(pu, 0, FUSE_INIT, sizeof(*fii), NULL); in perfuse_fs_init()
910 if ((error = xchg_msg(pu, 0, pm, sizeof(*fio), wait_reply)) != 0) in perfuse_fs_init()
923 perfuse_fs_unmount(struct puffs_usermount *pu, int flags) in perfuse_fs_unmount() argument
930 ps = puffs_getspecific(pu); in perfuse_fs_unmount()
931 opc = (puffs_cookie_t)puffs_getroot(pu); in perfuse_fs_unmount()
937 pm = ps->ps_new_msg(pu, opc, FUSE_DESTROY, 0, NULL); in perfuse_fs_unmount()
939 if ((error = xchg_msg(pu, opc, pm, UNSPEC_REPLY_LEN, wait_reply)) != 0){ in perfuse_fs_unmount()
949 ps->ps_umount(pu); in perfuse_fs_unmount()
958 perfuse_fs_statvfs(struct puffs_usermount *pu, struct puffs_statvfs *svfsb) in perfuse_fs_statvfs() argument
966 ps = puffs_getspecific(pu); in perfuse_fs_statvfs()
967 opc = (puffs_cookie_t)puffs_getroot(pu); in perfuse_fs_statvfs()
973 pm = ps->ps_new_msg(pu, opc, FUSE_STATFS, 0, NULL); in perfuse_fs_statvfs()
975 if ((error = xchg_msg(pu, opc, pm, sizeof(*fso), wait_reply)) != 0) in perfuse_fs_statvfs()
1022 perfuse_fs_sync(struct puffs_usermount *pu, int waitfor, in perfuse_fs_sync() argument
1029 return puffs_fsnop_sync(pu, waitfor, pcr); in perfuse_fs_sync()
1034 perfuse_fs_fhtonode(struct puffs_usermount *pu, void *fid, size_t fidsize, in perfuse_fs_fhtonode() argument
1043 perfuse_fs_nodetofh(struct puffs_usermount *pu, puffs_cookie_t cookie, in perfuse_fs_nodetofh() argument
1053 perfuse_fs_extattrctl(struct puffs_usermount *pu, int cmd,
1063 perfuse_fs_suspend(struct puffs_usermount *pu, int status) in perfuse_fs_suspend() argument
1070 perfuse_node_lookup(struct puffs_usermount *pu, puffs_cookie_t opc, in perfuse_node_lookup() argument
1078 ps = puffs_getspecific(pu); in perfuse_node_lookup()
1102 error = node_lookup_common(pu, (puffs_cookie_t)opc, pni, in perfuse_node_lookup()
1138 (void)perfuse_node_reclaim2(pu, pn, 1); in perfuse_node_lookup()
1157 perfuse_node_create(struct puffs_usermount *pu, puffs_cookie_t opc, in perfuse_node_create() argument
1181 ps = puffs_getspecific(pu); in perfuse_node_create()
1183 error = node_lookup_common(pu, opc, NULL, pcn->pcn_name, in perfuse_node_create()
1186 (void)perfuse_node_reclaim2(pu, pn, 1); in perfuse_node_create()
1191 error = perfuse_node_mknod(pu, opc, pni, pcn, vap); in perfuse_node_create()
1195 error = node_lookup_common(pu, opc, NULL, pcn->pcn_name, in perfuse_node_create()
1208 error = perfuse_node_open(pu, (puffs_cookie_t)pn, in perfuse_node_create()
1223 pm = ps->ps_new_msg(pu, opc, FUSE_CREATE, len, pcn->pcn_cred); in perfuse_node_create()
1231 if ((error = xchg_msg(pu, opc, pm, len, wait_reply)) != 0) { in perfuse_node_create()
1238 error = perfuse_node_create(pu, opc, pni, pcn, vap); in perfuse_node_create()
1253 pn = perfuse_new_pn(pu, name, opc); in perfuse_node_create()
1288 perfuse_node_mknod(struct puffs_usermount *pu, puffs_cookie_t opc, in perfuse_node_mknod() argument
1325 ps = puffs_getspecific(pu); in perfuse_node_mknod()
1332 pm = ps->ps_new_msg(pu, opc, FUSE_MKNOD, len, pcn->pcn_cred); in perfuse_node_mknod()
1339 error = node_mk_common(pu, opc, pni, pcn, pm); in perfuse_node_mknod()
1348 perfuse_node_open(struct puffs_usermount *pu, puffs_cookie_t opc, int mode, in perfuse_node_open() argument
1351 return perfuse_node_open2(pu, opc, mode, pcr, NULL); in perfuse_node_open()
1355 perfuse_node_open2(struct puffs_usermount *pu, puffs_cookie_t opc, int mode, in perfuse_node_open2() argument
1367 ps = puffs_getspecific(pu); in perfuse_node_open2()
1431 requeue_request(pu, opc, PCQ_OPEN); in perfuse_node_open2()
1441 pm = ps->ps_new_msg(pu, opc, op, sizeof(*foi), pcr); in perfuse_node_open2()
1446 if ((error = xchg_msg(pu, opc, pm, sizeof(*foo), wait_reply)) != 0) in perfuse_node_open2()
1484 perfuse_node_close(struct puffs_usermount *pu, puffs_cookie_t opc, int flags, in perfuse_node_close() argument
1501 perfuse_node_access(struct puffs_usermount *pu, puffs_cookie_t opc, int mode, in perfuse_node_access() argument
1519 ps = puffs_getspecific(pu); in perfuse_node_access()
1535 pm = ps->ps_new_msg(pu, opc, FUSE_ACCESS, sizeof(*fai), pcr); in perfuse_node_access()
1542 error = xchg_msg(pu, opc, pm, NO_PAYLOAD_REPLY_LEN, wait_reply); in perfuse_node_access()
1551 error = perfuse_node_access(pu, opc, mode, pcr); in perfuse_node_access()
1560 perfuse_node_getattr(struct puffs_usermount *pu, puffs_cookie_t opc, in perfuse_node_getattr() argument
1563 return perfuse_node_getattr_ttl(pu, opc, vap, pcr, NULL); in perfuse_node_getattr()
1567 perfuse_node_getattr_ttl(struct puffs_usermount *pu, puffs_cookie_t opc, in perfuse_node_getattr_ttl() argument
1587 requeue_request(pu, opc, PCQ_RESIZE); in perfuse_node_getattr_ttl()
1590 ps = puffs_getspecific(pu); in perfuse_node_getattr_ttl()
1596 pm = ps->ps_new_msg(pu, opc, FUSE_GETATTR, sizeof(*fgi), pcr); in perfuse_node_getattr_ttl()
1613 if ((error = xchg_msg(pu, opc, pm, sizeof(*fao), wait_reply)) != 0) in perfuse_node_getattr_ttl()
1648 perfuse_node_setattr(struct puffs_usermount *pu, puffs_cookie_t opc, in perfuse_node_setattr() argument
1651 return perfuse_node_setattr_ttl(pu, opc, in perfuse_node_setattr()
1656 perfuse_node_setattr_ttl(struct puffs_usermount *pu, puffs_cookie_t opc, in perfuse_node_setattr_ttl() argument
1673 ps = puffs_getspecific(pu); in perfuse_node_setattr_ttl()
1755 if ((error = perfuse_node_setattr_ttl(pu, opc, &resize_va, in perfuse_node_setattr_ttl()
1762 pm = ps->ps_new_msg(pu, opc, FUSE_SETATTR, sizeof(*fsi), pcr); in perfuse_node_setattr_ttl()
1787 requeue_request(pu, opc, PCQ_RESIZE); in perfuse_node_setattr_ttl()
1899 if ((error = xchg_msg(pu, opc, pm, sizeof(*fao), reply)) != 0) in perfuse_node_setattr_ttl()
1939 perfuse_node_poll(struct puffs_usermount *pu, puffs_cookie_t opc, int *events) in perfuse_node_poll() argument
1948 ps = puffs_getspecific(pu); in perfuse_node_poll()
1960 pm = ps->ps_new_msg(pu, opc, FUSE_POLL, sizeof(*fpi), NULL); in perfuse_node_poll()
1972 if ((error = xchg_msg(pu, opc, pm, sizeof(*fpo), wait_reply)) != 0) in perfuse_node_poll()
1988 perfuse_node_fsync(struct puffs_usermount *pu, puffs_cookie_t opc, in perfuse_node_fsync() argument
2000 ps = puffs_getspecific(pu); in perfuse_node_fsync()
2046 if ((error = perfuse_node_open(pu, opc, FREAD, pcr)) != 0) in perfuse_node_fsync()
2058 pm = ps->ps_new_msg(pu, opc, op, sizeof(*ffi), pcr); in perfuse_node_fsync()
2070 if ((error = xchg_msg(pu, opc, pm, in perfuse_node_fsync()
2101 perfuse_node_remove(struct puffs_usermount *pu, puffs_cookie_t opc, in perfuse_node_remove() argument
2135 requeue_request(pu, targ, PCQ_AFTERXCHG); in perfuse_node_remove()
2137 ps = puffs_getspecific(pu); in perfuse_node_remove()
2142 pm = ps->ps_new_msg(pu, opc, FUSE_UNLINK, len, pcn->pcn_cred); in perfuse_node_remove()
2146 if ((error = xchg_msg(pu, opc, pm, UNSPEC_REPLY_LEN, wait_reply)) != 0) in perfuse_node_remove()
2153 puffs_setback(puffs_cc_getcc(pu), PUFFS_SETBACK_NOREF_N2); in perfuse_node_remove()
2176 perfuse_node_link(struct puffs_usermount *pu, puffs_cookie_t opc, in perfuse_node_link() argument
2192 ps = puffs_getspecific(pu); in perfuse_node_link()
2197 pm = ps->ps_new_msg(pu, opc, FUSE_LINK, len, pcn->pcn_cred); in perfuse_node_link()
2202 if ((error = xchg_msg(pu, opc, pm, UNSPEC_REPLY_LEN, wait_reply)) != 0) in perfuse_node_link()
2215 perfuse_node_rename(struct puffs_usermount *pu, puffs_cookie_t opc, in perfuse_node_rename() argument
2248 requeue_request(pu, targ, PCQ_AFTERXCHG); in perfuse_node_rename()
2251 requeue_request(pu, src, PCQ_AFTERXCHG); in perfuse_node_rename()
2254 ps = puffs_getspecific(pu); in perfuse_node_rename()
2261 pm = ps->ps_new_msg(pu, opc, FUSE_RENAME, len, pcn_targ->pcn_cred); in perfuse_node_rename()
2269 if ((error = xchg_msg(pu, opc, pm, UNSPEC_REPLY_LEN, wait_reply)) != 0) in perfuse_node_rename()
2319 perfuse_node_mkdir(struct puffs_usermount *pu, puffs_cookie_t opc, in perfuse_node_mkdir() argument
2334 ps = puffs_getspecific(pu); in perfuse_node_mkdir()
2338 pm = ps->ps_new_msg(pu, opc, FUSE_MKDIR, len, pcn->pcn_cred); in perfuse_node_mkdir()
2344 error = node_mk_common(pu, opc, pni, pcn, pm); in perfuse_node_mkdir()
2352 perfuse_node_rmdir(struct puffs_usermount *pu, puffs_cookie_t opc, in perfuse_node_rmdir() argument
2384 requeue_request(pu, targ, PCQ_AFTERXCHG); in perfuse_node_rmdir()
2386 ps = puffs_getspecific(pu); in perfuse_node_rmdir()
2390 pm = ps->ps_new_msg(pu, opc, FUSE_RMDIR, len, pcn->pcn_cred); in perfuse_node_rmdir()
2394 if ((error = xchg_msg(pu, opc, pm, UNSPEC_REPLY_LEN, wait_reply)) != 0) in perfuse_node_rmdir()
2401 puffs_setback(puffs_cc_getcc(pu), PUFFS_SETBACK_NOREF_N2); in perfuse_node_rmdir()
2426 perfuse_node_symlink(struct puffs_usermount *pu, puffs_cookie_t opc, in perfuse_node_symlink() argument
2443 ps = puffs_getspecific(pu); in perfuse_node_symlink()
2449 pm = ps->ps_new_msg(pu, opc, FUSE_SYMLINK, len, pcn_src->pcn_cred); in perfuse_node_symlink()
2455 error = node_mk_common(pu, opc, pni, pcn_src, pm); in perfuse_node_symlink()
2463 perfuse_node_readdir(struct puffs_usermount *pu, puffs_cookie_t opc, in perfuse_node_readdir() argument
2481 ps = puffs_getspecific(pu); in perfuse_node_readdir()
2491 requeue_request(pu, opc, PCQ_READDIR); in perfuse_node_readdir()
2517 if ((error = perfuse_node_open(pu, opc, FREAD, pcr)) != 0) in perfuse_node_readdir()
2538 pm = ps->ps_new_msg(pu, opc, FUSE_READDIR, sizeof(*fri), pcr); in perfuse_node_readdir()
2551 if ((error = xchg_msg(pu, opc, pm, in perfuse_node_readdir()
2606 if (fuse_to_dirent(pu, opc, pnd->pnd_all_fd, in perfuse_node_readdir()
2638 perfuse_node_readlink(struct puffs_usermount *pu, puffs_cookie_t opc, in perfuse_node_readlink() argument
2651 ps = puffs_getspecific(pu); in perfuse_node_readlink()
2653 pm = ps->ps_new_msg(pu, opc, FUSE_READLINK, 0, pcr); in perfuse_node_readlink()
2655 if ((error = xchg_msg(pu, opc, pm, UNSPEC_REPLY_LEN, wait_reply)) != 0) in perfuse_node_readlink()
2685 perfuse_node_reclaim2(struct puffs_usermount *pu, in perfuse_node_reclaim2() argument
2702 ps = puffs_getspecific(pu); in perfuse_node_reclaim2()
2755 requeue_request(pu, opc, PCQ_REF); in perfuse_node_reclaim2()
2780 pm = ps->ps_new_msg(pu, opc, FUSE_FORGET, in perfuse_node_reclaim2()
2788 (void)xchg_msg(pu, opc, pm, UNSPEC_REPLY_LEN, no_reply); in perfuse_node_reclaim2()
2790 perfuse_destroy_pn(pu, opc); in perfuse_node_reclaim2()
2796 perfuse_node_reclaim(struct puffs_usermount *pu, puffs_cookie_t opc) in perfuse_node_reclaim() argument
2802 return perfuse_node_reclaim2(pu, opc, 1); in perfuse_node_reclaim()
2806 perfuse_node_inactive(struct puffs_usermount *pu, puffs_cookie_t opc) in perfuse_node_inactive() argument
2827 requeue_request(pu, opc, PCQ_AFTERWRITE); in perfuse_node_inactive()
2843 if ((error = perfuse_node_fsync(pu, opc, NULL, 0, 0, 0)) != 0) in perfuse_node_inactive()
2853 if ((error = perfuse_node_close_common(pu, opc, FWRITE)) != 0) in perfuse_node_inactive()
2859 if ((error = perfuse_node_close_common(pu, opc, FREAD)) != 0) in perfuse_node_inactive()
2868 puffs_setback(puffs_cc_getcc(pu), PUFFS_SETBACK_NOREF_N1); in perfuse_node_inactive()
2887 perfuse_node_print(struct puffs_usermount *pu, puffs_cookie_t opc) in perfuse_node_print() argument
2894 perfuse_node_pathconf(struct puffs_usermount *pu, puffs_cookie_t opc, in perfuse_node_pathconf() argument
2935 ps = puffs_getspecific(pu); in perfuse_node_pathconf()
2936 pm = ps->ps_new_msg(pu, opc, FUSE_STATFS, 0, NULL); in perfuse_node_pathconf()
2938 error = xchg_msg(pu, opc, pm, sizeof(*fso), wait_reply); in perfuse_node_pathconf()
2958 perfuse_node_advlock(struct puffs_usermount *pu, puffs_cookie_t opc, in perfuse_node_advlock() argument
2990 ps = puffs_getspecific(pu); in perfuse_node_advlock()
3004 pm = ps->ps_new_msg(pu, opc, fop, sizeof(*fli), NULL); in perfuse_node_advlock()
3023 if ((error = xchg_msg(pu, opc, pm, UNSPEC_REPLY_LEN, wait_reply)) != 0) in perfuse_node_advlock()
3077 perfuse_node_read(struct puffs_usermount *pu, puffs_cookie_t opc, uint8_t *buf, in perfuse_node_read() argument
3090 ps = puffs_getspecific(pu); in perfuse_node_read()
3111 pm = ps->ps_new_msg(pu, opc, FUSE_READ, sizeof(*fri), pcr); in perfuse_node_read()
3126 error = xchg_msg(pu, opc, pm, UNSPEC_REPLY_LEN, wait_reply); in perfuse_node_read()
3157 perfuse_node_write(struct puffs_usermount *pu, puffs_cookie_t opc, in perfuse_node_write() argument
3161 return perfuse_node_write2(pu, opc, buf, offset, resid, pcr, ioflag, 0); in perfuse_node_write()
3166 perfuse_node_write2(struct puffs_usermount *pu, puffs_cookie_t opc, in perfuse_node_write2() argument
3183 ps = puffs_getspecific(pu); in perfuse_node_write2()
3200 requeue_request(pu, opc, PCQ_WRITE); in perfuse_node_write2()
3208 if ((error = perfuse_node_getattr(pu, opc, vap, pcr)) != 0) in perfuse_node_write2()
3219 requeue_request(pu, opc, PCQ_RESIZE); in perfuse_node_write2()
3253 pm = ps->ps_new_msg(pu, opc, FUSE_WRITE, payload_len, pcr); in perfuse_node_write2()
3272 if ((error = xchg_msg(pu, opc, pm, in perfuse_node_write2()
3367 perfuse_cache_write(struct puffs_usermount *pu, puffs_cookie_t opc, size_t size, in perfuse_cache_write() argument
3375 perfuse_node_getextattr(struct puffs_usermount *pu, puffs_cookie_t opc, in perfuse_node_getextattr() argument
3395 ps = puffs_getspecific(pu); in perfuse_node_getextattr()
3400 pm = ps->ps_new_msg(pu, opc, FUSE_GETXATTR, len, pcr); in perfuse_node_getextattr()
3406 if ((error = xchg_msg(pu, opc, pm, UNSPEC_REPLY_LEN, wait_reply)) != 0) in perfuse_node_getextattr()
3455 perfuse_node_setextattr(struct puffs_usermount *pu, puffs_cookie_t opc, in perfuse_node_setextattr() argument
3474 ps = puffs_getspecific(pu); in perfuse_node_setextattr()
3481 pm = ps->ps_new_msg(pu, opc, FUSE_SETXATTR, len, pcr); in perfuse_node_setextattr()
3491 if ((error = xchg_msg(pu, opc, pm, in perfuse_node_setextattr()
3507 perfuse_node_listextattr(struct puffs_usermount *pu, puffs_cookie_t opc, in perfuse_node_listextattr() argument
3526 ps = puffs_getspecific(pu); in perfuse_node_listextattr()
3529 pm = ps->ps_new_msg(pu, opc, FUSE_LISTXATTR, len, pcr); in perfuse_node_listextattr()
3536 if ((error = xchg_msg(pu, opc, pm, UNSPEC_REPLY_LEN, wait_reply)) != 0) in perfuse_node_listextattr()
3611 perfuse_node_deleteextattr(struct puffs_usermount *pu, puffs_cookie_t opc, in perfuse_node_deleteextattr() argument
3627 ps = puffs_getspecific(pu); in perfuse_node_deleteextattr()
3631 pm = ps->ps_new_msg(pu, opc, FUSE_REMOVEXATTR, attrnamelen, pcr); in perfuse_node_deleteextattr()
3635 error = xchg_msg(pu, opc, pm, NO_PAYLOAD_REPLY_LEN, wait_reply); in perfuse_node_deleteextattr()
3647 perfuse_node_fallocate(struct puffs_usermount *pu, puffs_cookie_t opc, in perfuse_node_fallocate() argument
3655 ps = puffs_getspecific(pu); in perfuse_node_fallocate()
3661 pm = ps->ps_new_msg(pu, opc, FUSE_FALLOCATE, sizeof(*fai), NULL); in perfuse_node_fallocate()
3669 error = xchg_msg(pu, opc, pm, NO_PAYLOAD_REPLY_LEN, wait_reply); in perfuse_node_fallocate()