osfmk/ipc/ipc_pset.c

101 	ipc_pset_t pset;
107 			      &name, (ipc_object_t *) &pset);
110 	/* pset and space are locked */
112 	pset->ips_local_name = name;
113 	ipc_mqueue_init(&pset->ips_messages, TRUE /* set */);
117 	*psetp = pset;
141 	ipc_pset_t pset;
147 				   name, (ipc_object_t *) &pset);
150 	/* pset is locked */
152 	pset->ips_local_name = name;
153 	ipc_mqueue_init(&pset->ips_messages, TRUE /* set */);
155 	*psetp = pset;
162  *		Checks to see if a port is a member of a pset
169 	ipc_pset_t	pset,
174 	return (ipc_mqueue_member(&port->ip_messages, &pset->ips_messages));
189 	ipc_pset_t	  pset,
195 	assert(ips_active(pset));
198 	kr = ipc_mqueue_add(&port->ip_messages, &pset->ips_messages, wql);
220 	ipc_pset_t	  pset,
231 	kr = ipc_mqueue_remove(&port->ip_messages, &pset->ips_messages, wqlp);
278 	ipc_pset_t	pset)
287 	assert(ips_active(pset));
289 	pset->ips_object.io_bits &= ~IO_BITS_ACTIVE;
294 	ipc_mqueue_remove_all(&pset->ips_messages, links);
301 	imq_lock(&pset->ips_messages);
302 	ipc_mqueue_changed(&pset->ips_messages);
303 	imq_unlock(&pset->ips_messages);
306 	ips_unlock(pset);
307 	ips_release(pset);       /* consume the ref our caller gave us */
339         ipc_pset_t              pset = IPS_NULL;
345                                   (ipc_object_t *)&pset);
350         /* We've got a lock on pset */
358 	result = knote_link_wait_queue(kn, &pset->ips_messages.imq_wait_queue, wql);
361 		kn->kn_ptr.p_pset = pset;
362 		ips_reference(pset);
363 		ips_unlock(pset);
367 	ips_unlock(pset);
376         ipc_pset_t              pset = kn->kn_ptr.p_pset;
383 	ips_lock(pset);
384 	(void)knote_unlink_wait_queue(kn, &pset->ips_messages.imq_wait_queue, &wql);
386 	ips_unlock(pset);
387 	ips_release(pset);
398         ipc_pset_t              pset = IPS_NULL;
414 				  (ipc_object_t *)&pset);
415 	if (kr != KERN_SUCCESS || pset != kn->kn_ptr.p_pset || !ips_active(pset)) {
418 		if (pset != IPS_NULL) {
419 			ips_unlock(pset);
425 	ips_reference(pset);
426 	ips_unlock(pset);
451 	self->ith_object = (ipc_object_t)pset;
461 			&pset->ips_messages,
475 		ips_release(pset);
488 		ips_release(pset);
500 	/* kmsg and pset reference consumed */
557         ipc_pset_t              pset = kn->kn_ptr.p_pset;
558 	ipc_mqueue_t		set_mq = &pset->ips_messages;