X-Git-Url: https://git.saurik.com/apple/libdispatch.git/blobdiff_plain/e85f44377864e428703fb21503e29f422c11288f..refs/heads/master:/src/semaphore_internal.h diff --git a/src/semaphore_internal.h b/src/semaphore_internal.h index e5b319e..f9d0983 100644 --- 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