libdispatch-913.30.4.tar.gz

[apple/libdispatch.git] / src / semaphore_internal.h

diff --git a/src/semaphore_internal.h b/src/semaphore_internal.h
index e5b319e9143c2610ead65498693690b76b8fdb18..f9d0983aa0bed14b8eae6b99ee1dd2a8d540c3b6 100644 (file)
--- a/src/semaphore_internal.h
+++ b/src/semaphore_internal.h
@@ -1,5 +1,5 @@
 /*
- * Copyright (c) 2008-2011 Apple Inc. All rights reserved.
+ * Copyright (c) 2008-2013 Apple Inc. All rights reserved.
  *
  * @APPLE_APACHE_LICENSE_HEADER_START@
  *
@@ -27,40 +27,48 @@
 #ifndef __DISPATCH_SEMAPHORE_INTERNAL__
 #define __DISPATCH_SEMAPHORE_INTERNAL__
 
-struct dispatch_sema_notify_s {
-       struct dispatch_sema_notify_s *volatile dsn_next;
-       dispatch_queue_t dsn_queue;
-       void *dsn_ctxt;
-       void (*dsn_func)(void *);
+struct dispatch_queue_s;
+
+#define DISPATCH_SEMAPHORE_HEADER(cls, ns) \
+       DISPATCH_OBJECT_HEADER(cls); \
+       long volatile ns##_value; \
+       _dispatch_sema4_t ns##_sema
+
+struct dispatch_semaphore_header_s {
+       DISPATCH_SEMAPHORE_HEADER(semaphore, dsema);
 };
 
+DISPATCH_CLASS_DECL(semaphore);
 struct dispatch_semaphore_s {
-       DISPATCH_STRUCT_HEADER(dispatch_semaphore_s, dispatch_semaphore_vtable_s);
-       long dsema_value;
+       DISPATCH_SEMAPHORE_HEADER(semaphore, dsema);
        long dsema_orig;
-       size_t dsema_sent_ksignals;
-#if USE_MACH_SEM && USE_POSIX_SEM
-#error "Too many supported semaphore types"
-#elif USE_MACH_SEM
-       semaphore_t dsema_port;
-       semaphore_t dsema_waiter_port;
-#elif USE_POSIX_SEM
-       sem_t dsema_sem;
-#else
-#error "No supported semaphore type"
-#endif
-       size_t dsema_group_waiters;
-       struct dispatch_sema_notify_s *dsema_notify_head;
-       struct dispatch_sema_notify_s *dsema_notify_tail;
 };
 
-extern const struct dispatch_semaphore_vtable_s _dispatch_semaphore_vtable;
+DISPATCH_CLASS_DECL(group);
+struct dispatch_group_s {
+       DISPATCH_SEMAPHORE_HEADER(group, dg);
+       int volatile dg_waiters;
+       struct dispatch_continuation_s *volatile dg_notify_head;
+       struct dispatch_continuation_s *volatile dg_notify_tail;
+};
+
+typedef union {
+       struct dispatch_semaphore_header_s *_dsema_hdr;
+       struct dispatch_semaphore_s *_dsema;
+       struct dispatch_group_s *_dg;
+#if USE_OBJC
+       dispatch_semaphore_t _objc_dsema;
+       dispatch_group_t _objc_dg;
+#endif
+} dispatch_semaphore_class_t DISPATCH_TRANSPARENT_UNION;
+
+dispatch_group_t _dispatch_group_create_and_enter(void);
+void _dispatch_group_dispose(dispatch_object_t dou, bool *allow_free);
+size_t _dispatch_group_debug(dispatch_object_t dou, char *buf,
+               size_t bufsiz);
 
-typedef uintptr_t _dispatch_thread_semaphore_t;
-_dispatch_thread_semaphore_t _dispatch_get_thread_semaphore(void);
-void _dispatch_put_thread_semaphore(_dispatch_thread_semaphore_t);
-void _dispatch_thread_semaphore_wait(_dispatch_thread_semaphore_t);
-void _dispatch_thread_semaphore_signal(_dispatch_thread_semaphore_t);
-void _dispatch_thread_semaphore_dispose(_dispatch_thread_semaphore_t);
+void _dispatch_semaphore_dispose(dispatch_object_t dou, bool *allow_free);
+size_t _dispatch_semaphore_debug(dispatch_object_t dou, char *buf,
+               size_t bufsiz);
 
 #endif