diff --git a/tools/crm_ticket.c b/tools/crm_ticket.c
index 07b7df4e6b..65bbd2f6e1 100644
--- a/tools/crm_ticket.c
+++ b/tools/crm_ticket.c
@@ -1,1100 +1,1096 @@
/*
* Copyright 2012-2022 the Pacemaker project contributors
*
* The version control history for this file may have further details.
*
* This source code is licensed under the GNU General Public License version 2
* or later (GPLv2+) WITHOUT ANY WARRANTY.
*/
#include <crm_internal.h>
#include <sys/param.h>
#include <crm/crm.h>
#include <stdio.h>
#include <sys/types.h>
#include <unistd.h>
#include <stdlib.h>
#include <errno.h>
#include <fcntl.h>
#include <libgen.h>
#include <crm/msg_xml.h>
#include <crm/common/xml.h>
#include <crm/common/ipc.h>
#include <crm/cib.h>
#include <crm/cib/internal.h>
#include <crm/pengine/rules.h>
#include <crm/pengine/status.h>
#include <pacemaker-internal.h>
GError *error = NULL;
struct {
const char *attr_default;
const char *attr_id;
const char *attr_name;
const char *attr_value;
gboolean force;
const char *get_attr_name;
gboolean quiet;
const char *set_name;
char ticket_cmd;
const char *ticket_id;
const char *xml_file;
} options = {
.ticket_cmd = 'S'
};
int cib_options = cib_sync_call;
static pe_ticket_t *
find_ticket(const char *ticket_id, pe_working_set_t * data_set)
{
- pe_ticket_t *ticket = NULL;
-
- ticket = g_hash_table_lookup(data_set->tickets, ticket_id);
-
- return ticket;
+ return g_hash_table_lookup(data_set->tickets, ticket_id);
}
static void
print_date(time_t time)
{
int lpc = 0;
char date_str[26];
asctime_r(localtime(&time), date_str);
for (; lpc < 26; lpc++) {
if (date_str[lpc] == '\n') {
date_str[lpc] = 0;
}
}
fprintf(stdout, "'%s'", date_str);
}
static void
print_ticket(pe_ticket_t * ticket, gboolean raw, gboolean details)
{
if (raw) {
fprintf(stdout, "%s\n", ticket->id);
return;
}
fprintf(stdout, "%s\t%s %s",
ticket->id, ticket->granted ? "granted" : "revoked",
ticket->standby ? "[standby]" : " ");
if (details && g_hash_table_size(ticket->state) > 0) {
GHashTableIter iter;
const char *name = NULL;
const char *value = NULL;
int lpc = 0;
fprintf(stdout, " (");
g_hash_table_iter_init(&iter, ticket->state);
while (g_hash_table_iter_next(&iter, (void **)&name, (void **)&value)) {
if (lpc > 0) {
fprintf(stdout, ", ");
}
fprintf(stdout, "%s=", name);
if (pcmk__str_any_of(name, "last-granted", "expires", NULL)) {
long long time_ll;
pcmk__scan_ll(value, &time_ll, 0);
print_date((time_t) time_ll);
} else {
fprintf(stdout, "%s", value);
}
lpc++;
}
fprintf(stdout, ")\n");
} else {
if (ticket->last_granted > -1) {
fprintf(stdout, " last-granted=");
print_date(ticket->last_granted);
}
fprintf(stdout, "\n");
}
return;
}
static void
print_ticket_list(pe_working_set_t * data_set, gboolean raw, gboolean details)
{
GHashTableIter iter;
pe_ticket_t *ticket = NULL;
g_hash_table_iter_init(&iter, data_set->tickets);
while (g_hash_table_iter_next(&iter, NULL, (void **)&ticket)) {
print_ticket(ticket, raw, details);
}
}
#define XPATH_MAX 1024
static int
find_ticket_state(cib_t * the_cib, const char *ticket_id, xmlNode ** ticket_state_xml)
{
int offset = 0;
int rc = pcmk_ok;
xmlNode *xml_search = NULL;
char *xpath_string = NULL;
CRM_ASSERT(ticket_state_xml != NULL);
*ticket_state_xml = NULL;
xpath_string = calloc(1, XPATH_MAX);
offset += snprintf(xpath_string + offset, XPATH_MAX - offset, "%s", "/cib/status/tickets");
if (ticket_id) {
offset += snprintf(xpath_string + offset, XPATH_MAX - offset, "/%s[@id=\"%s\"]",
XML_CIB_TAG_TICKET_STATE, ticket_id);
}
CRM_LOG_ASSERT(offset > 0);
rc = the_cib->cmds->query(the_cib, xpath_string, &xml_search,
cib_sync_call | cib_scope_local | cib_xpath);
if (rc != pcmk_ok) {
goto done;
}
crm_log_xml_debug(xml_search, "Match");
if (xml_has_children(xml_search)) {
if (ticket_id) {
fprintf(stdout, "Multiple ticket_states match ticket_id=%s\n", ticket_id);
}
*ticket_state_xml = xml_search;
} else {
*ticket_state_xml = xml_search;
}
done:
free(xpath_string);
return rc;
}
static int
find_ticket_constraints(cib_t * the_cib, const char *ticket_id, xmlNode ** ticket_cons_xml)
{
int offset = 0;
int rc = pcmk_ok;
xmlNode *xml_search = NULL;
char *xpath_string = NULL;
const char *xpath_base = NULL;
CRM_ASSERT(ticket_cons_xml != NULL);
*ticket_cons_xml = NULL;
xpath_base = pcmk_cib_xpath_for(XML_CIB_TAG_CONSTRAINTS);
if (xpath_base == NULL) {
crm_err(XML_CIB_TAG_CONSTRAINTS " CIB element not known (bug?)");
return -ENOMSG;
}
xpath_string = calloc(1, XPATH_MAX);
offset += snprintf(xpath_string + offset, XPATH_MAX - offset, "%s/%s",
xpath_base, XML_CONS_TAG_RSC_TICKET);
if (ticket_id) {
offset += snprintf(xpath_string + offset, XPATH_MAX - offset, "[@ticket=\"%s\"]",
ticket_id);
}
CRM_LOG_ASSERT(offset > 0);
rc = the_cib->cmds->query(the_cib, xpath_string, &xml_search,
cib_sync_call | cib_scope_local | cib_xpath);
if (rc != pcmk_ok) {
goto done;
}
crm_log_xml_debug(xml_search, "Match");
*ticket_cons_xml = xml_search;
done:
free(xpath_string);
return rc;
}
static int
dump_ticket_xml(cib_t * the_cib, const char *ticket_id)
{
int rc = pcmk_ok;
xmlNode *state_xml = NULL;
rc = find_ticket_state(the_cib, ticket_id, &state_xml);
if (state_xml == NULL) {
return rc;
}
fprintf(stdout, "State XML:\n");
if (state_xml) {
char *state_xml_str = NULL;
state_xml_str = dump_xml_formatted(state_xml);
fprintf(stdout, "\n%s\n", crm_str(state_xml_str));
free_xml(state_xml);
free(state_xml_str);
}
return pcmk_ok;
}
static int
dump_constraints(cib_t * the_cib, const char *ticket_id)
{
int rc = pcmk_ok;
xmlNode *cons_xml = NULL;
char *cons_xml_str = NULL;
rc = find_ticket_constraints(the_cib, ticket_id, &cons_xml);
if (cons_xml == NULL) {
return rc;
}
cons_xml_str = dump_xml_formatted(cons_xml);
fprintf(stdout, "Constraints XML:\n\n%s\n", crm_str(cons_xml_str));
free_xml(cons_xml);
free(cons_xml_str);
return pcmk_ok;
}
static int
get_ticket_state_attr(const char *ticket_id, const char *attr_name, const char **attr_value,
pe_working_set_t * data_set)
{
pe_ticket_t *ticket = NULL;
CRM_ASSERT(attr_value != NULL);
*attr_value = NULL;
ticket = g_hash_table_lookup(data_set->tickets, ticket_id);
if (ticket == NULL) {
return -ENXIO;
}
*attr_value = g_hash_table_lookup(ticket->state, attr_name);
if (*attr_value == NULL) {
return -ENXIO;
}
return pcmk_ok;
}
static void
ticket_warning(const char *ticket_id, const char *action)
{
int offset = 0;
static int text_max = 1024;
char *warning = NULL;
const char *word = NULL;
warning = calloc(1, text_max);
if (pcmk__str_eq(action, "grant", pcmk__str_casei)) {
offset += snprintf(warning + offset, text_max - offset,
"This command cannot help you verify whether '%s' has been already granted elsewhere.\n",
ticket_id);
word = "to";
} else {
offset += snprintf(warning + offset, text_max - offset,
"Revoking '%s' can trigger the specified 'loss-policy'(s) relating to '%s'.\n\n",
ticket_id, ticket_id);
offset += snprintf(warning + offset, text_max - offset,
"You can check that with:\ncrm_ticket --ticket %s --constraints\n\n",
ticket_id);
offset += snprintf(warning + offset, text_max - offset,
"Otherwise before revoking '%s', you may want to make '%s' standby with:\ncrm_ticket --ticket %s --standby\n\n",
ticket_id, ticket_id, ticket_id);
word = "from";
}
offset += snprintf(warning + offset, text_max - offset,
"If you really want to %s '%s' %s this site now, and you know what you are doing,\n",
action, ticket_id, word);
offset += snprintf(warning + offset, text_max - offset,
"please specify --force.");
CRM_LOG_ASSERT(offset > 0);
fprintf(stdout, "%s\n", warning);
free(warning);
}
static gboolean
allow_modification(const char *ticket_id, GList *attr_delete,
GHashTable *attr_set)
{
const char *value = NULL;
GList *list_iter = NULL;
if (options.force) {
return TRUE;
}
if (g_hash_table_lookup_extended(attr_set, "granted", NULL, (gpointer *) & value)) {
if (crm_is_true(value)) {
ticket_warning(ticket_id, "grant");
return FALSE;
} else {
ticket_warning(ticket_id, "revoke");
return FALSE;
}
}
for(list_iter = attr_delete; list_iter; list_iter = list_iter->next) {
const char *key = (const char *)list_iter->data;
if (pcmk__str_eq(key, "granted", pcmk__str_casei)) {
ticket_warning(ticket_id, "revoke");
return FALSE;
}
}
return TRUE;
}
static int
modify_ticket_state(const char * ticket_id, GList *attr_delete, GHashTable * attr_set,
cib_t * cib, pe_working_set_t * data_set)
{
int rc = pcmk_ok;
xmlNode *xml_top = NULL;
xmlNode *ticket_state_xml = NULL;
gboolean found = FALSE;
GList *list_iter = NULL;
GHashTableIter hash_iter;
char *key = NULL;
char *value = NULL;
pe_ticket_t *ticket = NULL;
rc = find_ticket_state(cib, ticket_id, &ticket_state_xml);
if (rc == pcmk_ok) {
crm_debug("Found a match state for ticket: id=%s", ticket_id);
xml_top = ticket_state_xml;
found = TRUE;
} else if (rc != -ENXIO) {
return rc;
} else if (g_hash_table_size(attr_set) == 0){
return pcmk_ok;
} else {
xmlNode *xml_obj = NULL;
xml_top = create_xml_node(NULL, XML_CIB_TAG_STATUS);
xml_obj = create_xml_node(xml_top, XML_CIB_TAG_TICKETS);
ticket_state_xml = create_xml_node(xml_obj, XML_CIB_TAG_TICKET_STATE);
crm_xml_add(ticket_state_xml, XML_ATTR_ID, ticket_id);
}
for(list_iter = attr_delete; list_iter; list_iter = list_iter->next) {
const char *key = (const char *)list_iter->data;
xml_remove_prop(ticket_state_xml, key);
}
ticket = find_ticket(ticket_id, data_set);
g_hash_table_iter_init(&hash_iter, attr_set);
while (g_hash_table_iter_next(&hash_iter, (gpointer *) & key, (gpointer *) & value)) {
crm_xml_add(ticket_state_xml, key, value);
if (pcmk__str_eq(key, "granted", pcmk__str_casei)
&& (ticket == NULL || ticket->granted == FALSE)
&& crm_is_true(value)) {
char *now = pcmk__ttoa(time(NULL));
crm_xml_add(ticket_state_xml, "last-granted", now);
free(now);
}
}
if (found && (attr_delete != NULL)) {
crm_log_xml_debug(xml_top, "Replace");
rc = cib->cmds->replace(cib, XML_CIB_TAG_STATUS, ticket_state_xml, cib_options);
} else {
crm_log_xml_debug(xml_top, "Update");
rc = cib->cmds->modify(cib, XML_CIB_TAG_STATUS, xml_top, cib_options);
}
free_xml(xml_top);
return rc;
}
static int
delete_ticket_state(const char *ticket_id, cib_t * cib)
{
xmlNode *ticket_state_xml = NULL;
int rc = pcmk_ok;
rc = find_ticket_state(cib, ticket_id, &ticket_state_xml);
if (rc == -ENXIO) {
return pcmk_ok;
} else if (rc != pcmk_ok) {
return rc;
}
crm_log_xml_debug(ticket_state_xml, "Delete");
rc = cib->cmds->remove(cib, XML_CIB_TAG_STATUS, ticket_state_xml, cib_options);
if (rc == pcmk_ok) {
fprintf(stdout, "Cleaned up %s\n", ticket_id);
}
free_xml(ticket_state_xml);
return rc;
}
static pcmk__cli_option_t long_options[] = {
// long option, argument type, storage, short option, description, flags
{
"help", no_argument, NULL, '?',
"\t\tThis text", pcmk__option_default
},
{
"version", no_argument, NULL, '$',
"\t\tVersion information", pcmk__option_default
},
{
"verbose", no_argument, NULL, 'V',
"\t\tIncrease debug output", pcmk__option_default
},
{
"quiet", no_argument, NULL, 'Q',
"\t\tPrint only the value on stdout\n", pcmk__option_default
},
{
"ticket", required_argument, NULL, 't',
"\tTicket ID", pcmk__option_default
},
{
"-spacer-", no_argument, NULL, '-',
"\nQueries:", pcmk__option_default
},
{
"info", no_argument, NULL, 'l',
"\t\tDisplay the information of ticket(s)", pcmk__option_default
},
{
"details", no_argument, NULL, 'L',
"\t\tDisplay the details of ticket(s)", pcmk__option_default
},
{
"raw", no_argument, NULL, 'w',
"\t\tDisplay the IDs of ticket(s)", pcmk__option_default
},
{
"query-xml", no_argument, NULL, 'q',
"\tQuery the XML of ticket(s)", pcmk__option_default
},
{
"constraints", no_argument, NULL, 'c',
"\tDisplay the rsc_ticket constraints that apply to ticket(s)",
pcmk__option_default
},
{
"-spacer-", no_argument, NULL, '-',
"\nCommands:", pcmk__option_default
},
{
"grant", no_argument, NULL, 'g',
"\t\tGrant a ticket to this cluster site", pcmk__option_default
},
{
"revoke", no_argument, NULL, 'r',
"\t\tRevoke a ticket from this cluster site", pcmk__option_default
},
{
"standby", no_argument, NULL, 's',
"\t\tTell this cluster site this ticket is standby",
pcmk__option_default
},
{
"activate", no_argument, NULL, 'a',
"\tTell this cluster site this ticket is active", pcmk__option_default
},
{
"-spacer-", no_argument, NULL, '-',
"\nAdvanced Commands:", pcmk__option_default
},
{
"get-attr", required_argument, NULL, 'G',
"\tDisplay the named attribute for a ticket", pcmk__option_default
},
{
"set-attr", required_argument, NULL, 'S',
"\tSet the named attribute for a ticket", pcmk__option_default
},
{
"delete-attr", required_argument, NULL, 'D',
"\tDelete the named attribute for a ticket", pcmk__option_default
},
{
"cleanup", no_argument, NULL, 'C',
"\t\tDelete all state of a ticket at this cluster site",
pcmk__option_default
},
{
"-spacer-", no_argument, NULL, '-',
"\nAdditional Options:", pcmk__option_default
},
{
"attr-value", required_argument, NULL, 'v',
"\tAttribute value to use with -S", pcmk__option_default
},
{
"default", required_argument, NULL, 'd',
"\t(Advanced) Default attribute value to display if none is found "
"(for use with -G)",
pcmk__option_default
},
{
"force", no_argument, NULL, 'f',
"\t\t(Advanced) Force the action to be performed", pcmk__option_default
},
{
"xml-file", required_argument, NULL, 'x',
NULL, pcmk__option_hidden
},
/* legacy options */
{
"set-name", required_argument, NULL, 'n',
"\t(Advanced) ID of the instance_attributes object to change",
pcmk__option_default
},
{
"nvpair", required_argument, NULL, 'i',
"\t(Advanced) ID of the nvpair object to change/delete",
pcmk__option_default
},
{
"-spacer-", no_argument, NULL, '-',
"\nExamples:", pcmk__option_paragraph
},
{
"-spacer-", no_argument, NULL, '-',
"Display the info of tickets:", pcmk__option_paragraph
},
{
"-spacer-", no_argument, NULL, '-',
" crm_ticket --info", pcmk__option_example
},
{
"-spacer-", no_argument, NULL, '-',
"Display the detailed info of tickets:", pcmk__option_paragraph
},
{
"-spacer-", no_argument, NULL, '-',
" crm_ticket --details", pcmk__option_example
},
{
"-spacer-", no_argument, NULL, '-',
"Display the XML of 'ticketA':", pcmk__option_paragraph
},
{
"-spacer-", no_argument, NULL, '-',
" crm_ticket --ticket ticketA --query-xml", pcmk__option_example
},
{
"-spacer-", no_argument, NULL, '-',
"Display the rsc_ticket constraints that apply to 'ticketA':",
pcmk__option_paragraph
},
{
"-spacer-", no_argument, NULL, '-',
" crm_ticket --ticket ticketA --constraints", pcmk__option_example
},
{
"-spacer-", no_argument, NULL, '-',
"Grant 'ticketA' to this cluster site:", pcmk__option_paragraph
},
{
"-spacer-", no_argument, NULL, '-',
" crm_ticket --ticket ticketA --grant", pcmk__option_example
},
{
"-spacer-", no_argument, NULL, '-',
"Revoke 'ticketA' from this cluster site:", pcmk__option_paragraph
},
{
"-spacer-", no_argument, NULL, '-',
" crm_ticket --ticket ticketA --revoke", pcmk__option_example
},
{
"-spacer-", no_argument, NULL, '-',
"Make 'ticketA' standby (the cluster site will treat a granted "
"'ticketA' as 'standby', and the dependent resources will be "
"stopped or demoted gracefully without triggering loss-policies):",
pcmk__option_paragraph
},
{
"-spacer-", no_argument, NULL, '-',
" crm_ticket --ticket ticketA --standby", pcmk__option_example
},
{
"-spacer-", no_argument, NULL, '-',
"Activate 'ticketA' from being standby:", pcmk__option_paragraph
},
{
"-spacer-", no_argument, NULL, '-',
" crm_ticket --ticket ticketA --activate", pcmk__option_example
},
{
"-spacer-", no_argument, NULL, '-',
"Get the value of the 'granted' attribute for 'ticketA':",
pcmk__option_paragraph
},
{
"-spacer-", no_argument, NULL, '-',
" crm_ticket --ticket ticketA --get-attr granted", pcmk__option_example
},
{
"-spacer-", no_argument, NULL, '-',
"Set the value of the 'standby' attribute for 'ticketA':",
pcmk__option_paragraph
},
{
"-spacer-", no_argument, NULL, '-',
" crm_ticket --ticket ticketA --set-attr standby --attr-value true",
pcmk__option_example
},
{
"-spacer-", no_argument, NULL, '-',
"Delete the 'granted' attribute for 'ticketA':", pcmk__option_paragraph
},
{
"-spacer-", no_argument, NULL, '-',
" crm_ticket --ticket ticketA --delete-attr granted",
pcmk__option_example
},
{
"-spacer-", no_argument, NULL, '-',
"Erase the operation history of 'ticketA' at this cluster site:",
pcmk__option_paragraph
},
{
"-spacer-", no_argument, NULL, '-',
"The cluster site will 'forget' the existing ticket state.",
pcmk__option_paragraph
},
{
"-spacer-", no_argument, NULL, '-',
" crm_ticket --ticket ticketA --cleanup", pcmk__option_example
},
{ 0, 0, 0, 0 }
};
int
main(int argc, char **argv)
{
pe_working_set_t *data_set = NULL;
xmlNode *cib_xml_copy = NULL;
cib_t *cib_conn = NULL;
crm_exit_t exit_code = CRM_EX_OK;
int rc = pcmk_ok;
int option_index = 0;
int argerr = 0;
int flag;
guint modified = 0;
GList *attr_delete = NULL;
GHashTable *attr_set = pcmk__strkey_table(free, free);
crm_log_init(NULL, LOG_CRIT, FALSE, FALSE, argc, argv, FALSE);
pcmk__set_cli_options(NULL, "<query>|<command> [options]", long_options,
"perform tasks related to cluster tickets\n\n"
"Allows ticket attributes to be queried, modified "
"and deleted.\n");
if (argc < 2) {
pcmk__cli_help('?', CRM_EX_USAGE);
}
while (1) {
flag = pcmk__next_cli_option(argc, argv, &option_index, NULL);
if (flag == -1)
break;
switch (flag) {
case 'V':
crm_bump_log_level(argc, argv);
break;
case '$':
case '?':
pcmk__cli_help(flag, CRM_EX_OK);
break;
case 'Q':
options.quiet = TRUE;
break;
case 't':
options.ticket_id = optarg;
break;
case 'l':
case 'L':
case 'w':
case 'q':
case 'c':
options.ticket_cmd = flag;
break;
case 'g':
g_hash_table_insert(attr_set, strdup("granted"), strdup("true"));
modified++;
break;
case 'r':
g_hash_table_insert(attr_set, strdup("granted"), strdup("false"));
modified++;
break;
case 's':
g_hash_table_insert(attr_set, strdup("standby"), strdup("true"));
modified++;
break;
case 'a':
g_hash_table_insert(attr_set, strdup("standby"), strdup("false"));
modified++;
break;
case 'G':
options.get_attr_name = optarg;
options.ticket_cmd = flag;
break;
case 'S':
options.attr_name = optarg;
if (options.attr_name && options.attr_value) {
g_hash_table_insert(attr_set, strdup(options.attr_name), strdup(options.attr_value));
options.attr_name = NULL;
options.attr_value = NULL;
modified++;
}
break;
case 'D':
attr_delete = g_list_append(attr_delete, optarg);
modified++;
break;
case 'C':
options.ticket_cmd = flag;
break;
case 'v':
options.attr_value = optarg;
if (options.attr_name && options.attr_value) {
g_hash_table_insert(attr_set, strdup(options.attr_name), strdup(options.attr_value));
options.attr_name = NULL;
options.attr_value = NULL;
modified++;
}
break;
case 'd':
options.attr_default = optarg;
break;
case 'f':
options.force = TRUE;
break;
case 'x':
options.xml_file = optarg;
break;
case 'n':
options.set_name = optarg;
break;
case 'i':
options.attr_id = optarg;
break;
default:
CMD_ERR("Argument code 0%o (%c) is not (?yet?) supported", flag, flag);
++argerr;
break;
}
}
if (optind < argc && argv[optind] != NULL) {
CMD_ERR("non-option ARGV-elements:");
while (optind < argc && argv[optind] != NULL) {
CMD_ERR("%s", argv[optind++]);
++argerr;
}
}
if (optind > argc) {
++argerr;
}
if (argerr) {
pcmk__cli_help('?', CRM_EX_USAGE);
}
data_set = pe_new_working_set();
if (data_set == NULL) {
crm_perror(LOG_CRIT, "Could not allocate working set");
exit_code = CRM_EX_OSERR;
goto done;
}
pe__set_working_set_flags(data_set, pe_flag_no_counts|pe_flag_no_compat);
cib_conn = cib_new();
if (cib_conn == NULL) {
exit_code = CRM_EX_DISCONNECT;
g_set_error(&error, PCMK__EXITC_ERROR, exit_code, "Could not connect to the CIB manager");
goto done;
}
rc = cib_conn->cmds->signon(cib_conn, crm_system_name, cib_command);
if (rc != pcmk_ok) {
exit_code = crm_errno2exit(rc);
g_set_error(&error, PCMK__EXITC_ERROR, exit_code, "Could not connect to the CIB: %s",
pcmk_strerror(rc));
goto done;
}
if (options.xml_file != NULL) {
cib_xml_copy = filename2xml(options.xml_file);
} else {
rc = cib_conn->cmds->query(cib_conn, NULL, &cib_xml_copy, cib_scope_local | cib_sync_call);
if (rc != pcmk_ok) {
exit_code = crm_errno2exit(rc);
g_set_error(&error, PCMK__EXITC_ERROR, exit_code, "Could not get local CIB: %s",
pcmk_strerror(rc));
goto done;
}
}
if (cli_config_update(&cib_xml_copy, NULL, FALSE) == FALSE) {
exit_code = CRM_EX_CONFIG;
g_set_error(&error, PCMK__EXITC_ERROR, exit_code,
"Could not update local CIB to latest schema version");
goto done;
}
data_set->input = cib_xml_copy;
data_set->now = crm_time_new(NULL);
cluster_status(data_set);
/* For recording the tickets that are referenced in rsc_ticket constraints
* but have never been granted yet. */
pcmk__unpack_constraints(data_set);
if (options.ticket_cmd == 'l' || options.ticket_cmd == 'L' || options.ticket_cmd == 'w') {
gboolean raw = FALSE;
gboolean details = FALSE;
if (options.ticket_cmd == 'L') {
details = TRUE;
} else if (options.ticket_cmd == 'w') {
raw = TRUE;
}
if (options.ticket_id) {
pe_ticket_t *ticket = find_ticket(options.ticket_id, data_set);
if (ticket == NULL) {
exit_code = CRM_EX_NOSUCH;
g_set_error(&error, PCMK__EXITC_ERROR, exit_code,
"No such ticket '%s'", options.ticket_id);
goto done;
}
print_ticket(ticket, raw, details);
} else {
print_ticket_list(data_set, raw, details);
}
} else if (options.ticket_cmd == 'q') {
rc = dump_ticket_xml(cib_conn, options.ticket_id);
exit_code = crm_errno2exit(rc);
if (rc != pcmk_ok) {
g_set_error(&error, PCMK__EXITC_ERROR, exit_code,
"Could not query ticket XML: %s", pcmk_strerror(rc));
}
} else if (options.ticket_cmd == 'c') {
rc = dump_constraints(cib_conn, options.ticket_id);
exit_code = crm_errno2exit(rc);
if (rc != pcmk_ok) {
g_set_error(&error, PCMK__EXITC_ERROR, exit_code,
"Could not show ticket constraints: %s", pcmk_strerror(rc));
}
} else if (options.ticket_cmd == 'G') {
const char *value = NULL;
if (options.ticket_id == NULL) {
exit_code = CRM_EX_NOSUCH;
g_set_error(&error, PCMK__EXITC_ERROR, exit_code,
"Must supply ticket ID with -t");
goto done;
}
rc = get_ticket_state_attr(options.ticket_id, options.get_attr_name, &value, data_set);
if (rc == pcmk_ok) {
fprintf(stdout, "%s\n", value);
} else if (rc == -ENXIO && options.attr_default) {
fprintf(stdout, "%s\n", options.attr_default);
rc = pcmk_ok;
}
exit_code = crm_errno2exit(rc);
} else if (options.ticket_cmd == 'C') {
if (options.ticket_id == NULL) {
exit_code = CRM_EX_USAGE;
g_set_error(&error, PCMK__EXITC_ERROR, exit_code,
"Must supply ticket ID with -t");
goto done;
}
if (options.force == FALSE) {
pe_ticket_t *ticket = NULL;
ticket = find_ticket(options.ticket_id, data_set);
if (ticket == NULL) {
exit_code = CRM_EX_NOSUCH;
g_set_error(&error, PCMK__EXITC_ERROR, exit_code,
"No such ticket '%s'", options.ticket_id);
goto done;
}
if (ticket->granted) {
ticket_warning(options.ticket_id, "revoke");
exit_code = CRM_EX_INSUFFICIENT_PRIV;
goto done;
}
}
rc = delete_ticket_state(options.ticket_id, cib_conn);
exit_code = crm_errno2exit(rc);
if (rc != pcmk_ok) {
g_set_error(&error, PCMK__EXITC_ERROR, exit_code,
"Could not clean up ticket: %s", pcmk_strerror(rc));
}
} else if (modified) {
if (options.ticket_id == NULL) {
exit_code = CRM_EX_USAGE;
g_set_error(&error, PCMK__EXITC_ERROR, exit_code,
"Must supply ticket ID with -t");
goto done;
}
if (options.attr_value
&& (pcmk__str_empty(options.attr_name))) {
exit_code = CRM_EX_USAGE;
g_set_error(&error, PCMK__EXITC_ERROR, exit_code,
"Must supply attribute name with -S for -v %s", options.attr_value);
goto done;
}
if (options.attr_name
&& (pcmk__str_empty(options.attr_value))) {
exit_code = CRM_EX_USAGE;
g_set_error(&error, PCMK__EXITC_ERROR, exit_code,
"Must supply attribute value with -v for -S %s", options.attr_value);
goto done;
}
if (allow_modification(options.ticket_id, attr_delete, attr_set) == FALSE) {
exit_code = CRM_EX_INSUFFICIENT_PRIV;
g_set_error(&error, PCMK__EXITC_ERROR, exit_code,
"Ticket modification not allowed");
goto done;
}
rc = modify_ticket_state(options.ticket_id, attr_delete, attr_set, cib_conn, data_set);
exit_code = crm_errno2exit(rc);
if (rc != pcmk_ok) {
g_set_error(&error, PCMK__EXITC_ERROR, exit_code,
"Could not modify ticket: %s", pcmk_strerror(rc));
}
} else if (options.ticket_cmd == 'S') {
/* Correct usage was handled in the "if (modified)" block above, so
* this is just for reporting usage errors
*/
if (pcmk__str_empty(options.attr_name)) {
// We only get here if ticket_cmd was left as default
exit_code = CRM_EX_USAGE;
g_set_error(&error, PCMK__EXITC_ERROR, exit_code, "Must supply a command");
goto done;
}
if (options.ticket_id == NULL) {
exit_code = CRM_EX_USAGE;
g_set_error(&error, PCMK__EXITC_ERROR, exit_code,
"Must supply ticket ID with -t");
goto done;
}
if (pcmk__str_empty(options.attr_value)) {
exit_code = CRM_EX_USAGE;
g_set_error(&error, PCMK__EXITC_ERROR, exit_code,
"Must supply value with -v for -S %s", options.attr_name);
goto done;
}
} else {
exit_code = CRM_EX_USAGE;
g_set_error(&error, PCMK__EXITC_ERROR, exit_code,
"Unknown command: %c", options.ticket_cmd);
}
done:
if (attr_set) {
g_hash_table_destroy(attr_set);
}
attr_set = NULL;
if (attr_delete) {
g_list_free(attr_delete);
}
attr_delete = NULL;
pe_free_working_set(data_set);
data_set = NULL;
cib__clean_up_connection(&cib_conn);
if (rc == -pcmk_err_no_quorum) {
g_set_error(&error, PCMK__RC_ERROR, rc, "Use --force to ignore quorum");
}
pcmk__output_and_clear_error(error, NULL);
crm_exit(exit_code);
}