 |
pacemaker
2.1.9-49aab99839
Scalable High-Availability cluster resource manager
|
|
pacemaker
2.1.9-49aab99839
Scalable High-Availability cluster resource manager
|
#include <crm_internal.h>#include <arpa/inet.h>#include <inttypes.h>#include <netdb.h>#include <netinet/in.h>#include <stdbool.h>#include <stdint.h>#include <sys/socket.h>#include <sys/types.h>#include <sys/utsname.h>#include <bzlib.h>#include <corosync/corodefs.h>#include <corosync/corotypes.h>#include <corosync/hdb.h>#include <corosync/cpg.h>#include <qb/qbipc_common.h>#include <qb/qbipcc.h>#include <qb/qbutil.h>#include <crm/cluster/internal.h>#include <crm/common/ipc.h>#include <crm/common/ipc_internal.h>#include <crm/common/mainloop.h>#include <crm/common/xml.h>#include "crmcluster_private.h"#include <crm/cluster/compat.h>
Go to the source code of this file.
Macros | |
| #define | msg_data_len(msg) (msg->is_compressed?msg->compressed_size:msg->size) |
| #define | cs_repeat(rc, counter, max, code) |
| #define | CS_SEND_MAX 200 |
Typedefs | |
| typedef struct pcmk__cpg_host_s | pcmk__cpg_host_t |
| typedef struct pcmk__cpg_msg_s | pcmk__cpg_msg_t |
Functions | |
| struct pcmk__cpg_host_s | __attribute__ ((packed)) |
| struct qb_ipc_response_header header | __attribute__ ((aligned(8))) |
| uint32_t | pcmk__cpg_local_nodeid (cpg_handle_t handle) |
| char * | pcmk__cpg_message_data (cpg_handle_t handle, uint32_t sender_id, uint32_t pid, void *content, uint32_t *kind, const char **from) |
| void | pcmk__cpg_confchg_cb (cpg_handle_t handle, const struct cpg_name *group_name, const struct cpg_address *member_list, size_t member_list_entries, const struct cpg_address *left_list, size_t left_list_entries, const struct cpg_address *joined_list, size_t joined_list_entries) |
| int | pcmk_cpg_set_deliver_fn (pcmk_cluster_t *cluster, cpg_deliver_fn_t fn) |
| Set the CPG deliver callback function for a cluster object. More... | |
| int | pcmk_cpg_set_confchg_fn (pcmk_cluster_t *cluster, cpg_confchg_fn_t fn) |
| Set the CPG config change callback function for a cluster object. More... | |
| int | pcmk__cpg_connect (pcmk_cluster_t *cluster) |
| Connect to Corosync CPG. More... | |
| void | pcmk__cpg_disconnect (pcmk_cluster_t *cluster) |
| bool | pcmk__cpg_send_xml (const xmlNode *msg, const crm_node_t *node, enum crm_ais_msg_types dest) |
| gboolean | cluster_connect_cpg (pcmk_cluster_t *cluster) |
| void | cluster_disconnect_cpg (pcmk_cluster_t *cluster) |
| uint32_t | get_local_nodeid (cpg_handle_t handle) |
| void | pcmk_cpg_membership (cpg_handle_t handle, const struct cpg_name *group_name, const struct cpg_address *member_list, size_t member_list_entries, const struct cpg_address *left_list, size_t left_list_entries, const struct cpg_address *joined_list, size_t joined_list_entries) |
| gboolean | send_cluster_text (enum crm_ais_msg_class msg_class, const char *data, gboolean local, const crm_node_t *node, enum crm_ais_msg_types dest) |
| char * | pcmk_message_common_cs (cpg_handle_t handle, uint32_t nodeid, uint32_t pid, void *content, uint32_t *kind, const char **from) |
| enum crm_ais_msg_types | text2msg_type (const char *text) |
Variables | |
| uint32_t | id |
| uint32_t | pid |
| gboolean | local |
| enum crm_ais_msg_types | type |
| uint32_t | size |
| char | uname [MAX_NAME] |
| gboolean | is_compressed |
| pcmk__cpg_host_t | host |
| pcmk__cpg_host_t | sender |
| uint32_t | compressed_size |
| char | data [0] |
| #define cs_repeat | ( | rc, | |
| counter, | |||
| max, | |||
| code | |||
| ) |
| #define msg_data_len | ( | msg | ) | (msg->is_compressed?msg->compressed_size:msg->size) |
| typedef struct pcmk__cpg_host_s pcmk__cpg_host_t |
| typedef struct pcmk__cpg_msg_s pcmk__cpg_msg_t |
| struct pcmk__cpg_host_s __attribute__ | ( | (packed) | ) |
| struct qb_ipc_response_header header __attribute__::__attribute__ | ( | (aligned(8)) | ) |
| gboolean cluster_connect_cpg | ( | pcmk_cluster_t * | cluster | ) |
| void cluster_disconnect_cpg | ( | pcmk_cluster_t * | cluster | ) |
| void pcmk__cpg_confchg_cb | ( | cpg_handle_t | handle, |
| const struct cpg_name * | group_name, | ||
| const struct cpg_address * | member_list, | ||
| size_t | member_list_entries, | ||
| const struct cpg_address * | left_list, | ||
| size_t | left_list_entries, | ||
| const struct cpg_address * | joined_list, | ||
| size_t | joined_list_entries | ||
| ) |
| int pcmk__cpg_connect | ( | pcmk_cluster_t * | cluster | ) |
| void pcmk__cpg_disconnect | ( | pcmk_cluster_t * | cluster | ) |
| char* pcmk__cpg_message_data | ( | cpg_handle_t | handle, |
| uint32_t | sender_id, | ||
| uint32_t | pid, | ||
| void * | content, | ||
| uint32_t * | kind, | ||
| const char ** | from | ||
| ) |
| bool pcmk__cpg_send_xml | ( | const xmlNode * | msg, |
| const crm_node_t * | node, | ||
| enum crm_ais_msg_types | dest | ||
| ) |
| void pcmk_cpg_membership | ( | cpg_handle_t | handle, |
| const struct cpg_name * | group_name, | ||
| const struct cpg_address * | member_list, | ||
| size_t | member_list_entries, | ||
| const struct cpg_address * | left_list, | ||
| size_t | left_list_entries, | ||
| const struct cpg_address * | joined_list, | ||
| size_t | joined_list_entries | ||
| ) |
| int pcmk_cpg_set_confchg_fn | ( | pcmk_cluster_t * | cluster, |
| cpg_confchg_fn_t | fn | ||
| ) |
| int pcmk_cpg_set_deliver_fn | ( | pcmk_cluster_t * | cluster, |
| cpg_deliver_fn_t | fn | ||
| ) |
| char* pcmk_message_common_cs | ( | cpg_handle_t | handle, |
| uint32_t | nodeid, | ||
| uint32_t | pid, | ||
| void * | content, | ||
| uint32_t * | kind, | ||
| const char ** | from | ||
| ) |
| gboolean send_cluster_text | ( | enum crm_ais_msg_class | msg_class, |
| const char * | data, | ||
| gboolean | local, | ||
| const crm_node_t * | node, | ||
| enum crm_ais_msg_types | dest | ||
| ) |
| enum crm_ais_msg_types text2msg_type | ( | const char * | text | ) |
| pcmk__cpg_host_t host |
| pcmk__cpg_host_t sender |
| enum crm_ais_msg_types type |
1.8.14