Lines Matching refs:xi_queue

407 		nvl = fmd_protocol_xprt_ctl(xip->xi_queue->eq_mod,
412 fmd_eventq_insert_at_time(xip->xi_queue, e);
480 nvl = fmd_protocol_xprt_ctl(xip->xi_queue->eq_mod,
485 fmd_eventq_insert_at_time(xip->xi_queue, e);
540 fmd_dispq_dispatch_gid(fmd.d_disp, e, class, xip->xi_queue->eq_sgid);
620 nvl = fmd_protocol_xprt_sub(xip->xi_queue->eq_mod,
625 fmd_eventq_insert_at_time(xip->xi_queue, e);
831 xip->xi_queue = fmd_eventq_create(mp, &xip->xi_stats->xs_evqstat,
835 fmd_eventq_suspend(xip->xi_queue);
838 * Create our subscription hashes: local subscriptions go to xi_queue,
842 fmd_xprt_class_hash_create(&xip->xi_lsub, xip->xi_queue);
915 fmd_eventq_insert_at_time(xip->xi_queue, e);
926 fmd_module_t *mp = xip->xi_queue->eq_mod;
953 fmd_eventq_abort(xip->xi_queue);
999 fmd_eventq_destroy(xip->xi_queue);
1019 fmd_eventq_suspend(xip->xi_queue);
1042 fmd_eventq_resume(xip->xi_queue);
1052 fmd_module_t *mp = xip->xi_queue->eq_mod;
1056 while ((ep = fmd_eventq_delete(xip->xi_queue)) != NULL) {
1066 fmd_eventq_done(xip->xi_queue);
1069 fmd_eventq_insert_at_time(xip->xi_queue, ep);
1101 fmd_module_lock(xip->xi_queue->eq_mod);
1102 cp = fmd_case_create(xip->xi_queue->eq_mod, NULL, NULL);
1104 fmd_module_unlock(xip->xi_queue->eq_mod);
1191 fmd_module_unlock(xip->xi_queue->eq_mod);
1338 fmd_module_lock(xip->xi_queue->eq_mod);
1339 if ((cp = fmd_case_recreate(xip->xi_queue->eq_mod, xp,
1348 fmd_module_unlock(xip->xi_queue->eq_mod);
1443 fmd_module_unlock(xip->xi_queue->eq_mod);
1671 fmd_module_lock(xip->xi_queue->eq_mod);
1683 fmd_module_unlock(xip->xi_queue->eq_mod);
1698 fmd_module_lock(xip->xi_queue->eq_mod);
1707 fmd_module_unlock(xip->xi_queue->eq_mod);
1717 fmd_module_lock(xip->xi_queue->eq_mod);
1729 fmd_module_unlock(xip->xi_queue->eq_mod);
1772 nvl = fmd_protocol_xprt_uuclose(xip->xi_queue->eq_mod,
1777 fmd_eventq_insert_at_time(xip->xi_queue, e);
1797 nvl = fmd_protocol_xprt_uuresolved(xip->xi_queue->eq_mod,
1802 fmd_eventq_insert_at_time(xip->xi_queue, e);
1823 nvl = fmd_protocol_xprt_updated(xip->xi_queue->eq_mod,
1829 fmd_eventq_insert_at_time(xip->xi_queue, e);
1863 nvl = fmd_protocol_xprt_sub(xip->xi_queue->eq_mod,
1868 fmd_eventq_insert_at_time(xip->xi_queue, e);
1908 nvl = fmd_protocol_xprt_sub(xip->xi_queue->eq_mod,
1913 fmd_eventq_insert_at_time(xip->xi_queue, e);