source: rtems/c/src/librtems++/src/rtemsMessageQueue.cc @ 2936b425

4.104.114.84.9
Last change on this file since 2936b425 was 2936b425, checked in by Joel Sherrill <joel.sherrill@…>, on Jan 23, 1998 at 5:45:05 PM

Solaris port updates from Chris Johns

  • Property mode set to 100644
File size: 4.1 KB
Line 
1/*
2  ------------------------------------------------------------------------
3  $Id$
4  ------------------------------------------------------------------------
5
6  COPYRIGHT (c) 1997
7  Objective Design Systems Ltd Pty (ODS)
8  All rights reserved (R) Objective Design Systems Ltd Pty
9 
10  The license and distribution terms for this file may be found in the
11  file LICENSE in this distribution or at
12  http://www.OARcorp.com/rtems/license.html.
13
14  ------------------------------------------------------------------------
15
16  See header file.
17
18  ------------------------------------------------------------------------
19*/
20
21#include <string.h>
22#include <rtems++/rtemsMessageQueue.h>
23
24/* ----
25   rtemsMessageQueue
26*/
27
28rtemsMessageQueue::rtemsMessageQueue(const char* mqname,
29                                     const rtems_unsigned32 count,
30                                     const rtems_unsigned32 max_message_size,
31                                     const WaitMode wait_mode,
32                                     const Scope scope)
33  : name(0),
34    owner(true),
35    id(0)
36{
37  strcpy(name_str, "NOID");
38  create(mqname, count, max_message_size, wait_mode, scope);
39}
40
41rtemsMessageQueue::rtemsMessageQueue(const char *mqname,
42                                     const rtems_unsigned32 node)
43  : name(0),
44    owner(false),
45    id(0)
46{
47  strcpy(name_str, "NOID");
48  connect(mqname, node);
49}
50
51rtemsMessageQueue::rtemsMessageQueue(const rtemsMessageQueue& message_queue)
52  : name(0),
53    owner(false),
54    id(0)
55{
56  name = message_queue.name;
57  strcpy(name_str, message_queue.name_str);
58  id = message_queue.id;
59}
60
61rtemsMessageQueue::rtemsMessageQueue()
62  : name(0),
63    owner(false),
64    id(0)
65{
66  strcpy(name_str, "NOID");
67}
68
69rtemsMessageQueue::~rtemsMessageQueue()
70{
71  destroy();
72}
73
74void rtemsMessageQueue::make_invalid()
75{
76  strcpy(name_str, "NOID");
77  name = 0;
78  id = 0;
79  owner = false;
80}
81
82const rtems_status_code rtemsMessageQueue::create(const char* mqname,
83                                                  const rtems_unsigned32 count,
84                                                  const rtems_unsigned32 max_message_size,
85                                                  const WaitMode wait_mode,
86                                                  const Scope scope)
87{
88  if (id)
89    return set_status_code(RTEMS_ILLEGAL_ON_SELF);
90
91  owner = true;
92 
93  strcpy(name_str, "    ");
94  for (int c = 0; (c < 4) && (mqname[c] != '\0'); c++)
95    name_str[c] = mqname[c];
96  name = rtems_build_name(name_str[0],
97                          name_str[1],
98                          name_str[2],
99                          name_str[3]);
100 
101  set_status_code(rtems_message_queue_create(name,
102                                             count,
103                                             max_message_size,
104                                             scope | wait_mode,
105                                             &id));
106
107  if (unsuccessful())
108  {
109    make_invalid();
110  }
111 
112  return last_status_code();
113}
114
115const rtems_status_code rtemsMessageQueue::destroy()
116{
117  if (id && owner)
118  {
119    set_status_code(rtems_message_queue_delete(id));
120    make_invalid();
121  }
122  else
123    set_status_code(RTEMS_NOT_OWNER_OF_RESOURCE);
124 
125  return last_status_code();
126}
127
128const rtemsMessageQueue& rtemsMessageQueue::operator=(const rtemsMessageQueue& message_queue)
129{
130  if (!owner)
131  {
132    name = message_queue.name;
133    strcpy(name_str, message_queue.name_str);
134    id = message_queue.id;
135  }
136
137  return *this;
138}
139 
140const rtems_status_code rtemsMessageQueue::connect(const char *mqname,
141                                                   const rtems_unsigned32 node)
142{
143  if (id && owner)
144    return set_status_code(RTEMS_UNSATISFIED);
145
146  // change state to not owner
147  owner = false;
148 
149  strcpy(name_str, "    ");
150  for (int c = 0; (c < 4) && (mqname[c] != '\0'); c++)
151    name_str[c] = mqname[c];
152  name = rtems_build_name(name_str[0],
153                          name_str[1],
154                          name_str[2],
155                          name_str[3]);
156 
157  set_status_code(rtems_message_queue_ident(name, node, &id));
158
159  if (unsuccessful())
160  {
161    make_invalid();
162  }
163 
164  return last_status_code();
165}
Note: See TracBrowser for help on using the repository browser.