Lines Matching defs:msgreq
199 nfs_lockdmsg_enqueue(LOCKD_MSG_REQUEST *msgreq)
204 if (!mr || (msgreq->lmr_msg.lm_xid > mr->lmr_msg.lm_xid)) {
206 TAILQ_INSERT_TAIL(&nfs_pendlockq, msgreq, lmr_next);
210 while (mr && (msgreq->lmr_msg.lm_xid > mr->lmr_msg.lm_xid)) {
214 TAILQ_INSERT_AFTER(&nfs_pendlockq, mr, msgreq, lmr_next);
216 TAILQ_INSERT_HEAD(&nfs_pendlockq, msgreq, lmr_next);
225 nfs_lockdmsg_dequeue(LOCKD_MSG_REQUEST *msgreq)
227 TAILQ_REMOVE(&nfs_pendlockq, msgreq, lmr_next);
269 nfs_lockdmsg_compare_to_answer(LOCKD_MSG_REQUEST *msgreq, struct lockd_ans *ansp)
273 if (msgreq->lmr_msg.lm_fl.l_pid != ansp->la_pid)
275 if (msgreq->lmr_msg.lm_fl.l_start != ansp->la_start)
277 if (msgreq->lmr_msg.lm_fl.l_len != ansp->la_len)
279 if (msgreq->lmr_msg.lm_fh_len != ansp->la_fh_len)
281 if (bcmp(msgreq->lmr_msg.lm_fh, ansp->la_fh, ansp->la_fh_len))
558 LOCKD_MSG_REQUEST msgreq;
691 * and nfs_filehandle contained in msgreq so that
696 bzero(&msgreq, sizeof(msgreq));
697 msg = &msgreq.lmr_msg;
734 nfs_lockdmsg_enqueue(&msgreq);
771 if (!msgreq.lmr_answered)
772 error = msleep(&msgreq, nfs_lock_mutex, PCATCH | PUSER, "lockd", &ts);
773 if (msgreq.lmr_answered) {
782 if ((msgreq.lmr_errno == ENOTSUP) && nmp &&
845 if ((msgreq.lmr_errno == EINPROGRESS) &&
849 nfs_lockdmsg_dequeue(&msgreq);
851 nfs_lockdmsg_enqueue(&msgreq);
852 msgreq.lmr_saved_errno = error;
853 msgreq.lmr_errno = 0;
854 msgreq.lmr_answered = 0;
865 if ((msgreq.lmr_errno != EINPROGRESS) &&
875 if (msgreq.lmr_errno == EINPROGRESS) {
888 nfs_lockdmsg_dequeue(&msgreq);
890 nfs_lockdmsg_enqueue(&msgreq);
891 msgreq.lmr_saved_errno = msgreq.lmr_errno;
892 msgreq.lmr_errno = 0;
893 msgreq.lmr_answered = 0;
913 if (msgreq.lmr_errno == EINPROGRESS) {
917 msgreq.lmr_answered = 0;
922 (msgreq.lmr_saved_errno == EINPROGRESS)) {
929 nfs_lockdmsg_dequeue(&msgreq);
931 nfs_lockdmsg_enqueue(&msgreq);
932 msgreq.lmr_saved_errno = 0;
933 msgreq.lmr_errno = 0;
934 msgreq.lmr_answered = 0;
940 if ((msg->lm_flags & LOCKD_MSG_TEST) && msgreq.lmr_errno == 0) {
958 error = msgreq.lmr_saved_errno;
960 error = msgreq.lmr_errno;
1007 nfs_lockdmsg_dequeue(&msgreq);
1021 LOCKD_MSG_REQUEST *msgreq;
1036 msgreq = nfs_lockdmsg_find_by_xid(ansp->la_xid);
1044 if (!msgreq || nfs_lockdmsg_compare_to_answer(msgreq, ansp))
1045 msgreq = nfs_lockdmsg_find_by_answer(ansp);
1050 if (msgreq && (msgreq->lmr_msg.lm_flags & LOCKD_MSG_CANCEL))
1051 msgreq = NULL;
1053 if (!msgreq) {
1058 msgreq->lmr_errno = ansp->la_errno;
1059 if ((msgreq->lmr_msg.lm_flags & LOCKD_MSG_TEST) && msgreq->lmr_errno == 0) {
1062 msgreq->lmr_msg.lm_fl.l_type = F_WRLCK;
1064 msgreq->lmr_msg.lm_fl.l_type = F_RDLCK;
1065 msgreq->lmr_msg.lm_fl.l_pid = ansp->la_pid;
1066 msgreq->lmr_msg.lm_fl.l_start = ansp->la_start;
1067 msgreq->lmr_msg.lm_fl.l_len = ansp->la_len;
1069 msgreq->lmr_msg.lm_fl.l_type = F_UNLCK;
1073 msgreq->lmr_answered = 1;
1075 wakeup(msgreq);