diff options
Diffstat (limited to 'cpukit/score/src/coremsgbroadcast.c')
| -rw-r--r-- | cpukit/score/src/coremsgbroadcast.c | 26 |
1 files changed, 13 insertions, 13 deletions
diff --git a/cpukit/score/src/coremsgbroadcast.c b/cpukit/score/src/coremsgbroadcast.c index 12cb0dd4f1..fc89a8ad5f 100644 --- a/cpukit/score/src/coremsgbroadcast.c +++ b/cpukit/score/src/coremsgbroadcast.c @@ -55,13 +55,13 @@ CORE_message_queue_Status _CORE_message_queue_Broadcast( CORE_message_queue_Control *the_message_queue, const void *buffer, size_t size, -#if defined(RTEMS_MULTIPROCESSING) - Objects_Id id, - CORE_message_queue_API_mp_support_callout api_message_queue_mp_support, -#else - Objects_Id id __attribute__((unused)), - CORE_message_queue_API_mp_support_callout api_message_queue_mp_support __attribute__((unused)), -#endif + #if defined(RTEMS_MULTIPROCESSING) + Objects_Id id, + CORE_message_queue_API_mp_support_callout api_message_queue_mp_support, + #else + Objects_Id id __attribute__((unused)), + CORE_message_queue_API_mp_support_callout api_message_queue_mp_support __attribute__((unused)), + #endif uint32_t *count ) { @@ -91,9 +91,9 @@ CORE_message_queue_Status _CORE_message_queue_Broadcast( * There must be no pending messages if there is a thread waiting to * receive a message. */ - number_broadcasted = 0; - while ((the_thread = _Thread_queue_Dequeue(&the_message_queue->Wait_queue))) { + while ((the_thread = + _Thread_queue_Dequeue(&the_message_queue->Wait_queue) != NULL)) { waitp = &the_thread->Wait; number_broadcasted += 1; @@ -105,10 +105,10 @@ CORE_message_queue_Status _CORE_message_queue_Broadcast( *(size_t *) the_thread->Wait.return_argument = size; -#if defined(RTEMS_MULTIPROCESSING) - if ( !_Objects_Is_local_id( the_thread->Object.id ) ) - (*api_message_queue_mp_support) ( the_thread, id ); -#endif + #if defined(RTEMS_MULTIPROCESSING) + if ( !_Objects_Is_local_id( the_thread->Object.id ) ) + (*api_message_queue_mp_support) ( the_thread, id ); + #endif } *count = number_broadcasted; |