Jennifer added initial test code. Conditional'ed out until she has

the opportunity to work with it.

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 );