Home
last modified time | relevance | path

Searched refs:mod_queue (Results 1 – 8 of 8) sorted by relevance

/titanic_44/usr/src/cmd/fm/fmd/common/
H A Dfmd_module.c113 fmd_eventq_insert_at_head(mp->mod_queue, fmd.d_mod_event); in fmd_module_start()
134 while ((ep = fmd_eventq_delete(mp->mod_queue)) != NULL) { in fmd_module_start()
140 fmd_eventq_done(mp->mod_queue); in fmd_module_start()
146 fmd_eventq_done(mp->mod_queue); in fmd_module_start()
240 mp->mod_queue = fmd_eventq_create(mp, in fmd_module_create()
366 if (mp->mod_queue != NULL) in fmd_module_unload()
367 fmd_eventq_abort(mp->mod_queue); in fmd_module_unload()
453 if (mp->mod_queue != NULL) { in fmd_module_destroy()
454 fmd_eventq_destroy(mp->mod_queue); in fmd_module_destroy()
455 mp->mod_queue = NULL; in fmd_module_destroy()
[all …]
H A Dfmd_module.h125 struct fmd_eventq *mod_queue; /* eventq associated with module (ro) */ member
H A Dfmd_api.c523 fmd_dispq_insert(fmd.d_disp, mp->mod_queue, pap->cpa_argv[i]); in fmd_hdl_register()
619 fmd_dispq_delete(fmd.d_disp, mp->mod_queue, pap->cpa_argv[i]); in fmd_module_unregister()
643 fmd_eventq_abort(mp->mod_queue); in fmd_module_unregister()
661 fmd_dispq_insert(fmd.d_disp, mp->mod_queue, class); in fmd_hdl_subscribe()
677 fmd_dispq_delete(fmd.d_disp, mp->mod_queue, class); in fmd_hdl_unsubscribe()
681 fmd_eventq_cancel(mp->mod_queue, FMD_EVT_PROTOCOL, (void *)class); in fmd_hdl_unsubscribe()
1952 fmd_eventq_cancel(mp->mod_queue, FMD_EVT_TIMEOUT, (void *)id); in fmd_timer_remove()
H A Dfmd_dispq.c386 fmd_eventq_insert_at_time(fmd.d_self->mod_queue, ep); in fmd_dispq_dispatch_gid()
H A Dfmd.c876 dp->d_rmod->mod_queue = fmd_eventq_create(dp->d_rmod, in fmd_run()
H A Dfmd_xprt.c568 fmd_dispq_dispatch_gid(fmd.d_disp, e, class, mp->mod_queue->eq_sgid); in fmd_xprt_send_case_ro()
844 fmd_xprt_class_hash_create(&xip->xi_usub, fmd.d_rmod->mod_queue); in fmd_xprt_create()
H A Dfmd_case.c1112 fmd_eventq_insert_at_head(cip->ci_mod->mod_queue, e); in fmd_case_publish()
1900 fmd_eventq_insert_at_head(cip->ci_mod->mod_queue, e); in fmd_case_transition()
H A Dfmd_mdb.c1617 if (mdb_vread(&eq, sizeof (eq), (uintptr_t)m.mod_queue) in mq_walk_init()