27 #define VARIANT_CLONE 1
40 for (; gIter != NULL; gIter = gIter->next) {
43 mark_as_orphan(child);
51 clone_variant_data_t *clone_data = NULL;
53 get_clone_variant_data(clone_data, rsc);
56 "can only be used as an anonymous clone. "
59 clone_data->clone_node_max = 1;
60 clone_data->clone_max = g_list_length(data_set->
nodes);
68 char *child_id = NULL;
70 const char *child_base = NULL;
71 clone_variant_data_t *clone_data = NULL;
73 get_clone_variant_data(clone_data, rsc);
75 child_base =
ID(clone_data->xml_obj_child);
76 child_id =
crm_concat(child_base, sub_id,
':');
86 gboolean as_orphan = FALSE;
90 xmlNode *child_copy = NULL;
91 clone_variant_data_t *clone_data = NULL;
93 get_clone_variant_data(clone_data, rsc);
95 CRM_CHECK(clone_data->xml_obj_child != NULL,
return FALSE);
99 sub_id = clone_data->total_clones;
102 inc_max =
crm_itoa(clone_data->clone_max);
104 child_copy =
copy_xml(clone_data->xml_obj_child);
108 if (
common_unpack(child_copy, &child_rsc, rsc, data_set) == FALSE) {
116 clone_data->total_clones += 1;
117 pe_rsc_trace(child_rsc,
"Setting clone attributes for: %s", child_rsc->
id);
120 mark_as_orphan(child_rsc);
142 clone_variant_data_t *clone_data = NULL;
144 get_clone_variant_data(clone_data, rsc);
146 clone_data->master_node_max =
crm_parse_int(master_node_max,
"1");
156 const char *
type = NULL;
157 int num_xml_children = 0;
158 xmlNode *a_child = NULL;
159 xmlNode *xml_obj = rsc->
xml;
160 clone_variant_data_t *clone_data = NULL;
169 clone_data = calloc(1,
sizeof(clone_variant_data_t));
171 clone_data->interleave = FALSE;
172 clone_data->ordered = FALSE;
174 clone_data->active_clones = 0;
175 clone_data->xml_obj_child = NULL;
176 clone_data->clone_node_max =
crm_parse_int(max_clones_node,
"1");
181 }
else if (g_list_length(data_set->
nodes) > 0) {
182 clone_data->clone_max = g_list_length(data_set->
nodes);
185 clone_data->clone_max = 1;
189 clone_data->interleave = TRUE;
192 clone_data->ordered = TRUE;
195 crm_config_err(
"Anonymous clones (%s) may only support one copy per node", rsc->
id);
196 clone_data->clone_node_max = 1;
200 pe_rsc_trace(rsc,
"\tClone max: %d", clone_data->clone_max);
201 pe_rsc_trace(rsc,
"\tClone node max: %d", clone_data->clone_node_max);
207 if (clone_data->xml_obj_child == NULL) {
209 for (a_child = __xml_first_child(xml_obj); a_child != NULL; a_child = __xml_next_element(a_child)) {
216 if (clone_data->xml_obj_child == NULL) {
221 for (a_child = __xml_first_child(xml_obj); a_child != NULL; a_child = __xml_next_element(a_child)) {
222 if (
crm_str_eq((
const char *)a_child->name, type, TRUE)) {
227 if (num_xml_children > 1) {
228 crm_config_err(
"%s has too many children. Only the first (%s) will be cloned.",
229 rsc->
id,
ID(clone_data->xml_obj_child));
248 for (lpc = 0; lpc < clone_data->clone_max; lpc++) {
254 if (clone_data->clone_max == 0) {
263 pe_rsc_trace(rsc,
"Added %d children to resource %s...", clone_data->clone_max, rsc->
id);
272 for (; gIter != NULL; gIter = gIter->next) {
274 gboolean child_active = child_rsc->
fns->
active(child_rsc, all);
276 if (all == FALSE && child_active) {
278 }
else if (all && child_active == FALSE) {
291 short_print(
char *list,
const char *prefix,
const char *
type,
const char *suffix,
long options,
void *print_data)
301 status_print(
"%s%s: [%s ]%s", prefix, type, list, suffix);
303 if (options & pe_print_html) {
318 const char *target_role = g_hash_table_lookup(rsc->
meta,
331 const char *target_role = configured_role_str(rsc);
340 clone_print_xml(
resource_t * rsc,
const char *pre_text,
long options,
void *print_data)
343 char *child_text =
crm_concat(pre_text,
" ",
' ');
344 const char *target_role = configured_role_str(rsc);
349 status_print(
"multi_state=\"%s\" ", is_master_slave ?
"true" :
"false");
360 for (; gIter != NULL; gIter = gIter->next) {
363 child_rsc->
fns->
print(child_rsc, child_text, options, print_data);
375 if(is_set(rsc->
flags, flag)) {
383 for (gIter = rsc->
children; gIter != NULL; gIter = gIter->next) {
403 char *list_text = NULL;
404 char *child_text = NULL;
405 char *stopped_list = NULL;
406 const char *type =
"Clone";
412 clone_variant_data_t *clone_data = NULL;
413 int active_instances = 0;
415 if (pre_text == NULL) {
420 clone_print_xml(rsc, pre_text, options, print_data);
424 get_clone_variant_data(clone_data, rsc);
429 type =
"Master/Slave";
433 pre_text ? pre_text :
"", type, rsc->
id,
ID(clone_data->xml_obj_child),
437 if (options & pe_print_html) {
444 for (; gIter != NULL; gIter = gIter->next) {
445 gboolean print_full = FALSE;
452 if (child_rsc->
fns->
active(child_rsc, FALSE) == FALSE) {
476 }
else if (child_rsc->
fns->
active(child_rsc, TRUE)) {
488 master_list = g_list_append(master_list, location);
492 started_list = g_list_append(started_list, location);
506 if (options & pe_print_html) {
509 child_rsc->
fns->
print(child_rsc, child_text, options, print_data);
510 if (options & pe_print_html) {
518 for (gIter = master_list; gIter; gIter = gIter->next) {
525 short_print(list_text, child_text,
"Masters", NULL, options, print_data);
526 g_list_free(master_list);
532 for (gIter = started_list; gIter; gIter = gIter->next) {
543 short_print(list_text, child_text,
"Slaves (target-role)", NULL, options, print_data);
545 short_print(list_text, child_text,
"Slaves", NULL, options, print_data);
549 short_print(list_text, child_text,
"Started", NULL, options, print_data);
552 g_list_free(started_list);
557 const char *state =
"Stopped";
561 state =
"Stopped (disabled)";
565 && (clone_data->clone_max > active_instances)) {
571 free(stopped_list); stopped_list = NULL;
573 if (g_list_length(list) == 0) {
577 list = g_hash_table_get_values(rsc->
known_on);
581 for (nIter = list; nIter != NULL; nIter = nIter->next) {
591 short_print(stopped_list, child_text, state, NULL, options, print_data);
595 if (options & pe_print_html) {
606 clone_variant_data_t *clone_data = NULL;
608 get_clone_variant_data(clone_data, rsc);
612 for (; gIter != NULL; gIter = gIter->next) {
618 child_rsc->
xml = NULL;
622 child_rsc->
fns->
free(child_rsc);
628 CRM_ASSERT(clone_data->demote_notify == NULL);
631 CRM_ASSERT(clone_data->promote_notify == NULL);
643 for (; gIter != NULL; gIter = gIter->next) {
647 if (a_role > clone_role) {
#define CRM_CHECK(expr, failure_action)
xmlNode * find_xml_node(xmlNode *cib, const char *node_path, gboolean must_find)
node_t *(* location)(resource_t *, GListPtr *, gboolean)
gboolean clone_unpack(resource_t *rsc, pe_working_set_t *data_set)
#define XML_BOOLEAN_FALSE
#define crm_config_err(fmt...)
#define XML_RSC_ATTR_INCARNATION
gboolean common_unpack(xmlNode *xml_obj, resource_t **rsc, resource_t *parent, pe_working_set_t *data_set)
enum pe_obj_types variant
void(* free)(resource_t *)
void common_free(resource_t *rsc)
#define status_print(fmt, args...)
int crm_parse_int(const char *text, const char *default_text)
node_t * pe_find_node(GListPtr node_list, const char *uname)
#define XML_RSC_ATTR_STICKINESS
void force_non_unique_clone(resource_t *rsc, const char *rid, pe_working_set_t *data_set)
gboolean master_unpack(resource_t *rsc, pe_working_set_t *data_set)
gboolean clone_active(resource_t *rsc, gboolean all)
#define XML_RSC_ATTR_MASTER_NODEMAX
#define XML_RSC_ATTR_INCARNATION_MAX
xmlNode * copy_xml(xmlNode *src_node)
const char * role2text(enum rsc_role_e role)
gboolean(* active)(resource_t *, gboolean)
struct node_shared_s * details
#define set_bit(word, bit)
void clone_free(resource_t *rsc)
enum rsc_role_e clone_resource_state(const resource_t *rsc, gboolean current)
char * add_list_element(char *list, const char *value)
#define XML_CIB_TAG_RESOURCE
resource_object_functions_t * fns
GHashTable * allowed_nodes
#define XML_RSC_ATTR_ORDERED
const char * crm_element_value(xmlNode *data, const char *name)
#define XML_RSC_ATTR_INCARNATION_NODEMAX
#define XML_RSC_ATTR_TARGET_ROLE
void free_xml(xmlNode *child)
enum rsc_role_e text2role(const char *role)
gboolean crm_str_eq(const char *a, const char *b, gboolean use_case)
#define XML_RSC_ATTR_UNIQUE
void clone_print(resource_t *rsc, const char *pre_text, long options, void *print_data)
#define crm_config_warn(fmt...)
const char * crm_xml_add(xmlNode *node, const char *name, const char *value)
#define XML_RSC_ATTR_MASTER_MAX
resource_t * create_child_clone(resource_t *rsc, int sub_id, pe_working_set_t *data_set)
void add_hash_param(GHashTable *hash, const char *name, const char *value)
void(* print)(resource_t *, const char *, long, void *)
enum rsc_role_e(* state)(const resource_t *, gboolean)
#define pe_rsc_failure_ignored
resource_t * find_clone_instance(resource_t *rsc, const char *sub_id, pe_working_set_t *data_set)
bool is_set_recursive(resource_t *rsc, long long flag, bool any)
void clear_bit_recursive(resource_t *rsc, unsigned long long flag)
gboolean crm_is_true(const char *s)
#define XML_CIB_TAG_GROUP
#define pe_rsc_trace(rsc, fmt, args...)
char * crm_concat(const char *prefix, const char *suffix, char join)
void print_resource(int log_level, const char *pre_text, resource_t *rsc, gboolean details)
char * crm_itoa(int an_int)
resource_t * pe_find_resource(GListPtr rsc_list, const char *id_rh)
#define XML_RSC_ATTR_INTERLEAVE
gint sort_node_uname(gconstpointer a, gconstpointer b)
enum crm_ais_msg_types type