From 5e96e917578509149814e300d56d2a7d47b7f268 Mon Sep 17 00:00:00 2001 From: Joel Sherrill Date: Wed, 17 Nov 1999 15:24:11 +0000 Subject: Updated Mailbox Manager submitted and split into multiple files. --- c/src/exec/itron/src/trcv_mbx.c | 69 +++++++++++++++++++++++++++++++++++++++++ 1 file changed, 69 insertions(+) create mode 100644 c/src/exec/itron/src/trcv_mbx.c (limited to 'c/src/exec/itron/src/trcv_mbx.c') diff --git a/c/src/exec/itron/src/trcv_mbx.c b/c/src/exec/itron/src/trcv_mbx.c new file mode 100644 index 0000000000..39eecdf1de --- /dev/null +++ b/c/src/exec/itron/src/trcv_mbx.c @@ -0,0 +1,69 @@ +/* + * ITRON 3.0 Mailbox Manager + * + * The license and distribution terms for this file may be + * found in the file LICENSE in this distribution or at + * http://www.OARcorp.com/rtems/license.html. + * + * $Id$ + */ + +#include + +#include +#include + +/* + * trcv_msg - Receive Message from Mailbox with Timeout + */ + +ER trcv_msg( + T_MSG **ppk_msg, + ID mbxid, + TMO tmout +) +{ + register ITRON_Mailbox_Control *the_mailbox; + Watchdog_Interval interval; + boolean wait; + Objects_Locations location; + unsigned32 size; + + if (!ppk_msg) + return E_PAR; + + interval = 0; + if ( tmout == TMO_POL ) { + wait = FALSE; + } else { + wait = TRUE; + if ( tmout != TMO_FEVR ) + interval = TOD_MILLISECONDS_TO_TICKS(tmout); + } + + if ( wait && _ITRON_Is_in_non_task_state() ) + return E_CTX; + + the_mailbox = _ITRON_Mailbox_Get( mbxid, &location ); + switch ( location ) { + case OBJECTS_REMOTE: + case OBJECTS_ERROR: + return _ITRON_Mailbox_Clarify_get_id_error( mbxid ); + + case OBJECTS_LOCAL: + + _CORE_message_queue_Seize( + &the_mailbox->message_queue, + the_mailbox->Object.id, + ppk_msg, + &size, + wait, + interval + ); + break; + } + + _ITRON_return_errorno( + _ITRON_Mailbox_Translate_core_message_queue_return_code( + _Thread_Executing->Wait.return_code ) ); +} -- cgit v1.2.3