libdispatch-913.30.4.tar.gz

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

diff --git a/src/data_internal.h b/src/data_internal.h
index 314efa752a0a8e57eaf186899bbed21799a06d73..19fc3d9adeb6d053650df50c6f36dc67baa95a19 100644 (file)
--- a/src/data_internal.h
+++ b/src/data_internal.h
@@ -1,5 +1,5 @@
 /*
- * Copyright (c) 2009-2011 Apple Inc. All rights reserved.
+ * Copyright (c) 2009-2012 Apple Inc. All rights reserved.
  *
  * @APPLE_APACHE_LICENSE_HEADER_START@
  *
@@ -32,27 +32,120 @@
 #include <dispatch/base.h> // for HeaderDoc
 #endif
 
-struct dispatch_data_vtable_s {
-       DISPATCH_VTABLE_HEADER(dispatch_data_s);
-};
-
-extern const struct dispatch_data_vtable_s _dispatch_data_vtable;
-
 typedef struct range_record_s {
-       void* data_object;
+       dispatch_data_t data_object;
        size_t from;
        size_t length;
 } range_record;
 
-struct dispatch_data_s {
-       DISPATCH_STRUCT_HEADER(dispatch_data_s, dispatch_data_vtable_s);
-#if DISPATCH_DATA_MOVABLE
-       unsigned int locked;
+#if OS_OBJECT_HAVE_OBJC2
+#define DISPATCH_DATA_IS_BRIDGED_TO_NSDATA 1
+#else
+#define DISPATCH_DATA_IS_BRIDGED_TO_NSDATA 0
 #endif
-       bool leaf;
+
+#if DISPATCH_DATA_IS_BRIDGED_TO_NSDATA
+DISPATCH_OBJC_CLASS_DECL(data);
+DISPATCH_OBJC_CLASS_DECL(data_empty);
+_OS_OBJECT_DECL_PROTOCOL(dispatch_data, dispatch_object);
+#define DISPATCH_DATA_CLASS DISPATCH_VTABLE(data)
+#define DISPATCH_DATA_EMPTY_CLASS DISPATCH_VTABLE(data_empty)
+#else
+DISPATCH_CLASS_DECL(data);
+#define DISPATCH_DATA_CLASS DISPATCH_VTABLE(data)
+#endif // DISPATCH_DATA_IS_BRIDGED_TO_NSDATA
+
+struct dispatch_data_s {
+#if DISPATCH_DATA_IS_BRIDGED_TO_NSDATA
+       const void *do_vtable;
+       dispatch_queue_t do_targetq;
+       void *ctxt;
+       void *finalizer;
+#else
+       DISPATCH_OBJECT_HEADER(data);
+#endif // DISPATCH_DATA_IS_BRIDGED_TO_NSDATA
+       const void *buf;
        dispatch_block_t destructor;
        size_t size, num_records;
-       range_record records[];
+       range_record records[0];
 };
 
+DISPATCH_ALWAYS_INLINE
+static inline bool
+_dispatch_data_leaf(struct dispatch_data_s *dd)
+{
+       return dd->num_records == 0;
+}
+
+/*
+ * This is about the number of records required to hold that dispatch data
+ * if it's not a leaf. Callers either want that value, or have to special
+ * case the case when the dispatch data *is* a leaf before (and that the actual
+ * embedded record count of that dispatch data is 0)
+ */
+DISPATCH_ALWAYS_INLINE
+static inline size_t
+_dispatch_data_num_records(struct dispatch_data_s *dd)
+{
+       return dd->num_records ?: 1;
+}
+
+typedef dispatch_data_t (*dispatch_transform_t)(dispatch_data_t data);
+
+struct dispatch_data_format_type_s {
+       uint64_t type;
+       uint64_t input_mask;
+       uint64_t output_mask;
+       dispatch_transform_t decode;
+       dispatch_transform_t encode;
+};
+
+void _dispatch_data_init_with_bytes(dispatch_data_t data, const void *buffer,
+               size_t size, dispatch_block_t destructor);
+void _dispatch_data_dispose(dispatch_data_t data, bool *allow_free);
+void _dispatch_data_set_target_queue(struct dispatch_data_s *dd,
+               dispatch_queue_t tq);
+size_t _dispatch_data_debug(dispatch_data_t data, char* buf, size_t bufsiz);
+const void* _dispatch_data_get_flattened_bytes(struct dispatch_data_s *dd);
+
+#if !defined(__cplusplus)
+extern const dispatch_block_t _dispatch_data_destructor_inline;
+#define DISPATCH_DATA_DESTRUCTOR_INLINE (_dispatch_data_destructor_inline)
+
+/*
+ * the out parameters are about seeing "through" trivial subranges
+ * so for something like this: dd = { subrange [ dd1, offset1 ] },
+ * this will return { dd1, offset + offset1 }
+ *
+ * If the dispatch object isn't a trivial subrange, it returns { dd, offset }
+ */
+DISPATCH_ALWAYS_INLINE
+static inline const void*
+_dispatch_data_map_direct(struct dispatch_data_s *dd, size_t offset,
+               struct dispatch_data_s **dd_out, size_t *from_out)
+{
+       const void *buffer = NULL;
+
+       dispatch_assert(dd->size);
+       if (slowpath(!_dispatch_data_leaf(dd)) &&
+                       _dispatch_data_num_records(dd) == 1) {
+               offset += dd->records[0].from;
+               dd = (struct dispatch_data_s *)dd->records[0].data_object;
+       }
+
+       if (fastpath(_dispatch_data_leaf(dd))) {
+               buffer = dd->buf + offset;
+       } else {
+               buffer = os_atomic_load((void **)&dd->buf, relaxed);
+               if (buffer) {
+                       buffer += offset;
+               }
+       }
+       if (dd_out) *dd_out = dd;
+       if (from_out) *from_out = offset;
+       return buffer;
+}
+
+#endif // !defined(__cplusplus)
+
 #endif // __DISPATCH_DATA_INTERNAL__