Lines Matching refs:fdip

98 static void fdisp_make_pid(struct fuse_dispatcher *fdip, enum fuse_opcode op,
904 fdisp_refresh_pid(struct fuse_dispatcher *fdip, enum fuse_opcode op, in fdisp_refresh_pid() argument
907 MPASS(fdip->tick); in fdisp_refresh_pid()
908 MPASS2(sizeof(fdip->finh) + fdip->iosize <= fdip->tick->tk_ms_fiov.len, in fdisp_refresh_pid()
910 fticket_reset(fdip->tick); in fdisp_refresh_pid()
912 FUSE_DIMALLOC(&fdip->tick->tk_ms_fiov, fdip->finh, in fdisp_refresh_pid()
913 fdip->indata, fdip->iosize); in fdisp_refresh_pid()
915 fuse_setup_ihead(fdip->finh, fdip->tick, nid, op, fdip->iosize, pid, in fdisp_refresh_pid()
921 fdisp_make_pid(struct fuse_dispatcher *fdip, enum fuse_opcode op, in fdisp_make_pid() argument
924 if (fdip->tick) { in fdisp_make_pid()
925 fticket_refresh(fdip->tick); in fdisp_make_pid()
927 fdip->tick = fuse_ticket_fetch(data); in fdisp_make_pid()
931 FUSE_DIMALLOC(&fdip->tick->tk_ms_fiov, fdip->finh, in fdisp_make_pid()
932 fdip->indata, fdip->iosize); in fdisp_make_pid()
934 fuse_setup_ihead(fdip->finh, fdip->tick, nid, op, fdip->iosize, pid, cred); in fdisp_make_pid()
938 fdisp_make(struct fuse_dispatcher *fdip, enum fuse_opcode op, struct mount *mp, in fdisp_make() argument
944 return fdisp_make_pid(fdip, op, data, nid, td->td_proc->p_pid, cred); in fdisp_make()
948 fdisp_make_vp(struct fuse_dispatcher *fdip, enum fuse_opcode op, in fdisp_make_vp() argument
955 return fdisp_make_pid(fdip, op, data, VTOI(vp), in fdisp_make_vp()
961 fdisp_refresh_vp(struct fuse_dispatcher *fdip, enum fuse_opcode op, in fdisp_refresh_vp() argument
965 return fdisp_refresh_pid(fdip, op, vnode_mount(vp), VTOI(vp), in fdisp_refresh_vp()
972 fdisp_wait_answ(struct fuse_dispatcher *fdip) in fdisp_wait_answ() argument
976 fdip->answ_stat = 0; in fdisp_wait_answ()
977 fuse_insert_callback(fdip->tick, fuse_standard_handler); in fdisp_wait_answ()
978 fuse_insert_message(fdip->tick, false); in fdisp_wait_answ()
980 if ((err = fticket_wait_answer(fdip->tick))) { in fdisp_wait_answ()
981 fuse_lck_mtx_lock(fdip->tick->tk_aw_mtx); in fdisp_wait_answ()
983 if (fticket_answered(fdip->tick)) { in fdisp_wait_answ()
991 fuse_lck_mtx_unlock(fdip->tick->tk_aw_mtx); in fdisp_wait_answ()
1001 fticket_set_answered(fdip->tick); in fdisp_wait_answ()
1002 fuse_lck_mtx_unlock(fdip->tick->tk_aw_mtx); in fdisp_wait_answ()
1007 if (fdip->tick->tk_aw_errno == ENOTCONN) { in fdisp_wait_answ()
1011 } else if (fdip->tick->tk_aw_errno) { in fdisp_wait_answ()
1017 "IPC: explicit EIO-ing", fdip->tick->tk_aw_errno); in fdisp_wait_answ()
1021 if ((err = fdip->tick->tk_aw_ohead.error)) { in fdisp_wait_answ()
1023 "IPC: setting status", fdip->tick->tk_aw_ohead.error); in fdisp_wait_answ()
1033 fdip->answ_stat = err; in fdisp_wait_answ()
1036 fdip->answ = fticket_resp(fdip->tick)->base; in fdisp_wait_answ()
1037 fdip->iosize = fticket_resp(fdip->tick)->len; in fdisp_wait_answ()