diff options
Diffstat (limited to 'c/src')
| -rw-r--r-- | c/src/tests/psxtests/psxmsgq01/init.c | 130 |
1 files changed, 130 insertions, 0 deletions
diff --git a/c/src/tests/psxtests/psxmsgq01/init.c b/c/src/tests/psxtests/psxmsgq01/init.c index ed49515094..bd678cb73f 100644 --- a/c/src/tests/psxtests/psxmsgq01/init.c +++ b/c/src/tests/psxtests/psxmsgq01/init.c @@ -17,9 +17,139 @@ 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 ); |