cmd 26 daemons/controld/controld_remote_ra.c #define cmd_set_flags(cmd, flags_to_set) do { \ cmd 27 daemons/controld/controld_remote_ra.c (cmd)->status = pcmk__set_flags_as(__func__, __LINE__, LOG_TRACE, \ cmd 28 daemons/controld/controld_remote_ra.c "Remote command", (cmd)->rsc_id, (cmd)->status, \ cmd 32 daemons/controld/controld_remote_ra.c #define cmd_clear_flags(cmd, flags_to_clear) do { \ cmd 33 daemons/controld/controld_remote_ra.c (cmd)->status = pcmk__clear_flags_as(__func__, __LINE__, LOG_TRACE, \ cmd 34 daemons/controld/controld_remote_ra.c "Remote command", (cmd)->rsc_id, (cmd)->status, \ cmd 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); cmd 115 daemons/controld/controld_remote_ra.c static void handle_remote_ra_stop(lrm_state_t * lrm_state, remote_ra_cmd_t * cmd); cmd 121 daemons/controld/controld_remote_ra.c remote_ra_cmd_t *cmd = user_data; cmd 123 daemons/controld/controld_remote_ra.c if (!cmd) { cmd 126 daemons/controld/controld_remote_ra.c if (cmd->delay_id) { cmd 127 daemons/controld/controld_remote_ra.c g_source_remove(cmd->delay_id); cmd 129 daemons/controld/controld_remote_ra.c if (cmd->interval_id) { cmd 130 daemons/controld/controld_remote_ra.c g_source_remove(cmd->interval_id); cmd 132 daemons/controld/controld_remote_ra.c if (cmd->monitor_timeout_id) { cmd 133 daemons/controld/controld_remote_ra.c g_source_remove(cmd->monitor_timeout_id); cmd 135 daemons/controld/controld_remote_ra.c if (cmd->takeover_timeout_id) { cmd 136 daemons/controld/controld_remote_ra.c g_source_remove(cmd->takeover_timeout_id); cmd 138 daemons/controld/controld_remote_ra.c free(cmd->owner); cmd 139 daemons/controld/controld_remote_ra.c free(cmd->rsc_id); cmd 140 daemons/controld/controld_remote_ra.c free(cmd->action); cmd 141 daemons/controld/controld_remote_ra.c free(cmd->userdata); cmd 142 daemons/controld/controld_remote_ra.c pcmk__reset_result(&(cmd->result)); cmd 143 daemons/controld/controld_remote_ra.c lrmd_key_value_freeall(cmd->params); cmd 144 daemons/controld/controld_remote_ra.c free(cmd); cmd 163 daemons/controld/controld_remote_ra.c remote_ra_cmd_t *cmd = data; cmd 166 daemons/controld/controld_remote_ra.c cmd->interval_id = 0; cmd 167 daemons/controld/controld_remote_ra.c connection_rsc = controld_get_executor_state(cmd->rsc_id, false); cmd 171 daemons/controld/controld_remote_ra.c ra_data->recurring_cmds = g_list_remove(ra_data->recurring_cmds, cmd); cmd 173 daemons/controld/controld_remote_ra.c ra_data->cmds = g_list_append(ra_data->cmds, cmd); cmd 182 daemons/controld/controld_remote_ra.c remote_ra_cmd_t *cmd = data; cmd 185 daemons/controld/controld_remote_ra.c cmd->delay_id = 0; cmd 186 daemons/controld/controld_remote_ra.c connection_rsc = controld_get_executor_state(cmd->rsc_id, false); cmd 405 daemons/controld/controld_remote_ra.c check_remote_node_state(const remote_ra_cmd_t *cmd) cmd 408 daemons/controld/controld_remote_ra.c if (!pcmk__result_ok(&(cmd->result))) { cmd 412 daemons/controld/controld_remote_ra.c if (pcmk__str_eq(cmd->action, PCMK_ACTION_START, pcmk__str_casei)) { cmd 413 daemons/controld/controld_remote_ra.c remote_node_up(cmd->rsc_id); cmd 415 daemons/controld/controld_remote_ra.c } else if (pcmk__str_eq(cmd->action, PCMK_ACTION_MIGRATE_FROM, cmd 425 daemons/controld/controld_remote_ra.c pcmk__cluster_lookup_remote_node(cmd->rsc_id); cmd 430 daemons/controld/controld_remote_ra.c } else if (pcmk__str_eq(cmd->action, PCMK_ACTION_STOP, pcmk__str_casei)) { cmd 431 daemons/controld/controld_remote_ra.c lrm_state_t *lrm_state = controld_get_executor_state(cmd->rsc_id, cmd 438 daemons/controld/controld_remote_ra.c remote_node_down(cmd->rsc_id, DOWN_KEEP_LRM); cmd 444 daemons/controld/controld_remote_ra.c pcmk__cluster_forget_remote_node(cmd->rsc_id); cmd 461 daemons/controld/controld_remote_ra.c report_remote_ra_result(remote_ra_cmd_t * cmd) cmd 465 daemons/controld/controld_remote_ra.c check_remote_node_state(cmd); cmd 468 daemons/controld/controld_remote_ra.c op.rsc_id = cmd->rsc_id; cmd 469 daemons/controld/controld_remote_ra.c op.op_type = cmd->action; cmd 470 daemons/controld/controld_remote_ra.c op.user_data = cmd->userdata; cmd 471 daemons/controld/controld_remote_ra.c op.timeout = cmd->timeout; cmd 472 daemons/controld/controld_remote_ra.c op.interval_ms = cmd->interval_ms; cmd 473 daemons/controld/controld_remote_ra.c op.t_run = cmd->start_time; cmd 474 daemons/controld/controld_remote_ra.c op.t_rcchange = cmd->start_time; cmd 476 daemons/controld/controld_remote_ra.c lrmd__set_result(&op, cmd->result.exit_status, cmd->result.execution_status, cmd 477 daemons/controld/controld_remote_ra.c cmd->result.exit_reason); cmd 479 daemons/controld/controld_remote_ra.c if (pcmk_is_set(cmd->status, cmd_reported_success) && !pcmk__result_ok(&(cmd->result))) { cmd 495 daemons/controld/controld_remote_ra.c if (cmd->params) { cmd 499 daemons/controld/controld_remote_ra.c for (tmp = cmd->params; tmp; tmp = tmp->next) { cmd 504 daemons/controld/controld_remote_ra.c op.call_id = cmd->call_id; cmd 505 daemons/controld/controld_remote_ra.c op.remote_nodename = cmd->owner; cmd 516 daemons/controld/controld_remote_ra.c update_remaining_timeout(remote_ra_cmd_t * cmd) cmd 518 daemons/controld/controld_remote_ra.c cmd->remaining_timeout = ((cmd->timeout / 1000) - (time(NULL) - cmd->start_time)) * 1000; cmd 526 daemons/controld/controld_remote_ra.c remote_ra_cmd_t *cmd = NULL; cmd 532 daemons/controld/controld_remote_ra.c cmd = ra_data->cur_cmd; cmd 533 daemons/controld/controld_remote_ra.c if (!pcmk__strcase_any_of(cmd->action, PCMK_ACTION_START, cmd 537 daemons/controld/controld_remote_ra.c update_remaining_timeout(cmd); cmd 539 daemons/controld/controld_remote_ra.c if (cmd->remaining_timeout > 0) { cmd 540 daemons/controld/controld_remote_ra.c rc = handle_remote_ra_start(lrm_state, cmd, cmd->remaining_timeout); cmd 542 daemons/controld/controld_remote_ra.c pcmk__set_result(&(cmd->result), PCMK_OCF_UNKNOWN_ERROR, cmd 548 daemons/controld/controld_remote_ra.c report_remote_ra_result(cmd); cmd 554 daemons/controld/controld_remote_ra.c free_cmd(cmd); cmd 567 daemons/controld/controld_remote_ra.c remote_ra_cmd_t *cmd = data; cmd 569 daemons/controld/controld_remote_ra.c crm_info("takeover event timed out for node %s", cmd->rsc_id); cmd 570 daemons/controld/controld_remote_ra.c cmd->takeover_timeout_id = 0; cmd 572 daemons/controld/controld_remote_ra.c lrm_state = controld_get_executor_state(cmd->rsc_id, false); cmd 574 daemons/controld/controld_remote_ra.c handle_remote_ra_stop(lrm_state, cmd); cmd 575 daemons/controld/controld_remote_ra.c free_cmd(cmd); cmd 584 daemons/controld/controld_remote_ra.c remote_ra_cmd_t *cmd = data; cmd 586 daemons/controld/controld_remote_ra.c lrm_state = controld_get_executor_state(cmd->rsc_id, false); cmd 589 daemons/controld/controld_remote_ra.c cmd->rsc_id, (lrm_state? "" : " (no LRM state)")); cmd 590 daemons/controld/controld_remote_ra.c cmd->monitor_timeout_id = 0; cmd 591 daemons/controld/controld_remote_ra.c pcmk__set_result(&(cmd->result), PCMK_OCF_UNKNOWN_ERROR, PCMK_EXEC_TIMEOUT, cmd 597 daemons/controld/controld_remote_ra.c if (ra_data->cur_cmd == cmd) { cmd 605 daemons/controld/controld_remote_ra.c report_remote_ra_result(cmd); cmd 606 daemons/controld/controld_remote_ra.c free_cmd(cmd); cmd 641 daemons/controld/controld_remote_ra.c remote_ra_cmd_t *cmd = NULL; cmd 718 daemons/controld/controld_remote_ra.c cmd = ra_data->cur_cmd; cmd 723 daemons/controld/controld_remote_ra.c && pcmk__strcase_any_of(cmd->action, PCMK_ACTION_START, cmd 726 daemons/controld/controld_remote_ra.c update_remaining_timeout(cmd); cmd 731 daemons/controld/controld_remote_ra.c pcmk__set_result(&(cmd->result), PCMK_OCF_INVALID_PARAM, cmd 735 daemons/controld/controld_remote_ra.c } else if (cmd->remaining_timeout > 3000) { cmd 736 daemons/controld/controld_remote_ra.c crm_trace("rescheduling start, remaining timeout %d", cmd->remaining_timeout); cmd 742 daemons/controld/controld_remote_ra.c cmd->remaining_timeout); cmd 743 daemons/controld/controld_remote_ra.c pcmk__format_result(&(cmd->result), PCMK_OCF_UNKNOWN_ERROR, cmd 751 daemons/controld/controld_remote_ra.c pcmk__set_result(&(cmd->result), PCMK_OCF_OK, PCMK_EXEC_DONE, NULL); cmd 755 daemons/controld/controld_remote_ra.c crm_debug("Remote connection event matched %s action", cmd->action); cmd 756 daemons/controld/controld_remote_ra.c report_remote_ra_result(cmd); cmd 760 daemons/controld/controld_remote_ra.c && pcmk__str_eq(cmd->action, PCMK_ACTION_MONITOR, cmd 763 daemons/controld/controld_remote_ra.c if (cmd->monitor_timeout_id) { cmd 764 daemons/controld/controld_remote_ra.c g_source_remove(cmd->monitor_timeout_id); cmd 765 daemons/controld/controld_remote_ra.c cmd->monitor_timeout_id = 0; cmd 771 daemons/controld/controld_remote_ra.c if (!pcmk_is_set(cmd->status, cmd_reported_success)) { cmd 772 daemons/controld/controld_remote_ra.c pcmk__set_result(&(cmd->result), PCMK_OCF_OK, PCMK_EXEC_DONE, NULL); cmd 773 daemons/controld/controld_remote_ra.c report_remote_ra_result(cmd); cmd 774 daemons/controld/controld_remote_ra.c cmd_set_flags(cmd, cmd_reported_success); cmd 777 daemons/controld/controld_remote_ra.c crm_debug("Remote poke event matched %s action", cmd->action); cmd 780 daemons/controld/controld_remote_ra.c if (cmd->interval_ms && !pcmk_is_set(cmd->status, cmd_cancel)) { cmd 781 daemons/controld/controld_remote_ra.c ra_data->recurring_cmds = g_list_append(ra_data->recurring_cmds, cmd); cmd 782 daemons/controld/controld_remote_ra.c cmd->interval_id = pcmk__create_timer(cmd->interval_ms, cmd 783 daemons/controld/controld_remote_ra.c recurring_helper, cmd); cmd 784 daemons/controld/controld_remote_ra.c cmd = NULL; /* prevent free */ cmd 789 daemons/controld/controld_remote_ra.c && pcmk__str_eq(cmd->action, PCMK_ACTION_MONITOR, cmd 792 daemons/controld/controld_remote_ra.c !pcmk_is_set(cmd->status, cmd_cancel)) { cmd 793 daemons/controld/controld_remote_ra.c pcmk__set_result(&(cmd->result), PCMK_OCF_UNKNOWN_ERROR, cmd 797 daemons/controld/controld_remote_ra.c report_remote_ra_result(cmd); cmd 812 daemons/controld/controld_remote_ra.c free_cmd(cmd); cmd 817 daemons/controld/controld_remote_ra.c handle_remote_ra_stop(lrm_state_t * lrm_state, remote_ra_cmd_t * cmd) cmd 846 daemons/controld/controld_remote_ra.c if (cmd) { cmd 847 daemons/controld/controld_remote_ra.c pcmk__set_result(&(cmd->result), PCMK_OCF_OK, PCMK_EXEC_DONE, NULL); cmd 848 daemons/controld/controld_remote_ra.c report_remote_ra_result(cmd); cmd 854 daemons/controld/controld_remote_ra.c handle_remote_ra_start(lrm_state_t * lrm_state, remote_ra_cmd_t * cmd, int timeout_ms) cmd 862 daemons/controld/controld_remote_ra.c for (tmp = cmd->params; tmp; tmp = tmp->next) { cmd 881 daemons/controld/controld_remote_ra.c pcmk__format_result(&(cmd->result), PCMK_OCF_UNKNOWN_ERROR, cmd 895 daemons/controld/controld_remote_ra.c remote_ra_cmd_t *cmd; cmd 905 daemons/controld/controld_remote_ra.c cmd = first->data; cmd 906 daemons/controld/controld_remote_ra.c if (cmd->delay_id) { cmd 914 daemons/controld/controld_remote_ra.c if (pcmk__str_any_of(cmd->action, PCMK_ACTION_START, cmd 917 daemons/controld/controld_remote_ra.c if (handle_remote_ra_start(lrm_state, cmd, cmd 918 daemons/controld/controld_remote_ra.c cmd->timeout) == pcmk_rc_ok) { cmd 921 daemons/controld/controld_remote_ra.c cmd->action); cmd 922 daemons/controld/controld_remote_ra.c ra_data->cur_cmd = cmd; cmd 925 daemons/controld/controld_remote_ra.c report_remote_ra_result(cmd); cmd 927 daemons/controld/controld_remote_ra.c } else if (!strcmp(cmd->action, PCMK_ACTION_MONITOR)) { cmd 932 daemons/controld/controld_remote_ra.c pcmk__set_result(&(cmd->result), PCMK_OCF_UNKNOWN_ERROR, cmd 937 daemons/controld/controld_remote_ra.c pcmk__set_result(&(cmd->result), PCMK_OCF_NOT_RUNNING, cmd 943 daemons/controld/controld_remote_ra.c cmd->rsc_id); cmd 944 daemons/controld/controld_remote_ra.c ra_data->cur_cmd = cmd; cmd 945 daemons/controld/controld_remote_ra.c cmd->monitor_timeout_id = pcmk__create_timer(cmd->timeout, monitor_timeout_cb, cmd); cmd 948 daemons/controld/controld_remote_ra.c report_remote_ra_result(cmd); cmd 950 daemons/controld/controld_remote_ra.c } else if (!strcmp(cmd->action, PCMK_ACTION_STOP)) { cmd 959 daemons/controld/controld_remote_ra.c cmd->takeover_timeout_id = pcmk__create_timer((cmd->timeout/2), cmd 961 daemons/controld/controld_remote_ra.c cmd); cmd 962 daemons/controld/controld_remote_ra.c ra_data->cur_cmd = cmd; cmd 966 daemons/controld/controld_remote_ra.c handle_remote_ra_stop(lrm_state, cmd); cmd 968 daemons/controld/controld_remote_ra.c } else if (strcmp(cmd->action, PCMK_ACTION_MIGRATE_TO) == 0) { cmd 971 daemons/controld/controld_remote_ra.c pcmk__set_result(&(cmd->result), PCMK_OCF_OK, PCMK_EXEC_DONE, NULL); cmd 972 daemons/controld/controld_remote_ra.c report_remote_ra_result(cmd); cmd 974 daemons/controld/controld_remote_ra.c } else if (pcmk__str_any_of(cmd->action, PCMK_ACTION_RELOAD, cmd 985 daemons/controld/controld_remote_ra.c pcmk__set_result(&(cmd->result), PCMK_OCF_OK, PCMK_EXEC_DONE, NULL); cmd 986 daemons/controld/controld_remote_ra.c report_remote_ra_result(cmd); cmd 989 daemons/controld/controld_remote_ra.c free_cmd(cmd); cmd 1077 daemons/controld/controld_remote_ra.c remote_ra_cmd_t *cmd = NULL; cmd 1081 daemons/controld/controld_remote_ra.c cmd = gIter->data; cmd 1082 daemons/controld/controld_remote_ra.c if ((cmd->interval_ms > 0) cmd 1083 daemons/controld/controld_remote_ra.c && pcmk__str_eq(cmd->action, PCMK_ACTION_MONITOR, cmd 1085 daemons/controld/controld_remote_ra.c rm_list = g_list_append(rm_list, cmd); cmd 1090 daemons/controld/controld_remote_ra.c cmd = gIter->data; cmd 1092 daemons/controld/controld_remote_ra.c pcmk__set_result(&(cmd->result), PCMK_OCF_UNKNOWN_ERROR, cmd 1095 daemons/controld/controld_remote_ra.c cmd->action, cmd->rsc_id, cmd->interval_ms, cmd->userdata); cmd 1096 daemons/controld/controld_remote_ra.c report_remote_ra_result(cmd); cmd 1098 daemons/controld/controld_remote_ra.c list = g_list_remove(list, cmd); cmd 1099 daemons/controld/controld_remote_ra.c free_cmd(cmd); cmd 1110 daemons/controld/controld_remote_ra.c remote_ra_cmd_t *cmd = NULL; cmd 1114 daemons/controld/controld_remote_ra.c cmd = gIter->data; cmd 1115 daemons/controld/controld_remote_ra.c if ((cmd->interval_ms == interval_ms) cmd 1116 daemons/controld/controld_remote_ra.c && pcmk__str_eq(cmd->action, action, pcmk__str_casei)) { cmd 1119 daemons/controld/controld_remote_ra.c cmd = NULL; cmd 1121 daemons/controld/controld_remote_ra.c if (cmd) { cmd 1122 daemons/controld/controld_remote_ra.c list = g_list_remove(list, cmd); cmd 1123 daemons/controld/controld_remote_ra.c free_cmd(cmd); cmd 1161 daemons/controld/controld_remote_ra.c remote_ra_cmd_t *cmd = NULL; cmd 1179 daemons/controld/controld_remote_ra.c cmd = ra_data->cur_cmd; cmd 1184 daemons/controld/controld_remote_ra.c cmd = gIter->data; cmd 1185 daemons/controld/controld_remote_ra.c if ((cmd->interval_ms == interval_ms) cmd 1186 daemons/controld/controld_remote_ra.c && pcmk__str_eq(cmd->action, PCMK_ACTION_MONITOR, cmd 1193 daemons/controld/controld_remote_ra.c cmd = gIter->data; cmd 1194 daemons/controld/controld_remote_ra.c if ((cmd->interval_ms == interval_ms) cmd 1195 daemons/controld/controld_remote_ra.c && pcmk__str_eq(cmd->action, PCMK_ACTION_MONITOR, cmd 1206 daemons/controld/controld_remote_ra.c cmd->rsc_id, PCMK_ACTION_MONITOR, interval_ms); cmd 1210 daemons/controld/controld_remote_ra.c free(cmd->userdata); cmd 1211 daemons/controld/controld_remote_ra.c cmd->userdata = pcmk__str_copy(userdata); cmd 1215 daemons/controld/controld_remote_ra.c if (pcmk_is_set(cmd->status, cmd_reported_success)) { cmd 1216 daemons/controld/controld_remote_ra.c cmd->start_time = time(NULL); cmd 1217 daemons/controld/controld_remote_ra.c cmd->call_id = generate_callid(); cmd 1218 daemons/controld/controld_remote_ra.c cmd_clear_flags(cmd, cmd_reported_success); cmd 1224 daemons/controld/controld_remote_ra.c if (cmd->interval_id) { cmd 1225 daemons/controld/controld_remote_ra.c g_source_remove(cmd->interval_id); cmd 1226 daemons/controld/controld_remote_ra.c cmd->interval_id = 0; cmd 1227 daemons/controld/controld_remote_ra.c recurring_helper(cmd); cmd 1230 daemons/controld/controld_remote_ra.c return cmd; cmd 1259 daemons/controld/controld_remote_ra.c remote_ra_cmd_t *cmd = NULL; cmd 1282 daemons/controld/controld_remote_ra.c cmd = handle_dup_monitor(ra_data, interval_ms, userdata); cmd 1283 daemons/controld/controld_remote_ra.c if (cmd) { cmd 1284 daemons/controld/controld_remote_ra.c *call_id = cmd->call_id; cmd 1289 daemons/controld/controld_remote_ra.c cmd = pcmk__assert_alloc(1, sizeof(remote_ra_cmd_t)); cmd 1291 daemons/controld/controld_remote_ra.c cmd->owner = pcmk__str_copy(lrm_state->node_name); cmd 1292 daemons/controld/controld_remote_ra.c cmd->rsc_id = pcmk__str_copy(rsc_id); cmd 1293 daemons/controld/controld_remote_ra.c cmd->action = pcmk__str_copy(action); cmd 1294 daemons/controld/controld_remote_ra.c cmd->userdata = pcmk__str_copy(userdata); cmd 1295 daemons/controld/controld_remote_ra.c cmd->interval_ms = interval_ms; cmd 1296 daemons/controld/controld_remote_ra.c cmd->timeout = timeout_ms; cmd 1297 daemons/controld/controld_remote_ra.c cmd->start_delay = start_delay_ms; cmd 1298 daemons/controld/controld_remote_ra.c cmd->params = params; cmd 1299 daemons/controld/controld_remote_ra.c cmd->start_time = time(NULL); cmd 1301 daemons/controld/controld_remote_ra.c cmd->call_id = generate_callid(); cmd 1303 daemons/controld/controld_remote_ra.c if (cmd->start_delay) { cmd 1304 daemons/controld/controld_remote_ra.c cmd->delay_id = pcmk__create_timer(cmd->start_delay, start_delay_helper, cmd); cmd 1307 daemons/controld/controld_remote_ra.c ra_data->cmds = g_list_append(ra_data->cmds, cmd); cmd 1310 daemons/controld/controld_remote_ra.c *call_id = cmd->call_id; cmd 55 daemons/controld/controld_te_actions.c xmlNode *cmd = NULL; cmd 61 daemons/controld/controld_te_actions.c cmd = pcmk__new_request(pcmk_ipc_controld, CRM_SYSTEM_TENGINE, cmd 64 daemons/controld/controld_te_actions.c pcmk__cluster_send_message(node, pcmk_ipc_controld, cmd); cmd 65 daemons/controld/controld_te_actions.c pcmk__xml_free(cmd); cmd 103 daemons/controld/controld_te_actions.c xmlNode *cmd = NULL; cmd 168 daemons/controld/controld_te_actions.c cmd = pcmk__new_request(pcmk_ipc_controld, CRM_SYSTEM_TENGINE, router_node, cmd 174 daemons/controld/controld_te_actions.c crm_xml_add(cmd, PCMK__XA_TRANSITION_KEY, counter); cmd 178 daemons/controld/controld_te_actions.c rc = pcmk__cluster_send_message(node, pcmk_ipc_controld, cmd); cmd 180 daemons/controld/controld_te_actions.c pcmk__xml_free(cmd); cmd 356 daemons/controld/controld_te_actions.c xmlNode *cmd = NULL; cmd 407 daemons/controld/controld_te_actions.c cmd = pcmk__new_request(pcmk_ipc_controld, CRM_SYSTEM_TENGINE, router_node, cmd 413 daemons/controld/controld_te_actions.c .msg = cmd, cmd 435 daemons/controld/controld_te_actions.c rc = pcmk__cluster_send_message(node, pcmk_ipc_execd, cmd); cmd 439 daemons/controld/controld_te_actions.c pcmk__xml_free(cmd); cmd 100 daemons/execd/execd_commands.c static void cmd_finalize(lrmd_cmd_t * cmd, lrmd_rsc_t * rsc); cmd 188 daemons/execd/execd_commands.c cmd_original_times(lrmd_cmd_t * cmd) cmd 190 daemons/execd/execd_commands.c cmd->t_run = cmd->t_first_run; cmd 191 daemons/execd/execd_commands.c cmd->t_queue = cmd->t_first_queue; cmd 196 daemons/execd/execd_commands.c action_matches(const lrmd_cmd_t *cmd, const char *action, guint interval_ms) cmd 198 daemons/execd/execd_commands.c return (cmd->interval_ms == interval_ms) cmd 199 daemons/execd/execd_commands.c && pcmk__str_eq(cmd->action, action, pcmk__str_casei); cmd 211 daemons/execd/execd_commands.c log_finished(const lrmd_cmd_t *cmd, int exec_time_ms, int queue_time_ms) cmd 216 daemons/execd/execd_commands.c if (pcmk__str_eq(cmd->action, PCMK_ACTION_MONITOR, pcmk__str_casei)) { cmd 221 daemons/execd/execd_commands.c cmd->rsc_id, cmd->action, cmd->call_id); cmd 222 daemons/execd/execd_commands.c if (cmd->last_pid != 0) { cmd 223 daemons/execd/execd_commands.c g_string_append_printf(str, ", PID %d", cmd->last_pid); cmd 225 daemons/execd/execd_commands.c if (cmd->result.execution_status == PCMK_EXEC_DONE) { cmd 227 daemons/execd/execd_commands.c cmd->result.exit_status); cmd 230 daemons/execd/execd_commands.c pcmk_exec_status_str(cmd->result.execution_status), cmd 233 daemons/execd/execd_commands.c if (cmd->result.exit_reason != NULL) { cmd 234 daemons/execd/execd_commands.c pcmk__g_strcat(str, " (", cmd->result.exit_reason, ")", NULL); cmd 252 daemons/execd/execd_commands.c log_execute(lrmd_cmd_t * cmd) cmd 256 daemons/execd/execd_commands.c if (pcmk__str_eq(cmd->action, PCMK_ACTION_MONITOR, pcmk__str_casei)) { cmd 261 daemons/execd/execd_commands.c cmd->rsc_id, cmd->action, cmd->call_id); cmd 302 daemons/execd/execd_commands.c lrmd_cmd_t *cmd = NULL; cmd 304 daemons/execd/execd_commands.c cmd = pcmk__assert_alloc(1, sizeof(lrmd_cmd_t)); cmd 307 daemons/execd/execd_commands.c cmd->call_opts = call_options; cmd 308 daemons/execd/execd_commands.c cmd->client_id = pcmk__str_copy(client->id); cmd 310 daemons/execd/execd_commands.c crm_element_value_int(msg, PCMK__XA_LRMD_CALLID, &cmd->call_id); cmd 312 daemons/execd/execd_commands.c &cmd->interval_ms); cmd 313 daemons/execd/execd_commands.c crm_element_value_int(rsc_xml, PCMK__XA_LRMD_TIMEOUT, &cmd->timeout); cmd 315 daemons/execd/execd_commands.c &cmd->start_delay); cmd 316 daemons/execd/execd_commands.c cmd->timeout_orig = cmd->timeout; cmd 318 daemons/execd/execd_commands.c cmd->origin = crm_element_value_copy(rsc_xml, PCMK__XA_LRMD_ORIGIN); cmd 319 daemons/execd/execd_commands.c cmd->action = crm_element_value_copy(rsc_xml, PCMK__XA_LRMD_RSC_ACTION); cmd 320 daemons/execd/execd_commands.c cmd->userdata_str = crm_element_value_copy(rsc_xml, cmd 322 daemons/execd/execd_commands.c cmd->rsc_id = crm_element_value_copy(rsc_xml, PCMK__XA_LRMD_RSC_ID); cmd 324 daemons/execd/execd_commands.c cmd->params = xml2list(rsc_xml); cmd 326 daemons/execd/execd_commands.c if (pcmk__str_eq(g_hash_table_lookup(cmd->params, "CRM_meta_on_fail"), cmd 330 daemons/execd/execd_commands.c cmd->rsc_id, cmd->action, cmd->interval_ms); cmd 331 daemons/execd/execd_commands.c cmd->service_flags = pcmk__set_flags_as(__func__, __LINE__, cmd 333 daemons/execd/execd_commands.c cmd->action, 0, cmd 337 daemons/execd/execd_commands.c return cmd; cmd 341 daemons/execd/execd_commands.c stop_recurring_timer(lrmd_cmd_t *cmd) cmd 343 daemons/execd/execd_commands.c if (cmd) { cmd 344 daemons/execd/execd_commands.c if (cmd->stonith_recurring_id) { cmd 345 daemons/execd/execd_commands.c g_source_remove(cmd->stonith_recurring_id); cmd 347 daemons/execd/execd_commands.c cmd->stonith_recurring_id = 0; cmd 352 daemons/execd/execd_commands.c free_lrmd_cmd(lrmd_cmd_t * cmd) cmd 354 daemons/execd/execd_commands.c stop_recurring_timer(cmd); cmd 355 daemons/execd/execd_commands.c if (cmd->delay_id) { cmd 356 daemons/execd/execd_commands.c g_source_remove(cmd->delay_id); cmd 358 daemons/execd/execd_commands.c if (cmd->params) { cmd 359 daemons/execd/execd_commands.c g_hash_table_destroy(cmd->params); cmd 361 daemons/execd/execd_commands.c pcmk__reset_result(&(cmd->result)); cmd 362 daemons/execd/execd_commands.c free(cmd->origin); cmd 363 daemons/execd/execd_commands.c free(cmd->action); cmd 364 daemons/execd/execd_commands.c free(cmd->real_action); cmd 365 daemons/execd/execd_commands.c free(cmd->userdata_str); cmd 366 daemons/execd/execd_commands.c free(cmd->rsc_id); cmd 367 daemons/execd/execd_commands.c free(cmd->client_id); cmd 368 daemons/execd/execd_commands.c free(cmd); cmd 374 daemons/execd/execd_commands.c lrmd_cmd_t *cmd = data; cmd 377 daemons/execd/execd_commands.c cmd->stonith_recurring_id = 0; cmd 379 daemons/execd/execd_commands.c if (!cmd->rsc_id) { cmd 383 daemons/execd/execd_commands.c rsc = g_hash_table_lookup(rsc_list, cmd->rsc_id); cmd 388 daemons/execd/execd_commands.c rsc->recurring_ops = g_list_remove(rsc->recurring_ops, cmd); cmd 389 daemons/execd/execd_commands.c rsc->pending_ops = g_list_append(rsc->pending_ops, cmd); cmd 391 daemons/execd/execd_commands.c get_current_time(&(cmd->t_queue), &(cmd->t_first_queue)); cmd 399 daemons/execd/execd_commands.c start_recurring_timer(lrmd_cmd_t *cmd) cmd 401 daemons/execd/execd_commands.c if (!cmd || (cmd->interval_ms <= 0)) { cmd 405 daemons/execd/execd_commands.c cmd->stonith_recurring_id = pcmk__create_timer(cmd->interval_ms, cmd 407 daemons/execd/execd_commands.c cmd); cmd 413 daemons/execd/execd_commands.c lrmd_cmd_t *cmd = data; cmd 416 daemons/execd/execd_commands.c cmd->delay_id = 0; cmd 417 daemons/execd/execd_commands.c rsc = cmd->rsc_id ? g_hash_table_lookup(rsc_list, cmd->rsc_id) : NULL; cmd 434 daemons/execd/execd_commands.c find_duplicate_action(const GList *action_list, const lrmd_cmd_t *cmd) cmd 439 daemons/execd/execd_commands.c if (action_matches(cmd, dup->action, dup->interval_ms)) { cmd 447 daemons/execd/execd_commands.c merge_recurring_duplicate(lrmd_rsc_t * rsc, lrmd_cmd_t * cmd) cmd 452 daemons/execd/execd_commands.c if (cmd->interval_ms == 0) { cmd 457 daemons/execd/execd_commands.c dup = find_duplicate_action(rsc->pending_ops, cmd); cmd 460 daemons/execd/execd_commands.c dup = find_duplicate_action(rsc->recurring_ops, cmd); cmd 486 daemons/execd/execd_commands.c dup->userdata_str = cmd->userdata_str; cmd 487 daemons/execd/execd_commands.c cmd->userdata_str = NULL; cmd 488 daemons/execd/execd_commands.c dup->call_id = cmd->call_id; cmd 489 daemons/execd/execd_commands.c free_lrmd_cmd(cmd); cmd 490 daemons/execd/execd_commands.c cmd = NULL; cmd 511 daemons/execd/execd_commands.c schedule_lrmd_cmd(lrmd_rsc_t * rsc, lrmd_cmd_t * cmd) cmd 513 daemons/execd/execd_commands.c CRM_CHECK(cmd != NULL, return); cmd 516 daemons/execd/execd_commands.c crm_trace("Scheduling %s on %s", cmd->action, rsc->rsc_id); cmd 518 daemons/execd/execd_commands.c if (merge_recurring_duplicate(rsc, cmd)) { cmd 526 daemons/execd/execd_commands.c if (pcmk__str_eq(cmd->action, PCMK_ACTION_STOP, pcmk__str_casei)) { cmd 530 daemons/execd/execd_commands.c rsc->pending_ops = g_list_append(rsc->pending_ops, cmd); cmd 532 daemons/execd/execd_commands.c get_current_time(&(cmd->t_queue), &(cmd->t_first_queue)); cmd 536 daemons/execd/execd_commands.c if (cmd->start_delay) { cmd 537 daemons/execd/execd_commands.c cmd->delay_id = pcmk__create_timer(cmd->start_delay, start_delay_helper, cmd); cmd 597 daemons/execd/execd_commands.c send_cmd_complete_notify(lrmd_cmd_t * cmd) cmd 604 daemons/execd/execd_commands.c exec_time = time_diff_ms(NULL, &(cmd->t_run)); cmd 605 daemons/execd/execd_commands.c queue_time = time_diff_ms(&cmd->t_run, &(cmd->t_queue)); cmd 607 daemons/execd/execd_commands.c log_finished(cmd, exec_time, queue_time); cmd 612 daemons/execd/execd_commands.c if (cmd->first_notify_sent cmd 613 daemons/execd/execd_commands.c && pcmk_is_set(cmd->call_opts, lrmd_opt_notify_changes_only) cmd 614 daemons/execd/execd_commands.c && (cmd->last_notify_rc == cmd->result.exit_status) cmd 615 daemons/execd/execd_commands.c && (cmd->last_notify_op_status == cmd->result.execution_status)) { cmd 619 daemons/execd/execd_commands.c cmd->first_notify_sent = true; cmd 620 daemons/execd/execd_commands.c cmd->last_notify_rc = cmd->result.exit_status; cmd 621 daemons/execd/execd_commands.c cmd->last_notify_op_status = cmd->result.execution_status; cmd 626 daemons/execd/execd_commands.c crm_xml_add_int(notify, PCMK__XA_LRMD_TIMEOUT, cmd->timeout); cmd 627 daemons/execd/execd_commands.c crm_xml_add_ms(notify, PCMK__XA_LRMD_RSC_INTERVAL, cmd->interval_ms); cmd 628 daemons/execd/execd_commands.c crm_xml_add_int(notify, PCMK__XA_LRMD_RSC_START_DELAY, cmd->start_delay); cmd 629 daemons/execd/execd_commands.c crm_xml_add_int(notify, PCMK__XA_LRMD_EXEC_RC, cmd->result.exit_status); cmd 631 daemons/execd/execd_commands.c cmd->result.execution_status); cmd 632 daemons/execd/execd_commands.c crm_xml_add_int(notify, PCMK__XA_LRMD_CALLID, cmd->call_id); cmd 633 daemons/execd/execd_commands.c crm_xml_add_int(notify, PCMK__XA_LRMD_RSC_DELETED, cmd->rsc_deleted); cmd 636 daemons/execd/execd_commands.c (long long) cmd->epoch_last_run); cmd 638 daemons/execd/execd_commands.c (long long) cmd->epoch_rcchange); cmd 645 daemons/execd/execd_commands.c crm_xml_add(notify, PCMK__XA_LRMD_RSC_ID, cmd->rsc_id); cmd 646 daemons/execd/execd_commands.c if(cmd->real_action) { cmd 647 daemons/execd/execd_commands.c crm_xml_add(notify, PCMK__XA_LRMD_RSC_ACTION, cmd->real_action); cmd 649 daemons/execd/execd_commands.c crm_xml_add(notify, PCMK__XA_LRMD_RSC_ACTION, cmd->action); cmd 651 daemons/execd/execd_commands.c crm_xml_add(notify, PCMK__XA_LRMD_RSC_USERDATA_STR, cmd->userdata_str); cmd 652 daemons/execd/execd_commands.c crm_xml_add(notify, PCMK__XA_LRMD_RSC_EXIT_REASON, cmd->result.exit_reason); cmd 654 daemons/execd/execd_commands.c if (cmd->result.action_stderr != NULL) { cmd 656 daemons/execd/execd_commands.c cmd->result.action_stderr); cmd 658 daemons/execd/execd_commands.c } else if (cmd->result.action_stdout != NULL) { cmd 660 daemons/execd/execd_commands.c cmd->result.action_stdout); cmd 663 daemons/execd/execd_commands.c if (cmd->params) { cmd 670 daemons/execd/execd_commands.c g_hash_table_iter_init(&iter, cmd->params); cmd 675 daemons/execd/execd_commands.c if ((cmd->client_id != NULL) cmd 676 daemons/execd/execd_commands.c && pcmk_is_set(cmd->call_opts, lrmd_opt_notify_orig_only)) { cmd 678 daemons/execd/execd_commands.c pcmk__client_t *client = pcmk__find_client_by_id(cmd->client_id); cmd 717 daemons/execd/execd_commands.c cmd_reset(lrmd_cmd_t * cmd) cmd 719 daemons/execd/execd_commands.c cmd->last_pid = 0; cmd 721 daemons/execd/execd_commands.c memset(&cmd->t_run, 0, sizeof(cmd->t_run)); cmd 722 daemons/execd/execd_commands.c memset(&cmd->t_queue, 0, sizeof(cmd->t_queue)); cmd 724 daemons/execd/execd_commands.c cmd->epoch_last_run = 0; cmd 726 daemons/execd/execd_commands.c pcmk__reset_result(&(cmd->result)); cmd 727 daemons/execd/execd_commands.c cmd->result.execution_status = PCMK_EXEC_DONE; cmd 731 daemons/execd/execd_commands.c cmd_finalize(lrmd_cmd_t * cmd, lrmd_rsc_t * rsc) cmd 733 daemons/execd/execd_commands.c crm_trace("Resource operation rsc:%s action:%s completed (%p %p)", cmd->rsc_id, cmd->action, cmd 734 daemons/execd/execd_commands.c rsc ? rsc->active : NULL, cmd); cmd 736 daemons/execd/execd_commands.c if (rsc && (rsc->active == cmd)) { cmd 742 daemons/execd/execd_commands.c cmd->rsc_deleted = 1; cmd 746 daemons/execd/execd_commands.c cmd->timeout = cmd->timeout_orig; cmd 748 daemons/execd/execd_commands.c send_cmd_complete_notify(cmd); cmd 750 daemons/execd/execd_commands.c if ((cmd->interval_ms != 0) cmd 751 daemons/execd/execd_commands.c && (cmd->result.execution_status == PCMK_EXEC_CANCELLED)) { cmd 754 daemons/execd/execd_commands.c rsc->recurring_ops = g_list_remove(rsc->recurring_ops, cmd); cmd 755 daemons/execd/execd_commands.c rsc->pending_ops = g_list_remove(rsc->pending_ops, cmd); cmd 757 daemons/execd/execd_commands.c free_lrmd_cmd(cmd); cmd 758 daemons/execd/execd_commands.c } else if (cmd->interval_ms == 0) { cmd 760 daemons/execd/execd_commands.c rsc->pending_ops = g_list_remove(rsc->pending_ops, cmd); cmd 762 daemons/execd/execd_commands.c free_lrmd_cmd(cmd); cmd 765 daemons/execd/execd_commands.c cmd_reset(cmd); cmd 819 daemons/execd/execd_commands.c lrmd_cmd_t *cmd = action->cb_data; cmd 827 daemons/execd/execd_commands.c if (!cmd) { cmd 834 daemons/execd/execd_commands.c if (cmd->result.exit_status != action->rc) { cmd 835 daemons/execd/execd_commands.c cmd->epoch_rcchange = time(NULL); cmd 839 daemons/execd/execd_commands.c cmd->last_pid = action->pid; cmd 842 daemons/execd/execd_commands.c code = services_result2ocf(action->standard, cmd->action, action->rc); cmd 843 daemons/execd/execd_commands.c pcmk__set_result(&(cmd->result), (int) code, cmd 846 daemons/execd/execd_commands.c rsc = cmd->rsc_id ? g_hash_table_lookup(rsc_list, cmd->rsc_id) : NULL; cmd 860 daemons/execd/execd_commands.c if (pcmk__result_ok(&(cmd->result)) cmd 861 daemons/execd/execd_commands.c && pcmk__strcase_any_of(cmd->action, PCMK_ACTION_START, cmd 869 daemons/execd/execd_commands.c cmd->real_action = cmd->action; cmd 870 daemons/execd/execd_commands.c cmd->action = pcmk__str_copy(PCMK_ACTION_MONITOR); cmd 872 daemons/execd/execd_commands.c } else if (cmd->real_action != NULL) { cmd 874 daemons/execd/execd_commands.c if (cmd->result.execution_status == PCMK_EXEC_PENDING) { cmd 877 daemons/execd/execd_commands.c } else if (pcmk__result_ok(&(cmd->result)) cmd 878 daemons/execd/execd_commands.c && pcmk__str_eq(cmd->real_action, PCMK_ACTION_STOP, cmd 883 daemons/execd/execd_commands.c int time_sum = time_diff_ms(NULL, &(cmd->t_first_run)); cmd 884 daemons/execd/execd_commands.c int timeout_left = cmd->timeout_orig - time_sum; cmd 888 daemons/execd/execd_commands.c cmd->rsc_id, cmd->real_action, time_sum, timeout_left, cmd 889 daemons/execd/execd_commands.c crm_exit_str(cmd->result.exit_status), cmd 890 daemons/execd/execd_commands.c cmd->result.exit_status); cmd 891 daemons/execd/execd_commands.c cmd_original_times(cmd); cmd 894 daemons/execd/execd_commands.c if ((cmd->result.execution_status == PCMK_EXEC_DONE) cmd 895 daemons/execd/execd_commands.c && (cmd->result.exit_status == PCMK_OCF_NOT_RUNNING)) { cmd 897 daemons/execd/execd_commands.c if (pcmk__str_eq(cmd->real_action, PCMK_ACTION_START, cmd 899 daemons/execd/execd_commands.c cmd->result.exit_status = PCMK_OCF_UNKNOWN_ERROR; cmd 900 daemons/execd/execd_commands.c } else if (pcmk__str_eq(cmd->real_action, PCMK_ACTION_STOP, cmd 902 daemons/execd/execd_commands.c cmd->result.exit_status = PCMK_OCF_OK; cmd 912 daemons/execd/execd_commands.c int time_sum = time_diff_ms(NULL, &(cmd->t_first_run)); cmd 913 daemons/execd/execd_commands.c int timeout_left = cmd->timeout_orig - time_sum; cmd 914 daemons/execd/execd_commands.c int delay = cmd->timeout_orig / 10; cmd 922 daemons/execd/execd_commands.c cmd->start_delay = delay; cmd 923 daemons/execd/execd_commands.c cmd->timeout = timeout_left; cmd 925 daemons/execd/execd_commands.c if (pcmk__result_ok(&(cmd->result))) { cmd 927 daemons/execd/execd_commands.c cmd->rsc_id, cmd->real_action, time_sum, timeout_left, delay); cmd 929 daemons/execd/execd_commands.c } else if (cmd->result.execution_status == PCMK_EXEC_PENDING) { cmd 931 daemons/execd/execd_commands.c cmd->rsc_id, cmd->action, time_sum, timeout_left, delay); cmd 937 daemons/execd/execd_commands.c cmd->rsc_id, cmd->action, cmd 938 daemons/execd/execd_commands.c crm_exit_str(cmd->result.exit_status), cmd 940 daemons/execd/execd_commands.c cmd->result.exit_status, time_sum, delay); cmd 943 daemons/execd/execd_commands.c cmd_reset(cmd); cmd 947 daemons/execd/execd_commands.c schedule_lrmd_cmd(rsc, cmd); cmd 954 daemons/execd/execd_commands.c cmd->rsc_id, cmd 955 daemons/execd/execd_commands.c (cmd->real_action? cmd->real_action : cmd->action), cmd 956 daemons/execd/execd_commands.c cmd->result.exit_status, time_sum, timeout_left); cmd 957 daemons/execd/execd_commands.c pcmk__set_result(&(cmd->result), PCMK_OCF_UNKNOWN_ERROR, cmd 961 daemons/execd/execd_commands.c cmd_original_times(cmd); cmd 966 daemons/execd/execd_commands.c pcmk__set_result_output(&(cmd->result), services__grab_stdout(action), cmd 968 daemons/execd/execd_commands.c cmd_finalize(cmd, rsc); cmd 981 daemons/execd/execd_commands.c stonith_action_complete(lrmd_cmd_t *cmd, int exit_status, cmd 986 daemons/execd/execd_commands.c lrmd_rsc_t *rsc = g_hash_table_lookup(rsc_list, cmd->rsc_id); cmd 993 daemons/execd/execd_commands.c if (cmd->result.execution_status == PCMK_EXEC_CANCELLED) { cmd 1014 daemons/execd/execd_commands.c if (pcmk__str_eq(cmd->action, PCMK_ACTION_MONITOR, cmd 1018 daemons/execd/execd_commands.c } else if (pcmk__str_eq(cmd->action, PCMK_ACTION_STOP, cmd 1037 daemons/execd/execd_commands.c pcmk__set_result(&cmd->result, exit_status, execution_status, exit_reason); cmd 1040 daemons/execd/execd_commands.c if ((rsc != NULL) && pcmk__result_ok(&(cmd->result))) { cmd 1042 daemons/execd/execd_commands.c if (pcmk__str_eq(cmd->action, PCMK_ACTION_START, pcmk__str_casei)) { cmd 1046 daemons/execd/execd_commands.c } else if (pcmk__str_eq(cmd->action, PCMK_ACTION_STOP, cmd 1056 daemons/execd/execd_commands.c stop_recurring_timer(cmd); cmd 1062 daemons/execd/execd_commands.c if (rsc && (cmd->interval_ms > 0) cmd 1063 daemons/execd/execd_commands.c && (cmd->result.execution_status != PCMK_EXEC_CANCELLED)) { cmd 1064 daemons/execd/execd_commands.c start_recurring_timer(cmd); cmd 1067 daemons/execd/execd_commands.c cmd_finalize(cmd, rsc); cmd 1116 daemons/execd/execd_commands.c lrmd_cmd_t *cmd = op->data; cmd 1122 daemons/execd/execd_commands.c stonith_action_complete(cmd, cmd 1154 daemons/execd/execd_commands.c const lrmd_cmd_t *cmd) cmd 1162 daemons/execd/execd_commands.c if (cmd->params) { cmd 1165 daemons/execd/execd_commands.c g_hash_table_iter_init(&iter, cmd->params); cmd 1178 daemons/execd/execd_commands.c cmd->rsc_id, rsc->provider, cmd 1218 daemons/execd/execd_commands.c execd_stonith_monitor(stonith_t *stonith_api, lrmd_rsc_t *rsc, lrmd_cmd_t *cmd) cmd 1220 daemons/execd/execd_commands.c int rc = stonith_api->cmds->monitor(stonith_api, 0, cmd->rsc_id, cmd 1221 daemons/execd/execd_commands.c pcmk__timeout_ms2s(cmd->timeout)); cmd 1223 daemons/execd/execd_commands.c rc = stonith_api->cmds->register_callback(stonith_api, rc, 0, 0, cmd, cmd 1227 daemons/execd/execd_commands.c rsc->active = cmd; cmd 1236 daemons/execd/execd_commands.c execute_stonith_action(lrmd_rsc_t *rsc, lrmd_cmd_t *cmd) cmd 1243 daemons/execd/execd_commands.c if (pcmk__str_eq(cmd->action, PCMK_ACTION_MONITOR, pcmk__str_casei) cmd 1244 daemons/execd/execd_commands.c && (cmd->interval_ms == 0)) { cmd 1246 daemons/execd/execd_commands.c stonith_action_complete(cmd, rsc->fence_probe_result.exit_status, cmd 1252 daemons/execd/execd_commands.c stonith_action_complete(cmd, PCMK_OCF_UNKNOWN_ERROR, cmd 1257 daemons/execd/execd_commands.c } else if (pcmk__str_eq(cmd->action, PCMK_ACTION_START, pcmk__str_casei)) { cmd 1258 daemons/execd/execd_commands.c rc = execd_stonith_start(stonith_api, rsc, cmd); cmd 1263 daemons/execd/execd_commands.c } else if (pcmk__str_eq(cmd->action, PCMK_ACTION_STOP, pcmk__str_casei)) { cmd 1266 daemons/execd/execd_commands.c } else if (pcmk__str_eq(cmd->action, PCMK_ACTION_MONITOR, cmd 1271 daemons/execd/execd_commands.c stonith_action_complete(cmd, PCMK_OCF_UNIMPLEMENT_FEATURE, cmd 1278 daemons/execd/execd_commands.c rc = execd_stonith_monitor(stonith_api, rsc, cmd); cmd 1285 daemons/execd/execd_commands.c stonith_action_complete(cmd, cmd 1292 daemons/execd/execd_commands.c execute_nonstonith_action(lrmd_rsc_t *rsc, lrmd_cmd_t *cmd) cmd 1297 daemons/execd/execd_commands.c pcmk__assert((rsc != NULL) && (cmd != NULL)); cmd 1300 daemons/execd/execd_commands.c rsc->rsc_id, cmd->action, rsc->class, rsc->provider, rsc->type); cmd 1302 daemons/execd/execd_commands.c params_copy = pcmk__str_table_dup(cmd->params); cmd 1306 daemons/execd/execd_commands.c normalize_action_name(rsc, cmd->action), cmd 1307 daemons/execd/execd_commands.c cmd->interval_ms, cmd->timeout, cmd 1308 daemons/execd/execd_commands.c params_copy, cmd->service_flags); cmd 1311 daemons/execd/execd_commands.c pcmk__set_result(&(cmd->result), PCMK_OCF_UNKNOWN_ERROR, cmd 1313 daemons/execd/execd_commands.c cmd_finalize(cmd, rsc); cmd 1318 daemons/execd/execd_commands.c pcmk__set_result(&(cmd->result), action->rc, action->status, cmd 1321 daemons/execd/execd_commands.c cmd_finalize(cmd, rsc); cmd 1325 daemons/execd/execd_commands.c action->cb_data = cmd; cmd 1345 daemons/execd/execd_commands.c pcmk__set_result(&(cmd->result), action->rc, action->status, cmd 1355 daemons/execd/execd_commands.c lrmd_cmd_t *cmd = NULL; cmd 1367 daemons/execd/execd_commands.c cmd = first->data; cmd 1368 daemons/execd/execd_commands.c if (cmd->delay_id) { cmd 1371 daemons/execd/execd_commands.c cmd->rsc_id, cmd->action, cmd->start_delay); cmd 1378 daemons/execd/execd_commands.c get_current_time(&(cmd->t_run), &(cmd->t_first_run)); cmd 1380 daemons/execd/execd_commands.c cmd->epoch_last_run = time(NULL); cmd 1383 daemons/execd/execd_commands.c if (!cmd) { cmd 1388 daemons/execd/execd_commands.c rsc->active = cmd; /* only one op at a time for a rsc */ cmd 1389 daemons/execd/execd_commands.c if (cmd->interval_ms) { cmd 1390 daemons/execd/execd_commands.c rsc->recurring_ops = g_list_append(rsc->recurring_ops, cmd); cmd 1393 daemons/execd/execd_commands.c log_execute(cmd); cmd 1396 daemons/execd/execd_commands.c execute_stonith_action(rsc, cmd); cmd 1398 daemons/execd/execd_commands.c execute_nonstonith_action(rsc, cmd); cmd 1415 daemons/execd/execd_commands.c lrmd_cmd_t *cmd = gIter->data; cmd 1418 daemons/execd/execd_commands.c cmd->result.execution_status = PCMK_EXEC_CANCELLED; cmd 1419 daemons/execd/execd_commands.c cmd_finalize(cmd, NULL); cmd 1429 daemons/execd/execd_commands.c lrmd_cmd_t *cmd = gIter->data; cmd 1432 daemons/execd/execd_commands.c cmd->result.execution_status = PCMK_EXEC_CANCELLED; cmd 1437 daemons/execd/execd_commands.c if (rsc->active != cmd) { cmd 1438 daemons/execd/execd_commands.c cmd_finalize(cmd, NULL); cmd 1446 daemons/execd/execd_commands.c normalize_action_name(rsc, cmd->action), cmd 1447 daemons/execd/execd_commands.c cmd->interval_ms); cmd 1606 daemons/execd/execd_commands.c lrmd_cmd_t *cmd = NULL; cmd 1621 daemons/execd/execd_commands.c cmd = create_lrmd_cmd(request, client); cmd 1622 daemons/execd/execd_commands.c call_id = cmd->call_id; cmd 1626 daemons/execd/execd_commands.c schedule_lrmd_cmd(rsc, cmd); cmd 1653 daemons/execd/execd_commands.c lrmd_cmd_t *cmd = gIter->data; cmd 1655 daemons/execd/execd_commands.c if (action_matches(cmd, action, interval_ms)) { cmd 1656 daemons/execd/execd_commands.c cmd->result.execution_status = PCMK_EXEC_CANCELLED; cmd 1657 daemons/execd/execd_commands.c cmd_finalize(cmd, rsc); cmd 1666 daemons/execd/execd_commands.c lrmd_cmd_t *cmd = gIter->data; cmd 1668 daemons/execd/execd_commands.c if (action_matches(cmd, action, interval_ms)) { cmd 1669 daemons/execd/execd_commands.c cmd->result.execution_status = PCMK_EXEC_CANCELLED; cmd 1670 daemons/execd/execd_commands.c if (rsc->active != cmd) { cmd 1671 daemons/execd/execd_commands.c cmd_finalize(cmd, rsc); cmd 1712 daemons/execd/execd_commands.c lrmd_cmd_t *cmd = cmd_iter->data; cmd 1714 daemons/execd/execd_commands.c if (cmd->interval_ms == 0) { cmd 1718 daemons/execd/execd_commands.c if (client_id && !pcmk__str_eq(cmd->client_id, client_id, pcmk__str_casei)) { cmd 1722 daemons/execd/execd_commands.c cancel_op(rsc->rsc_id, cmd->action, cmd->interval_ms); cmd 1753 daemons/execd/execd_commands.c lrmd_cmd_t *cmd = item->data; cmd 1757 daemons/execd/execd_commands.c pcmk__s(cmd->real_action, cmd->action)); cmd 1758 daemons/execd/execd_commands.c crm_xml_add_ms(op_xml, PCMK__XA_LRMD_RSC_INTERVAL, cmd->interval_ms); cmd 1759 daemons/execd/execd_commands.c crm_xml_add_int(op_xml, PCMK__XA_LRMD_TIMEOUT, cmd->timeout_orig); cmd 178 daemons/fenced/cts-fence-helper.c #define single_test(cmd, str, num_notifications, expected_rc) \ cmd 181 daemons/fenced/cts-fence-helper.c rc = cmd; \ cmd 117 daemons/fenced/fenced_commands.c static xmlNode *construct_async_reply(const async_command_t *cmd, cmd 250 daemons/fenced/fenced_commands.c cmd_device(const async_command_t *cmd) cmd 252 daemons/fenced/fenced_commands.c if ((cmd == NULL) || (cmd->device == NULL) || (device_list == NULL)) { cmd 255 daemons/fenced/fenced_commands.c return g_hash_table_lookup(device_list, cmd->device); cmd 303 daemons/fenced/fenced_commands.c free_async_command(async_command_t * cmd) cmd 305 daemons/fenced/fenced_commands.c if (!cmd) { cmd 309 daemons/fenced/fenced_commands.c if (cmd->delay_id) { cmd 310 daemons/fenced/fenced_commands.c g_source_remove(cmd->delay_id); cmd 313 daemons/fenced/fenced_commands.c cmd_list = g_list_remove(cmd_list, cmd); cmd 315 daemons/fenced/fenced_commands.c g_list_free_full(cmd->device_list, free); cmd 316 daemons/fenced/fenced_commands.c free(cmd->device); cmd 317 daemons/fenced/fenced_commands.c free(cmd->action); cmd 318 daemons/fenced/fenced_commands.c free(cmd->target); cmd 319 daemons/fenced/fenced_commands.c free(cmd->remote_op_id); cmd 320 daemons/fenced/fenced_commands.c free(cmd->client); cmd 321 daemons/fenced/fenced_commands.c free(cmd->client_name); cmd 322 daemons/fenced/fenced_commands.c free(cmd->origin); cmd 323 daemons/fenced/fenced_commands.c free(cmd->op); cmd 324 daemons/fenced/fenced_commands.c free(cmd); cmd 342 daemons/fenced/fenced_commands.c async_command_t *cmd = NULL; cmd 354 daemons/fenced/fenced_commands.c cmd = pcmk__assert_alloc(1, sizeof(async_command_t)); cmd 357 daemons/fenced/fenced_commands.c cmd->action = crm_element_value_copy(op, PCMK__XA_ST_DEVICE_ACTION); cmd 358 daemons/fenced/fenced_commands.c cmd->op = crm_element_value_copy(msg, PCMK__XA_ST_OP); cmd 359 daemons/fenced/fenced_commands.c cmd->client = crm_element_value_copy(msg, PCMK__XA_ST_CLIENTID); cmd 360 daemons/fenced/fenced_commands.c if ((cmd->action == NULL) || (cmd->op == NULL) || (cmd->client == NULL)) { cmd 361 daemons/fenced/fenced_commands.c free_async_command(cmd); cmd 365 daemons/fenced/fenced_commands.c crm_element_value_int(msg, PCMK__XA_ST_CALLID, &(cmd->id)); cmd 366 daemons/fenced/fenced_commands.c crm_element_value_int(msg, PCMK__XA_ST_DELAY, &(cmd->start_delay)); cmd 367 daemons/fenced/fenced_commands.c crm_element_value_int(msg, PCMK__XA_ST_TIMEOUT, &(cmd->default_timeout)); cmd 368 daemons/fenced/fenced_commands.c cmd->timeout = cmd->default_timeout; cmd 370 daemons/fenced/fenced_commands.c rc = pcmk__xe_get_flags(msg, PCMK__XA_ST_CALLOPT, &(cmd->options), cmd 376 daemons/fenced/fenced_commands.c cmd->origin = crm_element_value_copy(msg, PCMK__XA_SRC); cmd 377 daemons/fenced/fenced_commands.c cmd->remote_op_id = crm_element_value_copy(msg, PCMK__XA_ST_REMOTE_OP); cmd 378 daemons/fenced/fenced_commands.c cmd->client_name = crm_element_value_copy(msg, PCMK__XA_ST_CLIENTNAME); cmd 379 daemons/fenced/fenced_commands.c cmd->target = crm_element_value_copy(op, PCMK__XA_ST_TARGET); cmd 380 daemons/fenced/fenced_commands.c cmd->device = crm_element_value_copy(op, PCMK__XA_ST_DEVICE_ID); cmd 382 daemons/fenced/fenced_commands.c cmd->done_cb = st_child_done; cmd 385 daemons/fenced/fenced_commands.c cmd_list = g_list_append(cmd_list, cmd); cmd 387 daemons/fenced/fenced_commands.c return cmd; cmd 415 daemons/fenced/fenced_commands.c async_command_t *cmd = gIter->data; cmd 419 daemons/fenced/fenced_commands.c if (cmd->active_on == device) { cmd 430 daemons/fenced/fenced_commands.c async_command_t *cmd = (async_command_t *) user_data; cmd 435 daemons/fenced/fenced_commands.c cmd->activating_on?cmd->activating_on:cmd->active_on; cmd 439 daemons/fenced/fenced_commands.c cmd->action, pid, cmd 440 daemons/fenced/fenced_commands.c ((cmd->target == NULL)? "" : " targeting "), cmd 441 daemons/fenced/fenced_commands.c pcmk__s(cmd->target, ""), device->id, cmd->timeout); cmd 442 daemons/fenced/fenced_commands.c cmd->active_on = device; cmd 443 daemons/fenced/fenced_commands.c cmd->activating_on = NULL; cmd 482 daemons/fenced/fenced_commands.c report_internal_result(async_command_t *cmd, int exit_status, cmd 488 daemons/fenced/fenced_commands.c cmd->done_cb(0, &result, cmd); cmd 498 daemons/fenced/fenced_commands.c async_command_t *cmd = NULL; cmd 534 daemons/fenced/fenced_commands.c cmd = pending_op; cmd 538 daemons/fenced/fenced_commands.c if (cmd == NULL) { cmd 545 daemons/fenced/fenced_commands.c if (pcmk__is_fencing_action(cmd->action)) { cmd 551 daemons/fenced/fenced_commands.c crm_info("Faking success for %s watchdog operation", cmd->action); cmd 552 daemons/fenced/fenced_commands.c report_internal_result(cmd, CRM_EX_OK, PCMK_EXEC_DONE, NULL); cmd 560 daemons/fenced/fenced_commands.c if (pcmk__str_eq(cmd->action, PCMK_ACTION_STOP, pcmk__str_none)) { cmd 568 daemons/fenced/fenced_commands.c report_internal_result(cmd, CRM_EX_ERROR, PCMK_EXEC_NO_SECRETS, cmd 575 daemons/fenced/fenced_commands.c action_str = cmd->action; cmd 576 daemons/fenced/fenced_commands.c if (pcmk__str_eq(cmd->action, PCMK_ACTION_REBOOT, pcmk__str_none) cmd 581 daemons/fenced/fenced_commands.c ((cmd->target == NULL)? "" : " targeting "), cmd 582 daemons/fenced/fenced_commands.c pcmk__s(cmd->target, ""), device->id, device->agent); cmd 593 daemons/fenced/fenced_commands.c action = stonith__action_create(device->agent, action_str, cmd->target, cmd 594 daemons/fenced/fenced_commands.c cmd->target_nodeid, cmd->timeout, cmd 599 daemons/fenced/fenced_commands.c cmd->activating_on = device; cmd 600 daemons/fenced/fenced_commands.c exec_rc = stonith__execute_async(action, (void *)cmd, cmd->done_cb, cmd 603 daemons/fenced/fenced_commands.c cmd->activating_on = NULL; cmd 604 daemons/fenced/fenced_commands.c cmd->done_cb(0, stonith__action_result(action), cmd); cmd 627 daemons/fenced/fenced_commands.c async_command_t *cmd = data; cmd 628 daemons/fenced/fenced_commands.c stonith_device_t *device = cmd_device(cmd); cmd 630 daemons/fenced/fenced_commands.c cmd->delay_id = 0; cmd 639 daemons/fenced/fenced_commands.c schedule_stonith_command(async_command_t * cmd, stonith_device_t * device) cmd 643 daemons/fenced/fenced_commands.c int requested_delay = cmd->start_delay; cmd 645 daemons/fenced/fenced_commands.c CRM_CHECK(cmd != NULL, return); cmd 648 daemons/fenced/fenced_commands.c if (cmd->device) { cmd 649 daemons/fenced/fenced_commands.c free(cmd->device); cmd 652 daemons/fenced/fenced_commands.c if (device->include_nodeid && (cmd->target != NULL)) { cmd 654 daemons/fenced/fenced_commands.c pcmk__get_node(0, cmd->target, NULL, cmd 657 daemons/fenced/fenced_commands.c cmd->target_nodeid = node->cluster_layer_id; cmd 660 daemons/fenced/fenced_commands.c cmd->device = pcmk__str_copy(device->id); cmd 661 daemons/fenced/fenced_commands.c cmd->timeout = get_action_timeout(device, cmd->action, cmd->default_timeout); cmd 663 daemons/fenced/fenced_commands.c if (cmd->remote_op_id) { cmd 666 daemons/fenced/fenced_commands.c cmd->action, cmd 667 daemons/fenced/fenced_commands.c (cmd->target == NULL)? "" : " targeting ", cmd 668 daemons/fenced/fenced_commands.c pcmk__s(cmd->target, ""), cmd 669 daemons/fenced/fenced_commands.c device->id, cmd->origin, cmd->remote_op_id, cmd->timeout); cmd 672 daemons/fenced/fenced_commands.c cmd->action, cmd 673 daemons/fenced/fenced_commands.c (cmd->target == NULL)? "" : " targeting ", cmd 674 daemons/fenced/fenced_commands.c pcmk__s(cmd->target, ""), cmd 675 daemons/fenced/fenced_commands.c device->id, cmd->client, cmd->timeout); cmd 678 daemons/fenced/fenced_commands.c device->pending_ops = g_list_append(device->pending_ops, cmd); cmd 686 daemons/fenced/fenced_commands.c delay_max = get_action_delay_max(device, cmd->action); cmd 687 daemons/fenced/fenced_commands.c delay_base = get_action_delay_base(device, cmd->action, cmd->target); cmd 695 daemons/fenced/fenced_commands.c delay_base, delay_max, cmd->action, device->id); cmd 700 daemons/fenced/fenced_commands.c cmd->start_delay += cmd 705 daemons/fenced/fenced_commands.c if (cmd->start_delay > 0) { cmd 708 daemons/fenced/fenced_commands.c cmd->action, cmd 709 daemons/fenced/fenced_commands.c (cmd->target == NULL)? "" : " targeting ", cmd 710 daemons/fenced/fenced_commands.c pcmk__s(cmd->target, ""), cmd 711 daemons/fenced/fenced_commands.c device->id, cmd->start_delay, cmd->timeout, cmd 713 daemons/fenced/fenced_commands.c cmd->delay_id = cmd 714 daemons/fenced/fenced_commands.c pcmk__create_timer(cmd->start_delay * 1000, start_delay_helper, cmd); cmd 728 daemons/fenced/fenced_commands.c async_command_t *cmd = gIter->data; cmd 730 daemons/fenced/fenced_commands.c crm_warn("Removal of device '%s' purged operation '%s'", device->id, cmd->action); cmd 731 daemons/fenced/fenced_commands.c report_internal_result(cmd, CRM_EX_ERROR, PCMK_EXEC_NO_FENCE_DEVICE, cmd 1104 daemons/fenced/fenced_commands.c async_command_t *cmd = NULL; cmd 1106 daemons/fenced/fenced_commands.c cmd = pcmk__assert_alloc(1, sizeof(async_command_t)); cmd 1108 daemons/fenced/fenced_commands.c cmd->id = -1; cmd 1109 daemons/fenced/fenced_commands.c cmd->default_timeout = timeout ? timeout : 60; cmd 1110 daemons/fenced/fenced_commands.c cmd->timeout = cmd->default_timeout; cmd 1111 daemons/fenced/fenced_commands.c cmd->action = pcmk__str_copy(action); cmd 1112 daemons/fenced/fenced_commands.c cmd->target = pcmk__str_copy(target); cmd 1113 daemons/fenced/fenced_commands.c cmd->device = pcmk__str_copy(device->id); cmd 1114 daemons/fenced/fenced_commands.c cmd->origin = pcmk__str_copy(origin); cmd 1115 daemons/fenced/fenced_commands.c cmd->client = pcmk__str_copy(crm_system_name); cmd 1116 daemons/fenced/fenced_commands.c cmd->client_name = pcmk__str_copy(crm_system_name); cmd 1118 daemons/fenced/fenced_commands.c cmd->internal_user_data = internal_user_data; cmd 1119 daemons/fenced/fenced_commands.c cmd->done_cb = done_cb; /* cmd, not internal_user_data, is passed to 'done_cb' as the userdata */ cmd 1121 daemons/fenced/fenced_commands.c schedule_stonith_command(cmd, device); cmd 1135 daemons/fenced/fenced_commands.c async_command_t *cmd = user_data; cmd 1136 daemons/fenced/fenced_commands.c struct device_search_s *search = cmd->internal_user_data; cmd 1137 daemons/fenced/fenced_commands.c stonith_device_t *dev = cmd_device(cmd); cmd 1140 daemons/fenced/fenced_commands.c free_async_command(cmd); cmd 1185 daemons/fenced/fenced_commands.c async_command_t *cmd = user_data; cmd 1186 daemons/fenced/fenced_commands.c struct device_search_s *search = cmd->internal_user_data; cmd 1187 daemons/fenced/fenced_commands.c stonith_device_t *dev = cmd_device(cmd); cmd 1190 daemons/fenced/fenced_commands.c free_async_command(cmd); cmd 1897 daemons/fenced/fenced_commands.c async_command_t *cmd = NULL; cmd 1947 daemons/fenced/fenced_commands.c cmd = create_async_command(msg); cmd 1948 daemons/fenced/fenced_commands.c if (cmd == NULL) { cmd 1954 daemons/fenced/fenced_commands.c schedule_stonith_command(cmd, device); cmd 2488 daemons/fenced/fenced_commands.c log_async_result(const async_command_t *cmd, cmd 2494 daemons/fenced/fenced_commands.c guint devices_remaining = g_list_length(cmd->next_device_iter); cmd 2500 daemons/fenced/fenced_commands.c log_level = (cmd->target == NULL)? LOG_DEBUG : LOG_NOTICE; cmd 2502 daemons/fenced/fenced_commands.c && !pcmk__str_eq(cmd->action, PCMK_ACTION_METADATA, cmd 2508 daemons/fenced/fenced_commands.c log_level = (cmd->target == NULL)? LOG_NOTICE : LOG_ERR; cmd 2510 daemons/fenced/fenced_commands.c && !pcmk__str_eq(cmd->action, PCMK_ACTION_METADATA, cmd 2517 daemons/fenced/fenced_commands.c pcmk__g_strcat(msg, "Operation '", cmd->action, "' ", NULL); cmd 2521 daemons/fenced/fenced_commands.c if (cmd->target != NULL) { cmd 2522 daemons/fenced/fenced_commands.c pcmk__g_strcat(msg, "targeting ", cmd->target, " ", NULL); cmd 2524 daemons/fenced/fenced_commands.c if (cmd->device != NULL) { cmd 2525 daemons/fenced/fenced_commands.c pcmk__g_strcat(msg, "using ", cmd->device, " ", NULL); cmd 2549 daemons/fenced/fenced_commands.c (op_merged? "merged " : ""), cmd->id, cmd 2550 daemons/fenced/fenced_commands.c cmd->client_name); cmd 2558 daemons/fenced/fenced_commands.c char *prefix = crm_strdup_printf("%s[%d]", cmd->device, pid); cmd 2575 daemons/fenced/fenced_commands.c send_async_reply(const async_command_t *cmd, const pcmk__action_result_t *result, cmd 2581 daemons/fenced/fenced_commands.c CRM_CHECK((cmd != NULL) && (result != NULL), return); cmd 2583 daemons/fenced/fenced_commands.c log_async_result(cmd, result, pid, NULL, merged); cmd 2585 daemons/fenced/fenced_commands.c if (cmd->client != NULL) { cmd 2586 daemons/fenced/fenced_commands.c client = pcmk__find_client_by_id(cmd->client); cmd 2587 daemons/fenced/fenced_commands.c if ((client == NULL) && (cmd->origin == NULL)) { cmd 2588 daemons/fenced/fenced_commands.c crm_trace("Skipping reply to %s: no longer a client", cmd->client); cmd 2593 daemons/fenced/fenced_commands.c reply = construct_async_reply(cmd, result); cmd 2598 daemons/fenced/fenced_commands.c if (pcmk__is_fencing_action(cmd->action) cmd 2599 daemons/fenced/fenced_commands.c && pcmk__str_eq(cmd->origin, cmd->target, pcmk__str_casei)) { cmd 2604 daemons/fenced/fenced_commands.c cmd->action, cmd->target); cmd 2610 daemons/fenced/fenced_commands.c stonith_send_reply(reply, cmd->options, cmd->origin, client); cmd 2618 daemons/fenced/fenced_commands.c cancel_stonith_command(async_command_t * cmd) cmd 2620 daemons/fenced/fenced_commands.c stonith_device_t *device = cmd_device(cmd); cmd 2624 daemons/fenced/fenced_commands.c cmd->action, device->id); cmd 2625 daemons/fenced/fenced_commands.c device->pending_ops = g_list_remove(device->pending_ops, cmd); cmd 2649 daemons/fenced/fenced_commands.c reply_to_duplicates(async_command_t *cmd, const pcmk__action_result_t *result, cmd 2659 daemons/fenced/fenced_commands.c if (cmd == cmd_other) { cmd 2669 daemons/fenced/fenced_commands.c if (pcmk__str_eq(cmd->client, cmd_other->client, pcmk__str_casei) || cmd 2670 daemons/fenced/fenced_commands.c !pcmk__str_eq(cmd->target, cmd_other->target, pcmk__str_casei) || cmd 2671 daemons/fenced/fenced_commands.c !pcmk__str_eq(cmd->action, cmd_other->action, pcmk__str_none) || cmd 2672 daemons/fenced/fenced_commands.c !pcmk__str_eq(cmd->device, cmd_other->device, pcmk__str_casei)) { cmd 2682 daemons/fenced/fenced_commands.c cmd->client_name); cmd 2703 daemons/fenced/fenced_commands.c next_required_device(async_command_t *cmd) cmd 2705 daemons/fenced/fenced_commands.c for (GList *iter = cmd->next_device_iter; iter != NULL; iter = iter->next) { cmd 2709 daemons/fenced/fenced_commands.c if (is_action_required(cmd->action, next_device)) { cmd 2713 daemons/fenced/fenced_commands.c cmd->next_device_iter = iter->next; cmd 2723 daemons/fenced/fenced_commands.c async_command_t *cmd = user_data; cmd 2728 daemons/fenced/fenced_commands.c CRM_CHECK(cmd != NULL, return); cmd 2730 daemons/fenced/fenced_commands.c device = cmd_device(cmd); cmd 2731 daemons/fenced/fenced_commands.c cmd->active_on = NULL; cmd 2736 daemons/fenced/fenced_commands.c && pcmk__strcase_any_of(cmd->action, PCMK_ACTION_LIST, cmd 2747 daemons/fenced/fenced_commands.c next_device = next_required_device(cmd); cmd 2749 daemons/fenced/fenced_commands.c } else if ((cmd->next_device_iter != NULL) cmd 2750 daemons/fenced/fenced_commands.c && !is_action_required(cmd->action, device)) { cmd 2754 daemons/fenced/fenced_commands.c cmd->next_device_iter->data); cmd 2755 daemons/fenced/fenced_commands.c cmd->next_device_iter = cmd->next_device_iter->next; cmd 2759 daemons/fenced/fenced_commands.c send_async_reply(cmd, result, pid, false); cmd 2761 daemons/fenced/fenced_commands.c reply_to_duplicates(cmd, result, pid); cmd 2763 daemons/fenced/fenced_commands.c free_async_command(cmd); cmd 2766 daemons/fenced/fenced_commands.c log_async_result(cmd, result, pid, next_device->id, false); cmd 2767 daemons/fenced/fenced_commands.c schedule_stonith_command(cmd, next_device); cmd 2788 daemons/fenced/fenced_commands.c async_command_t *cmd = user_data; cmd 2793 daemons/fenced/fenced_commands.c ndevices, pcmk__plural_s(ndevices), cmd->target); cmd 2806 daemons/fenced/fenced_commands.c cmd->target); cmd 2807 daemons/fenced/fenced_commands.c send_async_reply(cmd, &result, 0, false); cmd 2809 daemons/fenced/fenced_commands.c free_async_command(cmd); cmd 2813 daemons/fenced/fenced_commands.c cmd->device_list = devices; cmd 2814 daemons/fenced/fenced_commands.c cmd->next_device_iter = devices->next; cmd 2815 daemons/fenced/fenced_commands.c schedule_stonith_command(cmd, device); cmd 2831 daemons/fenced/fenced_commands.c async_command_t *cmd = NULL; cmd 2838 daemons/fenced/fenced_commands.c cmd = create_async_command(msg); cmd 2839 daemons/fenced/fenced_commands.c if (cmd == NULL) { cmd 2854 daemons/fenced/fenced_commands.c schedule_stonith_command(cmd, device); cmd 2859 daemons/fenced/fenced_commands.c if (pcmk_is_set(cmd->options, st_opt_cs_nodeid)) { cmd 2873 daemons/fenced/fenced_commands.c get_capable_devices(host, cmd->action, cmd->default_timeout, cmd 2874 daemons/fenced/fenced_commands.c TRUE, cmd, stonith_fence_get_devices_cb, cmd 2875 daemons/fenced/fenced_commands.c fenced_support_flag(cmd->action)); cmd 2954 daemons/fenced/fenced_commands.c construct_async_reply(const async_command_t *cmd, cmd 2961 daemons/fenced/fenced_commands.c crm_xml_add(reply, PCMK__XA_ST_OP, cmd->op); cmd 2962 daemons/fenced/fenced_commands.c crm_xml_add(reply, PCMK__XA_ST_DEVICE_ID, cmd->device); cmd 2963 daemons/fenced/fenced_commands.c crm_xml_add(reply, PCMK__XA_ST_REMOTE_OP, cmd->remote_op_id); cmd 2964 daemons/fenced/fenced_commands.c crm_xml_add(reply, PCMK__XA_ST_CLIENTID, cmd->client); cmd 2965 daemons/fenced/fenced_commands.c crm_xml_add(reply, PCMK__XA_ST_CLIENTNAME, cmd->client_name); cmd 2966 daemons/fenced/fenced_commands.c crm_xml_add(reply, PCMK__XA_ST_TARGET, cmd->target); cmd 2967 daemons/fenced/fenced_commands.c crm_xml_add(reply, PCMK__XA_ST_DEVICE_ACTION, cmd->op); cmd 2968 daemons/fenced/fenced_commands.c crm_xml_add(reply, PCMK__XA_ST_ORIGIN, cmd->origin); cmd 2969 daemons/fenced/fenced_commands.c crm_xml_add_int(reply, PCMK__XA_ST_CALLID, cmd->id); cmd 2970 daemons/fenced/fenced_commands.c crm_xml_add_int(reply, PCMK__XA_ST_CALLOPT, cmd->options); cmd 28 include/crm/common/options_internal.h _Noreturn void pcmk__cli_help(char cmd); cmd 302 lib/common/ipc_pacemakerd.c xmlNode *cmd; cmd 314 lib/common/ipc_pacemakerd.c cmd = pcmk__new_request(pcmk_ipc_pacemakerd, sender_system, NULL, cmd 318 lib/common/ipc_pacemakerd.c if (cmd) { cmd 319 lib/common/ipc_pacemakerd.c rc = pcmk__send_ipc_request(api, cmd); cmd 324 lib/common/ipc_pacemakerd.c pcmk__xml_free(cmd); cmd 159 lib/common/ipc_schedulerd.c xmlNode *cmd = NULL; cmd 172 lib/common/ipc_schedulerd.c cmd = pcmk__new_request(pcmk_ipc_schedulerd, sender_system, NULL, cmd 176 lib/common/ipc_schedulerd.c if (cmd) { cmd 177 lib/common/ipc_schedulerd.c rc = pcmk__send_ipc_request(api, cmd); cmd 183 lib/common/ipc_schedulerd.c *ref = strdup(crm_element_value(cmd, PCMK_XA_REFERENCE)); cmd 184 lib/common/ipc_schedulerd.c pcmk__xml_free(cmd); cmd 22 lib/common/options.c pcmk__cli_help(char cmd) cmd 24 lib/common/options.c if (cmd == 'v' || cmd == '$') { cmd 29 lib/common/options.c } else if (cmd == '!') { cmd 23 lib/common/unittest.c char *cmd = NULL; cmd 53 lib/common/unittest.c cmd = crm_strdup_printf("xmllint --relaxng %s/api/api-result.rng %s", cmd 56 lib/common/unittest.c if (!g_spawn_command_line_sync(cmd, &out, &err, &status, &gerr)) { cmd 66 lib/common/unittest.c free(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 667 tools/crm_node.c xmlNode *cmd = NULL; cmd 689 tools/crm_node.c cmd = pcmk__new_request(pcmk_ipc_fenced, crm_system_name, NULL, cmd 692 tools/crm_node.c crm_xml_add_ll(cmd, PCMK_XA_ID, node_id); cmd 694 tools/crm_node.c crm_xml_add(cmd, PCMK_XA_UNAME, node_name); cmd 696 tools/crm_node.c rc = crm_ipc_send(conn, cmd, 0, 0, NULL); cmd 706 tools/crm_node.c pcmk__xml_free(cmd); cmd 209 tools/crm_resource_runtime.c const char * attr_name, cib_t * cib, const char * cmd, cmd 229 tools/crm_resource_runtime.c cmd, attr_name, rsc->id, rsc_id); cmd 246 tools/crm_resource_runtime.c attr_name, lookup_id, cmd, rsc_id); cmd 73 tools/crm_shadow.c enum shadow_command cmd; cmd 1042 tools/crm_shadow.c options.cmd = shadow_cmd_which; cmd 1045 tools/crm_shadow.c options.cmd = shadow_cmd_display; cmd 1048 tools/crm_shadow.c options.cmd = shadow_cmd_diff; cmd 1051 tools/crm_shadow.c options.cmd = shadow_cmd_file; cmd 1054 tools/crm_shadow.c options.cmd = shadow_cmd_create; cmd 1057 tools/crm_shadow.c options.cmd = shadow_cmd_create_empty; cmd 1060 tools/crm_shadow.c options.cmd = shadow_cmd_commit; cmd 1063 tools/crm_shadow.c options.cmd = shadow_cmd_delete; cmd 1066 tools/crm_shadow.c options.cmd = shadow_cmd_edit; cmd 1069 tools/crm_shadow.c options.cmd = shadow_cmd_reset; cmd 1072 tools/crm_shadow.c options.cmd = shadow_cmd_switch; cmd 1236 tools/crm_shadow.c if (options.cmd == shadow_cmd_none) { cmd 1255 tools/crm_shadow.c switch (options.cmd) {