X-Git-Url: https://codewiz.org/gitweb?a=blobdiff_plain;f=bertos%2Fkern%2Fmsg.h;h=f00f6060294e224edd97c65c2abea38a23fc6ce6;hb=dcee6b7043c0b895dc3489dd379a5264b5af32c1;hp=25b7a4ef06b8079e494ac806c5834b31574bb445;hpb=0c055cc202274669194ab67c2efaa12294c86504;p=bertos.git

diff --git a/bertos/kern/msg.h b/bertos/kern/msg.h
index 25b7a4ef..f00f6060 100644
--- a/bertos/kern/msg.h
+++ b/bertos/kern/msg.h
@@ -27,7 +27,7 @@
  * the GNU General Public License.
  *
  * Copyright 2004 Develer S.r.l. (http://www.develer.com/)
- * Copyright 1999,2001 Bernardo Innocenti <bernie@develer.com>
+ * Copyright 1999,2001 Bernie Innocenti <bernie@codewiz.org>
  *
  * -->
  *
@@ -37,7 +37,7 @@
  *
  * \version $Id$
  *
- * \author Bernardo Innocenti <bernie@develer.com>
+ * \author Bernie Innocenti <bernie@codewiz.org>
  *
  * \brief Simple inter-process messaging system
  *
@@ -67,6 +67,11 @@
  * receiver wakes up, it usually invokes msg_get() to pick
  * the next message from the port.
  *
+ * \note
+ * When you put a message into a port, such message becomes
+ * unavailable until you retrieve it using msg_get(), eg.
+ * you must not delete it or put it into another port.
+ *
  * Message ports can hold any number of pending messages,
  * and receivers usually process them in FIFO order.
  * Other scheduling policies are possible, but not implemented
@@ -106,6 +111,8 @@
  *	} TestMsg;
  *
  *
+ *  PROC_DEFINE_STACK(sender_stack, KERN_MINSTACKSIZE);
+ *
  *	// A process that sends two messages and waits for replies.
  *	static void sender_proc(void)
  *	{
@@ -114,30 +121,30 @@
  *		TestMsg msg2;
  *		Msg *reply;
  *
- *		msg_initPort(&reply_port,
- *			event_createSignal(proc_current(), SIGF_SINGLE);
+ *		msg_initPort(&test_reply_port,
+ *			event_createSignal(proc_current(), SIG_SINGLE);
  *
  *		// Fill-in first message and send it out.
  *		msg1.x = 3;
  *		msg1.y = 2;
  *		msg1.msg.replyPort = &test_reply_port;
- *		msg_put(&test_port, &msg1);
+ *		msg_put(&test_port, &msg1.msg);
  *
  *		// Fill-in second message and send it out too.
  *		msg2.x = 5;
  *		msg2.y = 4;
  *		msg2.msg.replyPort = &test_reply_port;
- *		msg_put(&test_port, &msg1);
+ *		msg_put(&test_port, &msg2.msg);
  *
  *		// Wait for a reply...
  *		sig_wait(SIG_SINGLE);
  *
- *		reply = (TestMsg *)msg_get(&test_reply_port);
+        reply = containerof(msg_get(&test_reply_port), TestMsg, msg);
  *		ASSERT(reply != NULL);
  *		ASSERT(reply->result == 5);
  *
  *		// Get reply to second message.
- *		while (!(reply = (TestMsg *)msg_get(&test_reply_port))
+ *		while (!(reply = containerof(msg_get(&test_reply_port), TestMsg, msg)))
  *		{
  *			// Not yet, be patient and wait some more.
  *			sig_wait(SIG_SINGLE);
@@ -151,28 +158,30 @@
  *	static void receiver_proc(void)
  *	{
  *		msg_initPort(&test_port,
- *			event_createSignal(proc_current(), SIGF_EXAMPLE);
+ *			event_createSignal(proc_current(), SIG_EXAMPLE);
  *
- *		proc_new(sender_proc, (iptr_t)&test_port,
- *			sender_stack, sizeof(sender_stack);
+ *		proc_new(sender_proc, NULL,sizeof(sender_stack), sender_stack);
  *
  *		for (;;)
  *		{
- *			sigmask_t sigs = sig_wait(SIGF_EXAMPLE | more_signals);
+ *			sigmask_t sigs = sig_wait(SIG_EXAMPLE | more_signals);
  *
- *			if (sigs & SIGF_EXAMPLE)
+ *			if (sigs & SIG_EXAMPLE)
  *			{
  *				TestMsg *emsg;
- *				while (emsg = (TestMsg *)msg_get(&test_port)
+ *				while((emsg = containerof(msg_get(&test_port), TestMsg, msg)))
  *				{
  *					// Do something with the message
  *					emsg->result = emsg->x + emsg->y;
- *					msg_reply((Msg *)msg);
+ *					msg_reply(emsg->msg);
  *				}
  *			}
  *		}
  *	}
  * \endcode
+ *
+ * $WIZ$ module_name = "msg"
+ * $WIZ$ module_depends = "event", "signal", "kernel"
  */
 
 
@@ -180,8 +189,8 @@
 #define KERN_MSG_H
 
 #include <mware/event.h>
-#include <mware/list.h>
-
+#include <struct/list.h>
+#include <kern/proc.h>
 
 typedef struct MsgPort
 {
@@ -282,4 +291,8 @@ INLINE void msg_reply(Msg *msg)
 	msg_put(msg->replyPort, msg);
 }
 
+int msg_testRun(void);
+int msg_testSetup(void);
+int msg_testTearDown(void);
+
 #endif /* KERN_MSG_H */