URL https://opencores.org/ocsvn/openrisc/openrisc/trunk

Subversion Repositories openrisc

[/] [openrisc/] [trunk/] [rtos/] [rtems/] [c/] [src/] [exec/] [rtems/] [src/] [msgqsubmit.c] - Blame information for rev 593

Go to most recent revision | Details | Compare with Previous | View Log


/*
 *  Message Queue Manager
 *
 *
 *  COPYRIGHT (c) 1989-1999.
 *  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.OARcorp.com/rtems/license.html.
 *
 *  $Id: msgqsubmit.c,v 1.2 2001-09-27 11:59:19 chris Exp $
 */
 
#include <rtems/system.h>
#include <rtems/score/sysstate.h>
#include <rtems/score/chain.h>
#include <rtems/score/isr.h>
#include <rtems/score/coremsg.h>
#include <rtems/score/object.h>
#include <rtems/score/states.h>
#include <rtems/score/thread.h>
#include <rtems/score/wkspace.h>
#if defined(RTEMS_MULTIPROCESSING)
#include <rtems/score/mpci.h>
#endif
#include <rtems/rtems/status.h>
#include <rtems/rtems/attr.h>
#include <rtems/rtems/message.h>
#include <rtems/rtems/options.h>
#include <rtems/rtems/support.h>
 
/*PAGE
 *
 *  _Message_queue_Submit
 *
 *  This routine implements the directives rtems_message_queue_send
 *  and rtems_message_queue_urgent.  It processes a message that is
 *  to be submitted to the designated message queue.  The message will
 *  either be processed as a send send message which it will be inserted
 *  at the rear of the queue or it will be processed as an urgent message
 *  which will be inserted at the front of the queue.
 *
 *  Input parameters:
 *    id          - pointer to message queue
 *    buffer      - pointer to message buffer
 *    size        - size in bytes of message to send
 *    submit_type - send or urgent message
 *
 *  Output parameters:
 *    RTEMS_SUCCESSFUL - if successful
 *    error code       - if unsuccessful
 */
 
rtems_status_code _Message_queue_Submit(
  Objects_Id                  id,
  void                       *buffer,
  unsigned32                  size,
  Message_queue_Submit_types  submit_type
)
{
  register Message_queue_Control  *the_message_queue;
  Objects_Locations                location;
 
  the_message_queue = _Message_queue_Get( id, &location );
  switch ( location )
  {
    case OBJECTS_REMOTE:
#if defined(RTEMS_MULTIPROCESSING)
      switch ( submit_type ) {
        case MESSAGE_QUEUE_SEND_REQUEST:
          return _Message_queue_MP_Send_request_packet(
              MESSAGE_QUEUE_MP_SEND_REQUEST,
              id,
              buffer,
              &size,
              0,                               /* option_set */
              MPCI_DEFAULT_TIMEOUT
            );
 
        case MESSAGE_QUEUE_URGENT_REQUEST:
          return _Message_queue_MP_Send_request_packet(
              MESSAGE_QUEUE_MP_URGENT_REQUEST,
              id,
              buffer,
              &size,
              0,                               /* option_set */
              MPCI_DEFAULT_TIMEOUT
            );
      }
      break;
#endif
 
    case OBJECTS_ERROR:
      return RTEMS_INVALID_ID;
 
    case OBJECTS_LOCAL:
      switch ( submit_type ) {
        case MESSAGE_QUEUE_SEND_REQUEST:
          _CORE_message_queue_Send(
            &the_message_queue->message_queue,
            buffer,
            size,
            id,
#if defined(RTEMS_MULTIPROCESSING)
            _Message_queue_Core_message_queue_mp_support,
#else
            NULL,
#endif
            FALSE,   /* sender does not block */
 
          );
          break;
        case MESSAGE_QUEUE_URGENT_REQUEST:
          _CORE_message_queue_Urgent(
            &the_message_queue->message_queue,
            buffer,
            size,
            id,
#if defined(RTEMS_MULTIPROCESSING)
            _Message_queue_Core_message_queue_mp_support,
#else
            NULL,
#endif
            FALSE,   /* sender does not block */
 
          );
          break;
        default:
          return RTEMS_INTERNAL_ERROR;   /* should never get here */
      }
 
      _Thread_Enable_dispatch();
      return _Message_queue_Translate_core_message_queue_return_code(
        _Thread_Executing->Wait.return_code
      );
 
  }
  return RTEMS_INTERNAL_ERROR;   /* unreached - only to remove warnings */
}

