Lines Matching refs:hdr
2400 static void _dispatch_kevent_mach_msg_recv(mach_msg_header_t *hdr);
2401 static void _dispatch_kevent_mach_msg_destroy(mach_msg_header_t *hdr);
2404 mach_msg_header_t *hdr, mach_msg_size_t siz);
2408 static void _dispatch_mach_notify_source_invoke(mach_msg_header_t *hdr);
2415 dispatch_mach_reply_refs_t dmr, mach_msg_header_t *hdr,
2675 mach_msg_header_t *hdr = (mach_msg_header_t*)ke->ext[0];
2680 if (!dispatch_assume(hdr)) {
2684 return _dispatch_kevent_mach_msg_recv(hdr);
2693 hdr = malloc(siz);
2695 if (!dispatch_assume(hdr)) {
2697 hdr = _dispatch_get_mach_recv_msg_buf();
2703 kr = mach_msg(hdr, options, 0, siz, name, MACH_MSG_TIMEOUT_NONE,
2706 return _dispatch_kevent_mach_msg_recv(hdr);
2711 hdr->msgh_id, ke->ext[1]);
2720 if (!dispatch_assume(hdr)) {
2725 kr = mach_msg(hdr, options, 0, siz, _dispatch_mach_recv_portset,
2728 hdr->msgh_size <= UINT_MAX - dispatch_mach_trailer_size)) {
2732 msgsiz = hdr->msgh_size + dispatch_mach_trailer_size;
2734 void *shrink = realloc(hdr, msgsiz);
2735 if (shrink) hdr = shrink;
2737 _dispatch_kevent_mach_msg_recv(hdr);
2738 hdr = NULL;
2741 siz = hdr->msgh_size + dispatch_mach_trailer_size;
2748 hdr = reallocf(hdr, siz);
2751 if (hdr != _dispatch_get_mach_recv_msg_buf()) {
2752 free(hdr);
2762 _dispatch_kevent_mach_msg_recv(mach_msg_header_t *hdr)
2766 mach_port_t name = hdr->msgh_local_port;
2767 mach_msg_size_t siz = hdr->msgh_size + dispatch_mach_trailer_size;
2769 if (!dispatch_assume(hdr->msgh_size <= UINT_MAX -
2773 return _dispatch_kevent_mach_msg_destroy(hdr);
2778 return _dispatch_kevent_mach_msg_destroy(hdr);
2785 return _dispatch_kevent_mach_msg_destroy(hdr);
2791 return _dispatch_source_merge_mach_msg(dsi, dri, dk, hdr, siz);
2796 return _dispatch_kevent_mach_msg_destroy(hdr);
2800 _dispatch_kevent_mach_msg_destroy(mach_msg_header_t *hdr)
2802 if (hdr) {
2803 mach_msg_destroy(hdr);
2804 if (hdr != _dispatch_get_mach_recv_msg_buf()) {
2805 free(hdr);
2812 dispatch_kevent_t dk, mach_msg_header_t *hdr, mach_msg_size_t siz)
2815 _dispatch_mach_notify_source_invoke(hdr);
2816 return _dispatch_kevent_mach_msg_destroy(hdr);
2822 return _dispatch_mach_msg_recv((dispatch_mach_t)ds, dmr, hdr, siz);
2971 _dispatch_mach_notify_source_invoke(mach_msg_header_t *hdr)
2977 boolean_t success = libdispatch_internal_protocol_server(hdr, &reply.Head);
2978 if (!success && reply.RetCode == MIG_BAD_ID && hdr->msgh_id == 950) {
3298 mach_msg_header_t *hdr, mach_msg_size_t siz)
3300 _dispatch_debug_machport(hdr->msgh_remote_port);
3302 hdr->msgh_local_port, hdr->msgh_id, hdr->msgh_remote_port);
3304 return _dispatch_kevent_mach_msg_destroy(hdr);
3311 _voucher_mach_msg_clear(hdr, false); // deallocate reply message voucher
3318 voucher = voucher_create_with_mach_msg(hdr);
3322 destructor = (hdr == _dispatch_get_mach_recv_msg_buf()) ?
3325 dmsg = dispatch_mach_msg_create(hdr, siz, destructor, NULL);
3338 mach_msg_header_t *hdr = _dispatch_mach_msg_get_msg(dou._dmsg);
3339 mach_port_t remote = hdr->msgh_remote_port;
3347 mach_msg_header_t *hdr;
3350 DISPATCH_MACH_MSG_DESTRUCTOR_DEFAULT, &hdr);
3351 if (local_port) hdr->msgh_local_port = local_port;
3352 if (remote_port) hdr->msgh_remote_port = remote_port;
3363 mach_msg_header_t *hdr;
3365 DISPATCH_MACH_MSG_DESTRUCTOR_DEFAULT, &hdr);
3367 hdr->msgh_local_port = dmsg->dmsg_reply;
3374 hdr->msgh_local_port = (mach_port_t)dmr->dmr_dkev->dk_kevent.ident;
4152 mach_msg_header_t *hdr = _dispatch_mach_msg_get_msg(dmsg);
4153 if (hdr->msgh_id) {
4155 hdr->msgh_id);
4157 if (hdr->msgh_size) {
4159 hdr->msgh_size);
4161 if (hdr->msgh_bits) {
4163 MACH_MSGH_BITS_LOCAL(hdr->msgh_bits),
4164 MACH_MSGH_BITS_REMOTE(hdr->msgh_bits));
4165 if (MACH_MSGH_BITS_OTHER(hdr->msgh_bits)) {
4167 MACH_MSGH_BITS_OTHER(hdr->msgh_bits));
4171 if (hdr->msgh_local_port && hdr->msgh_remote_port) {
4173 "remote 0x%x", hdr->msgh_local_port, hdr->msgh_remote_port);
4174 } else if (hdr->msgh_local_port) {
4176 hdr->msgh_local_port);
4177 } else if (hdr->msgh_remote_port) {
4179 hdr->msgh_remote_port);