cmd 44 daemons/based/cibmon.c void usage(const char *cmd, crm_exit_t exit_status); cmd 168 daemons/based/cibmon.c usage(const char *cmd, crm_exit_t exit_status) cmd 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); cmd 89 daemons/controld/controld_remote_ra.c static void handle_remote_ra_stop(lrm_state_t * lrm_state, remote_ra_cmd_t * cmd); cmd 95 daemons/controld/controld_remote_ra.c remote_ra_cmd_t *cmd = user_data; cmd 97 daemons/controld/controld_remote_ra.c if (!cmd) { cmd 100 daemons/controld/controld_remote_ra.c if (cmd->delay_id) { cmd 101 daemons/controld/controld_remote_ra.c g_source_remove(cmd->delay_id); cmd 103 daemons/controld/controld_remote_ra.c if (cmd->interval_id) { cmd 104 daemons/controld/controld_remote_ra.c g_source_remove(cmd->interval_id); cmd 106 daemons/controld/controld_remote_ra.c if (cmd->monitor_timeout_id) { cmd 107 daemons/controld/controld_remote_ra.c g_source_remove(cmd->monitor_timeout_id); cmd 109 daemons/controld/controld_remote_ra.c if (cmd->takeover_timeout_id) { cmd 110 daemons/controld/controld_remote_ra.c g_source_remove(cmd->takeover_timeout_id); cmd 112 daemons/controld/controld_remote_ra.c free(cmd->owner); cmd 113 daemons/controld/controld_remote_ra.c free(cmd->rsc_id); cmd 114 daemons/controld/controld_remote_ra.c free(cmd->action); cmd 115 daemons/controld/controld_remote_ra.c free(cmd->userdata); cmd 116 daemons/controld/controld_remote_ra.c free(cmd->exit_reason); cmd 117 daemons/controld/controld_remote_ra.c lrmd_key_value_freeall(cmd->params); cmd 118 daemons/controld/controld_remote_ra.c free(cmd); cmd 137 daemons/controld/controld_remote_ra.c remote_ra_cmd_t *cmd = data; cmd 140 daemons/controld/controld_remote_ra.c cmd->interval_id = 0; cmd 141 daemons/controld/controld_remote_ra.c connection_rsc = lrm_state_find(cmd->rsc_id); cmd 145 daemons/controld/controld_remote_ra.c ra_data->recurring_cmds = g_list_remove(ra_data->recurring_cmds, cmd); cmd 147 daemons/controld/controld_remote_ra.c ra_data->cmds = g_list_append(ra_data->cmds, cmd); cmd 156 daemons/controld/controld_remote_ra.c remote_ra_cmd_t *cmd = data; cmd 159 daemons/controld/controld_remote_ra.c cmd->delay_id = 0; cmd 160 daemons/controld/controld_remote_ra.c connection_rsc = lrm_state_find(cmd->rsc_id); cmd 296 daemons/controld/controld_remote_ra.c check_remote_node_state(remote_ra_cmd_t *cmd) cmd 299 daemons/controld/controld_remote_ra.c if (cmd->rc != PCMK_OCF_OK) { cmd 303 daemons/controld/controld_remote_ra.c if (pcmk__str_eq(cmd->action, "start", pcmk__str_casei)) { cmd 304 daemons/controld/controld_remote_ra.c remote_node_up(cmd->rsc_id); cmd 306 daemons/controld/controld_remote_ra.c } else if (pcmk__str_eq(cmd->action, "migrate_from", pcmk__str_casei)) { cmd 314 daemons/controld/controld_remote_ra.c crm_node_t *node = crm_remote_peer_get(cmd->rsc_id); cmd 319 daemons/controld/controld_remote_ra.c } else if (pcmk__str_eq(cmd->action, "stop", pcmk__str_casei)) { cmd 320 daemons/controld/controld_remote_ra.c lrm_state_t *lrm_state = lrm_state_find(cmd->rsc_id); cmd 326 daemons/controld/controld_remote_ra.c remote_node_down(cmd->rsc_id, DOWN_KEEP_LRM); cmd 332 daemons/controld/controld_remote_ra.c crm_remote_peer_cache_remove(cmd->rsc_id); cmd 349 daemons/controld/controld_remote_ra.c report_remote_ra_result(remote_ra_cmd_t * cmd) cmd 353 daemons/controld/controld_remote_ra.c check_remote_node_state(cmd); cmd 356 daemons/controld/controld_remote_ra.c op.rsc_id = cmd->rsc_id; cmd 357 daemons/controld/controld_remote_ra.c op.op_type = cmd->action; cmd 358 daemons/controld/controld_remote_ra.c op.user_data = cmd->userdata; cmd 359 daemons/controld/controld_remote_ra.c op.exit_reason = cmd->exit_reason; cmd 360 daemons/controld/controld_remote_ra.c op.timeout = cmd->timeout; cmd 361 daemons/controld/controld_remote_ra.c op.interval_ms = cmd->interval_ms; cmd 362 daemons/controld/controld_remote_ra.c op.rc = cmd->rc; cmd 363 daemons/controld/controld_remote_ra.c op.op_status = cmd->op_status; cmd 364 daemons/controld/controld_remote_ra.c op.t_run = (unsigned int) cmd->start_time; cmd 365 daemons/controld/controld_remote_ra.c op.t_rcchange = (unsigned int) cmd->start_time; cmd 366 daemons/controld/controld_remote_ra.c if (cmd->reported_success && cmd->rc != PCMK_OCF_OK) { cmd 382 daemons/controld/controld_remote_ra.c if (cmd->params) { cmd 386 daemons/controld/controld_remote_ra.c for (tmp = cmd->params; tmp; tmp = tmp->next) { cmd 391 daemons/controld/controld_remote_ra.c op.call_id = cmd->call_id; cmd 392 daemons/controld/controld_remote_ra.c op.remote_nodename = cmd->owner; cmd 402 daemons/controld/controld_remote_ra.c update_remaining_timeout(remote_ra_cmd_t * cmd) cmd 404 daemons/controld/controld_remote_ra.c cmd->remaining_timeout = ((cmd->timeout / 1000) - (time(NULL) - cmd->start_time)) * 1000; cmd 412 daemons/controld/controld_remote_ra.c remote_ra_cmd_t *cmd = NULL; cmd 418 daemons/controld/controld_remote_ra.c cmd = ra_data->cur_cmd; cmd 419 daemons/controld/controld_remote_ra.c if (!pcmk__strcase_any_of(cmd->action, "start", "migrate_from", NULL)) { cmd 422 daemons/controld/controld_remote_ra.c update_remaining_timeout(cmd); cmd 424 daemons/controld/controld_remote_ra.c if (cmd->remaining_timeout > 0) { cmd 425 daemons/controld/controld_remote_ra.c rc = handle_remote_ra_start(lrm_state, cmd, cmd->remaining_timeout); cmd 429 daemons/controld/controld_remote_ra.c cmd->rc = PCMK_OCF_UNKNOWN_ERROR; cmd 430 daemons/controld/controld_remote_ra.c cmd->op_status = PCMK_LRM_OP_ERROR; cmd 431 daemons/controld/controld_remote_ra.c report_remote_ra_result(cmd); cmd 437 daemons/controld/controld_remote_ra.c free_cmd(cmd); cmd 450 daemons/controld/controld_remote_ra.c remote_ra_cmd_t *cmd = data; cmd 452 daemons/controld/controld_remote_ra.c crm_info("takeover event timed out for node %s", cmd->rsc_id); cmd 453 daemons/controld/controld_remote_ra.c cmd->takeover_timeout_id = 0; cmd 455 daemons/controld/controld_remote_ra.c lrm_state = lrm_state_find(cmd->rsc_id); cmd 457 daemons/controld/controld_remote_ra.c handle_remote_ra_stop(lrm_state, cmd); cmd 458 daemons/controld/controld_remote_ra.c free_cmd(cmd); cmd 467 daemons/controld/controld_remote_ra.c remote_ra_cmd_t *cmd = data; cmd 469 daemons/controld/controld_remote_ra.c lrm_state = lrm_state_find(cmd->rsc_id); cmd 472 daemons/controld/controld_remote_ra.c cmd->rsc_id, (lrm_state? "" : " (no LRM state)")); cmd 473 daemons/controld/controld_remote_ra.c cmd->monitor_timeout_id = 0; cmd 474 daemons/controld/controld_remote_ra.c cmd->op_status = PCMK_LRM_OP_TIMEOUT; cmd 475 daemons/controld/controld_remote_ra.c cmd->rc = PCMK_OCF_UNKNOWN_ERROR; cmd 480 daemons/controld/controld_remote_ra.c if (ra_data->cur_cmd == cmd) { cmd 488 daemons/controld/controld_remote_ra.c report_remote_ra_result(cmd); cmd 489 daemons/controld/controld_remote_ra.c free_cmd(cmd); cmd 525 daemons/controld/controld_remote_ra.c remote_ra_cmd_t *cmd = NULL; cmd 597 daemons/controld/controld_remote_ra.c cmd = ra_data->cur_cmd; cmd 601 daemons/controld/controld_remote_ra.c if (op->type == lrmd_event_connect && pcmk__strcase_any_of(cmd->action, "start", cmd 604 daemons/controld/controld_remote_ra.c update_remaining_timeout(cmd); cmd 608 daemons/controld/controld_remote_ra.c cmd->op_status = PCMK_LRM_OP_ERROR; cmd 609 daemons/controld/controld_remote_ra.c cmd->rc = PCMK_OCF_INVALID_PARAM; cmd 610 daemons/controld/controld_remote_ra.c cmd->exit_reason = strdup("Authentication key not readable"); cmd 612 daemons/controld/controld_remote_ra.c } else if (cmd->remaining_timeout > 3000) { cmd 613 daemons/controld/controld_remote_ra.c crm_trace("rescheduling start, remaining timeout %d", cmd->remaining_timeout); cmd 619 daemons/controld/controld_remote_ra.c cmd->remaining_timeout); cmd 620 daemons/controld/controld_remote_ra.c cmd->op_status = PCMK_LRM_OP_TIMEOUT; cmd 621 daemons/controld/controld_remote_ra.c cmd->rc = PCMK_OCF_UNKNOWN_ERROR; cmd 626 daemons/controld/controld_remote_ra.c cmd->rc = PCMK_OCF_OK; cmd 627 daemons/controld/controld_remote_ra.c cmd->op_status = PCMK_LRM_OP_DONE; cmd 631 daemons/controld/controld_remote_ra.c crm_debug("Remote connection event matched %s action", cmd->action); cmd 632 daemons/controld/controld_remote_ra.c report_remote_ra_result(cmd); cmd 635 daemons/controld/controld_remote_ra.c } else if (op->type == lrmd_event_poke && pcmk__str_eq(cmd->action, "monitor", pcmk__str_casei)) { cmd 637 daemons/controld/controld_remote_ra.c if (cmd->monitor_timeout_id) { cmd 638 daemons/controld/controld_remote_ra.c g_source_remove(cmd->monitor_timeout_id); cmd 639 daemons/controld/controld_remote_ra.c cmd->monitor_timeout_id = 0; cmd 645 daemons/controld/controld_remote_ra.c if (!cmd->reported_success) { cmd 646 daemons/controld/controld_remote_ra.c cmd->rc = PCMK_OCF_OK; cmd 647 daemons/controld/controld_remote_ra.c cmd->op_status = PCMK_LRM_OP_DONE; cmd 648 daemons/controld/controld_remote_ra.c report_remote_ra_result(cmd); cmd 649 daemons/controld/controld_remote_ra.c cmd->reported_success = 1; cmd 652 daemons/controld/controld_remote_ra.c crm_debug("Remote poke event matched %s action", cmd->action); cmd 655 daemons/controld/controld_remote_ra.c if (cmd->interval_ms && (cmd->cancel == FALSE)) { cmd 656 daemons/controld/controld_remote_ra.c ra_data->recurring_cmds = g_list_append(ra_data->recurring_cmds, cmd); cmd 657 daemons/controld/controld_remote_ra.c cmd->interval_id = g_timeout_add(cmd->interval_ms, cmd 658 daemons/controld/controld_remote_ra.c recurring_helper, cmd); cmd 659 daemons/controld/controld_remote_ra.c cmd = NULL; /* prevent free */ cmd 663 daemons/controld/controld_remote_ra.c } else if (op->type == lrmd_event_disconnect && pcmk__str_eq(cmd->action, "monitor", pcmk__str_casei)) { cmd 664 daemons/controld/controld_remote_ra.c if (ra_data->active == TRUE && (cmd->cancel == FALSE)) { cmd 665 daemons/controld/controld_remote_ra.c cmd->rc = PCMK_OCF_UNKNOWN_ERROR; cmd 666 daemons/controld/controld_remote_ra.c cmd->op_status = PCMK_LRM_OP_ERROR; cmd 667 daemons/controld/controld_remote_ra.c report_remote_ra_result(cmd); cmd 673 daemons/controld/controld_remote_ra.c } else if (op->type == lrmd_event_new_client && pcmk__str_eq(cmd->action, "stop", pcmk__str_casei)) { cmd 675 daemons/controld/controld_remote_ra.c handle_remote_ra_stop(lrm_state, cmd); cmd 687 daemons/controld/controld_remote_ra.c free_cmd(cmd); cmd 692 daemons/controld/controld_remote_ra.c handle_remote_ra_stop(lrm_state_t * lrm_state, remote_ra_cmd_t * cmd) cmd 721 daemons/controld/controld_remote_ra.c if (cmd) { cmd 722 daemons/controld/controld_remote_ra.c cmd->rc = PCMK_OCF_OK; cmd 723 daemons/controld/controld_remote_ra.c cmd->op_status = PCMK_LRM_OP_DONE; cmd 725 daemons/controld/controld_remote_ra.c report_remote_ra_result(cmd); cmd 730 daemons/controld/controld_remote_ra.c handle_remote_ra_start(lrm_state_t * lrm_state, remote_ra_cmd_t * cmd, int timeout_ms) cmd 738 daemons/controld/controld_remote_ra.c for (tmp = cmd->params; tmp; tmp = tmp->next) { cmd 758 daemons/controld/controld_remote_ra.c remote_ra_cmd_t *cmd; cmd 768 daemons/controld/controld_remote_ra.c cmd = first->data; cmd 769 daemons/controld/controld_remote_ra.c if (cmd->delay_id) { cmd 777 daemons/controld/controld_remote_ra.c if (!strcmp(cmd->action, "start") || !strcmp(cmd->action, "migrate_from")) { cmd 779 daemons/controld/controld_remote_ra.c rc = handle_remote_ra_start(lrm_state, cmd, cmd->timeout); cmd 783 daemons/controld/controld_remote_ra.c cmd->action); cmd 784 daemons/controld/controld_remote_ra.c ra_data->cur_cmd = cmd; cmd 788 daemons/controld/controld_remote_ra.c cmd->action); cmd 789 daemons/controld/controld_remote_ra.c cmd->rc = PCMK_OCF_UNKNOWN_ERROR; cmd 790 daemons/controld/controld_remote_ra.c cmd->op_status = PCMK_LRM_OP_ERROR; cmd 792 daemons/controld/controld_remote_ra.c report_remote_ra_result(cmd); cmd 794 daemons/controld/controld_remote_ra.c } else if (!strcmp(cmd->action, "monitor")) { cmd 799 daemons/controld/controld_remote_ra.c cmd->rc = PCMK_OCF_UNKNOWN_ERROR; cmd 800 daemons/controld/controld_remote_ra.c cmd->op_status = PCMK_LRM_OP_ERROR; cmd 804 daemons/controld/controld_remote_ra.c cmd->op_status = PCMK_LRM_OP_DONE; cmd 805 daemons/controld/controld_remote_ra.c cmd->rc = PCMK_OCF_NOT_RUNNING; cmd 810 daemons/controld/controld_remote_ra.c cmd->rsc_id); cmd 811 daemons/controld/controld_remote_ra.c ra_data->cur_cmd = cmd; cmd 812 daemons/controld/controld_remote_ra.c cmd->monitor_timeout_id = g_timeout_add(cmd->timeout, monitor_timeout_cb, cmd); cmd 815 daemons/controld/controld_remote_ra.c report_remote_ra_result(cmd); cmd 817 daemons/controld/controld_remote_ra.c } else if (!strcmp(cmd->action, "stop")) { cmd 826 daemons/controld/controld_remote_ra.c cmd->takeover_timeout_id = g_timeout_add((cmd->timeout/2), connection_takeover_timeout_cb, cmd); cmd 827 daemons/controld/controld_remote_ra.c ra_data->cur_cmd = cmd; cmd 831 daemons/controld/controld_remote_ra.c handle_remote_ra_stop(lrm_state, cmd); cmd 833 daemons/controld/controld_remote_ra.c } else if (!strcmp(cmd->action, "migrate_to")) { cmd 835 daemons/controld/controld_remote_ra.c cmd->rc = PCMK_OCF_OK; cmd 836 daemons/controld/controld_remote_ra.c cmd->op_status = PCMK_LRM_OP_DONE; cmd 837 daemons/controld/controld_remote_ra.c report_remote_ra_result(cmd); cmd 838 daemons/controld/controld_remote_ra.c } else if (!strcmp(cmd->action, "reload")) { cmd 840 daemons/controld/controld_remote_ra.c cmd->rc = PCMK_OCF_OK; cmd 841 daemons/controld/controld_remote_ra.c cmd->op_status = PCMK_LRM_OP_DONE; cmd 842 daemons/controld/controld_remote_ra.c report_remote_ra_result(cmd); cmd 845 daemons/controld/controld_remote_ra.c free_cmd(cmd); cmd 936 daemons/controld/controld_remote_ra.c remote_ra_cmd_t *cmd = NULL; cmd 940 daemons/controld/controld_remote_ra.c cmd = gIter->data; cmd 941 daemons/controld/controld_remote_ra.c if ((cmd->interval_ms > 0) && pcmk__str_eq(cmd->action, "monitor", pcmk__str_casei)) { cmd 942 daemons/controld/controld_remote_ra.c rm_list = g_list_append(rm_list, cmd); cmd 947 daemons/controld/controld_remote_ra.c cmd = gIter->data; cmd 949 daemons/controld/controld_remote_ra.c cmd->rc = PCMK_OCF_UNKNOWN_ERROR; cmd 950 daemons/controld/controld_remote_ra.c cmd->op_status = PCMK_LRM_OP_ERROR; cmd 952 daemons/controld/controld_remote_ra.c cmd->action, cmd->rsc_id, cmd->interval_ms, cmd->userdata); cmd 953 daemons/controld/controld_remote_ra.c report_remote_ra_result(cmd); cmd 955 daemons/controld/controld_remote_ra.c list = g_list_remove(list, cmd); cmd 956 daemons/controld/controld_remote_ra.c free_cmd(cmd); cmd 967 daemons/controld/controld_remote_ra.c remote_ra_cmd_t *cmd = NULL; cmd 971 daemons/controld/controld_remote_ra.c cmd = gIter->data; cmd 972 daemons/controld/controld_remote_ra.c if ((cmd->interval_ms == interval_ms) cmd 973 daemons/controld/controld_remote_ra.c && pcmk__str_eq(cmd->action, action, pcmk__str_casei)) { cmd 976 daemons/controld/controld_remote_ra.c cmd = NULL; cmd 978 daemons/controld/controld_remote_ra.c if (cmd) { cmd 979 daemons/controld/controld_remote_ra.c list = g_list_remove(list, cmd); cmd 980 daemons/controld/controld_remote_ra.c free_cmd(cmd); cmd 1016 daemons/controld/controld_remote_ra.c remote_ra_cmd_t *cmd = NULL; cmd 1033 daemons/controld/controld_remote_ra.c cmd = ra_data->cur_cmd; cmd 1038 daemons/controld/controld_remote_ra.c cmd = gIter->data; cmd 1039 daemons/controld/controld_remote_ra.c if ((cmd->interval_ms == interval_ms) cmd 1040 daemons/controld/controld_remote_ra.c && pcmk__str_eq(cmd->action, "monitor", pcmk__str_casei)) { cmd 1046 daemons/controld/controld_remote_ra.c cmd = gIter->data; cmd 1047 daemons/controld/controld_remote_ra.c if ((cmd->interval_ms == interval_ms) cmd 1048 daemons/controld/controld_remote_ra.c && pcmk__str_eq(cmd->action, "monitor", pcmk__str_casei)) { cmd 1058 daemons/controld/controld_remote_ra.c cmd->rsc_id, "monitor", interval_ms); cmd 1062 daemons/controld/controld_remote_ra.c free(cmd->userdata); cmd 1063 daemons/controld/controld_remote_ra.c cmd->userdata = strdup(userdata); cmd 1067 daemons/controld/controld_remote_ra.c if (cmd->reported_success) { cmd 1068 daemons/controld/controld_remote_ra.c cmd->start_time = time(NULL); cmd 1069 daemons/controld/controld_remote_ra.c cmd->call_id = generate_callid(); cmd 1070 daemons/controld/controld_remote_ra.c cmd->reported_success = 0; cmd 1076 daemons/controld/controld_remote_ra.c if (cmd->interval_id) { cmd 1077 daemons/controld/controld_remote_ra.c g_source_remove(cmd->interval_id); cmd 1078 daemons/controld/controld_remote_ra.c cmd->interval_id = 0; cmd 1079 daemons/controld/controld_remote_ra.c recurring_helper(cmd); cmd 1082 daemons/controld/controld_remote_ra.c return cmd; cmd 1094 daemons/controld/controld_remote_ra.c remote_ra_cmd_t *cmd = NULL; cmd 1111 daemons/controld/controld_remote_ra.c cmd = handle_dup_monitor(ra_data, interval_ms, userdata); cmd 1112 daemons/controld/controld_remote_ra.c if (cmd) { cmd 1113 daemons/controld/controld_remote_ra.c rc = cmd->call_id; cmd 1117 daemons/controld/controld_remote_ra.c cmd = calloc(1, sizeof(remote_ra_cmd_t)); cmd 1118 daemons/controld/controld_remote_ra.c cmd->owner = strdup(lrm_state->node_name); cmd 1119 daemons/controld/controld_remote_ra.c cmd->rsc_id = strdup(rsc_id); cmd 1120 daemons/controld/controld_remote_ra.c cmd->action = strdup(action); cmd 1121 daemons/controld/controld_remote_ra.c cmd->userdata = strdup(userdata); cmd 1122 daemons/controld/controld_remote_ra.c cmd->interval_ms = interval_ms; cmd 1123 daemons/controld/controld_remote_ra.c cmd->timeout = timeout; cmd 1124 daemons/controld/controld_remote_ra.c cmd->start_delay = start_delay; cmd 1125 daemons/controld/controld_remote_ra.c cmd->params = params; cmd 1126 daemons/controld/controld_remote_ra.c cmd->start_time = time(NULL); cmd 1128 daemons/controld/controld_remote_ra.c cmd->call_id = generate_callid(); cmd 1130 daemons/controld/controld_remote_ra.c if (cmd->start_delay) { cmd 1131 daemons/controld/controld_remote_ra.c cmd->delay_id = g_timeout_add(cmd->start_delay, start_delay_helper, cmd); cmd 1134 daemons/controld/controld_remote_ra.c ra_data->cmds = g_list_append(ra_data->cmds, cmd); cmd 1137 daemons/controld/controld_remote_ra.c return cmd->call_id; cmd 175 daemons/controld/controld_schedulerd.c pe_subsystem_send(xmlNode *cmd) cmd 178 daemons/controld/controld_schedulerd.c int sent = crm_ipc_send(mainloop_get_ipc_client(pe_subsystem), cmd, cmd 410 daemons/controld/controld_schedulerd.c xmlNode *cmd = NULL; cmd 457 daemons/controld/controld_schedulerd.c cmd = create_request(CRM_OP_PECALC, output, NULL, CRM_SYSTEM_PENGINE, CRM_SYSTEM_DC, NULL); cmd 459 daemons/controld/controld_schedulerd.c rc = pe_subsystem_send(cmd); cmd 465 daemons/controld/controld_schedulerd.c controld_expect_sched_reply(cmd); cmd 469 daemons/controld/controld_schedulerd.c free_xml(cmd); cmd 52 daemons/controld/controld_te_actions.c xmlNode *cmd = NULL; cmd 58 daemons/controld/controld_te_actions.c cmd = create_request(task, pseudo->xml, node->uname, cmd 60 daemons/controld/controld_te_actions.c send_cluster_message(node, crm_msg_crmd, cmd, FALSE); cmd 61 daemons/controld/controld_te_actions.c free_xml(cmd); cmd 91 daemons/controld/controld_te_actions.c xmlNode *cmd = NULL; cmd 149 daemons/controld/controld_te_actions.c cmd = create_request(task, action->xml, router_node, CRM_SYSTEM_CRMD, CRM_SYSTEM_TENGINE, NULL); cmd 153 daemons/controld/controld_te_actions.c crm_xml_add(cmd, XML_ATTR_TRANSITION_KEY, counter); cmd 155 daemons/controld/controld_te_actions.c rc = send_cluster_message(crm_get_peer(0, router_node), crm_msg_crmd, cmd, TRUE); cmd 157 daemons/controld/controld_te_actions.c free_xml(cmd); cmd 274 daemons/controld/controld_te_actions.c xmlNode *cmd = NULL; cmd 324 daemons/controld/controld_te_actions.c cmd = create_request(CRM_OP_INVOKE_LRM, rsc_op, router_node, cmd 330 daemons/controld/controld_te_actions.c .msg = cmd, cmd 347 daemons/controld/controld_te_actions.c rc = send_cluster_message(crm_get_peer(0, router_node), crm_msg_lrmd, cmd, TRUE); cmd 351 daemons/controld/controld_te_actions.c free_xml(cmd); cmd 30 daemons/controld/pacemaker-controld.c void usage(const char *cmd, int exit_status); cmd 101 daemons/execd/execd_commands.c static void cmd_finalize(lrmd_cmd_t * cmd, lrmd_rsc_t * rsc); cmd 189 daemons/execd/execd_commands.c cmd_original_times(lrmd_cmd_t * cmd) cmd 191 daemons/execd/execd_commands.c cmd->t_run = cmd->t_first_run; cmd 192 daemons/execd/execd_commands.c cmd->t_queue = cmd->t_first_queue; cmd 197 daemons/execd/execd_commands.c log_finished(lrmd_cmd_t * cmd, int exec_time, int queue_time) cmd 202 daemons/execd/execd_commands.c if (cmd->last_pid) { cmd 203 daemons/execd/execd_commands.c snprintf(pid_str, 32, "%d", cmd->last_pid); cmd 206 daemons/execd/execd_commands.c if (pcmk__str_eq(cmd->action, "monitor", pcmk__str_casei)) { cmd 212 daemons/execd/execd_commands.c cmd->rsc_id, cmd->action, cmd->call_id, cmd 213 daemons/execd/execd_commands.c (cmd->last_pid? ", PID " : ""), pid_str, cmd->exec_rc, cmd 217 daemons/execd/execd_commands.c cmd->rsc_id, cmd->action, cmd->call_id, cmd 218 daemons/execd/execd_commands.c (cmd->last_pid? ", PID " : ""), pid_str, cmd->exec_rc); cmd 223 daemons/execd/execd_commands.c log_execute(lrmd_cmd_t * cmd) cmd 227 daemons/execd/execd_commands.c if (pcmk__str_eq(cmd->action, "monitor", pcmk__str_casei)) { cmd 232 daemons/execd/execd_commands.c cmd->rsc_id, cmd->action, cmd->call_id); cmd 269 daemons/execd/execd_commands.c lrmd_cmd_t *cmd = NULL; cmd 271 daemons/execd/execd_commands.c cmd = calloc(1, sizeof(lrmd_cmd_t)); cmd 274 daemons/execd/execd_commands.c cmd->call_opts = call_options; cmd 275 daemons/execd/execd_commands.c cmd->client_id = strdup(client->id); cmd 277 daemons/execd/execd_commands.c crm_element_value_int(msg, F_LRMD_CALLID, &cmd->call_id); cmd 278 daemons/execd/execd_commands.c crm_element_value_ms(rsc_xml, F_LRMD_RSC_INTERVAL, &cmd->interval_ms); cmd 279 daemons/execd/execd_commands.c crm_element_value_int(rsc_xml, F_LRMD_TIMEOUT, &cmd->timeout); cmd 280 daemons/execd/execd_commands.c crm_element_value_int(rsc_xml, F_LRMD_RSC_START_DELAY, &cmd->start_delay); cmd 281 daemons/execd/execd_commands.c cmd->timeout_orig = cmd->timeout; cmd 283 daemons/execd/execd_commands.c cmd->origin = crm_element_value_copy(rsc_xml, F_LRMD_ORIGIN); cmd 284 daemons/execd/execd_commands.c cmd->action = crm_element_value_copy(rsc_xml, F_LRMD_RSC_ACTION); cmd 285 daemons/execd/execd_commands.c cmd->userdata_str = crm_element_value_copy(rsc_xml, F_LRMD_RSC_USERDATA_STR); cmd 286 daemons/execd/execd_commands.c cmd->rsc_id = crm_element_value_copy(rsc_xml, F_LRMD_RSC_ID); cmd 288 daemons/execd/execd_commands.c cmd->params = xml2list(rsc_xml); cmd 290 daemons/execd/execd_commands.c if (pcmk__str_eq(g_hash_table_lookup(cmd->params, "CRM_meta_on_fail"), "block", pcmk__str_casei)) { cmd 293 daemons/execd/execd_commands.c cmd->rsc_id, cmd->action, cmd->interval_ms); cmd 294 daemons/execd/execd_commands.c cmd->service_flags = pcmk__set_flags_as(__func__, __LINE__, cmd 296 daemons/execd/execd_commands.c cmd->action, 0, cmd 300 daemons/execd/execd_commands.c return cmd; cmd 304 daemons/execd/execd_commands.c stop_recurring_timer(lrmd_cmd_t *cmd) cmd 306 daemons/execd/execd_commands.c if (cmd) { cmd 307 daemons/execd/execd_commands.c if (cmd->stonith_recurring_id) { cmd 308 daemons/execd/execd_commands.c g_source_remove(cmd->stonith_recurring_id); cmd 310 daemons/execd/execd_commands.c cmd->stonith_recurring_id = 0; cmd 315 daemons/execd/execd_commands.c free_lrmd_cmd(lrmd_cmd_t * cmd) cmd 317 daemons/execd/execd_commands.c stop_recurring_timer(cmd); cmd 318 daemons/execd/execd_commands.c if (cmd->delay_id) { cmd 319 daemons/execd/execd_commands.c g_source_remove(cmd->delay_id); cmd 321 daemons/execd/execd_commands.c if (cmd->params) { cmd 322 daemons/execd/execd_commands.c g_hash_table_destroy(cmd->params); cmd 324 daemons/execd/execd_commands.c free(cmd->origin); cmd 325 daemons/execd/execd_commands.c free(cmd->action); cmd 326 daemons/execd/execd_commands.c free(cmd->real_action); cmd 327 daemons/execd/execd_commands.c free(cmd->userdata_str); cmd 328 daemons/execd/execd_commands.c free(cmd->rsc_id); cmd 329 daemons/execd/execd_commands.c free(cmd->output); cmd 330 daemons/execd/execd_commands.c free(cmd->exit_reason); cmd 331 daemons/execd/execd_commands.c free(cmd->client_id); cmd 332 daemons/execd/execd_commands.c free(cmd); cmd 338 daemons/execd/execd_commands.c lrmd_cmd_t *cmd = data; cmd 341 daemons/execd/execd_commands.c cmd->stonith_recurring_id = 0; cmd 343 daemons/execd/execd_commands.c if (!cmd->rsc_id) { cmd 347 daemons/execd/execd_commands.c rsc = g_hash_table_lookup(rsc_list, cmd->rsc_id); cmd 352 daemons/execd/execd_commands.c rsc->recurring_ops = g_list_remove(rsc->recurring_ops, cmd); cmd 353 daemons/execd/execd_commands.c rsc->pending_ops = g_list_append(rsc->pending_ops, cmd); cmd 355 daemons/execd/execd_commands.c get_current_time(&(cmd->t_queue), &(cmd->t_first_queue)); cmd 363 daemons/execd/execd_commands.c start_recurring_timer(lrmd_cmd_t *cmd) cmd 365 daemons/execd/execd_commands.c if (cmd && (cmd->interval_ms > 0)) { cmd 366 daemons/execd/execd_commands.c cmd->stonith_recurring_id = g_timeout_add(cmd->interval_ms, cmd 368 daemons/execd/execd_commands.c cmd); cmd 375 daemons/execd/execd_commands.c lrmd_cmd_t *cmd = data; cmd 378 daemons/execd/execd_commands.c cmd->delay_id = 0; cmd 379 daemons/execd/execd_commands.c rsc = cmd->rsc_id ? g_hash_table_lookup(rsc_list, cmd->rsc_id) : NULL; cmd 389 daemons/execd/execd_commands.c merge_recurring_duplicate(lrmd_rsc_t * rsc, lrmd_cmd_t * cmd) cmd 395 daemons/execd/execd_commands.c if (cmd->interval_ms == 0) { cmd 401 daemons/execd/execd_commands.c if (pcmk__str_eq(cmd->action, dup->action, pcmk__str_casei) cmd 402 daemons/execd/execd_commands.c && (cmd->interval_ms == dup->interval_ms)) { cmd 412 daemons/execd/execd_commands.c if (pcmk__str_eq(cmd->action, dup->action, pcmk__str_casei) cmd 413 daemons/execd/execd_commands.c && (cmd->interval_ms == dup->interval_ms)) { cmd 433 daemons/execd/execd_commands.c dup->userdata_str = cmd->userdata_str; cmd 434 daemons/execd/execd_commands.c cmd->userdata_str = NULL; cmd 435 daemons/execd/execd_commands.c dup->call_id = cmd->call_id; cmd 440 daemons/execd/execd_commands.c stop_recurring_timer(cmd); cmd 441 daemons/execd/execd_commands.c stonith_recurring_op_helper(cmd); cmd 450 daemons/execd/execd_commands.c free_lrmd_cmd(cmd); cmd 456 daemons/execd/execd_commands.c schedule_lrmd_cmd(lrmd_rsc_t * rsc, lrmd_cmd_t * cmd) cmd 459 daemons/execd/execd_commands.c CRM_CHECK(cmd != NULL, return); cmd 462 daemons/execd/execd_commands.c crm_trace("Scheduling %s on %s", cmd->action, rsc->rsc_id); cmd 464 daemons/execd/execd_commands.c dup_processed = merge_recurring_duplicate(rsc, cmd); cmd 473 daemons/execd/execd_commands.c if (pcmk__str_eq(cmd->action, "stop", pcmk__str_casei)) { cmd 477 daemons/execd/execd_commands.c rsc->pending_ops = g_list_append(rsc->pending_ops, cmd); cmd 479 daemons/execd/execd_commands.c get_current_time(&(cmd->t_queue), &(cmd->t_first_queue)); cmd 483 daemons/execd/execd_commands.c if (cmd->start_delay) { cmd 484 daemons/execd/execd_commands.c cmd->delay_id = g_timeout_add(cmd->start_delay, start_delay_helper, cmd); cmd 545 daemons/execd/execd_commands.c send_cmd_complete_notify(lrmd_cmd_t * cmd) cmd 550 daemons/execd/execd_commands.c int exec_time = time_diff_ms(NULL, &(cmd->t_run)); cmd 551 daemons/execd/execd_commands.c int queue_time = time_diff_ms(&cmd->t_run, &(cmd->t_queue)); cmd 553 daemons/execd/execd_commands.c log_finished(cmd, exec_time, queue_time); cmd 555 daemons/execd/execd_commands.c log_finished(cmd, 0, 0); cmd 561 daemons/execd/execd_commands.c if (cmd->first_notify_sent && (cmd->call_opts & lrmd_opt_notify_changes_only)) { cmd 562 daemons/execd/execd_commands.c if (cmd->last_notify_rc == cmd->exec_rc && cmd 563 daemons/execd/execd_commands.c cmd->last_notify_op_status == cmd->lrmd_op_status) { cmd 571 daemons/execd/execd_commands.c cmd->first_notify_sent = 1; cmd 572 daemons/execd/execd_commands.c cmd->last_notify_rc = cmd->exec_rc; cmd 573 daemons/execd/execd_commands.c cmd->last_notify_op_status = cmd->lrmd_op_status; cmd 578 daemons/execd/execd_commands.c crm_xml_add_int(notify, F_LRMD_TIMEOUT, cmd->timeout); cmd 579 daemons/execd/execd_commands.c crm_xml_add_ms(notify, F_LRMD_RSC_INTERVAL, cmd->interval_ms); cmd 580 daemons/execd/execd_commands.c crm_xml_add_int(notify, F_LRMD_RSC_START_DELAY, cmd->start_delay); cmd 581 daemons/execd/execd_commands.c crm_xml_add_int(notify, F_LRMD_EXEC_RC, cmd->exec_rc); cmd 582 daemons/execd/execd_commands.c crm_xml_add_int(notify, F_LRMD_OP_STATUS, cmd->lrmd_op_status); cmd 583 daemons/execd/execd_commands.c crm_xml_add_int(notify, F_LRMD_CALLID, cmd->call_id); cmd 584 daemons/execd/execd_commands.c crm_xml_add_int(notify, F_LRMD_RSC_DELETED, cmd->rsc_deleted); cmd 587 daemons/execd/execd_commands.c (long long) cmd->epoch_last_run); cmd 589 daemons/execd/execd_commands.c (long long) cmd->epoch_rcchange); cmd 596 daemons/execd/execd_commands.c crm_xml_add(notify, F_LRMD_RSC_ID, cmd->rsc_id); cmd 597 daemons/execd/execd_commands.c if(cmd->real_action) { cmd 598 daemons/execd/execd_commands.c crm_xml_add(notify, F_LRMD_RSC_ACTION, cmd->real_action); cmd 600 daemons/execd/execd_commands.c crm_xml_add(notify, F_LRMD_RSC_ACTION, cmd->action); cmd 602 daemons/execd/execd_commands.c crm_xml_add(notify, F_LRMD_RSC_USERDATA_STR, cmd->userdata_str); cmd 603 daemons/execd/execd_commands.c crm_xml_add(notify, F_LRMD_RSC_OUTPUT, cmd->output); cmd 604 daemons/execd/execd_commands.c crm_xml_add(notify, F_LRMD_RSC_EXIT_REASON, cmd->exit_reason); cmd 606 daemons/execd/execd_commands.c if (cmd->params) { cmd 613 daemons/execd/execd_commands.c g_hash_table_iter_init(&iter, cmd->params); cmd 618 daemons/execd/execd_commands.c if (cmd->client_id && (cmd->call_opts & lrmd_opt_notify_orig_only)) { cmd 619 daemons/execd/execd_commands.c pcmk__client_t *client = pcmk__find_client_by_id(cmd->client_id); cmd 657 daemons/execd/execd_commands.c cmd_reset(lrmd_cmd_t * cmd) cmd 659 daemons/execd/execd_commands.c cmd->lrmd_op_status = 0; cmd 660 daemons/execd/execd_commands.c cmd->last_pid = 0; cmd 662 daemons/execd/execd_commands.c memset(&cmd->t_run, 0, sizeof(cmd->t_run)); cmd 663 daemons/execd/execd_commands.c memset(&cmd->t_queue, 0, sizeof(cmd->t_queue)); cmd 665 daemons/execd/execd_commands.c cmd->epoch_last_run = 0; cmd 666 daemons/execd/execd_commands.c free(cmd->exit_reason); cmd 667 daemons/execd/execd_commands.c cmd->exit_reason = NULL; cmd 668 daemons/execd/execd_commands.c free(cmd->output); cmd 669 daemons/execd/execd_commands.c cmd->output = NULL; cmd 673 daemons/execd/execd_commands.c cmd_finalize(lrmd_cmd_t * cmd, lrmd_rsc_t * rsc) cmd 675 daemons/execd/execd_commands.c crm_trace("Resource operation rsc:%s action:%s completed (%p %p)", cmd->rsc_id, cmd->action, cmd 676 daemons/execd/execd_commands.c rsc ? rsc->active : NULL, cmd); cmd 678 daemons/execd/execd_commands.c if (rsc && (rsc->active == cmd)) { cmd 684 daemons/execd/execd_commands.c cmd->rsc_deleted = 1; cmd 688 daemons/execd/execd_commands.c cmd->timeout = cmd->timeout_orig; cmd 690 daemons/execd/execd_commands.c send_cmd_complete_notify(cmd); cmd 692 daemons/execd/execd_commands.c if (cmd->interval_ms && (cmd->lrmd_op_status == PCMK_LRM_OP_CANCELLED)) { cmd 694 daemons/execd/execd_commands.c rsc->recurring_ops = g_list_remove(rsc->recurring_ops, cmd); cmd 695 daemons/execd/execd_commands.c rsc->pending_ops = g_list_remove(rsc->pending_ops, cmd); cmd 697 daemons/execd/execd_commands.c free_lrmd_cmd(cmd); cmd 698 daemons/execd/execd_commands.c } else if (cmd->interval_ms == 0) { cmd 700 daemons/execd/execd_commands.c rsc->pending_ops = g_list_remove(rsc->pending_ops, cmd); cmd 702 daemons/execd/execd_commands.c free_lrmd_cmd(cmd); cmd 705 daemons/execd/execd_commands.c cmd_reset(cmd); cmd 811 daemons/execd/execd_commands.c lrmd_cmd_t *cmd = action->cb_data; cmd 812 daemons/execd/execd_commands.c return get_uniform_rc(action->standard, cmd->action, action->rc); cmd 900 daemons/execd/execd_commands.c lrmd_cmd_t *cmd = action->cb_data; cmd 907 daemons/execd/execd_commands.c if (!cmd) { cmd 914 daemons/execd/execd_commands.c if (cmd->exec_rc != action->rc) { cmd 915 daemons/execd/execd_commands.c cmd->epoch_rcchange = time(NULL); cmd 919 daemons/execd/execd_commands.c cmd->last_pid = action->pid; cmd 920 daemons/execd/execd_commands.c cmd->exec_rc = action_get_uniform_rc(action); cmd 921 daemons/execd/execd_commands.c cmd->lrmd_op_status = action->status; cmd 922 daemons/execd/execd_commands.c rsc = cmd->rsc_id ? g_hash_table_lookup(rsc_list, cmd->rsc_id) : NULL; cmd 932 daemons/execd/execd_commands.c if ((cmd->exec_rc == PCMK_OCF_OK) cmd 933 daemons/execd/execd_commands.c && pcmk__strcase_any_of(cmd->action, "start", "stop", NULL)) { cmd 940 daemons/execd/execd_commands.c cmd->real_action = cmd->action; cmd 941 daemons/execd/execd_commands.c cmd->action = strdup("monitor"); cmd 943 daemons/execd/execd_commands.c } else if (cmd->real_action != NULL) { cmd 945 daemons/execd/execd_commands.c if ((cmd->lrmd_op_status == PCMK_LRM_OP_DONE) cmd 946 daemons/execd/execd_commands.c && (cmd->exec_rc == PCMK_OCF_PENDING)) { cmd 949 daemons/execd/execd_commands.c } else if ((cmd->exec_rc == PCMK_OCF_OK) cmd 950 daemons/execd/execd_commands.c && pcmk__str_eq(cmd->real_action, "stop", pcmk__str_casei)) { cmd 954 daemons/execd/execd_commands.c int time_sum = time_diff_ms(NULL, &(cmd->t_first_run)); cmd 955 daemons/execd/execd_commands.c int timeout_left = cmd->timeout_orig - time_sum; cmd 959 daemons/execd/execd_commands.c cmd->rsc_id, cmd->real_action, time_sum, timeout_left, cmd 960 daemons/execd/execd_commands.c services_ocf_exitcode_str(cmd->exec_rc), cmd 961 daemons/execd/execd_commands.c cmd->exec_rc); cmd 962 daemons/execd/execd_commands.c cmd_original_times(cmd); cmd 965 daemons/execd/execd_commands.c if ((cmd->lrmd_op_status == PCMK_LRM_OP_DONE) cmd 966 daemons/execd/execd_commands.c && (cmd->exec_rc == PCMK_OCF_NOT_RUNNING)) { cmd 968 daemons/execd/execd_commands.c if (pcmk__str_eq(cmd->real_action, "start", pcmk__str_casei)) { cmd 969 daemons/execd/execd_commands.c cmd->exec_rc = PCMK_OCF_UNKNOWN_ERROR; cmd 970 daemons/execd/execd_commands.c } else if (pcmk__str_eq(cmd->real_action, "stop", pcmk__str_casei)) { cmd 971 daemons/execd/execd_commands.c cmd->exec_rc = PCMK_OCF_OK; cmd 981 daemons/execd/execd_commands.c if (pcmk__str_eq(cmd->action, "monitor", pcmk__str_casei) && cmd 982 daemons/execd/execd_commands.c (cmd->interval_ms == 0) && cmd->exec_rc == PCMK_OCF_OK) { cmd 984 daemons/execd/execd_commands.c cmd->exec_rc = PCMK_OCF_NOT_RUNNING; cmd 986 daemons/execd/execd_commands.c } else if (pcmk__str_eq(cmd->action, "start", pcmk__str_casei) && cmd->exec_rc != PCMK_OCF_OK) { cmd 996 daemons/execd/execd_commands.c int time_sum = time_diff_ms(NULL, &(cmd->t_first_run)); cmd 997 daemons/execd/execd_commands.c int timeout_left = cmd->timeout_orig - time_sum; cmd 998 daemons/execd/execd_commands.c int delay = cmd->timeout_orig / 10; cmd 1006 daemons/execd/execd_commands.c cmd->start_delay = delay; cmd 1007 daemons/execd/execd_commands.c cmd->timeout = timeout_left; cmd 1009 daemons/execd/execd_commands.c if(cmd->exec_rc == PCMK_OCF_OK) { cmd 1011 daemons/execd/execd_commands.c cmd->rsc_id, cmd->real_action, time_sum, timeout_left, delay); cmd 1013 daemons/execd/execd_commands.c } else if(cmd->exec_rc == PCMK_OCF_PENDING) { cmd 1015 daemons/execd/execd_commands.c cmd->rsc_id, cmd->action, time_sum, timeout_left, delay); cmd 1019 daemons/execd/execd_commands.c cmd->rsc_id, cmd->action, services_ocf_exitcode_str(cmd->exec_rc), cmd->exec_rc, time_sum, timeout_left, delay); cmd 1022 daemons/execd/execd_commands.c cmd_reset(cmd); cmd 1026 daemons/execd/execd_commands.c schedule_lrmd_cmd(rsc, cmd); cmd 1033 daemons/execd/execd_commands.c cmd->rsc_id, cmd->real_action?cmd->real_action:cmd->action, cmd->exec_rc, time_sum, timeout_left); cmd 1034 daemons/execd/execd_commands.c cmd->lrmd_op_status = PCMK_LRM_OP_TIMEOUT; cmd 1035 daemons/execd/execd_commands.c cmd->exec_rc = PCMK_OCF_TIMEOUT; cmd 1036 daemons/execd/execd_commands.c cmd_original_times(cmd); cmd 1042 daemons/execd/execd_commands.c cmd->output = strdup(action->stderr_data); cmd 1043 daemons/execd/execd_commands.c cmd->exit_reason = parse_exit_reason(action->stderr_data); cmd 1046 daemons/execd/execd_commands.c cmd->output = strdup(action->stdout_data); cmd 1049 daemons/execd/execd_commands.c cmd_finalize(cmd, rsc); cmd 1103 daemons/execd/execd_commands.c stonith_action_complete(lrmd_cmd_t * cmd, int rc) cmd 1106 daemons/execd/execd_commands.c lrmd_rsc_t *rsc = g_hash_table_lookup(rsc_list, cmd->rsc_id); cmd 1108 daemons/execd/execd_commands.c cmd->exec_rc = stonith2uniform_rc(cmd->action, rc); cmd 1114 daemons/execd/execd_commands.c if (cmd->lrmd_op_status != PCMK_LRM_OP_CANCELLED) { cmd 1115 daemons/execd/execd_commands.c cmd->lrmd_op_status = stonith_rc2status(cmd->action, cmd->interval_ms, cmd 1119 daemons/execd/execd_commands.c if (rsc && (cmd->exec_rc == PCMK_OCF_OK)) { cmd 1120 daemons/execd/execd_commands.c if (pcmk__str_eq(cmd->action, "start", pcmk__str_casei)) { cmd 1122 daemons/execd/execd_commands.c } else if (pcmk__str_eq(cmd->action, "stop", pcmk__str_casei)) { cmd 1131 daemons/execd/execd_commands.c stop_recurring_timer(cmd); cmd 1137 daemons/execd/execd_commands.c if (rsc && (cmd->interval_ms > 0) cmd 1138 daemons/execd/execd_commands.c && (cmd->lrmd_op_status != PCMK_LRM_OP_CANCELLED)) { cmd 1139 daemons/execd/execd_commands.c start_recurring_timer(cmd); cmd 1142 daemons/execd/execd_commands.c cmd_finalize(cmd, rsc); cmd 1214 daemons/execd/execd_commands.c execd_stonith_start(stonith_t *stonith_api, lrmd_rsc_t *rsc, lrmd_cmd_t *cmd) cmd 1222 daemons/execd/execd_commands.c if (cmd->params) { cmd 1225 daemons/execd/execd_commands.c g_hash_table_iter_init(&iter, cmd->params); cmd 1238 daemons/execd/execd_commands.c cmd->rsc_id, rsc->provider, cmd 1278 daemons/execd/execd_commands.c execd_stonith_monitor(stonith_t *stonith_api, lrmd_rsc_t *rsc, lrmd_cmd_t *cmd) cmd 1280 daemons/execd/execd_commands.c int rc = stonith_api->cmds->monitor(stonith_api, 0, cmd->rsc_id, cmd 1281 daemons/execd/execd_commands.c cmd->timeout / 1000); cmd 1283 daemons/execd/execd_commands.c rc = stonith_api->cmds->register_callback(stonith_api, rc, 0, 0, cmd, cmd 1287 daemons/execd/execd_commands.c rsc->active = cmd; cmd 1296 daemons/execd/execd_commands.c lrmd_rsc_execute_stonith(lrmd_rsc_t * rsc, lrmd_cmd_t * cmd) cmd 1306 daemons/execd/execd_commands.c } else if (pcmk__str_eq(cmd->action, "start", pcmk__str_casei)) { cmd 1307 daemons/execd/execd_commands.c rc = execd_stonith_start(stonith_api, rsc, cmd); cmd 1312 daemons/execd/execd_commands.c } else if (pcmk__str_eq(cmd->action, "stop", pcmk__str_casei)) { cmd 1315 daemons/execd/execd_commands.c } else if (pcmk__str_eq(cmd->action, "monitor", pcmk__str_casei)) { cmd 1316 daemons/execd/execd_commands.c if (cmd->interval_ms > 0) { cmd 1324 daemons/execd/execd_commands.c rc = execd_stonith_monitor(stonith_api, rsc, cmd); cmd 1331 daemons/execd/execd_commands.c stonith_action_complete(cmd, rc); cmd 1335 daemons/execd/execd_commands.c lrmd_rsc_execute_service_lib(lrmd_rsc_t * rsc, lrmd_cmd_t * cmd) cmd 1341 daemons/execd/execd_commands.c CRM_ASSERT(cmd); cmd 1344 daemons/execd/execd_commands.c rsc->rsc_id, cmd->action, rsc->class, rsc->provider, rsc->type); cmd 1349 daemons/execd/execd_commands.c && pcmk__str_eq(cmd->action, "stop", pcmk__str_casei)) { cmd 1351 daemons/execd/execd_commands.c cmd->exec_rc = PCMK_OCF_OK; cmd 1356 daemons/execd/execd_commands.c params_copy = crm_str_table_dup(cmd->params); cmd 1360 daemons/execd/execd_commands.c normalize_action_name(rsc, cmd->action), cmd 1361 daemons/execd/execd_commands.c cmd->interval_ms, cmd->timeout, cmd 1362 daemons/execd/execd_commands.c params_copy, cmd->service_flags); cmd 1365 daemons/execd/execd_commands.c crm_err("Failed to create action, action:%s on resource %s", cmd->action, rsc->rsc_id); cmd 1366 daemons/execd/execd_commands.c cmd->lrmd_op_status = PCMK_LRM_OP_ERROR; cmd 1370 daemons/execd/execd_commands.c action->cb_data = cmd; cmd 1382 daemons/execd/execd_commands.c cmd->exec_rc = action->rc; cmd 1384 daemons/execd/execd_commands.c cmd->lrmd_op_status = action->status; cmd 1386 daemons/execd/execd_commands.c cmd->lrmd_op_status = PCMK_LRM_OP_ERROR; cmd 1392 daemons/execd/execd_commands.c cmd_finalize(cmd, rsc); cmd 1399 daemons/execd/execd_commands.c lrmd_cmd_t *cmd = NULL; cmd 1411 daemons/execd/execd_commands.c cmd = first->data; cmd 1412 daemons/execd/execd_commands.c if (cmd->delay_id) { cmd 1415 daemons/execd/execd_commands.c cmd->rsc_id, cmd->action, cmd->start_delay); cmd 1422 daemons/execd/execd_commands.c get_current_time(&(cmd->t_run), &(cmd->t_first_run)); cmd 1424 daemons/execd/execd_commands.c cmd->epoch_last_run = time(NULL); cmd 1427 daemons/execd/execd_commands.c if (!cmd) { cmd 1432 daemons/execd/execd_commands.c rsc->active = cmd; /* only one op at a time for a rsc */ cmd 1433 daemons/execd/execd_commands.c if (cmd->interval_ms) { cmd 1434 daemons/execd/execd_commands.c rsc->recurring_ops = g_list_append(rsc->recurring_ops, cmd); cmd 1437 daemons/execd/execd_commands.c log_execute(cmd); cmd 1440 daemons/execd/execd_commands.c lrmd_rsc_execute_stonith(rsc, cmd); cmd 1442 daemons/execd/execd_commands.c lrmd_rsc_execute_service_lib(rsc, cmd); cmd 1465 daemons/execd/execd_commands.c lrmd_cmd_t *cmd = gIter->data; cmd 1468 daemons/execd/execd_commands.c cmd->lrmd_op_status = PCMK_LRM_OP_CANCELLED; cmd 1469 daemons/execd/execd_commands.c cmd_finalize(cmd, NULL); cmd 1479 daemons/execd/execd_commands.c lrmd_cmd_t *cmd = gIter->data; cmd 1482 daemons/execd/execd_commands.c cmd->lrmd_op_status = PCMK_LRM_OP_CANCELLED; cmd 1487 daemons/execd/execd_commands.c if (rsc->active != cmd) { cmd 1488 daemons/execd/execd_commands.c cmd_finalize(cmd, NULL); cmd 1496 daemons/execd/execd_commands.c normalize_action_name(rsc, cmd->action), cmd 1497 daemons/execd/execd_commands.c cmd->interval_ms); cmd 1635 daemons/execd/execd_commands.c lrmd_cmd_t *cmd = NULL; cmd 1649 daemons/execd/execd_commands.c cmd = create_lrmd_cmd(request, client); cmd 1650 daemons/execd/execd_commands.c call_id = cmd->call_id; cmd 1654 daemons/execd/execd_commands.c schedule_lrmd_cmd(rsc, cmd); cmd 1681 daemons/execd/execd_commands.c lrmd_cmd_t *cmd = gIter->data; cmd 1683 daemons/execd/execd_commands.c if (pcmk__str_eq(cmd->action, action, pcmk__str_casei) cmd 1684 daemons/execd/execd_commands.c && (cmd->interval_ms == interval_ms)) { cmd 1686 daemons/execd/execd_commands.c cmd->lrmd_op_status = PCMK_LRM_OP_CANCELLED; cmd 1687 daemons/execd/execd_commands.c cmd_finalize(cmd, rsc); cmd 1696 daemons/execd/execd_commands.c lrmd_cmd_t *cmd = gIter->data; cmd 1698 daemons/execd/execd_commands.c if (pcmk__str_eq(cmd->action, action, pcmk__str_casei) cmd 1699 daemons/execd/execd_commands.c && (cmd->interval_ms == interval_ms)) { cmd 1701 daemons/execd/execd_commands.c cmd->lrmd_op_status = PCMK_LRM_OP_CANCELLED; cmd 1702 daemons/execd/execd_commands.c if (rsc->active != cmd) { cmd 1703 daemons/execd/execd_commands.c cmd_finalize(cmd, rsc); cmd 1744 daemons/execd/execd_commands.c lrmd_cmd_t *cmd = cmd_iter->data; cmd 1746 daemons/execd/execd_commands.c if (cmd->interval_ms == 0) { cmd 1750 daemons/execd/execd_commands.c if (client_id && !pcmk__str_eq(cmd->client_id, client_id, pcmk__str_casei)) { cmd 1754 daemons/execd/execd_commands.c cancel_op(rsc->rsc_id, cmd->action, cmd->interval_ms); cmd 1784 daemons/execd/execd_commands.c lrmd_cmd_t *cmd = item->data; cmd 1788 daemons/execd/execd_commands.c (cmd->real_action? cmd->real_action : cmd->action)); cmd 1789 daemons/execd/execd_commands.c crm_xml_add_ms(op_xml, F_LRMD_RSC_INTERVAL, cmd->interval_ms); cmd 1790 daemons/execd/execd_commands.c crm_xml_add_int(op_xml, F_LRMD_TIMEOUT, cmd->timeout_orig); cmd 157 daemons/fenced/cts-fence-helper.c #define single_test(cmd, str, num_notifications, expected_rc) \ cmd 160 daemons/fenced/cts-fence-helper.c rc = cmd; \ cmd 111 daemons/fenced/fenced_commands.c static xmlNode *stonith_construct_async_reply(async_command_t * cmd, const char *output, cmd 205 daemons/fenced/fenced_commands.c free_async_command(async_command_t * cmd) cmd 207 daemons/fenced/fenced_commands.c if (!cmd) { cmd 211 daemons/fenced/fenced_commands.c if (cmd->delay_id) { cmd 212 daemons/fenced/fenced_commands.c g_source_remove(cmd->delay_id); cmd 215 daemons/fenced/fenced_commands.c cmd_list = g_list_remove(cmd_list, cmd); cmd 217 daemons/fenced/fenced_commands.c g_list_free_full(cmd->device_list, free); cmd 218 daemons/fenced/fenced_commands.c free(cmd->device); cmd 219 daemons/fenced/fenced_commands.c free(cmd->action); cmd 220 daemons/fenced/fenced_commands.c free(cmd->victim); cmd 221 daemons/fenced/fenced_commands.c free(cmd->remote_op_id); cmd 222 daemons/fenced/fenced_commands.c free(cmd->client); cmd 223 daemons/fenced/fenced_commands.c free(cmd->client_name); cmd 224 daemons/fenced/fenced_commands.c free(cmd->origin); cmd 225 daemons/fenced/fenced_commands.c free(cmd->mode); cmd 226 daemons/fenced/fenced_commands.c free(cmd->op); cmd 227 daemons/fenced/fenced_commands.c free(cmd); cmd 233 daemons/fenced/fenced_commands.c async_command_t *cmd = NULL; cmd 240 daemons/fenced/fenced_commands.c cmd = calloc(1, sizeof(async_command_t)); cmd 241 daemons/fenced/fenced_commands.c crm_element_value_int(msg, F_STONITH_CALLID, &(cmd->id)); cmd 242 daemons/fenced/fenced_commands.c crm_element_value_int(msg, F_STONITH_CALLOPTS, &(cmd->options)); cmd 243 daemons/fenced/fenced_commands.c crm_element_value_int(msg, F_STONITH_TIMEOUT, &(cmd->default_timeout)); cmd 244 daemons/fenced/fenced_commands.c cmd->timeout = cmd->default_timeout; cmd 246 daemons/fenced/fenced_commands.c crm_element_value_int(msg, F_STONITH_DELAY, &(cmd->start_delay)); cmd 248 daemons/fenced/fenced_commands.c cmd->origin = crm_element_value_copy(msg, F_ORIG); cmd 249 daemons/fenced/fenced_commands.c cmd->remote_op_id = crm_element_value_copy(msg, F_STONITH_REMOTE_OP_ID); cmd 250 daemons/fenced/fenced_commands.c cmd->client = crm_element_value_copy(msg, F_STONITH_CLIENTID); cmd 251 daemons/fenced/fenced_commands.c cmd->client_name = crm_element_value_copy(msg, F_STONITH_CLIENTNAME); cmd 252 daemons/fenced/fenced_commands.c cmd->op = crm_element_value_copy(msg, F_STONITH_OPERATION); cmd 253 daemons/fenced/fenced_commands.c cmd->action = strdup(action); cmd 254 daemons/fenced/fenced_commands.c cmd->victim = crm_element_value_copy(op, F_STONITH_TARGET); cmd 255 daemons/fenced/fenced_commands.c cmd->mode = crm_element_value_copy(op, F_STONITH_MODE); cmd 256 daemons/fenced/fenced_commands.c cmd->device = crm_element_value_copy(op, F_STONITH_DEVICE); cmd 258 daemons/fenced/fenced_commands.c CRM_CHECK(cmd->op != NULL, crm_log_xml_warn(msg, "NoOp"); free_async_command(cmd); return NULL); cmd 259 daemons/fenced/fenced_commands.c CRM_CHECK(cmd->client != NULL, crm_log_xml_warn(msg, "NoClient")); cmd 261 daemons/fenced/fenced_commands.c cmd->done_cb = st_child_done; cmd 262 daemons/fenced/fenced_commands.c cmd_list = g_list_append(cmd_list, cmd); cmd 263 daemons/fenced/fenced_commands.c return cmd; cmd 294 daemons/fenced/fenced_commands.c async_command_t *cmd = gIter->data; cmd 298 daemons/fenced/fenced_commands.c if (cmd->active_on == device) { cmd 309 daemons/fenced/fenced_commands.c async_command_t *cmd = (async_command_t *) user_data; cmd 314 daemons/fenced/fenced_commands.c cmd->activating_on?cmd->activating_on:cmd->active_on; cmd 318 daemons/fenced/fenced_commands.c cmd->action, cmd->victim ? " targeting " : "", cmd->victim ? cmd->victim : "", cmd 319 daemons/fenced/fenced_commands.c device->id, pid, cmd->timeout); cmd 320 daemons/fenced/fenced_commands.c cmd->active_on = device; cmd 321 daemons/fenced/fenced_commands.c cmd->activating_on = NULL; cmd 330 daemons/fenced/fenced_commands.c async_command_t *cmd = NULL; cmd 364 daemons/fenced/fenced_commands.c cmd = pending_op; cmd 368 daemons/fenced/fenced_commands.c if (cmd == NULL) { cmd 374 daemons/fenced/fenced_commands.c if(pcmk__str_eq(cmd->action, "reboot", pcmk__str_casei)) { cmd 378 daemons/fenced/fenced_commands.c } else if(pcmk__str_eq(cmd->action, "off", pcmk__str_casei)) { cmd 383 daemons/fenced/fenced_commands.c crm_info("Faking success for %s watchdog operation", cmd->action); cmd 384 daemons/fenced/fenced_commands.c cmd->done_cb(0, 0, NULL, cmd); cmd 392 daemons/fenced/fenced_commands.c if (pcmk__str_eq(cmd->action, "stop", pcmk__str_casei)) { cmd 400 daemons/fenced/fenced_commands.c cmd->done_cb(0, exec_rc, NULL, cmd); cmd 406 daemons/fenced/fenced_commands.c action_str = cmd->action; cmd 407 daemons/fenced/fenced_commands.c if (pcmk__str_eq(cmd->action, "reboot", pcmk__str_casei) cmd 423 daemons/fenced/fenced_commands.c cmd->victim, cmd 424 daemons/fenced/fenced_commands.c cmd->victim_nodeid, cmd 425 daemons/fenced/fenced_commands.c cmd->timeout, device->params, cmd 430 daemons/fenced/fenced_commands.c cmd->activating_on = device; cmd 431 daemons/fenced/fenced_commands.c exec_rc = stonith_action_execute_async(action, (void *)cmd, cmd 432 daemons/fenced/fenced_commands.c cmd->done_cb, fork_cb); cmd 436 daemons/fenced/fenced_commands.c cmd->action, cmd->victim ? " targeting " : "", cmd->victim ? cmd->victim : "", cmd 438 daemons/fenced/fenced_commands.c cmd->activating_on = NULL; cmd 439 daemons/fenced/fenced_commands.c cmd->done_cb(0, exec_rc, NULL, cmd); cmd 461 daemons/fenced/fenced_commands.c async_command_t *cmd = data; cmd 464 daemons/fenced/fenced_commands.c cmd->delay_id = 0; cmd 465 daemons/fenced/fenced_commands.c device = cmd->device ? g_hash_table_lookup(device_list, cmd->device) : NULL; cmd 475 daemons/fenced/fenced_commands.c schedule_stonith_command(async_command_t * cmd, stonith_device_t * device) cmd 479 daemons/fenced/fenced_commands.c int requested_delay = cmd->start_delay; cmd 481 daemons/fenced/fenced_commands.c CRM_CHECK(cmd != NULL, return); cmd 484 daemons/fenced/fenced_commands.c if (cmd->device) { cmd 485 daemons/fenced/fenced_commands.c free(cmd->device); cmd 488 daemons/fenced/fenced_commands.c if (device->include_nodeid && cmd->victim) { cmd 489 daemons/fenced/fenced_commands.c crm_node_t *node = crm_get_peer(0, cmd->victim); cmd 491 daemons/fenced/fenced_commands.c cmd->victim_nodeid = node->id; cmd 494 daemons/fenced/fenced_commands.c cmd->device = strdup(device->id); cmd 495 daemons/fenced/fenced_commands.c cmd->timeout = get_action_timeout(device, cmd->action, cmd->default_timeout); cmd 497 daemons/fenced/fenced_commands.c if (cmd->remote_op_id) { cmd 499 daemons/fenced/fenced_commands.c cmd->action, cmd 500 daemons/fenced/fenced_commands.c cmd->victim ? " targeting " : "", cmd->victim ? cmd->victim : "", cmd 501 daemons/fenced/fenced_commands.c device->id, cmd->origin, cmd->remote_op_id, cmd->timeout); cmd 504 daemons/fenced/fenced_commands.c cmd->action, cmd 505 daemons/fenced/fenced_commands.c cmd->victim ? " targeting " : "", cmd->victim ? cmd->victim : "", cmd 506 daemons/fenced/fenced_commands.c device->id, cmd->client, cmd->timeout); cmd 509 daemons/fenced/fenced_commands.c device->pending_ops = g_list_append(device->pending_ops, cmd); cmd 517 daemons/fenced/fenced_commands.c delay_max = get_action_delay_max(device, cmd->action); cmd 518 daemons/fenced/fenced_commands.c delay_base = get_action_delay_base(device, cmd->action); cmd 525 daemons/fenced/fenced_commands.c delay_base, delay_max, cmd->action, device->id); cmd 530 daemons/fenced/fenced_commands.c cmd->start_delay += cmd 535 daemons/fenced/fenced_commands.c if (cmd->start_delay > 0) { cmd 538 daemons/fenced/fenced_commands.c cmd->action, cmd 539 daemons/fenced/fenced_commands.c cmd->victim ? " targeting " : "", cmd->victim ? cmd->victim : "", cmd 540 daemons/fenced/fenced_commands.c device->id, cmd->start_delay, cmd->timeout, cmd 542 daemons/fenced/fenced_commands.c cmd->delay_id = cmd 543 daemons/fenced/fenced_commands.c g_timeout_add_seconds(cmd->start_delay, start_delay_helper, cmd); cmd 557 daemons/fenced/fenced_commands.c async_command_t *cmd = gIter->data; cmd 559 daemons/fenced/fenced_commands.c crm_warn("Removal of device '%s' purged operation '%s'", device->id, cmd->action); cmd 560 daemons/fenced/fenced_commands.c cmd->done_cb(0, -ENODEV, NULL, cmd); cmd 975 daemons/fenced/fenced_commands.c async_command_t *cmd = NULL; cmd 977 daemons/fenced/fenced_commands.c cmd = calloc(1, sizeof(async_command_t)); cmd 979 daemons/fenced/fenced_commands.c cmd->id = -1; cmd 980 daemons/fenced/fenced_commands.c cmd->default_timeout = timeout ? timeout : 60; cmd 981 daemons/fenced/fenced_commands.c cmd->timeout = cmd->default_timeout; cmd 982 daemons/fenced/fenced_commands.c cmd->action = strdup(action); cmd 983 daemons/fenced/fenced_commands.c cmd->victim = victim ? strdup(victim) : NULL; cmd 984 daemons/fenced/fenced_commands.c cmd->device = strdup(device->id); cmd 985 daemons/fenced/fenced_commands.c cmd->origin = strdup(origin); cmd 986 daemons/fenced/fenced_commands.c cmd->client = strdup(crm_system_name); cmd 987 daemons/fenced/fenced_commands.c cmd->client_name = strdup(crm_system_name); cmd 989 daemons/fenced/fenced_commands.c cmd->internal_user_data = internal_user_data; cmd 990 daemons/fenced/fenced_commands.c cmd->done_cb = done_cb; /* cmd, not internal_user_data, is passed to 'done_cb' as the userdata */ cmd 992 daemons/fenced/fenced_commands.c schedule_stonith_command(cmd, device); cmd 1016 daemons/fenced/fenced_commands.c async_command_t *cmd = user_data; cmd 1017 daemons/fenced/fenced_commands.c struct device_search_s *search = cmd->internal_user_data; cmd 1018 daemons/fenced/fenced_commands.c stonith_device_t *dev = cmd->device ? g_hash_table_lookup(device_list, cmd->device) : NULL; cmd 1021 daemons/fenced/fenced_commands.c free_async_command(cmd); cmd 1047 daemons/fenced/fenced_commands.c async_command_t *cmd = user_data; cmd 1048 daemons/fenced/fenced_commands.c struct device_search_s *search = cmd->internal_user_data; cmd 1049 daemons/fenced/fenced_commands.c stonith_device_t *dev = cmd->device ? g_hash_table_lookup(device_list, cmd->device) : NULL; cmd 1052 daemons/fenced/fenced_commands.c free_async_command(cmd); cmd 1524 daemons/fenced/fenced_commands.c async_command_t *cmd = NULL; cmd 1544 daemons/fenced/fenced_commands.c cmd = create_async_command(msg); cmd 1545 daemons/fenced/fenced_commands.c if (cmd == NULL) { cmd 1549 daemons/fenced/fenced_commands.c schedule_stonith_command(cmd, device); cmd 2023 daemons/fenced/fenced_commands.c log_operation(async_command_t * cmd, int rc, int pid, const char *next, const char *output, gboolean op_merged) cmd 2029 daemons/fenced/fenced_commands.c if (cmd->victim != NULL) { cmd 2032 daemons/fenced/fenced_commands.c cmd->action, pid, cmd->id, cmd->client_name, cmd->victim, cmd 2033 daemons/fenced/fenced_commands.c cmd->device, (op_merged? " (merged)" : ""), cmd 2039 daemons/fenced/fenced_commands.c cmd->action, pid, cmd->device, cmd 2047 daemons/fenced/fenced_commands.c char *prefix = crm_strdup_printf("%s:%d", cmd->device, pid); cmd 2055 daemons/fenced/fenced_commands.c stonith_send_async_reply(async_command_t * cmd, const char *output, int rc, GPid pid, int options) cmd 2060 daemons/fenced/fenced_commands.c reply = stonith_construct_async_reply(cmd, output, NULL, rc); cmd 2062 daemons/fenced/fenced_commands.c if (pcmk__str_eq(cmd->action, "metadata", pcmk__str_casei)) { cmd 2064 daemons/fenced/fenced_commands.c crm_trace("Metadata query for %s", cmd->device); cmd 2067 daemons/fenced/fenced_commands.c } else if (pcmk__str_any_of(cmd->action, "monitor", "list", "status", NULL)) { cmd 2068 daemons/fenced/fenced_commands.c crm_trace("Never broadcast '%s' replies", cmd->action); cmd 2070 daemons/fenced/fenced_commands.c } else if (!stand_alone && pcmk__str_eq(cmd->origin, cmd->victim, pcmk__str_casei) && !pcmk__str_eq(cmd->action, "on", pcmk__str_casei)) { cmd 2071 daemons/fenced/fenced_commands.c crm_trace("Broadcast '%s' reply for %s", cmd->action, cmd->victim); cmd 2076 daemons/fenced/fenced_commands.c log_operation(cmd, rc, pid, NULL, output, (options & st_reply_opt_merged ? TRUE : FALSE)); cmd 2087 daemons/fenced/fenced_commands.c } else if (cmd->origin) { cmd 2088 daemons/fenced/fenced_commands.c crm_trace("Directed reply to %s", cmd->origin); cmd 2089 daemons/fenced/fenced_commands.c send_cluster_message(crm_get_peer(0, cmd->origin), crm_msg_stonith_ng, reply, FALSE); cmd 2093 daemons/fenced/fenced_commands.c (cmd->options & st_opt_sync_call) ? "" : "a-", cmd->client_name); cmd 2094 daemons/fenced/fenced_commands.c do_local_reply(reply, cmd->client, cmd->options & st_opt_sync_call, FALSE); cmd 2102 daemons/fenced/fenced_commands.c crm_xml_add(notify_data, F_STONITH_TARGET, cmd->victim); cmd 2103 daemons/fenced/fenced_commands.c crm_xml_add(notify_data, F_STONITH_OPERATION, cmd->op); cmd 2105 daemons/fenced/fenced_commands.c crm_xml_add(notify_data, F_STONITH_DEVICE, cmd->device); cmd 2106 daemons/fenced/fenced_commands.c crm_xml_add(notify_data, F_STONITH_REMOTE_OP_ID, cmd->remote_op_id); cmd 2107 daemons/fenced/fenced_commands.c crm_xml_add(notify_data, F_STONITH_ORIGIN, cmd->client); cmd 2117 daemons/fenced/fenced_commands.c cancel_stonith_command(async_command_t * cmd) cmd 2121 daemons/fenced/fenced_commands.c CRM_CHECK(cmd != NULL, return); cmd 2123 daemons/fenced/fenced_commands.c if (!cmd->device) { cmd 2127 daemons/fenced/fenced_commands.c device = g_hash_table_lookup(device_list, cmd->device); cmd 2130 daemons/fenced/fenced_commands.c crm_trace("Cancel scheduled '%s' action on %s", cmd->action, device->id); cmd 2131 daemons/fenced/fenced_commands.c device->pending_ops = g_list_remove(device->pending_ops, cmd); cmd 2140 daemons/fenced/fenced_commands.c async_command_t *cmd = user_data; cmd 2145 daemons/fenced/fenced_commands.c CRM_CHECK(cmd != NULL, return); cmd 2147 daemons/fenced/fenced_commands.c cmd->active_on = NULL; cmd 2150 daemons/fenced/fenced_commands.c device = g_hash_table_lookup(device_list, cmd->device); cmd 2153 daemons/fenced/fenced_commands.c (pcmk__strcase_any_of(cmd->action, "list", "monitor", "status", NULL))) { cmd 2162 daemons/fenced/fenced_commands.c cmd->action, cmd->device, rc, g_list_length(cmd->device_next)); cmd 2167 daemons/fenced/fenced_commands.c for (iter = cmd->device_next; iter != NULL; iter = iter->next) { cmd 2170 daemons/fenced/fenced_commands.c if (next_device != NULL && is_action_required(cmd->action, next_device)) { cmd 2171 daemons/fenced/fenced_commands.c cmd->device_next = iter->next; cmd 2177 daemons/fenced/fenced_commands.c } else if (rc != 0 && cmd->device_next && (is_action_required(cmd->action, device) == FALSE)) { cmd 2180 daemons/fenced/fenced_commands.c next_device = g_hash_table_lookup(device_list, cmd->device_next->data); cmd 2181 daemons/fenced/fenced_commands.c cmd->device_next = cmd->device_next->next; cmd 2186 daemons/fenced/fenced_commands.c log_operation(cmd, rc, pid, next_device->id, output, FALSE); cmd 2188 daemons/fenced/fenced_commands.c schedule_stonith_command(cmd, next_device); cmd 2190 daemons/fenced/fenced_commands.c cmd = NULL; cmd 2194 daemons/fenced/fenced_commands.c stonith_send_async_reply(cmd, output, rc, pid, st_reply_opt_none); cmd 2209 daemons/fenced/fenced_commands.c if (cmd == cmd_other) { cmd 2219 daemons/fenced/fenced_commands.c if (pcmk__str_eq(cmd->client, cmd_other->client, pcmk__str_casei) || cmd 2220 daemons/fenced/fenced_commands.c !pcmk__str_eq(cmd->victim, cmd_other->victim, pcmk__str_casei) || cmd 2221 daemons/fenced/fenced_commands.c !pcmk__str_eq(cmd->action, cmd_other->action, pcmk__str_casei) || cmd 2222 daemons/fenced/fenced_commands.c !pcmk__str_eq(cmd->device, cmd_other->device, pcmk__str_casei)) { cmd 2237 daemons/fenced/fenced_commands.c cmd_other->action, cmd_other->victim, cmd_other->client_name, cmd->client_name); cmd 2249 daemons/fenced/fenced_commands.c free_async_command(cmd); cmd 2269 daemons/fenced/fenced_commands.c async_command_t *cmd = user_data; cmd 2272 daemons/fenced/fenced_commands.c crm_info("Found %d matching devices for '%s'", g_list_length(devices), cmd->victim); cmd 2280 daemons/fenced/fenced_commands.c cmd->device_list = devices; cmd 2281 daemons/fenced/fenced_commands.c cmd->device_next = devices->next; cmd 2288 daemons/fenced/fenced_commands.c schedule_stonith_command(cmd, device); cmd 2294 daemons/fenced/fenced_commands.c stonith_send_async_reply(cmd, NULL, -ENODEV, 0, st_reply_opt_none); cmd 2296 daemons/fenced/fenced_commands.c free_async_command(cmd); cmd 2305 daemons/fenced/fenced_commands.c async_command_t *cmd = create_async_command(msg); cmd 2308 daemons/fenced/fenced_commands.c if (cmd == NULL) { cmd 2319 daemons/fenced/fenced_commands.c schedule_stonith_command(cmd, device); cmd 2324 daemons/fenced/fenced_commands.c if (cmd->options & st_opt_cs_nodeid) { cmd 2334 daemons/fenced/fenced_commands.c get_capable_devices(host, cmd->action, cmd->default_timeout, cmd 2335 daemons/fenced/fenced_commands.c TRUE, cmd, stonith_fence_get_devices_cb); cmd 2391 daemons/fenced/fenced_commands.c stonith_construct_async_reply(async_command_t * cmd, const char *output, xmlNode * data, int rc) cmd 2401 daemons/fenced/fenced_commands.c crm_xml_add(reply, F_STONITH_OPERATION, cmd->op); cmd 2402 daemons/fenced/fenced_commands.c crm_xml_add(reply, F_STONITH_DEVICE, cmd->device); cmd 2403 daemons/fenced/fenced_commands.c crm_xml_add(reply, F_STONITH_REMOTE_OP_ID, cmd->remote_op_id); cmd 2404 daemons/fenced/fenced_commands.c crm_xml_add(reply, F_STONITH_CLIENTID, cmd->client); cmd 2405 daemons/fenced/fenced_commands.c crm_xml_add(reply, F_STONITH_CLIENTNAME, cmd->client_name); cmd 2406 daemons/fenced/fenced_commands.c crm_xml_add(reply, F_STONITH_TARGET, cmd->victim); cmd 2407 daemons/fenced/fenced_commands.c crm_xml_add(reply, F_STONITH_ACTION, cmd->op); cmd 2408 daemons/fenced/fenced_commands.c crm_xml_add(reply, F_STONITH_ORIGIN, cmd->origin); cmd 2409 daemons/fenced/fenced_commands.c crm_xml_add_int(reply, F_STONITH_CALLID, cmd->id); cmd 2410 daemons/fenced/fenced_commands.c crm_xml_add_int(reply, F_STONITH_CALLOPTS, cmd->options); cmd 65 include/crm/common/options_internal.h _Noreturn void pcmk__cli_help(char cmd, crm_exit_t exit_code); cmd 208 lib/common/ipc_pacemakerd.c xmlNode *cmd; cmd 215 lib/common/ipc_pacemakerd.c cmd = create_request(CRM_OP_PING, NULL, NULL, CRM_SYSTEM_MCP, cmd 219 lib/common/ipc_pacemakerd.c if (cmd) { cmd 220 lib/common/ipc_pacemakerd.c rc = pcmk__send_ipc_request(api, cmd); cmd 226 lib/common/ipc_pacemakerd.c free_xml(cmd); cmd 192 lib/common/options.c pcmk__cli_help(char cmd, crm_exit_t exit_code) cmd 197 lib/common/options.c if (cmd == 'v' || cmd == '$') { cmd 203 lib/common/options.c if (cmd == '!') { cmd 435 libltdl/loaders/dyld.c if (LC_ID_DYLIB == lc->cmd) cmd 483 libltdl/loaders/dyld.c if ((LC_LOAD_DYLIB == lc->cmd) || (LC_LOAD_WEAK_DYLIB == lc->cmd)) cmd 409 tools/crm_node.c xmlNode *cmd = NULL; cmd 425 tools/crm_node.c cmd = create_xml_node(NULL, __func__); cmd 427 tools/crm_node.c crm_xml_add(cmd, F_TYPE, T_ATTRD); cmd 428 tools/crm_node.c crm_xml_add(cmd, F_ORIG, crm_system_name); cmd 430 tools/crm_node.c crm_xml_add(cmd, PCMK__XA_TASK, PCMK__ATTRD_CMD_PEER_REMOVE); cmd 431 tools/crm_node.c crm_xml_add(cmd, PCMK__XA_ATTR_NODE_NAME, node_name); cmd 434 tools/crm_node.c crm_xml_add_int(cmd, PCMK__XA_ATTR_NODE_ID, (int) nodeid); cmd 438 tools/crm_node.c cmd = create_request(CRM_OP_RM_NODE_CACHE, NULL, NULL, target, cmd 441 tools/crm_node.c crm_xml_set_id(cmd, "%ld", nodeid); cmd 443 tools/crm_node.c crm_xml_add(cmd, XML_ATTR_UNAME, node_name); cmd 446 tools/crm_node.c rc = crm_ipc_send(conn, cmd, 0, 0, NULL); cmd 459 tools/crm_node.c free_xml(cmd); cmd 111 tools/crm_resource.c #define SET_COMMAND(cmd) do { \ cmd 117 tools/crm_resource.c options.rsc_cmd = (cmd); \ cmd 120 tools/crm_resource.c #define SET_COMMAND(cmd) do { options.rsc_cmd = (cmd); } while (0) cmd 161 tools/crm_resource_runtime.c const char * attr_name, cib_t * cib, const char * cmd, int depth) cmd 171 tools/crm_resource_runtime.c attr_id, attr_name, cib, cmd, depth+1); cmd 195 tools/crm_resource_runtime.c const char * attr_name, cib_t * cib, const char * cmd, gboolean force) cmd 216 tools/crm_resource_runtime.c printf("Performing %s of '%s' on '%s', the parent of '%s'\n", cmd, attr_name, rsc->id, rsc_id); cmd 230 tools/crm_resource_runtime.c printf("A value for '%s' already exists in child '%s', performing %s on that instead of '%s'\n", attr_name, lookup_id, cmd, rsc_id); cmd 242 tools/crm_resource_runtime.c cib, cmd, 0);