RTOS/rtems
1
0
Fork 0
forked from Imagelibrary/rtems
Code Pull Requests Activity

+ Added tests for open, close, unlink, and send.

Browse Source
This commit is contained in:
Jennifer Averett
2000-01-05 17:21:12 +00:00
parent b302d527c7
commit 99e7ab890b
2 changed files with 446 additions and 106 deletions
Download Patch File Download Diff File Expand all files Collapse all files

276
c/src/tests/psxtests/psxmsgq01/init.c
View File

@@ -35,6 +35,14 @@ char *Get_Too_Long_Name()
return Queue_Name;
}
typedef enum {
DEFAULT_SIZE_TYPE,
TEST_SIZE_TYPE,
MAX_SIZE,
TYPES_OF_TEST_SIZES
} TEST_MQ_SIZE_TYPES;
/*
* Opens CONFIGURE_MAXIMUM_POSIX_MESSAGE_QUEUES then leaves size queues
* opened but closes the rest.
@@ -65,21 +73,20 @@ void validate_mq_open_error_codes(
attr.mq_maxmsg = -1;
puts( "mq_open - Create with maxmsg (-1) (EINVAL)" );
n_mq2 = mq_open("mq2", O_CREAT, O_RDONLY, &attr);
n_mq2 = mq_open("mq2", O_CREAT | O_RDONLY, 0x777, &attr);
fatal_directive_status(
(int) n_mq2, (int ) (-1), "mq_open error return status" );
fatal_directive_status( errno, EINVAL, "mq_open errno EINVAL");
attr.mq_msgsize = -1;
puts( "mq_open - Create with msgsize (-1) (EINVAL)" );
n_mq2 = mq_open("mq2", O_CREAT, O_RDONLY, &attr);
n_mq2 = mq_open("mq2", O_CREAT | O_RDONLY, 0x777, &attr);
fatal_directive_status(
(int) n_mq2, (int ) (-1), "mq_open error return status" );
fatal_directive_status( errno, EINVAL, "mq_open errno EINVAL");
puts( "mq_open - Open new mq without create flag (ENOENT)" );
n_mq2 = mq_open("mq3", O_EXCL, O_RDONLY, NULL);
n_mq2 = mq_open("mq3", O_EXCL | O_RDONLY, 0x777, NULL);
fatal_directive_status(
(int) n_mq2, (int ) (-1), "mq_open error return status" );
fatal_directive_status( errno, ENOENT, "mq_open errno ENOENT");
@@ -94,7 +101,7 @@ void validate_mq_open_error_codes(
*/
puts( "mq_open - Open with too long of a name (ENAMETOOLONG)" );
n_mq2 = mq_open( Get_Too_Long_Name(), O_CREAT, O_RDONLY, NULL );
n_mq2 = mq_open( Get_Too_Long_Name(), O_CREAT | O_RDONLY, 0x777, NULL );
fatal_directive_status(
(int) n_mq2, (int ) (-1), "mq_open error return status" );
fatal_directive_status( errno, ENAMETOOLONG, "mq_open errno ENAMETOOLONG");
@@ -105,7 +112,7 @@ void validate_mq_open_error_codes(
puts( "mq_open - SUCCESSFUL" );
for (i = 0; i < CONFIGURE_MAXIMUM_POSIX_MESSAGE_QUEUES; i++) {
mqs[i] = mq_open( Get_Queue_Name(i), O_CREAT, O_RDONLY, NULL );
mqs[i] = mq_open( Get_Queue_Name(i), O_CREAT | O_RDWR, 0x777, NULL );
assert( mqs[i] != (-1) );
/*XXX - Isn't there a more general check */
}
@@ -125,14 +132,14 @@ void validate_mq_open_error_codes(
/*
* XXX EACCES - queue exists permissions specified by o_flag are denied.
puts( "mq_open - open mq as write (EACCES)" );
n_mq2 = mq_open("mq1", O_CREAT, O_WRONLY, NULL);
n_mq2 = mq_open("mq1", O_CREAT | O_WRONLY, 0x777, NULL);
fatal_directive_status(
(int) n_mq2, (int ) (-1), "mq_open error return status" );
fatal_directive_status( errno, EACCES, "mq_open errno EACCES");
*/
puts( "mq_open - Create an Existing mq (EEXIST)" );
n_mq2 = mq_open("mq1", O_CREAT | O_EXCL, O_RDONLY, NULL);
n_mq2 = mq_open("mq1", O_CREAT | O_EXCL | O_RDONLY, 0x777, NULL);
fatal_directive_status(
(int) n_mq2, (int ) (-1), "mq_open error return status" );
fatal_directive_status( errno, EEXIST, "mq_open errno EEXIST");
@@ -143,7 +150,7 @@ void validate_mq_open_error_codes(
*/
puts( "mq_open - system is out of resources (ENFILE)" );
n_mq2 = mq_open( Get_Queue_Name(i), O_CREAT, O_RDONLY, NULL );
n_mq2 = mq_open( Get_Queue_Name(i), O_CREAT | O_RDONLY, 0x777, NULL );
fatal_directive_status(
(int) n_mq2, (int ) (-1), "mq_open error return status" );
fatal_directive_status( errno, ENFILE, "mq_open errno ENFILE");
@@ -164,8 +171,8 @@ void validate_mq_open_error_codes(
}
void validate_mq_unlink_error_codes(
mqd_t *mqs, /* Must be large enough for Maximum to be opened. */
int size /* Number still open */
mqd_t *mqs,
int size /* Number still open in mqs */
)
{
int status;
@@ -177,24 +184,36 @@ void validate_mq_unlink_error_codes(
/*
* XXX ENAMETOOLONG - Not checked in either sem_unlink or mq_unlink is
* this an error?
for ( i=0; i< PATH_MAX+1; i++ )
name[i] = 'N';
puts( "mq_open - Open with too long of a name (ENAMETOOLONG)" );
n_mq2 = mq_open( Get_Too_Long_Name(), O_CREAT, O_RDONLY, NULL );
fatal_directive_status(
(int) n_mq2, (int ) (-1), "mq_open error return status" );
fatal_directive_status( errno, ENAMETOOLONG, "mq_open errno ENAMETOOLONG");
*/
*/
puts( "mq_unlink - mq_unlink with too long of a name (ENAMETOOLONG)" );
status = mq_unlink( Get_Too_Long_Name() );
fatal_directive_status( status, -1, "mq_unlink error return status");
fatal_directive_status( errno, ENAMETOOLONG, "mq_unlink errno ENAMETOOLONG");
puts( "mq_unlink - UNSUCCESSFUL (ENOENT)" );
status = mq_unlink(Get_Queue_Name(size));
fatal_directive_status( status, -1, "mq_unlink error return status");
fatal_directive_status( errno, ENOENT, "mq_unlink errno ENOENT");
/*
* XXX - These errors are not in the POSIX manual but may occur.
*/
puts( "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( "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");
}
void validate_mq_close_error_codes(
mqd_t *mqs, /* Must be large enough for Maximum to be opened. */
int size /* Number still open */
mqd_t *mqs,
int size /* Number still open in mqs */
)
{
int status;
@@ -203,7 +222,167 @@ void validate_mq_close_error_codes(
status = mq_close(mqs[size]);
fatal_directive_status( status, -1, "mq_close error return status");
fatal_directive_status( errno, EBADF, "mq_close errno EBADF");
}
/*
* Returns the number of messages queued after the test on the
* first queue.
*/
int validate_mq_send_error_codes(
mqd_t *mqs,
int size /* Number still open in mqs */
)
{
int status;
int i;
mqd_t n_mq1;
struct mq_attr attr;
attr.mq_maxmsg = 3;
attr.mq_msgsize = 8;
/*
* XXX - EBADF Not a valid message descriptor.
* Write to a invalid message descriptor
* XXX - Write to a read only queue
*/
puts( "mq_send - Closed message queue (EBADF)" );
status = mq_send( mqs[size], "", 1, 0 );
fatal_directive_status( status, -1, "mq_send error return status");
fatal_directive_status( errno, EBADF, "mq_send errno EBADF");
puts( "mq_open - Open a read only queue" );
n_mq1 = mq_open("read_only", O_CREAT | O_RDONLY, 0x777, &attr);
assert( n_mq1 != (-1) );
/*XXX - Isn't there a more general check */
puts( "mq_send - Read only message queue (EBADF)" );
status = mq_send( n_mq1, "", 1, 0 );
fatal_directive_status( status, -1, "mq_send error return status");
fatal_directive_status( errno, EBADF, "mq_send errno EBADF");
status = mq_close( n_mq1 );
fatal_directive_status( status, 0, "mq_close message queue");
status = mq_unlink( "read_only" );
fatal_directive_status( status, 0, "mq_unlink message queue");
/*
* XXX - EINTR
* Signal interrupted the call.
puts( "mq_send - UNSUCCESSFUL (EINTR)" );
status = mq_send( mqs, "", 0xffff, 0 );
fatal_directive_status( status, -1, "mq_send error return status");
fatal_directive_status( errno, E, "mq_send errno E");
*/
/*
* XXX - EINVAL priority is out of range.
*/
puts( "mq_send - Priority out of range (EINVAL)" );
status = mq_send( mqs[0], "", 1, MQ_PRIO_MAX + 1 );
fatal_directive_status( status, -1, "mq_send error return status");
fatal_directive_status( errno, EINVAL, "mq_send errno EINVAL");
/*
* XXX - EMSGSIZE - Message size larger than msg_len
*/
puts( "mq_send - Message longer than msg_len (EMSGSIZE)" );
status = mq_send( mqs[0], "", 0xffff, 0 );
fatal_directive_status( status, -1, "mq_send error return status");
fatal_directive_status( errno, EMSGSIZE, "mq_send errno EMSGSIZE");
/*
* ENOSYS - send is supported should never happen.
*/
/*
* XXX - EAGAIN
* O_NONBLOCK and message queue is full.
* This is validated in the read/write test.
*/
i=0;
do {
status = mq_send( mqs[0], "", 1, 0 );
i++;
} while (status == 0);
fatal_directive_status( status, -1, "mq_send error return status");
fatal_directive_status( errno, EAGAIN, "mq_send errno EAGAIN");
return i-1;
}
void validate_mq_receive_error_codes(
mqd_t *mqs,
int size /* Number still open in mqs */
)
{
int status;
/*
* EAGAIN -
*/
/*
* EBADF -
*/
/*
* EMSGSIZE -
*/
/*
* EINTR -
*/
/*
* EBADMSG - a data corruption problem.
* XXX - Can not cause.
*/
/*
puts( "mq_ - UNSUCCESSFUL ()" );
status = mq_( );
fatal_directive_status( status, -1, "mq_ error return status");
fatal_directive_status( errno, E, "mq_c errno E");
*/
/*
* ENOSYS -
*/
}
void non_blocking_mq_read_write(
mqd_t *mqs,
int size /* Number still open in mqs */
)
{
/*
int status;
char *messages[] = {
"Msg 1",
"Test 2",
"12345678901234567890"
};
status = mq_send( mqs[0], messages[0], strlen( messages[0] ), 0 );
fatal_directive_status( status, 0, "mq_send error return status" );
puts( "mq_send - UNSUCCESSFUL ()" );
do {
status = mq_send( );
fatal_directive_status( status, -1, "mq_send error return status");
fatal_directive_status( errno, E, "mq_send errno E");
}
*/
}
void *POSIX_Init(
@@ -211,15 +390,14 @@ void *POSIX_Init(
)
{
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];
struct mq_attr attr;
char *messages[] = {
"Msg 1",
"Test 2",
"12345678901234567890"
};
puts( "\n\n*** POSIX MESSAGE QUEUE TEST ***" );
@@ -227,14 +405,18 @@ void *POSIX_Init(
validate_mq_unlink_error_codes( mqs, 2 );
validate_mq_close_error_codes( mqs, 2 );
validate_mq_send_error_codes( mqs, 2 );
validate_mq_receive_error_codes( mqs, 2 );
/*
* Validate a second open returns the same message queue.
*/
puts( "mq_open - Open an existing mq ( same id )" );
n_mq2 = mq_open("mq1", 0 );
n_mq1 = mq_open("mq1", 0 );
fatal_directive_status(
(int) n_mq2, (int ) mqs[0], "mq_open error return status" );
(int) n_mq1, (int ) mqs[0], "mq_open error return status" );
/*
* Unlink the message queue, then verify an open of the same name produces a
@@ -251,50 +433,36 @@ void *POSIX_Init(
assert( n_mq2 != n_mq1 );
/*
* Validate it n_mq2 (the last open for mq1 name can be
* correctly closed and unlinked.
* Validate it "mq1" can be closed and unlinked.
*/
puts( "Init: mq_unlink - mq1 (2) SUCCESSFUL" );
puts( "mq_unlink - mq1 SUCCESSFUL" );
status = mq_unlink( "mq1" );
fatal_directive_status( status, 0, "mq_unlink locked message queue");
puts( "Init: mq_close (2) - SUCCESSFUL" );
puts( "mq_close mq1 - SUCCESSFUL" );
status = mq_close( n_mq2 );
fatal_directive_status( status, 0, "mq_close message queue");
status = mq_close( n_mq1 );
fatal_directive_status( status, 0, "mq_close message queue");
status = mq_close( mqs[0] );
fatal_directive_status( status, 0, "mq_close message queue");
puts( "Init: mq_unlink - UNSUCCESSFUL (ENOENT)" );
puts( "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.
*/
* XXX - Don't think we need this save until yellow line tested.
puts( "Init: mq_unlink - UNSUCCESSFUL (ENOENT)" );
status = mq_unlink("mq3");
fatal_directive_status( status, -1, "mq_unlink error return status");
fatal_directive_status( errno, ENOENT, "mq_unlink errno ENOENT");
assert( (status == -1) && (errno == ENOENT) );
*/
/*
@@ -312,3 +480,5 @@ void *POSIX_Init(
return NULL; /* just so the compiler thinks we returned something */
}

276
testsuites/psxtests/psxmsgq01/init.c
View File

@@ -35,6 +35,14 @@ char *Get_Too_Long_Name()
return Queue_Name;
}
typedef enum {
DEFAULT_SIZE_TYPE,
TEST_SIZE_TYPE,
MAX_SIZE,
TYPES_OF_TEST_SIZES
} TEST_MQ_SIZE_TYPES;
/*
* Opens CONFIGURE_MAXIMUM_POSIX_MESSAGE_QUEUES then leaves size queues
* opened but closes the rest.
@@ -65,21 +73,20 @@ void validate_mq_open_error_codes(
attr.mq_maxmsg = -1;
puts( "mq_open - Create with maxmsg (-1) (EINVAL)" );
n_mq2 = mq_open("mq2", O_CREAT, O_RDONLY, &attr);
n_mq2 = mq_open("mq2", O_CREAT | O_RDONLY, 0x777, &attr);
fatal_directive_status(
(int) n_mq2, (int ) (-1), "mq_open error return status" );
fatal_directive_status( errno, EINVAL, "mq_open errno EINVAL");
attr.mq_msgsize = -1;
puts( "mq_open - Create with msgsize (-1) (EINVAL)" );
n_mq2 = mq_open("mq2", O_CREAT, O_RDONLY, &attr);
n_mq2 = mq_open("mq2", O_CREAT | O_RDONLY, 0x777, &attr);
fatal_directive_status(
(int) n_mq2, (int ) (-1), "mq_open error return status" );
fatal_directive_status( errno, EINVAL, "mq_open errno EINVAL");
puts( "mq_open - Open new mq without create flag (ENOENT)" );
n_mq2 = mq_open("mq3", O_EXCL, O_RDONLY, NULL);
n_mq2 = mq_open("mq3", O_EXCL | O_RDONLY, 0x777, NULL);
fatal_directive_status(
(int) n_mq2, (int ) (-1), "mq_open error return status" );
fatal_directive_status( errno, ENOENT, "mq_open errno ENOENT");
@@ -94,7 +101,7 @@ void validate_mq_open_error_codes(
*/
puts( "mq_open - Open with too long of a name (ENAMETOOLONG)" );
n_mq2 = mq_open( Get_Too_Long_Name(), O_CREAT, O_RDONLY, NULL );
n_mq2 = mq_open( Get_Too_Long_Name(), O_CREAT | O_RDONLY, 0x777, NULL );
fatal_directive_status(
(int) n_mq2, (int ) (-1), "mq_open error return status" );
fatal_directive_status( errno, ENAMETOOLONG, "mq_open errno ENAMETOOLONG");
@@ -105,7 +112,7 @@ void validate_mq_open_error_codes(
puts( "mq_open - SUCCESSFUL" );
for (i = 0; i < CONFIGURE_MAXIMUM_POSIX_MESSAGE_QUEUES; i++) {
mqs[i] = mq_open( Get_Queue_Name(i), O_CREAT, O_RDONLY, NULL );
mqs[i] = mq_open( Get_Queue_Name(i), O_CREAT | O_RDWR, 0x777, NULL );
assert( mqs[i] != (-1) );
/*XXX - Isn't there a more general check */
}
@@ -125,14 +132,14 @@ void validate_mq_open_error_codes(
/*
* XXX EACCES - queue exists permissions specified by o_flag are denied.
puts( "mq_open - open mq as write (EACCES)" );
n_mq2 = mq_open("mq1", O_CREAT, O_WRONLY, NULL);
n_mq2 = mq_open("mq1", O_CREAT | O_WRONLY, 0x777, NULL);
fatal_directive_status(
(int) n_mq2, (int ) (-1), "mq_open error return status" );
fatal_directive_status( errno, EACCES, "mq_open errno EACCES");
*/
puts( "mq_open - Create an Existing mq (EEXIST)" );
n_mq2 = mq_open("mq1", O_CREAT | O_EXCL, O_RDONLY, NULL);
n_mq2 = mq_open("mq1", O_CREAT | O_EXCL | O_RDONLY, 0x777, NULL);
fatal_directive_status(
(int) n_mq2, (int ) (-1), "mq_open error return status" );
fatal_directive_status( errno, EEXIST, "mq_open errno EEXIST");
@@ -143,7 +150,7 @@ void validate_mq_open_error_codes(
*/
puts( "mq_open - system is out of resources (ENFILE)" );
n_mq2 = mq_open( Get_Queue_Name(i), O_CREAT, O_RDONLY, NULL );
n_mq2 = mq_open( Get_Queue_Name(i), O_CREAT | O_RDONLY, 0x777, NULL );
fatal_directive_status(
(int) n_mq2, (int ) (-1), "mq_open error return status" );
fatal_directive_status( errno, ENFILE, "mq_open errno ENFILE");
@@ -164,8 +171,8 @@ void validate_mq_open_error_codes(
}
void validate_mq_unlink_error_codes(
mqd_t *mqs, /* Must be large enough for Maximum to be opened. */
int size /* Number still open */
mqd_t *mqs,
int size /* Number still open in mqs */
)
{
int status;
@@ -177,24 +184,36 @@ void validate_mq_unlink_error_codes(
/*
* XXX ENAMETOOLONG - Not checked in either sem_unlink or mq_unlink is
* this an error?
for ( i=0; i< PATH_MAX+1; i++ )
name[i] = 'N';
puts( "mq_open - Open with too long of a name (ENAMETOOLONG)" );
n_mq2 = mq_open( Get_Too_Long_Name(), O_CREAT, O_RDONLY, NULL );
fatal_directive_status(
(int) n_mq2, (int ) (-1), "mq_open error return status" );
fatal_directive_status( errno, ENAMETOOLONG, "mq_open errno ENAMETOOLONG");
*/
*/
puts( "mq_unlink - mq_unlink with too long of a name (ENAMETOOLONG)" );
status = mq_unlink( Get_Too_Long_Name() );
fatal_directive_status( status, -1, "mq_unlink error return status");
fatal_directive_status( errno, ENAMETOOLONG, "mq_unlink errno ENAMETOOLONG");
puts( "mq_unlink - UNSUCCESSFUL (ENOENT)" );
status = mq_unlink(Get_Queue_Name(size));
fatal_directive_status( status, -1, "mq_unlink error return status");
fatal_directive_status( errno, ENOENT, "mq_unlink errno ENOENT");
/*
* XXX - These errors are not in the POSIX manual but may occur.
*/
puts( "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( "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");
}
void validate_mq_close_error_codes(
mqd_t *mqs, /* Must be large enough for Maximum to be opened. */
int size /* Number still open */
mqd_t *mqs,
int size /* Number still open in mqs */
)
{
int status;
@@ -203,7 +222,167 @@ void validate_mq_close_error_codes(
status = mq_close(mqs[size]);
fatal_directive_status( status, -1, "mq_close error return status");
fatal_directive_status( errno, EBADF, "mq_close errno EBADF");
}
/*
* Returns the number of messages queued after the test on the
* first queue.
*/
int validate_mq_send_error_codes(
mqd_t *mqs,
int size /* Number still open in mqs */
)
{
int status;
int i;
mqd_t n_mq1;
struct mq_attr attr;
attr.mq_maxmsg = 3;
attr.mq_msgsize = 8;
/*
* XXX - EBADF Not a valid message descriptor.
* Write to a invalid message descriptor
* XXX - Write to a read only queue
*/
puts( "mq_send - Closed message queue (EBADF)" );
status = mq_send( mqs[size], "", 1, 0 );
fatal_directive_status( status, -1, "mq_send error return status");
fatal_directive_status( errno, EBADF, "mq_send errno EBADF");
puts( "mq_open - Open a read only queue" );
n_mq1 = mq_open("read_only", O_CREAT | O_RDONLY, 0x777, &attr);
assert( n_mq1 != (-1) );
/*XXX - Isn't there a more general check */
puts( "mq_send - Read only message queue (EBADF)" );
status = mq_send( n_mq1, "", 1, 0 );
fatal_directive_status( status, -1, "mq_send error return status");
fatal_directive_status( errno, EBADF, "mq_send errno EBADF");
status = mq_close( n_mq1 );
fatal_directive_status( status, 0, "mq_close message queue");
status = mq_unlink( "read_only" );
fatal_directive_status( status, 0, "mq_unlink message queue");
/*
* XXX - EINTR
* Signal interrupted the call.
puts( "mq_send - UNSUCCESSFUL (EINTR)" );
status = mq_send( mqs, "", 0xffff, 0 );
fatal_directive_status( status, -1, "mq_send error return status");
fatal_directive_status( errno, E, "mq_send errno E");
*/
/*
* XXX - EINVAL priority is out of range.
*/
puts( "mq_send - Priority out of range (EINVAL)" );
status = mq_send( mqs[0], "", 1, MQ_PRIO_MAX + 1 );
fatal_directive_status( status, -1, "mq_send error return status");
fatal_directive_status( errno, EINVAL, "mq_send errno EINVAL");
/*
* XXX - EMSGSIZE - Message size larger than msg_len
*/
puts( "mq_send - Message longer than msg_len (EMSGSIZE)" );
status = mq_send( mqs[0], "", 0xffff, 0 );
fatal_directive_status( status, -1, "mq_send error return status");
fatal_directive_status( errno, EMSGSIZE, "mq_send errno EMSGSIZE");
/*
* ENOSYS - send is supported should never happen.
*/
/*
* XXX - EAGAIN
* O_NONBLOCK and message queue is full.
* This is validated in the read/write test.
*/
i=0;
do {
status = mq_send( mqs[0], "", 1, 0 );
i++;
} while (status == 0);
fatal_directive_status( status, -1, "mq_send error return status");
fatal_directive_status( errno, EAGAIN, "mq_send errno EAGAIN");
return i-1;
}
void validate_mq_receive_error_codes(
mqd_t *mqs,
int size /* Number still open in mqs */
)
{
int status;
/*
* EAGAIN -
*/
/*
* EBADF -
*/
/*
* EMSGSIZE -
*/
/*
* EINTR -
*/
/*
* EBADMSG - a data corruption problem.
* XXX - Can not cause.
*/
/*
puts( "mq_ - UNSUCCESSFUL ()" );
status = mq_( );
fatal_directive_status( status, -1, "mq_ error return status");
fatal_directive_status( errno, E, "mq_c errno E");
*/
/*
* ENOSYS -
*/
}
void non_blocking_mq_read_write(
mqd_t *mqs,
int size /* Number still open in mqs */
)
{
/*
int status;
char *messages[] = {
"Msg 1",
"Test 2",
"12345678901234567890"
};
status = mq_send( mqs[0], messages[0], strlen( messages[0] ), 0 );
fatal_directive_status( status, 0, "mq_send error return status" );
puts( "mq_send - UNSUCCESSFUL ()" );
do {
status = mq_send( );
fatal_directive_status( status, -1, "mq_send error return status");
fatal_directive_status( errno, E, "mq_send errno E");
}
*/
}
void *POSIX_Init(
@@ -211,15 +390,14 @@ void *POSIX_Init(
)
{
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];
struct mq_attr attr;
char *messages[] = {
"Msg 1",
"Test 2",
"12345678901234567890"
};
puts( "\n\n*** POSIX MESSAGE QUEUE TEST ***" );
@@ -227,14 +405,18 @@ void *POSIX_Init(
validate_mq_unlink_error_codes( mqs, 2 );
validate_mq_close_error_codes( mqs, 2 );
validate_mq_send_error_codes( mqs, 2 );
validate_mq_receive_error_codes( mqs, 2 );
/*
* Validate a second open returns the same message queue.
*/
puts( "mq_open - Open an existing mq ( same id )" );
n_mq2 = mq_open("mq1", 0 );
n_mq1 = mq_open("mq1", 0 );
fatal_directive_status(
(int) n_mq2, (int ) mqs[0], "mq_open error return status" );
(int) n_mq1, (int ) mqs[0], "mq_open error return status" );
/*
* Unlink the message queue, then verify an open of the same name produces a
@@ -251,50 +433,36 @@ void *POSIX_Init(
assert( n_mq2 != n_mq1 );
/*
* Validate it n_mq2 (the last open for mq1 name can be
* correctly closed and unlinked.
* Validate it "mq1" can be closed and unlinked.
*/
puts( "Init: mq_unlink - mq1 (2) SUCCESSFUL" );
puts( "mq_unlink - mq1 SUCCESSFUL" );
status = mq_unlink( "mq1" );
fatal_directive_status( status, 0, "mq_unlink locked message queue");
puts( "Init: mq_close (2) - SUCCESSFUL" );
puts( "mq_close mq1 - SUCCESSFUL" );
status = mq_close( n_mq2 );
fatal_directive_status( status, 0, "mq_close message queue");
status = mq_close( n_mq1 );
fatal_directive_status( status, 0, "mq_close message queue");
status = mq_close( mqs[0] );
fatal_directive_status( status, 0, "mq_close message queue");
puts( "Init: mq_unlink - UNSUCCESSFUL (ENOENT)" );
puts( "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.
*/
* XXX - Don't think we need this save until yellow line tested.
puts( "Init: mq_unlink - UNSUCCESSFUL (ENOENT)" );
status = mq_unlink("mq3");
fatal_directive_status( status, -1, "mq_unlink error return status");
fatal_directive_status( errno, ENOENT, "mq_unlink errno ENOENT");
assert( (status == -1) && (errno == ENOENT) );
*/
/*
@@ -312,3 +480,5 @@ void *POSIX_Init(
return NULL; /* just so the compiler thinks we returned something */
}