Lines Matching defs:pset
99 ipc_pset_t pset;
105 &name, (ipc_object_t *) &pset);
108 /* pset is locked */
110 pset->ips_local_name = name;
111 ipc_mqueue_init(&pset->ips_messages, TRUE /* set */);
114 *psetp = pset;
138 ipc_pset_t pset;
144 name, (ipc_object_t *) &pset);
147 /* pset is locked */
149 pset->ips_local_name = name;
150 ipc_mqueue_init(&pset->ips_messages, TRUE /* set */);
152 *psetp = pset;
159 * Checks to see if a port is a member of a pset
166 ipc_pset_t pset,
171 return (ipc_mqueue_member(&port->ip_messages, &pset->ips_messages));
186 ipc_pset_t pset,
191 assert(ips_active(pset));
194 kr = ipc_mqueue_add(&port->ip_messages, &pset->ips_messages);
216 ipc_pset_t pset,
226 kr = ipc_mqueue_remove(&port->ip_messages, &pset->ips_messages);
272 ipc_pset_t pset)
276 assert(ips_active(pset));
278 pset->ips_object.io_bits &= ~IO_BITS_ACTIVE;
283 ipc_mqueue_remove_all(&pset->ips_messages);
286 imq_lock(&pset->ips_messages);
287 ipc_mqueue_changed(&pset->ips_messages);
288 imq_unlock(&pset->ips_messages);
293 ips_release(pset); /* consume the ref our caller gave us */
294 ips_check_unlock(pset);
330 ipc_pset_t pset)
332 printf("pset 0x%x\n", pset);
336 ipc_object_print(&pset->ips_object);
337 iprintf("local_name = 0x%x\n", pset->ips_local_name);
339 ipc_list_count(pset->ips_messages.imq_messages.ikmq_base),
340 pset->ips_messages.imq_messages.ikmq_base);
341 printf(",rcvrs queue= 0x%x\n", &pset->ips_messages.imq_wait_queue);