24 #include <sys/param.h> 25 #include <sys/types.h> 35 #define s_if_plural(i) (((i) == 1)? "" : "s") 68 static gboolean crm_autoreap = TRUE;
95 if (node_name == NULL) {
114 node->
uuid = strdup(node_name);
115 if (node->
uuid == NULL) {
123 crm_trace(
"added %s to remote cache", node_name);
148 crm_trace(
"removed %s from remote peer cache", node_name);
164 remote_state_from_cib(xmlNode *node_state)
178 struct refresh_data {
191 remote_cache_refresh_helper(xmlNode *result,
void *user_data)
193 struct refresh_data *
data = user_data;
195 const char *state = NULL;
201 if (data->has_state) {
202 state = remote_state_from_cib(result);
226 mark_dirty(gpointer key, gpointer value, gpointer user_data)
232 is_dirty(gpointer key, gpointer value, gpointer user_data)
238 #define XPATH_GUEST_NODE_CONFIG \ 239 "//" XML_TAG_CIB "//" XML_CIB_TAG_CONFIGURATION "//" XML_CIB_TAG_RESOURCE \ 240 "//" XML_TAG_META_SETS "//" XML_CIB_TAG_NVPAIR \ 241 "[@name='" XML_RSC_ATTR_REMOTE_NODE "']" 244 #define XPATH_REMOTE_NODE_CONFIG \ 245 "//" XML_TAG_CIB "//" XML_CIB_TAG_CONFIGURATION "//" XML_CIB_TAG_RESOURCE \ 246 "[@type='remote'][@provider='pacemaker']" 249 #define XPATH_REMOTE_NODE_STATUS \ 250 "//" XML_TAG_CIB "//" XML_CIB_TAG_STATUS "//" XML_CIB_TAG_STATE \ 251 "[@" XML_NODE_IS_REMOTE "='true']" 261 struct refresh_data data;
273 data.has_state = TRUE;
275 remote_cache_refresh_helper, &data);
283 data.field =
"value";
284 data.has_state = FALSE;
286 remote_cache_refresh_helper, &data);
288 data.has_state = FALSE;
290 remote_cache_refresh_helper, &data);
313 #if SUPPORT_HEARTBEAT 315 return crm_is_heartbeat_peer_active(node);
323 crm_reap_dead_member(gpointer key, gpointer value, gpointer user_data)
328 if (search == NULL) {
331 }
else if (search->
id && node->
id != search->
id) {
338 crm_info(
"Removing node with name %s and id %u from membership cache",
360 crm_trace(
"Membership cache not initialized, ignoring purge request");
365 search.
uname = name ? strdup(name) : NULL;
366 matches = g_hash_table_foreach_remove(
crm_peer_cache, crm_reap_dead_member, &search);
368 crm_notice(
"Purged %d peer%s with id=%u%s%s from the membership cache",
370 (search.
uname?
" and/or uname=" :
""),
374 crm_info(
"No peers with id=%u%s%s to purge from the membership cache",
375 search.
id, (search.
uname?
" and/or uname=" :
""),
384 crm_count_peer(gpointer key, gpointer value, gpointer user_data)
386 guint *count = user_data;
406 destroy_crm_node(gpointer
data)
491 crm_autoreap = autoreap;
494 static void crm_dump_peer_hash(
int level,
const char *caller)
497 const char *
id = NULL;
501 while (g_hash_table_iter_next(&iter, (gpointer *) &
id, (gpointer *) &node)) {
502 do_crm_log(level,
"%s: Node %u/%s = %p - %s", caller, node->id, node->uname, node,
id);
506 static gboolean crm_hash_find_by_data(gpointer key, gpointer value, gpointer user_data)
508 if(value == user_data) {
566 while (g_hash_table_iter_next(&iter, NULL, (gpointer *) &node)) {
567 if(node->uname && strcasecmp(node->uname, uname) == 0) {
568 crm_trace(
"Name match: %s = %p", node->uname, node);
577 while (g_hash_table_iter_next(&iter, NULL, (gpointer *) &node)) {
579 crm_trace(
"ID match: %u = %p", node->id, node);
587 if(by_id == by_name) {
589 crm_trace(
"Consistent: %p for %u/%s", by_id,
id, uname);
591 }
else if(by_id == NULL && by_name) {
592 crm_trace(
"Only one: %p for %u/%s", by_name,
id, uname);
594 if(
id && by_name->
id) {
595 crm_dump_peer_hash(LOG_WARNING, __FUNCTION__);
596 crm_crit(
"Node %u and %u share the same name '%s'",
597 id, by_name->
id, uname);
604 }
else if(by_name == NULL && by_id) {
605 crm_trace(
"Only one: %p for %u/%s", by_id,
id, uname);
607 if(uname && by_id->
uname) {
608 crm_dump_peer_hash(LOG_WARNING, __FUNCTION__);
609 crm_crit(
"Node '%s' and '%s' share the same cluster nodeid %u: assuming '%s' is correct",
610 uname, by_id->
uname,
id, uname);
613 }
else if(uname && by_id->
uname) {
615 crm_notice(
"Node '%s' has changed its ID from %u to %u", by_id->
uname, by_name->
id, by_id->
id);
616 g_hash_table_foreach_remove(
crm_peer_cache, crm_hash_find_by_data, by_name);
619 crm_warn(
"Node '%s' and '%s' share the same cluster nodeid: %u %s", by_id->
uname, by_name->
uname,
id, uname);
620 crm_dump_peer_hash(LOG_INFO, __FUNCTION__);
621 crm_abort(__FILE__, __FUNCTION__, __LINE__,
"member weirdness", TRUE, TRUE);
624 }
else if(
id && by_name->
id) {
625 crm_warn(
"Node %u and %u share the same name: '%s'", by_id->
id, by_name->
id, uname);
637 crm_dump_peer_hash(LOG_DEBUG, __FUNCTION__);
639 crm_info(
"Merging %p into %p", by_name, by_id);
640 g_hash_table_foreach_remove(
crm_peer_cache, crm_hash_find_by_data, by_name);
654 if (node->
id == 0 || node->
uname == NULL) {
665 while (g_hash_table_iter_next(&iter, NULL, (gpointer *) &existing_node)) {
666 if (existing_node->id > 0
667 && existing_node->id != node->
id 668 && existing_node->uname != NULL
669 && strcasecmp(existing_node->uname, node->
uname) == 0) {
675 crm_warn(
"Removing cached offline node %u/%s which has conflicting uname with %u",
676 existing_node->id, existing_node->uname, node->
id);
678 g_hash_table_iter_remove(&iter);
692 char *uname_lookup = NULL;
702 if ((node == NULL || node->
uname == NULL) && (uname == NULL)) {
707 uname = uname_lookup;
708 crm_trace(
"Inferred a name of '%s' for node %u", uname,
id);
723 crm_info(
"Created entry %s/%p for node %s/%u (%d total)",
724 uniqueid, node, uname,
id, 1 + g_hash_table_size(
crm_peer_cache));
728 if(
id > 0 && uname && (node->
id == 0 || node->
uname == NULL)) {
729 crm_info(
"Node %u is now known as %s",
id, uname);
732 if(
id > 0 && node->
id == 0) {
736 if (uname && (node->
uname == NULL)) {
740 if(node->
uuid == NULL) {
744 crm_info(
"Node %u has uuid %s",
id, uuid);
747 crm_info(
"Cannot obtain a UUID for node %u/%s",
id, node->
uname);
769 uint32_t children,
const char *uuid,
const char *
uname,
const char *addr,
773 gboolean addr_changed = FALSE;
774 gboolean votes_changed = FALSE;
783 if (node->
uuid == NULL) {
788 }
else if (uuid != NULL) {
789 node->
uuid = strdup(uuid);
804 #if SUPPORT_HEARTBEAT 816 if (votes > 0 && node->
votes != votes) {
817 votes_changed = TRUE;
825 node->
addr = strdup(addr);
828 if (addr_changed || votes_changed) {
829 crm_info(
"%s: Node %s: id=%u state=%s addr=%s%s votes=%d%s born=" U64T " seen=" U64T 830 " proc=%.32x", source, node->
uname, node->
id, node->
state,
831 node->
addr, addr_changed ?
" (new)" :
"", node->
votes,
854 crm_err(
"Bug: can't update node name without name");
return);
856 crm_err(
"Bug: can't update node name to %s without node", uname);
860 crm_debug(
"Node uname '%s' did not change", uname);
864 for (
const char *c = uname; *c; ++c) {
865 if ((*c >=
'A') && (*c <=
'Z')) {
866 crm_warn(
"Node names with capitals are discouraged, consider changing '%s'",
873 node->
uname = strdup(uname);
882 crm_remove_conflicting_peer(node);
907 gboolean changed = FALSE;
910 source, peer2text(flag), status);
return NULL);
918 if (status == NULL) {
931 if (flag > 0 && node->
processes != flag) {
944 crm_info(
"%s: Node %s[%u] - all processes are now offline", source, node->
uname,
947 crm_info(
"%s: Node %s[%u] - %s is now %s", source, node->
uname, node->
id,
948 peer2text(flag), status);
967 is_set(node->
processes, crm_get_cluster_proc())?
971 crm_trace(
"%s: Node %s[%u] - %s is unchanged (%s)", source, node->
uname, node->
id,
972 peer2text(flag), status);
981 gboolean changed = FALSE;
983 CRM_CHECK(node != NULL,
crm_err(
"%s: Could not set 'expected' to %s", source, expected);
998 crm_info(
"%s: Node %s[%u] - expected state is now %s (was %s)", source, node->
uname, node->
id,
1002 crm_trace(
"%s: Node %s[%u] - expected state is unchanged (%s)", source, node->
uname,
1003 node->
id, expected);
1024 crm_update_peer_state_iter(
const char *source,
crm_node_t * node,
const char *state, uint64_t membership,
GHashTableIter *iter)
1029 crm_err(
"Could not set state for unknown host to %s" 1030 CRM_XS " source=%s", state, source);
1034 if (membership && is_member) {
1039 char *last = node->
state;
1043 node->
state = strdup(state);
1045 " nodeid=%u previous=%s source=%s", node->
uname, state,
1046 node->
id, (last? last :
"unknown"), source);
1058 crm_notice(
"Purged 1 peer with id=%u and/or uname=%s from the membership cache", node->
id, node->
uname);
1059 g_hash_table_iter_remove(iter);
1069 " nodeid=%u source=%s", node->
uname, state, node->
id, source);
1092 return crm_update_peer_state_iter(source, node, state, membership, NULL);
1109 while (g_hash_table_iter_next(&iter, NULL, (gpointer *)&node)) {
1110 if (node->last_seen != membership) {
1117 crm_update_peer_state_iter(__FUNCTION__, node,
CRM_NODE_LOST, membership, &iter);
1120 crm_info(
"State of node %s[%u] is still unknown",
1121 node->uname, node->id);
1141 crm_find_known_peer(
const char *
id,
const char *
uname)
1150 while (g_hash_table_iter_next(&iter, NULL, (gpointer *) &node)) {
1151 if (node->uname && strcasecmp(node->uname, uname) == 0) {
1152 crm_trace(
"Name match: %s = %p", node->uname, node);
1161 while (g_hash_table_iter_next(&iter, NULL, (gpointer *) &node)) {
1162 if(strcasecmp(node->uuid,
id) == 0) {
1163 crm_trace(
"ID match: %s= %p",
id, node);
1171 if (by_id == by_name) {
1173 crm_trace(
"Consistent: %p for %s/%s", by_id,
id, uname);
1175 }
else if (by_id == NULL && by_name) {
1176 crm_trace(
"Only one: %p for %s/%s", by_name,
id, uname);
1185 }
else if (by_name == NULL && by_id) {
1186 crm_trace(
"Only one: %p for %s/%s", by_id,
id, uname);
1192 }
else if (uname && by_id->
uname 1197 }
else if (
id && by_name->
uuid 1211 uname?
" with name " :
"",
1219 known_peer_cache_refresh_helper(xmlNode *xml_node,
void *user_data)
1225 CRM_CHECK(
id != NULL && uname !=NULL,
return);
1226 node = crm_find_known_peer(
id, uname);
1234 node->
uname = strdup(uname);
1237 node->
uuid = strdup(
id);
1245 node->
uname = strdup(uname);
1255 #define XPATH_MEMBER_NODE_CONFIG \ 1256 "//" XML_TAG_CIB "/" XML_CIB_TAG_CONFIGURATION "/" XML_CIB_TAG_NODES \ 1257 "/" XML_CIB_TAG_NODE "[not(@type) or @type='member']" 1260 crm_known_peer_cache_refresh(xmlNode *cib)
1267 known_peer_cache_refresh_helper, NULL);
1277 crm_known_peer_cache_refresh(cib);
1284 char *id_str = NULL;
1298 node = crm_find_known_peer(id_str, uname);
#define CRM_CHECK(expr, failure_action)
void crm_remote_peer_cache_add(const char *node_name)
Add a node to the remote peer cache.
void crm_reap_unseen_nodes(uint64_t membership)
#define crm_notice(fmt, args...)
#define XPATH_REMOTE_NODE_STATUS
GHashTable * crm_peer_cache
gboolean is_openais_cluster(void)
#define crm_crit(fmt, args...)
gboolean safe_str_neq(const char *a, const char *b)
char * crm_generate_uuid(void)
void crm_peer_destroy(void)
gboolean is_heartbeat_cluster(void)
int stonith_api_kick(uint32_t nodeid, const char *uname, int timeout, bool off)
crm_node_t * crm_find_peer(unsigned int id, const char *uname)
int get_corosync_id(int id, const char *uuid)
crm_node_t * crm_find_known_peer_full(unsigned int id, const char *uname, int flags)
crm_node_t * crm_find_peer_full(unsigned int id, const char *uname, int flags)
GHashTable * crm_remote_peer_cache
#define clear_bit(word, bit)
unsigned long long crm_peer_seq
char * get_node_name(uint32_t nodeid)
void crm_set_autoreap(gboolean autoreap)
Tell the library whether to automatically reap lost nodes.
void crm_peer_caches_refresh(xmlNode *cib)
void crm_remote_peer_cache_remove(const char *node_name)
gboolean crm_is_corosync_peer_active(const crm_node_t *node)
crm_node_t * crm_update_peer_state(const char *source, crm_node_t *node, const char *state, uint64_t membership)
Update a node's state and membership information.
int crm_remote_peer_cache_size(void)
#define crm_warn(fmt, args...)
#define set_bit(word, bit)
crm_node_t * crm_get_peer_full(unsigned int id, const char *uname, int flags)
crm_node_t * crm_update_peer(const char *source, unsigned int id, uint64_t born, uint64_t seen, int32_t votes, uint32_t children, const char *uuid, const char *uname, const char *addr, const char *state)
guint reap_crm_member(uint32_t id, const char *name)
Remove all peer cache entries matching a node ID and/or uname.
gboolean crm_is_peer_active(const crm_node_t *node)
#define crm_debug(fmt, args...)
const char * crm_element_value(const xmlNode *data, const char *name)
Retrieve the value of an XML attribute.
#define XPATH_GUEST_NODE_CONFIG
void crm_update_peer_expected(const char *source, crm_node_t *node, const char *expected)
#define crm_trace(fmt, args...)
#define do_crm_log(level, fmt, args...)
Log a message.
guint crm_strcase_hash(gconstpointer v)
int corosync_cmap_has_config(const char *prefix)
void crm_update_peer_uname(crm_node_t *node, const char *uname)
gboolean crm_str_eq(const char *a, const char *b, gboolean use_case)
void crm_set_status_callback(void(*dispatch)(enum crm_status_type, crm_node_t *, const void *))
Set a client function that will be called after peer status changes.
const char * name_for_cluster_type(enum cluster_type_e type)
int crm_terminate_member(int nodeid, const char *uname, void *unused)
void(* crm_status_callback)(enum crm_status_type, crm_node_t *, const void *)
void crm_remote_peer_cache_refresh(xmlNode *cib)
Repopulate the remote peer cache based on CIB XML.
guint crm_active_peers(void)
crm_node_t * crm_remote_peer_get(const char *node_name)
Get a remote node peer cache entry, creating it if necessary.
#define crm_err(fmt, args...)
int crm_terminate_member_no_mainloop(int nodeid, const char *uname, int *connection)
void crm_foreach_xpath_result(xmlNode *xml, const char *xpath, void(*helper)(xmlNode *, void *), void *user_data)
Run a supplied function for each result of an xpath search.
Wrappers for and extensions to libqb IPC.
GHashTable * crm_known_peer_cache
crm_node_t * crm_update_peer_proc(const char *source, crm_node_t *node, uint32_t flag, const char *status)
#define XML_NODE_IN_CLUSTER
gboolean crm_is_true(const char *s)
#define safe_str_eq(a, b)
char * crm_strdup_printf(char const *format,...) __attribute__((__format__(__printf__
void crm_abort(const char *file, const char *function, int line, const char *condition, gboolean do_core, gboolean do_fork)
crm_node_t * crm_get_peer(unsigned int id, const char *uname)
#define XPATH_MEMBER_NODE_CONFIG
#define XPATH_REMOTE_NODE_CONFIG
#define crm_info(fmt, args...)
const char * crm_peer_uuid(crm_node_t *node)
enum cluster_type_e get_cluster_type(void)