 |
pacemaker
2.0.3-4b1f869f0f
Scalable High-Availability cluster resource manager
|
Go to the documentation of this file.
47 parse_op_key(
const char *key,
char **rsc_id,
char **op_type, guint *interval_ms)
50 char *mutable_key = NULL;
51 char *mutable_key_ptr = NULL;
52 size_t len = 0, offset = 0;
53 unsigned long long ch = 0;
54 guint local_interval_ms = 0;
72 while ((offset > 0) && isdigit(key[offset])) {
73 ch = key[offset] -
'0';
74 for (
int digits = len - offset; digits > 1; --digits) {
77 local_interval_ms += ch;
80 crm_trace(
"Operation key '%s' has interval %ums", key, local_interval_ms);
82 *interval_ms = local_interval_ms;
85 CRM_CHECK((offset != (len - 1)) && (key[offset] ==
'_'),
return FALSE);
87 mutable_key =
strndup(key, offset);
90 while (offset > 0 && key[offset] !=
'_') {
95 free(mutable_key);
return FALSE);
97 mutable_key_ptr = mutable_key + offset + 1;
99 crm_trace(
" Action: %s", mutable_key_ptr);
101 *op_type = strdup(mutable_key_ptr);
104 mutable_key[offset] = 0;
107 notify = strstr(mutable_key,
"_post_notify");
108 if (notify &&
safe_str_eq(notify,
"_post_notify")) {
112 notify = strstr(mutable_key,
"_pre_notify");
113 if (notify &&
safe_str_eq(notify,
"_pre_notify")) {
119 *rsc_id = mutable_key;
132 CRM_CHECK(notify_type != NULL,
return NULL);
134 rsc_id, notify_type, op_type);
154 int *
op_status,
int *op_rc,
int *target_rc)
158 gboolean result = TRUE;
159 int local_op_status = -1;
160 int local_op_rc = -1;
165 res = sscanf(magic,
"%d:%d;%ms", &local_op_status, &local_op_rc, &key);
167 key = calloc(1, strlen(magic) - 3);
169 res = sscanf(magic,
"%d:%d;%s", &local_op_status, &local_op_rc, key);
172 crm_err(
"Could not decode transition information '%s': %s",
175 }
else if (res < 3) {
176 crm_warn(
"Transition information '%s' incomplete (%d of 3 expected items)",
184 *op_rc = local_op_rc;
198 action_id, transition_id, target_rc, 36, node);
218 int local_transition_id = -1;
219 int local_action_id = -1;
220 int local_target_rc = -1;
221 char local_uuid[37] = {
'\0' };
238 if (sscanf(key,
"%d:%d:%d:%36s", &local_action_id, &local_transition_id,
239 &local_target_rc, local_uuid) != 4) {
240 crm_err(
"Invalid transition key '%s'", key);
243 if (strlen(local_uuid) != 36) {
244 crm_warn(
"Invalid UUID '%s' in transition key '%s'", local_uuid, key);
247 *uuid = strdup(local_uuid);
251 *transition_id = local_transition_id;
254 *action_id = local_action_id;
257 *target_rc = local_target_rc;
266 char *timeout = NULL;
267 char *interval_ms_s = NULL;
269 const char *attr_filter[] = {
278 gboolean do_delete = FALSE;
280 static int meta_len = 0;
286 if (param_set == NULL) {
290 for (lpc = 0; lpc <
DIMOF(attr_filter); lpc++) {
302 xmlAttrPtr xIter = param_set->properties;
305 const char *prop_name = (
const char *)xIter->name;
309 if (strncasecmp(prop_name,
CRM_META, meta_len) == 0) {
319 if (interval_ms_s && strcmp(interval_ms_s,
"0")) {
321 if (timeout != NULL) {
360 if (target_rc != op->
rc) {
381 const char *interval_spec,
const char *timeout)
385 CRM_CHECK(prefix && task && interval_spec,
return NULL);
414 CRM_CHECK(rsc_class || op,
return FALSE);
bool crm_op_needs_metadata(const char *rsc_class, const char *op)
Check whether an operation requires resource agent meta-data.
#define XML_LRM_ATTR_TARGET_UUID
xmlNode * crm_create_op_xml(xmlNode *parent, const char *prefix, const char *task, const char *interval_spec, const char *timeout)
Create a CIB XML element for an operation.
#define CRMD_ACTION_NOTIFY
xmlNode * create_xml_node(xmlNode *parent, const char *name)
const char * pcmk_strerror(int rc)
#define CRM_CHECK(expr, failure_action)
#define crm_err(fmt, args...)
#define XML_LRM_ATTR_INTERVAL
#define crm_trace(fmt, args...)
#define safe_str_eq(a, b)
#define crm_warn(fmt, args...)
gboolean did_rsc_op_fail(lrmd_event_data_t *op, int target_rc)
#define XML_ATTR_CRM_VERSION
Wrappers for and extensions to libxml2.
void crm_xml_set_id(xmlNode *xml, const char *format,...) __attribute__((__format__(__printf__
#define CRMD_ACTION_MIGRATED
char * crm_strdup_printf(char const *format,...) __attribute__((__format__(__printf__
#define CRMD_ACTION_START
#define CRMD_ACTION_MIGRATE
const char * crm_xml_add(xmlNode *node, const char *name, const char *value)
Create an XML attribute with specified name and value.
char * generate_transition_key(int transition_id, int action_id, int target_rc, const char *node)
void filter_action_parameters(xmlNode *param_set, const char *version)
#define CRMD_ACTION_RELOAD
#define XML_LRM_ATTR_OP_DIGEST
int rsc_op_expected_rc(lrmd_event_data_t *op)
void xml_remove_prop(xmlNode *obj, const char *name)
gboolean parse_op_key(const char *key, char **rsc_id, char **op_type, guint *interval_ms)
char * crm_element_value_copy(const xmlNode *data, const char *name)
Retrieve a copy of the value of an XML attribute.
#define XML_LRM_ATTR_TARGET
#define CRMD_ACTION_DEMOTE
#define CRMD_ACTION_STATUS
#define XML_LRM_ATTR_INTERVAL_MS
char * generate_op_key(const char *rsc_id, const char *op_type, guint interval_ms)
Generate an operation key.
gboolean decode_transition_key(const char *key, char **uuid, int *transition_id, int *action_id, int *target_rc)
Parse a transition key into its constituent parts.
uint32_t pcmk_get_ra_caps(const char *standard)
Get capabilities of a resource agent standard.
char * strndup(const char *str, size_t len)
gboolean decode_transition_magic(const char *magic, char **uuid, int *transition_id, int *action_id, int *op_status, int *op_rc, int *target_rc)
Parse a transition magic string into its constituent parts.
char * crm_meta_name(const char *field)
#define CRMD_ACTION_PROMOTE
char * generate_notify_key(const char *rsc_id, const char *notify_type, const char *op_type)