Line No.	Rev	Author	Line
1	30	unneback	`/*`
2			`* Message Queue Manager`
3			`*`
4			`*`
5			`* COPYRIGHT (c) 1989-1999.`
6			`* On-Line Applications Research Corporation (OAR).`
7			`*`
8			`* The license and distribution terms for this file may be`
9			`* found in the file LICENSE in this distribution or at`
10			`* http://www.OARcorp.com/rtems/license.html.`
11			`*`
12			`* $Id: msgqsubmit.c,v 1.2 2001-09-27 11:59:19 chris Exp $`
13			`*/`
14
15			`#include <rtems/system.h>`
16			`#include <rtems/score/sysstate.h>`
17			`#include <rtems/score/chain.h>`
18			`#include <rtems/score/isr.h>`
19			`#include <rtems/score/coremsg.h>`
20			`#include <rtems/score/object.h>`
21			`#include <rtems/score/states.h>`
22			`#include <rtems/score/thread.h>`
23			`#include <rtems/score/wkspace.h>`
24			`#if defined(RTEMS_MULTIPROCESSING)`
25			`#include <rtems/score/mpci.h>`
26			`#endif`
27			`#include <rtems/rtems/status.h>`
28			`#include <rtems/rtems/attr.h>`
29			`#include <rtems/rtems/message.h>`
30			`#include <rtems/rtems/options.h>`
31			`#include <rtems/rtems/support.h>`
32
33			`/*PAGE`
34			`*`
35			`* _Message_queue_Submit`
36			`*`
37			`* This routine implements the directives rtems_message_queue_send`
38			`* and rtems_message_queue_urgent. It processes a message that is`
39			`* to be submitted to the designated message queue. The message will`
40			`* either be processed as a send send message which it will be inserted`
41			`* at the rear of the queue or it will be processed as an urgent message`
42			`* which will be inserted at the front of the queue.`
43			`*`
44			`* Input parameters:`
45			`* id - pointer to message queue`
46			`* buffer - pointer to message buffer`
47			`* size - size in bytes of message to send`
48			`* submit_type - send or urgent message`
49			`*`
50			`* Output parameters:`
51			`* RTEMS_SUCCESSFUL - if successful`
52			`* error code - if unsuccessful`
53			`*/`
54
55			`rtems_status_code _Message_queue_Submit(`
56			`Objects_Id id,`
57			`void *buffer,`
58			`unsigned32 size,`
59			`Message_queue_Submit_types submit_type`
60			`)`
61			`{`
62			`register Message_queue_Control *the_message_queue;`
63			`Objects_Locations location;`
64
65			`the_message_queue = _Message_queue_Get( id, &location );`
66			`switch ( location )`
67			`{`
68			`case OBJECTS_REMOTE:`
69			`#if defined(RTEMS_MULTIPROCESSING)`
70			`switch ( submit_type ) {`
71			`case MESSAGE_QUEUE_SEND_REQUEST:`
72			`return _Message_queue_MP_Send_request_packet(`
73			`MESSAGE_QUEUE_MP_SEND_REQUEST,`
74			`id,`
75			`buffer,`
76			`&size,`
77			`0, /* option_set */`
78			`MPCI_DEFAULT_TIMEOUT`
79			`);`
80
81			`case MESSAGE_QUEUE_URGENT_REQUEST:`
82			`return _Message_queue_MP_Send_request_packet(`
83			`MESSAGE_QUEUE_MP_URGENT_REQUEST,`
84			`id,`
85			`buffer,`
86			`&size,`
87			`0, /* option_set */`
88			`MPCI_DEFAULT_TIMEOUT`
89			`);`
90			`}`
91			`break;`
92			`#endif`
93
94			`case OBJECTS_ERROR:`
95			`return RTEMS_INVALID_ID;`
96
97			`case OBJECTS_LOCAL:`
98			`switch ( submit_type ) {`
99			`case MESSAGE_QUEUE_SEND_REQUEST:`
100			`_CORE_message_queue_Send(`
101			`&the_message_queue->message_queue,`
102			`buffer,`
103			`size,`
104			`id,`
105			`#if defined(RTEMS_MULTIPROCESSING)`
106			`_Message_queue_Core_message_queue_mp_support,`
107			`#else`
108			`NULL,`
109			`#endif`
110			`FALSE, /* sender does not block */`
111
112			`);`
113			`break;`
114			`case MESSAGE_QUEUE_URGENT_REQUEST:`
115			`_CORE_message_queue_Urgent(`
116			`&the_message_queue->message_queue,`
117			`buffer,`
118			`size,`
119			`id,`
120			`#if defined(RTEMS_MULTIPROCESSING)`
121			`_Message_queue_Core_message_queue_mp_support,`
122			`#else`
123			`NULL,`
124			`#endif`
125			`FALSE, /* sender does not block */`
126
127			`);`
128			`break;`
129			`default:`
130			`return RTEMS_INTERNAL_ERROR; /* should never get here */`
131			`}`
132
133			`_Thread_Enable_dispatch();`
134			`return _Message_queue_Translate_core_message_queue_return_code(`
135			`_Thread_Executing->Wait.return_code`
136			`);`
137
138			`}`
139			`return RTEMS_INTERNAL_ERROR; /* unreached - only to remove warnings */`
140			`}`

Browse

Tools

Subversion Repositories openrisc

[/] [openrisc/] [trunk/] [rtos/] [rtems/] [c/] [src/] [exec/] [rtems/] [src/] [msgqsubmit.c] - Blame information for rev 593