semaphore_internal.h [plain text]
#ifndef __DISPATCH_SEMAPHORE_INTERNAL__
#define __DISPATCH_SEMAPHORE_INTERNAL__
struct dispatch_queue_s;
#if USE_MACH_SEM
#define DISPATCH_OS_SEMA_FIELD(base) semaphore_t base##_port
#elif USE_POSIX_SEM
#define DISPATCH_OS_SEMA_FIELD(base) sem_t base##_sem
#elif USE_WIN32_SEM
#define DISPATCH_OS_SEMA_FIELD(base) HANDLE base##_handle
#else
#error "No supported semaphore type"
#endif
#define DISPATCH_SEMAPHORE_HEADER(cls, ns) \
DISPATCH_OBJECT_HEADER(cls); \
long volatile ns##_value; \
DISPATCH_OS_SEMA_FIELD(ns)
struct dispatch_semaphore_header_s {
DISPATCH_SEMAPHORE_HEADER(semaphore, dsema);
};
DISPATCH_CLASS_DECL(semaphore);
struct dispatch_semaphore_s {
DISPATCH_SEMAPHORE_HEADER(semaphore, dsema);
long dsema_orig;
};
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 __attribute__((__transparent_union__));
dispatch_group_t _dispatch_group_create_and_enter(void);
void _dispatch_group_dispose(dispatch_object_t dou);
size_t _dispatch_group_debug(dispatch_object_t dou, char *buf,
size_t bufsiz);
void _dispatch_semaphore_dispose(dispatch_object_t dou);
size_t _dispatch_semaphore_debug(dispatch_object_t dou, char *buf,
size_t bufsiz);
#endif