forked from Imagelibrary/rtems
a2e3f33f39
Move implementation specific parts of object.h and object.inl into new header file objectimpl.h. The object.h contains now only the application visible API.
87 lines
2.2 KiB
C
87 lines
2.2 KiB
C
/**
|
|
* @file
|
|
*
|
|
* @brief RTEMS Message Queue Get Number Pending
|
|
* @ingroup ClassicMessageQueue Message Queues
|
|
*/
|
|
|
|
/*
|
|
* COPYRIGHT (c) 1989-2007.
|
|
* On-Line Applications Research Corporation (OAR).
|
|
*
|
|
* The license and distribution terms for this file may be
|
|
* found in the file LICENSE in this distribution or at
|
|
* http://www.rtems.com/license/LICENSE.
|
|
*/
|
|
|
|
#if HAVE_CONFIG_H
|
|
#include "config.h"
|
|
#endif
|
|
|
|
#include <rtems/system.h>
|
|
#include <rtems/score/chain.h>
|
|
#include <rtems/score/isr.h>
|
|
#include <rtems/score/coremsgimpl.h>
|
|
#include <rtems/score/thread.h>
|
|
#include <rtems/score/wkspace.h>
|
|
#include <rtems/rtems/status.h>
|
|
#include <rtems/rtems/attrimpl.h>
|
|
#include <rtems/rtems/messageimpl.h>
|
|
#include <rtems/rtems/options.h>
|
|
#include <rtems/rtems/support.h>
|
|
|
|
/*
|
|
* rtems_message_queue_get_number_pending
|
|
*
|
|
* This directive returns the number of messages pending.
|
|
*
|
|
* Input parameters:
|
|
* id - queue id
|
|
* count - return area for count
|
|
*
|
|
* Output parameters:
|
|
* count - number of messages removed ( 0 = empty queue )
|
|
* RTEMS_SUCCESSFUL - if successful
|
|
* error code - if unsuccessful
|
|
*/
|
|
|
|
rtems_status_code rtems_message_queue_get_number_pending(
|
|
rtems_id id,
|
|
uint32_t *count
|
|
)
|
|
{
|
|
register Message_queue_Control *the_message_queue;
|
|
Objects_Locations location;
|
|
|
|
if ( !count )
|
|
return RTEMS_INVALID_ADDRESS;
|
|
|
|
the_message_queue = _Message_queue_Get( id, &location );
|
|
switch ( location ) {
|
|
|
|
case OBJECTS_LOCAL:
|
|
*count = the_message_queue->message_queue.number_of_pending_messages;
|
|
_Objects_Put( &the_message_queue->Object );
|
|
return RTEMS_SUCCESSFUL;
|
|
|
|
#if defined(RTEMS_MULTIPROCESSING)
|
|
case OBJECTS_REMOTE:
|
|
_Thread_Executing->Wait.return_argument = count;
|
|
|
|
return _Message_queue_MP_Send_request_packet(
|
|
MESSAGE_QUEUE_MP_GET_NUMBER_PENDING_REQUEST,
|
|
id,
|
|
0, /* buffer not used */
|
|
0, /* size */
|
|
0, /* option_set not used */
|
|
MPCI_DEFAULT_TIMEOUT
|
|
);
|
|
#endif
|
|
|
|
case OBJECTS_ERROR:
|
|
break;
|
|
}
|
|
|
|
return RTEMS_INVALID_ID;
|
|
}
|