Lines Matching refs:th
247 thread_t th;
250 th = wait_queue_wakeup64_identity_locked(
257 if (th == THREAD_NULL)
266 if (th->ith_state != MACH_RCV_IN_PROGRESS) {
267 thread_unlock(th);
279 msize = ipc_kmsg_copyout_size(kmsg, th->map);
280 if (th->ith_msize <
281 (msize + REQUESTED_TRAILER_SIZE(thread_is_64bit(th), th->ith_option))) {
282 th->ith_state = MACH_RCV_TOO_LARGE;
283 th->ith_msize = msize;
284 if (th->ith_option & MACH_RCV_LARGE) {
288 th->ith_receiver_name = port_mqueue->imq_receiver_name;
289 th->ith_kmsg = IKM_NULL;
290 th->ith_seqno = 0;
291 thread_unlock(th);
295 th->ith_state = MACH_MSG_SUCCESS;
305 th->ith_kmsg = kmsg;
306 th->ith_seqno = port_mqueue->imq_seqno++;
307 thread_unlock(th);