osfmk/ipc/ipc_pset.c

320 static int      filt_machportattach(struct knote *kn);
321 static void	filt_machportdetach(struct knote *kn);
322 static int	filt_machport(struct knote *kn, long hint);
323 static void     filt_machporttouch(struct knote *kn, struct kevent64_s *kev, long type);
324 static unsigned filt_machportpeek(struct knote *kn);
335         struct knote *kn)
337         mach_port_name_t        name = (mach_port_name_t)kn->kn_kevent.ident;
358 	result = knote_link_wait_queue(kn, &pset->ips_messages.imq_wait_queue, wql);
361 		kn->kn_ptr.p_pset = pset;
374         struct knote *kn)
376         ipc_pset_t              pset = kn->kn_ptr.p_pset;
384 	(void)knote_unlink_wait_queue(kn, &pset->ips_messages.imq_wait_queue, &wql);
385 	kn->kn_ptr.p_pset = IPS_NULL;
394         struct knote *kn,
397         mach_port_name_t        name = (mach_port_name_t)kn->kn_kevent.ident;
415 	if (kr != KERN_SUCCESS || pset != kn->kn_ptr.p_pset || !ips_active(pset)) {
416 		kn->kn_data = 0;
417 		kn->kn_flags |= (EV_EOF | EV_ONESHOT);
433 	option = kn->kn_sfflags & (MACH_RCV_MSG|MACH_RCV_LARGE|MACH_RCV_TRAILER_MASK);
435 		self->ith_msg_addr = (mach_vm_address_t) kn->kn_ext[0];
436 		size = (mach_msg_size_t)kn->kn_ext[1];
486 		kn->kn_data = self->ith_receiver_name;
496         kn->kn_data = MACH_PORT_NULL;
497 	kn->kn_ext[1] = self->ith_msize;
498 	kn->kn_fflags = mach_msg_receive_results();
504 filt_machporttouch(struct knote *kn, struct kevent64_s *kev, long type)
508                 kn->kn_sfflags = kev->fflags;
509                 kn->kn_sdata = kev->data;
512                 *kev = kn->kn_kevent;
513                 if (kn->kn_flags & EV_CLEAR) {
514 			kn->kn_data = 0;
515 			kn->kn_fflags = 0;
542 filt_machportpeek(struct knote *kn)
544         ipc_pset_t              pset = kn->kn_ptr.p_pset;