lrm_state 36 daemons/controld/controld_alerts.c lrm_state_t *lrm_state; lrm_state 42 daemons/controld/controld_alerts.c lrm_state = lrm_state_find(controld_globals.our_nodename); lrm_state 43 daemons/controld/controld_alerts.c if (lrm_state == NULL) { lrm_state 47 daemons/controld/controld_alerts.c lrmd_send_node_alert((lrmd_t *) lrm_state->conn, crmd_alert_list, lrm_state 55 daemons/controld/controld_alerts.c lrm_state_t *lrm_state; lrm_state 61 daemons/controld/controld_alerts.c lrm_state = lrm_state_find(controld_globals.our_nodename); lrm_state 62 daemons/controld/controld_alerts.c if (lrm_state == NULL) { lrm_state 67 daemons/controld/controld_alerts.c lrmd_send_fencing_alert((lrmd_t *) lrm_state->conn, crmd_alert_list, lrm_state 75 daemons/controld/controld_alerts.c lrm_state_t *lrm_state; lrm_state 81 daemons/controld/controld_alerts.c lrm_state = lrm_state_find(controld_globals.our_nodename); lrm_state 82 daemons/controld/controld_alerts.c if (lrm_state == NULL) { lrm_state 86 daemons/controld/controld_alerts.c lrmd_send_resource_alert((lrmd_t *) lrm_state->conn, crmd_alert_list, node, lrm_state 666 daemons/controld/controld_cib.c lrm_state_t *lrm_state = NULL; lrm_state 691 daemons/controld/controld_cib.c lrm_state = lrm_state_find(node_name); lrm_state 692 daemons/controld/controld_cib.c if (lrm_state == NULL) { lrm_state 704 daemons/controld/controld_cib.c metadata = controld_get_rsc_metadata(lrm_state, rsc, 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(const lrm_state_t *lrm_state, lrm_state 44 daemons/controld/controld_execd.c static void do_lrm_rsc_op(lrm_state_t *lrm_state, lrmd_rsc_info_t *rsc, lrm_state 47 daemons/controld/controld_execd.c static gboolean lrm_state_verify_stopped(lrm_state_t * lrm_state, enum crmd_fsa_state cur_state, lrm_state 157 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 164 daemons/controld/controld_execd.c controld_delete_resource_history(op->rsc_id, lrm_state->node_name, lrm_state 175 daemons/controld/controld_execd.c entry = g_hash_table_lookup(lrm_state->resource_history, op->rsc_id); lrm_state 179 daemons/controld/controld_execd.c g_hash_table_insert(lrm_state->resource_history, entry->id, entry); lrm_state 264 daemons/controld/controld_execd.c send_task_ok_ack(const lrm_state_t *lrm_state, const ha_msg_input_t *input, lrm_state 268 daemons/controld/controld_execd.c lrmd_event_data_t *op = construct_op(lrm_state, input->xml, rsc_id, task); lrm_state 297 daemons/controld/controld_execd.c lrm_state_t *lrm_state = lrm_state_find(op_node_name(op)); lrm_state 299 daemons/controld/controld_execd.c pcmk__assert(lrm_state != NULL); lrm_state 300 daemons/controld/controld_execd.c process_lrm_event(lrm_state, op, NULL, NULL); lrm_state 311 daemons/controld/controld_execd.c lrm_state_t *lrm_state) lrm_state 318 daemons/controld/controld_execd.c rc = controld_connect_local_executor(lrm_state); lrm_state 326 daemons/controld/controld_execd.c if (lrm_state->num_lrm_register_fails < MAX_LRM_REG_FAILS) { lrm_state 328 daemons/controld/controld_execd.c "(%d max): %s", lrm_state->num_lrm_register_fails, lrm_state 329 daemons/controld/controld_execd.c pcmk__plural_s(lrm_state->num_lrm_register_fails), lrm_state 338 daemons/controld/controld_execd.c "%d time%s: %s", lrm_state->num_lrm_register_fails, lrm_state 339 daemons/controld/controld_execd.c pcmk__plural_s(lrm_state->num_lrm_register_fails), lrm_state 356 daemons/controld/controld_execd.c lrm_state_t *lrm_state = NULL; lrm_state 361 daemons/controld/controld_execd.c lrm_state = lrm_state_find_or_create(controld_globals.our_nodename); lrm_state 362 daemons/controld/controld_execd.c if (lrm_state == NULL) { lrm_state 368 daemons/controld/controld_execd.c if (lrm_state_verify_stopped(lrm_state, cur_state, LOG_INFO) == FALSE) { lrm_state 376 daemons/controld/controld_execd.c lrm_state_disconnect(lrm_state); lrm_state 377 daemons/controld/controld_execd.c lrm_state_reset_tables(lrm_state, FALSE); lrm_state 381 daemons/controld/controld_execd.c try_local_executor_connect(action, msg_data, lrm_state); lrm_state 391 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 412 daemons/controld/controld_execd.c if ((lrm_state->active_ops != NULL) && lrm_state_is_connected(lrm_state)) { lrm_state 413 daemons/controld/controld_execd.c guint removed = g_hash_table_foreach_remove(lrm_state->active_ops, lrm_state 415 daemons/controld/controld_execd.c lrm_state); lrm_state 416 daemons/controld/controld_execd.c guint nremaining = g_hash_table_size(lrm_state->active_ops); lrm_state 424 daemons/controld/controld_execd.c if (lrm_state->active_ops != NULL) { lrm_state 425 daemons/controld/controld_execd.c g_hash_table_iter_init(&gIter, lrm_state->active_ops); lrm_state 441 daemons/controld/controld_execd.c g_hash_table_iter_init(&gIter, lrm_state->active_ops); lrm_state 452 daemons/controld/controld_execd.c if (lrm_state->resource_history == NULL) { lrm_state 462 daemons/controld/controld_execd.c g_hash_table_iter_init(&gIter, lrm_state->resource_history); lrm_state 464 daemons/controld/controld_execd.c if (is_rsc_active(lrm_state, entry->id) == FALSE) { lrm_state 474 daemons/controld/controld_execd.c if (lrm_state->active_ops != NULL) { lrm_state 477 daemons/controld/controld_execd.c g_hash_table_iter_init(&hIter, lrm_state->active_ops); lrm_state 497 daemons/controld/controld_execd.c is_rsc_active(lrm_state_t * lrm_state, const char *rsc_id) lrm_state 501 daemons/controld/controld_execd.c entry = g_hash_table_lookup(lrm_state->resource_history, rsc_id); lrm_state 532 daemons/controld/controld_execd.c build_active_RAs(lrm_state_t * lrm_state, xmlNode * rsc_list) lrm_state 537 daemons/controld/controld_execd.c g_hash_table_iter_init(&iter, lrm_state->resource_history); lrm_state 559 daemons/controld/controld_execd.c lrm_state->node_name); lrm_state 561 daemons/controld/controld_execd.c lrm_state->node_name); lrm_state 564 daemons/controld/controld_execd.c lrm_state->node_name); lrm_state 578 daemons/controld/controld_execd.c lrm_state_t *lrm_state = lrm_state_find(controld_globals.our_nodename); lrm_state 580 daemons/controld/controld_execd.c if (!lrm_state) { lrm_state 586 daemons/controld/controld_execd.c peer = pcmk__get_node(0, lrm_state->node_name, NULL, pcmk__node_search_any); lrm_state 601 daemons/controld/controld_execd.c build_active_RAs(lrm_state, rsc_list); lrm_state 663 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 672 daemons/controld/controld_execd.c op = construct_op(lrm_state, input->xml, rsc_id, PCMK_ACTION_DELETE); lrm_state 686 daemons/controld/controld_execd.c notify_deleted(event->lrm_state, op->input, event->rsc, event->rc); lrm_state 707 daemons/controld/controld_execd.c delete_rsc_entry(lrm_state_t *lrm_state, ha_msg_input_t *input, lrm_state 721 daemons/controld/controld_execd.c g_hash_table_remove(lrm_state->resource_history, rsc_id_copy); lrm_state 725 daemons/controld/controld_execd.c controld_delete_resource_history(rsc_id_copy, lrm_state->node_name, lrm_state 728 daemons/controld/controld_execd.c g_hash_table_foreach_remove(lrm_state->active_ops, lrm_state 734 daemons/controld/controld_execd.c notify_deleted(lrm_state, input, rsc_id, rc); lrm_state 739 daemons/controld/controld_execd.c event.lrm_state = lrm_state; lrm_state 740 daemons/controld/controld_execd.c g_hash_table_foreach_remove(lrm_state->deletion_ops, lrm_remove_deleted_rsc, &event); lrm_state 773 daemons/controld/controld_execd.c lrm_state_t *lrm_state = lrm_state_find(node_name); lrm_state 775 daemons/controld/controld_execd.c if (lrm_state == NULL) { lrm_state 778 daemons/controld/controld_execd.c if (lrm_state->resource_history != NULL) { lrm_state 779 daemons/controld/controld_execd.c rsc_history_t *entry = g_hash_table_lookup(lrm_state->resource_history, lrm_state 791 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 803 daemons/controld/controld_execd.c pending = g_hash_table_lookup(lrm_state->active_ops, key); lrm_state 825 daemons/controld/controld_execd.c rc = lrm_state_cancel(lrm_state, pending->rsc_id, pending->op_type, lrm_state 852 daemons/controld/controld_execd.c lrm_state_t *lrm_state; lrm_state 864 daemons/controld/controld_execd.c remove = !cancel_op(data->lrm_state, data->rsc->id, key, op->call_id, data->remove); lrm_state 870 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 882 daemons/controld/controld_execd.c data.lrm_state = lrm_state; lrm_state 884 daemons/controld/controld_execd.c removed = g_hash_table_foreach_remove(lrm_state->active_ops, lrm_state 887 daemons/controld/controld_execd.c removed, g_hash_table_size(lrm_state->active_ops)); lrm_state 909 daemons/controld/controld_execd.c get_lrm_resource(lrm_state_t *lrm_state, const xmlNode *rsc_xml, lrm_state 914 daemons/controld/controld_execd.c CRM_CHECK(lrm_state && rsc_xml && rsc_info, return -EINVAL); lrm_state 917 daemons/controld/controld_execd.c if (lrm_state_is_connected(lrm_state) == FALSE) { lrm_state 922 daemons/controld/controld_execd.c *rsc_info = lrm_state_get_rsc_info(lrm_state, id, 0); lrm_state 929 daemons/controld/controld_execd.c *rsc_info = lrm_state_get_rsc_info(lrm_state, long_id, 0); lrm_state 940 daemons/controld/controld_execd.c rc = lrm_state_register_rsc(lrm_state, id, class, provider, type, lrm_state 947 daemons/controld/controld_execd.c id, lrm_state->node_name, pcmk_strerror(rc), rc); lrm_state 953 daemons/controld/controld_execd.c if (lrm_state_is_local(lrm_state) == TRUE) { lrm_state 959 daemons/controld/controld_execd.c *rsc_info = lrm_state_get_rsc_info(lrm_state, id, 0); lrm_state 965 daemons/controld/controld_execd.c delete_resource(lrm_state_t *lrm_state, const char *id, lrmd_rsc_info_t *rsc, lrm_state 975 daemons/controld/controld_execd.c rc = lrm_state_unregister_rsc(lrm_state, id, 0); lrm_state 989 daemons/controld/controld_execd.c g_hash_table_insert(lrm_state->deletion_ops, ref, op); lrm_state 998 daemons/controld/controld_execd.c delete_rsc_entry(lrm_state, request, id, iter, rc, user, from_cib); lrm_state 1002 daemons/controld/controld_execd.c get_fake_call_id(lrm_state_t *lrm_state, const char *rsc_id) lrm_state 1007 daemons/controld/controld_execd.c if(lrm_state) { lrm_state 1008 daemons/controld/controld_execd.c entry = g_hash_table_lookup(lrm_state->resource_history, rsc_id); lrm_state 1025 daemons/controld/controld_execd.c fake_op_status(lrm_state_t *lrm_state, lrmd_event_data_t *op, int op_status, lrm_state 1028 daemons/controld/controld_execd.c op->call_id = get_fake_call_id(lrm_state, op->rsc_id); lrm_state 1036 daemons/controld/controld_execd.c force_reprobe(lrm_state_t *lrm_state, const char *from_sys, lrm_state 1043 daemons/controld/controld_execd.c crm_info("Clearing resource history on node %s", lrm_state->node_name); lrm_state 1044 daemons/controld/controld_execd.c g_hash_table_iter_init(&gIter, lrm_state->resource_history); lrm_state 1070 daemons/controld/controld_execd.c delete_resource(lrm_state, entry->id, &entry->rsc, &gIter, from_sys, lrm_state 1075 daemons/controld/controld_execd.c controld_delete_node_state(lrm_state->node_name, controld_section_lrm, lrm_state 1079 daemons/controld/controld_execd.c update_attrd(lrm_state->node_name, CRM_OP_PROBED, NULL, user_name, is_remote_node); lrm_state 1097 daemons/controld/controld_execd.c synthesize_lrmd_failure(lrm_state_t *lrm_state, const xmlNode *action, lrm_state 1121 daemons/controld/controld_execd.c op = construct_op(lrm_state, action, pcmk__xe_id(xml_rsc), operation); lrm_state 1125 daemons/controld/controld_execd.c fake_op_status(lrm_state, op, PCMK_EXEC_DONE, PCMK_OCF_OK, NULL); lrm_state 1127 daemons/controld/controld_execd.c fake_op_status(lrm_state, op, op_status, rc, exit_reason); lrm_state 1134 daemons/controld/controld_execd.c process_lrm_event(lrm_state, op, NULL, action); lrm_state 1162 daemons/controld/controld_execd.c fail_lrm_resource(xmlNode *xml, lrm_state_t *lrm_state, const char *user_name, lrm_state 1179 daemons/controld/controld_execd.c op = construct_op(lrm_state, xml, pcmk__xe_id(xml_rsc), "asyncmon"); lrm_state 1188 daemons/controld/controld_execd.c fake_op_status(lrm_state, op, PCMK_EXEC_ERROR, lrm_state 1198 daemons/controld/controld_execd.c if (get_lrm_resource(lrm_state, xml_rsc, TRUE, &rsc) == pcmk_ok) { lrm_state 1200 daemons/controld/controld_execd.c fake_op_status(lrm_state, op, PCMK_EXEC_DONE, PCMK_OCF_UNKNOWN_ERROR, lrm_state 1202 daemons/controld/controld_execd.c process_lrm_event(lrm_state, op, NULL, xml); lrm_state 1209 daemons/controld/controld_execd.c fake_op_status(lrm_state, op, PCMK_EXEC_ERROR, PCMK_OCF_UNKNOWN_ERROR, lrm_state 1219 daemons/controld/controld_execd.c handle_reprobe_op(lrm_state_t *lrm_state, const char *from_sys, lrm_state 1224 daemons/controld/controld_execd.c force_reprobe(lrm_state, from_sys, from_host, user_name, is_remote_node, lrm_state 1242 daemons/controld/controld_execd.c static bool do_lrm_cancel(ha_msg_input_t *input, lrm_state_t *lrm_state, lrm_state 1280 daemons/controld/controld_execd.c in_progress = cancel_op_key(lrm_state, rsc, op_key, TRUE); lrm_state 1284 daemons/controld/controld_execd.c in_progress = cancel_op(lrm_state, rsc->id, NULL, call, TRUE); lrm_state 1294 daemons/controld/controld_execd.c controld_delete_action_history_by_key(rsc->id, lrm_state->node_name, lrm_state 1296 daemons/controld/controld_execd.c send_task_ok_ack(lrm_state, input, rsc->id, rsc, op_task, lrm_state 1300 daemons/controld/controld_execd.c if (lrm_state->active_ops != NULL) { lrm_state 1301 daemons/controld/controld_execd.c g_hash_table_remove(lrm_state->active_ops, op_id); lrm_state 1319 daemons/controld/controld_execd.c send_task_ok_ack(lrm_state, input, rsc->id, rsc, op_task, lrm_state 1329 daemons/controld/controld_execd.c do_lrm_delete(ha_msg_input_t *input, lrm_state_t *lrm_state, lrm_state 1334 daemons/controld/controld_execd.c int cib_rc = controld_delete_resource_history(rsc->id, lrm_state->node_name, lrm_state 1341 daemons/controld/controld_execd.c op = construct_op(lrm_state, input->xml, rsc->id, PCMK_ACTION_DELETE); lrm_state 1356 daemons/controld/controld_execd.c delete_resource(lrm_state, rsc->id, rsc, NULL, from_sys, lrm_state 1399 daemons/controld/controld_execd.c lrm_state_t *lrm_state = lrm_state_find(lrm_op_target(data->input_xml)); lrm_state 1401 daemons/controld/controld_execd.c if ((lrm_state != NULL) && pcmk__result_ok(result)) { lrm_state 1402 daemons/controld/controld_execd.c md = controld_cache_metadata(lrm_state->metadata_cache, data->rsc, lrm_state 1406 daemons/controld/controld_execd.c do_lrm_rsc_op(lrm_state, data->rsc, data->input_xml, md); lrm_state 1418 daemons/controld/controld_execd.c lrm_state_t *lrm_state = NULL; lrm_state 1433 daemons/controld/controld_execd.c lrm_state = lrm_state_find(target_node); lrm_state 1434 daemons/controld/controld_execd.c if ((lrm_state == NULL) && is_remote_node) { lrm_state 1442 daemons/controld/controld_execd.c pcmk__assert(lrm_state != NULL); lrm_state 1469 daemons/controld/controld_execd.c fail_lrm_resource(input->xml, lrm_state, user_name, from_host, lrm_state 1482 daemons/controld/controld_execd.c update_attrd(lrm_state->node_name, CRM_OP_PROBED, PCMK_VALUE_TRUE, lrm_state 1493 daemons/controld/controld_execd.c handle_reprobe_op(lrm_state, from_sys, from_host, user_name, lrm_state 1507 daemons/controld/controld_execd.c rc = get_lrm_resource(lrm_state, xml_rsc, create_rsc, &rsc); lrm_state 1509 daemons/controld/controld_execd.c synthesize_lrmd_failure(lrm_state, input->xml, lrm_state 1523 daemons/controld/controld_execd.c delete_rsc_entry(lrm_state, input, pcmk__xe_id(xml_rsc), NULL, lrm_state 1531 daemons/controld/controld_execd.c synthesize_lrmd_failure(lrm_state, input->xml, PCMK_EXEC_ERROR, lrm_state 1542 daemons/controld/controld_execd.c synthesize_lrmd_failure(lrm_state, input->xml, PCMK_EXEC_ERROR, lrm_state 1549 daemons/controld/controld_execd.c if (!do_lrm_cancel(input, lrm_state, rsc, from_host, from_sys)) { lrm_state 1555 daemons/controld/controld_execd.c do_lrm_delete(input, lrm_state, rsc, from_sys, from_host, lrm_state 1570 daemons/controld/controld_execd.c md = controld_get_rsc_metadata(lrm_state, rsc, lrm_state 1598 daemons/controld/controld_execd.c do_lrm_rsc_op(lrm_state, rsc, input->xml, md); lrm_state 1612 daemons/controld/controld_execd.c construct_op(const lrm_state_t *lrm_state, const xmlNode *rsc_op, lrm_state 1687 daemons/controld/controld_execd.c if (lrm_state) { lrm_state 1688 daemons/controld/controld_execd.c entry = g_hash_table_lookup(lrm_state->resource_history, rsc_id); lrm_state 1805 daemons/controld/controld_execd.c lrm_state_t *lrm_state = state_entry->data; lrm_state 1807 daemons/controld/controld_execd.c if (!lrm_state_verify_stopped(lrm_state, cur_state, log_level)) { lrm_state 1820 daemons/controld/controld_execd.c lrm_state_t *lrm_state; lrm_state 1834 daemons/controld/controld_execd.c remove = !cancel_op(event->lrm_state, event->rsc->id, key, op->call_id, FALSE); lrm_state 1844 daemons/controld/controld_execd.c lrm_state_t *lrm_state = user_data; lrm_state 1850 daemons/controld/controld_execd.c remove = !cancel_op(lrm_state, op->rsc_id, key, op->call_id, FALSE); lrm_state 1918 daemons/controld/controld_execd.c do_lrm_rsc_op(lrm_state_t *lrm_state, lrmd_rsc_info_t *rsc, xmlNode *msg, lrm_state 1940 daemons/controld/controld_execd.c if (lrm_state == NULL) { lrm_state 1966 daemons/controld/controld_execd.c op = construct_op(lrm_state, msg, rsc->id, operation); lrm_state 1974 daemons/controld/controld_execd.c data.lrm_state = lrm_state; lrm_state 1975 daemons/controld/controld_execd.c removed = g_hash_table_foreach_remove(lrm_state->active_ops, lrm_state 1990 daemons/controld/controld_execd.c lrm_state->node_name, pcmk__s(transition, ""), rsc->id, lrm_state 2009 daemons/controld/controld_execd.c controld_record_pending_op(lrm_state->node_name, rsc, op); lrm_state 2015 daemons/controld/controld_execd.c cancel_op_key(lrm_state, rsc, op_id, FALSE); lrm_state 2018 daemons/controld/controld_execd.c rc = controld_execute_resource_agent(lrm_state, rsc->id, op->op_type, lrm_state 2043 daemons/controld/controld_execd.c g_hash_table_replace(lrm_state->active_ops, call_id_s, pending); lrm_state 2058 daemons/controld/controld_execd.c } else if (lrm_state_is_local(lrm_state)) { lrm_state 2061 daemons/controld/controld_execd.c fake_op_status(lrm_state, op, PCMK_EXEC_NOT_CONNECTED, lrm_state 2063 daemons/controld/controld_execd.c process_lrm_event(lrm_state, op, NULL, NULL); lrm_state 2069 daemons/controld/controld_execd.c operation, rsc->id, lrm_state->node_name, pcmk_rc_str(rc), rc); lrm_state 2070 daemons/controld/controld_execd.c fake_op_status(lrm_state, op, PCMK_EXEC_NOT_CONNECTED, lrm_state 2072 daemons/controld/controld_execd.c process_lrm_event(lrm_state, op, NULL, NULL); lrm_state 2113 daemons/controld/controld_execd.c did_lrm_rsc_op_fail(lrm_state_t *lrm_state, const char * rsc_id, lrm_state 2118 daemons/controld/controld_execd.c CRM_CHECK(lrm_state != NULL, return FALSE); lrm_state 2122 daemons/controld/controld_execd.c entry = g_hash_table_lookup(lrm_state->resource_history, rsc_id); lrm_state 2226 daemons/controld/controld_execd.c process_lrm_event(lrm_state_t *lrm_state, lrmd_event_data_t *op, lrm_state 2261 daemons/controld/controld_execd.c if (lrm_state) { lrm_state 2262 daemons/controld/controld_execd.c rsc = lrm_state_get_rsc_info(lrm_state, op->rsc_id, 0); lrm_state 2284 daemons/controld/controld_execd.c if (lrm_state) { lrm_state 2285 daemons/controld/controld_execd.c node_name = lrm_state->node_name; lrm_state 2292 daemons/controld/controld_execd.c if (lrm_state) { lrm_state 2293 daemons/controld/controld_execd.c pending = g_hash_table_lookup(lrm_state->active_ops, op_id); lrm_state 2368 daemons/controld/controld_execd.c if (lrm_state) { lrm_state 2378 daemons/controld/controld_execd.c if (did_lrm_rsc_op_fail(lrm_state, pending->rsc_id, lrm_state 2407 daemons/controld/controld_execd.c } else if (lrm_state && ((op->interval_ms == 0) lrm_state 2410 daemons/controld/controld_execd.c gboolean found = g_hash_table_remove(lrm_state->active_ops, op_id); lrm_state 2418 daemons/controld/controld_execd.c g_hash_table_size(lrm_state->active_ops)); lrm_state 2424 daemons/controld/controld_execd.c if (lrm_state) { lrm_state 2427 daemons/controld/controld_execd.c crmd_alert_resource_op(lrm_state->node_name, op); lrm_state 2431 daemons/controld/controld_execd.c controld_cache_metadata(lrm_state->metadata_cache, rsc, metadata); lrm_state 2438 daemons/controld/controld_execd.c if (lrm_state) { lrm_state 2439 daemons/controld/controld_execd.c delete_rsc_entry(lrm_state, NULL, op->rsc_id, NULL, pcmk_ok, NULL, lrm_state 2448 daemons/controld/controld_execd.c if (lrm_state && rsc) { lrm_state 2449 daemons/controld/controld_execd.c update_history_cache(lrm_state, rsc, op); lrm_state 66 daemons/controld/controld_execd_state.c lrm_state_t *lrm_state = user_data; lrm_state 71 daemons/controld/controld_execd_state.c lrm_state->node_name, (char*)key, op->user_data); lrm_state 87 daemons/controld/controld_execd_state.c event.remote_nodename = lrm_state->node_name; lrm_state 90 daemons/controld/controld_execd_state.c process_lrm_event(lrm_state, &event, op, NULL); lrm_state 96 daemons/controld/controld_execd_state.c lrm_state_is_local(lrm_state_t *lrm_state) lrm_state 98 daemons/controld/controld_execd_state.c return (lrm_state != NULL) lrm_state 99 daemons/controld/controld_execd_state.c && pcmk__str_eq(lrm_state->node_name, controld_globals.our_nodename, lrm_state 189 daemons/controld/controld_execd_state.c lrm_state_t *lrm_state = data; lrm_state 191 daemons/controld/controld_execd_state.c if (!lrm_state) { lrm_state 200 daemons/controld/controld_execd_state.c remote_proxy_disconnect_by_node(lrm_state->node_name); lrm_state 203 daemons/controld/controld_execd_state.c lrm_state->node_name, g_hash_table_size(proxy_table)); lrm_state 205 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 206 daemons/controld/controld_execd_state.c remote_ra_cleanup(lrm_state); lrm_state 207 daemons/controld/controld_execd_state.c lrmd_api_delete(lrm_state->conn); lrm_state 209 daemons/controld/controld_execd_state.c if (lrm_state->rsc_info_cache) { lrm_state 211 daemons/controld/controld_execd_state.c g_hash_table_size(lrm_state->rsc_info_cache)); lrm_state 212 daemons/controld/controld_execd_state.c g_hash_table_destroy(lrm_state->rsc_info_cache); lrm_state 214 daemons/controld/controld_execd_state.c if (lrm_state->resource_history) { lrm_state 216 daemons/controld/controld_execd_state.c g_hash_table_size(lrm_state->resource_history)); lrm_state 217 daemons/controld/controld_execd_state.c g_hash_table_destroy(lrm_state->resource_history); lrm_state 219 daemons/controld/controld_execd_state.c if (lrm_state->deletion_ops) { lrm_state 221 daemons/controld/controld_execd_state.c g_hash_table_size(lrm_state->deletion_ops)); lrm_state 222 daemons/controld/controld_execd_state.c g_hash_table_destroy(lrm_state->deletion_ops); lrm_state 224 daemons/controld/controld_execd_state.c if (lrm_state->active_ops != NULL) { lrm_state 226 daemons/controld/controld_execd_state.c g_hash_table_size(lrm_state->active_ops)); lrm_state 227 daemons/controld/controld_execd_state.c g_hash_table_destroy(lrm_state->active_ops); lrm_state 229 daemons/controld/controld_execd_state.c metadata_cache_free(lrm_state->metadata_cache); lrm_state 231 daemons/controld/controld_execd_state.c free((char *)lrm_state->node_name); lrm_state 232 daemons/controld/controld_execd_state.c free(lrm_state); lrm_state 236 daemons/controld/controld_execd_state.c lrm_state_reset_tables(lrm_state_t * lrm_state, gboolean reset_metadata) lrm_state 238 daemons/controld/controld_execd_state.c if (lrm_state->resource_history) { lrm_state 240 daemons/controld/controld_execd_state.c g_hash_table_size(lrm_state->resource_history)); lrm_state 241 daemons/controld/controld_execd_state.c g_hash_table_remove_all(lrm_state->resource_history); lrm_state 243 daemons/controld/controld_execd_state.c if (lrm_state->deletion_ops) { lrm_state 245 daemons/controld/controld_execd_state.c g_hash_table_size(lrm_state->deletion_ops)); lrm_state 246 daemons/controld/controld_execd_state.c g_hash_table_remove_all(lrm_state->deletion_ops); lrm_state 248 daemons/controld/controld_execd_state.c if (lrm_state->active_ops != NULL) { lrm_state 250 daemons/controld/controld_execd_state.c g_hash_table_size(lrm_state->active_ops)); lrm_state 251 daemons/controld/controld_execd_state.c g_hash_table_remove_all(lrm_state->active_ops); lrm_state 253 daemons/controld/controld_execd_state.c if (lrm_state->rsc_info_cache) { lrm_state 255 daemons/controld/controld_execd_state.c g_hash_table_size(lrm_state->rsc_info_cache)); lrm_state 256 daemons/controld/controld_execd_state.c g_hash_table_remove_all(lrm_state->rsc_info_cache); lrm_state 259 daemons/controld/controld_execd_state.c metadata_cache_reset(lrm_state->metadata_cache); lrm_state 312 daemons/controld/controld_execd_state.c lrm_state_t *lrm_state; lrm_state 316 daemons/controld/controld_execd_state.c lrm_state = g_hash_table_lookup(lrm_state_table, node_name); lrm_state 317 daemons/controld/controld_execd_state.c if (!lrm_state) { lrm_state 318 daemons/controld/controld_execd_state.c lrm_state = lrm_state_create(node_name); lrm_state 321 daemons/controld/controld_execd_state.c return lrm_state; lrm_state 334 daemons/controld/controld_execd_state.c lrm_state_disconnect_only(lrm_state_t * lrm_state) lrm_state 338 daemons/controld/controld_execd_state.c if (!lrm_state->conn) { lrm_state 341 daemons/controld/controld_execd_state.c crm_trace("Disconnecting %s", lrm_state->node_name); lrm_state 343 daemons/controld/controld_execd_state.c remote_proxy_disconnect_by_node(lrm_state->node_name); lrm_state 345 daemons/controld/controld_execd_state.c ((lrmd_t *) lrm_state->conn)->cmds->disconnect(lrm_state->conn); lrm_state 348 daemons/controld/controld_execd_state.c removed = g_hash_table_foreach_remove(lrm_state->active_ops, lrm_state 349 daemons/controld/controld_execd_state.c fail_pending_op, lrm_state); lrm_state 350 daemons/controld/controld_execd_state.c crm_trace("Synthesized %d operation failures for %s", removed, lrm_state->node_name); lrm_state 355 daemons/controld/controld_execd_state.c lrm_state_disconnect(lrm_state_t * lrm_state) lrm_state 357 daemons/controld/controld_execd_state.c if (!lrm_state->conn) { lrm_state 361 daemons/controld/controld_execd_state.c lrm_state_disconnect_only(lrm_state); lrm_state 363 daemons/controld/controld_execd_state.c lrmd_api_delete(lrm_state->conn); lrm_state 364 daemons/controld/controld_execd_state.c lrm_state->conn = NULL; lrm_state 368 daemons/controld/controld_execd_state.c lrm_state_is_connected(lrm_state_t * lrm_state) lrm_state 370 daemons/controld/controld_execd_state.c if (!lrm_state->conn) { lrm_state 373 daemons/controld/controld_execd_state.c return ((lrmd_t *) lrm_state->conn)->cmds->is_connected(lrm_state->conn); lrm_state 377 daemons/controld/controld_execd_state.c lrm_state_poke_connection(lrm_state_t * lrm_state) lrm_state 380 daemons/controld/controld_execd_state.c if (!lrm_state->conn) { lrm_state 383 daemons/controld/controld_execd_state.c return ((lrmd_t *) lrm_state->conn)->cmds->poke_connection(lrm_state->conn); lrm_state 388 daemons/controld/controld_execd_state.c controld_connect_local_executor(lrm_state_t *lrm_state) lrm_state 392 daemons/controld/controld_execd_state.c if (lrm_state->conn == NULL) { lrm_state 400 daemons/controld/controld_execd_state.c lrm_state->conn = api; lrm_state 403 daemons/controld/controld_execd_state.c rc = ((lrmd_t *) lrm_state->conn)->cmds->connect(lrm_state->conn, lrm_state 408 daemons/controld/controld_execd_state.c lrm_state->num_lrm_register_fails = 0; lrm_state 410 daemons/controld/controld_execd_state.c lrm_state->num_lrm_register_fails++; lrm_state 437 daemons/controld/controld_execd_state.c lrm_state_t *lrm_state = NULL; lrm_state 443 daemons/controld/controld_execd_state.c lrm_state = lrm_state_find(proxy->node_name); lrm_state 444 daemons/controld/controld_execd_state.c if (lrm_state) { lrm_state 494 daemons/controld/controld_execd_state.c lrm_state_t *lrm_state = userdata; lrm_state 502 daemons/controld/controld_execd_state.c proxy = crmd_remote_proxy_new(lrmd, lrm_state->node_name, session, channel); lrm_state 503 daemons/controld/controld_execd_state.c if (!remote_ra_controlling_guest(lrm_state)) { lrm_state 526 daemons/controld/controld_execd_state.c lrm_state->node_name); lrm_state 528 daemons/controld/controld_execd_state.c if (!remote_ra_is_in_maintenance(lrm_state)) { lrm_state 530 daemons/controld/controld_execd_state.c update_attrd(lrm_state->node_name, PCMK__NODE_ATTR_SHUTDOWN, now_s, lrm_state 537 daemons/controld/controld_execd_state.c lrm_state->node_name); lrm_state 542 daemons/controld/controld_execd_state.c lrm_state->node_name); lrm_state 557 daemons/controld/controld_execd_state.c CRM_CHECK(lrm_state->node_name, return); lrm_state 560 daemons/controld/controld_execd_state.c lrm_state->node_name); lrm_state 574 daemons/controld/controld_execd_state.c crm_xml_add(request, PCMK_XA_UNAME, lrm_state->node_name); lrm_state 599 daemons/controld/controld_execd_state.c remote_proxy_cb(lrmd, lrm_state->node_name, msg); lrm_state 606 daemons/controld/controld_execd_state.c controld_connect_remote_executor(lrm_state_t *lrm_state, const char *server, lrm_state 611 daemons/controld/controld_execd_state.c if (lrm_state->conn == NULL) { lrm_state 614 daemons/controld/controld_execd_state.c rc = lrmd__new(&api, lrm_state->node_name, server, port); lrm_state 621 daemons/controld/controld_execd_state.c lrm_state->conn = api; lrm_state 623 daemons/controld/controld_execd_state.c lrmd_internal_set_proxy_callback(api, lrm_state, crmd_remote_proxy_cb); lrm_state 628 daemons/controld/controld_execd_state.c rc = ((lrmd_t *) lrm_state->conn)->cmds->connect_async(lrm_state->conn, lrm_state 629 daemons/controld/controld_execd_state.c lrm_state->node_name, lrm_state 632 daemons/controld/controld_execd_state.c lrm_state->num_lrm_register_fails = 0; lrm_state 634 daemons/controld/controld_execd_state.c lrm_state->num_lrm_register_fails++; // Ignored for remote connections lrm_state 640 daemons/controld/controld_execd_state.c lrm_state_get_metadata(lrm_state_t * lrm_state, lrm_state 647 daemons/controld/controld_execd_state.c if (!lrm_state->conn) { lrm_state 666 daemons/controld/controld_execd_state.c lrm_state->node_name); lrm_state 668 daemons/controld/controld_execd_state.c return ((lrmd_t *) lrm_state->conn)->cmds->get_metadata_params(lrm_state->conn, lrm_state 673 daemons/controld/controld_execd_state.c lrm_state_cancel(lrm_state_t *lrm_state, const char *rsc_id, const char *action, lrm_state 676 daemons/controld/controld_execd_state.c if (!lrm_state->conn) { lrm_state 683 daemons/controld/controld_execd_state.c return remote_ra_cancel(lrm_state, rsc_id, action, interval_ms); lrm_state 685 daemons/controld/controld_execd_state.c return ((lrmd_t *) lrm_state->conn)->cmds->cancel(lrm_state->conn, rsc_id, lrm_state 690 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 694 daemons/controld/controld_execd_state.c if (!lrm_state->conn) { lrm_state 698 daemons/controld/controld_execd_state.c return remote_ra_get_rsc_info(lrm_state, rsc_id); lrm_state 701 daemons/controld/controld_execd_state.c rsc = g_hash_table_lookup(lrm_state->rsc_info_cache, rsc_id); lrm_state 704 daemons/controld/controld_execd_state.c rsc = ((lrmd_t *) lrm_state->conn)->cmds->get_rsc_info(lrm_state->conn, rsc_id, options); lrm_state 709 daemons/controld/controld_execd_state.c g_hash_table_insert(lrm_state->rsc_info_cache, rsc->id, rsc); lrm_state 733 daemons/controld/controld_execd_state.c controld_execute_resource_agent(lrm_state_t *lrm_state, const char *rsc_id, lrm_state 742 daemons/controld/controld_execd_state.c if (lrm_state->conn == NULL) { lrm_state 760 daemons/controld/controld_execd_state.c rc = controld_execute_remote_agent(lrm_state, rsc_id, action, lrm_state 765 daemons/controld/controld_execd_state.c rc = ((lrmd_t *) lrm_state->conn)->cmds->exec(lrm_state->conn, rsc_id, lrm_state 782 daemons/controld/controld_execd_state.c lrm_state_register_rsc(lrm_state_t * lrm_state, lrm_state 787 daemons/controld/controld_execd_state.c lrmd_t *conn = (lrmd_t *) lrm_state->conn; lrm_state 800 daemons/controld/controld_execd_state.c return conn->cmds->register_rsc(lrm_state->conn, rsc_id, class, provider, lrm_state 805 daemons/controld/controld_execd_state.c lrm_state_unregister_rsc(lrm_state_t * lrm_state, lrm_state 808 daemons/controld/controld_execd_state.c if (!lrm_state->conn) { lrm_state 817 daemons/controld/controld_execd_state.c g_hash_table_remove(lrm_state->rsc_info_cache, rsc_id); lrm_state 824 daemons/controld/controld_execd_state.c return ((lrmd_t *) lrm_state->conn)->cmds->unregister_rsc(lrm_state->conn, rsc_id, options); lrm_state 91 daemons/controld/controld_lrm.h lrm_state_is_local(lrm_state_t *lrm_state); lrm_state 98 daemons/controld/controld_lrm.h void lrm_state_reset_tables(lrm_state_t * lrm_state, gboolean reset_metadata); lrm_state 128 daemons/controld/controld_lrm.h void lrm_state_disconnect_only(lrm_state_t * lrm_state); lrm_state 129 daemons/controld/controld_lrm.h void lrm_state_disconnect(lrm_state_t * lrm_state); lrm_state 130 daemons/controld/controld_lrm.h int controld_connect_local_executor(lrm_state_t *lrm_state); lrm_state 131 daemons/controld/controld_lrm.h int controld_connect_remote_executor(lrm_state_t *lrm_state, const char *server, lrm_state 133 daemons/controld/controld_lrm.h int lrm_state_is_connected(lrm_state_t * lrm_state); lrm_state 134 daemons/controld/controld_lrm.h int lrm_state_poke_connection(lrm_state_t * lrm_state); lrm_state 136 daemons/controld/controld_lrm.h int lrm_state_get_metadata(lrm_state_t * lrm_state, lrm_state 140 daemons/controld/controld_lrm.h int lrm_state_cancel(lrm_state_t *lrm_state, const char *rsc_id, lrm_state 142 daemons/controld/controld_lrm.h int controld_execute_resource_agent(lrm_state_t *lrm_state, const char *rsc_id, lrm_state 147 daemons/controld/controld_lrm.h lrmd_rsc_info_t *lrm_state_get_rsc_info(lrm_state_t * lrm_state, lrm_state 149 daemons/controld/controld_lrm.h int lrm_state_register_rsc(lrm_state_t * lrm_state, lrm_state 153 daemons/controld/controld_lrm.h int lrm_state_unregister_rsc(lrm_state_t * lrm_state, lrm_state 159 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 160 daemons/controld/controld_lrm.h int remote_ra_cancel(lrm_state_t *lrm_state, const char *rsc_id, lrm_state 162 daemons/controld/controld_lrm.h int controld_execute_remote_agent(const lrm_state_t *lrm_state, lrm_state 168 daemons/controld/controld_lrm.h void remote_ra_cleanup(lrm_state_t * lrm_state); lrm_state 171 daemons/controld/controld_lrm.h gboolean remote_ra_is_in_maintenance(lrm_state_t * lrm_state); lrm_state 173 daemons/controld/controld_lrm.h gboolean remote_ra_controlling_guest(lrm_state_t * lrm_state); lrm_state 175 daemons/controld/controld_lrm.h void process_lrm_event(lrm_state_t *lrm_state, lrmd_event_data_t *op, lrm_state 247 daemons/controld/controld_metadata.c controld_get_rsc_metadata(lrm_state_t *lrm_state, const lrmd_rsc_info_t *rsc, lrm_state 255 daemons/controld/controld_metadata.c CRM_CHECK((lrm_state != NULL) && (rsc != NULL), return NULL); lrm_state 260 daemons/controld/controld_metadata.c metadata = g_hash_table_lookup(lrm_state->metadata_cache, key); lrm_state 296 daemons/controld/controld_metadata.c rc = lrm_state_get_metadata(lrm_state, rsc->standard, rsc->provider, lrm_state 307 daemons/controld/controld_metadata.c metadata = controld_cache_metadata(lrm_state->metadata_cache, rsc, lrm_state 77 daemons/controld/controld_metadata.h struct ra_metadata_s *controld_get_rsc_metadata(lrm_state_t *lrm_state, lrm_state 73 daemons/controld/controld_remote_ra.c #define lrm_remote_set_flags(lrm_state, flags_to_set) do { \ lrm_state 74 daemons/controld/controld_remote_ra.c lrm_state_t *lrm = (lrm_state); \ lrm_state 81 daemons/controld/controld_remote_ra.c #define lrm_remote_clear_flags(lrm_state, flags_to_clear) do { \ lrm_state 82 daemons/controld/controld_remote_ra.c lrm_state_t *lrm = (lrm_state); \ lrm_state 114 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 115 daemons/controld/controld_remote_ra.c static void handle_remote_ra_stop(lrm_state_t * lrm_state, remote_ra_cmd_t * cmd); lrm_state 429 daemons/controld/controld_remote_ra.c lrm_state_t *lrm_state = lrm_state_find(cmd->rsc_id); lrm_state 430 daemons/controld/controld_remote_ra.c remote_ra_data_t *ra_data = lrm_state? lrm_state->remote_ra_data : NULL; lrm_state 524 daemons/controld/controld_remote_ra.c lrm_state_t *lrm_state = data; lrm_state 525 daemons/controld/controld_remote_ra.c remote_ra_data_t *ra_data = lrm_state->remote_ra_data; lrm_state 540 daemons/controld/controld_remote_ra.c rc = handle_remote_ra_start(lrm_state, cmd, cmd->remaining_timeout); lrm_state 566 daemons/controld/controld_remote_ra.c lrm_state_t *lrm_state = NULL; lrm_state 572 daemons/controld/controld_remote_ra.c lrm_state = lrm_state_find(cmd->rsc_id); lrm_state 574 daemons/controld/controld_remote_ra.c handle_remote_ra_stop(lrm_state, cmd); lrm_state 583 daemons/controld/controld_remote_ra.c lrm_state_t *lrm_state = NULL; lrm_state 586 daemons/controld/controld_remote_ra.c lrm_state = lrm_state_find(cmd->rsc_id); lrm_state 589 daemons/controld/controld_remote_ra.c cmd->rsc_id, (lrm_state? "" : " (no LRM state)")); lrm_state 594 daemons/controld/controld_remote_ra.c if (lrm_state && lrm_state->remote_ra_data) { lrm_state 595 daemons/controld/controld_remote_ra.c remote_ra_data_t *ra_data = lrm_state->remote_ra_data; lrm_state 608 daemons/controld/controld_remote_ra.c if(lrm_state) { lrm_state 609 daemons/controld/controld_remote_ra.c lrm_state_disconnect(lrm_state); lrm_state 615 daemons/controld/controld_remote_ra.c synthesize_lrmd_success(lrm_state_t *lrm_state, const char *rsc_id, const char *op_type) lrm_state 619 daemons/controld/controld_remote_ra.c if (lrm_state == NULL) { lrm_state 621 daemons/controld/controld_remote_ra.c lrm_state = lrm_state_find(controld_globals.our_nodename); lrm_state 623 daemons/controld/controld_remote_ra.c pcmk__assert(lrm_state != NULL); lrm_state 633 daemons/controld/controld_remote_ra.c process_lrm_event(lrm_state, &op, NULL, NULL); lrm_state 640 daemons/controld/controld_remote_ra.c lrm_state_t *lrm_state = NULL; lrm_state 651 daemons/controld/controld_remote_ra.c lrm_state = lrm_state_find(op->remote_nodename); lrm_state 652 daemons/controld/controld_remote_ra.c if (!lrm_state || !lrm_state->remote_ra_data) { lrm_state 656 daemons/controld/controld_remote_ra.c ra_data = lrm_state->remote_ra_data; lrm_state 663 daemons/controld/controld_remote_ra.c lrm_remote_clear_flags(lrm_state, expect_takeover); lrm_state 664 daemons/controld/controld_remote_ra.c lrm_remote_set_flags(lrm_state, takeover_complete); lrm_state 672 daemons/controld/controld_remote_ra.c lrm_state_disconnect_only(lrm_state); lrm_state 691 daemons/controld/controld_remote_ra.c lrm_state->node_name); lrm_state 693 daemons/controld/controld_remote_ra.c } else if (!remote_ra_is_in_maintenance(lrm_state)) { lrm_state 695 daemons/controld/controld_remote_ra.c lrm_state->node_name); lrm_state 701 daemons/controld/controld_remote_ra.c lrm_state->node_name); lrm_state 703 daemons/controld/controld_remote_ra.c handle_remote_ra_stop(lrm_state, NULL); lrm_state 704 daemons/controld/controld_remote_ra.c remote_node_down(lrm_state->node_name, DOWN_KEEP_LRM); lrm_state 706 daemons/controld/controld_remote_ra.c synthesize_lrmd_success(NULL, lrm_state->node_name, lrm_state 736 daemons/controld/controld_remote_ra.c g_timeout_add(1000, retry_start_cmd_cb, lrm_state); lrm_state 749 daemons/controld/controld_remote_ra.c lrm_state_reset_tables(lrm_state, TRUE); lrm_state 751 daemons/controld/controld_remote_ra.c lrm_remote_set_flags(lrm_state, remote_active); lrm_state 798 daemons/controld/controld_remote_ra.c lrm_state->node_name); lrm_state 806 daemons/controld/controld_remote_ra.c handle_remote_ra_stop(lrm_state, cmd); lrm_state 823 daemons/controld/controld_remote_ra.c handle_remote_ra_stop(lrm_state_t * lrm_state, remote_ra_cmd_t * cmd) lrm_state 827 daemons/controld/controld_remote_ra.c pcmk__assert(lrm_state != NULL); lrm_state 828 daemons/controld/controld_remote_ra.c ra_data = lrm_state->remote_ra_data; lrm_state 832 daemons/controld/controld_remote_ra.c g_hash_table_remove_all(lrm_state->active_ops); lrm_state 836 daemons/controld/controld_remote_ra.c lrm_state_reset_tables(lrm_state, FALSE); lrm_state 839 daemons/controld/controld_remote_ra.c lrm_remote_clear_flags(lrm_state, remote_active); lrm_state 840 daemons/controld/controld_remote_ra.c lrm_state_disconnect(lrm_state); lrm_state 860 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 880 daemons/controld/controld_remote_ra.c lrm_remote_set_flags(lrm_state, controlling_guest); lrm_state 884 daemons/controld/controld_remote_ra.c rc = controld_connect_remote_executor(lrm_state, server, port, lrm_state 890 daemons/controld/controld_remote_ra.c lrm_state->node_name, pcmk_rc_str(rc)); lrm_state 899 daemons/controld/controld_remote_ra.c lrm_state_t *lrm_state = user_data; lrm_state 900 daemons/controld/controld_remote_ra.c remote_ra_data_t *ra_data = lrm_state->remote_ra_data; lrm_state 922 daemons/controld/controld_remote_ra.c lrm_remote_clear_flags(lrm_state, expect_takeover | takeover_complete); lrm_state 923 daemons/controld/controld_remote_ra.c if (handle_remote_ra_start(lrm_state, cmd, lrm_state 935 daemons/controld/controld_remote_ra.c if (lrm_state_is_connected(lrm_state) == TRUE) { lrm_state 936 daemons/controld/controld_remote_ra.c rc = lrm_state_poke_connection(lrm_state); lrm_state 970 daemons/controld/controld_remote_ra.c handle_remote_ra_stop(lrm_state, cmd); lrm_state 973 daemons/controld/controld_remote_ra.c lrm_remote_clear_flags(lrm_state, takeover_complete); lrm_state 974 daemons/controld/controld_remote_ra.c lrm_remote_set_flags(lrm_state, expect_takeover); lrm_state 1000 daemons/controld/controld_remote_ra.c remote_ra_data_init(lrm_state_t * lrm_state) lrm_state 1004 daemons/controld/controld_remote_ra.c if (lrm_state->remote_ra_data) { lrm_state 1009 daemons/controld/controld_remote_ra.c ra_data->work = mainloop_add_trigger(G_PRIORITY_HIGH, handle_remote_ra_exec, lrm_state); lrm_state 1010 daemons/controld/controld_remote_ra.c lrm_state->remote_ra_data = ra_data; lrm_state 1014 daemons/controld/controld_remote_ra.c remote_ra_cleanup(lrm_state_t * lrm_state) lrm_state 1016 daemons/controld/controld_remote_ra.c remote_ra_data_t *ra_data = lrm_state->remote_ra_data; lrm_state 1031 daemons/controld/controld_remote_ra.c lrm_state->remote_ra_data = NULL; lrm_state 1049 daemons/controld/controld_remote_ra.c remote_ra_get_rsc_info(lrm_state_t * lrm_state, const char *rsc_id) lrm_state 1135 daemons/controld/controld_remote_ra.c remote_ra_cancel(lrm_state_t *lrm_state, const char *rsc_id, lrm_state 1256 daemons/controld/controld_remote_ra.c controld_execute_remote_agent(const lrm_state_t *lrm_state, const char *rsc_id, lrm_state 1268 daemons/controld/controld_remote_ra.c CRM_CHECK((lrm_state != NULL) && (rsc_id != NULL) && (action != NULL) lrm_state 1295 daemons/controld/controld_remote_ra.c cmd->owner = pcmk__str_copy(lrm_state->node_name); lrm_state 1327 daemons/controld/controld_remote_ra.c lrm_state_t *lrm_state = lrm_state_find(node_name); lrm_state 1329 daemons/controld/controld_remote_ra.c if (lrm_state && lrm_state_is_connected(lrm_state)) { lrm_state 1330 daemons/controld/controld_remote_ra.c remote_ra_data_t *ra_data = lrm_state->remote_ra_data; lrm_state 1392 daemons/controld/controld_remote_ra.c remote_ra_maintenance(lrm_state_t * lrm_state, gboolean maintenance) lrm_state 1399 daemons/controld/controld_remote_ra.c node = pcmk__cluster_lookup_remote_node(lrm_state->node_name); lrm_state 1409 daemons/controld/controld_remote_ra.c lrm_remote_set_flags(lrm_state, remote_in_maint); lrm_state 1411 daemons/controld/controld_remote_ra.c lrm_remote_clear_flags(lrm_state, remote_in_maint); lrm_state 1440 daemons/controld/controld_remote_ra.c lrm_state_t *lrm_state = lrm_state_find(pcmk__xe_id(node)); lrm_state 1443 daemons/controld/controld_remote_ra.c if (lrm_state && lrm_state->remote_ra_data && lrm_state 1444 daemons/controld/controld_remote_ra.c pcmk_is_set(((remote_ra_data_t *) lrm_state->remote_ra_data)->status, remote_active)) { lrm_state 1453 daemons/controld/controld_remote_ra.c remote_ra_maintenance(lrm_state, in_maint); lrm_state 1464 daemons/controld/controld_remote_ra.c remote_ra_is_in_maintenance(lrm_state_t * lrm_state) lrm_state 1466 daemons/controld/controld_remote_ra.c remote_ra_data_t *ra_data = lrm_state->remote_ra_data; lrm_state 1471 daemons/controld/controld_remote_ra.c remote_ra_controlling_guest(lrm_state_t * lrm_state) lrm_state 1473 daemons/controld/controld_remote_ra.c remote_ra_data_t *ra_data = lrm_state->remote_ra_data;