d/freebsd-nq
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Replace selwakeuppri with selwakeup, let scheduler figure out

Browse Source 
appropriate thread priority.
This commit is contained in:
David Xu 2005-12-16 15:01:16 +00:00
parent 6e02dbdfa3
commit 03f70aec67
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
sys/kern/uipc_mqueue.c
View File

@ -1674,7 +1674,7 @@ _mqueue_send(struct mqueue *mq, struct mqueue_msg *msg, int timo)
mqueue_send_notification(mq);
if (mq->mq_flags & MQ_RSEL) {
mq->mq_flags &= ~MQ_RSEL;
selwakeuppri(&mq->mq_rsel, PSOCK);
selwakeup(&mq->mq_rsel);
}
KNOTE_LOCKED(&mq->mq_rsel.si_note, 0);
mtx_unlock(&mq->mq_mutex);
@ -1809,7 +1809,7 @@ _mqueue_recv(struct mqueue *mq, struct mqueue_msg **msg, int timo)
wakeup_one(&mq->mq_senders);
if (mq->mq_flags & MQ_WSEL) {
mq->mq_flags &= ~MQ_WSEL;
selwakeuppri(&mq->mq_wsel, PSOCK);
selwakeup(&mq->mq_wsel);
}
KNOTE_LOCKED(&mq->mq_wsel.si_note, 0);
}
@ -2260,11 +2260,11 @@ mqueue_fdclose(struct thread *td, int fd, struct file *fp)
/* have to wakeup thread in same process */
if (mq->mq_flags & MQ_RSEL) {
mq->mq_flags &= ~MQ_RSEL;
selwakeuppri(&mq->mq_rsel, PSOCK);
selwakeup(&mq->mq_rsel);
}
if (mq->mq_flags & MQ_WSEL) {
mq->mq_flags &= ~MQ_WSEL;
selwakeuppri(&mq->mq_wsel, PSOCK);
selwakeup(&mq->mq_wsel);
}
mtx_unlock(&mq->mq_mutex);
}