lrm_state 33 daemons/controld/controld_execd.c lrm_state_t *lrm_state; lrm_state 36 daemons/controld/controld_execd.c static gboolean is_rsc_active(lrm_state_t * lrm_state, const char *rsc_id); lrm_state 37 daemons/controld/controld_execd.c static gboolean build_active_RAs(lrm_state_t * lrm_state, xmlNode * rsc_list); lrm_state 40 daemons/controld/controld_execd.c static lrmd_event_data_t *construct_op(lrm_state_t * lrm_state, xmlNode * rsc_op, lrm_state 42 daemons/controld/controld_execd.c static void do_lrm_rsc_op(lrm_state_t *lrm_state, lrmd_rsc_info_t *rsc, lrm_state 45 daemons/controld/controld_execd.c static gboolean lrm_state_verify_stopped(lrm_state_t * lrm_state, enum crmd_fsa_state cur_state, lrm_state 161 daemons/controld/controld_execd.c update_history_cache(lrm_state_t * lrm_state, lrmd_rsc_info_t * rsc, lrmd_event_data_t * op) lrm_state 168 daemons/controld/controld_execd.c controld_delete_resource_history(op->rsc_id, lrm_state->node_name, lrm_state 179 daemons/controld/controld_execd.c entry = g_hash_table_lookup(lrm_state->resource_history, op->rsc_id); lrm_state 183 daemons/controld/controld_execd.c g_hash_table_insert(lrm_state->resource_history, entry->id, entry); lrm_state 268 daemons/controld/controld_execd.c send_task_ok_ack(lrm_state_t *lrm_state, ha_msg_input_t *input, lrm_state 272 daemons/controld/controld_execd.c lrmd_event_data_t *op = construct_op(lrm_state, input->xml, rsc_id, task); lrm_state 302 daemons/controld/controld_execd.c lrm_state_t *lrm_state = lrm_state_find(op_node_name(op)); lrm_state 304 daemons/controld/controld_execd.c CRM_ASSERT(lrm_state != NULL); lrm_state 305 daemons/controld/controld_execd.c process_lrm_event(lrm_state, op, NULL, NULL); lrm_state 326 daemons/controld/controld_execd.c lrm_state_t *lrm_state = NULL; lrm_state 331 daemons/controld/controld_execd.c lrm_state = lrm_state_find_or_create(fsa_our_uname); lrm_state 332 daemons/controld/controld_execd.c if (lrm_state == NULL) { lrm_state 338 daemons/controld/controld_execd.c if (lrm_state_verify_stopped(lrm_state, cur_state, LOG_INFO) == FALSE) { lrm_state 347 daemons/controld/controld_execd.c lrm_state_disconnect(lrm_state); lrm_state 348 daemons/controld/controld_execd.c lrm_state_reset_tables(lrm_state, FALSE); lrm_state 356 daemons/controld/controld_execd.c ret = lrm_state_ipc_connect(lrm_state); lrm_state 359 daemons/controld/controld_execd.c if (lrm_state->num_lrm_register_fails < MAX_LRM_REG_FAILS) { lrm_state 361 daemons/controld/controld_execd.c lrm_state->num_lrm_register_fails, lrm_state 362 daemons/controld/controld_execd.c pcmk__plural_s(lrm_state->num_lrm_register_fails), lrm_state 373 daemons/controld/controld_execd.c lrm_state->num_lrm_register_fails, lrm_state 374 daemons/controld/controld_execd.c pcmk__plural_s(lrm_state->num_lrm_register_fails)); lrm_state 390 daemons/controld/controld_execd.c lrm_state_verify_stopped(lrm_state_t * lrm_state, enum crmd_fsa_state cur_state, int log_level) lrm_state 411 daemons/controld/controld_execd.c if (lrm_state->pending_ops && lrm_state_is_connected(lrm_state) == TRUE) { lrm_state 413 daemons/controld/controld_execd.c lrm_state->pending_ops, stop_recurring_actions, lrm_state); lrm_state 414 daemons/controld/controld_execd.c guint nremaining = g_hash_table_size(lrm_state->pending_ops); lrm_state 422 daemons/controld/controld_execd.c if (lrm_state->pending_ops) { lrm_state 423 daemons/controld/controld_execd.c g_hash_table_iter_init(&gIter, lrm_state->pending_ops); lrm_state 438 daemons/controld/controld_execd.c g_hash_table_iter_init(&gIter, lrm_state->pending_ops); lrm_state 449 daemons/controld/controld_execd.c if (lrm_state->resource_history == NULL) { lrm_state 459 daemons/controld/controld_execd.c g_hash_table_iter_init(&gIter, lrm_state->resource_history); lrm_state 461 daemons/controld/controld_execd.c if (is_rsc_active(lrm_state, entry->id) == FALSE) { lrm_state 471 daemons/controld/controld_execd.c if (lrm_state->pending_ops) { lrm_state 474 daemons/controld/controld_execd.c g_hash_table_iter_init(&hIter, lrm_state->pending_ops); lrm_state 652 daemons/controld/controld_execd.c lrm_state_t *lrm_state = NULL; lrm_state 688 daemons/controld/controld_execd.c lrm_state = lrm_state_find(node_name); lrm_state 689 daemons/controld/controld_execd.c if (lrm_state == NULL) { lrm_state 696 daemons/controld/controld_execd.c metadata = metadata_cache_get(lrm_state->metadata_cache, rsc); lrm_state 712 daemons/controld/controld_execd.c int rc = lrm_state_get_metadata(lrm_state, rsc->standard, lrm_state 722 daemons/controld/controld_execd.c metadata = metadata_cache_update(lrm_state->metadata_cache, rsc, lrm_state 744 daemons/controld/controld_execd.c is_rsc_active(lrm_state_t * lrm_state, const char *rsc_id) lrm_state 748 daemons/controld/controld_execd.c entry = g_hash_table_lookup(lrm_state->resource_history, rsc_id); lrm_state 776 daemons/controld/controld_execd.c build_active_RAs(lrm_state_t * lrm_state, xmlNode * rsc_list) lrm_state 781 daemons/controld/controld_execd.c g_hash_table_iter_init(&iter, lrm_state->resource_history); lrm_state 799 daemons/controld/controld_execd.c build_operation_update(xml_rsc, &(entry->rsc), entry->failed, lrm_state->node_name, lrm_state 801 daemons/controld/controld_execd.c build_operation_update(xml_rsc, &(entry->rsc), entry->last, lrm_state->node_name, lrm_state 804 daemons/controld/controld_execd.c build_operation_update(xml_rsc, &(entry->rsc), gIter->data, lrm_state->node_name, lrm_state 813 daemons/controld/controld_execd.c do_lrm_query_internal(lrm_state_t *lrm_state, int update_flags) lrm_state 820 daemons/controld/controld_execd.c peer = crm_get_peer_full(0, lrm_state->node_name, CRM_GET_PEER_ANY); lrm_state 834 daemons/controld/controld_execd.c build_active_RAs(lrm_state, rsc_list); lrm_state 844 daemons/controld/controld_execd.c lrm_state_t *lrm_state = lrm_state_find(node_name); lrm_state 846 daemons/controld/controld_execd.c if (!lrm_state) { lrm_state 850 daemons/controld/controld_execd.c return do_lrm_query_internal(lrm_state, lrm_state 906 daemons/controld/controld_execd.c notify_deleted(lrm_state_t * lrm_state, ha_msg_input_t * input, const char *rsc_id, int rc) lrm_state 915 daemons/controld/controld_execd.c op = construct_op(lrm_state, input->xml, rsc_id, CRMD_ACTION_DELETE); lrm_state 929 daemons/controld/controld_execd.c notify_deleted(event->lrm_state, op->input, event->rsc, event->rc); lrm_state 950 daemons/controld/controld_execd.c delete_rsc_entry(lrm_state_t * lrm_state, ha_msg_input_t * input, const char *rsc_id, lrm_state 963 daemons/controld/controld_execd.c g_hash_table_remove(lrm_state->resource_history, rsc_id_copy); lrm_state 965 daemons/controld/controld_execd.c controld_delete_resource_history(rsc_id_copy, lrm_state->node_name, lrm_state 967 daemons/controld/controld_execd.c g_hash_table_foreach_remove(lrm_state->pending_ops, lrm_remove_deleted_op, rsc_id_copy); lrm_state 972 daemons/controld/controld_execd.c notify_deleted(lrm_state, input, rsc_id, rc); lrm_state 977 daemons/controld/controld_execd.c event.lrm_state = lrm_state; lrm_state 978 daemons/controld/controld_execd.c g_hash_table_foreach_remove(lrm_state->deletion_ops, lrm_remove_deleted_rsc, &event); lrm_state 989 daemons/controld/controld_execd.c erase_lrm_history_by_op(lrm_state_t *lrm_state, lrmd_event_data_t *op) lrm_state 1048 daemons/controld/controld_execd.c erase_lrm_history_by_id(lrm_state_t *lrm_state, const char *rsc_id, lrm_state 1057 daemons/controld/controld_execd.c lrm_state->node_name, rsc_id, key, lrm_state 1062 daemons/controld/controld_execd.c lrm_state->node_name, rsc_id, key, lrm_state 1066 daemons/controld/controld_execd.c lrm_state->node_name, rsc_id, key); lrm_state 1108 daemons/controld/controld_execd.c lrm_state_t *lrm_state = NULL; lrm_state 1110 daemons/controld/controld_execd.c lrm_state = lrm_state_find(node_name); lrm_state 1111 daemons/controld/controld_execd.c if (lrm_state == NULL) { lrm_state 1120 daemons/controld/controld_execd.c erase_lrm_history_by_id(lrm_state, rsc_id, op_key, orig_op_key, 0); lrm_state 1125 daemons/controld/controld_execd.c if (lrm_state->resource_history) { lrm_state 1126 daemons/controld/controld_execd.c rsc_history_t *entry = g_hash_table_lookup(lrm_state->resource_history, lrm_state 1138 daemons/controld/controld_execd.c cancel_op(lrm_state_t * lrm_state, const char *rsc_id, const char *key, int op, gboolean remove) lrm_state 1150 daemons/controld/controld_execd.c pending = g_hash_table_lookup(lrm_state->pending_ops, key); lrm_state 1172 daemons/controld/controld_execd.c rc = lrm_state_cancel(lrm_state, pending->rsc_id, pending->op_type, lrm_state 1199 daemons/controld/controld_execd.c lrm_state_t *lrm_state; lrm_state 1211 daemons/controld/controld_execd.c remove = !cancel_op(data->lrm_state, data->rsc->id, key, op->call_id, data->remove); lrm_state 1217 daemons/controld/controld_execd.c cancel_op_key(lrm_state_t * lrm_state, lrmd_rsc_info_t * rsc, const char *key, gboolean remove) lrm_state 1229 daemons/controld/controld_execd.c data.lrm_state = lrm_state; lrm_state 1231 daemons/controld/controld_execd.c removed = g_hash_table_foreach_remove(lrm_state->pending_ops, cancel_action_by_key, &data); lrm_state 1233 daemons/controld/controld_execd.c removed, g_hash_table_size(lrm_state->pending_ops)); lrm_state 1255 daemons/controld/controld_execd.c get_lrm_resource(lrm_state_t *lrm_state, xmlNode *rsc_xml, gboolean do_create, lrm_state 1260 daemons/controld/controld_execd.c CRM_CHECK(lrm_state && rsc_xml && rsc_info, return -EINVAL); lrm_state 1263 daemons/controld/controld_execd.c if (lrm_state_is_connected(lrm_state) == FALSE) { lrm_state 1268 daemons/controld/controld_execd.c *rsc_info = lrm_state_get_rsc_info(lrm_state, id, 0); lrm_state 1275 daemons/controld/controld_execd.c *rsc_info = lrm_state_get_rsc_info(lrm_state, long_id, 0); lrm_state 1286 daemons/controld/controld_execd.c rc = lrm_state_register_rsc(lrm_state, id, class, provider, type, lrm_state 1293 daemons/controld/controld_execd.c id, lrm_state->node_name, pcmk_strerror(rc), rc); lrm_state 1299 daemons/controld/controld_execd.c if (lrm_state_is_local(lrm_state) == TRUE) { lrm_state 1305 daemons/controld/controld_execd.c *rsc_info = lrm_state_get_rsc_info(lrm_state, id, 0); lrm_state 1311 daemons/controld/controld_execd.c delete_resource(lrm_state_t * lrm_state, lrm_state 1326 daemons/controld/controld_execd.c rc = lrm_state_unregister_rsc(lrm_state, id, 0); lrm_state 1340 daemons/controld/controld_execd.c g_hash_table_insert(lrm_state->deletion_ops, ref, op); lrm_state 1349 daemons/controld/controld_execd.c delete_rsc_entry(lrm_state, request, id, gIter, rc, user); lrm_state 1353 daemons/controld/controld_execd.c get_fake_call_id(lrm_state_t *lrm_state, const char *rsc_id) lrm_state 1358 daemons/controld/controld_execd.c if(lrm_state) { lrm_state 1359 daemons/controld/controld_execd.c entry = g_hash_table_lookup(lrm_state->resource_history, rsc_id); lrm_state 1376 daemons/controld/controld_execd.c fake_op_status(lrm_state_t *lrm_state, lrmd_event_data_t *op, int op_status, lrm_state 1379 daemons/controld/controld_execd.c op->call_id = get_fake_call_id(lrm_state, op->rsc_id); lrm_state 1387 daemons/controld/controld_execd.c force_reprobe(lrm_state_t *lrm_state, const char *from_sys, lrm_state 1394 daemons/controld/controld_execd.c crm_info("Clearing resource history on node %s", lrm_state->node_name); lrm_state 1395 daemons/controld/controld_execd.c g_hash_table_iter_init(&gIter, lrm_state->resource_history); lrm_state 1412 daemons/controld/controld_execd.c delete_resource(lrm_state, entry->id, &entry->rsc, &gIter, from_sys, lrm_state 1417 daemons/controld/controld_execd.c controld_delete_node_state(lrm_state->node_name, controld_section_lrm, lrm_state 1423 daemons/controld/controld_execd.c update_attrd(lrm_state->node_name, CRM_OP_PROBED, NULL, user_name, is_remote_node); lrm_state 1440 daemons/controld/controld_execd.c synthesize_lrmd_failure(lrm_state_t *lrm_state, xmlNode *action, lrm_state 1462 daemons/controld/controld_execd.c op = construct_op(lrm_state, action, ID(xml_rsc), operation); lrm_state 1465 daemons/controld/controld_execd.c fake_op_status(lrm_state, op, PCMK_LRM_OP_DONE, PCMK_OCF_OK); lrm_state 1467 daemons/controld/controld_execd.c fake_op_status(lrm_state, op, op_status, rc); lrm_state 1474 daemons/controld/controld_execd.c process_lrm_event(lrm_state, op, NULL, action); lrm_state 1501 daemons/controld/controld_execd.c fail_lrm_resource(xmlNode *xml, lrm_state_t *lrm_state, const char *user_name, lrm_state 1518 daemons/controld/controld_execd.c op = construct_op(lrm_state, xml, ID(xml_rsc), "asyncmon"); lrm_state 1519 daemons/controld/controld_execd.c fake_op_status(lrm_state, op, PCMK_LRM_OP_DONE, PCMK_OCF_UNKNOWN_ERROR); lrm_state 1534 daemons/controld/controld_execd.c if (get_lrm_resource(lrm_state, xml_rsc, TRUE, &rsc) == pcmk_ok) { lrm_state 1537 daemons/controld/controld_execd.c process_lrm_event(lrm_state, op, NULL, xml); lrm_state 1552 daemons/controld/controld_execd.c handle_refresh_op(lrm_state_t *lrm_state, const char *user_name, lrm_state 1556 daemons/controld/controld_execd.c xmlNode *fragment = do_lrm_query_internal(lrm_state, node_update_all); lrm_state 1578 daemons/controld/controld_execd.c handle_query_op(xmlNode *msg, lrm_state_t *lrm_state) lrm_state 1580 daemons/controld/controld_execd.c xmlNode *data = do_lrm_query_internal(lrm_state, node_update_all); lrm_state 1592 daemons/controld/controld_execd.c handle_reprobe_op(lrm_state_t *lrm_state, const char *from_sys, lrm_state 1597 daemons/controld/controld_execd.c force_reprobe(lrm_state, from_sys, from_host, user_name, is_remote_node); lrm_state 1614 daemons/controld/controld_execd.c static bool do_lrm_cancel(ha_msg_input_t *input, lrm_state_t *lrm_state, lrm_state 1651 daemons/controld/controld_execd.c in_progress = cancel_op_key(lrm_state, rsc, op_key, TRUE); lrm_state 1655 daemons/controld/controld_execd.c in_progress = cancel_op(lrm_state, rsc->id, NULL, call, TRUE); lrm_state 1665 daemons/controld/controld_execd.c erase_lrm_history_by_id(lrm_state, rsc->id, op_key, NULL, call); lrm_state 1666 daemons/controld/controld_execd.c send_task_ok_ack(lrm_state, input, rsc->id, rsc, op_task, lrm_state 1670 daemons/controld/controld_execd.c g_hash_table_remove(lrm_state->pending_ops, op_id); lrm_state 1686 daemons/controld/controld_execd.c send_task_ok_ack(lrm_state, input, rsc->id, rsc, op_task, lrm_state 1696 daemons/controld/controld_execd.c do_lrm_delete(ha_msg_input_t *input, lrm_state_t *lrm_state, lrm_state 1703 daemons/controld/controld_execd.c int cib_rc = controld_delete_resource_history(rsc->id, lrm_state->node_name, lrm_state 1710 daemons/controld/controld_execd.c op = construct_op(lrm_state, input->xml, rsc->id, CRMD_ACTION_DELETE); lrm_state 1728 daemons/controld/controld_execd.c delete_resource(lrm_state, rsc->id, rsc, NULL, from_sys, lrm_state 1739 daemons/controld/controld_execd.c lrm_state_t *lrm_state = NULL; lrm_state 1754 daemons/controld/controld_execd.c lrm_state = lrm_state_find(target_node); lrm_state 1755 daemons/controld/controld_execd.c if ((lrm_state == NULL) && is_remote_node) { lrm_state 1762 daemons/controld/controld_execd.c CRM_ASSERT(lrm_state != NULL); lrm_state 1788 daemons/controld/controld_execd.c fail_lrm_resource(input->xml, lrm_state, user_name, from_host, lrm_state 1797 daemons/controld/controld_execd.c handle_refresh_op(lrm_state, user_name, from_host, from_sys); lrm_state 1800 daemons/controld/controld_execd.c handle_query_op(input->msg, lrm_state); lrm_state 1803 daemons/controld/controld_execd.c update_attrd(lrm_state->node_name, CRM_OP_PROBED, XML_BOOLEAN_TRUE, lrm_state 1808 daemons/controld/controld_execd.c handle_reprobe_op(lrm_state, from_sys, from_host, user_name, lrm_state 1821 daemons/controld/controld_execd.c rc = get_lrm_resource(lrm_state, xml_rsc, create_rsc, &rsc); lrm_state 1823 daemons/controld/controld_execd.c synthesize_lrmd_failure(lrm_state, input->xml, lrm_state 1836 daemons/controld/controld_execd.c delete_rsc_entry(lrm_state, input, ID(xml_rsc), NULL, pcmk_ok, lrm_state 1844 daemons/controld/controld_execd.c synthesize_lrmd_failure(lrm_state, input->xml, PCMK_LRM_OP_ERROR, lrm_state 1854 daemons/controld/controld_execd.c synthesize_lrmd_failure(lrm_state, input->xml, PCMK_LRM_OP_ERROR, lrm_state 1860 daemons/controld/controld_execd.c if (!do_lrm_cancel(input, lrm_state, rsc, from_host, from_sys)) { lrm_state 1865 daemons/controld/controld_execd.c do_lrm_delete(input, lrm_state, rsc, from_sys, from_host, lrm_state 1869 daemons/controld/controld_execd.c do_lrm_rsc_op(lrm_state, rsc, operation, input->xml); lrm_state 1882 daemons/controld/controld_execd.c resolve_versioned_parameters(lrm_state_t *lrm_state, const char *rsc_id, lrm_state 1887 daemons/controld/controld_execd.c lrmd_rsc_info_t *rsc = lrm_state_get_rsc_info(lrm_state, rsc_id, 0); lrm_state 1890 daemons/controld/controld_execd.c metadata = metadata_cache_get(lrm_state->metadata_cache, rsc); lrm_state 1936 daemons/controld/controld_execd.c construct_op(lrm_state_t *lrm_state, xmlNode *rsc_op, const char *rsc_id, lrm_state 2004 daemons/controld/controld_execd.c if (lrm_state && !is_remote_lrmd_ra(NULL, NULL, rsc_id) lrm_state 2007 daemons/controld/controld_execd.c resolve_versioned_parameters(lrm_state, rsc_id, rsc_op, params); lrm_state 2017 daemons/controld/controld_execd.c if (lrm_state) { lrm_state 2018 daemons/controld/controld_execd.c entry = g_hash_table_lookup(lrm_state->resource_history, rsc_id); lrm_state 2131 daemons/controld/controld_execd.c lrm_state_t *lrm_state = state_entry->data; lrm_state 2133 daemons/controld/controld_execd.c if (!lrm_state_verify_stopped(lrm_state, cur_state, log_level)) { lrm_state 2146 daemons/controld/controld_execd.c lrm_state_t *lrm_state; lrm_state 2160 daemons/controld/controld_execd.c remove = !cancel_op(event->lrm_state, event->rsc->id, key, op->call_id, FALSE); lrm_state 2170 daemons/controld/controld_execd.c lrm_state_t *lrm_state = user_data; lrm_state 2176 daemons/controld/controld_execd.c remove = !cancel_op(lrm_state, op->rsc_id, key, op->call_id, FALSE); lrm_state 2218 daemons/controld/controld_execd.c do_lrm_rsc_op(lrm_state_t *lrm_state, lrmd_rsc_info_t *rsc, lrm_state 2240 daemons/controld/controld_execd.c op = construct_op(lrm_state, msg, rsc->id, operation); lrm_state 2266 daemons/controld/controld_execd.c data.lrm_state = lrm_state; lrm_state 2268 daemons/controld/controld_execd.c lrm_state->pending_ops, stop_recurring_action_by_rsc, &data); lrm_state 2280 daemons/controld/controld_execd.c crm_action_str(op->op_type, op->interval_ms), rsc->id, lrm_state->node_name, lrm_state 2309 daemons/controld/controld_execd.c record_pending_op(lrm_state->node_name, rsc, op); lrm_state 2315 daemons/controld/controld_execd.c cancel_op_key(lrm_state, rsc, op_id, FALSE); lrm_state 2329 daemons/controld/controld_execd.c call_id = lrm_state_exec(lrm_state, rsc->id, op->op_type, op->user_data, lrm_state 2333 daemons/controld/controld_execd.c if (call_id <= 0 && lrm_state_is_local(lrm_state)) { lrm_state 2339 daemons/controld/controld_execd.c operation, rsc->id, lrm_state->node_name, call_id); lrm_state 2340 daemons/controld/controld_execd.c fake_op_status(lrm_state, op, PCMK_LRM_OP_DONE, PCMK_OCF_UNKNOWN_ERROR); lrm_state 2341 daemons/controld/controld_execd.c process_lrm_event(lrm_state, op, NULL, NULL); lrm_state 2364 daemons/controld/controld_execd.c g_hash_table_replace(lrm_state->pending_ops, call_id_s, pending); lrm_state 2577 daemons/controld/controld_execd.c did_lrm_rsc_op_fail(lrm_state_t *lrm_state, const char * rsc_id, lrm_state 2582 daemons/controld/controld_execd.c CRM_CHECK(lrm_state != NULL, return FALSE); lrm_state 2586 daemons/controld/controld_execd.c entry = g_hash_table_lookup(lrm_state->resource_history, rsc_id); lrm_state 2601 daemons/controld/controld_execd.c process_lrm_event(lrm_state_t *lrm_state, lrmd_event_data_t *op, lrm_state 2637 daemons/controld/controld_execd.c if (lrm_state) { lrm_state 2638 daemons/controld/controld_execd.c rsc = lrm_state_get_rsc_info(lrm_state, op->rsc_id, 0); lrm_state 2659 daemons/controld/controld_execd.c if (lrm_state) { lrm_state 2660 daemons/controld/controld_execd.c node_name = lrm_state->node_name; lrm_state 2667 daemons/controld/controld_execd.c if (lrm_state) { lrm_state 2668 daemons/controld/controld_execd.c pending = g_hash_table_lookup(lrm_state->pending_ops, op_id); lrm_state 2742 daemons/controld/controld_execd.c if (lrm_state) { lrm_state 2743 daemons/controld/controld_execd.c erase_lrm_history_by_op(lrm_state, op); lrm_state 2755 daemons/controld/controld_execd.c if (did_lrm_rsc_op_fail(lrm_state, pending->rsc_id, lrm_state 2784 daemons/controld/controld_execd.c } else if (lrm_state && ((op->interval_ms == 0) lrm_state 2787 daemons/controld/controld_execd.c gboolean found = g_hash_table_remove(lrm_state->pending_ops, op_id); lrm_state 2795 daemons/controld/controld_execd.c g_hash_table_size(lrm_state->pending_ops)); lrm_state 2854 daemons/controld/controld_execd.c if (lrm_state) { lrm_state 2856 daemons/controld/controld_execd.c crmd_alert_resource_op(lrm_state->node_name, op); lrm_state 2860 daemons/controld/controld_execd.c metadata_cache_update(lrm_state->metadata_cache, rsc, metadata); lrm_state 2867 daemons/controld/controld_execd.c if (lrm_state) { lrm_state 2868 daemons/controld/controld_execd.c delete_rsc_entry(lrm_state, NULL, op->rsc_id, NULL, pcmk_ok, NULL); lrm_state 2876 daemons/controld/controld_execd.c if (lrm_state && rsc) { lrm_state 2877 daemons/controld/controld_execd.c update_history_cache(lrm_state, rsc, op); lrm_state 63 daemons/controld/controld_execd_state.c lrm_state_t *lrm_state = user_data; lrm_state 68 daemons/controld/controld_execd_state.c lrm_state->node_name, (char*)key, op->user_data); lrm_state 82 daemons/controld/controld_execd_state.c event.remote_nodename = lrm_state->node_name; lrm_state 85 daemons/controld/controld_execd_state.c process_lrm_event(lrm_state, &event, op, NULL); lrm_state 90 daemons/controld/controld_execd_state.c lrm_state_is_local(lrm_state_t *lrm_state) lrm_state 92 daemons/controld/controld_execd_state.c if (lrm_state == NULL || fsa_our_uname == NULL) { lrm_state 96 daemons/controld/controld_execd_state.c if (strcmp(lrm_state->node_name, fsa_our_uname) != 0) { lrm_state 162 daemons/controld/controld_execd_state.c lrm_state_t *lrm_state = data; lrm_state 164 daemons/controld/controld_execd_state.c if (!lrm_state) { lrm_state 168 daemons/controld/controld_execd_state.c crm_trace("Destroying proxy table %s with %d members", lrm_state->node_name, g_hash_table_size(proxy_table)); lrm_state 169 daemons/controld/controld_execd_state.c g_hash_table_foreach_remove(proxy_table, remote_proxy_remove_by_node, (char *) lrm_state->node_name); lrm_state 170 daemons/controld/controld_execd_state.c remote_ra_cleanup(lrm_state); lrm_state 171 daemons/controld/controld_execd_state.c lrmd_api_delete(lrm_state->conn); lrm_state 173 daemons/controld/controld_execd_state.c if (lrm_state->rsc_info_cache) { lrm_state 174 daemons/controld/controld_execd_state.c crm_trace("Destroying rsc info cache with %d members", g_hash_table_size(lrm_state->rsc_info_cache)); lrm_state 175 daemons/controld/controld_execd_state.c g_hash_table_destroy(lrm_state->rsc_info_cache); lrm_state 177 daemons/controld/controld_execd_state.c if (lrm_state->resource_history) { lrm_state 178 daemons/controld/controld_execd_state.c crm_trace("Destroying history op cache with %d members", g_hash_table_size(lrm_state->resource_history)); lrm_state 179 daemons/controld/controld_execd_state.c g_hash_table_destroy(lrm_state->resource_history); lrm_state 181 daemons/controld/controld_execd_state.c if (lrm_state->deletion_ops) { lrm_state 182 daemons/controld/controld_execd_state.c crm_trace("Destroying deletion op cache with %d members", g_hash_table_size(lrm_state->deletion_ops)); lrm_state 183 daemons/controld/controld_execd_state.c g_hash_table_destroy(lrm_state->deletion_ops); lrm_state 185 daemons/controld/controld_execd_state.c if (lrm_state->pending_ops) { lrm_state 186 daemons/controld/controld_execd_state.c crm_trace("Destroying pending op cache with %d members", g_hash_table_size(lrm_state->pending_ops)); lrm_state 187 daemons/controld/controld_execd_state.c g_hash_table_destroy(lrm_state->pending_ops); lrm_state 189 daemons/controld/controld_execd_state.c metadata_cache_free(lrm_state->metadata_cache); lrm_state 191 daemons/controld/controld_execd_state.c free((char *)lrm_state->node_name); lrm_state 192 daemons/controld/controld_execd_state.c free(lrm_state); lrm_state 196 daemons/controld/controld_execd_state.c lrm_state_reset_tables(lrm_state_t * lrm_state, gboolean reset_metadata) lrm_state 198 daemons/controld/controld_execd_state.c if (lrm_state->resource_history) { lrm_state 200 daemons/controld/controld_execd_state.c g_hash_table_size(lrm_state->resource_history)); lrm_state 201 daemons/controld/controld_execd_state.c g_hash_table_remove_all(lrm_state->resource_history); lrm_state 203 daemons/controld/controld_execd_state.c if (lrm_state->deletion_ops) { lrm_state 205 daemons/controld/controld_execd_state.c g_hash_table_size(lrm_state->deletion_ops)); lrm_state 206 daemons/controld/controld_execd_state.c g_hash_table_remove_all(lrm_state->deletion_ops); lrm_state 208 daemons/controld/controld_execd_state.c if (lrm_state->pending_ops) { lrm_state 210 daemons/controld/controld_execd_state.c g_hash_table_size(lrm_state->pending_ops)); lrm_state 211 daemons/controld/controld_execd_state.c g_hash_table_remove_all(lrm_state->pending_ops); lrm_state 213 daemons/controld/controld_execd_state.c if (lrm_state->rsc_info_cache) { lrm_state 215 daemons/controld/controld_execd_state.c g_hash_table_size(lrm_state->rsc_info_cache)); lrm_state 216 daemons/controld/controld_execd_state.c g_hash_table_remove_all(lrm_state->rsc_info_cache); lrm_state 219 daemons/controld/controld_execd_state.c metadata_cache_reset(lrm_state->metadata_cache); lrm_state 272 daemons/controld/controld_execd_state.c lrm_state_t *lrm_state; lrm_state 274 daemons/controld/controld_execd_state.c lrm_state = g_hash_table_lookup(lrm_state_table, node_name); lrm_state 275 daemons/controld/controld_execd_state.c if (!lrm_state) { lrm_state 276 daemons/controld/controld_execd_state.c lrm_state = lrm_state_create(node_name); lrm_state 279 daemons/controld/controld_execd_state.c return lrm_state; lrm_state 328 daemons/controld/controld_execd_state.c lrm_state_disconnect_only(lrm_state_t * lrm_state) lrm_state 332 daemons/controld/controld_execd_state.c if (!lrm_state->conn) { lrm_state 335 daemons/controld/controld_execd_state.c crm_trace("Disconnecting %s", lrm_state->node_name); lrm_state 337 daemons/controld/controld_execd_state.c remote_proxy_disconnect_by_node(lrm_state->node_name); lrm_state 339 daemons/controld/controld_execd_state.c ((lrmd_t *) lrm_state->conn)->cmds->disconnect(lrm_state->conn); lrm_state 342 daemons/controld/controld_execd_state.c removed = g_hash_table_foreach_remove(lrm_state->pending_ops, fail_pending_op, lrm_state); lrm_state 343 daemons/controld/controld_execd_state.c crm_trace("Synthesized %d operation failures for %s", removed, lrm_state->node_name); lrm_state 348 daemons/controld/controld_execd_state.c lrm_state_disconnect(lrm_state_t * lrm_state) lrm_state 350 daemons/controld/controld_execd_state.c if (!lrm_state->conn) { lrm_state 354 daemons/controld/controld_execd_state.c lrm_state_disconnect_only(lrm_state); lrm_state 356 daemons/controld/controld_execd_state.c lrmd_api_delete(lrm_state->conn); lrm_state 357 daemons/controld/controld_execd_state.c lrm_state->conn = NULL; lrm_state 361 daemons/controld/controld_execd_state.c lrm_state_is_connected(lrm_state_t * lrm_state) lrm_state 363 daemons/controld/controld_execd_state.c if (!lrm_state->conn) { lrm_state 366 daemons/controld/controld_execd_state.c return ((lrmd_t *) lrm_state->conn)->cmds->is_connected(lrm_state->conn); lrm_state 370 daemons/controld/controld_execd_state.c lrm_state_poke_connection(lrm_state_t * lrm_state) lrm_state 373 daemons/controld/controld_execd_state.c if (!lrm_state->conn) { lrm_state 376 daemons/controld/controld_execd_state.c return ((lrmd_t *) lrm_state->conn)->cmds->poke_connection(lrm_state->conn); lrm_state 380 daemons/controld/controld_execd_state.c lrm_state_ipc_connect(lrm_state_t * lrm_state) lrm_state 384 daemons/controld/controld_execd_state.c if (!lrm_state->conn) { lrm_state 385 daemons/controld/controld_execd_state.c lrm_state->conn = lrmd_api_new(); lrm_state 386 daemons/controld/controld_execd_state.c ((lrmd_t *) lrm_state->conn)->cmds->set_callback(lrm_state->conn, lrm_op_callback); lrm_state 389 daemons/controld/controld_execd_state.c ret = ((lrmd_t *) lrm_state->conn)->cmds->connect(lrm_state->conn, CRM_SYSTEM_CRMD, NULL); lrm_state 392 daemons/controld/controld_execd_state.c lrm_state->num_lrm_register_fails++; lrm_state 394 daemons/controld/controld_execd_state.c lrm_state->num_lrm_register_fails = 0; lrm_state 422 daemons/controld/controld_execd_state.c lrm_state_t *lrm_state = NULL; lrm_state 428 daemons/controld/controld_execd_state.c lrm_state = lrm_state_find(proxy->node_name); lrm_state 429 daemons/controld/controld_execd_state.c if (lrm_state) { lrm_state 478 daemons/controld/controld_execd_state.c lrm_state_t *lrm_state = userdata; lrm_state 486 daemons/controld/controld_execd_state.c proxy = crmd_remote_proxy_new(lrmd, lrm_state->node_name, session, channel); lrm_state 487 daemons/controld/controld_execd_state.c if (!remote_ra_controlling_guest(lrm_state)) { lrm_state 503 daemons/controld/controld_execd_state.c lrm_state->node_name); lrm_state 505 daemons/controld/controld_execd_state.c if (!remote_ra_is_in_maintenance(lrm_state)) { lrm_state 507 daemons/controld/controld_execd_state.c update_attrd(lrm_state->node_name, XML_CIB_ATTR_SHUTDOWN, now_s, NULL, TRUE); lrm_state 513 daemons/controld/controld_execd_state.c lrm_state->node_name); lrm_state 518 daemons/controld/controld_execd_state.c lrm_state->node_name); lrm_state 531 daemons/controld/controld_execd_state.c CRM_CHECK(lrm_state->node_name, return); lrm_state 533 daemons/controld/controld_execd_state.c pcmk__update_acl_user(request, F_LRMD_IPC_USER, lrm_state->node_name); lrm_state 547 daemons/controld/controld_execd_state.c crm_xml_add(request, XML_ATTR_UNAME, lrm_state->node_name); lrm_state 568 daemons/controld/controld_execd_state.c remote_proxy_cb(lrmd, lrm_state->node_name, msg); lrm_state 574 daemons/controld/controld_execd_state.c lrm_state_remote_connect_async(lrm_state_t * lrm_state, const char *server, int port, lrm_state 579 daemons/controld/controld_execd_state.c if (!lrm_state->conn) { lrm_state 580 daemons/controld/controld_execd_state.c lrm_state->conn = lrmd_remote_api_new(lrm_state->node_name, server, port); lrm_state 581 daemons/controld/controld_execd_state.c if (!lrm_state->conn) { lrm_state 584 daemons/controld/controld_execd_state.c ((lrmd_t *) lrm_state->conn)->cmds->set_callback(lrm_state->conn, remote_lrm_op_callback); lrm_state 585 daemons/controld/controld_execd_state.c lrmd_internal_set_proxy_callback(lrm_state->conn, lrm_state, crmd_remote_proxy_cb); lrm_state 590 daemons/controld/controld_execd_state.c ((lrmd_t *) lrm_state->conn)->cmds->connect_async(lrm_state->conn, lrm_state->node_name, lrm_state 594 daemons/controld/controld_execd_state.c lrm_state->num_lrm_register_fails++; lrm_state 596 daemons/controld/controld_execd_state.c lrm_state->num_lrm_register_fails = 0; lrm_state 603 daemons/controld/controld_execd_state.c lrm_state_get_metadata(lrm_state_t * lrm_state, lrm_state 610 daemons/controld/controld_execd_state.c if (!lrm_state->conn) { lrm_state 629 daemons/controld/controld_execd_state.c lrm_state->node_name); lrm_state 631 daemons/controld/controld_execd_state.c return ((lrmd_t *) lrm_state->conn)->cmds->get_metadata_params(lrm_state->conn, lrm_state 636 daemons/controld/controld_execd_state.c lrm_state_cancel(lrm_state_t *lrm_state, const char *rsc_id, const char *action, lrm_state 639 daemons/controld/controld_execd_state.c if (!lrm_state->conn) { lrm_state 646 daemons/controld/controld_execd_state.c return remote_ra_cancel(lrm_state, rsc_id, action, interval_ms); lrm_state 648 daemons/controld/controld_execd_state.c return ((lrmd_t *) lrm_state->conn)->cmds->cancel(lrm_state->conn, rsc_id, lrm_state 653 daemons/controld/controld_execd_state.c lrm_state_get_rsc_info(lrm_state_t * lrm_state, const char *rsc_id, enum lrmd_call_options options) lrm_state 657 daemons/controld/controld_execd_state.c if (!lrm_state->conn) { lrm_state 661 daemons/controld/controld_execd_state.c return remote_ra_get_rsc_info(lrm_state, rsc_id); lrm_state 664 daemons/controld/controld_execd_state.c rsc = g_hash_table_lookup(lrm_state->rsc_info_cache, rsc_id); lrm_state 667 daemons/controld/controld_execd_state.c rsc = ((lrmd_t *) lrm_state->conn)->cmds->get_rsc_info(lrm_state->conn, rsc_id, options); lrm_state 672 daemons/controld/controld_execd_state.c g_hash_table_insert(lrm_state->rsc_info_cache, rsc->id, rsc); lrm_state 680 daemons/controld/controld_execd_state.c lrm_state_exec(lrm_state_t *lrm_state, const char *rsc_id, const char *action, lrm_state 687 daemons/controld/controld_execd_state.c if (!lrm_state->conn) { lrm_state 693 daemons/controld/controld_execd_state.c return remote_ra_exec(lrm_state, rsc_id, action, userdata, interval_ms, lrm_state 697 daemons/controld/controld_execd_state.c return ((lrmd_t *) lrm_state->conn)->cmds->exec(lrm_state->conn, lrm_state 708 daemons/controld/controld_execd_state.c lrm_state_register_rsc(lrm_state_t * lrm_state, lrm_state 713 daemons/controld/controld_execd_state.c lrmd_t *conn = (lrmd_t *) lrm_state->conn; lrm_state 726 daemons/controld/controld_execd_state.c return conn->cmds->register_rsc(lrm_state->conn, rsc_id, class, provider, lrm_state 731 daemons/controld/controld_execd_state.c lrm_state_unregister_rsc(lrm_state_t * lrm_state, lrm_state 734 daemons/controld/controld_execd_state.c if (!lrm_state->conn) { lrm_state 743 daemons/controld/controld_execd_state.c g_hash_table_remove(lrm_state->rsc_info_cache, rsc_id); lrm_state 750 daemons/controld/controld_execd_state.c return ((lrmd_t *) lrm_state->conn)->cmds->unregister_rsc(lrm_state->conn, rsc_id, options); lrm_state 769 daemons/controld/controld_execd_state.c lrm_state_t *lrm_state; lrm_state 775 daemons/controld/controld_execd_state.c lrm_state = lrm_state_find(fsa_our_uname); lrm_state 776 daemons/controld/controld_execd_state.c if (lrm_state == NULL) { lrm_state 780 daemons/controld/controld_execd_state.c lrmd_send_node_alert((lrmd_t *) lrm_state->conn, crmd_alert_list, lrm_state 788 daemons/controld/controld_execd_state.c lrm_state_t *lrm_state; lrm_state 794 daemons/controld/controld_execd_state.c lrm_state = lrm_state_find(fsa_our_uname); lrm_state 795 daemons/controld/controld_execd_state.c if (lrm_state == NULL) { lrm_state 805 daemons/controld/controld_execd_state.c lrmd_send_fencing_alert((lrmd_t *) lrm_state->conn, crmd_alert_list, lrm_state 813 daemons/controld/controld_execd_state.c lrm_state_t *lrm_state; lrm_state 819 daemons/controld/controld_execd_state.c lrm_state = lrm_state_find(fsa_our_uname); lrm_state 820 daemons/controld/controld_execd_state.c if (lrm_state == NULL) { lrm_state 824 daemons/controld/controld_execd_state.c lrmd_send_resource_alert((lrmd_t *) lrm_state->conn, crmd_alert_list, node, lrm_state 92 daemons/controld/controld_lrm.h lrm_state_is_local(lrm_state_t *lrm_state); lrm_state 99 daemons/controld/controld_lrm.h void lrm_state_reset_tables(lrm_state_t * lrm_state, gboolean reset_metadata); lrm_state 139 daemons/controld/controld_lrm.h void lrm_state_disconnect_only(lrm_state_t * lrm_state); lrm_state 140 daemons/controld/controld_lrm.h void lrm_state_disconnect(lrm_state_t * lrm_state); lrm_state 141 daemons/controld/controld_lrm.h int lrm_state_ipc_connect(lrm_state_t * lrm_state); lrm_state 142 daemons/controld/controld_lrm.h int lrm_state_remote_connect_async(lrm_state_t * lrm_state, const char *server, int port, lrm_state 144 daemons/controld/controld_lrm.h int lrm_state_is_connected(lrm_state_t * lrm_state); lrm_state 145 daemons/controld/controld_lrm.h int lrm_state_poke_connection(lrm_state_t * lrm_state); lrm_state 147 daemons/controld/controld_lrm.h int lrm_state_get_metadata(lrm_state_t * lrm_state, lrm_state 151 daemons/controld/controld_lrm.h int lrm_state_cancel(lrm_state_t *lrm_state, const char *rsc_id, lrm_state 153 daemons/controld/controld_lrm.h int lrm_state_exec(lrm_state_t *lrm_state, const char *rsc_id, lrm_state 158 daemons/controld/controld_lrm.h lrmd_rsc_info_t *lrm_state_get_rsc_info(lrm_state_t * lrm_state, lrm_state 160 daemons/controld/controld_lrm.h int lrm_state_register_rsc(lrm_state_t * lrm_state, lrm_state 164 daemons/controld/controld_lrm.h int lrm_state_unregister_rsc(lrm_state_t * lrm_state, lrm_state 170 daemons/controld/controld_lrm.h lrmd_rsc_info_t *remote_ra_get_rsc_info(lrm_state_t * lrm_state, const char *rsc_id); lrm_state 171 daemons/controld/controld_lrm.h int remote_ra_cancel(lrm_state_t *lrm_state, const char *rsc_id, lrm_state 173 daemons/controld/controld_lrm.h int remote_ra_exec(lrm_state_t *lrm_state, const char *rsc_id, lrm_state 178 daemons/controld/controld_lrm.h void remote_ra_cleanup(lrm_state_t * lrm_state); lrm_state 181 daemons/controld/controld_lrm.h gboolean remote_ra_is_in_maintenance(lrm_state_t * lrm_state); lrm_state 183 daemons/controld/controld_lrm.h gboolean remote_ra_controlling_guest(lrm_state_t * lrm_state); lrm_state 185 daemons/controld/controld_lrm.h void process_lrm_event(lrm_state_t *lrm_state, lrmd_event_data_t *op, lrm_state 88 daemons/controld/controld_remote_ra.c static int handle_remote_ra_start(lrm_state_t * lrm_state, remote_ra_cmd_t * cmd, int timeout_ms); lrm_state 89 daemons/controld/controld_remote_ra.c static void handle_remote_ra_stop(lrm_state_t * lrm_state, remote_ra_cmd_t * cmd); lrm_state 320 daemons/controld/controld_remote_ra.c lrm_state_t *lrm_state = lrm_state_find(cmd->rsc_id); lrm_state 321 daemons/controld/controld_remote_ra.c remote_ra_data_t *ra_data = lrm_state? lrm_state->remote_ra_data : NULL; lrm_state 410 daemons/controld/controld_remote_ra.c lrm_state_t *lrm_state = data; lrm_state 411 daemons/controld/controld_remote_ra.c remote_ra_data_t *ra_data = lrm_state->remote_ra_data; lrm_state 425 daemons/controld/controld_remote_ra.c rc = handle_remote_ra_start(lrm_state, cmd, cmd->remaining_timeout); lrm_state 449 daemons/controld/controld_remote_ra.c lrm_state_t *lrm_state = NULL; lrm_state 455 daemons/controld/controld_remote_ra.c lrm_state = lrm_state_find(cmd->rsc_id); lrm_state 457 daemons/controld/controld_remote_ra.c handle_remote_ra_stop(lrm_state, cmd); lrm_state 466 daemons/controld/controld_remote_ra.c lrm_state_t *lrm_state = NULL; lrm_state 469 daemons/controld/controld_remote_ra.c lrm_state = lrm_state_find(cmd->rsc_id); lrm_state 472 daemons/controld/controld_remote_ra.c cmd->rsc_id, (lrm_state? "" : " (no LRM state)")); lrm_state 477 daemons/controld/controld_remote_ra.c if (lrm_state && lrm_state->remote_ra_data) { lrm_state 478 daemons/controld/controld_remote_ra.c remote_ra_data_t *ra_data = lrm_state->remote_ra_data; lrm_state 491 daemons/controld/controld_remote_ra.c if(lrm_state) { lrm_state 492 daemons/controld/controld_remote_ra.c lrm_state_disconnect(lrm_state); lrm_state 498 daemons/controld/controld_remote_ra.c synthesize_lrmd_success(lrm_state_t *lrm_state, const char *rsc_id, const char *op_type) lrm_state 502 daemons/controld/controld_remote_ra.c if (lrm_state == NULL) { lrm_state 504 daemons/controld/controld_remote_ra.c lrm_state = lrm_state_find(fsa_our_uname); lrm_state 506 daemons/controld/controld_remote_ra.c CRM_ASSERT(lrm_state != NULL); lrm_state 516 daemons/controld/controld_remote_ra.c process_lrm_event(lrm_state, &op, NULL, NULL); lrm_state 523 daemons/controld/controld_remote_ra.c lrm_state_t *lrm_state = NULL; lrm_state 534 daemons/controld/controld_remote_ra.c lrm_state = lrm_state_find(op->remote_nodename); lrm_state 535 daemons/controld/controld_remote_ra.c if (!lrm_state || !lrm_state->remote_ra_data) { lrm_state 539 daemons/controld/controld_remote_ra.c ra_data = lrm_state->remote_ra_data; lrm_state 553 daemons/controld/controld_remote_ra.c lrm_state_disconnect_only(lrm_state); lrm_state 572 daemons/controld/controld_remote_ra.c lrm_state->node_name); lrm_state 574 daemons/controld/controld_remote_ra.c } else if (!remote_ra_is_in_maintenance(lrm_state)) { lrm_state 576 daemons/controld/controld_remote_ra.c lrm_state->node_name); lrm_state 582 daemons/controld/controld_remote_ra.c lrm_state->node_name); lrm_state 584 daemons/controld/controld_remote_ra.c handle_remote_ra_stop(lrm_state, NULL); lrm_state 585 daemons/controld/controld_remote_ra.c remote_node_down(lrm_state->node_name, DOWN_KEEP_LRM); lrm_state 587 daemons/controld/controld_remote_ra.c synthesize_lrmd_success(NULL, lrm_state->node_name, "stop"); lrm_state 614 daemons/controld/controld_remote_ra.c g_timeout_add(1000, retry_start_cmd_cb, lrm_state); lrm_state 625 daemons/controld/controld_remote_ra.c lrm_state_reset_tables(lrm_state, TRUE); lrm_state 669 daemons/controld/controld_remote_ra.c lrm_state->node_name); lrm_state 675 daemons/controld/controld_remote_ra.c handle_remote_ra_stop(lrm_state, cmd); lrm_state 692 daemons/controld/controld_remote_ra.c handle_remote_ra_stop(lrm_state_t * lrm_state, remote_ra_cmd_t * cmd) lrm_state 696 daemons/controld/controld_remote_ra.c CRM_ASSERT(lrm_state); lrm_state 697 daemons/controld/controld_remote_ra.c ra_data = lrm_state->remote_ra_data; lrm_state 701 daemons/controld/controld_remote_ra.c g_hash_table_remove_all(lrm_state->pending_ops); lrm_state 705 daemons/controld/controld_remote_ra.c lrm_state_reset_tables(lrm_state, FALSE); lrm_state 709 daemons/controld/controld_remote_ra.c lrm_state_disconnect(lrm_state); lrm_state 730 daemons/controld/controld_remote_ra.c handle_remote_ra_start(lrm_state_t * lrm_state, remote_ra_cmd_t * cmd, int timeout_ms) lrm_state 735 daemons/controld/controld_remote_ra.c remote_ra_data_t *ra_data = lrm_state->remote_ra_data; lrm_state 749 daemons/controld/controld_remote_ra.c return lrm_state_remote_connect_async(lrm_state, server, port, timeout_used); lrm_state 756 daemons/controld/controld_remote_ra.c lrm_state_t *lrm_state = user_data; lrm_state 757 daemons/controld/controld_remote_ra.c remote_ra_data_t *ra_data = lrm_state->remote_ra_data; lrm_state 779 daemons/controld/controld_remote_ra.c rc = handle_remote_ra_start(lrm_state, cmd, cmd->timeout); lrm_state 796 daemons/controld/controld_remote_ra.c if (lrm_state_is_connected(lrm_state) == TRUE) { lrm_state 797 daemons/controld/controld_remote_ra.c rc = lrm_state_poke_connection(lrm_state); lrm_state 831 daemons/controld/controld_remote_ra.c handle_remote_ra_stop(lrm_state, cmd); lrm_state 852 daemons/controld/controld_remote_ra.c remote_ra_data_init(lrm_state_t * lrm_state) lrm_state 856 daemons/controld/controld_remote_ra.c if (lrm_state->remote_ra_data) { lrm_state 861 daemons/controld/controld_remote_ra.c ra_data->work = mainloop_add_trigger(G_PRIORITY_HIGH, handle_remote_ra_exec, lrm_state); lrm_state 862 daemons/controld/controld_remote_ra.c lrm_state->remote_ra_data = ra_data; lrm_state 866 daemons/controld/controld_remote_ra.c remote_ra_cleanup(lrm_state_t * lrm_state) lrm_state 868 daemons/controld/controld_remote_ra.c remote_ra_data_t *ra_data = lrm_state->remote_ra_data; lrm_state 883 daemons/controld/controld_remote_ra.c lrm_state->remote_ra_data = NULL; lrm_state 900 daemons/controld/controld_remote_ra.c remote_ra_get_rsc_info(lrm_state_t * lrm_state, const char *rsc_id) lrm_state 986 daemons/controld/controld_remote_ra.c remote_ra_cancel(lrm_state_t *lrm_state, const char *rsc_id, lrm_state 1086 daemons/controld/controld_remote_ra.c remote_ra_exec(lrm_state_t *lrm_state, const char *rsc_id, const char *action, lrm_state 1118 daemons/controld/controld_remote_ra.c cmd->owner = strdup(lrm_state->node_name); lrm_state 1153 daemons/controld/controld_remote_ra.c lrm_state_t *lrm_state = lrm_state_find(node_name); lrm_state 1155 daemons/controld/controld_remote_ra.c if (lrm_state && lrm_state_is_connected(lrm_state)) { lrm_state 1156 daemons/controld/controld_remote_ra.c remote_ra_data_t *ra_data = lrm_state->remote_ra_data; lrm_state 1220 daemons/controld/controld_remote_ra.c remote_ra_maintenance(lrm_state_t * lrm_state, gboolean maintenance) lrm_state 1222 daemons/controld/controld_remote_ra.c remote_ra_data_t *ra_data = lrm_state->remote_ra_data; lrm_state 1228 daemons/controld/controld_remote_ra.c node = crm_remote_peer_get(lrm_state->node_name); lrm_state 1236 daemons/controld/controld_remote_ra.c crm_perror(LOG_WARNING, "%s CIB node state update failed", lrm_state->node_name); lrm_state 1267 daemons/controld/controld_remote_ra.c lrm_state_t *lrm_state = lrm_state_find(ID(node)); lrm_state 1270 daemons/controld/controld_remote_ra.c if (lrm_state && lrm_state->remote_ra_data && lrm_state 1271 daemons/controld/controld_remote_ra.c ((remote_ra_data_t *) lrm_state->remote_ra_data)->active) { lrm_state 1273 daemons/controld/controld_remote_ra.c remote_ra_maintenance(lrm_state, lrm_state 1286 daemons/controld/controld_remote_ra.c remote_ra_is_in_maintenance(lrm_state_t * lrm_state) lrm_state 1288 daemons/controld/controld_remote_ra.c remote_ra_data_t *ra_data = lrm_state->remote_ra_data; lrm_state 1294 daemons/controld/controld_remote_ra.c remote_ra_controlling_guest(lrm_state_t * lrm_state) lrm_state 1296 daemons/controld/controld_remote_ra.c remote_ra_data_t *ra_data = lrm_state->remote_ra_data; lrm_state 63 lib/pengine/unpack.c static void unpack_lrm_resources(pe_node_t *node, xmlNode *lrm_state,