2409 static void _dispatch_mach_reply_kevent_unregister(dispatch_mach_t dm,
2411 static void _dispatch_mach_kevent_unregister(dispatch_mach_t dm);
2414 static void _dispatch_mach_msg_recv(dispatch_mach_t dm,
2417 static void _dispatch_mach_merge_kevent(dispatch_mach_t dm,
2854 			dispatch_mach_t dm = (dispatch_mach_t)dsi;  in _dispatch_mach_notify_merge()  local
2855 			_dispatch_mach_merge_kevent(dm, &kev);  in _dispatch_mach_notify_merge()
2856 			if (unreg && dm->dm_dkev) {  in _dispatch_mach_notify_merge()
2857 				_dispatch_mach_kevent_unregister(dm);  in _dispatch_mach_notify_merge()
3044 static void _dispatch_mach_msg_disconnected(dispatch_mach_t dm,
3048 static bool _dispatch_mach_reconnect_invoke(dispatch_mach_t dm,
3052 static void _dispatch_mach_push(dispatch_object_t dm, dispatch_object_t dou,
3059 	dispatch_mach_t dm;  in _dispatch_mach_create()  local
3062 	dm = _dispatch_alloc(DISPATCH_VTABLE(mach),  in _dispatch_mach_create()
3064 	_dispatch_queue_init((dispatch_queue_t)dm);  in _dispatch_mach_create()
3065 	dm->dq_label = label;  in _dispatch_mach_create()
3067 	dm->do_ref_cnt++; // the reference _dispatch_mach_cancel_invoke holds  in _dispatch_mach_create()
3068 	dm->do_ref_cnt++; // since channel is created suspended  in _dispatch_mach_create()
3069 	dm->do_suspend_cnt = DISPATCH_OBJECT_SUSPEND_INTERVAL;  in _dispatch_mach_create()
3070 	dm->do_targetq = &_dispatch_mgr_q;  in _dispatch_mach_create()
3073 	dr->dr_source_wref = _dispatch_ptr2wref(dm);  in _dispatch_mach_create()
3076 	dm->ds_refs = dr;  in _dispatch_mach_create()
3077 	dm->dm_handler_is_block = handler_is_block;  in _dispatch_mach_create()
3079 	dm->dm_refs = _dispatch_calloc(1ul,  in _dispatch_mach_create()
3081 	dm->dm_refs->dr_source_wref = _dispatch_ptr2wref(dm);  in _dispatch_mach_create()
3082 	dm->dm_refs->dm_disconnect_cnt = DISPATCH_MACH_NEVER_CONNECTED;  in _dispatch_mach_create()
3083 	TAILQ_INIT(&dm->dm_refs->dm_replies);  in _dispatch_mach_create()
3086 	dispatch_set_target_queue(dm, q);  in _dispatch_mach_create()
3087 	_dispatch_object_debug(dm, "%s", __func__);  in _dispatch_mach_create()
3088 	return dm;  in _dispatch_mach_create()
3108 _dispatch_mach_dispose(dispatch_mach_t dm)  in _dispatch_mach_dispose()  argument
3110 	_dispatch_object_debug(dm, "%s", __func__);  in _dispatch_mach_dispose()
3111 	dispatch_mach_refs_t dr = dm->ds_refs;  in _dispatch_mach_dispose()
3112 	if (dm->dm_handler_is_block && dr->dm_handler_ctxt) {  in _dispatch_mach_dispose()
3116 	free(dm->dm_refs);  in _dispatch_mach_dispose()
3117 	_dispatch_queue_destroy(dm);  in _dispatch_mach_dispose()
3121 dispatch_mach_connect(dispatch_mach_t dm, mach_port_t receive,  in dispatch_mach_connect()  argument
3124 	dispatch_mach_send_refs_t dr = dm->dm_refs;  in dispatch_mach_connect()
3134 		dm->ds_dkev = dk;  in dispatch_mach_connect()
3135 		dm->ds_pending_data_mask = dk->dk_kevent.fflags;  in dispatch_mach_connect()
3136 		_dispatch_retain(dm); // the reference the manager queue holds  in dispatch_mach_connect()
3149 	dm->ds_pending_data_mask |= DISPATCH_MACH_RECV_MESSAGE_DIRECT_ONCE;  in dispatch_mach_connect()
3154 	_dispatch_object_debug(dm, "%s", __func__);  in dispatch_mach_connect()
3155 	return dispatch_resume(dm);  in dispatch_mach_connect()
3160 _dispatch_mach_reply_kevent_unregister(dispatch_mach_t dm,  in _dispatch_mach_reply_kevent_unregister()  argument
3170 	TAILQ_REMOVE(&dm->dm_refs->dm_replies, dmr, dmr_list);  in _dispatch_mach_reply_kevent_unregister()
3173 	if (dmsgr) _dispatch_mach_push(dm, dmsgr, dmsgr->dmsg_priority);  in _dispatch_mach_reply_kevent_unregister()
3178 _dispatch_mach_reply_kevent_register(dispatch_mach_t dm, mach_port_t reply,  in _dispatch_mach_reply_kevent_register()  argument
3193 	dmr->dr_source_wref = _dispatch_ptr2wref(dm);  in _dispatch_mach_reply_kevent_register()
3208 	TAILQ_INSERT_TAIL(&dm->dm_refs->dm_replies, dmr, dmr_list);  in _dispatch_mach_reply_kevent_register()
3210 		_dispatch_mach_reply_kevent_unregister(dm, dmr, true);  in _dispatch_mach_reply_kevent_register()
3216 _dispatch_mach_kevent_unregister(dispatch_mach_t dm)  in _dispatch_mach_kevent_unregister()  argument
3218 	dispatch_kevent_t dk = dm->dm_dkev;  in _dispatch_mach_kevent_unregister()
3219 	dm->dm_dkev = NULL;  in _dispatch_mach_kevent_unregister()
3220 	TAILQ_REMOVE(&dk->dk_sources, (dispatch_source_refs_t)dm->dm_refs,  in _dispatch_mach_kevent_unregister()
3222 	dm->ds_pending_data_mask &= ~(unsigned long)  in _dispatch_mach_kevent_unregister()
3230 _dispatch_mach_kevent_register(dispatch_mach_t dm, mach_port_t send)  in _dispatch_mach_kevent_register()  argument
3242 	dm->ds_pending_data_mask |= dk->dk_kevent.fflags;  in _dispatch_mach_kevent_register()
3247 			(dispatch_source_refs_t)dm->dm_refs, dr_list);  in _dispatch_mach_kevent_register()
3248 	dm->dm_dkev = dk;  in _dispatch_mach_kevent_register()
3249 	if (do_resume && _dispatch_kevent_resume(dm->dm_dkev, flags, 0)) {  in _dispatch_mach_kevent_register()
3250 		_dispatch_mach_kevent_unregister(dm);  in _dispatch_mach_kevent_register()
3255 _dispatch_mach_push(dispatch_object_t dm, dispatch_object_t dou,  in _dispatch_mach_push()  argument
3258 	return _dispatch_queue_push(dm._dq, dou, pp);  in _dispatch_mach_push()
3297 _dispatch_mach_msg_recv(dispatch_mach_t dm, dispatch_mach_reply_refs_t dmr,  in _dispatch_mach_msg_recv()  argument
3303 	if (slowpath(dm->ds_atomic_flags & DSF_CANCELED)) {  in _dispatch_mach_msg_recv()
3316 		_dispatch_mach_reply_kevent_unregister(dm, dmr, false);  in _dispatch_mach_msg_recv()
3332 	return _dispatch_mach_push(dm, dmsg, dmsg->dmsg_priority);  in _dispatch_mach_msg_recv()
3344 _dispatch_mach_msg_disconnected(dispatch_mach_t dm, mach_port_t local_port,  in _dispatch_mach_msg_disconnected()  argument
3354 	return _dispatch_mach_push(dm, dmsg, dmsg->dmsg_priority);  in _dispatch_mach_msg_disconnected()
3386 _dispatch_mach_msg_not_sent(dispatch_mach_t dm, dispatch_object_t dou)  in _dispatch_mach_msg_not_sent()  argument
3391 	_dispatch_mach_push(dm, dmsg, dmsg->dmsg_priority);  in _dispatch_mach_msg_not_sent()
3392 	if (dmsgr) _dispatch_mach_push(dm, dmsgr, dmsgr->dmsg_priority);  in _dispatch_mach_msg_not_sent()
3397 _dispatch_mach_msg_send(dispatch_mach_t dm, dispatch_object_t dou)  in _dispatch_mach_msg_send()  argument
3399 	dispatch_mach_send_refs_t dr = dm->dm_refs;  in _dispatch_mach_msg_send()
3407 		if (dm->dm_dkev && slowpath(_dispatch_queue_get_current() !=  in _dispatch_mach_msg_send()
3413 		dr->dm_checkin = _dispatch_mach_msg_send(dm, dr->dm_checkin)._dmsg;  in _dispatch_mach_msg_send()
3430 				if (slowpath(!dm->dm_dkev)) {  in _dispatch_mach_msg_send()
3431 					_dispatch_mach_kevent_register(dm, msg->msgh_remote_port);  in _dispatch_mach_msg_send()
3433 				if (fastpath(dm->dm_dkev)) {  in _dispatch_mach_msg_send()
3434 					if (DISPATCH_MACH_KEVENT_ARMED(dm->dm_dkev)) {  in _dispatch_mach_msg_send()
3476 					"armed", (mach_port_t)dm->dm_dkev->dk_kevent.ident);  in _dispatch_mach_msg_send()
3477 			DISPATCH_MACH_KEVENT_ARMED(dm->dm_dkev) = 1;  in _dispatch_mach_msg_send()
3497 			!(dm->ds_dkev && dm->ds_dkev->dk_kevent.ident == reply)) {  in _dispatch_mach_msg_send()
3505 		_dispatch_mach_reply_kevent_register(dm, reply, dmsg);  in _dispatch_mach_msg_send()
3507 	if (slowpath(dmsg == dr->dm_checkin) && dm->dm_dkev) {  in _dispatch_mach_msg_send()
3508 		_dispatch_mach_kevent_unregister(dm);  in _dispatch_mach_msg_send()
3515 	_dispatch_mach_push(dm, dmsg, dmsg->dmsg_priority);  in _dispatch_mach_msg_send()
3516 	if (dmsgr) _dispatch_mach_push(dm, dmsgr, dmsgr->dmsg_priority);  in _dispatch_mach_msg_send()
3524 _dispatch_mach_send_push_wakeup(dispatch_mach_t dm, dispatch_object_t dou,  in _dispatch_mach_send_push_wakeup()  argument
3527 	dispatch_mach_send_refs_t dr = dm->dm_refs;  in _dispatch_mach_send_push_wakeup()
3538 		_dispatch_wakeup(dm);  in _dispatch_mach_send_push_wakeup()
3544 _dispatch_mach_send_push(dispatch_mach_t dm, dispatch_object_t dou)  in _dispatch_mach_send_push()  argument
3546 	return _dispatch_mach_send_push_wakeup(dm, dou, false);  in _dispatch_mach_send_push()
3551 _dispatch_mach_send_drain(dispatch_mach_t dm)  in _dispatch_mach_send_drain()  argument
3553 	dispatch_mach_send_refs_t dr = dm->dm_refs;  in _dispatch_mach_send_drain()
3569 					return _dispatch_mach_push(dm, dc,  in _dispatch_mach_send_drain()
3579 				if (slowpath(!_dispatch_mach_reconnect_invoke(dm, dc))) {  in _dispatch_mach_send_drain()
3586 					slowpath(dm->ds_atomic_flags & DSF_CANCELED)) {  in _dispatch_mach_send_drain()
3587 				_dispatch_mach_msg_not_sent(dm, dc);  in _dispatch_mach_send_drain()
3590 			if (slowpath(dc = _dispatch_mach_msg_send(dm, dc)._do)) {  in _dispatch_mach_send_drain()
3607 	_dispatch_wakeup(dm);  in _dispatch_mach_send_drain()
3611 _dispatch_mach_send(dispatch_mach_t dm)  in _dispatch_mach_send()  argument
3613 	dispatch_mach_send_refs_t dr = dm->dm_refs;  in _dispatch_mach_send()
3618 	_dispatch_object_debug(dm, "%s", __func__);  in _dispatch_mach_send()
3619 	_dispatch_mach_send_drain(dm);  in _dispatch_mach_send()
3624 _dispatch_mach_merge_kevent(dispatch_mach_t dm, const struct kevent64_s *ke)  in _dispatch_mach_merge_kevent()  argument
3626 	if (!(ke->fflags & dm->ds_pending_data_mask)) {  in _dispatch_mach_merge_kevent()
3629 	_dispatch_mach_send(dm);  in _dispatch_mach_merge_kevent()
3652 dispatch_mach_send(dispatch_mach_t dm, dispatch_mach_msg_t dmsg,  in dispatch_mach_send()  argument
3655 	dispatch_mach_send_refs_t dr = dm->dm_refs;  in dispatch_mach_send()
3675 			slowpath(dm->ds_atomic_flags & DSF_CANCELED) ||  in dispatch_mach_send()
3679 		return _dispatch_mach_send_push(dm, dmsg);  in dispatch_mach_send()
3681 	if (slowpath(dmsg = _dispatch_mach_msg_send(dm, dmsg)._dmsg)) {  in dispatch_mach_send()
3684 		return _dispatch_mach_send_push_wakeup(dm, dmsg, true);  in dispatch_mach_send()
3687 		return _dispatch_mach_send_drain(dm);  in dispatch_mach_send()
3690 	_dispatch_wakeup(dm);  in dispatch_mach_send()
3694 _dispatch_mach_disconnect(dispatch_mach_t dm)  in _dispatch_mach_disconnect()  argument
3696 	dispatch_mach_send_refs_t dr = dm->dm_refs;  in _dispatch_mach_disconnect()
3697 	if (dm->dm_dkev) {  in _dispatch_mach_disconnect()
3698 		_dispatch_mach_kevent_unregister(dm);  in _dispatch_mach_disconnect()
3701 		_dispatch_mach_msg_disconnected(dm, MACH_PORT_NULL, dr->dm_send);  in _dispatch_mach_disconnect()
3705 		_dispatch_mach_msg_not_sent(dm, dr->dm_checkin);  in _dispatch_mach_disconnect()
3708 	if (!TAILQ_EMPTY(&dm->dm_refs->dm_replies)) {  in _dispatch_mach_disconnect()
3710 		TAILQ_FOREACH_SAFE(dmr, &dm->dm_refs->dm_replies, dmr_list, tmp){  in _dispatch_mach_disconnect()
3711 			_dispatch_mach_reply_kevent_unregister(dm, dmr, true);  in _dispatch_mach_disconnect()
3718 _dispatch_mach_cancel(dispatch_mach_t dm)  in _dispatch_mach_cancel()  argument
3720 	dispatch_mach_send_refs_t dr = dm->dm_refs;  in _dispatch_mach_cancel()
3724 	_dispatch_object_debug(dm, "%s", __func__);  in _dispatch_mach_cancel()
3725 	_dispatch_mach_disconnect(dm);  in _dispatch_mach_cancel()
3726 	if (dm->ds_dkev) {  in _dispatch_mach_cancel()
3727 		mach_port_t local_port = (mach_port_t)dm->ds_dkev->dk_kevent.ident;  in _dispatch_mach_cancel()
3728 		_dispatch_source_kevent_unregister((dispatch_source_t)dm);  in _dispatch_mach_cancel()
3729 		_dispatch_mach_msg_disconnected(dm, local_port, MACH_PORT_NULL);  in _dispatch_mach_cancel()
3737 _dispatch_mach_reconnect_invoke(dispatch_mach_t dm, dispatch_object_t dou)  in _dispatch_mach_reconnect_invoke()  argument
3739 	if (dm->dm_dkev || !TAILQ_EMPTY(&dm->dm_refs->dm_replies)) {  in _dispatch_mach_reconnect_invoke()
3745 	_dispatch_mach_disconnect(dm);  in _dispatch_mach_reconnect_invoke()
3746 	dispatch_mach_send_refs_t dr = dm->dm_refs;  in _dispatch_mach_reconnect_invoke()
3751 	_dispatch_object_debug(dm, "%s", __func__);  in _dispatch_mach_reconnect_invoke()
3757 dispatch_mach_reconnect(dispatch_mach_t dm, mach_port_t send,  in dispatch_mach_reconnect()  argument
3760 	dispatch_mach_send_refs_t dr = dm->dm_refs;  in dispatch_mach_reconnect()
3777 	return _dispatch_mach_send_push(dm, dc);  in dispatch_mach_reconnect()
3783 _dispatch_mach_send_sync_slow(dispatch_mach_t dm)  in _dispatch_mach_send_sync_slow()  argument
3790 	_dispatch_mach_send_push(dm, &dc);  in _dispatch_mach_send_sync_slow()
3798 dispatch_mach_get_checkin_port(dispatch_mach_t dm)  in dispatch_mach_get_checkin_port()  argument
3800 	dispatch_mach_send_refs_t dr = dm->dm_refs;  in dispatch_mach_get_checkin_port()
3801 	if (slowpath(dm->ds_atomic_flags & DSF_CANCELED)) {  in dispatch_mach_get_checkin_port()
3809 _dispatch_mach_connect_invoke(dispatch_mach_t dm)  in _dispatch_mach_connect_invoke()  argument
3811 	dispatch_mach_refs_t dr = dm->ds_refs;  in _dispatch_mach_connect_invoke()
3814 	dm->dm_connect_handler_called = 1;  in _dispatch_mach_connect_invoke()
3821 	dispatch_mach_t dm = (dispatch_mach_t)_dispatch_queue_get_current();  in _dispatch_mach_msg_invoke()  local
3822 	dispatch_mach_refs_t dr = dm->ds_refs;  in _dispatch_mach_msg_invoke()
3827 	_dispatch_thread_setspecific(dispatch_queue_key, dm->do_targetq);  in _dispatch_mach_msg_invoke()
3833 	if (slowpath(!dm->dm_connect_handler_called)) {  in _dispatch_mach_msg_invoke()
3834 		_dispatch_mach_connect_invoke(dm);  in _dispatch_mach_msg_invoke()
3838 	_dispatch_thread_setspecific(dispatch_queue_key, (dispatch_queue_t)dm);  in _dispatch_mach_msg_invoke()
3847 	dispatch_mach_t dm = (dispatch_mach_t)_dispatch_queue_get_current();  in _dispatch_mach_barrier_invoke()  local
3848 	dispatch_mach_refs_t dr = dm->ds_refs;  in _dispatch_mach_barrier_invoke()
3854 	_dispatch_thread_setspecific(dispatch_queue_key, dm->do_targetq);  in _dispatch_mach_barrier_invoke()
3855 	if (slowpath(!dm->dm_connect_handler_called)) {  in _dispatch_mach_barrier_invoke()
3856 		_dispatch_mach_connect_invoke(dm);  in _dispatch_mach_barrier_invoke()
3861 	_dispatch_thread_setspecific(dispatch_queue_key, (dispatch_queue_t)dm);  in _dispatch_mach_barrier_invoke()
3863 		(void)dispatch_atomic_dec2o(dm->dm_refs, dm_sending, release);  in _dispatch_mach_barrier_invoke()
3869 dispatch_mach_send_barrier_f(dispatch_mach_t dm, void *context,  in dispatch_mach_send_barrier_f()  argument
3881 	dispatch_mach_send_refs_t dr = dm->dm_refs;  in dispatch_mach_send_barrier_f()
3884 		return _dispatch_mach_send_push(dm, dc);  in dispatch_mach_send_barrier_f()
3887 	return _dispatch_mach_push(dm, dc, dc->dc_priority);  in dispatch_mach_send_barrier_f()
3892 dispatch_mach_receive_barrier_f(dispatch_mach_t dm, void *context,  in dispatch_mach_receive_barrier_f()  argument
3904 	return _dispatch_mach_push(dm, dc, dc->dc_priority);  in dispatch_mach_receive_barrier_f()
3909 dispatch_mach_send_barrier(dispatch_mach_t dm, dispatch_block_t barrier)  in dispatch_mach_send_barrier()  argument
3911 	dispatch_mach_send_barrier_f(dm, _dispatch_Block_copy(barrier),  in dispatch_mach_send_barrier()
3917 dispatch_mach_receive_barrier(dispatch_mach_t dm, dispatch_block_t barrier)  in dispatch_mach_receive_barrier()  argument
3919 	dispatch_mach_receive_barrier_f(dm, _dispatch_Block_copy(barrier),  in dispatch_mach_receive_barrier()
3925 _dispatch_mach_cancel_invoke(dispatch_mach_t dm)  in _dispatch_mach_cancel_invoke()  argument
3927 	dispatch_mach_refs_t dr = dm->ds_refs;  in _dispatch_mach_cancel_invoke()
3928 	if (slowpath(!dm->dm_connect_handler_called)) {  in _dispatch_mach_cancel_invoke()
3929 		_dispatch_mach_connect_invoke(dm);  in _dispatch_mach_cancel_invoke()
3933 	dm->dm_cancel_handler_called = 1;  in _dispatch_mach_cancel_invoke()
3934 	_dispatch_release(dm); // the retain is done at creation time  in _dispatch_mach_cancel_invoke()
3939 dispatch_mach_cancel(dispatch_mach_t dm)  in dispatch_mach_cancel()  argument
3941 	dispatch_source_cancel((dispatch_source_t)dm);  in dispatch_mach_cancel()
3949 	dispatch_mach_t dm = dou._dm;  in _dispatch_mach_invoke2()  local
3960 	dispatch_mach_send_refs_t dr = dm->dm_refs;  in _dispatch_mach_invoke2()
3962 	if (slowpath(!dm->ds_is_installed)) {  in _dispatch_mach_invoke2()
3967 		if (dm->ds_dkev) {  in _dispatch_mach_invoke2()
3968 			_dispatch_source_kevent_register((dispatch_source_t)dm);  in _dispatch_mach_invoke2()
3970 		dm->ds_is_installed = true;  in _dispatch_mach_invoke2()
3971 		_dispatch_mach_send(dm);  in _dispatch_mach_invoke2()
3974 		if (dm->dq_items_tail) {  in _dispatch_mach_invoke2()
3975 			return dm->do_targetq;  in _dispatch_mach_invoke2()
3977 	} else if (dm->dq_items_tail) {  in _dispatch_mach_invoke2()
3979 		if (dq != dm->do_targetq) {  in _dispatch_mach_invoke2()
3980 			return dm->do_targetq;  in _dispatch_mach_invoke2()
3982 		dispatch_queue_t tq = dm->do_targetq;  in _dispatch_mach_invoke2()
3986 		if (slowpath(tq != dm->do_targetq)) {  in _dispatch_mach_invoke2()
3988 			return dm->do_targetq;  in _dispatch_mach_invoke2()
3996 				(dm->dm_dkev || !TAILQ_EMPTY(&dm->dm_refs->dm_replies)))) {  in _dispatch_mach_invoke2()
4002 		if (!(dm->dm_dkev && DISPATCH_MACH_KEVENT_ARMED(dm->dm_dkev)) ||  in _dispatch_mach_invoke2()
4003 				(dm->ds_atomic_flags & DSF_CANCELED) || dr->dm_disconnect_cnt) {  in _dispatch_mach_invoke2()
4005 			_dispatch_mach_send(dm);  in _dispatch_mach_invoke2()
4007 	} else if (dm->ds_atomic_flags & DSF_CANCELED){  in _dispatch_mach_invoke2()
4011 		if (dm->ds_dkev || dm->dm_dkev || dr->dm_send ||  in _dispatch_mach_invoke2()
4012 				!TAILQ_EMPTY(&dm->dm_refs->dm_replies)) {  in _dispatch_mach_invoke2()
4016 			if (!_dispatch_mach_cancel(dm)) {  in _dispatch_mach_invoke2()
4020 		if (!dm->dm_cancel_handler_called) {  in _dispatch_mach_invoke2()
4021 			if (dq != dm->do_targetq) {  in _dispatch_mach_invoke2()
4022 				return dm->do_targetq;  in _dispatch_mach_invoke2()
4024 			_dispatch_mach_cancel_invoke(dm);  in _dispatch_mach_invoke2()
4032 _dispatch_mach_invoke(dispatch_mach_t dm)  in _dispatch_mach_invoke()  argument
4034 	_dispatch_queue_class_invoke(dm, _dispatch_mach_invoke2);  in _dispatch_mach_invoke()
4038 _dispatch_mach_probe(dispatch_mach_t dm)  in _dispatch_mach_probe()  argument
4043 	dispatch_mach_send_refs_t dr = dm->dm_refs;  in _dispatch_mach_probe()
4045 	if (slowpath(!dm->ds_is_installed)) {  in _dispatch_mach_probe()
4048 	} else if (_dispatch_queue_class_probe(dm)) {  in _dispatch_mach_probe()
4056 			(!(dm->dm_dkev && DISPATCH_MACH_KEVENT_ARMED(dm->dm_dkev)) ||  in _dispatch_mach_probe()
4057 			(dm->ds_atomic_flags & DSF_CANCELED) || dr->dm_disconnect_cnt)) {  in _dispatch_mach_probe()
4060 	} else if (dm->ds_atomic_flags & DSF_CANCELED) {  in _dispatch_mach_probe()
4061 		if (dm->ds_dkev || dm->dm_dkev || dr->dm_send ||  in _dispatch_mach_probe()
4062 				!TAILQ_EMPTY(&dm->dm_refs->dm_replies) ||  in _dispatch_mach_probe()
4063 				!dm->dm_cancel_handler_called) {  in _dispatch_mach_probe()
4423 _dispatch_mach_debug_attr(dispatch_mach_t dm, char* buf, size_t bufsiz)  in _dispatch_mach_debug_attr()  argument
4425 	dispatch_queue_t target = dm->do_targetq;  in _dispatch_mach_debug_attr()
4430 			dm->ds_dkev ?(mach_port_t)dm->ds_dkev->dk_kevent.ident:0,  in _dispatch_mach_debug_attr()
4431 			dm->dm_refs->dm_send,  in _dispatch_mach_debug_attr()
4432 			dm->dm_dkev ?(mach_port_t)dm->dm_dkev->dk_kevent.ident:0,  in _dispatch_mach_debug_attr()
4433 			dm->dm_dkev && DISPATCH_MACH_KEVENT_ARMED(dm->dm_dkev) ?  in _dispatch_mach_debug_attr()
4434 			" (armed)" : "", dm->dm_refs->dm_checkin_port,  in _dispatch_mach_debug_attr()
4435 			dm->dm_refs->dm_checkin ? " (pending)" : "",  in _dispatch_mach_debug_attr()
4436 			dm->dm_refs->dm_sending, dm->dm_refs->dm_disconnect_cnt,  in _dispatch_mach_debug_attr()
4437 			(bool)(dm->ds_atomic_flags & DSF_CANCELED));  in _dispatch_mach_debug_attr()
4440 _dispatch_mach_debug(dispatch_mach_t dm, char* buf, size_t bufsiz)  in _dispatch_mach_debug()  argument
4444 			dm->dq_label && !dm->dm_cancel_handler_called ? dm->dq_label :  in _dispatch_mach_debug()
4445 			dx_kind(dm), dm);  in _dispatch_mach_debug()
4446 	offset += _dispatch_object_debug_attr(dm, &buf[offset], bufsiz - offset);  in _dispatch_mach_debug()
4447 	offset += _dispatch_mach_debug_attr(dm, &buf[offset], bufsiz - offset);  in _dispatch_mach_debug()