cmd 86 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 87 daemons/controld/controld_remote_ra.c static void handle_remote_ra_stop(lrm_state_t * lrm_state, remote_ra_cmd_t * cmd); cmd 93 daemons/controld/controld_remote_ra.c remote_ra_cmd_t *cmd = user_data; cmd 95 daemons/controld/controld_remote_ra.c if (!cmd) { cmd 98 daemons/controld/controld_remote_ra.c if (cmd->delay_id) { cmd 99 daemons/controld/controld_remote_ra.c g_source_remove(cmd->delay_id); cmd 101 daemons/controld/controld_remote_ra.c if (cmd->interval_id) { cmd 102 daemons/controld/controld_remote_ra.c g_source_remove(cmd->interval_id); cmd 104 daemons/controld/controld_remote_ra.c if (cmd->monitor_timeout_id) { cmd 105 daemons/controld/controld_remote_ra.c g_source_remove(cmd->monitor_timeout_id); cmd 107 daemons/controld/controld_remote_ra.c if (cmd->takeover_timeout_id) { cmd 108 daemons/controld/controld_remote_ra.c g_source_remove(cmd->takeover_timeout_id); cmd 110 daemons/controld/controld_remote_ra.c free(cmd->owner); cmd 111 daemons/controld/controld_remote_ra.c free(cmd->rsc_id); cmd 112 daemons/controld/controld_remote_ra.c free(cmd->action); cmd 113 daemons/controld/controld_remote_ra.c free(cmd->userdata); cmd 114 daemons/controld/controld_remote_ra.c pcmk__reset_result(&(cmd->result)); cmd 115 daemons/controld/controld_remote_ra.c lrmd_key_value_freeall(cmd->params); cmd 116 daemons/controld/controld_remote_ra.c free(cmd); cmd 135 daemons/controld/controld_remote_ra.c remote_ra_cmd_t *cmd = data; cmd 138 daemons/controld/controld_remote_ra.c cmd->interval_id = 0; cmd 139 daemons/controld/controld_remote_ra.c connection_rsc = lrm_state_find(cmd->rsc_id); cmd 143 daemons/controld/controld_remote_ra.c ra_data->recurring_cmds = g_list_remove(ra_data->recurring_cmds, cmd); cmd 145 daemons/controld/controld_remote_ra.c ra_data->cmds = g_list_append(ra_data->cmds, cmd); cmd 154 daemons/controld/controld_remote_ra.c remote_ra_cmd_t *cmd = data; cmd 157 daemons/controld/controld_remote_ra.c cmd->delay_id = 0; cmd 158 daemons/controld/controld_remote_ra.c connection_rsc = lrm_state_find(cmd->rsc_id); cmd 302 daemons/controld/controld_remote_ra.c check_remote_node_state(remote_ra_cmd_t *cmd) cmd 305 daemons/controld/controld_remote_ra.c if (!pcmk__result_ok(&(cmd->result))) { cmd 309 daemons/controld/controld_remote_ra.c if (pcmk__str_eq(cmd->action, "start", pcmk__str_casei)) { cmd 310 daemons/controld/controld_remote_ra.c remote_node_up(cmd->rsc_id); cmd 312 daemons/controld/controld_remote_ra.c } else if (pcmk__str_eq(cmd->action, "migrate_from", pcmk__str_casei)) { cmd 320 daemons/controld/controld_remote_ra.c crm_node_t *node = crm_remote_peer_get(cmd->rsc_id); cmd 325 daemons/controld/controld_remote_ra.c } else if (pcmk__str_eq(cmd->action, "stop", pcmk__str_casei)) { cmd 326 daemons/controld/controld_remote_ra.c lrm_state_t *lrm_state = lrm_state_find(cmd->rsc_id); cmd 332 daemons/controld/controld_remote_ra.c remote_node_down(cmd->rsc_id, DOWN_KEEP_LRM); cmd 338 daemons/controld/controld_remote_ra.c crm_remote_peer_cache_remove(cmd->rsc_id); cmd 355 daemons/controld/controld_remote_ra.c report_remote_ra_result(remote_ra_cmd_t * cmd) cmd 359 daemons/controld/controld_remote_ra.c check_remote_node_state(cmd); cmd 362 daemons/controld/controld_remote_ra.c op.rsc_id = cmd->rsc_id; cmd 363 daemons/controld/controld_remote_ra.c op.op_type = cmd->action; cmd 364 daemons/controld/controld_remote_ra.c op.user_data = cmd->userdata; cmd 365 daemons/controld/controld_remote_ra.c op.timeout = cmd->timeout; cmd 366 daemons/controld/controld_remote_ra.c op.interval_ms = cmd->interval_ms; cmd 367 daemons/controld/controld_remote_ra.c op.t_run = (unsigned int) cmd->start_time; cmd 368 daemons/controld/controld_remote_ra.c op.t_rcchange = (unsigned int) cmd->start_time; cmd 370 daemons/controld/controld_remote_ra.c lrmd__set_result(&op, cmd->result.exit_status, cmd->result.execution_status, cmd 371 daemons/controld/controld_remote_ra.c cmd->result.exit_reason); cmd 373 daemons/controld/controld_remote_ra.c if (cmd->reported_success && !pcmk__result_ok(&(cmd->result))) { cmd 389 daemons/controld/controld_remote_ra.c if (cmd->params) { cmd 393 daemons/controld/controld_remote_ra.c for (tmp = cmd->params; tmp; tmp = tmp->next) { cmd 398 daemons/controld/controld_remote_ra.c op.call_id = cmd->call_id; cmd 399 daemons/controld/controld_remote_ra.c op.remote_nodename = cmd->owner; cmd 410 daemons/controld/controld_remote_ra.c update_remaining_timeout(remote_ra_cmd_t * cmd) cmd 412 daemons/controld/controld_remote_ra.c cmd->remaining_timeout = ((cmd->timeout / 1000) - (time(NULL) - cmd->start_time)) * 1000; cmd 420 daemons/controld/controld_remote_ra.c remote_ra_cmd_t *cmd = NULL; cmd 426 daemons/controld/controld_remote_ra.c cmd = ra_data->cur_cmd; cmd 427 daemons/controld/controld_remote_ra.c if (!pcmk__strcase_any_of(cmd->action, "start", "migrate_from", NULL)) { cmd 430 daemons/controld/controld_remote_ra.c update_remaining_timeout(cmd); cmd 432 daemons/controld/controld_remote_ra.c if (cmd->remaining_timeout > 0) { cmd 433 daemons/controld/controld_remote_ra.c rc = handle_remote_ra_start(lrm_state, cmd, cmd->remaining_timeout); cmd 435 daemons/controld/controld_remote_ra.c pcmk__set_result(&(cmd->result), PCMK_OCF_UNKNOWN_ERROR, cmd 441 daemons/controld/controld_remote_ra.c report_remote_ra_result(cmd); cmd 447 daemons/controld/controld_remote_ra.c free_cmd(cmd); cmd 460 daemons/controld/controld_remote_ra.c remote_ra_cmd_t *cmd = data; cmd 462 daemons/controld/controld_remote_ra.c crm_info("takeover event timed out for node %s", cmd->rsc_id); cmd 463 daemons/controld/controld_remote_ra.c cmd->takeover_timeout_id = 0; cmd 465 daemons/controld/controld_remote_ra.c lrm_state = lrm_state_find(cmd->rsc_id); cmd 467 daemons/controld/controld_remote_ra.c handle_remote_ra_stop(lrm_state, cmd); cmd 468 daemons/controld/controld_remote_ra.c free_cmd(cmd); cmd 477 daemons/controld/controld_remote_ra.c remote_ra_cmd_t *cmd = data; cmd 479 daemons/controld/controld_remote_ra.c lrm_state = lrm_state_find(cmd->rsc_id); cmd 482 daemons/controld/controld_remote_ra.c cmd->rsc_id, (lrm_state? "" : " (no LRM state)")); cmd 483 daemons/controld/controld_remote_ra.c cmd->monitor_timeout_id = 0; cmd 484 daemons/controld/controld_remote_ra.c pcmk__set_result(&(cmd->result), PCMK_OCF_UNKNOWN_ERROR, PCMK_EXEC_TIMEOUT, cmd 490 daemons/controld/controld_remote_ra.c if (ra_data->cur_cmd == cmd) { cmd 498 daemons/controld/controld_remote_ra.c report_remote_ra_result(cmd); cmd 499 daemons/controld/controld_remote_ra.c free_cmd(cmd); cmd 534 daemons/controld/controld_remote_ra.c remote_ra_cmd_t *cmd = NULL; cmd 607 daemons/controld/controld_remote_ra.c cmd = ra_data->cur_cmd; cmd 611 daemons/controld/controld_remote_ra.c if (op->type == lrmd_event_connect && pcmk__strcase_any_of(cmd->action, "start", cmd 614 daemons/controld/controld_remote_ra.c update_remaining_timeout(cmd); cmd 619 daemons/controld/controld_remote_ra.c pcmk__set_result(&(cmd->result), PCMK_OCF_INVALID_PARAM, cmd 623 daemons/controld/controld_remote_ra.c } else if (cmd->remaining_timeout > 3000) { cmd 624 daemons/controld/controld_remote_ra.c crm_trace("rescheduling start, remaining timeout %d", cmd->remaining_timeout); cmd 630 daemons/controld/controld_remote_ra.c cmd->remaining_timeout); cmd 631 daemons/controld/controld_remote_ra.c pcmk__format_result(&(cmd->result), PCMK_OCF_UNKNOWN_ERROR, cmd 639 daemons/controld/controld_remote_ra.c pcmk__set_result(&(cmd->result), PCMK_OCF_OK, PCMK_EXEC_DONE, NULL); cmd 643 daemons/controld/controld_remote_ra.c crm_debug("Remote connection event matched %s action", cmd->action); cmd 644 daemons/controld/controld_remote_ra.c report_remote_ra_result(cmd); cmd 647 daemons/controld/controld_remote_ra.c } else if (op->type == lrmd_event_poke && pcmk__str_eq(cmd->action, "monitor", pcmk__str_casei)) { cmd 649 daemons/controld/controld_remote_ra.c if (cmd->monitor_timeout_id) { cmd 650 daemons/controld/controld_remote_ra.c g_source_remove(cmd->monitor_timeout_id); cmd 651 daemons/controld/controld_remote_ra.c cmd->monitor_timeout_id = 0; cmd 657 daemons/controld/controld_remote_ra.c if (!cmd->reported_success) { cmd 658 daemons/controld/controld_remote_ra.c pcmk__set_result(&(cmd->result), PCMK_OCF_OK, PCMK_EXEC_DONE, NULL); cmd 659 daemons/controld/controld_remote_ra.c report_remote_ra_result(cmd); cmd 660 daemons/controld/controld_remote_ra.c cmd->reported_success = 1; cmd 663 daemons/controld/controld_remote_ra.c crm_debug("Remote poke event matched %s action", cmd->action); cmd 666 daemons/controld/controld_remote_ra.c if (cmd->interval_ms && (cmd->cancel == FALSE)) { cmd 667 daemons/controld/controld_remote_ra.c ra_data->recurring_cmds = g_list_append(ra_data->recurring_cmds, cmd); cmd 668 daemons/controld/controld_remote_ra.c cmd->interval_id = g_timeout_add(cmd->interval_ms, cmd 669 daemons/controld/controld_remote_ra.c recurring_helper, cmd); cmd 670 daemons/controld/controld_remote_ra.c cmd = NULL; /* prevent free */ cmd 674 daemons/controld/controld_remote_ra.c } else if (op->type == lrmd_event_disconnect && pcmk__str_eq(cmd->action, "monitor", pcmk__str_casei)) { cmd 675 daemons/controld/controld_remote_ra.c if (ra_data->active == TRUE && (cmd->cancel == FALSE)) { cmd 676 daemons/controld/controld_remote_ra.c pcmk__set_result(&(cmd->result), PCMK_OCF_UNKNOWN_ERROR, cmd 680 daemons/controld/controld_remote_ra.c report_remote_ra_result(cmd); cmd 686 daemons/controld/controld_remote_ra.c } else if (op->type == lrmd_event_new_client && pcmk__str_eq(cmd->action, "stop", pcmk__str_casei)) { cmd 688 daemons/controld/controld_remote_ra.c handle_remote_ra_stop(lrm_state, cmd); cmd 700 daemons/controld/controld_remote_ra.c free_cmd(cmd); cmd 705 daemons/controld/controld_remote_ra.c handle_remote_ra_stop(lrm_state_t * lrm_state, remote_ra_cmd_t * cmd) cmd 734 daemons/controld/controld_remote_ra.c if (cmd) { cmd 735 daemons/controld/controld_remote_ra.c pcmk__set_result(&(cmd->result), PCMK_OCF_OK, PCMK_EXEC_DONE, NULL); cmd 736 daemons/controld/controld_remote_ra.c report_remote_ra_result(cmd); cmd 742 daemons/controld/controld_remote_ra.c handle_remote_ra_start(lrm_state_t * lrm_state, remote_ra_cmd_t * cmd, int timeout_ms) cmd 751 daemons/controld/controld_remote_ra.c for (tmp = cmd->params; tmp; tmp = tmp->next) { cmd 765 daemons/controld/controld_remote_ra.c pcmk__format_result(&(cmd->result), PCMK_OCF_UNKNOWN_ERROR, cmd 779 daemons/controld/controld_remote_ra.c remote_ra_cmd_t *cmd; cmd 789 daemons/controld/controld_remote_ra.c cmd = first->data; cmd 790 daemons/controld/controld_remote_ra.c if (cmd->delay_id) { cmd 798 daemons/controld/controld_remote_ra.c if (!strcmp(cmd->action, "start") || !strcmp(cmd->action, "migrate_from")) { cmd 800 daemons/controld/controld_remote_ra.c if (handle_remote_ra_start(lrm_state, cmd, cmd 801 daemons/controld/controld_remote_ra.c cmd->timeout) == pcmk_rc_ok) { cmd 804 daemons/controld/controld_remote_ra.c cmd->action); cmd 805 daemons/controld/controld_remote_ra.c ra_data->cur_cmd = cmd; cmd 808 daemons/controld/controld_remote_ra.c report_remote_ra_result(cmd); cmd 810 daemons/controld/controld_remote_ra.c } else if (!strcmp(cmd->action, "monitor")) { cmd 815 daemons/controld/controld_remote_ra.c pcmk__set_result(&(cmd->result), PCMK_OCF_UNKNOWN_ERROR, cmd 820 daemons/controld/controld_remote_ra.c pcmk__set_result(&(cmd->result), PCMK_OCF_NOT_RUNNING, cmd 826 daemons/controld/controld_remote_ra.c cmd->rsc_id); cmd 827 daemons/controld/controld_remote_ra.c ra_data->cur_cmd = cmd; cmd 828 daemons/controld/controld_remote_ra.c cmd->monitor_timeout_id = g_timeout_add(cmd->timeout, monitor_timeout_cb, cmd); cmd 831 daemons/controld/controld_remote_ra.c report_remote_ra_result(cmd); cmd 833 daemons/controld/controld_remote_ra.c } else if (!strcmp(cmd->action, "stop")) { cmd 842 daemons/controld/controld_remote_ra.c cmd->takeover_timeout_id = g_timeout_add((cmd->timeout/2), connection_takeover_timeout_cb, cmd); cmd 843 daemons/controld/controld_remote_ra.c ra_data->cur_cmd = cmd; cmd 847 daemons/controld/controld_remote_ra.c handle_remote_ra_stop(lrm_state, cmd); cmd 849 daemons/controld/controld_remote_ra.c } else if (!strcmp(cmd->action, "migrate_to")) { cmd 851 daemons/controld/controld_remote_ra.c pcmk__set_result(&(cmd->result), PCMK_OCF_OK, PCMK_EXEC_DONE, NULL); cmd 852 daemons/controld/controld_remote_ra.c report_remote_ra_result(cmd); cmd 853 daemons/controld/controld_remote_ra.c } else if (pcmk__str_any_of(cmd->action, CRMD_ACTION_RELOAD, cmd 864 daemons/controld/controld_remote_ra.c pcmk__set_result(&(cmd->result), PCMK_OCF_OK, PCMK_EXEC_DONE, NULL); cmd 865 daemons/controld/controld_remote_ra.c report_remote_ra_result(cmd); cmd 868 daemons/controld/controld_remote_ra.c free_cmd(cmd); cmd 957 daemons/controld/controld_remote_ra.c remote_ra_cmd_t *cmd = NULL; cmd 961 daemons/controld/controld_remote_ra.c cmd = gIter->data; cmd 962 daemons/controld/controld_remote_ra.c if ((cmd->interval_ms > 0) && pcmk__str_eq(cmd->action, "monitor", pcmk__str_casei)) { cmd 963 daemons/controld/controld_remote_ra.c rm_list = g_list_append(rm_list, cmd); cmd 968 daemons/controld/controld_remote_ra.c cmd = gIter->data; cmd 970 daemons/controld/controld_remote_ra.c pcmk__set_result(&(cmd->result), PCMK_OCF_UNKNOWN_ERROR, cmd 973 daemons/controld/controld_remote_ra.c cmd->action, cmd->rsc_id, cmd->interval_ms, cmd->userdata); cmd 974 daemons/controld/controld_remote_ra.c report_remote_ra_result(cmd); cmd 976 daemons/controld/controld_remote_ra.c list = g_list_remove(list, cmd); cmd 977 daemons/controld/controld_remote_ra.c free_cmd(cmd); cmd 988 daemons/controld/controld_remote_ra.c remote_ra_cmd_t *cmd = NULL; cmd 992 daemons/controld/controld_remote_ra.c cmd = gIter->data; cmd 993 daemons/controld/controld_remote_ra.c if ((cmd->interval_ms == interval_ms) cmd 994 daemons/controld/controld_remote_ra.c && pcmk__str_eq(cmd->action, action, pcmk__str_casei)) { cmd 997 daemons/controld/controld_remote_ra.c cmd = NULL; cmd 999 daemons/controld/controld_remote_ra.c if (cmd) { cmd 1000 daemons/controld/controld_remote_ra.c list = g_list_remove(list, cmd); cmd 1001 daemons/controld/controld_remote_ra.c free_cmd(cmd); cmd 1037 daemons/controld/controld_remote_ra.c remote_ra_cmd_t *cmd = NULL; cmd 1054 daemons/controld/controld_remote_ra.c cmd = ra_data->cur_cmd; cmd 1059 daemons/controld/controld_remote_ra.c cmd = gIter->data; cmd 1060 daemons/controld/controld_remote_ra.c if ((cmd->interval_ms == interval_ms) cmd 1061 daemons/controld/controld_remote_ra.c && pcmk__str_eq(cmd->action, "monitor", pcmk__str_casei)) { cmd 1067 daemons/controld/controld_remote_ra.c cmd = gIter->data; cmd 1068 daemons/controld/controld_remote_ra.c if ((cmd->interval_ms == interval_ms) cmd 1069 daemons/controld/controld_remote_ra.c && pcmk__str_eq(cmd->action, "monitor", pcmk__str_casei)) { cmd 1079 daemons/controld/controld_remote_ra.c cmd->rsc_id, "monitor", interval_ms); cmd 1083 daemons/controld/controld_remote_ra.c free(cmd->userdata); cmd 1084 daemons/controld/controld_remote_ra.c cmd->userdata = strdup(userdata); cmd 1088 daemons/controld/controld_remote_ra.c if (cmd->reported_success) { cmd 1089 daemons/controld/controld_remote_ra.c cmd->start_time = time(NULL); cmd 1090 daemons/controld/controld_remote_ra.c cmd->call_id = generate_callid(); cmd 1091 daemons/controld/controld_remote_ra.c cmd->reported_success = 0; cmd 1097 daemons/controld/controld_remote_ra.c if (cmd->interval_id) { cmd 1098 daemons/controld/controld_remote_ra.c g_source_remove(cmd->interval_id); cmd 1099 daemons/controld/controld_remote_ra.c cmd->interval_id = 0; cmd 1100 daemons/controld/controld_remote_ra.c recurring_helper(cmd); cmd 1103 daemons/controld/controld_remote_ra.c return cmd; cmd 1132 daemons/controld/controld_remote_ra.c remote_ra_cmd_t *cmd = NULL; cmd 1155 daemons/controld/controld_remote_ra.c cmd = handle_dup_monitor(ra_data, interval_ms, userdata); cmd 1156 daemons/controld/controld_remote_ra.c if (cmd) { cmd 1157 daemons/controld/controld_remote_ra.c *call_id = cmd->call_id; cmd 1162 daemons/controld/controld_remote_ra.c cmd = calloc(1, sizeof(remote_ra_cmd_t)); cmd 1163 daemons/controld/controld_remote_ra.c if (cmd == NULL) { cmd 1168 daemons/controld/controld_remote_ra.c cmd->owner = strdup(lrm_state->node_name); cmd 1169 daemons/controld/controld_remote_ra.c cmd->rsc_id = strdup(rsc_id); cmd 1170 daemons/controld/controld_remote_ra.c cmd->action = strdup(action); cmd 1171 daemons/controld/controld_remote_ra.c cmd->userdata = strdup(userdata); cmd 1172 daemons/controld/controld_remote_ra.c if ((cmd->owner == NULL) || (cmd->rsc_id == NULL) || (cmd->action == NULL) cmd 1173 daemons/controld/controld_remote_ra.c || (cmd->userdata == NULL)) { cmd 1174 daemons/controld/controld_remote_ra.c free_cmd(cmd); cmd 1179 daemons/controld/controld_remote_ra.c cmd->interval_ms = interval_ms; cmd 1180 daemons/controld/controld_remote_ra.c cmd->timeout = timeout_ms; cmd 1181 daemons/controld/controld_remote_ra.c cmd->start_delay = start_delay_ms; cmd 1182 daemons/controld/controld_remote_ra.c cmd->params = params; cmd 1183 daemons/controld/controld_remote_ra.c cmd->start_time = time(NULL); cmd 1185 daemons/controld/controld_remote_ra.c cmd->call_id = generate_callid(); cmd 1187 daemons/controld/controld_remote_ra.c if (cmd->start_delay) { cmd 1188 daemons/controld/controld_remote_ra.c cmd->delay_id = g_timeout_add(cmd->start_delay, start_delay_helper, cmd); cmd 1191 daemons/controld/controld_remote_ra.c ra_data->cmds = g_list_append(ra_data->cmds, cmd); cmd 1194 daemons/controld/controld_remote_ra.c *call_id = cmd->call_id; 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 90 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 304 daemons/controld/controld_te_actions.c xmlNode *cmd = NULL; cmd 354 daemons/controld/controld_te_actions.c cmd = create_request(CRM_OP_INVOKE_LRM, rsc_op, router_node, cmd 360 daemons/controld/controld_te_actions.c .msg = cmd, cmd 377 daemons/controld/controld_te_actions.c rc = send_cluster_message(crm_get_peer(0, router_node), crm_msg_lrmd, cmd, TRUE); cmd 381 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 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(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(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, "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 232 daemons/execd/execd_commands.c if (cmd->result.exit_reason != NULL) { cmd 233 daemons/execd/execd_commands.c g_string_append_printf(str, " (%s)", cmd->result.exit_reason); cmd 251 daemons/execd/execd_commands.c log_execute(lrmd_cmd_t * cmd) cmd 255 daemons/execd/execd_commands.c if (pcmk__str_eq(cmd->action, "monitor", pcmk__str_casei)) { cmd 260 daemons/execd/execd_commands.c cmd->rsc_id, cmd->action, cmd->call_id); cmd 300 daemons/execd/execd_commands.c lrmd_cmd_t *cmd = NULL; cmd 302 daemons/execd/execd_commands.c cmd = calloc(1, sizeof(lrmd_cmd_t)); cmd 305 daemons/execd/execd_commands.c cmd->call_opts = call_options; cmd 306 daemons/execd/execd_commands.c cmd->client_id = strdup(client->id); cmd 308 daemons/execd/execd_commands.c crm_element_value_int(msg, F_LRMD_CALLID, &cmd->call_id); cmd 309 daemons/execd/execd_commands.c crm_element_value_ms(rsc_xml, F_LRMD_RSC_INTERVAL, &cmd->interval_ms); cmd 310 daemons/execd/execd_commands.c crm_element_value_int(rsc_xml, F_LRMD_TIMEOUT, &cmd->timeout); cmd 311 daemons/execd/execd_commands.c crm_element_value_int(rsc_xml, F_LRMD_RSC_START_DELAY, &cmd->start_delay); cmd 312 daemons/execd/execd_commands.c cmd->timeout_orig = cmd->timeout; cmd 314 daemons/execd/execd_commands.c cmd->origin = crm_element_value_copy(rsc_xml, F_LRMD_ORIGIN); cmd 315 daemons/execd/execd_commands.c cmd->action = crm_element_value_copy(rsc_xml, F_LRMD_RSC_ACTION); cmd 316 daemons/execd/execd_commands.c cmd->userdata_str = crm_element_value_copy(rsc_xml, F_LRMD_RSC_USERDATA_STR); cmd 317 daemons/execd/execd_commands.c cmd->rsc_id = crm_element_value_copy(rsc_xml, F_LRMD_RSC_ID); cmd 319 daemons/execd/execd_commands.c cmd->params = xml2list(rsc_xml); cmd 321 daemons/execd/execd_commands.c if (pcmk__str_eq(g_hash_table_lookup(cmd->params, "CRM_meta_on_fail"), "block", pcmk__str_casei)) { cmd 324 daemons/execd/execd_commands.c cmd->rsc_id, cmd->action, cmd->interval_ms); cmd 325 daemons/execd/execd_commands.c cmd->service_flags = pcmk__set_flags_as(__func__, __LINE__, cmd 327 daemons/execd/execd_commands.c cmd->action, 0, cmd 331 daemons/execd/execd_commands.c return cmd; cmd 335 daemons/execd/execd_commands.c stop_recurring_timer(lrmd_cmd_t *cmd) cmd 337 daemons/execd/execd_commands.c if (cmd) { cmd 338 daemons/execd/execd_commands.c if (cmd->stonith_recurring_id) { cmd 339 daemons/execd/execd_commands.c g_source_remove(cmd->stonith_recurring_id); cmd 341 daemons/execd/execd_commands.c cmd->stonith_recurring_id = 0; cmd 346 daemons/execd/execd_commands.c free_lrmd_cmd(lrmd_cmd_t * cmd) cmd 348 daemons/execd/execd_commands.c stop_recurring_timer(cmd); cmd 349 daemons/execd/execd_commands.c if (cmd->delay_id) { cmd 350 daemons/execd/execd_commands.c g_source_remove(cmd->delay_id); cmd 352 daemons/execd/execd_commands.c if (cmd->params) { cmd 353 daemons/execd/execd_commands.c g_hash_table_destroy(cmd->params); cmd 355 daemons/execd/execd_commands.c pcmk__reset_result(&(cmd->result)); cmd 356 daemons/execd/execd_commands.c free(cmd->origin); cmd 357 daemons/execd/execd_commands.c free(cmd->action); cmd 358 daemons/execd/execd_commands.c free(cmd->real_action); cmd 359 daemons/execd/execd_commands.c free(cmd->userdata_str); cmd 360 daemons/execd/execd_commands.c free(cmd->rsc_id); cmd 361 daemons/execd/execd_commands.c free(cmd->client_id); cmd 362 daemons/execd/execd_commands.c free(cmd); cmd 368 daemons/execd/execd_commands.c lrmd_cmd_t *cmd = data; cmd 371 daemons/execd/execd_commands.c cmd->stonith_recurring_id = 0; cmd 373 daemons/execd/execd_commands.c if (!cmd->rsc_id) { cmd 377 daemons/execd/execd_commands.c rsc = g_hash_table_lookup(rsc_list, cmd->rsc_id); cmd 382 daemons/execd/execd_commands.c rsc->recurring_ops = g_list_remove(rsc->recurring_ops, cmd); cmd 383 daemons/execd/execd_commands.c rsc->pending_ops = g_list_append(rsc->pending_ops, cmd); cmd 385 daemons/execd/execd_commands.c get_current_time(&(cmd->t_queue), &(cmd->t_first_queue)); cmd 393 daemons/execd/execd_commands.c start_recurring_timer(lrmd_cmd_t *cmd) cmd 395 daemons/execd/execd_commands.c if (cmd && (cmd->interval_ms > 0)) { cmd 396 daemons/execd/execd_commands.c cmd->stonith_recurring_id = g_timeout_add(cmd->interval_ms, cmd 398 daemons/execd/execd_commands.c cmd); cmd 405 daemons/execd/execd_commands.c lrmd_cmd_t *cmd = data; cmd 408 daemons/execd/execd_commands.c cmd->delay_id = 0; cmd 409 daemons/execd/execd_commands.c rsc = cmd->rsc_id ? g_hash_table_lookup(rsc_list, cmd->rsc_id) : NULL; cmd 423 daemons/execd/execd_commands.c find_duplicate_action(GList *action_list, lrmd_cmd_t *cmd) cmd 428 daemons/execd/execd_commands.c if (action_matches(cmd, dup->action, dup->interval_ms)) { cmd 436 daemons/execd/execd_commands.c merge_recurring_duplicate(lrmd_rsc_t * rsc, lrmd_cmd_t * cmd) cmd 441 daemons/execd/execd_commands.c if (cmd->interval_ms == 0) { cmd 446 daemons/execd/execd_commands.c dup = find_duplicate_action(rsc->pending_ops, cmd); cmd 449 daemons/execd/execd_commands.c dup = find_duplicate_action(rsc->recurring_ops, cmd); cmd 475 daemons/execd/execd_commands.c dup->userdata_str = cmd->userdata_str; cmd 476 daemons/execd/execd_commands.c cmd->userdata_str = NULL; cmd 477 daemons/execd/execd_commands.c dup->call_id = cmd->call_id; cmd 478 daemons/execd/execd_commands.c free_lrmd_cmd(cmd); cmd 479 daemons/execd/execd_commands.c cmd = NULL; cmd 500 daemons/execd/execd_commands.c schedule_lrmd_cmd(lrmd_rsc_t * rsc, lrmd_cmd_t * cmd) cmd 502 daemons/execd/execd_commands.c CRM_CHECK(cmd != NULL, return); cmd 505 daemons/execd/execd_commands.c crm_trace("Scheduling %s on %s", cmd->action, rsc->rsc_id); cmd 507 daemons/execd/execd_commands.c if (merge_recurring_duplicate(rsc, cmd)) { cmd 515 daemons/execd/execd_commands.c if (pcmk__str_eq(cmd->action, "stop", pcmk__str_casei)) { cmd 519 daemons/execd/execd_commands.c rsc->pending_ops = g_list_append(rsc->pending_ops, cmd); cmd 521 daemons/execd/execd_commands.c get_current_time(&(cmd->t_queue), &(cmd->t_first_queue)); cmd 525 daemons/execd/execd_commands.c if (cmd->start_delay) { cmd 526 daemons/execd/execd_commands.c cmd->delay_id = g_timeout_add(cmd->start_delay, start_delay_helper, cmd); cmd 586 daemons/execd/execd_commands.c send_cmd_complete_notify(lrmd_cmd_t * cmd) cmd 593 daemons/execd/execd_commands.c exec_time = time_diff_ms(NULL, &(cmd->t_run)); cmd 594 daemons/execd/execd_commands.c queue_time = time_diff_ms(&cmd->t_run, &(cmd->t_queue)); cmd 596 daemons/execd/execd_commands.c log_finished(cmd, exec_time, queue_time); cmd 601 daemons/execd/execd_commands.c if (cmd->first_notify_sent && (cmd->call_opts & lrmd_opt_notify_changes_only)) { cmd 602 daemons/execd/execd_commands.c if ((cmd->last_notify_rc == cmd->result.exit_status) && cmd 603 daemons/execd/execd_commands.c (cmd->last_notify_op_status == cmd->result.execution_status)) { cmd 611 daemons/execd/execd_commands.c cmd->first_notify_sent = true; cmd 612 daemons/execd/execd_commands.c cmd->last_notify_rc = cmd->result.exit_status; cmd 613 daemons/execd/execd_commands.c cmd->last_notify_op_status = cmd->result.execution_status; cmd 618 daemons/execd/execd_commands.c crm_xml_add_int(notify, F_LRMD_TIMEOUT, cmd->timeout); cmd 619 daemons/execd/execd_commands.c crm_xml_add_ms(notify, F_LRMD_RSC_INTERVAL, cmd->interval_ms); cmd 620 daemons/execd/execd_commands.c crm_xml_add_int(notify, F_LRMD_RSC_START_DELAY, cmd->start_delay); cmd 621 daemons/execd/execd_commands.c crm_xml_add_int(notify, F_LRMD_EXEC_RC, cmd->result.exit_status); cmd 622 daemons/execd/execd_commands.c crm_xml_add_int(notify, F_LRMD_OP_STATUS, cmd->result.execution_status); cmd 623 daemons/execd/execd_commands.c crm_xml_add_int(notify, F_LRMD_CALLID, cmd->call_id); cmd 624 daemons/execd/execd_commands.c crm_xml_add_int(notify, F_LRMD_RSC_DELETED, cmd->rsc_deleted); cmd 627 daemons/execd/execd_commands.c (long long) cmd->epoch_last_run); cmd 629 daemons/execd/execd_commands.c (long long) cmd->epoch_rcchange); cmd 636 daemons/execd/execd_commands.c crm_xml_add(notify, F_LRMD_RSC_ID, cmd->rsc_id); cmd 637 daemons/execd/execd_commands.c if(cmd->real_action) { cmd 638 daemons/execd/execd_commands.c crm_xml_add(notify, F_LRMD_RSC_ACTION, cmd->real_action); cmd 640 daemons/execd/execd_commands.c crm_xml_add(notify, F_LRMD_RSC_ACTION, cmd->action); cmd 642 daemons/execd/execd_commands.c crm_xml_add(notify, F_LRMD_RSC_USERDATA_STR, cmd->userdata_str); cmd 643 daemons/execd/execd_commands.c crm_xml_add(notify, F_LRMD_RSC_EXIT_REASON, cmd->result.exit_reason); cmd 645 daemons/execd/execd_commands.c if (cmd->result.action_stderr != NULL) { cmd 646 daemons/execd/execd_commands.c crm_xml_add(notify, F_LRMD_RSC_OUTPUT, cmd->result.action_stderr); cmd 648 daemons/execd/execd_commands.c } else if (cmd->result.action_stdout != NULL) { cmd 649 daemons/execd/execd_commands.c crm_xml_add(notify, F_LRMD_RSC_OUTPUT, cmd->result.action_stdout); cmd 652 daemons/execd/execd_commands.c if (cmd->params) { cmd 659 daemons/execd/execd_commands.c g_hash_table_iter_init(&iter, cmd->params); cmd 664 daemons/execd/execd_commands.c if (cmd->client_id && (cmd->call_opts & lrmd_opt_notify_orig_only)) { cmd 665 daemons/execd/execd_commands.c pcmk__client_t *client = pcmk__find_client_by_id(cmd->client_id); cmd 703 daemons/execd/execd_commands.c cmd_reset(lrmd_cmd_t * cmd) cmd 705 daemons/execd/execd_commands.c cmd->last_pid = 0; cmd 707 daemons/execd/execd_commands.c memset(&cmd->t_run, 0, sizeof(cmd->t_run)); cmd 708 daemons/execd/execd_commands.c memset(&cmd->t_queue, 0, sizeof(cmd->t_queue)); cmd 710 daemons/execd/execd_commands.c cmd->epoch_last_run = 0; cmd 712 daemons/execd/execd_commands.c pcmk__reset_result(&(cmd->result)); cmd 713 daemons/execd/execd_commands.c cmd->result.execution_status = PCMK_EXEC_DONE; cmd 717 daemons/execd/execd_commands.c cmd_finalize(lrmd_cmd_t * cmd, lrmd_rsc_t * rsc) cmd 719 daemons/execd/execd_commands.c crm_trace("Resource operation rsc:%s action:%s completed (%p %p)", cmd->rsc_id, cmd->action, cmd 720 daemons/execd/execd_commands.c rsc ? rsc->active : NULL, cmd); cmd 722 daemons/execd/execd_commands.c if (rsc && (rsc->active == cmd)) { cmd 728 daemons/execd/execd_commands.c cmd->rsc_deleted = 1; cmd 732 daemons/execd/execd_commands.c cmd->timeout = cmd->timeout_orig; cmd 734 daemons/execd/execd_commands.c send_cmd_complete_notify(cmd); cmd 736 daemons/execd/execd_commands.c if ((cmd->interval_ms != 0) cmd 737 daemons/execd/execd_commands.c && (cmd->result.execution_status == PCMK_EXEC_CANCELLED)) { cmd 740 daemons/execd/execd_commands.c rsc->recurring_ops = g_list_remove(rsc->recurring_ops, cmd); cmd 741 daemons/execd/execd_commands.c rsc->pending_ops = g_list_remove(rsc->pending_ops, cmd); cmd 743 daemons/execd/execd_commands.c free_lrmd_cmd(cmd); cmd 744 daemons/execd/execd_commands.c } else if (cmd->interval_ms == 0) { cmd 746 daemons/execd/execd_commands.c rsc->pending_ops = g_list_remove(rsc->pending_ops, cmd); cmd 748 daemons/execd/execd_commands.c free_lrmd_cmd(cmd); cmd 751 daemons/execd/execd_commands.c cmd_reset(cmd); cmd 805 daemons/execd/execd_commands.c lrmd_cmd_t *cmd = action->cb_data; cmd 813 daemons/execd/execd_commands.c if (!cmd) { cmd 820 daemons/execd/execd_commands.c if (cmd->result.exit_status != action->rc) { cmd 821 daemons/execd/execd_commands.c cmd->epoch_rcchange = time(NULL); cmd 825 daemons/execd/execd_commands.c cmd->last_pid = action->pid; cmd 828 daemons/execd/execd_commands.c code = services_result2ocf(action->standard, cmd->action, action->rc); cmd 829 daemons/execd/execd_commands.c pcmk__set_result(&(cmd->result), (int) code, cmd 832 daemons/execd/execd_commands.c rsc = cmd->rsc_id ? g_hash_table_lookup(rsc_list, cmd->rsc_id) : NULL; cmd 842 daemons/execd/execd_commands.c if (pcmk__result_ok(&(cmd->result)) cmd 843 daemons/execd/execd_commands.c && pcmk__strcase_any_of(cmd->action, "start", "stop", NULL)) { cmd 850 daemons/execd/execd_commands.c cmd->real_action = cmd->action; cmd 851 daemons/execd/execd_commands.c cmd->action = strdup("monitor"); cmd 853 daemons/execd/execd_commands.c } else if (cmd->real_action != NULL) { cmd 855 daemons/execd/execd_commands.c if (cmd->result.execution_status == PCMK_EXEC_PENDING) { cmd 858 daemons/execd/execd_commands.c } else if (pcmk__result_ok(&(cmd->result)) cmd 859 daemons/execd/execd_commands.c && pcmk__str_eq(cmd->real_action, "stop", pcmk__str_casei)) { cmd 863 daemons/execd/execd_commands.c int time_sum = time_diff_ms(NULL, &(cmd->t_first_run)); cmd 864 daemons/execd/execd_commands.c int timeout_left = cmd->timeout_orig - time_sum; cmd 868 daemons/execd/execd_commands.c cmd->rsc_id, cmd->real_action, time_sum, timeout_left, cmd 869 daemons/execd/execd_commands.c services_ocf_exitcode_str(cmd->result.exit_status), cmd 870 daemons/execd/execd_commands.c cmd->result.exit_status); cmd 871 daemons/execd/execd_commands.c cmd_original_times(cmd); cmd 874 daemons/execd/execd_commands.c if ((cmd->result.execution_status == PCMK_EXEC_DONE) cmd 875 daemons/execd/execd_commands.c && (cmd->result.exit_status == PCMK_OCF_NOT_RUNNING)) { cmd 877 daemons/execd/execd_commands.c if (pcmk__str_eq(cmd->real_action, "start", pcmk__str_casei)) { cmd 878 daemons/execd/execd_commands.c cmd->result.exit_status = PCMK_OCF_UNKNOWN_ERROR; cmd 879 daemons/execd/execd_commands.c } else if (pcmk__str_eq(cmd->real_action, "stop", pcmk__str_casei)) { cmd 880 daemons/execd/execd_commands.c cmd->result.exit_status = PCMK_OCF_OK; cmd 890 daemons/execd/execd_commands.c if (action_matches(cmd, "monitor", 0) cmd 891 daemons/execd/execd_commands.c && pcmk__result_ok(&(cmd->result))) { cmd 893 daemons/execd/execd_commands.c cmd->result.exit_status = PCMK_OCF_NOT_RUNNING; cmd 895 daemons/execd/execd_commands.c } else if (pcmk__str_eq(cmd->action, "start", pcmk__str_casei) cmd 896 daemons/execd/execd_commands.c && !pcmk__result_ok(&(cmd->result))) { cmd 906 daemons/execd/execd_commands.c int time_sum = time_diff_ms(NULL, &(cmd->t_first_run)); cmd 907 daemons/execd/execd_commands.c int timeout_left = cmd->timeout_orig - time_sum; cmd 908 daemons/execd/execd_commands.c int delay = cmd->timeout_orig / 10; cmd 916 daemons/execd/execd_commands.c cmd->start_delay = delay; cmd 917 daemons/execd/execd_commands.c cmd->timeout = timeout_left; cmd 919 daemons/execd/execd_commands.c if (pcmk__result_ok(&(cmd->result))) { cmd 921 daemons/execd/execd_commands.c cmd->rsc_id, cmd->real_action, time_sum, timeout_left, delay); cmd 923 daemons/execd/execd_commands.c } else if (cmd->result.execution_status == PCMK_EXEC_PENDING) { cmd 925 daemons/execd/execd_commands.c cmd->rsc_id, cmd->action, time_sum, timeout_left, delay); cmd 929 daemons/execd/execd_commands.c cmd->rsc_id, cmd->action, cmd 930 daemons/execd/execd_commands.c services_ocf_exitcode_str(cmd->result.exit_status), cmd 931 daemons/execd/execd_commands.c cmd->result.exit_status, time_sum, timeout_left, cmd 935 daemons/execd/execd_commands.c cmd_reset(cmd); cmd 939 daemons/execd/execd_commands.c schedule_lrmd_cmd(rsc, cmd); cmd 946 daemons/execd/execd_commands.c cmd->rsc_id, cmd 947 daemons/execd/execd_commands.c (cmd->real_action? cmd->real_action : cmd->action), cmd 948 daemons/execd/execd_commands.c cmd->result.exit_status, time_sum, timeout_left); cmd 949 daemons/execd/execd_commands.c pcmk__set_result(&(cmd->result), PCMK_OCF_UNKNOWN_ERROR, cmd 953 daemons/execd/execd_commands.c cmd_original_times(cmd); cmd 958 daemons/execd/execd_commands.c pcmk__set_result_output(&(cmd->result), services__grab_stdout(action), cmd 960 daemons/execd/execd_commands.c cmd_finalize(cmd, rsc); cmd 973 daemons/execd/execd_commands.c stonith_action_complete(lrmd_cmd_t *cmd, int exit_status, cmd 978 daemons/execd/execd_commands.c lrmd_rsc_t *rsc = g_hash_table_lookup(rsc_list, cmd->rsc_id); cmd 985 daemons/execd/execd_commands.c if (cmd->result.execution_status == PCMK_EXEC_CANCELLED) { cmd 1006 daemons/execd/execd_commands.c if (pcmk__str_eq(cmd->action, CRMD_ACTION_STATUS, cmd 1010 daemons/execd/execd_commands.c } else if (pcmk__str_eq(cmd->action, CRMD_ACTION_STOP, cmd 1029 daemons/execd/execd_commands.c pcmk__set_result(&cmd->result, exit_status, execution_status, exit_reason); cmd 1032 daemons/execd/execd_commands.c if ((rsc != NULL) && pcmk__result_ok(&(cmd->result))) { cmd 1034 daemons/execd/execd_commands.c if (pcmk__str_eq(cmd->action, "start", pcmk__str_casei)) { cmd 1038 daemons/execd/execd_commands.c } else if (pcmk__str_eq(cmd->action, "stop", pcmk__str_casei)) { cmd 1047 daemons/execd/execd_commands.c stop_recurring_timer(cmd); cmd 1053 daemons/execd/execd_commands.c if (rsc && (cmd->interval_ms > 0) cmd 1054 daemons/execd/execd_commands.c && (cmd->result.execution_status != PCMK_EXEC_CANCELLED)) { cmd 1055 daemons/execd/execd_commands.c start_recurring_timer(cmd); cmd 1058 daemons/execd/execd_commands.c cmd_finalize(cmd, rsc); cmd 1141 daemons/execd/execd_commands.c execd_stonith_start(stonith_t *stonith_api, lrmd_rsc_t *rsc, lrmd_cmd_t *cmd) cmd 1149 daemons/execd/execd_commands.c if (cmd->params) { cmd 1152 daemons/execd/execd_commands.c g_hash_table_iter_init(&iter, cmd->params); cmd 1165 daemons/execd/execd_commands.c cmd->rsc_id, rsc->provider, cmd 1205 daemons/execd/execd_commands.c execd_stonith_monitor(stonith_t *stonith_api, lrmd_rsc_t *rsc, lrmd_cmd_t *cmd) cmd 1207 daemons/execd/execd_commands.c int rc = stonith_api->cmds->monitor(stonith_api, 0, cmd->rsc_id, cmd 1208 daemons/execd/execd_commands.c cmd->timeout / 1000); cmd 1210 daemons/execd/execd_commands.c rc = stonith_api->cmds->register_callback(stonith_api, rc, 0, 0, cmd, cmd 1214 daemons/execd/execd_commands.c rsc->active = cmd; cmd 1223 daemons/execd/execd_commands.c lrmd_rsc_execute_stonith(lrmd_rsc_t * rsc, lrmd_cmd_t * cmd) cmd 1230 daemons/execd/execd_commands.c if (pcmk__str_eq(cmd->action, "monitor", pcmk__str_casei) cmd 1231 daemons/execd/execd_commands.c && (cmd->interval_ms == 0)) { cmd 1233 daemons/execd/execd_commands.c stonith_action_complete(cmd, rsc->fence_probe_result.exit_status, cmd 1239 daemons/execd/execd_commands.c stonith_action_complete(cmd, PCMK_OCF_UNKNOWN_ERROR, cmd 1244 daemons/execd/execd_commands.c } else if (pcmk__str_eq(cmd->action, "start", pcmk__str_casei)) { cmd 1245 daemons/execd/execd_commands.c rc = execd_stonith_start(stonith_api, rsc, cmd); cmd 1250 daemons/execd/execd_commands.c } else if (pcmk__str_eq(cmd->action, "stop", pcmk__str_casei)) { cmd 1253 daemons/execd/execd_commands.c } else if (pcmk__str_eq(cmd->action, "monitor", pcmk__str_casei)) { cmd 1257 daemons/execd/execd_commands.c stonith_action_complete(cmd, PCMK_OCF_UNIMPLEMENT_FEATURE, cmd 1264 daemons/execd/execd_commands.c rc = execd_stonith_monitor(stonith_api, rsc, cmd); cmd 1271 daemons/execd/execd_commands.c stonith_action_complete(cmd, cmd 1278 daemons/execd/execd_commands.c lrmd_rsc_execute_service_lib(lrmd_rsc_t * rsc, lrmd_cmd_t * cmd) cmd 1284 daemons/execd/execd_commands.c CRM_ASSERT(cmd); cmd 1287 daemons/execd/execd_commands.c rsc->rsc_id, cmd->action, rsc->class, rsc->provider, rsc->type); cmd 1292 daemons/execd/execd_commands.c && pcmk__str_eq(cmd->action, "stop", pcmk__str_casei)) { cmd 1294 daemons/execd/execd_commands.c cmd->result.exit_status = PCMK_OCF_OK; cmd 1299 daemons/execd/execd_commands.c params_copy = pcmk__str_table_dup(cmd->params); cmd 1303 daemons/execd/execd_commands.c normalize_action_name(rsc, cmd->action), cmd 1304 daemons/execd/execd_commands.c cmd->interval_ms, cmd->timeout, cmd 1305 daemons/execd/execd_commands.c params_copy, cmd->service_flags); cmd 1308 daemons/execd/execd_commands.c pcmk__set_result(&(cmd->result), PCMK_OCF_UNKNOWN_ERROR, cmd 1314 daemons/execd/execd_commands.c pcmk__set_result(&(cmd->result), action->rc, action->status, cmd 1320 daemons/execd/execd_commands.c action->cb_data = cmd; cmd 1330 daemons/execd/execd_commands.c pcmk__set_result(&(cmd->result), action->rc, action->status, cmd 1336 daemons/execd/execd_commands.c cmd_finalize(cmd, rsc); cmd 1343 daemons/execd/execd_commands.c lrmd_cmd_t *cmd = NULL; cmd 1355 daemons/execd/execd_commands.c cmd = first->data; cmd 1356 daemons/execd/execd_commands.c if (cmd->delay_id) { cmd 1359 daemons/execd/execd_commands.c cmd->rsc_id, cmd->action, cmd->start_delay); cmd 1366 daemons/execd/execd_commands.c get_current_time(&(cmd->t_run), &(cmd->t_first_run)); cmd 1368 daemons/execd/execd_commands.c cmd->epoch_last_run = time(NULL); cmd 1371 daemons/execd/execd_commands.c if (!cmd) { cmd 1376 daemons/execd/execd_commands.c rsc->active = cmd; /* only one op at a time for a rsc */ cmd 1377 daemons/execd/execd_commands.c if (cmd->interval_ms) { cmd 1378 daemons/execd/execd_commands.c rsc->recurring_ops = g_list_append(rsc->recurring_ops, cmd); cmd 1381 daemons/execd/execd_commands.c log_execute(cmd); cmd 1384 daemons/execd/execd_commands.c lrmd_rsc_execute_stonith(rsc, cmd); cmd 1386 daemons/execd/execd_commands.c lrmd_rsc_execute_service_lib(rsc, cmd); cmd 1409 daemons/execd/execd_commands.c lrmd_cmd_t *cmd = gIter->data; cmd 1412 daemons/execd/execd_commands.c cmd->result.execution_status = PCMK_EXEC_CANCELLED; cmd 1413 daemons/execd/execd_commands.c cmd_finalize(cmd, NULL); cmd 1423 daemons/execd/execd_commands.c lrmd_cmd_t *cmd = gIter->data; cmd 1426 daemons/execd/execd_commands.c cmd->result.execution_status = PCMK_EXEC_CANCELLED; cmd 1431 daemons/execd/execd_commands.c if (rsc->active != cmd) { cmd 1432 daemons/execd/execd_commands.c cmd_finalize(cmd, NULL); cmd 1440 daemons/execd/execd_commands.c normalize_action_name(rsc, cmd->action), cmd 1441 daemons/execd/execd_commands.c cmd->interval_ms); cmd 1578 daemons/execd/execd_commands.c lrmd_cmd_t *cmd = NULL; cmd 1592 daemons/execd/execd_commands.c cmd = create_lrmd_cmd(request, client); cmd 1593 daemons/execd/execd_commands.c call_id = cmd->call_id; cmd 1597 daemons/execd/execd_commands.c schedule_lrmd_cmd(rsc, cmd); cmd 1624 daemons/execd/execd_commands.c lrmd_cmd_t *cmd = gIter->data; cmd 1626 daemons/execd/execd_commands.c if (action_matches(cmd, action, interval_ms)) { cmd 1627 daemons/execd/execd_commands.c cmd->result.execution_status = PCMK_EXEC_CANCELLED; cmd 1628 daemons/execd/execd_commands.c cmd_finalize(cmd, rsc); cmd 1637 daemons/execd/execd_commands.c lrmd_cmd_t *cmd = gIter->data; cmd 1639 daemons/execd/execd_commands.c if (action_matches(cmd, action, interval_ms)) { cmd 1640 daemons/execd/execd_commands.c cmd->result.execution_status = PCMK_EXEC_CANCELLED; cmd 1641 daemons/execd/execd_commands.c if (rsc->active != cmd) { cmd 1642 daemons/execd/execd_commands.c cmd_finalize(cmd, rsc); cmd 1683 daemons/execd/execd_commands.c lrmd_cmd_t *cmd = cmd_iter->data; cmd 1685 daemons/execd/execd_commands.c if (cmd->interval_ms == 0) { cmd 1689 daemons/execd/execd_commands.c if (client_id && !pcmk__str_eq(cmd->client_id, client_id, pcmk__str_casei)) { cmd 1693 daemons/execd/execd_commands.c cancel_op(rsc->rsc_id, cmd->action, cmd->interval_ms); cmd 1723 daemons/execd/execd_commands.c lrmd_cmd_t *cmd = item->data; cmd 1727 daemons/execd/execd_commands.c (cmd->real_action? cmd->real_action : cmd->action)); cmd 1728 daemons/execd/execd_commands.c crm_xml_add_ms(op_xml, F_LRMD_RSC_INTERVAL, cmd->interval_ms); cmd 1729 daemons/execd/execd_commands.c crm_xml_add_int(op_xml, F_LRMD_TIMEOUT, cmd->timeout_orig); cmd 171 daemons/fenced/cts-fence-helper.c #define single_test(cmd, str, num_notifications, expected_rc) \ cmd 174 daemons/fenced/cts-fence-helper.c rc = cmd; \ cmd 118 daemons/fenced/fenced_commands.c static xmlNode *construct_async_reply(async_command_t *cmd, cmd 239 daemons/fenced/fenced_commands.c free_async_command(async_command_t * cmd) cmd 241 daemons/fenced/fenced_commands.c if (!cmd) { cmd 245 daemons/fenced/fenced_commands.c if (cmd->delay_id) { cmd 246 daemons/fenced/fenced_commands.c g_source_remove(cmd->delay_id); cmd 249 daemons/fenced/fenced_commands.c cmd_list = g_list_remove(cmd_list, cmd); cmd 251 daemons/fenced/fenced_commands.c g_list_free_full(cmd->device_list, free); cmd 252 daemons/fenced/fenced_commands.c free(cmd->device); cmd 253 daemons/fenced/fenced_commands.c free(cmd->action); cmd 254 daemons/fenced/fenced_commands.c free(cmd->victim); cmd 255 daemons/fenced/fenced_commands.c free(cmd->remote_op_id); cmd 256 daemons/fenced/fenced_commands.c free(cmd->client); cmd 257 daemons/fenced/fenced_commands.c free(cmd->client_name); cmd 258 daemons/fenced/fenced_commands.c free(cmd->origin); cmd 259 daemons/fenced/fenced_commands.c free(cmd->op); cmd 260 daemons/fenced/fenced_commands.c free(cmd); cmd 266 daemons/fenced/fenced_commands.c async_command_t *cmd = NULL; cmd 273 daemons/fenced/fenced_commands.c cmd = calloc(1, sizeof(async_command_t)); cmd 274 daemons/fenced/fenced_commands.c crm_element_value_int(msg, F_STONITH_CALLID, &(cmd->id)); cmd 275 daemons/fenced/fenced_commands.c crm_element_value_int(msg, F_STONITH_CALLOPTS, &(cmd->options)); cmd 276 daemons/fenced/fenced_commands.c crm_element_value_int(msg, F_STONITH_TIMEOUT, &(cmd->default_timeout)); cmd 277 daemons/fenced/fenced_commands.c cmd->timeout = cmd->default_timeout; cmd 279 daemons/fenced/fenced_commands.c crm_element_value_int(msg, F_STONITH_DELAY, &(cmd->start_delay)); cmd 281 daemons/fenced/fenced_commands.c cmd->origin = crm_element_value_copy(msg, F_ORIG); cmd 282 daemons/fenced/fenced_commands.c cmd->remote_op_id = crm_element_value_copy(msg, F_STONITH_REMOTE_OP_ID); cmd 283 daemons/fenced/fenced_commands.c cmd->client = crm_element_value_copy(msg, F_STONITH_CLIENTID); cmd 284 daemons/fenced/fenced_commands.c cmd->client_name = crm_element_value_copy(msg, F_STONITH_CLIENTNAME); cmd 285 daemons/fenced/fenced_commands.c cmd->op = crm_element_value_copy(msg, F_STONITH_OPERATION); cmd 286 daemons/fenced/fenced_commands.c cmd->action = strdup(action); cmd 287 daemons/fenced/fenced_commands.c cmd->victim = crm_element_value_copy(op, F_STONITH_TARGET); cmd 288 daemons/fenced/fenced_commands.c cmd->device = crm_element_value_copy(op, F_STONITH_DEVICE); cmd 290 daemons/fenced/fenced_commands.c CRM_CHECK(cmd->op != NULL, crm_log_xml_warn(msg, "NoOp"); free_async_command(cmd); return NULL); cmd 291 daemons/fenced/fenced_commands.c CRM_CHECK(cmd->client != NULL, crm_log_xml_warn(msg, "NoClient")); cmd 293 daemons/fenced/fenced_commands.c cmd->done_cb = st_child_done; cmd 294 daemons/fenced/fenced_commands.c cmd_list = g_list_append(cmd_list, cmd); cmd 295 daemons/fenced/fenced_commands.c return cmd; cmd 323 daemons/fenced/fenced_commands.c async_command_t *cmd = gIter->data; cmd 327 daemons/fenced/fenced_commands.c if (cmd->active_on == device) { cmd 338 daemons/fenced/fenced_commands.c async_command_t *cmd = (async_command_t *) user_data; cmd 343 daemons/fenced/fenced_commands.c cmd->activating_on?cmd->activating_on:cmd->active_on; cmd 347 daemons/fenced/fenced_commands.c cmd->action, pid, cmd 348 daemons/fenced/fenced_commands.c ((cmd->victim == NULL)? "" : " targeting "), cmd 349 daemons/fenced/fenced_commands.c ((cmd->victim == NULL)? "" : cmd->victim), cmd 350 daemons/fenced/fenced_commands.c device->id, cmd->timeout); cmd 351 daemons/fenced/fenced_commands.c cmd->active_on = device; cmd 352 daemons/fenced/fenced_commands.c cmd->activating_on = NULL; cmd 391 daemons/fenced/fenced_commands.c report_internal_result(async_command_t *cmd, int exit_status, cmd 397 daemons/fenced/fenced_commands.c cmd->done_cb(0, &result, cmd); cmd 407 daemons/fenced/fenced_commands.c async_command_t *cmd = NULL; cmd 443 daemons/fenced/fenced_commands.c cmd = pending_op; cmd 447 daemons/fenced/fenced_commands.c if (cmd == NULL) { cmd 454 daemons/fenced/fenced_commands.c if (pcmk__is_fencing_action(cmd->action)) { cmd 460 daemons/fenced/fenced_commands.c crm_info("Faking success for %s watchdog operation", cmd->action); cmd 461 daemons/fenced/fenced_commands.c report_internal_result(cmd, CRM_EX_OK, PCMK_EXEC_DONE, NULL); cmd 469 daemons/fenced/fenced_commands.c if (pcmk__str_eq(cmd->action, "stop", pcmk__str_casei)) { cmd 477 daemons/fenced/fenced_commands.c report_internal_result(cmd, CRM_EX_ERROR, PCMK_EXEC_NO_SECRETS, cmd 484 daemons/fenced/fenced_commands.c action_str = cmd->action; cmd 485 daemons/fenced/fenced_commands.c if (pcmk__str_eq(cmd->action, "reboot", pcmk__str_casei) cmd 490 daemons/fenced/fenced_commands.c ((cmd->victim == NULL)? "" : " targeting "), cmd 491 daemons/fenced/fenced_commands.c ((cmd->victim == NULL)? "" : cmd->victim), cmd 505 daemons/fenced/fenced_commands.c cmd->victim, cmd 506 daemons/fenced/fenced_commands.c cmd->victim_nodeid, cmd 507 daemons/fenced/fenced_commands.c cmd->timeout, device->params, cmd 512 daemons/fenced/fenced_commands.c cmd->activating_on = device; cmd 513 daemons/fenced/fenced_commands.c exec_rc = stonith_action_execute_async(action, (void *)cmd, cmd 514 daemons/fenced/fenced_commands.c cmd->done_cb, fork_cb); cmd 516 daemons/fenced/fenced_commands.c cmd->activating_on = NULL; cmd 517 daemons/fenced/fenced_commands.c cmd->done_cb(0, stonith__action_result(action), cmd); cmd 540 daemons/fenced/fenced_commands.c async_command_t *cmd = data; cmd 543 daemons/fenced/fenced_commands.c cmd->delay_id = 0; cmd 544 daemons/fenced/fenced_commands.c device = cmd->device ? g_hash_table_lookup(device_list, cmd->device) : NULL; cmd 554 daemons/fenced/fenced_commands.c schedule_stonith_command(async_command_t * cmd, stonith_device_t * device) cmd 558 daemons/fenced/fenced_commands.c int requested_delay = cmd->start_delay; cmd 560 daemons/fenced/fenced_commands.c CRM_CHECK(cmd != NULL, return); cmd 563 daemons/fenced/fenced_commands.c if (cmd->device) { cmd 564 daemons/fenced/fenced_commands.c free(cmd->device); cmd 567 daemons/fenced/fenced_commands.c if (device->include_nodeid && cmd->victim) { cmd 568 daemons/fenced/fenced_commands.c crm_node_t *node = crm_get_peer(0, cmd->victim); cmd 570 daemons/fenced/fenced_commands.c cmd->victim_nodeid = node->id; cmd 573 daemons/fenced/fenced_commands.c cmd->device = strdup(device->id); cmd 574 daemons/fenced/fenced_commands.c cmd->timeout = get_action_timeout(device, cmd->action, cmd->default_timeout); cmd 576 daemons/fenced/fenced_commands.c if (cmd->remote_op_id) { cmd 579 daemons/fenced/fenced_commands.c cmd->action, cmd 580 daemons/fenced/fenced_commands.c cmd->victim ? " targeting " : "", cmd->victim ? cmd->victim : "", cmd 581 daemons/fenced/fenced_commands.c device->id, cmd->origin, cmd->remote_op_id, cmd->timeout); cmd 584 daemons/fenced/fenced_commands.c cmd->action, cmd 585 daemons/fenced/fenced_commands.c cmd->victim ? " targeting " : "", cmd->victim ? cmd->victim : "", cmd 586 daemons/fenced/fenced_commands.c device->id, cmd->client, cmd->timeout); cmd 589 daemons/fenced/fenced_commands.c device->pending_ops = g_list_append(device->pending_ops, cmd); cmd 597 daemons/fenced/fenced_commands.c delay_max = get_action_delay_max(device, cmd->action); cmd 598 daemons/fenced/fenced_commands.c delay_base = get_action_delay_base(device, cmd->action, cmd->victim); cmd 606 daemons/fenced/fenced_commands.c delay_base, delay_max, cmd->action, device->id); cmd 611 daemons/fenced/fenced_commands.c cmd->start_delay += cmd 616 daemons/fenced/fenced_commands.c if (cmd->start_delay > 0) { cmd 619 daemons/fenced/fenced_commands.c cmd->action, cmd 620 daemons/fenced/fenced_commands.c cmd->victim ? " targeting " : "", cmd->victim ? cmd->victim : "", cmd 621 daemons/fenced/fenced_commands.c device->id, cmd->start_delay, cmd->timeout, cmd 623 daemons/fenced/fenced_commands.c cmd->delay_id = cmd 624 daemons/fenced/fenced_commands.c g_timeout_add_seconds(cmd->start_delay, start_delay_helper, cmd); cmd 638 daemons/fenced/fenced_commands.c async_command_t *cmd = gIter->data; cmd 640 daemons/fenced/fenced_commands.c crm_warn("Removal of device '%s' purged operation '%s'", device->id, cmd->action); cmd 641 daemons/fenced/fenced_commands.c report_internal_result(cmd, CRM_EX_ERROR, PCMK_EXEC_NO_FENCE_DEVICE, cmd 1094 daemons/fenced/fenced_commands.c async_command_t *cmd = NULL; cmd 1096 daemons/fenced/fenced_commands.c cmd = calloc(1, sizeof(async_command_t)); cmd 1098 daemons/fenced/fenced_commands.c cmd->id = -1; cmd 1099 daemons/fenced/fenced_commands.c cmd->default_timeout = timeout ? timeout : 60; cmd 1100 daemons/fenced/fenced_commands.c cmd->timeout = cmd->default_timeout; cmd 1101 daemons/fenced/fenced_commands.c cmd->action = strdup(action); cmd 1102 daemons/fenced/fenced_commands.c pcmk__str_update(&cmd->victim, victim); cmd 1103 daemons/fenced/fenced_commands.c cmd->device = strdup(device->id); cmd 1104 daemons/fenced/fenced_commands.c cmd->origin = strdup(origin); cmd 1105 daemons/fenced/fenced_commands.c cmd->client = strdup(crm_system_name); cmd 1106 daemons/fenced/fenced_commands.c cmd->client_name = strdup(crm_system_name); cmd 1108 daemons/fenced/fenced_commands.c cmd->internal_user_data = internal_user_data; cmd 1109 daemons/fenced/fenced_commands.c cmd->done_cb = done_cb; /* cmd, not internal_user_data, is passed to 'done_cb' as the userdata */ cmd 1111 daemons/fenced/fenced_commands.c schedule_stonith_command(cmd, device); cmd 1125 daemons/fenced/fenced_commands.c async_command_t *cmd = user_data; cmd 1126 daemons/fenced/fenced_commands.c struct device_search_s *search = cmd->internal_user_data; cmd 1127 daemons/fenced/fenced_commands.c stonith_device_t *dev = cmd->device ? g_hash_table_lookup(device_list, cmd->device) : NULL; cmd 1130 daemons/fenced/fenced_commands.c free_async_command(cmd); cmd 1175 daemons/fenced/fenced_commands.c async_command_t *cmd = user_data; cmd 1176 daemons/fenced/fenced_commands.c struct device_search_s *search = cmd->internal_user_data; cmd 1177 daemons/fenced/fenced_commands.c stonith_device_t *dev = cmd->device ? g_hash_table_lookup(device_list, cmd->device) : NULL; cmd 1180 daemons/fenced/fenced_commands.c free_async_command(cmd); cmd 1853 daemons/fenced/fenced_commands.c async_command_t *cmd = NULL; cmd 1902 daemons/fenced/fenced_commands.c cmd = create_async_command(msg); cmd 1903 daemons/fenced/fenced_commands.c if (cmd == NULL) { cmd 1908 daemons/fenced/fenced_commands.c schedule_stonith_command(cmd, device); cmd 2360 daemons/fenced/fenced_commands.c log_async_result(async_command_t *cmd, const pcmk__action_result_t *result, cmd 2365 daemons/fenced/fenced_commands.c guint devices_remaining = g_list_length(cmd->device_next); cmd 2371 daemons/fenced/fenced_commands.c log_level = (cmd->victim == NULL)? LOG_DEBUG : LOG_NOTICE; cmd 2373 daemons/fenced/fenced_commands.c && !pcmk__str_eq(cmd->action, "metadata", pcmk__str_casei)) { cmd 2378 daemons/fenced/fenced_commands.c log_level = (cmd->victim == NULL)? LOG_NOTICE : LOG_ERR; cmd 2380 daemons/fenced/fenced_commands.c && !pcmk__str_eq(cmd->action, "metadata", pcmk__str_casei)) { cmd 2386 daemons/fenced/fenced_commands.c g_string_printf(msg, "Operation '%s' ", cmd->action); cmd 2390 daemons/fenced/fenced_commands.c if (cmd->victim != NULL) { cmd 2391 daemons/fenced/fenced_commands.c g_string_append_printf(msg, "targeting %s ", cmd->victim); cmd 2393 daemons/fenced/fenced_commands.c g_string_append_printf(msg, "using %s ", cmd->device); cmd 2416 daemons/fenced/fenced_commands.c (op_merged? "merged " : ""), cmd->id, cmd 2417 daemons/fenced/fenced_commands.c cmd->client_name); cmd 2425 daemons/fenced/fenced_commands.c char *prefix = crm_strdup_printf("%s[%d]", cmd->device, pid); cmd 2442 daemons/fenced/fenced_commands.c send_async_reply(async_command_t *cmd, const pcmk__action_result_t *result, cmd 2448 daemons/fenced/fenced_commands.c CRM_CHECK((cmd != NULL) && (result != NULL), return); cmd 2450 daemons/fenced/fenced_commands.c log_async_result(cmd, result, pid, NULL, merged); cmd 2452 daemons/fenced/fenced_commands.c if (cmd->client != NULL) { cmd 2453 daemons/fenced/fenced_commands.c client = pcmk__find_client_by_id(cmd->client); cmd 2454 daemons/fenced/fenced_commands.c if ((client == NULL) && (cmd->origin == NULL)) { cmd 2455 daemons/fenced/fenced_commands.c crm_trace("Skipping reply to %s: no longer a client", cmd->client); cmd 2460 daemons/fenced/fenced_commands.c reply = construct_async_reply(cmd, result); cmd 2465 daemons/fenced/fenced_commands.c if (!stand_alone && pcmk__is_fencing_action(cmd->action) cmd 2466 daemons/fenced/fenced_commands.c && pcmk__str_eq(cmd->origin, cmd->victim, pcmk__str_casei)) { cmd 2471 daemons/fenced/fenced_commands.c cmd->action, cmd->victim); cmd 2477 daemons/fenced/fenced_commands.c stonith_send_reply(reply, cmd->options, cmd->origin, client); cmd 2488 daemons/fenced/fenced_commands.c crm_xml_add(notify_data, F_STONITH_TARGET, cmd->victim); cmd 2489 daemons/fenced/fenced_commands.c crm_xml_add(notify_data, F_STONITH_OPERATION, cmd->op); cmd 2491 daemons/fenced/fenced_commands.c crm_xml_add(notify_data, F_STONITH_DEVICE, cmd->device); cmd 2492 daemons/fenced/fenced_commands.c crm_xml_add(notify_data, F_STONITH_REMOTE_OP_ID, cmd->remote_op_id); cmd 2493 daemons/fenced/fenced_commands.c crm_xml_add(notify_data, F_STONITH_ORIGIN, cmd->client); cmd 2501 daemons/fenced/fenced_commands.c cancel_stonith_command(async_command_t * cmd) cmd 2505 daemons/fenced/fenced_commands.c CRM_CHECK(cmd != NULL, return); cmd 2507 daemons/fenced/fenced_commands.c if (!cmd->device) { cmd 2511 daemons/fenced/fenced_commands.c device = g_hash_table_lookup(device_list, cmd->device); cmd 2515 daemons/fenced/fenced_commands.c cmd->action, device->id); cmd 2516 daemons/fenced/fenced_commands.c device->pending_ops = g_list_remove(device->pending_ops, cmd); cmd 2525 daemons/fenced/fenced_commands.c async_command_t *cmd = user_data; cmd 2530 daemons/fenced/fenced_commands.c CRM_CHECK(cmd != NULL, return); cmd 2532 daemons/fenced/fenced_commands.c cmd->active_on = NULL; cmd 2535 daemons/fenced/fenced_commands.c device = g_hash_table_lookup(device_list, cmd->device); cmd 2538 daemons/fenced/fenced_commands.c (pcmk__strcase_any_of(cmd->action, "list", "monitor", "status", NULL))) { cmd 2549 daemons/fenced/fenced_commands.c for (iter = cmd->device_next; iter != NULL; iter = iter->next) { cmd 2552 daemons/fenced/fenced_commands.c if (next_device != NULL && is_action_required(cmd->action, next_device)) { cmd 2553 daemons/fenced/fenced_commands.c cmd->device_next = iter->next; cmd 2559 daemons/fenced/fenced_commands.c } else if ((cmd->device_next != NULL) cmd 2560 daemons/fenced/fenced_commands.c && !is_action_required(cmd->action, device)) { cmd 2563 daemons/fenced/fenced_commands.c next_device = g_hash_table_lookup(device_list, cmd->device_next->data); cmd 2564 daemons/fenced/fenced_commands.c cmd->device_next = cmd->device_next->next; cmd 2569 daemons/fenced/fenced_commands.c log_async_result(cmd, result, pid, next_device->id, false); cmd 2570 daemons/fenced/fenced_commands.c schedule_stonith_command(cmd, next_device); cmd 2572 daemons/fenced/fenced_commands.c cmd = NULL; cmd 2576 daemons/fenced/fenced_commands.c send_async_reply(cmd, result, pid, false); cmd 2591 daemons/fenced/fenced_commands.c if (cmd == cmd_other) { cmd 2601 daemons/fenced/fenced_commands.c if (pcmk__str_eq(cmd->client, cmd_other->client, pcmk__str_casei) || cmd 2602 daemons/fenced/fenced_commands.c !pcmk__str_eq(cmd->victim, cmd_other->victim, pcmk__str_casei) || cmd 2603 daemons/fenced/fenced_commands.c !pcmk__str_eq(cmd->action, cmd_other->action, pcmk__str_casei) || cmd 2604 daemons/fenced/fenced_commands.c !pcmk__str_eq(cmd->device, cmd_other->device, pcmk__str_casei)) { cmd 2620 daemons/fenced/fenced_commands.c cmd->client_name); cmd 2632 daemons/fenced/fenced_commands.c free_async_command(cmd); cmd 2652 daemons/fenced/fenced_commands.c async_command_t *cmd = user_data; cmd 2657 daemons/fenced/fenced_commands.c ndevices, pcmk__plural_s(ndevices), cmd->victim); cmd 2670 daemons/fenced/fenced_commands.c cmd->victim); cmd 2671 daemons/fenced/fenced_commands.c send_async_reply(cmd, &result, 0, false); cmd 2673 daemons/fenced/fenced_commands.c free_async_command(cmd); cmd 2677 daemons/fenced/fenced_commands.c cmd->device_list = devices; cmd 2678 daemons/fenced/fenced_commands.c cmd->device_next = devices->next; cmd 2679 daemons/fenced/fenced_commands.c schedule_stonith_command(cmd, device); cmd 2695 daemons/fenced/fenced_commands.c async_command_t *cmd = create_async_command(msg); cmd 2700 daemons/fenced/fenced_commands.c if (cmd == NULL) { cmd 2714 daemons/fenced/fenced_commands.c schedule_stonith_command(cmd, device); cmd 2719 daemons/fenced/fenced_commands.c if (pcmk_is_set(cmd->options, st_opt_cs_nodeid)) { cmd 2731 daemons/fenced/fenced_commands.c get_capable_devices(host, cmd->action, cmd->default_timeout, cmd 2732 daemons/fenced/fenced_commands.c TRUE, cmd, stonith_fence_get_devices_cb); cmd 2809 daemons/fenced/fenced_commands.c construct_async_reply(async_command_t *cmd, const pcmk__action_result_t *result) cmd 2815 daemons/fenced/fenced_commands.c crm_xml_add(reply, F_STONITH_OPERATION, cmd->op); cmd 2816 daemons/fenced/fenced_commands.c crm_xml_add(reply, F_STONITH_DEVICE, cmd->device); cmd 2817 daemons/fenced/fenced_commands.c crm_xml_add(reply, F_STONITH_REMOTE_OP_ID, cmd->remote_op_id); cmd 2818 daemons/fenced/fenced_commands.c crm_xml_add(reply, F_STONITH_CLIENTID, cmd->client); cmd 2819 daemons/fenced/fenced_commands.c crm_xml_add(reply, F_STONITH_CLIENTNAME, cmd->client_name); cmd 2820 daemons/fenced/fenced_commands.c crm_xml_add(reply, F_STONITH_TARGET, cmd->victim); cmd 2821 daemons/fenced/fenced_commands.c crm_xml_add(reply, F_STONITH_ACTION, cmd->op); cmd 2822 daemons/fenced/fenced_commands.c crm_xml_add(reply, F_STONITH_ORIGIN, cmd->origin); cmd 2823 daemons/fenced/fenced_commands.c crm_xml_add_int(reply, F_STONITH_CALLID, cmd->id); cmd 2824 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 218 lib/common/ipc_pacemakerd.c xmlNode *cmd; cmd 228 lib/common/ipc_pacemakerd.c cmd = create_request(task, NULL, NULL, CRM_SYSTEM_MCP, cmd 232 lib/common/ipc_pacemakerd.c if (cmd) { cmd 233 lib/common/ipc_pacemakerd.c rc = pcmk__send_ipc_request(api, cmd); cmd 238 lib/common/ipc_pacemakerd.c free_xml(cmd); cmd 144 lib/common/ipc_schedulerd.c xmlNode *cmd = NULL; cmd 154 lib/common/ipc_schedulerd.c cmd = create_request(task, cib, NULL, CRM_SYSTEM_PENGINE, cmd 158 lib/common/ipc_schedulerd.c if (cmd) { cmd 159 lib/common/ipc_schedulerd.c rc = pcmk__send_ipc_request(api, cmd); cmd 165 lib/common/ipc_schedulerd.c *ref = strdup(crm_element_value(cmd, F_CRM_REFERENCE)); cmd 166 lib/common/ipc_schedulerd.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 204 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 248 maint/gnulib/lib/chdir-long.c char const *cmd = "pwd"; cmd 249 maint/gnulib/lib/chdir-long.c execlp (cmd, (char *) NULL); cmd 250 maint/gnulib/lib/chdir-long.c error (EXIT_FAILURE, errno, "%s", cmd); cmd 182 maint/gnulib/lib/flock.c int cmd, r; cmd 186 maint/gnulib/lib/flock.c cmd = F_SETLK; cmd 188 maint/gnulib/lib/flock.c cmd = F_SETLKW; cmd 211 maint/gnulib/lib/flock.c r = fcntl (fd, cmd, &fl); cmd 318 maint/gnulib/lib/get_progname_of.c char *cmd = status.pst_cmd; cmd 325 maint/gnulib/lib/get_progname_of.c char *space = strchr (cmd, ' '); cmd 328 maint/gnulib/lib/get_progname_of.c p = strrchr (cmd, '/'); cmd 332 maint/gnulib/lib/get_progname_of.c p = cmd; cmd 354 maint/gnulib/lib/get_progname_of.c char *cmd = status64 + 168; cmd 361 maint/gnulib/lib/get_progname_of.c char *space = strchr (cmd, ' '); cmd 364 maint/gnulib/lib/get_progname_of.c p = strrchr (cmd, '/'); cmd 368 maint/gnulib/lib/get_progname_of.c p = cmd; cmd 126 maint/gnulib/lib/getprogname.c char *cmd = status.pst_cmd; cmd 133 maint/gnulib/lib/getprogname.c char *space = strchr (cmd, ' '); cmd 136 maint/gnulib/lib/getprogname.c p = strrchr (cmd, '/'); cmd 140 maint/gnulib/lib/getprogname.c p = cmd; cmd 162 maint/gnulib/lib/getprogname.c char *cmd = status64 + 168; cmd 169 maint/gnulib/lib/getprogname.c char *space = strchr (cmd, ' '); cmd 172 maint/gnulib/lib/getprogname.c p = strrchr (cmd, '/'); cmd 176 maint/gnulib/lib/getprogname.c p = cmd; cmd 31 maint/gnulib/lib/popen-safer.c popen_safer (char const *cmd, char const *mode) cmd 47 maint/gnulib/lib/popen-safer.c fp = popen_safer (cmd, mode); cmd 57 maint/gnulib/lib/popen-safer.c fp = popen (cmd, mode); cmd 1053 maint/gnulib/lib/stdio.in.h (const char *cmd, const char *mode) cmd 1055 maint/gnulib/lib/stdio.in.h _GL_CXXALIAS_RPL (popen, FILE *, (const char *cmd, const char *mode)); cmd 1059 maint/gnulib/lib/stdio.in.h (const char *cmd, const char *mode) cmd 1062 maint/gnulib/lib/stdio.in.h _GL_CXXALIAS_SYS (popen, FILE *, (const char *cmd, const char *mode)); cmd 1069 maint/gnulib/lib/stdio.in.h (const char *cmd, const char *mode) cmd 33 maint/gnulib/tests/test-popen.h char *cmd; cmd 50 maint/gnulib/tests/test-popen.h cmd = malloc (len + 3); /* Adding " r" and NUL. */ cmd 51 maint/gnulib/tests/test-popen.h ASSERT (cmd); cmd 53 maint/gnulib/tests/test-popen.h strcpy (cmd, argv[0]); cmd 54 maint/gnulib/tests/test-popen.h cmd[len] = ' '; cmd 55 maint/gnulib/tests/test-popen.h cmd[len + 2] = '\0'; cmd 67 maint/gnulib/tests/test-popen.h cmd[len + 1] = 'r'; cmd 68 maint/gnulib/tests/test-popen.h ASSERT (child = popen (cmd, "r")); cmd 79 maint/gnulib/tests/test-popen.h cmd[len + 1] = 'w'; cmd 80 maint/gnulib/tests/test-popen.h ASSERT (child = popen (cmd, "w")); cmd 91 maint/gnulib/tests/test-popen.h free (cmd); cmd 410 tools/crm_node.c xmlNode *cmd = NULL; cmd 426 tools/crm_node.c cmd = create_xml_node(NULL, __func__); cmd 428 tools/crm_node.c crm_xml_add(cmd, F_TYPE, T_ATTRD); cmd 429 tools/crm_node.c crm_xml_add(cmd, F_ORIG, crm_system_name); cmd 431 tools/crm_node.c crm_xml_add(cmd, PCMK__XA_TASK, PCMK__ATTRD_CMD_PEER_REMOVE); cmd 432 tools/crm_node.c crm_xml_add(cmd, PCMK__XA_ATTR_NODE_NAME, node_name); cmd 435 tools/crm_node.c crm_xml_add_int(cmd, PCMK__XA_ATTR_NODE_ID, (int) nodeid); cmd 439 tools/crm_node.c cmd = create_request(CRM_OP_RM_NODE_CACHE, NULL, NULL, target, cmd 442 tools/crm_node.c crm_xml_set_id(cmd, "%ld", nodeid); cmd 444 tools/crm_node.c crm_xml_add(cmd, XML_ATTR_UNAME, node_name); cmd 447 tools/crm_node.c rc = crm_ipc_send(conn, cmd, 0, 0, NULL); cmd 460 tools/crm_node.c free_xml(cmd); cmd 126 tools/crm_resource.c #define SET_COMMAND(cmd) do { \ cmd 132 tools/crm_resource.c options.rsc_cmd = (cmd); \ cmd 135 tools/crm_resource.c #define SET_COMMAND(cmd) do { \ cmd 139 tools/crm_resource.c options.rsc_cmd = (cmd); \ cmd 195 tools/crm_resource_runtime.c cib_t * cib, const char * cmd, int depth) cmd 205 tools/crm_resource_runtime.c attr_id, attr_name, cib, cmd, depth+1); cmd 231 tools/crm_resource_runtime.c const char * attr_name, cib_t * cib, const char * cmd, cmd 254 tools/crm_resource_runtime.c cmd, attr_name, rsc->id, rsc_id); cmd 268 tools/crm_resource_runtime.c attr_name, lookup_id, cmd, rsc_id); cmd 279 tools/crm_resource_runtime.c cib, cmd, 0);