src/sys/kern/lwkt_msgport.c - diff

Return to lwkt_msgport.c CVS log

Up to [DragonFly] / src / sys / kern

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);
}	}