eina: overhaul Mac OS X semaphores
authorJean Guyomarc'h <jean.guyomarch@openwide.fr>
Fri, 26 Aug 2016 15:41:20 +0000 (17:41 +0200)
committerJean Guyomarc'h <jean@guyomarch.bzh>
Fri, 26 Aug 2016 19:16:39 +0000 (21:16 +0200)
Mac OS X does not support POSIX unnamed semaphores, only named
semaphores, which are persistant IPC: when the program exits,
and if semaphores where not released, they stay forever...

All EFL programs were "leaking" a semaphore, due to how
eina_log_monitor manages its resources. Therefore, after building
EFL a lot (which run eolian_gen, eolian_cxx, elua, edje_cc, ...)
we were not able to create any semaphore...

Now, we get rid of these semaphores and use Mac OS X's own
semaphores. Code is less cumbersome, and we don't have any
disavantage of the named semaphores.

Fixes T4423

@fix

src/lib/eina/eina_inline_lock_posix.x

index b52a647..d2e4b95 100644 (file)
 # include <libkern/OSAtomic.h>
 #endif
 
+#ifdef EINA_HAVE_OSX_SEMAPHORE
+# include <mach/mach.h>
+#endif
+
 #include <semaphore.h>
 
 #include <sys/time.h>
@@ -94,15 +98,7 @@ typedef Eina_Lock Eina_Spinlock;
 #endif
 
 #if defined(EINA_HAVE_OSX_SEMAPHORE)
-/* OSX supports only named semaphores.
- * So, we need to be able to generate a unique string identifier for each
- * semaphore we want to create. */
-struct _Eina_Semaphore
-{
-   sem_t       *sema;
-   char         name[32];
-};
-typedef struct _Eina_Semaphore Eina_Semaphore;
+typedef semaphore_t Eina_Semaphore;
 #else
 typedef sem_t Eina_Semaphore;
 #endif
@@ -838,13 +834,10 @@ eina_semaphore_new(Eina_Semaphore *sem, int count_init)
      return EINA_FALSE;
 
 #if defined(EINA_HAVE_OSX_SEMAPHORE)
-   /* Atomic increment to generate the unique identifier */
-   snprintf(sem->name, sizeof(sem->name), "/eina%x%x%x",
-            (unsigned int)getpid(), (unsigned int)rand(), (unsigned int)rand());
-   sem->name[sizeof(sem->name) - 1] = '\0';
-   sem_unlink(sem->name);
-   sem->sema = sem_open(sem->name, O_CREAT | O_EXCL, 0600, count_init);
-   return (sem->sema == SEM_FAILED) ? EINA_FALSE : EINA_TRUE;
+   kern_return_t kr;
+
+   kr = semaphore_create(mach_task_self(), sem, SYNC_POLICY_FIFO, count_init);
+   return (kr == KERN_SUCCESS) ? EINA_TRUE : EINA_FALSE;
 #else
    return (sem_init(sem, 0, count_init) == 0) ? EINA_TRUE : EINA_FALSE;
 #endif
@@ -857,9 +850,8 @@ eina_semaphore_free(Eina_Semaphore *sem)
      return EINA_FALSE;
 
 #if defined(EINA_HAVE_OSX_SEMAPHORE)
-   const int closed = sem_close(sem->sema);
-   const int unlinked = sem_unlink(sem->name);
-   return ((closed == 0) && (unlinked == 0)) ? EINA_TRUE : EINA_FALSE;
+   return (semaphore_destroy(*sem, mach_task_self()) == KERN_SUCCESS)
+      ? EINA_TRUE : EINA_FALSE;
 #else
    return (sem_destroy(sem) == 0) ? EINA_TRUE : EINA_FALSE;
 #endif
@@ -877,7 +869,7 @@ eina_semaphore_lock(Eina_Semaphore *sem)
      {
         if (
 #if defined(EINA_HAVE_OSX_SEMAPHORE)
-            sem_wait(sem->sema)
+            semaphore_wait(*sem)
 #else
             sem_wait(sem)
 #endif
@@ -906,7 +898,7 @@ eina_semaphore_release(Eina_Semaphore *sem, int count_release EINA_UNUSED)
      return EINA_FALSE;
 
 #if defined(EINA_HAVE_OSX_SEMAPHORE)
-   return (sem_post(sem->sema) == 0) ? EINA_TRUE : EINA_FALSE;
+   return (semaphore_signal(*sem) == KERN_SUCCESS) ? EINA_TRUE : EINA_FALSE;
 #else
    return (sem_post(sem) == 0) ? EINA_TRUE : EINA_FALSE;
 #endif