libdispatch-913.30.4.tar.gz

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

diff --git a/src/introspection_internal.h b/src/introspection_internal.h
index 7b015aa0e07a2c8a1908b74b50ba983da381ab8b..e2fa6d18b8136e2af5c7e78a409da487221c522e 100644 (file)
--- a/src/introspection_internal.h
+++ b/src/introspection_internal.h
@@ -29,10 +29,28 @@
 
 #if DISPATCH_INTROSPECTION
 
-#define DISPATCH_INTROSPECTION_QUEUE_LIST \
-               TAILQ_ENTRY(dispatch_queue_s) diq_list
-#define DISPATCH_INTROSPECTION_QUEUE_LIST_SIZE \
-               sizeof(TAILQ_ENTRY(dispatch_queue_s))
+#define DISPATCH_INTROSPECTION_QUEUE_HEADER \
+               TAILQ_ENTRY(dispatch_queue_s) diq_list; \
+               dispatch_unfair_lock_s diq_order_top_head_lock; \
+               dispatch_unfair_lock_s diq_order_bottom_head_lock; \
+               TAILQ_HEAD(, dispatch_queue_order_entry_s) diq_order_top_head; \
+               TAILQ_HEAD(, dispatch_queue_order_entry_s) diq_order_bottom_head
+#define DISPATCH_INTROSPECTION_QUEUE_HEADER_SIZE \
+               sizeof(struct { DISPATCH_INTROSPECTION_QUEUE_HEADER; })
+
+struct dispatch_introspection_state_s {
+       TAILQ_HEAD(, dispatch_introspection_thread_s) threads;
+       TAILQ_HEAD(, dispatch_queue_s) queues;
+       dispatch_unfair_lock_s threads_lock;
+       dispatch_unfair_lock_s queues_lock;
+
+       ptrdiff_t thread_queue_offset;
+
+       // dispatch introspection features
+       bool debug_queue_inversions; // DISPATCH_DEBUG_QUEUE_INVERSIONS
+};
+
+extern struct dispatch_introspection_state_s _dispatch_introspection;
 
 void _dispatch_introspection_init(void);
 void _dispatch_introspection_thread_add(void);
@@ -46,7 +64,9 @@ void _dispatch_introspection_queue_item_complete(dispatch_object_t dou);
 void _dispatch_introspection_callout_entry(void *ctxt, dispatch_function_t f);
 void _dispatch_introspection_callout_return(void *ctxt, dispatch_function_t f);
 
-#if !__OBJC2__
+#if DISPATCH_PURE_C
+
+static dispatch_queue_t _dispatch_queue_get_current(void);
 
 DISPATCH_ALWAYS_INLINE
 static inline void
@@ -70,16 +90,30 @@ _dispatch_introspection_queue_pop(dispatch_queue_t dq, dispatch_object_t dou) {
        _dispatch_introspection_queue_item_dequeue(dq, dou);
 };
 
-#endif
+void
+_dispatch_introspection_order_record(dispatch_queue_t top_q,
+               dispatch_queue_t bottom_q);
+
+void
+_dispatch_introspection_target_queue_changed(dispatch_queue_t dq);
+
+DISPATCH_ALWAYS_INLINE
+static inline void
+_dispatch_introspection_sync_begin(dispatch_queue_t dq)
+{
+       if (!_dispatch_introspection.debug_queue_inversions) return;
+       _dispatch_introspection_order_record(dq, _dispatch_queue_get_current());
+}
+
+#endif // DISPATCH_PURE_C
 
-#else
+#else // DISPATCH_INTROSPECTION
 
-#define DISPATCH_INTROSPECTION_QUEUE_LIST
-#define DISPATCH_INTROSPECTION_QUEUE_LIST_SIZE 0
+#define DISPATCH_INTROSPECTION_QUEUE_HEADER
+#define DISPATCH_INTROSPECTION_QUEUE_HEADER_SIZE 0
 
 #define _dispatch_introspection_init()
 #define _dispatch_introspection_thread_add()
-#define _dispatch_introspection_thread_remove()
 
 DISPATCH_ALWAYS_INLINE
 static inline dispatch_queue_t
@@ -120,6 +154,15 @@ static inline void
 _dispatch_introspection_callout_return(void *ctxt DISPATCH_UNUSED,
                dispatch_function_t f DISPATCH_UNUSED) {}
 
+DISPATCH_ALWAYS_INLINE
+static inline void
+_dispatch_introspection_target_queue_changed(
+               dispatch_queue_t dq DISPATCH_UNUSED) {}
+
+DISPATCH_ALWAYS_INLINE
+static inline void
+_dispatch_introspection_sync_begin(dispatch_queue_t dq DISPATCH_UNUSED) {}
+
 #endif // DISPATCH_INTROSPECTION
 
 #endif // __DISPATCH_INTROSPECTION_INTERNAL__