Cygwin: POSIX msg queues: move IPC object creation into fhandler

Signed-off-by: Corinna Vinschen <corinna@vinschen.de>

winsup/cygwin/fhandler_mqueue.cc

@@ -7,6 +7,7 @@ Cygwin license.  Please consult the file "CYGWIN_LICENSE" for
 details. */
 
 #include "winsup.h"
+#include "shared_info.h"
 #include "path.h"
 #include "fhandler.h"
 #include "dtable.h"
@@ -22,14 +23,54 @@ struct mq_info *
 fhandler_mqueue::mqinfo (const char *name, int8_t *mptr, HANDLE sect,
 			 size_t size, mode_t mode, int flags)
 {
+  WCHAR buf[MAX_PATH];
+  UNICODE_STRING uname;
+  OBJECT_ATTRIBUTES attr;
+  NTSTATUS status;
+
   set_name (name);
   mqinfo ()->mqi_hdr = (struct mq_hdr *) mptr;
   mqinfo ()->mqi_sect = sect;
   mqinfo ()->mqi_sectsize = size;
   mqinfo ()->mqi_mode = mode;
-  mqinfo ()->mqi_magic = MQI_MAGIC;
   mqinfo ()->mqi_flags = flags;
+
+  __small_swprintf (buf, L"mqueue/mtx%s", name);
+  RtlInitUnicodeString (&uname, buf);
+  InitializeObjectAttributes (&attr, &uname, OBJ_OPENIF | OBJ_CASE_INSENSITIVE,
+                              get_shared_parent_dir (),
+                              everyone_sd (CYG_MUTANT_ACCESS));
+  status = NtCreateMutant (&mqinfo ()->mqi_lock, CYG_MUTANT_ACCESS, &attr,
+			   FALSE);
+  if (!NT_SUCCESS (status))
+    goto err;
+
+  wcsncpy (buf + 7, L"snd", 3);
+  /* same length, no RtlInitUnicodeString required */
+  InitializeObjectAttributes (&attr, &uname, OBJ_OPENIF | OBJ_CASE_INSENSITIVE,
+                              get_shared_parent_dir (),
+                              everyone_sd (CYG_EVENT_ACCESS));
+  status = NtCreateEvent (&mqinfo ()->mqi_waitsend, CYG_EVENT_ACCESS, &attr,
+			  NotificationEvent, FALSE);
+  if (!NT_SUCCESS (status))
+    goto err;
+  wcsncpy (buf + 7, L"rcv", 3);
+  /* same length, same attributes, no more init required */
+  status = NtCreateEvent (&mqinfo ()->mqi_waitrecv, CYG_EVENT_ACCESS, &attr,
+			  NotificationEvent, FALSE);
+  if (!NT_SUCCESS (status))
+    goto err;
+
+  mqinfo ()->mqi_magic = MQI_MAGIC;
   return mqinfo ();
+
+err:
+  if (mqinfo ()->mqi_waitsend)
+    NtClose (mqinfo ()->mqi_waitsend);
+  if (mqinfo ()->mqi_lock)
+    NtClose (mqinfo ()->mqi_lock);
+  __seterrno_from_nt_status (status);
+  return NULL;
 }
 
 char *

winsup/cygwin/posix_ipc.cc

@@ -94,28 +94,6 @@ check_path (char *res_name, ipc_type_t type, const char *name, size_t len)
   return true;
 }
 
-static int
-ipc_mutex_init (HANDLE *pmtx, const char *name)
-{
-  WCHAR buf[MAX_PATH];
-  UNICODE_STRING uname;
-  OBJECT_ATTRIBUTES attr;
-  NTSTATUS status;
-
-  __small_swprintf (buf, L"mqueue/mtx%s", name);
-  RtlInitUnicodeString (&uname, buf);
-  InitializeObjectAttributes (&attr, &uname, OBJ_OPENIF | OBJ_CASE_INSENSITIVE,
-			      get_shared_parent_dir (),
-			      everyone_sd (CYG_MUTANT_ACCESS));
-  status = NtCreateMutant (pmtx, CYG_MUTANT_ACCESS, &attr, FALSE);
-  if (!NT_SUCCESS (status))
-    {
-      debug_printf ("NtCreateMutant: %y", status);
-      return geterrno_from_win_error (RtlNtStatusToDosError (status));
-    }
-  return 0;
-}
-
 static int
 ipc_mutex_lock (HANDLE mtx, bool eintr)
 {
@@ -140,29 +118,6 @@ ipc_mutex_unlock (HANDLE mtx)
   return ReleaseMutex (mtx) ? 0 : geterrno_from_win_error ();
 }
 
