cmd                28 daemons/controld/controld_remote_ra.c #define cmd_set_flags(cmd, flags_to_set) do { \
cmd                29 daemons/controld/controld_remote_ra.c     (cmd)->status = pcmk__set_flags_as(__func__, __LINE__, LOG_TRACE, \
cmd                30 daemons/controld/controld_remote_ra.c                                        "Remote command", (cmd)->rsc_id, (cmd)->status, \
cmd                34 daemons/controld/controld_remote_ra.c #define cmd_clear_flags(cmd, flags_to_clear) do { \
cmd                35 daemons/controld/controld_remote_ra.c     (cmd)->status = pcmk__clear_flags_as(__func__, __LINE__, LOG_TRACE, \
cmd                36 daemons/controld/controld_remote_ra.c                                          "Remote command", (cmd)->rsc_id, (cmd)->status, \
cmd               115 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               116 daemons/controld/controld_remote_ra.c static void handle_remote_ra_stop(lrm_state_t * lrm_state, remote_ra_cmd_t * cmd);
cmd               122 daemons/controld/controld_remote_ra.c     remote_ra_cmd_t *cmd = user_data;
cmd               124 daemons/controld/controld_remote_ra.c     if (!cmd) {
cmd               127 daemons/controld/controld_remote_ra.c     if (cmd->delay_id) {
cmd               128 daemons/controld/controld_remote_ra.c         g_source_remove(cmd->delay_id);
cmd               130 daemons/controld/controld_remote_ra.c     if (cmd->interval_id) {
cmd               131 daemons/controld/controld_remote_ra.c         g_source_remove(cmd->interval_id);
cmd               133 daemons/controld/controld_remote_ra.c     if (cmd->monitor_timeout_id) {
cmd               134 daemons/controld/controld_remote_ra.c         g_source_remove(cmd->monitor_timeout_id);
cmd               136 daemons/controld/controld_remote_ra.c     if (cmd->takeover_timeout_id) {
cmd               137 daemons/controld/controld_remote_ra.c         g_source_remove(cmd->takeover_timeout_id);
cmd               139 daemons/controld/controld_remote_ra.c     free(cmd->owner);
cmd               140 daemons/controld/controld_remote_ra.c     free(cmd->rsc_id);
cmd               141 daemons/controld/controld_remote_ra.c     free(cmd->action);
cmd               142 daemons/controld/controld_remote_ra.c     free(cmd->userdata);
cmd               143 daemons/controld/controld_remote_ra.c     pcmk__reset_result(&(cmd->result));
cmd               144 daemons/controld/controld_remote_ra.c     lrmd_key_value_freeall(cmd->params);
cmd               145 daemons/controld/controld_remote_ra.c     free(cmd);
cmd               164 daemons/controld/controld_remote_ra.c     remote_ra_cmd_t *cmd = data;
cmd               167 daemons/controld/controld_remote_ra.c     cmd->interval_id = 0;
cmd               168 daemons/controld/controld_remote_ra.c     connection_rsc = controld_get_executor_state(cmd->rsc_id, false);
cmd               172 daemons/controld/controld_remote_ra.c         ra_data->recurring_cmds = g_list_remove(ra_data->recurring_cmds, cmd);
cmd               174 daemons/controld/controld_remote_ra.c         ra_data->cmds = g_list_append(ra_data->cmds, cmd);
cmd               183 daemons/controld/controld_remote_ra.c     remote_ra_cmd_t *cmd = data;
cmd               186 daemons/controld/controld_remote_ra.c     cmd->delay_id = 0;
cmd               187 daemons/controld/controld_remote_ra.c     connection_rsc = controld_get_executor_state(cmd->rsc_id, false);
cmd               407 daemons/controld/controld_remote_ra.c check_remote_node_state(const remote_ra_cmd_t *cmd)
cmd               410 daemons/controld/controld_remote_ra.c     if (!pcmk__result_ok(&(cmd->result))) {
cmd               414 daemons/controld/controld_remote_ra.c     if (pcmk__str_eq(cmd->action, PCMK_ACTION_START, pcmk__str_casei)) {
cmd               415 daemons/controld/controld_remote_ra.c         remote_node_up(cmd->rsc_id);
cmd               417 daemons/controld/controld_remote_ra.c     } else if (pcmk__str_eq(cmd->action, PCMK_ACTION_MIGRATE_FROM,
cmd               427 daemons/controld/controld_remote_ra.c             pcmk__cluster_lookup_remote_node(cmd->rsc_id);
cmd               432 daemons/controld/controld_remote_ra.c     } else if (pcmk__str_eq(cmd->action, PCMK_ACTION_STOP, pcmk__str_casei)) {
cmd               433 daemons/controld/controld_remote_ra.c         lrm_state_t *lrm_state = controld_get_executor_state(cmd->rsc_id,
cmd               440 daemons/controld/controld_remote_ra.c                 remote_node_down(cmd->rsc_id, DOWN_KEEP_LRM);
cmd               446 daemons/controld/controld_remote_ra.c                 pcmk__cluster_forget_remote_node(cmd->rsc_id);
cmd               463 daemons/controld/controld_remote_ra.c report_remote_ra_result(remote_ra_cmd_t * cmd)
cmd               467 daemons/controld/controld_remote_ra.c     check_remote_node_state(cmd);
cmd               470 daemons/controld/controld_remote_ra.c     op.rsc_id = cmd->rsc_id;
cmd               471 daemons/controld/controld_remote_ra.c     op.op_type = cmd->action;
cmd               472 daemons/controld/controld_remote_ra.c     op.user_data = cmd->userdata;
cmd               473 daemons/controld/controld_remote_ra.c     op.timeout = cmd->timeout;
cmd               474 daemons/controld/controld_remote_ra.c     op.interval_ms = cmd->interval_ms;
cmd               475 daemons/controld/controld_remote_ra.c     op.t_run = cmd->start_time;
cmd               476 daemons/controld/controld_remote_ra.c     op.t_rcchange = cmd->start_time;
cmd               478 daemons/controld/controld_remote_ra.c     lrmd__set_result(&op, cmd->result.exit_status, cmd->result.execution_status,
cmd               479 daemons/controld/controld_remote_ra.c                      cmd->result.exit_reason);
cmd               481 daemons/controld/controld_remote_ra.c     if (pcmk_is_set(cmd->status, cmd_reported_success) && !pcmk__result_ok(&(cmd->result))) {
cmd               497 daemons/controld/controld_remote_ra.c     if (cmd->params) {
cmd               501 daemons/controld/controld_remote_ra.c         for (tmp = cmd->params; tmp; tmp = tmp->next) {
cmd               506 daemons/controld/controld_remote_ra.c     op.call_id = cmd->call_id;
cmd               507 daemons/controld/controld_remote_ra.c     op.remote_nodename = cmd->owner;
cmd               526 daemons/controld/controld_remote_ra.c remaining_timeout_sec(const remote_ra_cmd_t *cmd)
cmd               528 daemons/controld/controld_remote_ra.c     return pcmk__timeout_ms2s(cmd->timeout) - (time(NULL) - cmd->start_time);
cmd               536 daemons/controld/controld_remote_ra.c     remote_ra_cmd_t *cmd = NULL;
cmd               543 daemons/controld/controld_remote_ra.c     cmd = ra_data->cur_cmd;
cmd               544 daemons/controld/controld_remote_ra.c     if (!pcmk__is_up_action(cmd->action)) {
cmd               548 daemons/controld/controld_remote_ra.c     remaining = remaining_timeout_sec(cmd);
cmd               550 daemons/controld/controld_remote_ra.c         rc = handle_remote_ra_start(lrm_state, cmd, remaining * 1000);
cmd               552 daemons/controld/controld_remote_ra.c         pcmk__set_result(&(cmd->result), PCMK_OCF_UNKNOWN_ERROR,
cmd               558 daemons/controld/controld_remote_ra.c         report_remote_ra_result(cmd);
cmd               564 daemons/controld/controld_remote_ra.c         free_cmd(cmd);
cmd               577 daemons/controld/controld_remote_ra.c     remote_ra_cmd_t *cmd = data;
cmd               579 daemons/controld/controld_remote_ra.c     crm_info("takeover event timed out for node %s", cmd->rsc_id);
cmd               580 daemons/controld/controld_remote_ra.c     cmd->takeover_timeout_id = 0;
cmd               582 daemons/controld/controld_remote_ra.c     lrm_state = controld_get_executor_state(cmd->rsc_id, false);
cmd               584 daemons/controld/controld_remote_ra.c     handle_remote_ra_stop(lrm_state, cmd);
cmd               585 daemons/controld/controld_remote_ra.c     free_cmd(cmd);
cmd               594 daemons/controld/controld_remote_ra.c     remote_ra_cmd_t *cmd = data;
cmd               596 daemons/controld/controld_remote_ra.c     lrm_state = controld_get_executor_state(cmd->rsc_id, false);
cmd               599 daemons/controld/controld_remote_ra.c              cmd->rsc_id, (lrm_state? "" : " (no LRM state)"));
cmd               600 daemons/controld/controld_remote_ra.c     cmd->monitor_timeout_id = 0;
cmd               601 daemons/controld/controld_remote_ra.c     pcmk__set_result(&(cmd->result), PCMK_OCF_UNKNOWN_ERROR, PCMK_EXEC_TIMEOUT,
cmd               607 daemons/controld/controld_remote_ra.c         if (ra_data->cur_cmd == cmd) {
cmd               615 daemons/controld/controld_remote_ra.c     report_remote_ra_result(cmd);
cmd               616 daemons/controld/controld_remote_ra.c     free_cmd(cmd);
cmd               652 daemons/controld/controld_remote_ra.c     remote_ra_cmd_t *cmd = NULL;
cmd               729 daemons/controld/controld_remote_ra.c     cmd = ra_data->cur_cmd;
cmd               733 daemons/controld/controld_remote_ra.c     if ((op->type == lrmd_event_connect) && pcmk__is_up_action(cmd->action)) {
cmd               735 daemons/controld/controld_remote_ra.c             int remaining = remaining_timeout_sec(cmd);
cmd               740 daemons/controld/controld_remote_ra.c                 pcmk__set_result(&(cmd->result), PCMK_OCF_INVALID_PARAM,
cmd               753 daemons/controld/controld_remote_ra.c                 pcmk__format_result(&(cmd->result), PCMK_OCF_UNKNOWN_ERROR,
cmd               761 daemons/controld/controld_remote_ra.c             pcmk__set_result(&(cmd->result), PCMK_OCF_OK, PCMK_EXEC_DONE, NULL);
cmd               765 daemons/controld/controld_remote_ra.c         crm_debug("Remote connection event matched %s action", cmd->action);
cmd               766 daemons/controld/controld_remote_ra.c         report_remote_ra_result(cmd);
cmd               770 daemons/controld/controld_remote_ra.c                && pcmk__str_eq(cmd->action, PCMK_ACTION_MONITOR,
cmd               773 daemons/controld/controld_remote_ra.c         if (cmd->monitor_timeout_id) {
cmd               774 daemons/controld/controld_remote_ra.c             g_source_remove(cmd->monitor_timeout_id);
cmd               775 daemons/controld/controld_remote_ra.c             cmd->monitor_timeout_id = 0;
cmd               781 daemons/controld/controld_remote_ra.c         if (!pcmk_is_set(cmd->status, cmd_reported_success)) {
cmd               782 daemons/controld/controld_remote_ra.c             pcmk__set_result(&(cmd->result), PCMK_OCF_OK, PCMK_EXEC_DONE, NULL);
cmd               783 daemons/controld/controld_remote_ra.c             report_remote_ra_result(cmd);
cmd               784 daemons/controld/controld_remote_ra.c             cmd_set_flags(cmd, cmd_reported_success);
cmd               787 daemons/controld/controld_remote_ra.c         crm_debug("Remote poke event matched %s action", cmd->action);
cmd               790 daemons/controld/controld_remote_ra.c         if (cmd->interval_ms && !pcmk_is_set(cmd->status, cmd_cancel)) {
cmd               791 daemons/controld/controld_remote_ra.c             ra_data->recurring_cmds = g_list_append(ra_data->recurring_cmds, cmd);
cmd               792 daemons/controld/controld_remote_ra.c             cmd->interval_id = pcmk__create_timer(cmd->interval_ms,
cmd               793 daemons/controld/controld_remote_ra.c                                                   recurring_helper, cmd);
cmd               794 daemons/controld/controld_remote_ra.c             cmd = NULL;         /* prevent free */
cmd               799 daemons/controld/controld_remote_ra.c                && pcmk__str_eq(cmd->action, PCMK_ACTION_MONITOR,
cmd               802 daemons/controld/controld_remote_ra.c             !pcmk_is_set(cmd->status, cmd_cancel)) {
cmd               803 daemons/controld/controld_remote_ra.c             pcmk__set_result(&(cmd->result), PCMK_OCF_UNKNOWN_ERROR,
cmd               807 daemons/controld/controld_remote_ra.c             report_remote_ra_result(cmd);
cmd               822 daemons/controld/controld_remote_ra.c         free_cmd(cmd);
cmd               827 daemons/controld/controld_remote_ra.c handle_remote_ra_stop(lrm_state_t * lrm_state, remote_ra_cmd_t * cmd)
cmd               856 daemons/controld/controld_remote_ra.c     if (cmd) {
cmd               857 daemons/controld/controld_remote_ra.c         pcmk__set_result(&(cmd->result), PCMK_OCF_OK, PCMK_EXEC_DONE, NULL);
cmd               858 daemons/controld/controld_remote_ra.c         report_remote_ra_result(cmd);
cmd               864 daemons/controld/controld_remote_ra.c handle_remote_ra_start(lrm_state_t * lrm_state, remote_ra_cmd_t * cmd, int timeout_ms)
cmd               872 daemons/controld/controld_remote_ra.c     for (tmp = cmd->params; tmp; tmp = tmp->next) {
cmd               891 daemons/controld/controld_remote_ra.c         pcmk__format_result(&(cmd->result), PCMK_OCF_UNKNOWN_ERROR,
cmd               905 daemons/controld/controld_remote_ra.c     remote_ra_cmd_t *cmd;
cmd               915 daemons/controld/controld_remote_ra.c         cmd = first->data;
cmd               916 daemons/controld/controld_remote_ra.c         if (cmd->delay_id) {
cmd               924 daemons/controld/controld_remote_ra.c         if (pcmk__str_any_of(cmd->action, PCMK_ACTION_START,
cmd               927 daemons/controld/controld_remote_ra.c             if (handle_remote_ra_start(lrm_state, cmd,
cmd               928 daemons/controld/controld_remote_ra.c                                        cmd->timeout) == pcmk_rc_ok) {
cmd               931 daemons/controld/controld_remote_ra.c                           cmd->action);
cmd               932 daemons/controld/controld_remote_ra.c                 ra_data->cur_cmd = cmd;
cmd               935 daemons/controld/controld_remote_ra.c             report_remote_ra_result(cmd);
cmd               937 daemons/controld/controld_remote_ra.c         } else if (!strcmp(cmd->action, PCMK_ACTION_MONITOR)) {
cmd               942 daemons/controld/controld_remote_ra.c                     pcmk__set_result(&(cmd->result), PCMK_OCF_UNKNOWN_ERROR,
cmd               947 daemons/controld/controld_remote_ra.c                 pcmk__set_result(&(cmd->result), PCMK_OCF_NOT_RUNNING,
cmd               953 daemons/controld/controld_remote_ra.c                           cmd->rsc_id);
cmd               954 daemons/controld/controld_remote_ra.c                 ra_data->cur_cmd = cmd;
cmd               955 daemons/controld/controld_remote_ra.c                 cmd->monitor_timeout_id = pcmk__create_timer(cmd->timeout, monitor_timeout_cb, cmd);
cmd               958 daemons/controld/controld_remote_ra.c             report_remote_ra_result(cmd);
cmd               960 daemons/controld/controld_remote_ra.c         } else if (!strcmp(cmd->action, PCMK_ACTION_STOP)) {
cmd               970 daemons/controld/controld_remote_ra.c                 cmd->takeover_timeout_id = pcmk__create_timer((cmd->timeout/2),
cmd               972 daemons/controld/controld_remote_ra.c                                                               cmd);
cmd               973 daemons/controld/controld_remote_ra.c                 ra_data->cur_cmd = cmd;
cmd               977 daemons/controld/controld_remote_ra.c             handle_remote_ra_stop(lrm_state, cmd);
cmd               979 daemons/controld/controld_remote_ra.c         } else if (strcmp(cmd->action, PCMK_ACTION_MIGRATE_TO) == 0) {
cmd               982 daemons/controld/controld_remote_ra.c             pcmk__set_result(&(cmd->result), PCMK_OCF_OK, PCMK_EXEC_DONE, NULL);
cmd               983 daemons/controld/controld_remote_ra.c             report_remote_ra_result(cmd);
cmd               985 daemons/controld/controld_remote_ra.c         } else if (pcmk__str_any_of(cmd->action, PCMK_ACTION_RELOAD,
cmd               996 daemons/controld/controld_remote_ra.c             pcmk__set_result(&(cmd->result), PCMK_OCF_OK, PCMK_EXEC_DONE, NULL);
cmd               997 daemons/controld/controld_remote_ra.c             report_remote_ra_result(cmd);
cmd              1000 daemons/controld/controld_remote_ra.c         free_cmd(cmd);
cmd              1088 daemons/controld/controld_remote_ra.c     remote_ra_cmd_t *cmd = NULL;
cmd              1092 daemons/controld/controld_remote_ra.c         cmd = gIter->data;
cmd              1093 daemons/controld/controld_remote_ra.c         if ((cmd->interval_ms > 0)
cmd              1094 daemons/controld/controld_remote_ra.c             && pcmk__str_eq(cmd->action, PCMK_ACTION_MONITOR,
cmd              1096 daemons/controld/controld_remote_ra.c             rm_list = g_list_append(rm_list, cmd);
cmd              1101 daemons/controld/controld_remote_ra.c         cmd = gIter->data;
cmd              1103 daemons/controld/controld_remote_ra.c         pcmk__set_result(&(cmd->result), PCMK_OCF_UNKNOWN_ERROR,
cmd              1106 daemons/controld/controld_remote_ra.c                   cmd->action, cmd->rsc_id, cmd->interval_ms, cmd->userdata);
cmd              1107 daemons/controld/controld_remote_ra.c         report_remote_ra_result(cmd);
cmd              1109 daemons/controld/controld_remote_ra.c         list = g_list_remove(list, cmd);
cmd              1110 daemons/controld/controld_remote_ra.c         free_cmd(cmd);
cmd              1121 daemons/controld/controld_remote_ra.c     remote_ra_cmd_t *cmd = NULL;
cmd              1125 daemons/controld/controld_remote_ra.c         cmd = gIter->data;
cmd              1126 daemons/controld/controld_remote_ra.c         if ((cmd->interval_ms == interval_ms)
cmd              1127 daemons/controld/controld_remote_ra.c             && pcmk__str_eq(cmd->action, action, pcmk__str_casei)) {
cmd              1130 daemons/controld/controld_remote_ra.c         cmd = NULL;
cmd              1132 daemons/controld/controld_remote_ra.c     if (cmd) {
cmd              1133 daemons/controld/controld_remote_ra.c         list = g_list_remove(list, cmd);
cmd              1134 daemons/controld/controld_remote_ra.c         free_cmd(cmd);
cmd              1172 daemons/controld/controld_remote_ra.c     remote_ra_cmd_t *cmd = NULL;
cmd              1190 daemons/controld/controld_remote_ra.c         cmd = ra_data->cur_cmd;
cmd              1195 daemons/controld/controld_remote_ra.c         cmd = gIter->data;
cmd              1196 daemons/controld/controld_remote_ra.c         if ((cmd->interval_ms == interval_ms)
cmd              1197 daemons/controld/controld_remote_ra.c             && pcmk__str_eq(cmd->action, PCMK_ACTION_MONITOR,
cmd              1204 daemons/controld/controld_remote_ra.c         cmd = gIter->data;
cmd              1205 daemons/controld/controld_remote_ra.c         if ((cmd->interval_ms == interval_ms)
cmd              1206 daemons/controld/controld_remote_ra.c             && pcmk__str_eq(cmd->action, PCMK_ACTION_MONITOR,
cmd              1217 daemons/controld/controld_remote_ra.c               cmd->rsc_id, PCMK_ACTION_MONITOR, interval_ms);
cmd              1221 daemons/controld/controld_remote_ra.c        free(cmd->userdata);
cmd              1222 daemons/controld/controld_remote_ra.c        cmd->userdata = pcmk__str_copy(userdata);
cmd              1226 daemons/controld/controld_remote_ra.c     if (pcmk_is_set(cmd->status, cmd_reported_success)) {
cmd              1227 daemons/controld/controld_remote_ra.c         cmd->start_time = time(NULL);
cmd              1228 daemons/controld/controld_remote_ra.c         cmd->call_id = generate_callid();
cmd              1229 daemons/controld/controld_remote_ra.c         cmd_clear_flags(cmd, cmd_reported_success);
cmd              1235 daemons/controld/controld_remote_ra.c     if (cmd->interval_id) {
cmd              1236 daemons/controld/controld_remote_ra.c         g_source_remove(cmd->interval_id);
cmd              1237 daemons/controld/controld_remote_ra.c         cmd->interval_id = 0;
cmd              1238 daemons/controld/controld_remote_ra.c         recurring_helper(cmd);
cmd              1241 daemons/controld/controld_remote_ra.c     return cmd;
cmd              1270 daemons/controld/controld_remote_ra.c     remote_ra_cmd_t *cmd = NULL;
cmd              1293 daemons/controld/controld_remote_ra.c     cmd = handle_dup_monitor(ra_data, interval_ms, userdata);
cmd              1294 daemons/controld/controld_remote_ra.c     if (cmd) {
cmd              1295 daemons/controld/controld_remote_ra.c         *call_id = cmd->call_id;
cmd              1300 daemons/controld/controld_remote_ra.c     cmd = pcmk__assert_alloc(1, sizeof(remote_ra_cmd_t));
cmd              1302 daemons/controld/controld_remote_ra.c     cmd->owner = pcmk__str_copy(lrm_state->node_name);
cmd              1303 daemons/controld/controld_remote_ra.c     cmd->rsc_id = pcmk__str_copy(rsc_id);
cmd              1304 daemons/controld/controld_remote_ra.c     cmd->action = pcmk__str_copy(action);
cmd              1305 daemons/controld/controld_remote_ra.c     cmd->userdata = pcmk__str_copy(userdata);
cmd              1306 daemons/controld/controld_remote_ra.c     cmd->interval_ms = interval_ms;
cmd              1307 daemons/controld/controld_remote_ra.c     cmd->timeout = timeout_ms;
cmd              1308 daemons/controld/controld_remote_ra.c     cmd->start_delay = start_delay_ms;
cmd              1309 daemons/controld/controld_remote_ra.c     cmd->params = params;
cmd              1310 daemons/controld/controld_remote_ra.c     cmd->start_time = time(NULL);
cmd              1312 daemons/controld/controld_remote_ra.c     cmd->call_id = generate_callid();
cmd              1314 daemons/controld/controld_remote_ra.c     if (cmd->start_delay) {
cmd              1315 daemons/controld/controld_remote_ra.c         cmd->delay_id = pcmk__create_timer(cmd->start_delay, start_delay_helper, cmd);
cmd              1318 daemons/controld/controld_remote_ra.c     ra_data->cmds = g_list_append(ra_data->cmds, cmd);
cmd              1321 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               400 daemons/controld/controld_te_actions.c     cmd = pcmk__new_request(pcmk_ipc_controld, CRM_SYSTEM_TENGINE, router_node,
cmd               406 daemons/controld/controld_te_actions.c             .msg = cmd,
cmd               432 daemons/controld/controld_te_actions.c         rc = pcmk__cluster_send_message(node, pcmk_ipc_execd, cmd);
cmd               436 daemons/controld/controld_te_actions.c     pcmk__xml_free(cmd);
cmd               101 daemons/execd/execd_commands.c static void cmd_finalize(lrmd_cmd_t * cmd, lrmd_rsc_t * rsc);
cmd               189 daemons/execd/execd_commands.c cmd_original_times(lrmd_cmd_t * cmd)
cmd               191 daemons/execd/execd_commands.c     cmd->t_run = cmd->t_first_run;
cmd               192 daemons/execd/execd_commands.c     cmd->t_queue = cmd->t_first_queue;
cmd               197 daemons/execd/execd_commands.c action_matches(const lrmd_cmd_t *cmd, const char *action, guint interval_ms)
cmd               199 daemons/execd/execd_commands.c     return (cmd->interval_ms == interval_ms)
cmd               200 daemons/execd/execd_commands.c            && pcmk__str_eq(cmd->action, action, pcmk__str_casei);
cmd               212 daemons/execd/execd_commands.c log_finished(const lrmd_cmd_t *cmd, int exec_time_ms, int queue_time_ms)
cmd               217 daemons/execd/execd_commands.c     if (pcmk__str_eq(cmd->action, PCMK_ACTION_MONITOR, pcmk__str_casei)) {
cmd               222 daemons/execd/execd_commands.c                            cmd->rsc_id, cmd->action, cmd->call_id);
cmd               223 daemons/execd/execd_commands.c     if (cmd->last_pid != 0) {
cmd               224 daemons/execd/execd_commands.c         g_string_append_printf(str, ", PID %d", cmd->last_pid);
cmd               226 daemons/execd/execd_commands.c     switch (cmd->result.execution_status) {
cmd               229 daemons/execd/execd_commands.c                                    cmd->result.exit_status);
cmd               236 daemons/execd/execd_commands.c                            pcmk_exec_status_str(cmd->result.execution_status),
cmd               240 daemons/execd/execd_commands.c     if (cmd->result.exit_reason != NULL) {
cmd               241 daemons/execd/execd_commands.c         pcmk__g_strcat(str, " (", cmd->result.exit_reason, ")", NULL);
cmd               259 daemons/execd/execd_commands.c log_execute(lrmd_cmd_t * cmd)
cmd               263 daemons/execd/execd_commands.c     if (pcmk__str_eq(cmd->action, PCMK_ACTION_MONITOR, pcmk__str_casei)) {
cmd               268 daemons/execd/execd_commands.c                cmd->rsc_id, cmd->action, cmd->call_id);
cmd               311 daemons/execd/execd_commands.c     lrmd_cmd_t *cmd = NULL;
cmd               313 daemons/execd/execd_commands.c     cmd = pcmk__assert_alloc(1, sizeof(lrmd_cmd_t));
cmd               316 daemons/execd/execd_commands.c     cmd->call_opts = call_options;
cmd               317 daemons/execd/execd_commands.c     cmd->client_id = pcmk__str_copy(client->id);
cmd               319 daemons/execd/execd_commands.c     crm_element_value_int(msg, PCMK__XA_LRMD_CALLID, &cmd->call_id);
cmd               321 daemons/execd/execd_commands.c                          &cmd->interval_ms);
cmd               322 daemons/execd/execd_commands.c     crm_element_value_int(rsc_xml, PCMK__XA_LRMD_TIMEOUT, &cmd->timeout);
cmd               324 daemons/execd/execd_commands.c                           &cmd->start_delay);
cmd               325 daemons/execd/execd_commands.c     cmd->timeout_orig = cmd->timeout;
cmd               327 daemons/execd/execd_commands.c     cmd->origin = crm_element_value_copy(rsc_xml, PCMK__XA_LRMD_ORIGIN);
cmd               328 daemons/execd/execd_commands.c     cmd->action = crm_element_value_copy(rsc_xml, PCMK__XA_LRMD_RSC_ACTION);
cmd               329 daemons/execd/execd_commands.c     cmd->userdata_str = crm_element_value_copy(rsc_xml,
cmd               331 daemons/execd/execd_commands.c     cmd->rsc_id = crm_element_value_copy(rsc_xml, PCMK__XA_LRMD_RSC_ID);
cmd               333 daemons/execd/execd_commands.c     cmd->params = xml2list(rsc_xml);
cmd               335 daemons/execd/execd_commands.c     if (pcmk__str_eq(g_hash_table_lookup(cmd->params, "CRM_meta_on_fail"),
cmd               339 daemons/execd/execd_commands.c                   cmd->rsc_id, cmd->action, cmd->interval_ms);
cmd               340 daemons/execd/execd_commands.c         cmd->service_flags = pcmk__set_flags_as(__func__, __LINE__,
cmd               342 daemons/execd/execd_commands.c                                                 cmd->action, 0,
cmd               346 daemons/execd/execd_commands.c     return cmd;
cmd               350 daemons/execd/execd_commands.c stop_recurring_timer(lrmd_cmd_t *cmd)
cmd               352 daemons/execd/execd_commands.c     if (cmd) {
cmd               353 daemons/execd/execd_commands.c         if (cmd->stonith_recurring_id) {
cmd               354 daemons/execd/execd_commands.c             g_source_remove(cmd->stonith_recurring_id);
cmd               356 daemons/execd/execd_commands.c         cmd->stonith_recurring_id = 0;
cmd               361 daemons/execd/execd_commands.c free_lrmd_cmd(lrmd_cmd_t * cmd)
cmd               363 daemons/execd/execd_commands.c     stop_recurring_timer(cmd);
cmd               364 daemons/execd/execd_commands.c     if (cmd->delay_id) {
cmd               365 daemons/execd/execd_commands.c         g_source_remove(cmd->delay_id);
cmd               367 daemons/execd/execd_commands.c     if (cmd->params) {
cmd               368 daemons/execd/execd_commands.c         g_hash_table_destroy(cmd->params);
cmd               370 daemons/execd/execd_commands.c     pcmk__reset_result(&(cmd->result));
cmd               371 daemons/execd/execd_commands.c     free(cmd->origin);
cmd               372 daemons/execd/execd_commands.c     free(cmd->action);
cmd               373 daemons/execd/execd_commands.c     free(cmd->real_action);
cmd               374 daemons/execd/execd_commands.c     free(cmd->userdata_str);
cmd               375 daemons/execd/execd_commands.c     free(cmd->rsc_id);
cmd               376 daemons/execd/execd_commands.c     free(cmd->client_id);
cmd               377 daemons/execd/execd_commands.c     free(cmd);
cmd               383 daemons/execd/execd_commands.c     lrmd_cmd_t *cmd = data;
cmd               386 daemons/execd/execd_commands.c     cmd->stonith_recurring_id = 0;
cmd               388 daemons/execd/execd_commands.c     if (!cmd->rsc_id) {
cmd               392 daemons/execd/execd_commands.c     rsc = g_hash_table_lookup(rsc_list, cmd->rsc_id);
cmd               397 daemons/execd/execd_commands.c     rsc->recurring_ops = g_list_remove(rsc->recurring_ops, cmd);
cmd               398 daemons/execd/execd_commands.c     rsc->pending_ops = g_list_append(rsc->pending_ops, cmd);
cmd               400 daemons/execd/execd_commands.c     get_current_time(&(cmd->t_queue), &(cmd->t_first_queue));
cmd               408 daemons/execd/execd_commands.c start_recurring_timer(lrmd_cmd_t *cmd)
cmd               410 daemons/execd/execd_commands.c     if (!cmd || (cmd->interval_ms <= 0)) {
cmd               414 daemons/execd/execd_commands.c     cmd->stonith_recurring_id = pcmk__create_timer(cmd->interval_ms,
cmd               416 daemons/execd/execd_commands.c                                                    cmd);
cmd               422 daemons/execd/execd_commands.c     lrmd_cmd_t *cmd = data;
cmd               425 daemons/execd/execd_commands.c     cmd->delay_id = 0;
cmd               426 daemons/execd/execd_commands.c     rsc = cmd->rsc_id ? g_hash_table_lookup(rsc_list, cmd->rsc_id) : NULL;
cmd               443 daemons/execd/execd_commands.c find_duplicate_action(const GList *action_list, const lrmd_cmd_t *cmd)
cmd               448 daemons/execd/execd_commands.c         if (action_matches(cmd, dup->action, dup->interval_ms)) {
cmd               456 daemons/execd/execd_commands.c merge_recurring_duplicate(lrmd_rsc_t * rsc, lrmd_cmd_t * cmd)
cmd               461 daemons/execd/execd_commands.c     if (cmd->interval_ms == 0) {
cmd               466 daemons/execd/execd_commands.c     dup = find_duplicate_action(rsc->pending_ops, cmd);
cmd               469 daemons/execd/execd_commands.c         dup = find_duplicate_action(rsc->recurring_ops, cmd);
cmd               495 daemons/execd/execd_commands.c     dup->userdata_str = cmd->userdata_str;
cmd               496 daemons/execd/execd_commands.c     cmd->userdata_str = NULL;
cmd               497 daemons/execd/execd_commands.c     dup->call_id = cmd->call_id;
cmd               498 daemons/execd/execd_commands.c     free_lrmd_cmd(cmd);
cmd               499 daemons/execd/execd_commands.c     cmd = NULL;
cmd               520 daemons/execd/execd_commands.c schedule_lrmd_cmd(lrmd_rsc_t * rsc, lrmd_cmd_t * cmd)
cmd               522 daemons/execd/execd_commands.c     CRM_CHECK(cmd != NULL, return);
cmd               525 daemons/execd/execd_commands.c     crm_trace("Scheduling %s on %s", cmd->action, rsc->rsc_id);
cmd               527 daemons/execd/execd_commands.c     if (merge_recurring_duplicate(rsc, cmd)) {
cmd               535 daemons/execd/execd_commands.c     if (pcmk__str_eq(cmd->action, PCMK_ACTION_STOP, pcmk__str_casei)) {
cmd               539 daemons/execd/execd_commands.c     rsc->pending_ops = g_list_append(rsc->pending_ops, cmd);
cmd               541 daemons/execd/execd_commands.c     get_current_time(&(cmd->t_queue), &(cmd->t_first_queue));
cmd               545 daemons/execd/execd_commands.c     if (cmd->start_delay) {
cmd               546 daemons/execd/execd_commands.c         cmd->delay_id = pcmk__create_timer(cmd->start_delay, start_delay_helper, cmd);
cmd               606 daemons/execd/execd_commands.c send_cmd_complete_notify(lrmd_cmd_t * cmd)
cmd               613 daemons/execd/execd_commands.c     exec_time = time_diff_ms(NULL, &(cmd->t_run));
cmd               614 daemons/execd/execd_commands.c     queue_time = time_diff_ms(&cmd->t_run, &(cmd->t_queue));
cmd               616 daemons/execd/execd_commands.c     log_finished(cmd, exec_time, queue_time);
cmd               621 daemons/execd/execd_commands.c     if (cmd->first_notify_sent
cmd               622 daemons/execd/execd_commands.c         && pcmk_is_set(cmd->call_opts, lrmd_opt_notify_changes_only)
cmd               623 daemons/execd/execd_commands.c         && (cmd->last_notify_rc == cmd->result.exit_status)
cmd               624 daemons/execd/execd_commands.c         && (cmd->last_notify_op_status == cmd->result.execution_status)) {
cmd               628 daemons/execd/execd_commands.c     cmd->first_notify_sent = true;
cmd               629 daemons/execd/execd_commands.c     cmd->last_notify_rc = cmd->result.exit_status;
cmd               630 daemons/execd/execd_commands.c     cmd->last_notify_op_status = cmd->result.execution_status;
cmd               635 daemons/execd/execd_commands.c     crm_xml_add_int(notify, PCMK__XA_LRMD_TIMEOUT, cmd->timeout);
cmd               636 daemons/execd/execd_commands.c     crm_xml_add_ms(notify, PCMK__XA_LRMD_RSC_INTERVAL, cmd->interval_ms);
cmd               637 daemons/execd/execd_commands.c     crm_xml_add_int(notify, PCMK__XA_LRMD_RSC_START_DELAY, cmd->start_delay);
cmd               638 daemons/execd/execd_commands.c     crm_xml_add_int(notify, PCMK__XA_LRMD_EXEC_RC, cmd->result.exit_status);
cmd               640 daemons/execd/execd_commands.c                     cmd->result.execution_status);
cmd               641 daemons/execd/execd_commands.c     crm_xml_add_int(notify, PCMK__XA_LRMD_CALLID, cmd->call_id);
cmd               642 daemons/execd/execd_commands.c     crm_xml_add_int(notify, PCMK__XA_LRMD_RSC_DELETED, cmd->rsc_deleted);
cmd               645 daemons/execd/execd_commands.c                    (long long) cmd->epoch_last_run);
cmd               647 daemons/execd/execd_commands.c                    (long long) cmd->epoch_rcchange);
cmd               654 daemons/execd/execd_commands.c     crm_xml_add(notify, PCMK__XA_LRMD_RSC_ID, cmd->rsc_id);
cmd               655 daemons/execd/execd_commands.c     if(cmd->real_action) {
cmd               656 daemons/execd/execd_commands.c         crm_xml_add(notify, PCMK__XA_LRMD_RSC_ACTION, cmd->real_action);
cmd               658 daemons/execd/execd_commands.c         crm_xml_add(notify, PCMK__XA_LRMD_RSC_ACTION, cmd->action);
cmd               660 daemons/execd/execd_commands.c     crm_xml_add(notify, PCMK__XA_LRMD_RSC_USERDATA_STR, cmd->userdata_str);
cmd               661 daemons/execd/execd_commands.c     crm_xml_add(notify, PCMK__XA_LRMD_RSC_EXIT_REASON, cmd->result.exit_reason);
cmd               663 daemons/execd/execd_commands.c     if (cmd->result.action_stderr != NULL) {
cmd               665 daemons/execd/execd_commands.c                     cmd->result.action_stderr);
cmd               667 daemons/execd/execd_commands.c     } else if (cmd->result.action_stdout != NULL) {
cmd               669 daemons/execd/execd_commands.c                     cmd->result.action_stdout);
cmd               672 daemons/execd/execd_commands.c     if (cmd->params) {
cmd               679 daemons/execd/execd_commands.c         g_hash_table_iter_init(&iter, cmd->params);
cmd               684 daemons/execd/execd_commands.c     if ((cmd->client_id != NULL)
cmd               685 daemons/execd/execd_commands.c         && pcmk_is_set(cmd->call_opts, lrmd_opt_notify_orig_only)) {
cmd               687 daemons/execd/execd_commands.c         pcmk__client_t *client = pcmk__find_client_by_id(cmd->client_id);
cmd               727 daemons/execd/execd_commands.c cmd_reset(lrmd_cmd_t * cmd)
cmd               729 daemons/execd/execd_commands.c     cmd->last_pid = 0;
cmd               731 daemons/execd/execd_commands.c     memset(&cmd->t_run, 0, sizeof(cmd->t_run));
cmd               732 daemons/execd/execd_commands.c     memset(&cmd->t_queue, 0, sizeof(cmd->t_queue));
cmd               734 daemons/execd/execd_commands.c     cmd->epoch_last_run = 0;
cmd               736 daemons/execd/execd_commands.c     pcmk__reset_result(&(cmd->result));
cmd               737 daemons/execd/execd_commands.c     cmd->result.execution_status = PCMK_EXEC_DONE;
cmd               741 daemons/execd/execd_commands.c cmd_finalize(lrmd_cmd_t * cmd, lrmd_rsc_t * rsc)
cmd               743 daemons/execd/execd_commands.c     crm_trace("Resource operation rsc:%s action:%s completed (%p %p)", cmd->rsc_id, cmd->action,
cmd               744 daemons/execd/execd_commands.c               rsc ? rsc->active : NULL, cmd);
cmd               746 daemons/execd/execd_commands.c     if (rsc && (rsc->active == cmd)) {
cmd               752 daemons/execd/execd_commands.c         cmd->rsc_deleted = 1;
cmd               756 daemons/execd/execd_commands.c     cmd->timeout = cmd->timeout_orig;
cmd               758 daemons/execd/execd_commands.c     send_cmd_complete_notify(cmd);
cmd               760 daemons/execd/execd_commands.c     if ((cmd->interval_ms != 0)
cmd               761 daemons/execd/execd_commands.c         && (cmd->result.execution_status == PCMK_EXEC_CANCELLED)) {
cmd               764 daemons/execd/execd_commands.c             rsc->recurring_ops = g_list_remove(rsc->recurring_ops, cmd);
cmd               765 daemons/execd/execd_commands.c             rsc->pending_ops = g_list_remove(rsc->pending_ops, cmd);
cmd               767 daemons/execd/execd_commands.c         free_lrmd_cmd(cmd);
cmd               768 daemons/execd/execd_commands.c     } else if (cmd->interval_ms == 0) {
cmd               770 daemons/execd/execd_commands.c             rsc->pending_ops = g_list_remove(rsc->pending_ops, cmd);
cmd               772 daemons/execd/execd_commands.c         free_lrmd_cmd(cmd);
cmd               775 daemons/execd/execd_commands.c         cmd_reset(cmd);
cmd               829 daemons/execd/execd_commands.c     lrmd_cmd_t *cmd = action->cb_data;
cmd               840 daemons/execd/execd_commands.c     if (!cmd) {
cmd               847 daemons/execd/execd_commands.c     if (cmd->result.exit_status != action->rc) {
cmd               848 daemons/execd/execd_commands.c         cmd->epoch_rcchange = time(NULL);
cmd               852 daemons/execd/execd_commands.c     cmd->last_pid = action->pid;
cmd               855 daemons/execd/execd_commands.c     code = services_result2ocf(action->standard, cmd->action, action->rc);
cmd               856 daemons/execd/execd_commands.c     pcmk__set_result(&(cmd->result), (int) code,
cmd               859 daemons/execd/execd_commands.c     rsc = cmd->rsc_id ? g_hash_table_lookup(rsc_list, cmd->rsc_id) : NULL;
cmd               876 daemons/execd/execd_commands.c     if (pcmk__result_ok(&(cmd->result))
cmd               877 daemons/execd/execd_commands.c         && pcmk__strcase_any_of(cmd->action, PCMK_ACTION_START,
cmd               887 daemons/execd/execd_commands.c         services__copy_result(action, &(cmd->result));
cmd               890 daemons/execd/execd_commands.c     } else if (cmd->result.execution_status == PCMK_EXEC_PENDING &&
cmd               891 daemons/execd/execd_commands.c                pcmk__str_any_of(cmd->action, PCMK_ACTION_MONITOR, PCMK_ACTION_STATUS, NULL) &&
cmd               892 daemons/execd/execd_commands.c                cmd->interval_ms == 0 &&
cmd               893 daemons/execd/execd_commands.c                cmd->real_action == NULL) {
cmd               896 daemons/execd/execd_commands.c         cmd->real_action = cmd->action;
cmd               897 daemons/execd/execd_commands.c         cmd->action = pcmk__str_copy(PCMK_ACTION_MONITOR);
cmd               898 daemons/execd/execd_commands.c     } else if (cmd->real_action != NULL) {
cmd               900 daemons/execd/execd_commands.c         if (cmd->result.execution_status == PCMK_EXEC_PENDING) {
cmd               903 daemons/execd/execd_commands.c         } else if (pcmk__result_ok(&(cmd->result))
cmd               904 daemons/execd/execd_commands.c                    && pcmk__str_eq(cmd->real_action, PCMK_ACTION_STOP,
cmd               909 daemons/execd/execd_commands.c             int time_sum = time_diff_ms(NULL, &(cmd->t_first_run));
cmd               910 daemons/execd/execd_commands.c             int timeout_left = cmd->timeout_orig - time_sum;
cmd               914 daemons/execd/execd_commands.c                       cmd->rsc_id, cmd->real_action, time_sum, timeout_left,
cmd               915 daemons/execd/execd_commands.c                       crm_exit_str(cmd->result.exit_status),
cmd               916 daemons/execd/execd_commands.c                       cmd->result.exit_status);
cmd               917 daemons/execd/execd_commands.c             cmd_original_times(cmd);
cmd               920 daemons/execd/execd_commands.c             if ((cmd->result.execution_status == PCMK_EXEC_DONE)
cmd               921 daemons/execd/execd_commands.c                 && (cmd->result.exit_status == PCMK_OCF_NOT_RUNNING)) {
cmd               923 daemons/execd/execd_commands.c                 if (pcmk__str_eq(cmd->real_action, PCMK_ACTION_START,
cmd               925 daemons/execd/execd_commands.c                     cmd->result.exit_status = PCMK_OCF_UNKNOWN_ERROR;
cmd               926 daemons/execd/execd_commands.c                 } else if (pcmk__str_eq(cmd->real_action, PCMK_ACTION_STOP,
cmd               928 daemons/execd/execd_commands.c                     cmd->result.exit_status = PCMK_OCF_OK;
cmd               932 daemons/execd/execd_commands.c     } else if (pcmk__str_any_of(cmd->action, PCMK_ACTION_MONITOR, PCMK_ACTION_STATUS, NULL)
cmd               933 daemons/execd/execd_commands.c                && (cmd->interval_ms > 0)) {
cmd               938 daemons/execd/execd_commands.c         if ((cmd->result.execution_status == PCMK_EXEC_PENDING) &&
cmd               939 daemons/execd/execd_commands.c             (cmd->last_notify_op_status == PCMK_EXEC_PENDING)) {
cmd               940 daemons/execd/execd_commands.c             int time_left = time(NULL) - (cmd->epoch_rcchange + (cmd->timeout_orig/1000));
cmd               945 daemons/execd/execd_commands.c                            cmd->rsc_id, cmd->action, cmd->result.exit_status,
cmd               946 daemons/execd/execd_commands.c                            pcmk__trim(ctime(&cmd->epoch_rcchange)), cmd->timeout_orig);
cmd               947 daemons/execd/execd_commands.c                 pcmk__set_result(&(cmd->result), PCMK_OCF_UNKNOWN_ERROR,
cmd               951 daemons/execd/execd_commands.c                 cmd_original_times(cmd);
cmd               960 daemons/execd/execd_commands.c     time_sum = time_diff_ms(NULL, &(cmd->t_first_run));
cmd               961 daemons/execd/execd_commands.c     timeout_left = cmd->timeout_orig - time_sum;
cmd               962 daemons/execd/execd_commands.c     delay = cmd->timeout_orig / 10;
cmd               970 daemons/execd/execd_commands.c         cmd->start_delay = delay;
cmd               971 daemons/execd/execd_commands.c         cmd->timeout = timeout_left;
cmd               973 daemons/execd/execd_commands.c         if (pcmk__result_ok(&(cmd->result))) {
cmd               975 daemons/execd/execd_commands.c                       cmd->rsc_id, cmd->real_action, time_sum, timeout_left, delay);
cmd               977 daemons/execd/execd_commands.c         } else if (cmd->result.execution_status == PCMK_EXEC_PENDING) {
cmd               979 daemons/execd/execd_commands.c                      cmd->rsc_id, cmd->action, time_sum, timeout_left, delay);
cmd               985 daemons/execd/execd_commands.c                        cmd->rsc_id, cmd->action,
cmd               986 daemons/execd/execd_commands.c                        crm_exit_str(cmd->result.exit_status),
cmd               988 daemons/execd/execd_commands.c                        cmd->result.exit_status, time_sum, delay);
cmd               991 daemons/execd/execd_commands.c         cmd_reset(cmd);
cmd               995 daemons/execd/execd_commands.c         schedule_lrmd_cmd(rsc, cmd);
cmd              1002 daemons/execd/execd_commands.c                    cmd->rsc_id,
cmd              1003 daemons/execd/execd_commands.c                    (cmd->real_action? cmd->real_action : cmd->action),
cmd              1004 daemons/execd/execd_commands.c                    cmd->result.exit_status, time_sum, timeout_left);
cmd              1005 daemons/execd/execd_commands.c         pcmk__set_result(&(cmd->result), PCMK_OCF_UNKNOWN_ERROR,
cmd              1009 daemons/execd/execd_commands.c         cmd_original_times(cmd);
cmd              1014 daemons/execd/execd_commands.c     pcmk__set_result_output(&(cmd->result), services__grab_stdout(action),
cmd              1016 daemons/execd/execd_commands.c     cmd_finalize(cmd, rsc);
cmd              1029 daemons/execd/execd_commands.c stonith_action_complete(lrmd_cmd_t *cmd, int exit_status,
cmd              1034 daemons/execd/execd_commands.c     lrmd_rsc_t *rsc = g_hash_table_lookup(rsc_list, cmd->rsc_id);
cmd              1041 daemons/execd/execd_commands.c     if (cmd->result.execution_status == PCMK_EXEC_CANCELLED) {
cmd              1062 daemons/execd/execd_commands.c                 if (pcmk__str_eq(cmd->action, PCMK_ACTION_MONITOR,
cmd              1066 daemons/execd/execd_commands.c                 } else if (pcmk__str_eq(cmd->action, PCMK_ACTION_STOP,
cmd              1085 daemons/execd/execd_commands.c     pcmk__set_result(&cmd->result, exit_status, execution_status, exit_reason);
cmd              1088 daemons/execd/execd_commands.c     if ((rsc != NULL) && pcmk__result_ok(&(cmd->result))) {
cmd              1090 daemons/execd/execd_commands.c         if (pcmk__str_eq(cmd->action, PCMK_ACTION_START, pcmk__str_casei)) {
cmd              1094 daemons/execd/execd_commands.c         } else if (pcmk__str_eq(cmd->action, PCMK_ACTION_STOP,
cmd              1104 daemons/execd/execd_commands.c     stop_recurring_timer(cmd);
cmd              1110 daemons/execd/execd_commands.c     if (rsc && (cmd->interval_ms > 0)
cmd              1111 daemons/execd/execd_commands.c         && (cmd->result.execution_status != PCMK_EXEC_CANCELLED)) {
cmd              1112 daemons/execd/execd_commands.c         start_recurring_timer(cmd);
cmd              1115 daemons/execd/execd_commands.c     cmd_finalize(cmd, rsc);
cmd              1164 daemons/execd/execd_commands.c             lrmd_cmd_t *cmd = op->data;
cmd              1170 daemons/execd/execd_commands.c             stonith_action_complete(cmd,
cmd              1202 daemons/execd/execd_commands.c                     const lrmd_cmd_t *cmd)
cmd              1210 daemons/execd/execd_commands.c     if (cmd->params) {
cmd              1213 daemons/execd/execd_commands.c         g_hash_table_iter_init(&iter, cmd->params);
cmd              1226 daemons/execd/execd_commands.c                                             cmd->rsc_id, rsc->provider,
cmd              1266 daemons/execd/execd_commands.c execd_stonith_monitor(stonith_t *stonith_api, lrmd_rsc_t *rsc, lrmd_cmd_t *cmd)
cmd              1268 daemons/execd/execd_commands.c     int rc = stonith_api->cmds->monitor(stonith_api, 0, cmd->rsc_id,
cmd              1269 daemons/execd/execd_commands.c                                         pcmk__timeout_ms2s(cmd->timeout));
cmd              1271 daemons/execd/execd_commands.c     rc = stonith_api->cmds->register_callback(stonith_api, rc, 0, 0, cmd,
cmd              1275 daemons/execd/execd_commands.c         rsc->active = cmd;
cmd              1284 daemons/execd/execd_commands.c execute_stonith_action(lrmd_rsc_t *rsc, lrmd_cmd_t *cmd)
cmd              1293 daemons/execd/execd_commands.c     if (pcmk__str_eq(cmd->action, PCMK_ACTION_MONITOR, pcmk__str_casei)
cmd              1294 daemons/execd/execd_commands.c         && (cmd->interval_ms == 0)) {
cmd              1296 daemons/execd/execd_commands.c         stonith_action_complete(cmd, rsc->fence_probe_result.exit_status,
cmd              1303 daemons/execd/execd_commands.c         stonith_action_complete(cmd, PCMK_OCF_UNKNOWN_ERROR,
cmd              1309 daemons/execd/execd_commands.c     if (pcmk__str_eq(cmd->action, PCMK_ACTION_START, pcmk__str_casei)) {
cmd              1310 daemons/execd/execd_commands.c         rc = execd_stonith_start(stonith_api, rsc, cmd);
cmd              1315 daemons/execd/execd_commands.c     } else if (pcmk__str_eq(cmd->action, PCMK_ACTION_STOP, pcmk__str_casei)) {
cmd              1318 daemons/execd/execd_commands.c     } else if (pcmk__str_eq(cmd->action, PCMK_ACTION_MONITOR,
cmd              1323 daemons/execd/execd_commands.c         stonith_action_complete(cmd, PCMK_OCF_UNIMPLEMENT_FEATURE,
cmd              1330 daemons/execd/execd_commands.c         rc = execd_stonith_monitor(stonith_api, rsc, cmd);
cmd              1340 daemons/execd/execd_commands.c     stonith_action_complete(cmd,
cmd              1346 daemons/execd/execd_commands.c execute_nonstonith_action(lrmd_rsc_t *rsc, lrmd_cmd_t *cmd)
cmd              1351 daemons/execd/execd_commands.c     pcmk__assert((rsc != NULL) && (cmd != NULL));
cmd              1354 daemons/execd/execd_commands.c               rsc->rsc_id, cmd->action, rsc->class, rsc->provider, rsc->type);
cmd              1356 daemons/execd/execd_commands.c     params_copy = pcmk__str_table_dup(cmd->params);
cmd              1360 daemons/execd/execd_commands.c                                      normalize_action_name(rsc, cmd->action),
cmd              1361 daemons/execd/execd_commands.c                                      cmd->interval_ms, cmd->timeout,
cmd              1362 daemons/execd/execd_commands.c                                      params_copy, cmd->service_flags);
cmd              1365 daemons/execd/execd_commands.c         pcmk__set_result(&(cmd->result), PCMK_OCF_UNKNOWN_ERROR,
cmd              1367 daemons/execd/execd_commands.c         cmd_finalize(cmd, rsc);
cmd              1372 daemons/execd/execd_commands.c         services__copy_result(action, &(cmd->result));
cmd              1374 daemons/execd/execd_commands.c         cmd_finalize(cmd, rsc);
cmd              1378 daemons/execd/execd_commands.c     action->cb_data = cmd;
cmd              1397 daemons/execd/execd_commands.c         services__copy_result(action, &(cmd->result));
cmd              1406 daemons/execd/execd_commands.c     lrmd_cmd_t *cmd = NULL;
cmd              1418 daemons/execd/execd_commands.c         cmd = first->data;
cmd              1419 daemons/execd/execd_commands.c         if (cmd->delay_id) {
cmd              1422 daemons/execd/execd_commands.c                  cmd->rsc_id, cmd->action, cmd->start_delay);
cmd              1429 daemons/execd/execd_commands.c         get_current_time(&(cmd->t_run), &(cmd->t_first_run));
cmd              1431 daemons/execd/execd_commands.c         cmd->epoch_last_run = time(NULL);
cmd              1434 daemons/execd/execd_commands.c     if (!cmd) {
cmd              1439 daemons/execd/execd_commands.c     rsc->active = cmd;          /* only one op at a time for a rsc */
cmd              1440 daemons/execd/execd_commands.c     if (cmd->interval_ms) {
cmd              1441 daemons/execd/execd_commands.c         rsc->recurring_ops = g_list_append(rsc->recurring_ops, cmd);
cmd              1444 daemons/execd/execd_commands.c     log_execute(cmd);
cmd              1447 daemons/execd/execd_commands.c         execute_stonith_action(rsc, cmd);
cmd              1449 daemons/execd/execd_commands.c         execute_nonstonith_action(rsc, cmd);
cmd              1466 daemons/execd/execd_commands.c         lrmd_cmd_t *cmd = gIter->data;
cmd              1469 daemons/execd/execd_commands.c         cmd->result.execution_status = PCMK_EXEC_CANCELLED;
cmd              1470 daemons/execd/execd_commands.c         cmd_finalize(cmd, NULL);
cmd              1480 daemons/execd/execd_commands.c         lrmd_cmd_t *cmd = gIter->data;
cmd              1483 daemons/execd/execd_commands.c             cmd->result.execution_status = PCMK_EXEC_CANCELLED;
cmd              1488 daemons/execd/execd_commands.c             if (rsc->active != cmd) {
cmd              1489 daemons/execd/execd_commands.c                 cmd_finalize(cmd, NULL);
cmd              1497 daemons/execd/execd_commands.c                                    normalize_action_name(rsc, cmd->action),
cmd              1498 daemons/execd/execd_commands.c                                    cmd->interval_ms);
cmd              1668 daemons/execd/execd_commands.c     lrmd_cmd_t *cmd = NULL;
cmd              1684 daemons/execd/execd_commands.c     cmd = create_lrmd_cmd(request, client);
cmd              1685 daemons/execd/execd_commands.c     call_id = cmd->call_id;
cmd              1689 daemons/execd/execd_commands.c     schedule_lrmd_cmd(rsc, cmd);
cmd              1716 daemons/execd/execd_commands.c         lrmd_cmd_t *cmd = gIter->data;
cmd              1718 daemons/execd/execd_commands.c         if (action_matches(cmd, action, interval_ms)) {
cmd              1719 daemons/execd/execd_commands.c             cmd->result.execution_status = PCMK_EXEC_CANCELLED;
cmd              1720 daemons/execd/execd_commands.c             cmd_finalize(cmd, rsc);
cmd              1729 daemons/execd/execd_commands.c             lrmd_cmd_t *cmd = gIter->data;
cmd              1731 daemons/execd/execd_commands.c             if (action_matches(cmd, action, interval_ms)) {
cmd              1732 daemons/execd/execd_commands.c                 cmd->result.execution_status = PCMK_EXEC_CANCELLED;
cmd              1733 daemons/execd/execd_commands.c                 if (rsc->active != cmd) {
cmd              1734 daemons/execd/execd_commands.c                     cmd_finalize(cmd, rsc);
cmd              1775 daemons/execd/execd_commands.c         lrmd_cmd_t *cmd = cmd_iter->data;
cmd              1777 daemons/execd/execd_commands.c         if (cmd->interval_ms == 0) {
cmd              1781 daemons/execd/execd_commands.c         if (client_id && !pcmk__str_eq(cmd->client_id, client_id, pcmk__str_casei)) {
cmd              1785 daemons/execd/execd_commands.c         cancel_op(rsc->rsc_id, cmd->action, cmd->interval_ms);
cmd              1817 daemons/execd/execd_commands.c         lrmd_cmd_t *cmd = item->data;
cmd              1821 daemons/execd/execd_commands.c                     pcmk__s(cmd->real_action, cmd->action));
cmd              1822 daemons/execd/execd_commands.c         crm_xml_add_ms(op_xml, PCMK__XA_LRMD_RSC_INTERVAL, cmd->interval_ms);
cmd              1823 daemons/execd/execd_commands.c         crm_xml_add_int(op_xml, PCMK__XA_LRMD_TIMEOUT, cmd->timeout_orig);
cmd               149 daemons/fenced/cts-fence-helper.c #define single_test(cmd, str, num_notifications, expected_rc) \
cmd               152 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               308 daemons/fenced/fenced_commands.c cmd_device(const async_command_t *cmd)
cmd               310 daemons/fenced/fenced_commands.c     if ((cmd == NULL) || (cmd->device == NULL) || (device_table == NULL)) {
cmd               313 daemons/fenced/fenced_commands.c     return g_hash_table_lookup(device_table, cmd->device);
cmd               361 daemons/fenced/fenced_commands.c free_async_command(async_command_t * cmd)
cmd               363 daemons/fenced/fenced_commands.c     if (!cmd) {
cmd               367 daemons/fenced/fenced_commands.c     if (cmd->delay_id) {
cmd               368 daemons/fenced/fenced_commands.c         g_source_remove(cmd->delay_id);
cmd               371 daemons/fenced/fenced_commands.c     cmd_list = g_list_remove(cmd_list, cmd);
cmd               373 daemons/fenced/fenced_commands.c     g_list_free_full(cmd->device_list, free);
cmd               374 daemons/fenced/fenced_commands.c     free(cmd->device);
cmd               375 daemons/fenced/fenced_commands.c     free(cmd->action);
cmd               376 daemons/fenced/fenced_commands.c     free(cmd->target);
cmd               377 daemons/fenced/fenced_commands.c     free(cmd->remote_op_id);
cmd               378 daemons/fenced/fenced_commands.c     free(cmd->client);
cmd               379 daemons/fenced/fenced_commands.c     free(cmd->client_name);
cmd               380 daemons/fenced/fenced_commands.c     free(cmd->origin);
cmd               381 daemons/fenced/fenced_commands.c     free(cmd->op);
cmd               382 daemons/fenced/fenced_commands.c     free(cmd);
cmd               400 daemons/fenced/fenced_commands.c     async_command_t *cmd = NULL;
cmd               413 daemons/fenced/fenced_commands.c     cmd = pcmk__assert_alloc(1, sizeof(async_command_t));
cmd               416 daemons/fenced/fenced_commands.c     cmd->action = crm_element_value_copy(op, PCMK__XA_ST_DEVICE_ACTION);
cmd               417 daemons/fenced/fenced_commands.c     cmd->op = crm_element_value_copy(msg, PCMK__XA_ST_OP);
cmd               418 daemons/fenced/fenced_commands.c     cmd->client = crm_element_value_copy(msg, PCMK__XA_ST_CLIENTID);
cmd               419 daemons/fenced/fenced_commands.c     if ((cmd->action == NULL) || (cmd->op == NULL) || (cmd->client == NULL)) {
cmd               420 daemons/fenced/fenced_commands.c         free_async_command(cmd);
cmd               424 daemons/fenced/fenced_commands.c     crm_element_value_int(msg, PCMK__XA_ST_CALLID, &(cmd->id));
cmd               425 daemons/fenced/fenced_commands.c     crm_element_value_int(msg, PCMK__XA_ST_DELAY, &(cmd->start_delay));
cmd               426 daemons/fenced/fenced_commands.c     crm_element_value_int(msg, PCMK__XA_ST_TIMEOUT, &(cmd->default_timeout));
cmd               427 daemons/fenced/fenced_commands.c     cmd->timeout = cmd->default_timeout;
cmd               429 daemons/fenced/fenced_commands.c     rc = pcmk__xe_get_flags(msg, PCMK__XA_ST_CALLOPT, &(cmd->options),
cmd               435 daemons/fenced/fenced_commands.c     cmd->origin = crm_element_value_copy(msg, PCMK__XA_SRC);
cmd               436 daemons/fenced/fenced_commands.c     cmd->remote_op_id = crm_element_value_copy(msg, PCMK__XA_ST_REMOTE_OP);
cmd               437 daemons/fenced/fenced_commands.c     cmd->client_name = crm_element_value_copy(msg, PCMK__XA_ST_CLIENTNAME);
cmd               438 daemons/fenced/fenced_commands.c     cmd->target = crm_element_value_copy(op, PCMK__XA_ST_TARGET);
cmd               439 daemons/fenced/fenced_commands.c     cmd->device = crm_element_value_copy(op, PCMK__XA_ST_DEVICE_ID);
cmd               441 daemons/fenced/fenced_commands.c     cmd->done_cb = st_child_done;
cmd               444 daemons/fenced/fenced_commands.c     cmd_list = g_list_append(cmd_list, cmd);
cmd               446 daemons/fenced/fenced_commands.c     return cmd;
cmd               474 daemons/fenced/fenced_commands.c         async_command_t *cmd = gIter->data;
cmd               478 daemons/fenced/fenced_commands.c         if (cmd->active_on == device) {
cmd               489 daemons/fenced/fenced_commands.c     async_command_t *cmd = (async_command_t *) user_data;
cmd               490 daemons/fenced/fenced_commands.c     fenced_device_t *device = cmd->activating_on;
cmd               496 daemons/fenced/fenced_commands.c         device = cmd->active_on;
cmd               501 daemons/fenced/fenced_commands.c               cmd->action, pid,
cmd               502 daemons/fenced/fenced_commands.c               ((cmd->target == NULL)? "" : " targeting "),
cmd               503 daemons/fenced/fenced_commands.c               pcmk__s(cmd->target, ""), device->id, cmd->timeout);
cmd               504 daemons/fenced/fenced_commands.c     cmd->active_on = device;
cmd               505 daemons/fenced/fenced_commands.c     cmd->activating_on = NULL;
cmd               544 daemons/fenced/fenced_commands.c report_internal_result(async_command_t *cmd, int exit_status,
cmd               550 daemons/fenced/fenced_commands.c     cmd->done_cb(0, &result, cmd);
cmd               559 daemons/fenced/fenced_commands.c     async_command_t *cmd = NULL;
cmd               595 daemons/fenced/fenced_commands.c         cmd = pending_op;
cmd               599 daemons/fenced/fenced_commands.c     if (cmd == NULL) {
cmd               606 daemons/fenced/fenced_commands.c         if (pcmk__is_fencing_action(cmd->action)) {
cmd               612 daemons/fenced/fenced_commands.c             crm_info("Faking success for %s watchdog operation", cmd->action);
cmd               613 daemons/fenced/fenced_commands.c             report_internal_result(cmd, CRM_EX_OK, PCMK_EXEC_DONE, NULL);
cmd               621 daemons/fenced/fenced_commands.c         if (pcmk__str_eq(cmd->action, PCMK_ACTION_STOP, pcmk__str_none)) {
cmd               629 daemons/fenced/fenced_commands.c             report_internal_result(cmd, CRM_EX_ERROR, PCMK_EXEC_NO_SECRETS,
cmd               636 daemons/fenced/fenced_commands.c     action_str = cmd->action;
cmd               637 daemons/fenced/fenced_commands.c     if (pcmk__str_eq(cmd->action, PCMK_ACTION_REBOOT, pcmk__str_none)
cmd               642 daemons/fenced/fenced_commands.c                    ((cmd->target == NULL)? "" : " targeting "),
cmd               643 daemons/fenced/fenced_commands.c                    pcmk__s(cmd->target, ""), device->id, device->agent);
cmd               647 daemons/fenced/fenced_commands.c     action = stonith__action_create(device->agent, action_str, cmd->target,
cmd               648 daemons/fenced/fenced_commands.c                                     cmd->timeout, device->params,
cmd               653 daemons/fenced/fenced_commands.c     cmd->activating_on = device;
cmd               654 daemons/fenced/fenced_commands.c     exec_rc = stonith__execute_async(action, (void *)cmd, cmd->done_cb,
cmd               657 daemons/fenced/fenced_commands.c         cmd->activating_on = NULL;
cmd               658 daemons/fenced/fenced_commands.c         cmd->done_cb(0, stonith__action_result(action), cmd);
cmd               681 daemons/fenced/fenced_commands.c     async_command_t *cmd = data;
cmd               682 daemons/fenced/fenced_commands.c     fenced_device_t *device = cmd_device(cmd);
cmd               684 daemons/fenced/fenced_commands.c     cmd->delay_id = 0;
cmd               693 daemons/fenced/fenced_commands.c schedule_stonith_command(async_command_t *cmd, fenced_device_t *device)
cmd               697 daemons/fenced/fenced_commands.c     int requested_delay = cmd->start_delay;
cmd               699 daemons/fenced/fenced_commands.c     CRM_CHECK(cmd != NULL, return);
cmd               702 daemons/fenced/fenced_commands.c     if (cmd->device) {
cmd               703 daemons/fenced/fenced_commands.c         free(cmd->device);
cmd               706 daemons/fenced/fenced_commands.c     cmd->device = pcmk__str_copy(device->id);
cmd               707 daemons/fenced/fenced_commands.c     cmd->timeout = get_action_timeout(device, cmd->action, cmd->default_timeout);
cmd               709 daemons/fenced/fenced_commands.c     if (cmd->remote_op_id) {
cmd               712 daemons/fenced/fenced_commands.c                   cmd->action,
cmd               713 daemons/fenced/fenced_commands.c                   (cmd->target == NULL)? "" : " targeting ",
cmd               714 daemons/fenced/fenced_commands.c                   pcmk__s(cmd->target, ""),
cmd               715 daemons/fenced/fenced_commands.c                   device->id, cmd->origin, cmd->remote_op_id, cmd->timeout);
cmd               718 daemons/fenced/fenced_commands.c                   cmd->action,
cmd               719 daemons/fenced/fenced_commands.c                   (cmd->target == NULL)? "" : " targeting ",
cmd               720 daemons/fenced/fenced_commands.c                   pcmk__s(cmd->target, ""),
cmd               721 daemons/fenced/fenced_commands.c                   device->id, cmd->client, cmd->timeout);
cmd               724 daemons/fenced/fenced_commands.c     device->pending_ops = g_list_append(device->pending_ops, cmd);
cmd               732 daemons/fenced/fenced_commands.c     delay_max = get_action_delay_max(device, cmd->action);
cmd               733 daemons/fenced/fenced_commands.c     delay_base = get_action_delay_base(device, cmd->action, cmd->target);
cmd               741 daemons/fenced/fenced_commands.c                  delay_base, delay_max, cmd->action, device->id);
cmd               745 daemons/fenced/fenced_commands.c         cmd->start_delay +=
cmd               751 daemons/fenced/fenced_commands.c     if (cmd->start_delay > 0) {
cmd               754 daemons/fenced/fenced_commands.c                    cmd->action,
cmd               755 daemons/fenced/fenced_commands.c                    (cmd->target == NULL)? "" : " targeting ",
cmd               756 daemons/fenced/fenced_commands.c                    pcmk__s(cmd->target, ""),
cmd               757 daemons/fenced/fenced_commands.c                    device->id, cmd->start_delay, cmd->timeout,
cmd               759 daemons/fenced/fenced_commands.c         cmd->delay_id =
cmd               760 daemons/fenced/fenced_commands.c             pcmk__create_timer(cmd->start_delay * 1000, start_delay_helper, cmd);
cmd               774 daemons/fenced/fenced_commands.c         async_command_t *cmd = gIter->data;
cmd               776 daemons/fenced/fenced_commands.c         crm_warn("Removal of device '%s' purged operation '%s'", device->id, cmd->action);
cmd               777 daemons/fenced/fenced_commands.c         report_internal_result(cmd, CRM_EX_ERROR, PCMK_EXEC_NO_FENCE_DEVICE,
cmd              1131 daemons/fenced/fenced_commands.c     async_command_t *cmd = NULL;
cmd              1133 daemons/fenced/fenced_commands.c     cmd = pcmk__assert_alloc(1, sizeof(async_command_t));
cmd              1135 daemons/fenced/fenced_commands.c     cmd->id = -1;
cmd              1136 daemons/fenced/fenced_commands.c     cmd->default_timeout = timeout ? timeout : 60;
cmd              1137 daemons/fenced/fenced_commands.c     cmd->timeout = cmd->default_timeout;
cmd              1138 daemons/fenced/fenced_commands.c     cmd->action = pcmk__str_copy(action);
cmd              1139 daemons/fenced/fenced_commands.c     cmd->target = pcmk__str_copy(target);
cmd              1140 daemons/fenced/fenced_commands.c     cmd->device = pcmk__str_copy(device->id);
cmd              1141 daemons/fenced/fenced_commands.c     cmd->origin = pcmk__str_copy(origin);
cmd              1142 daemons/fenced/fenced_commands.c     cmd->client = pcmk__str_copy(crm_system_name);
cmd              1143 daemons/fenced/fenced_commands.c     cmd->client_name = pcmk__str_copy(crm_system_name);
cmd              1145 daemons/fenced/fenced_commands.c     cmd->internal_user_data = internal_user_data;
cmd              1146 daemons/fenced/fenced_commands.c     cmd->done_cb = done_cb; /* cmd, not internal_user_data, is passed to 'done_cb' as the userdata */
cmd              1148 daemons/fenced/fenced_commands.c     schedule_stonith_command(cmd, device);
cmd              1162 daemons/fenced/fenced_commands.c     async_command_t *cmd = user_data;
cmd              1163 daemons/fenced/fenced_commands.c     struct device_search_s *search = cmd->internal_user_data;
cmd              1164 daemons/fenced/fenced_commands.c     fenced_device_t *dev = cmd_device(cmd);
cmd              1167 daemons/fenced/fenced_commands.c     free_async_command(cmd);
cmd              1212 daemons/fenced/fenced_commands.c     async_command_t *cmd = user_data;
cmd              1213 daemons/fenced/fenced_commands.c     struct device_search_s *search = cmd->internal_user_data;
cmd              1214 daemons/fenced/fenced_commands.c     fenced_device_t *dev = cmd_device(cmd);
cmd              1217 daemons/fenced/fenced_commands.c     free_async_command(cmd);
cmd              1903 daemons/fenced/fenced_commands.c     async_command_t *cmd = NULL;
cmd              1953 daemons/fenced/fenced_commands.c     cmd = create_async_command(msg);
cmd              1954 daemons/fenced/fenced_commands.c     if (cmd == NULL) {
cmd              1960 daemons/fenced/fenced_commands.c     schedule_stonith_command(cmd, device);
cmd              2508 daemons/fenced/fenced_commands.c log_async_result(const async_command_t *cmd,
cmd              2514 daemons/fenced/fenced_commands.c     guint devices_remaining = g_list_length(cmd->next_device_iter);
cmd              2520 daemons/fenced/fenced_commands.c         log_level = (cmd->target == NULL)? LOG_DEBUG : LOG_NOTICE;
cmd              2522 daemons/fenced/fenced_commands.c             && !pcmk__str_eq(cmd->action, PCMK_ACTION_METADATA,
cmd              2528 daemons/fenced/fenced_commands.c         log_level = (cmd->target == NULL)? LOG_NOTICE : LOG_ERR;
cmd              2530 daemons/fenced/fenced_commands.c             && !pcmk__str_eq(cmd->action, PCMK_ACTION_METADATA,
cmd              2537 daemons/fenced/fenced_commands.c     pcmk__g_strcat(msg, "Operation '", cmd->action, "' ", NULL);
cmd              2541 daemons/fenced/fenced_commands.c     if (cmd->target != NULL) {
cmd              2542 daemons/fenced/fenced_commands.c         pcmk__g_strcat(msg, "targeting ", cmd->target, " ", NULL);
cmd              2544 daemons/fenced/fenced_commands.c     if (cmd->device != NULL) {
cmd              2545 daemons/fenced/fenced_commands.c         pcmk__g_strcat(msg, "using ", cmd->device, " ", NULL);
cmd              2569 daemons/fenced/fenced_commands.c                            (op_merged? "merged " : ""), cmd->id,
cmd              2570 daemons/fenced/fenced_commands.c                            cmd->client_name);
cmd              2578 daemons/fenced/fenced_commands.c         char *prefix = crm_strdup_printf("%s[%d]", cmd->device, pid);
cmd              2595 daemons/fenced/fenced_commands.c send_async_reply(const async_command_t *cmd, const pcmk__action_result_t *result,
cmd              2601 daemons/fenced/fenced_commands.c     CRM_CHECK((cmd != NULL) && (result != NULL), return);
cmd              2603 daemons/fenced/fenced_commands.c     log_async_result(cmd, result, pid, NULL, merged);
cmd              2605 daemons/fenced/fenced_commands.c     if (cmd->client != NULL) {
cmd              2606 daemons/fenced/fenced_commands.c         client = pcmk__find_client_by_id(cmd->client);
cmd              2607 daemons/fenced/fenced_commands.c         if ((client == NULL) && (cmd->origin == NULL)) {
cmd              2608 daemons/fenced/fenced_commands.c             crm_trace("Skipping reply to %s: no longer a client", cmd->client);
cmd              2613 daemons/fenced/fenced_commands.c     reply = construct_async_reply(cmd, result);
cmd              2618 daemons/fenced/fenced_commands.c     if (pcmk__is_fencing_action(cmd->action)
cmd              2619 daemons/fenced/fenced_commands.c         && pcmk__str_eq(cmd->origin, cmd->target, pcmk__str_casei)) {
cmd              2624 daemons/fenced/fenced_commands.c                   cmd->action, cmd->target);
cmd              2630 daemons/fenced/fenced_commands.c         stonith_send_reply(reply, cmd->options, cmd->origin, client);
cmd              2638 daemons/fenced/fenced_commands.c cancel_stonith_command(async_command_t * cmd)
cmd              2640 daemons/fenced/fenced_commands.c     fenced_device_t *device = cmd_device(cmd);
cmd              2644 daemons/fenced/fenced_commands.c                   cmd->action, device->id);
cmd              2645 daemons/fenced/fenced_commands.c         device->pending_ops = g_list_remove(device->pending_ops, cmd);
cmd              2669 daemons/fenced/fenced_commands.c reply_to_duplicates(async_command_t *cmd, const pcmk__action_result_t *result,
cmd              2679 daemons/fenced/fenced_commands.c         if (cmd == cmd_other) {
cmd              2689 daemons/fenced/fenced_commands.c         if (pcmk__str_eq(cmd->client, cmd_other->client, pcmk__str_casei) ||
cmd              2690 daemons/fenced/fenced_commands.c             !pcmk__str_eq(cmd->target, cmd_other->target, pcmk__str_casei) ||
cmd              2691 daemons/fenced/fenced_commands.c             !pcmk__str_eq(cmd->action, cmd_other->action, pcmk__str_none) ||
cmd              2692 daemons/fenced/fenced_commands.c             !pcmk__str_eq(cmd->device, cmd_other->device, pcmk__str_casei)) {
cmd              2702 daemons/fenced/fenced_commands.c                    cmd->client_name);
cmd              2723 daemons/fenced/fenced_commands.c next_required_device(async_command_t *cmd)
cmd              2725 daemons/fenced/fenced_commands.c     for (GList *iter = cmd->next_device_iter; iter != NULL; iter = iter->next) {
cmd              2729 daemons/fenced/fenced_commands.c         if (is_action_required(cmd->action, next_device)) {
cmd              2733 daemons/fenced/fenced_commands.c             cmd->next_device_iter = iter->next;
cmd              2743 daemons/fenced/fenced_commands.c     async_command_t *cmd = user_data;
cmd              2748 daemons/fenced/fenced_commands.c     CRM_CHECK(cmd != NULL, return);
cmd              2750 daemons/fenced/fenced_commands.c     device = cmd_device(cmd);
cmd              2751 daemons/fenced/fenced_commands.c     cmd->active_on = NULL;
cmd              2757 daemons/fenced/fenced_commands.c             && pcmk__strcase_any_of(cmd->action, PCMK_ACTION_LIST,
cmd              2768 daemons/fenced/fenced_commands.c         next_device = next_required_device(cmd);
cmd              2770 daemons/fenced/fenced_commands.c     } else if ((cmd->next_device_iter != NULL)
cmd              2771 daemons/fenced/fenced_commands.c                && !is_action_required(cmd->action, device)) {
cmd              2775 daemons/fenced/fenced_commands.c                                           cmd->next_device_iter->data);
cmd              2776 daemons/fenced/fenced_commands.c         cmd->next_device_iter = cmd->next_device_iter->next;
cmd              2780 daemons/fenced/fenced_commands.c         send_async_reply(cmd, result, pid, false);
cmd              2782 daemons/fenced/fenced_commands.c             reply_to_duplicates(cmd, result, pid);
cmd              2784 daemons/fenced/fenced_commands.c         free_async_command(cmd);
cmd              2787 daemons/fenced/fenced_commands.c         log_async_result(cmd, result, pid, next_device->id, false);
cmd              2788 daemons/fenced/fenced_commands.c         schedule_stonith_command(cmd, next_device);
cmd              2795 daemons/fenced/fenced_commands.c     async_command_t *cmd = user_data;
cmd              2800 daemons/fenced/fenced_commands.c              ndevices, pcmk__plural_s(ndevices), cmd->target);
cmd              2811 daemons/fenced/fenced_commands.c                             cmd->target);
cmd              2812 daemons/fenced/fenced_commands.c         send_async_reply(cmd, &result, 0, false);
cmd              2814 daemons/fenced/fenced_commands.c         free_async_command(cmd);
cmd              2822 daemons/fenced/fenced_commands.c         cmd->device_list = devices;
cmd              2823 daemons/fenced/fenced_commands.c         cmd->next_device_iter = devices->next;
cmd              2824 daemons/fenced/fenced_commands.c         schedule_stonith_command(cmd, device);
cmd              2840 daemons/fenced/fenced_commands.c     async_command_t *cmd = NULL;
cmd              2848 daemons/fenced/fenced_commands.c     cmd = create_async_command(msg);
cmd              2849 daemons/fenced/fenced_commands.c     if (cmd == NULL) {
cmd              2864 daemons/fenced/fenced_commands.c         schedule_stonith_command(cmd, device);
cmd              2869 daemons/fenced/fenced_commands.c         if (pcmk_is_set(cmd->options, st_opt_cs_nodeid)) {
cmd              2883 daemons/fenced/fenced_commands.c         get_capable_devices(host, cmd->action, cmd->default_timeout,
cmd              2884 daemons/fenced/fenced_commands.c                             TRUE, cmd, stonith_fence_get_devices_cb,
cmd              2885 daemons/fenced/fenced_commands.c                             fenced_support_flag(cmd->action));
cmd              2964 daemons/fenced/fenced_commands.c construct_async_reply(const async_command_t *cmd,
cmd              2971 daemons/fenced/fenced_commands.c     crm_xml_add(reply, PCMK__XA_ST_OP, cmd->op);
cmd              2972 daemons/fenced/fenced_commands.c     crm_xml_add(reply, PCMK__XA_ST_DEVICE_ID, cmd->device);
cmd              2973 daemons/fenced/fenced_commands.c     crm_xml_add(reply, PCMK__XA_ST_REMOTE_OP, cmd->remote_op_id);
cmd              2974 daemons/fenced/fenced_commands.c     crm_xml_add(reply, PCMK__XA_ST_CLIENTID, cmd->client);
cmd              2975 daemons/fenced/fenced_commands.c     crm_xml_add(reply, PCMK__XA_ST_CLIENTNAME, cmd->client_name);
cmd              2976 daemons/fenced/fenced_commands.c     crm_xml_add(reply, PCMK__XA_ST_TARGET, cmd->target);
cmd              2977 daemons/fenced/fenced_commands.c     crm_xml_add(reply, PCMK__XA_ST_DEVICE_ACTION, cmd->op);
cmd              2978 daemons/fenced/fenced_commands.c     crm_xml_add(reply, PCMK__XA_ST_ORIGIN, cmd->origin);
cmd              2979 daemons/fenced/fenced_commands.c     crm_xml_add_int(reply, PCMK__XA_ST_CALLID, cmd->id);
cmd              2980 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                25 lib/common/unittest.c     char *cmd = NULL;
cmd                55 lib/common/unittest.c     cmd = crm_strdup_printf("xmllint --relaxng %s/api/api-result.rng %s",
cmd                58 lib/common/unittest.c     if (!g_spawn_command_line_sync(cmd, &out, &err, &status, &gerr)) {
cmd                68 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               227 tools/crm_resource_runtime.c                              const char * attr_name, cib_t * cib, const char * cmd,
cmd               247 tools/crm_resource_runtime.c                       cmd, attr_name, rsc->id, rsc_id);
cmd               264 tools/crm_resource_runtime.c                           attr_name, lookup_id, cmd, rsc_id);
cmd                72 tools/crm_shadow.c     enum shadow_command cmd;
cmd              1040 tools/crm_shadow.c         options.cmd = shadow_cmd_which;
cmd              1043 tools/crm_shadow.c         options.cmd = shadow_cmd_display;
cmd              1046 tools/crm_shadow.c         options.cmd = shadow_cmd_diff;
cmd              1049 tools/crm_shadow.c         options.cmd = shadow_cmd_file;
cmd              1052 tools/crm_shadow.c         options.cmd = shadow_cmd_create;
cmd              1055 tools/crm_shadow.c         options.cmd = shadow_cmd_create_empty;
cmd              1058 tools/crm_shadow.c         options.cmd = shadow_cmd_commit;
cmd              1061 tools/crm_shadow.c         options.cmd = shadow_cmd_delete;
cmd              1064 tools/crm_shadow.c         options.cmd = shadow_cmd_edit;
cmd              1067 tools/crm_shadow.c         options.cmd = shadow_cmd_reset;
cmd              1070 tools/crm_shadow.c         options.cmd = shadow_cmd_switch;
cmd              1234 tools/crm_shadow.c     if (options.cmd == shadow_cmd_none) {
cmd              1253 tools/crm_shadow.c     switch (options.cmd) {