source: rtems/cpukit/rtems/src/msgqbroadcast.c @ 7f04cb18

4.11
Last change on this file since 7f04cb18 was 7f04cb18, checked in by Sebastian Huber <sebastian.huber@…>, on Jul 25, 2013 at 7:10:38 AM

score: Create mpci implementation header

Move implementation specific parts of mpci.h into new header file
mpciimpl.h. The mpci.h contains now only the application visible API.

  • Property mode set to 100644
File size: 2.3 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/object.h>
26#include <rtems/score/thread.h>
27#include <rtems/score/wkspace.h>
28#include <rtems/rtems/status.h>
29#include <rtems/rtems/attrimpl.h>
30#include <rtems/rtems/messageimpl.h>
31#include <rtems/rtems/options.h>
32#include <rtems/rtems/support.h>
33
34rtems_status_code rtems_message_queue_broadcast(
35  rtems_id    id,
36  const void *buffer,
37  size_t      size,
38  uint32_t   *count
39)
40{
41  register Message_queue_Control *the_message_queue;
42  Objects_Locations               location;
43  CORE_message_queue_Status       core_status;
44
45  if ( !buffer )
46    return RTEMS_INVALID_ADDRESS;
47
48  if ( !count )
49    return RTEMS_INVALID_ADDRESS;
50
51  the_message_queue = _Message_queue_Get( id, &location );
52  switch ( location ) {
53
54    case OBJECTS_LOCAL:
55      core_status = _CORE_message_queue_Broadcast(
56                      &the_message_queue->message_queue,
57                      buffer,
58                      size,
59                      id,
60                      #if defined(RTEMS_MULTIPROCESSING)
61                        _Message_queue_Core_message_queue_mp_support,
62                      #else
63                        NULL,
64                      #endif
65                      count
66                    );
67
68      _Objects_Put( &the_message_queue->Object );
69      return
70        _Message_queue_Translate_core_message_queue_return_code( core_status );
71
72#if defined(RTEMS_MULTIPROCESSING)
73    case OBJECTS_REMOTE:
74      _Thread_Executing->Wait.return_argument = count;
75
76      return
77        _Message_queue_MP_Send_request_packet(
78          MESSAGE_QUEUE_MP_BROADCAST_REQUEST,
79          id,
80          buffer,
81          &size,
82          0,                               /* option_set not used */
83          MPCI_DEFAULT_TIMEOUT
84        );
85#endif
86
87    case OBJECTS_ERROR:
88      break;
89  }
90  return RTEMS_INVALID_ID;
91}
Note: See TracBrowser for help on using the repository browser.