Diff for /src/sys/kern/lwkt_msgport.c between versions 1.15 and 1.16

version 1.15, 2004/03/06 01:58:54 version 1.16, 2004/03/06 19:40:28
Line 90  static void lwkt_default_abortport(lwkt_ Line 90  static void lwkt_default_abortport(lwkt_
 static void lwkt_replyport_remote(lwkt_msg_t msg);  static void lwkt_replyport_remote(lwkt_msg_t msg);
 static void lwkt_putport_remote(lwkt_msg_t msg);  static void lwkt_putport_remote(lwkt_msg_t msg);
   
 void  
 lwkt_initmsg_td(lwkt_msg_t msg, thread_t td)  
 {  
     lwkt_initmsg(msg, &td->td_msgport, 0);  
 }  
   
 /*  /*
  * lwkt_sendmsg()   * lwkt_sendmsg()
  *   *
Line 116  lwkt_sendmsg(lwkt_port_t port, lwkt_msg_ Line 110  lwkt_sendmsg(lwkt_port_t port, lwkt_msg_
   
     msg->ms_flags |= MSGF_ASYNC;      msg->ms_flags |= MSGF_ASYNC;
     msg->ms_flags &= ~(MSGF_REPLY | MSGF_QUEUED);      msg->ms_flags &= ~(MSGF_REPLY | MSGF_QUEUED);
    msg->ms_reply_port = &curthread->td_msgport;    KKASSERT(msg->ms_reply_port != NULL);
     if ((error = lwkt_beginmsg(port, msg)) != EASYNC) {      if ((error = lwkt_beginmsg(port, msg)) != EASYNC) {
         lwkt_replymsg(msg, error);          lwkt_replymsg(msg, error);
     }      }
Line 144  lwkt_domsg(lwkt_port_t port, lwkt_msg_t Line 138  lwkt_domsg(lwkt_port_t port, lwkt_msg_t
     int error;      int error;
   
     msg->ms_flags &= ~(MSGF_ASYNC | MSGF_REPLY | MSGF_QUEUED);      msg->ms_flags &= ~(MSGF_ASYNC | MSGF_REPLY | MSGF_QUEUED);
    msg->ms_reply_port = &curthread->td_msgport;    KKASSERT(msg->ms_reply_port != NULL);
     if ((error = lwkt_beginmsg(port, msg)) == EASYNC) {      if ((error = lwkt_beginmsg(port, msg)) == EASYNC) {
         error = lwkt_waitmsg(msg);          error = lwkt_waitmsg(msg);
     }      }

Removed from v.1.15  
changed lines
  Added in v.1.16