URL https://opencores.org/ocsvn/openrisc_2011-10-31/openrisc_2011-10-31/trunk

Subversion Repositories openrisc_2011-10-31

[/] [openrisc/] [trunk/] [rtos/] [rtems/] [c/] [src/] [librtems++/] [src/] [rtemsMessageQueue.cc] - Blame information for rev 173

Details | Compare with Previous | View Log


/*
  ------------------------------------------------------------------------
  $Id: rtemsMessageQueue.cc,v 1.2 2001-09-27 12:02:05 chris Exp $
  ------------------------------------------------------------------------
 
  COPYRIGHT (c) 1997
  Objective Design Systems Ltd Pty (ODS)
  All rights reserved (R) Objective Design Systems Ltd Pty
 
  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.
 
  ------------------------------------------------------------------------
 
  See header file.
 
  ------------------------------------------------------------------------
*/
 
#include <string.h>
#include <rtems++/rtemsMessageQueue.h>
 
/* ----
   rtemsMessageQueue
*/
 
rtemsMessageQueue::rtemsMessageQueue(const char* mqname,
                                     const rtems_unsigned32 count,
                                     const rtems_unsigned32 max_message_size,
                                     const WaitMode wait_mode,
                                     const Scope scope)
  : name(0),
    owner(true),
    id(0)
{
  strcpy(name_str, "NOID");
  create(mqname, count, max_message_size, wait_mode, scope);
}
 
rtemsMessageQueue::rtemsMessageQueue(const char *mqname,
                                     const rtems_unsigned32 node)
  : name(0),
    owner(false),
    id(0)
{
  strcpy(name_str, "NOID");
  connect(mqname, node);
}
 
rtemsMessageQueue::rtemsMessageQueue(const rtemsMessageQueue& message_queue)
  : name(0),
    owner(false),
    id(0)
{
  name = message_queue.name;
  strcpy(name_str, message_queue.name_str);
  id = message_queue.id;
}
 
rtemsMessageQueue::rtemsMessageQueue()
  : name(0),
    owner(false),
    id(0)
{
  strcpy(name_str, "NOID");
}
 
rtemsMessageQueue::~rtemsMessageQueue()
{
  destroy();
}
 
void rtemsMessageQueue::make_invalid()
{
  strcpy(name_str, "NOID");
  name = 0;
  id = 0;
  owner = false;
}
 
const rtems_status_code rtemsMessageQueue::create(const char* mqname,
                                                  const rtems_unsigned32 count,
                                                  const rtems_unsigned32 max_message_size,
                                                  const WaitMode wait_mode,
                                                  const Scope scope)
{
  if (id)
    return set_status_code(RTEMS_ILLEGAL_ON_SELF);
 
  owner = true;
 
  strcpy(name_str, "    ");
  for (int c = 0; (c < 4) && (mqname[c] != '\0'); c++)
    name_str[c] = mqname[c];
  name = rtems_build_name(name_str[0],
                          name_str[1],
                          name_str[2],
                          name_str[3]);
 
  set_status_code(rtems_message_queue_create(name,
                                             count,
                                             max_message_size,
                                             scope | wait_mode,
                                             &id));
 
  if (unsuccessful())
  {
    make_invalid();
  }
 
  return last_status_code();
}
 
const rtems_status_code rtemsMessageQueue::destroy()
{
  if (id && owner)
  {
    set_status_code(rtems_message_queue_delete(id));
    make_invalid();
  }
  else
    set_status_code(RTEMS_NOT_OWNER_OF_RESOURCE);
 
  return last_status_code();
}
 
const rtemsMessageQueue& rtemsMessageQueue::operator=(const rtemsMessageQueue& message_queue)
{
  if (!owner)
  {
    name = message_queue.name;
    strcpy(name_str, message_queue.name_str);
    id = message_queue.id;
  }
 
  return *this;
}
 
const rtems_status_code rtemsMessageQueue::connect(const char *mqname,
                                                   const rtems_unsigned32 node)
{
  if (id && owner)
    return set_status_code(RTEMS_UNSATISFIED);
 
  // change state to not owner
  owner = false;
 
  strcpy(name_str, "    ");
  for (int c = 0; (c < 4) && (mqname[c] != '\0'); c++)
    name_str[c] = mqname[c];
  name = rtems_build_name(name_str[0],
                          name_str[1],
                          name_str[2],
                          name_str[3]);
 
  set_status_code(rtems_message_queue_ident(name, node, &id));
 
  if (unsuccessful())
  {
    make_invalid();
  }
 
  return last_status_code();
}

Line No.	Rev	Author	Line
1	30	unneback	`/*`
2			`------------------------------------------------------------------------`
3			$Id: rtemsMessageQueue.cc,v 1.2 2001-09-27 12:02:05 chris Exp $
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
28			`rtemsMessageQueue::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
41			`rtemsMessageQueue::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
51			`rtemsMessageQueue::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
61			`rtemsMessageQueue::rtemsMessageQueue()`
62			`: name(0),`
63			`owner(false),`
64			`id(0)`
65			`{`
66			`strcpy(name_str, "NOID");`
67			`}`
68
69			`rtemsMessageQueue::~rtemsMessageQueue()`
70			`{`
71			`destroy();`
72			`}`
73
74			`void rtemsMessageQueue::make_invalid()`
75			`{`
76			`strcpy(name_str, "NOID");`
77			`name = 0;`
78			`id = 0;`
79			`owner = false;`
80			`}`
81
82			`const 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
115			`const 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
128			`const 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
140			`const 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			`}`

Browse

Tools

Subversion Repositories openrisc_2011-10-31

[/] [openrisc/] [trunk/] [rtos/] [rtems/] [c/] [src/] [librtems++/] [src/] [rtemsMessageQueue.cc] - Blame information for rev 173