Searched refs:ct_equeue_t (Results 1 – 5 of 5) sorted by relevance
180 } ct_equeue_t; typedef244 ct_equeue_t ct_type_events; /* bundle queue */289 ct_equeue_t ct_events; /* contract event queue */307 ct_equeue_t *ctl_equeue; /* queue */347 void cte_add_listener(ct_equeue_t *, ct_listener_t *);389 ct_equeue_t *contract_type_bundle(ct_type_t *);390 ct_equeue_t *contract_type_pbundle(ct_type_t *, struct proc *);
177 ct_equeue_t *ctfs_bu_queue; /* queue we're watching */
205 static void cte_copy(ct_equeue_t *, ct_equeue_t *);499 ct_equeue_t *q = NULL; in contract_abandon()601 ct_equeue_t *q; in contract_adopt()1372 ct_equeue_t *1385 ct_equeue_t *1408 ct_equeue_t *q = kmem_zalloc(sizeof (ct_equeue_t), KM_SLEEP); in contract_type_pbundle()2068 cte_copy(ct_equeue_t *q, ct_equeue_t *newq) in cte_copy()2301 ct_equeue_t *q; in cte_publish_all()2428 ct_equeue_t *q = l->ctl_equeue; in cte_remove_listener()2470 ct_equeue_t *q = l->ctl_equeue; in cte_reset_listener()[all …]
61 OFFSETOF(ct_equeue_t, ctq_events); in ct_event_walk_init()78 OFFSETOF(ct_equeue_t, ctq_listeners); in ct_listener_walk_init()
58 ctfs_endpoint_open(ctfs_endpoint_t *endpt, ct_equeue_t *q, int flag) in ctfs_endpoint_open()