-static int
-ipc_cond_init (HANDLE *pevt, const char *name, char sr)
-{
-  WCHAR buf[MAX_PATH];
-  UNICODE_STRING uname;
-  OBJECT_ATTRIBUTES attr;
-  NTSTATUS status;
-
-  __small_swprintf (buf, L"mqueue/evt%s%c", name, sr);
-  RtlInitUnicodeString (&uname, buf);
-  InitializeObjectAttributes (&attr, &uname, OBJ_OPENIF | OBJ_CASE_INSENSITIVE,
-			      get_shared_parent_dir (),
-			      everyone_sd (CYG_EVENT_ACCESS));
-  status = NtCreateEvent (pevt, CYG_EVENT_ACCESS, &attr,
-			  NotificationEvent, FALSE);
-  if (!NT_SUCCESS (status))
-    {
-      debug_printf ("NtCreateEvent: %y", status);
-      return geterrno_from_win_error (RtlNtStatusToDosError (status));
-    }
-  return 0;
-}
-
 static int
 ipc_cond_timedwait (HANDLE evt, HANDLE mtx, const struct timespec *abstime)
 {
@@ -352,31 +307,6 @@ struct mq_attr defattr = { 0, 10, 8192, 0 };	/* Linux defaults. */
 extern "C" off_t lseek64 (int, off_t, int);
 extern "C" void *mmap64 (void *, size_t, int, int, int, off_t);
 
-static inline int
-_mq_ipc_init (struct mq_info *mqinfo, const char *name)
-{
-  int ret;
-
-  /* Initialize mutex & condition variable */
-  ret = ipc_mutex_init (&mqinfo->mqi_lock, name);
-  if (ret)
-    return ret;
-  ret = ipc_cond_init (&mqinfo->mqi_waitsend, name, 'S');
-  if (ret)
-    {
-      NtClose (mqinfo->mqi_lock);
-      return ret;
-    }
-  ret = ipc_cond_init (&mqinfo->mqi_waitrecv, name, 'R');
-  if (ret)
-    {
-      NtClose (mqinfo->mqi_waitsend);
-      NtClose (mqinfo->mqi_lock);
-      return ret;
-    }
-  return 0;
-}
-
 static int8_t *
 _map_file (int fd, SIZE_T filesize, HANDLE &secth)
 {
@@ -489,14 +419,8 @@ mq_open (const char *name, int oflag, ...)
 	  fdm = fh;
 
 	  mqinfo = fh->mqinfo (name, mptr, secth, filesize, mode, nonblock);
-
+	  if (!mqinfo)
-	  /* Initialize mutex & condition variables */
+	    __leave;
-	  i = _mq_ipc_init (mqinfo, fh->get_name ());
-	  if (i != 0)
-	    {
-	      set_errno (i);
-	      __leave;
-	    }
 
 	  /* Initialize header at beginning of file */
 	  /* Create free list with all messages on it */
@@ -589,14 +513,8 @@ mq_open (const char *name, int oflag, ...)
 
       mqinfo = fh->mqinfo (name, mptr, secth, filesize, statbuff.st_mode,
 			   nonblock);
-
+      if (!mqinfo)
-      /* Initialize mutex & condition variable */
+	__leave;
-      i = _mq_ipc_init (mqinfo, fh->get_name ());
-      if (i != 0)
-	{
-	  set_errno (i);
-	  __leave;
-	}
 
       return (mqd_t) fdm;
     }
@@ -611,15 +529,6 @@ mq_open (const char *name, int oflag, ...)
       NtUnmapViewOfSection (NtCurrentProcess (), mptr);
       NtClose (secth);
     }
-  if (mqinfo)
-    {
-      if (mqinfo->mqi_lock)
-	NtClose (mqinfo->mqi_lock);
-      if (mqinfo->mqi_waitsend)
-	NtClose (mqinfo->mqi_waitsend);
-      if (mqinfo->mqi_waitrecv)
-	NtClose (mqinfo->mqi_waitrecv);
-    }
   if (fd >= 0)
     close (fd);
   return (mqd_t) -1;