 |
pacemaker
2.0.1-9e909a5bdd
Scalable High-Availability cluster resource manager
|
Go to the documentation of this file.
8 #ifndef CRM_CLUSTER_INTERNAL__H
9 # define CRM_CLUSTER_INTERNAL__H
65 crm_get_cluster_proc()
77 static inline const char *
80 const char *text =
"unknown";
87 text =
"pacemaker-based";
90 text =
"pacemaker-controld";
93 text =
"pacemaker-schedulerd";
96 text =
"pacemaker-execd";
99 text =
"pacemaker-attrd";
102 text =
"pacemaker-fenced";
105 text =
"corosync-cpg";
111 static inline const char *
123 # define ais_data_len(msg) (msg->is_compressed?msg->compressed_size:msg->size)
159 static inline const char *
160 ais_error2text(
int error)
162 const char *text =
"unknown";
164 # if SUPPORT_COROSYNC
170 text =
"Library error";
173 text =
"Version error";
176 text =
"Initialization error";
181 case CS_ERR_TRY_AGAIN:
184 case CS_ERR_INVALID_PARAM:
185 text =
"Invalid parameter";
187 case CS_ERR_NO_MEMORY:
190 case CS_ERR_BAD_HANDLE:
197 text =
"Access error";
199 case CS_ERR_NOT_EXIST:
200 text =
"Doesn't exist";
202 case CS_ERR_NAME_TOO_LONG:
203 text =
"Name too long";
208 case CS_ERR_NO_SPACE:
211 case CS_ERR_INTERRUPT:
214 case CS_ERR_NAME_NOT_FOUND:
215 text =
"Name not found";
217 case CS_ERR_NO_RESOURCES:
218 text =
"No resources";
220 case CS_ERR_NOT_SUPPORTED:
221 text =
"Not supported";
223 case CS_ERR_BAD_OPERATION:
224 text =
"Bad operation";
226 case CS_ERR_FAILED_OPERATION:
227 text =
"Failed operation";
229 case CS_ERR_MESSAGE_ERROR:
230 text =
"Message error";
232 case CS_ERR_QUEUE_FULL:
235 case CS_ERR_QUEUE_NOT_AVAILABLE:
236 text =
"Queue not available";
238 case CS_ERR_BAD_FLAGS:
244 case CS_ERR_NO_SECTIONS:
245 text =
"No sections";
252 static inline const char *
255 const char *text =
"unknown";
294 # if SUPPORT_COROSYNC
318 const char *state,
int membership);
325 void (*destroy) (gpointer));
enum cluster_type_e find_corosync_variant(void)
gboolean check_message_sanity(const AIS_Message *msg, const char *data)
gboolean init_cs_connection_once(crm_cluster_t *cluster)
gboolean send_cluster_message_cs(xmlNode *msg, gboolean local, crm_node_t *node, enum crm_ais_msg_types dest)
gboolean cluster_connect_quorum(gboolean(*dispatch)(unsigned long long, gboolean), void(*destroy)(gpointer))
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)
enum crm_ais_msg_types type
cs_ipc_header_response_t header __attribute__((aligned(8)))
int corosync_cmap_has_config(const char *prefix)
void crm_reap_unseen_nodes(uint64_t ring_id)
char * get_corosync_uuid(crm_node_t *node)
crm_node_t * crm_update_peer_proc(const char *source, crm_node_t *peer, uint32_t flag, const char *status)
gboolean send_cpg_iov(struct iovec *iov)
enum crm_proc_flag __attribute__
void crm_peer_caches_refresh(xmlNode *cib)
gboolean node_name_is_valid(const char *key, const char *name)
crm_node_t * crm_find_peer(unsigned int id, const char *uname)
gboolean corosync_initialize_nodelist(void *cluster, gboolean force_member, xmlNode *xml_parent)
struct qb_ipc_response_header cs_ipc_header_response_t
void terminate_cs_connection(crm_cluster_t *cluster)
void crm_update_peer_uname(crm_node_t *node, const char *uname)
enum crm_ais_msg_types type
char * corosync_node_name(uint64_t cmap_handle, uint32_t nodeid)
crm_node_t * crm_update_peer_state(const char *source, crm_node_t *node, const char *state, int membership)
Update a node's state and membership information.
char * corosync_cluster_name(void)
void crm_update_peer_expected(const char *source, crm_node_t *node, const char *expected)
gboolean init_cs_connection(crm_cluster_t *cluster)
enum cluster_type_e get_cluster_type(void)