ct_equeue_t
OFFSETOF(ct_equeue_t, ctq_events);
OFFSETOF(ct_equeue_t, ctq_listeners);
ctfs_endpoint_open(ctfs_endpoint_t *endpt, ct_equeue_t *q, int flag)
ct_equeue_t *
ct_equeue_t *
size_t size = CTT_MAXTYPE * sizeof (ct_equeue_t *);
ct_equeue_t **qa = kmem_zalloc(size, KM_SLEEP);
ct_equeue_t *q = kmem_zalloc(sizeof (ct_equeue_t), KM_SLEEP);
cte_queue_create(ct_equeue_t *q, ct_listnum_t list, int maxinf, int dynamic)
cte_queue_destroy(ct_equeue_t *q)
kmem_free(q, sizeof (ct_equeue_t));
cte_qrele(ct_equeue_t *q, ct_listener_t *l, ct_kevent_t *e)
cte_qmove(ct_equeue_t *q, ct_listener_t *l, ct_kevent_t *e)
cte_checkcred(ct_equeue_t *q, ct_kevent_t *e, const cred_t *cr)
cte_qreadable(ct_equeue_t *q, ct_listener_t *l, const cred_t *cr,
static void cte_queue_create(ct_equeue_t *, ct_listnum_t, int, int);
static void cte_queue_destroy(ct_equeue_t *);
static void cte_queue_drain(ct_equeue_t *, int);
cte_qwakeup(ct_equeue_t *q, ct_kevent_t *e)
static void cte_trim(ct_equeue_t *, contract_t *);
static void cte_copy(ct_equeue_t *, ct_equeue_t *);
cte_copy(ct_equeue_t *q, ct_equeue_t *newq)
cte_trim(ct_equeue_t *q, contract_t *ct)
cte_queue_drain(ct_equeue_t *q, int ack)
cte_publish(ct_equeue_t *q, ct_kevent_t *e, timespec_t *tsp, boolean_t mayexist)
ct_equeue_t *q;
cte_add_listener(ct_equeue_t *q, ct_listener_t *l)
ct_equeue_t *q = l->ctl_equeue;
ct_equeue_t *q = l->ctl_equeue;
ct_equeue_t *q = l->ctl_equeue;
ct_equeue_t *q = l->ctl_equeue;
ct_equeue_t *q = l->ctl_equeue;
ct_equeue_t *q = NULL;
ct_equeue_t *q;
kmem_free(p->p_ct_equeue, CTT_MAXTYPE * sizeof (ct_equeue_t *));
ct_equeue_t ct_type_events; /* bundle queue */
ct_equeue_t ct_events; /* contract event queue */
ct_equeue_t *ctl_equeue; /* queue */
void cte_add_listener(ct_equeue_t *, ct_listener_t *);
ct_equeue_t *contract_type_bundle(ct_type_t *);
ct_equeue_t *contract_type_pbundle(ct_type_t *, struct proc *);
ct_equeue_t *ctfs_bu_queue; /* queue we're watching */