diff options
Diffstat (limited to 'libports/manage-one-thread.c')
-rw-r--r-- | libports/manage-one-thread.c | 20 |
1 files changed, 19 insertions, 1 deletions
diff --git a/libports/manage-one-thread.c b/libports/manage-one-thread.c index cbd2df7d..192907ac 100644 --- a/libports/manage-one-thread.c +++ b/libports/manage-one-thread.c @@ -25,6 +25,7 @@ ports_manage_port_operations_one_thread (struct port_bucket *bucket, ports_demuxer_type demuxer, int timeout) { + struct ports_thread thread; error_t err; int @@ -57,7 +58,21 @@ ports_manage_port_operations_one_thread (struct port_bucket *bucket, outp->RetCodeType = RetCodeType; outp->RetCode = MIG_BAD_ID; - pi = ports_lookup_port (bucket, inp->msgh_local_port, 0); + if (MACH_MSGH_BITS_LOCAL (inp->msgh_bits) == + MACH_MSG_TYPE_PROTECTED_PAYLOAD) + pi = ports_lookup_payload (bucket, inp->msgh_protected_payload, NULL); + else + { + pi = ports_lookup_port (bucket, inp->msgh_local_port, 0); + if (pi) + { + inp->msgh_bits = MACH_MSGH_BITS ( + MACH_MSGH_BITS_REMOTE (inp->msgh_bits), + MACH_MSG_TYPE_PROTECTED_PAYLOAD); + inp->msgh_protected_payload = (unsigned long) pi; + } + } + if (pi) { err = ports_begin_rpc (pi, inp->msgh_id, &link); @@ -83,6 +98,7 @@ ports_manage_port_operations_one_thread (struct port_bucket *bucket, status = 1; } + _ports_thread_quiescent (&bucket->threadpool, &thread); return status; } @@ -93,8 +109,10 @@ ports_manage_port_operations_one_thread (struct port_bucket *bucket, zero. */ timeout = 0; + _ports_thread_online (&bucket->threadpool, &thread); do err = mach_msg_server_timeout (internal_demuxer, 0, bucket->portset, timeout ? MACH_RCV_TIMEOUT : 0, timeout); while (err != MACH_RCV_TIMED_OUT); + _ports_thread_offline (&bucket->threadpool, &thread); } |