merge darwin/darwin-006

Author: das

PATCHES

@@ -241,3 +241,29 @@ github commits starting with 29bdc2f from
 [4a6ec51] APPLIED rdar://25159995
 [bc16cc9] APPLIED rdar://25159995
 [954ace4] APPLIED rdar://25159995
+[5ea30b5] APPLIED rdar://26822213
+[9f1e778] APPLIED rdar://26822213
+[3339b81] APPLIED rdar://26822213
+[4fa8d8d] APPLIED rdar://26822213
+[e922531] APPLIED rdar://26822213
+[195cbcf] APPLIED rdar://27303844
+[5b893c8] APPLIED rdar://27303844
+[92689ed] APPLIED rdar://27303844
+[ecc14fa] APPLIED rdar://27303844
+[2dbf83c] APPLIED rdar://27303844
+[78b9e82] APPLIED rdar://27303844
+[2c0e5ee] APPLIED rdar://27303844
+[5ee237f] APPLIED rdar://27600964
+[77299ec] APPLIED rdar://27600964
+[57c5c28] APPLIED rdar://27600964
+[f8423ec] APPLIED rdar://27600964
+[325f73d] APPLIED rdar://27600964
+[b84e87e] APPLIED rdar://27600964
+[ae71a91] APPLIED rdar://27600964
+[8669dea] APPLIED rdar://27600964
+[a8d0327] APPLIED rdar://27600964
+[2e4e6af] APPLIED rdar://27600964
+[2457fb2] APPLIED rdar://27600964
+[4d58038] APPLIED rdar://27600964
+[98d0a05] APPLIED rdar://27600964
+[8976101] APPLIED rdar://27600964

config/config.h

@@ -13,6 +13,10 @@
    don't. */
 #define HAVE_DECL_FD_COPY 1
 
+/* Define to 1 if you have the declaration of `NOTE_LOWAT', and to 0 if you
+   don't. */
+#define HAVE_DECL_NOTE_LOWAT 1
+
 /* Define to 1 if you have the declaration of `NOTE_NONE', and to 0 if you
    don't. */
 #define HAVE_DECL_NOTE_NONE 1

configure.ac

