--- src/sys/kern/lwkt_msgport.c 2008/09/09 07:21:54 1.47 +++ src/sys/kern/lwkt_msgport.c 2008/11/01 10:38:21 1.48 @@ -241,10 +241,10 @@ static __inline void _lwkt_schedule_msg(thread_t td, int flags) { - if (flags & MSGF_NORESCHED) - lwkt_schedule_noresched(td); - else - lwkt_schedule(td); + if (flags & MSGF_NORESCHED) + lwkt_schedule_noresched(td); + else + lwkt_schedule(td); } /* @@ -646,7 +646,7 @@ lwkt_thread_waitport(lwkt_port_t port, i error = lwkt_sleep("waitport", flags); port->mp_flags &= ~MSGPORTF_WAITING; if (error) - goto done; + goto done; } _lwkt_pullmsg(port, msg); done: @@ -757,7 +757,7 @@ lwkt_spin_waitmsg(lwkt_msg_t msg, int fl if (sentabort && msg->ms_error == EINTR) msg->ms_error = sentabort; if (msg->ms_flags & MSGF_QUEUED) - _lwkt_pullmsg(port, msg); + _lwkt_pullmsg(port, msg); spin_unlock_wr(&port->mpu_spin); } else { if (msg->ms_flags & MSGF_QUEUED) { @@ -922,7 +922,7 @@ lwkt_serialize_waitmsg(lwkt_msg_t msg, i if (sentabort && msg->ms_error == EINTR) msg->ms_error = sentabort; if (msg->ms_flags & MSGF_QUEUED) - _lwkt_pullmsg(port, msg); + _lwkt_pullmsg(port, msg); } else { if (msg->ms_flags & MSGF_QUEUED) { port = msg->ms_reply_port;