Lines Matching defs:pu
92 getfiobyfd(struct puffs_usermount *pu, int fd)
96 LIST_FOREACH(fio, &pu->pu_ios, fio_entries)
326 errnotify(struct puffs_usermount *pu, struct puffs_framebuf *pufbuf, int error)
334 pufbuf->fcb(pu, pufbuf, pufbuf->fcb_arg, error);
343 fio = getfiobyfd(pu, fd); \
358 struct puffs_usermount *pu = pcc->pcc_pu;
393 puffs_framev_enqueue_cb(struct puffs_usermount *pu, int fd,
418 puffs_framev_enqueue_justsend(struct puffs_usermount *pu, int fd,
449 struct puffs_usermount *pu = pcc->pcc_pu;
454 fio = getfiobyfd(pu, fd);
485 struct puffs_usermount *pu = pcc->pcc_pu;
537 struct puffs_usermount *pu = pcc->pcc_pu;
550 fio = getfiobyfd(pu, fd);
563 if (kevent(pu->pu_kq, &kev, 1, NULL, 0, NULL) == -1)
580 rv = kevent(pu->pu_kq, &kev, 1, NULL, 0, NULL);
620 findbuf(struct puffs_usermount *pu, struct puffs_framectrl *fctrl,
627 if (fctrl->cmpfb(pu, findme, cand, ¬resp) == 0 || notresp)
658 puffs__framev_input(struct puffs_usermount *pu, struct puffs_framectrl *fctrl,
674 rv = fctrl->rfb(pu, pufbuf, fio->io_fd, &complete);
678 puffs__framev_readclose(pu, fio, rv);
690 appbuf = findbuf(pu, fctrl, fio, pufbuf);
699 fctrl->gotfb(pu, pufbuf);
716 appbuf->fcb(pu, appbuf, appbuf->fcb_arg, 0);
726 puffs__framev_output(struct puffs_usermount *pu, struct puffs_framectrl *fctrl,
739 rv = fctrl->wfb(pu, pufbuf, fio->io_fd, &complete);
742 puffs__framev_writeclose(pu, fio, rv);
756 errnotify(pu, pufbuf, ENXIO);
777 puffs__framev_addfd_ctrl(struct puffs_usermount *pu, int fd, int what,
785 nevs = pu->pu_nevs+2;
786 if (reallocarr(&pu->pu_evs, nevs, sizeof(struct kevent)) != 0) {
806 if (pu->pu_state & PU_INLOOP) {
819 rv = kevent(pu->pu_kq, kev, nf, NULL, 0, NULL);
828 LIST_INSERT_HEAD(&pu->pu_ios, fio, fio_entries);
829 pu->pu_nevs = nevs;
838 puffs_framev_addfd(struct puffs_usermount *pu, int fd, int what)
841 return puffs__framev_addfd_ctrl(pu, fd, what,
842 &pu->pu_framectrl[PU_FRAMECTRL_USER]);
852 puffs_framev_enablefd(struct puffs_usermount *pu, int fd, int what)
860 fio = getfiobyfd(pu, fd);
869 rv = kevent(pu->pu_kq, &kev, 1, NULL, 0, NULL);
883 puffs_framev_disablefd(struct puffs_usermount *pu, int fd, int what)
892 fio = getfiobyfd(pu, fd);
908 rv = kevent(pu->pu_kq, kev, i, NULL, 0, NULL);
923 puffs__framev_readclose(struct puffs_usermount *pu,
939 errnotify(pu, fio->cur_in, error);
945 errnotify(pu, pufbuf, error);
949 (void) kevent(pu->pu_kq, &kev, 1, NULL, 0, NULL);
956 fio->fctrl->fdnotfn(pu, fio->io_fd, notflag);
960 puffs__framev_writeclose(struct puffs_usermount *pu,
973 errnotify(pu, pufbuf, error);
977 (void) kevent(pu->pu_kq, &kev, 1, NULL, 0, NULL);
984 fio->fctrl->fdnotfn(pu, fio->io_fd, notflag);
988 removefio(struct puffs_usermount *pu, struct puffs_fctrl_io *fio, int error)
993 if (pu->pu_state & PU_INLOOP) {
994 puffs__framev_readclose(pu, fio, error);
995 puffs__framev_writeclose(pu, fio, error);
1005 pu->pu_nevs -= 2;
1009 LIST_INSERT_HEAD(&pu->pu_ios_rmlist, fio, fio_entries);
1016 puffs_framev_removefd(struct puffs_usermount *pu, int fd, int error)
1020 fio = getfiobyfd(pu, fd);
1026 return removefio(pu, fio, error ? error : ECONNRESET);
1030 puffs_framev_removeonclose(struct puffs_usermount *pu, int fd, int what)
1034 (void) puffs_framev_removefd(pu, fd, ECONNRESET);
1038 puffs_framev_unmountonclose(struct puffs_usermount *pu, int fd, int what)
1042 puffs_framev_removeonclose(pu, fd, what);
1044 PU_SETSTATE(pu, PUFFS_STATE_UNMOUNTED);
1048 puffs_framev_init(struct puffs_usermount *pu,
1055 pfctrl = &pu->pu_framectrl[PU_FRAMECTRL_USER];
1064 puffs__framev_exit(struct puffs_usermount *pu)
1068 while ((fio = LIST_FIRST(&pu->pu_ios)) != NULL)
1069 removefio(pu, fio, ENXIO);
1070 free(pu->pu_evs);
1072 /* closing pu->pu_kq takes care of puffsfd */