summaryrefslogtreecommitdiff
path: root/src/ipc.c
diff options
context:
space:
mode:
author[email protected] <[email protected]>2011-07-13 12:02:01 +0000
committer[email protected] <[email protected]>2011-07-13 12:02:01 +0000
commit573b73465e9b8616ed111ede6c82b0be76d54602 (patch)
tree02d77b4a62546adfa019710477422a652f494efd /src/ipc.c
parent98d59d153e14d59af5fcb7db0afc66c885365525 (diff)
more updates on previous change
git-svn-id: https://rt-thread.googlecode.com/svn/trunk@1627 bbd45198-f89e-11dd-88c7-29a3b14d5316
Diffstat (limited to 'src/ipc.c')
-rw-r--r--src/ipc.c21
1 files changed, 15 insertions, 6 deletions
diff --git a/src/ipc.c b/src/ipc.c
index a9ba1f150c..b97ba3008e 100644
--- a/src/ipc.c
+++ b/src/ipc.c
@@ -1327,12 +1327,23 @@ rt_err_t rt_mb_send_wait (rt_mailbox_t mb, rt_uint32_t value, rt_int32_t timeout
/* disable interrupt */
temp = rt_hw_interrupt_disable();
+ /* for non-blocking call */
+ if (mb->entry == mb->size && timeout == 0)
+ {
+ rt_hw_interrupt_enable(temp);
+ return -RT_EFULL;
+ }
+
+ tick_delta = 0;
+
/* get current thread */
thread = rt_thread_self();
/* mailbox is full */
while (mb->entry == mb->size)
{
+ RT_DEBUG_NOT_IN_INTERRUPT;
+
/* reset error number in thread */
thread->error = RT_EOK;
@@ -1345,8 +1356,6 @@ rt_err_t rt_mb_send_wait (rt_mailbox_t mb, rt_uint32_t value, rt_int32_t timeout
thread->error = -RT_EFULL;
return -RT_EFULL;
}
-
- RT_DEBUG_NOT_IN_INTERRUPT;
/* suspend current thread */
rt_ipc_list_suspend(&(mb->suspend_sender_thread),
@@ -1464,8 +1473,6 @@ rt_err_t rt_mb_recv (rt_mailbox_t mb, rt_uint32_t* value, rt_int32_t timeout)
return -RT_ETIMEOUT;
}
- RT_DEBUG_NOT_IN_INTERRUPT;
-
tick_delta = 0;
/* get current thread */
@@ -1474,6 +1481,8 @@ rt_err_t rt_mb_recv (rt_mailbox_t mb, rt_uint32_t* value, rt_int32_t timeout)
/* mailbox is empty */
while (mb->entry == 0)
{
+ RT_DEBUG_NOT_IN_INTERRUPT;
+
/* reset error number in thread */
thread->error = RT_EOK;
@@ -1969,8 +1978,6 @@ rt_err_t rt_mq_recv (rt_mq_t mq, void* buffer, rt_size_t size, rt_int32_t timeou
return -RT_ETIMEOUT;
}
- RT_DEBUG_NOT_IN_INTERRUPT;
-
tick_delta = 0;
/* get current thread */
@@ -1979,6 +1986,8 @@ rt_err_t rt_mq_recv (rt_mq_t mq, void* buffer, rt_size_t size, rt_int32_t timeou
/* message queue is empty */
while (mq->entry == 0)
{
+ RT_DEBUG_NOT_IN_INTERRUPT;
+
/* reset error number in thread */
thread->error = RT_EOK;