1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
|
/*
* 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$
*/
#define CONFIGURE_INIT
#include "system.h"
#include <sched.h>
void *POSIX_Init(
void *argument
)
{
int status;
int value;
int i;
mqd_t mqs[CONFIGURE_MAXIMUM_POSIX_MESSAGE_QUEUES];
mqd_t mq2;
mqd_t *n_mq1;
mqd_t *n_mq2;
struct timespec waittime;
char failure_msg[80];
puts( "\n\n*** POSIX MESSAGE QUEUE TEST ***" );
#if 0
/* Modes are currently unsupported */
/*
* Validate all mq_open return paths.
*/
puts( "Init: mq_open - mq1 SUCCESSFUL" );
n_mq1 = mq_open( "mq1", O_CREAT, 00777, 1 );
assert( n_mq1 != SEM_FAILED );
puts( "Init: mq_open - Create an Existing mq (EEXIST)" );
n_mq2 = mq_open("mq1", O_CREAT | O_EXCL, 00777, 1);
fatal_directive_status(
(int) n_mq2, (int ) SEM_FAILED, "mq_open error return status" );
fatal_directive_status( errno, EEXIST, "mq_open errno EEXIST");
puts( "Init: mq_open - Open new mq without create flag (ENOENT)" );
n_mq2 = mq_open("mq3", O_EXCL, 00777, 1);
fatal_directive_status(
(int) n_mq2, (int ) SEM_FAILED, "mq_open error return status" );
fatal_directive_status( errno, ENOENT, "mq_open errno EEXIST");
/*
* XXX - Could not hit the following errors:
* E_POSIX_Semaphore_Create_support only fails if
* ENOSYS - When semaphore is shared between processes.
* ENOSPC - When out of memory.
*/
/*
* Validate we can wait on a message queue opened with mq_open.
*/
puts( "Init: mq_wait on mq1" );
status = mq_receive(n_mq1);
fatal_directive_status( status, 0, "mq_wait opened message queue");
/*
* Validate a second open returns the same message queue.
*/
puts( "Init: mq_open - Open an existing mq ( same id )" );
n_mq2 = mq_open("mq1", 0 );
fatal_directive_status(
(int) n_mq2, (int ) n_mq1, "mq_open error return status" );
/*
* Unlink the message queue, then verify an open of the same name produces a
* different message queue.
*/
puts( "Init: mq_unlink - mq1 SUCCESSFUL" );
status = mq_unlink( "mq1" );
fatal_directive_status( status, 0, "mq_unlink locked message queue");
puts( "Init: mq_open - Reopen mq1 SUCCESSFUL with a different id" );
n_mq2 = mq_open( "mq1", O_CREAT | O_EXCL, 00777, 1);
assert( n_mq2 != SEM_FAILED );
assert( n_mq2 != n_mq1 );
/*
* Validate we can call close on a message queue opened with mq_open.
*/
puts( "Init: mq_close (1) - SUCCESSFUL" );
status = mq_close( n_mq1 );
fatal_directive_status( status, 0, "mq_close message queue");
/*
* Validate it n_mq2 (the last open for mq1 name can be
* correctly closed and unlinked.
*/
puts( "Init: mq_close (2) - SUCCESSFUL" );
status = mq_close( n_mq2 );
fatal_directive_status( status, 0, "mq_close message queue");
puts( "Init: mq_unlink - mq1 (2) SUCCESSFUL" );
status = mq_unlink( "mq1" );
fatal_directive_status( status, 0, "mq_unlink locked message queue");
puts( "Init: mq_close - UNSUCCESSFUL (EINVAL)" );
status = mq_close(n_mq2);
fatal_directive_status( status, -1, "mq_close error return status");
fatal_directive_status( errno, EINVAL, "mq_close errno EINVAL");
puts( "Init: mq_unlink - UNSUCCESSFUL (ENOENT)" );
status = mq_unlink("mq1");
fatal_directive_status( status, -1, "mq_unlink error return status");
fatal_directive_status( errno, ENOENT, "mq_close errno EINVAL");
/*
* Validate we can unlink (2)
*/
puts( "Init: mq_unlink (NULL) - EINVAL" );
status = mq_unlink( NULL );
fatal_directive_status( status, -1, "mq_unlink error return status");
fatal_directive_status( errno, EINVAL, "mq_unlink errno value");
puts( "Init: mq_unlink (\"\") - EINVAL" );
status = mq_unlink( "" );
fatal_directive_status( status, -1, "mq_unlink error return status");
fatal_directive_status( errno, EINVAL, "mq_unlink errno value");
/*
* XXX - Cant' create location OBJECTS_ERROR or OBJECTS_REMOTE.
* mq_close and mq_unlink.
*/
puts( "Init: mq_unlink - UNSUCCESSFUL (ENOENT)" );
status = mq_unlink("mq2");
fatal_directive_status( status, -1, "mq_unlink error return status");
fatal_directive_status( errno, ENOENT, "mq_unlink errno ENOENT");
assert( (status == -1) && (errno == ENOENT) );
#endif
puts( "*** END OF POSIX MESSAGE QUEUE TEST ***" );
exit( 0 );
return NULL; /* just so the compiler thinks we returned something */
}
|
