Lines Matching refs:rip
713 restarter_inst_t *rip; in restarter_delete_inst() local
728 rip = uu_list_find(instance_list.ril_instance_list, &id, NULL, NULL); in restarter_delete_inst()
729 if (rip == NULL) { in restarter_delete_inst()
734 assert(ri == rip); in restarter_delete_inst()
1245 restarter_inst_t *rip; in stop_instance_fmri() local
1248 rip = inst_lookup_by_name(fmri); in stop_instance_fmri()
1249 if (rip == NULL) in stop_instance_fmri()
1252 r = stop_instance(h, rip, flags); in stop_instance_fmri()
1254 MUTEX_UNLOCK(&rip->ri_lock); in stop_instance_fmri()
1260 unmaintain_instance(scf_handle_t *h, restarter_inst_t *rip, in unmaintain_instance() argument
1270 assert(MUTEX_HELD(&rip->ri_lock)); in unmaintain_instance()
1272 if (rip->ri_i.i_state != RESTARTER_STATE_MAINT) { in unmaintain_instance()
1275 "maintenance state.\n", rip->ri_i.i_fmri); in unmaintain_instance()
1296 log_instance(rip, B_TRUE, "Leaving maintenance because %s.", in unmaintain_instance()
1299 "%s.\n", rip->ri_i.i_fmri, cp); in unmaintain_instance()
1301 (void) restarter_instance_update_states(h, rip, RESTARTER_STATE_UNINIT, in unmaintain_instance()
1308 if (rip->ri_i.i_primary_ctid == 0) in unmaintain_instance()
1311 ctid = rip->ri_i.i_primary_ctid; in unmaintain_instance()
1313 rip->ri_i.i_primary_ctid = 0; in unmaintain_instance()
1316 switch (r = libscf_fmri_get_instance(h, rip->ri_i.i_fmri, &inst)) { in unmaintain_instance()
1364 rip->ri_i.i_fmri, strerror(r)); in unmaintain_instance()
1561 event_from_tty(scf_handle_t *h, restarter_inst_t *rip) in event_from_tty() argument
1566 if (libscf_fmri_get_instance(h, rip->ri_i.i_fmri, &inst)) in event_from_tty()
1576 restart_dump(scf_handle_t *h, restarter_inst_t *rip) in restart_dump() argument
1581 if (libscf_fmri_get_instance(h, rip->ri_i.i_fmri, &inst)) in restart_dump()
1592 maintain_instance(scf_handle_t *h, restarter_inst_t *rip, int immediate, in maintain_instance() argument
1598 assert(MUTEX_HELD(&rip->ri_lock)); in maintain_instance()
1600 assert(rip->ri_method_thread == 0); in maintain_instance()
1602 log_instance(rip, B_TRUE, "Stopping for maintenance due to %s.", in maintain_instance()
1605 rip->ri_i.i_fmri, restarter_get_str_short(reason)); in maintain_instance()
1608 if (rip->ri_i.i_state == RESTARTER_STATE_MAINT) { in maintain_instance()
1611 rip->ri_i.i_fmri); in maintain_instance()
1621 libscf_fmri_get_instance(h, rip->ri_i.i_fmri, &scf_inst) == 0) { in maintain_instance()
1626 rip->ri_i.i_fmri); in maintain_instance()
1630 "failed: ", rip->ri_i.i_fmri); in maintain_instance()
1635 rip->ri_i.i_fmri); in maintain_instance()
1640 if (immediate || !instance_started(rip)) { in maintain_instance()
1641 if (rip->ri_i.i_primary_ctid != 0) { in maintain_instance()
1642 rip->ri_m_inst = safe_scf_instance_create(h); in maintain_instance()
1643 rip->ri_mi_deleted = B_FALSE; in maintain_instance()
1645 libscf_reget_instance(rip); in maintain_instance()
1646 method_remove_contract(rip, B_TRUE, B_TRUE); in maintain_instance()
1648 scf_instance_destroy(rip->ri_m_inst); in maintain_instance()
1651 (void) restarter_instance_update_states(h, rip, in maintain_instance()
1657 (void) restarter_instance_update_states(h, rip, rip->ri_i.i_state, in maintain_instance()
1660 log_transition(rip, MAINT_REQUESTED); in maintain_instance()
1663 info->sf_id = rip->ri_id; in maintain_instance()
1667 rip->ri_method_thread = startd_thread_create(method_thread, info); in maintain_instance()
1671 refresh_instance(scf_handle_t *h, restarter_inst_t *rip) in refresh_instance() argument
1678 assert(MUTEX_HELD(&rip->ri_lock)); in refresh_instance()
1680 log_instance(rip, B_TRUE, "Rereading configuration."); in refresh_instance()
1682 rip->ri_i.i_fmri); in refresh_instance()
1685 r = libscf_fmri_get_instance(h, rip->ri_i.i_fmri, &inst); in refresh_instance()
1706 r = libscf_get_startd_properties(inst, snap, &rip->ri_flags, in refresh_instance()
1707 &rip->ri_utmpx_prefix); in refresh_instance()
1711 rip->ri_i.i_fmri, service_style(rip->ri_flags)); in refresh_instance()
1729 if (instance_started(rip)) { in refresh_instance()
1731 (void) restarter_instance_update_states(h, rip, in refresh_instance()
1732 rip->ri_i.i_state, rip->ri_i.i_state, RERR_NONE, in refresh_instance()
1736 info->sf_id = rip->ri_id; in refresh_instance()
1741 assert(rip->ri_method_thread == 0); in refresh_instance()
1742 rip->ri_method_thread = in refresh_instance()
1770 restarter_inst_t *rip; in restarter_process_events() local
1779 rip = inst_lookup_queue(fmri); in restarter_process_events()
1780 if (rip == NULL) in restarter_process_events()
1785 while ((event = uu_list_first(rip->ri_queue)) != NULL) { in restarter_process_events()
1789 MUTEX_UNLOCK(&rip->ri_queue_lock); in restarter_process_events()
1909 rip = inst_lookup_queue(fmri); in restarter_process_events()
1910 if (rip == NULL) in restarter_process_events()
1914 uu_list_remove(rip->ri_queue, event); in restarter_process_events()
1918 assert(rip != NULL); in restarter_process_events()
1925 (void) pthread_cond_reltimedwait_np(&rip->ri_queue_cv, in restarter_process_events()
1926 &rip->ri_queue_lock, &to); in restarter_process_events()
1928 if (uu_list_first(rip->ri_queue) != NULL) in restarter_process_events()
1931 rip->ri_queue_thread = 0; in restarter_process_events()
1932 MUTEX_UNLOCK(&rip->ri_queue_lock); in restarter_process_events()
2007 restarter_inst_t *rip; in restarter_event_thread() local
2037 rip = inst_lookup_queue(e->rpe_inst); in restarter_event_thread()
2038 if (rip == NULL) { in restarter_event_thread()
2048 uu_list_numnodes(rip->ri_queue) > in restarter_event_thread()
2050 MUTEX_UNLOCK(&rip->ri_queue_lock); in restarter_event_thread()
2051 log_instance(rip, B_TRUE, "Instance event " in restarter_event_thread()
2056 "request.\n", rip->ri_i.i_fmri); in restarter_event_thread()
2061 restarter_queue_event(rip, e); in restarter_event_thread()
2063 if (rip->ri_queue_thread == 0) { in restarter_event_thread()
2069 rip->ri_queue_thread = startd_thread_create( in restarter_event_thread()
2077 &rip->ri_queue_cv); in restarter_event_thread()
2080 MUTEX_UNLOCK(&rip->ri_queue_lock); in restarter_event_thread()