source: rtems/cpukit/rtems/src/msgqbroadcast.c @ a2e3f33

4.11
Last change on this file since a2e3f33 was a2e3f33, checked in by Sebastian Huber <sebastian.huber@…>, on Jul 24, 2013 at 11:50:54 AM

score: Create object implementation header

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.

  • Property mode set to 100644
File size: 2.2 KB
Line 
1/**
2 *  @file
3 *
4 *  @brief RTEMS Broadcast Message Queue
5 *  @ingroup ClassicMessageQueue
6 */
7
8/*
9 *  COPYRIGHT (c) 1989-2007.
10 *  On-Line Applications Research Corporation (OAR).
11 *
12 *  The license and distribution terms for this file may be
13 *  found in the file LICENSE in this distribution or at
14 *  http://www.rtems.com/license/LICENSE.
15 */
16
17#if HAVE_CONFIG_H
18#include "config.h"
19#endif
20
21#include <rtems/system.h>
22#include <rtems/score/chain.h>
23#include <rtems/score/isr.h>
24#include <rtems/score/coremsgimpl.h>
25#include <rtems/score/thread.h>
26#include <rtems/score/wkspace.h>
27#include <rtems/rtems/status.h>
28#include <rtems/rtems/attrimpl.h>
29#include <rtems/rtems/messageimpl.h>
30#include <rtems/rtems/options.h>
31#include <rtems/rtems/support.h>
32
33rtems_status_code rtems_message_queue_broadcast(
34  rtems_id    id,
35  const void *buffer,
36  size_t      size,
37  uint32_t   *count
38)
39{
40  register Message_queue_Control *the_message_queue;
41  Objects_Locations               location;
42  CORE_message_queue_Status       core_status;
43
44  if ( !buffer )
45    return RTEMS_INVALID_ADDRESS;
46
47  if ( !count )
48    return RTEMS_INVALID_ADDRESS;
49
50  the_message_queue = _Message_queue_Get( id, &location );
51  switch ( location ) {
52
53    case OBJECTS_LOCAL:
54      core_status = _CORE_message_queue_Broadcast(
55                      &the_message_queue->message_queue,
56                      buffer,
57                      size,
58                      id,
59                      #if defined(RTEMS_MULTIPROCESSING)
60                        _Message_queue_Core_message_queue_mp_support,
61                      #else
62                        NULL,
63                      #endif
64                      count
65                    );
66
67      _Objects_Put( &the_message_queue->Object );
68      return
69        _Message_queue_Translate_core_message_queue_return_code( core_status );
70
71#if defined(RTEMS_MULTIPROCESSING)
72    case OBJECTS_REMOTE:
73      _Thread_Executing->Wait.return_argument = count;
74
75      return
76        _Message_queue_MP_Send_request_packet(
77          MESSAGE_QUEUE_MP_BROADCAST_REQUEST,
78          id,
79          buffer,
80          &size,
81          0,                               /* option_set not used */
82          MPCI_DEFAULT_TIMEOUT
83        );
84#endif
85
86    case OBJECTS_ERROR:
87      break;
88  }
89  return RTEMS_INVALID_ID;
90}
Note: See TracBrowser for help on using the repository browser.