 |
pacemaker
1.1.18-7fdfbbe
Scalable High-Availability cluster resource manager
|
|
pacemaker
1.1.18-7fdfbbe
Scalable High-Availability cluster resource manager
|
#include <crm_internal.h>#include <crm/cluster/internal.h>#include <sys/types.h>#include <sys/uio.h>#include <sys/socket.h>#include <sys/un.h>#include <netinet/in.h>#include <arpa/inet.h>#include <unistd.h>#include <fcntl.h>#include <stdlib.h>#include <stdio.h>#include <errno.h>#include <signal.h>#include <string.h>#include <corosync/totem/totempg.h>#include <corosync/engine/objdb.h>#include <corosync/engine/config.h>#include <config.h>#include "plugin.h"#include "utils.h"#include <glib.h>#include <sys/resource.h>#include <sys/utsname.h>#include <sys/wait.h>#include <sys/stat.h>#include <pthread.h>#include <bzlib.h>#include <pwd.h>
Go to the source code of this file.
Macros | |
| #define | MAX_RESPAWN 100 |
| #define | LOOPBACK_ID 16777343 |
| #define | crm_flag_none 0x00000000 |
| #define | crm_flag_members 0x00000001 |
| #define | min(x, y) (x)<(y)?(x):(y) |
Typedefs | |
| typedef const void | ais_void_ptr |
Functions | |
| struct crm_identify_msg_s | __attribute__ ((packed)) |
| cs_ipc_header_request_t header | __attribute__ ((aligned(8))) |
| void | send_cluster_id (void) |
| int | send_plugin_msg_raw (const AIS_Message *ais_msg) |
| char * | pcmk_generate_membership_data (void) |
| gboolean | check_message_sanity (const AIS_Message *msg, const char *data) |
| int | pcmk_shutdown (void) |
| void | pcmk_peer_update (enum totem_configuration_type configuration_type, const unsigned int *member_list, size_t member_list_entries, const unsigned int *left_list, size_t left_list_entries, const unsigned int *joined_list, size_t joined_list_entries, const struct memb_ring_id *ring_id) |
| int | pcmk_startup (struct corosync_api_v1 *corosync_api) |
| int | pcmk_config_init (struct corosync_api_v1 *corosync_api) |
| int | pcmk_ipc_exit (void *conn) |
| int | pcmk_ipc_connect (void *conn) |
| void | pcmk_ipc (void *conn, ais_void_ptr *msg) |
| void | pcmk_exec_dump (void) |
| void | pcmk_cluster_swab (void *msg) |
| void | pcmk_cluster_callback (ais_void_ptr *message, unsigned int nodeid) |
| void | pcmk_nodeid (void *conn, ais_void_ptr *msg) |
| void | pcmk_nodes (void *conn, ais_void_ptr *msg) |
| void | pcmk_notify (void *conn, ais_void_ptr *msg) |
| void | pcmk_remove_member (void *conn, ais_void_ptr *msg) |
| void | pcmk_quorum (void *conn, ais_void_ptr *msg) |
| void | pcmk_cluster_id_swab (void *msg) |
| void | pcmk_cluster_id_callback (ais_void_ptr *message, unsigned int nodeid) |
| void | ais_remove_peer (char *node_id) |
| void | ais_remove_peer_by_name (const char *node_name) |
| struct corosync_service_engine * | pcmk_get_handler_ver0 (void) |
| void | member_loop_fn (gpointer key, gpointer value, gpointer user_data) |
| void | send_member_notification (void) |
| gboolean | route_ais_message (const AIS_Message *msg, gboolean local_origin) |
| gboolean | process_ais_message (const AIS_Message *msg) |
Variables | |
| struct corosync_api_v1 * | pcmk_api = NULL |
| uint32_t | plugin_has_votes = 0 |
| uint32_t | plugin_expected_votes = 2 |
| int | use_mgmtd = 0 |
| int | plugin_log_level = LOG_DEBUG |
| char * | local_uname = NULL |
| int | local_uname_len = 0 |
| char * | local_cname = NULL |
| int | local_cname_len = 0 |
| uint32_t | local_nodeid = 0 |
| char * | ipc_channel_name = NULL |
| uint64_t | membership_seq = 0 |
| pthread_t | pcmk_wait_thread |
| gboolean | use_mcp = FALSE |
| gboolean | wait_active = TRUE |
| gboolean | have_reliable_membership_id = FALSE |
| GHashTable * | ipc_client_list = NULL |
| GHashTable * | membership_list = NULL |
| GHashTable * | membership_notify_list = NULL |
| uint32_t | id |
| uint32_t | pid |
| int32_t | votes |
| uint32_t | processes |
| char | uname [256] |
| char | version [256] |
| uint64_t | born_on |
| struct corosync_service_engine | pcmk_service_handler |
| struct corosync_service_engine_iface_ver0 | pcmk_service_handler_iface |
| struct res_overlay | __attribute__ |
| struct res_overlay * | res_overlay = NULL |
| typedef const void ais_void_ptr |
| struct crm_identify_msg_s __attribute__ | ( | (packed) | ) |
| cs_ipc_header_request_t header __attribute__::__attribute__ | ( | (aligned(8)) | ) |
| gboolean check_message_sanity | ( | const AIS_Message * | msg, |
| const char * | data | ||
| ) |
| void member_loop_fn | ( | gpointer | key, |
| gpointer | value, | ||
| gpointer | user_data | ||
| ) |
| void pcmk_cluster_callback | ( | ais_void_ptr * | message, |
| unsigned int | nodeid | ||
| ) |
| void pcmk_cluster_id_callback | ( | ais_void_ptr * | message, |
| unsigned int | nodeid | ||
| ) |
| int pcmk_config_init | ( | struct corosync_api_v1 * | corosync_api | ) |
| struct corosync_service_engine * pcmk_get_handler_ver0 | ( | void | ) |
| void pcmk_ipc | ( | void * | conn, |
| ais_void_ptr * | msg | ||
| ) |
| void pcmk_nodeid | ( | void * | conn, |
| ais_void_ptr * | msg | ||
| ) |
| void pcmk_nodes | ( | void * | conn, |
| ais_void_ptr * | msg | ||
| ) |
| void pcmk_notify | ( | void * | conn, |
| ais_void_ptr * | msg | ||
| ) |
| void pcmk_peer_update | ( | enum totem_configuration_type | configuration_type, |
| const unsigned int * | member_list, | ||
| size_t | member_list_entries, | ||
| const unsigned int * | left_list, | ||
| size_t | left_list_entries, | ||
| const unsigned int * | joined_list, | ||
| size_t | joined_list_entries, | ||
| const struct memb_ring_id * | ring_id | ||
| ) |
| void pcmk_quorum | ( | void * | conn, |
| ais_void_ptr * | msg | ||
| ) |
| void pcmk_remove_member | ( | void * | conn, |
| ais_void_ptr * | msg | ||
| ) |
| gboolean process_ais_message | ( | const AIS_Message * | msg | ) |
| gboolean route_ais_message | ( | const AIS_Message * | msg, |
| gboolean | local_origin | ||
| ) |
| int send_plugin_msg_raw | ( | const AIS_Message * | ais_msg | ) |
| struct res_overlay __attribute__ |
| struct corosync_service_engine pcmk_service_handler |
| struct corosync_service_engine_iface_ver0 pcmk_service_handler_iface |
1.8.5