diff --git a/cpukit/ChangeLog b/cpukit/ChangeLog index ca5527a0b1..721106dbb2 100644 --- a/cpukit/ChangeLog +++ b/cpukit/ChangeLog @@ -1,3 +1,10 @@ +2009-07-02 Joel Sherrill + + * score/include/rtems/score/coremsg.h, score/src/coremsgflushwait.c: + Mark _CORE_message_queue_Flush_waiting_threads with + FUNCTIONALITY_NOT_CURRENTLY_USED_BY_ANY_API since there is no way to + reach it via an API. + 2009-07-01 Joel Sherrill * score/include/rtems/score/tod.h: Correct name of parameter. diff --git a/cpukit/score/include/rtems/score/coremsg.h b/cpukit/score/include/rtems/score/coremsg.h index 4ccbf06987..c1e6fe97e2 100644 --- a/cpukit/score/include/rtems/score/coremsg.h +++ b/cpukit/score/include/rtems/score/coremsg.h @@ -293,18 +293,20 @@ uint32_t _CORE_message_queue_Flush_support( CORE_message_queue_Control *the_message_queue ); -/** - * @brief Flush Waiting Threads. - * - * This function flushes the threads which are blocked on - * @a the_message_queue's pending message queue. They are - * unblocked whether blocked sending or receiving. - * - * @param[in] the_message_queue points to the message queue to flush - */ -void _CORE_message_queue_Flush_waiting_threads( - CORE_message_queue_Control *the_message_queue -); +#if defined(FUNCTIONALITY_NOT_CURRENTLY_USED_BY_ANY_API) + /** + * @brief Flush Waiting Threads. + * + * This function flushes the threads which are blocked on + * @a the_message_queue's pending message queue. They are + * unblocked whether blocked sending or receiving. + * + * @param[in] the_message_queue points to the message queue to flush + */ + void _CORE_message_queue_Flush_waiting_threads( + CORE_message_queue_Control *the_message_queue + ); +#endif /** * @brief Broadcast a Message to the Message Queue diff --git a/cpukit/score/src/coremsgflushwait.c b/cpukit/score/src/coremsgflushwait.c index f624e7f252..d7b3c00f5f 100644 --- a/cpukit/score/src/coremsgflushwait.c +++ b/cpukit/score/src/coremsgflushwait.c @@ -30,41 +30,43 @@ #include #include -/*PAGE - * - * _CORE_message_queue_Flush_waiting_threads - * - * This function flushes the message_queue's task wait queue. The number - * of messages flushed from the queue is returned. - * - * Input parameters: - * the_message_queue - the message_queue to be flushed - * - * Output parameters: - * returns - the number of messages flushed from the queue - */ - -void _CORE_message_queue_Flush_waiting_threads( - CORE_message_queue_Control *the_message_queue -) -{ - /* XXX this is not supported for global message queues */ - - /* - * IF there are no pending messages, - * THEN threads may be blocked waiting to RECEIVE a message, +#if defined(FUNCTIONALITY_NOT_CURRENTLY_USED_BY_ANY_API) + /*PAGE * - * IF the pending message queue is full - * THEN threads may be blocked waiting to SEND a message + * _CORE_message_queue_Flush_waiting_threads * - * But in either case, we will return "unsatisfied nowait" - * to indicate that the blocking condition was not satisfied - * and that the blocking state was canceled. + * This function flushes the message_queue's task wait queue. The number + * of messages flushed from the queue is returned. + * + * Input parameters: + * the_message_queue - the message_queue to be flushed + * + * Output parameters: + * returns - the number of messages flushed from the queue */ - _Thread_queue_Flush( - &the_message_queue->Wait_queue, - NULL, - CORE_MESSAGE_QUEUE_STATUS_UNSATISFIED_NOWAIT - ); -} + void _CORE_message_queue_Flush_waiting_threads( + CORE_message_queue_Control *the_message_queue + ) + { + /* XXX this is not supported for global message queues */ + + /* + * IF there are no pending messages, + * THEN threads may be blocked waiting to RECEIVE a message, + * + * IF the pending message queue is full + * THEN threads may be blocked waiting to SEND a message + * + * But in either case, we will return "unsatisfied nowait" + * to indicate that the blocking condition was not satisfied + * and that the blocking state was canceled. + */ + + _Thread_queue_Flush( + &the_message_queue->Wait_queue, + NULL, + CORE_MESSAGE_QUEUE_STATUS_UNSATISFIED_NOWAIT + ); + } +#endif