@@ -353,7 +353,7 @@ AC_CHECK_FUNCS([mach_port_construct])
 #
 AC_CHECK_DECLS([CLOCK_UPTIME, CLOCK_MONOTONIC], [], [],
   [[#include <time.h>]])
-AC_CHECK_DECLS([NOTE_NONE, NOTE_REAP, NOTE_REVOKE, NOTE_SIGNAL], [], [],
+AC_CHECK_DECLS([NOTE_NONE, NOTE_REAP, NOTE_REVOKE, NOTE_SIGNAL, NOTE_LOWAT], [], [],
   [[#include <sys/event.h>]])
 AC_CHECK_DECLS([FD_COPY], [], [], [[#include <sys/select.h>]])
 AC_CHECK_DECLS([SIGEMT], [], [], [[#include <signal.h>]])

dispatch/Makefile.am

@@ -24,5 +24,5 @@ dispatch_HEADERS=	\
 	time.h
 
 if HAVE_SWIFT
-dispatch_HEADERS+=module.modulemap
+dispatch_HEADERS+=module.map
 endif

dispatch/base.h

@@ -64,6 +64,7 @@
 #define DISPATCH_MALLOC __attribute__((__malloc__))
 #define DISPATCH_ALWAYS_INLINE __attribute__((__always_inline__))
 #define DISPATCH_UNAVAILABLE __attribute__((__unavailable__))
+#define DISPATCH_UNAVAILABLE_MSG(msg) __attribute__((__unavailable__(msg)))
 #else
 /*! @parseOnly */
 #define DISPATCH_NORETURN
@@ -99,6 +100,16 @@
 #define DISPATCH_ALWAYS_INLINE
 /*! @parseOnly */
 #define DISPATCH_UNAVAILABLE
+/*! @parseOnly */
+#define DISPATCH_UNAVAILABLE_MSG(msg)
+#endif
+
+#ifdef __linux__
+#define DISPATCH_LINUX_UNAVAILABLE() \
+		DISPATCH_UNAVAILABLE_MSG( \
+		"This interface is unavailable on linux systems")
+#else
+#define DISPATCH_LINUX_UNAVAILABLE()
 #endif
 
 #ifndef DISPATCH_ALIAS_V2

dispatch/dispatch.h

@@ -24,71 +24,36 @@
 #ifdef __APPLE__
 #include <Availability.h>
 #include <TargetConditionals.h>
-#endif
-#include <sys/cdefs.h>
-#include <sys/types.h>
-#include <stddef.h>
-#include <stdint.h>
-#include <stdbool.h>
-#include <stdarg.h>
-#include <unistd.h>
-#include <fcntl.h>
-
-#ifdef __has_attribute
-#if __has_attribute(unavailable)
-#define __DISPATCH_UNAVAILABLE(msg) __attribute__((__unavailable__(msg)))
-#endif
-#endif
-#ifndef __DISPATCH_UNAVAILABLE
-#define __DISPATCH_UNAVAILABLE(msg)
-#endif
-
-#ifdef __linux__
-#if __has_feature(modules)
-#include <stdio.h> // for off_t (to match Glibc.modulemap)
-#endif
-#define DISPATCH_LINUX_UNAVAILABLE() \
-		__DISPATCH_UNAVAILABLE("This interface is unavailable on linux systems")
 #else
-#define DISPATCH_LINUX_UNAVAILABLE()
-#endif
-
-#ifndef __OSX_AVAILABLE_STARTING
 #define __OSX_AVAILABLE_STARTING(x, y)
-#endif
-#ifndef __OSX_AVAILABLE_BUT_DEPRECATED
 #define __OSX_AVAILABLE_BUT_DEPRECATED(...)
-#endif
-#ifndef __OSX_AVAILABLE_BUT_DEPRECATED_MSG
 #define __OSX_AVAILABLE_BUT_DEPRECATED_MSG(...)
-#endif
-
-#ifndef __OSX_AVAILABLE
 #define __OSX_AVAILABLE(...)
-#endif
-#ifndef __IOS_AVAILABLE
 #define __IOS_AVAILABLE(...)
-#endif
-#ifndef __TVOS_AVAILABLE
 #define __TVOS_AVAILABLE(...)
-#endif
-#ifndef __WATCHOS_AVAILABLE
 #define __WATCHOS_AVAILABLE(...)
-#endif
-#ifndef __OSX_DEPRECATED
 #define __OSX_DEPRECATED(...)
-#endif
-#ifndef __IOS_DEPRECATED
 #define __IOS_DEPRECATED(...)
-#endif
-#ifndef __TVOS_DEPRECATED
 #define __TVOS_DEPRECATED(...)
-#endif
-#ifndef __WATCHOS_DEPRECATED
 #define __WATCHOS_DEPRECATED(...)
+#endif // __APPLE__
+
+#include <sys/cdefs.h>
+#include <sys/types.h>
+#include <stddef.h>
+#include <stdint.h>
+#include <stdbool.h>
+#include <stdarg.h>
+#include <unistd.h>
+#include <fcntl.h>
+
+#if defined(__linux__) && defined(__has_feature)
+#if __has_feature(modules)
+#include <stdio.h> // for off_t (to match Glibc.modulemap)
+#endif
 #endif
 
-#define DISPATCH_API_VERSION 20160612
+#define DISPATCH_API_VERSION 20160712
 
 #ifndef __DISPATCH_BUILDING_DISPATCH__
 

dispatch/group.h

@@ -134,8 +134,7 @@ dispatch_group_async_f(dispatch_group_t group,
  * @discussion
  * This function waits for the completion of the blocks associated with the
  * given dispatch group, and returns after all blocks have completed or when
- * the specified timeout has elapsed. When a timeout occurs, the group is
- * restored to its original state.
+ * the specified timeout has elapsed.
  *
  * This function will return immediately if there are no blocks associated
  * with the dispatch group (i.e. the group is empty).
@@ -262,7 +261,7 @@ dispatch_group_enter(dispatch_group_t group);
  *
  * @discussion
  * Calling this function indicates block has completed and left the dispatch
- * groupJ by a means other than dispatch_group_async().
+ * group by a means other than dispatch_group_async().
  *
  * @param group
  * The dispatch group to update.

dispatch/module.map

@@ -0,0 +1,20 @@
+module Dispatch {
+	requires blocks
+	export *
+	link "dispatch"
+	link "BlocksRuntime"
+}
+
+module DispatchIntrospection [system] [extern_c] {
+	header "introspection.h"
+	export *
+}
+
+module CDispatch [system] [extern_c] {
+	umbrella header "dispatch.h"
+	module * { export * }
+	export *
+	requires blocks
+	link "dispatch"
+	link "BlocksRuntime"
+}

dispatch/module.modulemap

@@ -1,20 +1,10 @@
-module Dispatch {
-	requires blocks
+module Dispatch [system] [extern_c] {
+	umbrella header "dispatch.h"
+	module * { export * }
 	export *
-	link "dispatch"
-	link "BlocksRuntime"
 }
 
 module DispatchIntrospection [system] [extern_c] {
 	header "introspection.h"
 	export *
 }
-
-module CDispatch [system] [extern_c] {
-	umbrella header "dispatch.h"
-	module * { export * }
-	export *
-	requires blocks
-	link "dispatch"
-	link "BlocksRuntime"
-}

man/dispatch_source_create.3

@@ -271,8 +271,8 @@ Sources of this type allow applications to manually trigger the source's event
 handler via a call to
 .Fn dispatch_source_merge_data .
 The data will be merged with the source's pending data via an atomic add or
-logic OR (based on the source's type), and the event handler block will be
-submitted to the source's target queue. The
+atomic bitwise OR (based on the source's type), and the event handler block will
+be submitted to the source's target queue. The
 .Fa data
 is application defined. These sources have no
 .Fa handle
@@ -297,7 +297,8 @@ The data returned by
 .Fn dispatch_source_get_data
 indicates which of the events in the
 .Fa mask
-were observed.  Note that because this source type will request notifications on the provided port, it should not be mixed with the use of
+were observed.  Note that because this source type will request notifications on
+the provided port, it should not be mixed with the use of
 .Fn mach_port_request_notification
 on the same port.
 .Pp
@@ -314,8 +315,8 @@ on the mach port is waiting to be received.
 .Pp
 .Vt DISPATCH_SOURCE_TYPE_MEMORYPRESSURE
 .Pp
-Sources of this type monitor the system memory pressure condition for state changes.
-The
+Sources of this type monitor the system memory pressure condition for state
+changes.  The
 .Fa handle
 is unused and should be zero. The
 .Fa mask

os/firehose_buffer_private.h

@@ -69,7 +69,7 @@ typedef struct firehose_buffer_chunk_s {
 	uint8_t  fbc_data[FIREHOSE_BUFFER_CHUNK_SIZE
 			- sizeof(firehose_buffer_pos_u)
 			- sizeof(uint64_t)];
-} *firehose_buffer_chunk_t;
+} __attribute__((aligned(8))) *firehose_buffer_chunk_t;
 
 typedef struct firehose_buffer_range_s {
 	uint16_t fbr_offset; // offset from the start of the buffer

private/private.h

@@ -66,7 +66,7 @@
 #endif /* !__DISPATCH_BUILDING_DISPATCH__ */
 
 // <rdar://problem/9627726> Check that public and private dispatch headers match
-#if DISPATCH_API_VERSION != 20160612 // Keep in sync with <dispatch/dispatch.h>
+#if DISPATCH_API_VERSION != 20160712 // Keep in sync with <dispatch/dispatch.h>
 #error "Dispatch header mismatch between /usr/include and /usr/local/include"
 #endif
 
@@ -199,10 +199,17 @@ DISPATCH_EXPORT DISPATCH_NOTHROW
 dispatch_runloop_handle_t
 _dispatch_get_main_queue_handle_4CF(void);
 
+#if TARGET_OS_MAC
+__OSX_AVAILABLE_STARTING(__MAC_10_6,__IPHONE_4_0)
+DISPATCH_EXPORT DISPATCH_NOTHROW
+void
+_dispatch_main_queue_callback_4CF(mach_msg_header_t *_Null_unspecified msg);
+#else
 __OSX_AVAILABLE_STARTING(__MAC_10_6,__IPHONE_4_0)
 DISPATCH_EXPORT DISPATCH_NOTHROW
 void
 _dispatch_main_queue_callback_4CF(void *_Null_unspecified msg);
+#endif
 
 __OSX_AVAILABLE_STARTING(__MAC_10_9,__IPHONE_7_0)
 DISPATCH_EXPORT DISPATCH_MALLOC DISPATCH_RETURNS_RETAINED DISPATCH_WARN_RESULT

private/queue_private.h

@@ -227,6 +227,23 @@ dispatch_pthread_root_queue_flags_pool_size(uint8_t pool_size)
 
 #endif /* __BLOCKS__ */
 
+/*!
+ * @function dispatch_pthread_root_queue_copy_current
+ *
+ * @abstract
+ * Returns a reference to the pthread root queue object that has created the
+ * currently executing thread, or NULL if the current thread is not associated
+ * to a pthread root queue.
+ *
+ * @result
+ * A new reference to a pthread root queue object or NULL.
+ */
+__OSX_AVAILABLE(10.12) __IOS_AVAILABLE(10.0)
+__TVOS_AVAILABLE(10.0) __WATCHOS_AVAILABLE(3.0)
+DISPATCH_EXPORT DISPATCH_RETURNS_RETAINED DISPATCH_WARN_RESULT DISPATCH_NOTHROW
+dispatch_queue_t _Nullable
+dispatch_pthread_root_queue_copy_current(void);
+
 /*!
  * @constant DISPATCH_APPLY_CURRENT_ROOT_QUEUE
  * @discussion Constant to pass to the dispatch_apply() and dispatch_apply_f()

src/Makefile.am

@@ -157,7 +157,7 @@ SWIFT_GEN_FILES=	\
 	$(SWIFT_OBJ_FILES:%=%.~partial.swiftdoc) \
 	$(SWIFT_OBJ_FILES:%=%.~partial.swiftdeps)
 
-SWIFTC_FLAGS = -Xcc -fmodule-map-file=$(abs_top_srcdir)/dispatch/module.modulemap -I$(abs_top_srcdir) -Xcc -fblocks
+SWIFTC_FLAGS = -Xcc -fmodule-map-file=$(abs_top_srcdir)/dispatch/module.map -I$(abs_top_srcdir) -Xcc -fblocks
 if DISPATCH_ENABLE_OPTIMIZATION
 SWIFTC_FLAGS+=-O
 endif

src/apply.c

@@ -87,6 +87,9 @@ _dispatch_apply_invoke2(void *ctxt, long invoke_flags)
 		_dispatch_thread_event_destroy(&da->da_event);
 	}
 	if (os_atomic_dec2o(da, da_thr_cnt, release) == 0) {
+#if DISPATCH_INTROSPECTION
+		_dispatch_continuation_free(da->da_dc);
+#endif
 		_dispatch_continuation_free((dispatch_continuation_t)da);
 	}
 }
@@ -145,6 +148,9 @@ _dispatch_apply_serial(void *ctxt)
 		});
 	} while (++idx < iter);
 
+#if DISPATCH_INTROSPECTION
+	_dispatch_continuation_free(da->da_dc);
+#endif
 	_dispatch_continuation_free((dispatch_continuation_t)da);
 }
 
@@ -262,7 +268,12 @@ dispatch_apply_f(size_t iterations, dispatch_queue_t dq, void *ctxt,
 	da->da_iterations = iterations;
 	da->da_nested = nested;
 	da->da_thr_cnt = thr_cnt;
+#if DISPATCH_INTROSPECTION
+	da->da_dc = _dispatch_continuation_alloc();
+	*da->da_dc = dc;
+#else
 	da->da_dc = &dc;
+#endif
 	da->da_flags = 0;
 
 	if (slowpath(dq->dq_width == 1) || slowpath(thr_cnt <= 1)) {

src/data.c

@@ -108,11 +108,12 @@ const dispatch_block_t _dispatch_data_destructor_none = ^{
 	DISPATCH_INTERNAL_CRASH(0, "none destructor called");
 };
 
+#if !HAVE_MACH
 const dispatch_block_t _dispatch_data_destructor_munmap = ^{
 	DISPATCH_INTERNAL_CRASH(0, "munmap destructor called");
 };
-
-#ifndef __linux__
+#else
+// _dispatch_data_destructor_munmap is a linker alias to the following
 const dispatch_block_t _dispatch_data_destructor_vm_deallocate = ^{
 	DISPATCH_INTERNAL_CRASH(0, "vmdeallocate destructor called");
 };
@@ -253,7 +254,7 @@ dispatch_data_create_f(const void *buffer, size_t size, dispatch_queue_t queue,
 	if (destructor != DISPATCH_DATA_DESTRUCTOR_DEFAULT &&
 			destructor != DISPATCH_DATA_DESTRUCTOR_FREE &&
 			destructor != DISPATCH_DATA_DESTRUCTOR_NONE &&
-#ifndef __linux__
+#if HAVE_MACH
 			destructor != DISPATCH_DATA_DESTRUCTOR_VM_DEALLOCATE &&
 #endif
 			destructor != DISPATCH_DATA_DESTRUCTOR_INLINE) {