![]() |
pacemaker
2.0.3-4b1f869f0f
Scalable High-Availability cluster resource manager
|
#include <config.h>#include <portability.h>#include <glib.h>#include <stdbool.h>#include <libxml/tree.h>#include <crm/lrmd.h>#include <crm/common/logging.h>#include <crm/common/ipcs.h>#include <crm/common/internal.h>#include <string.h>#include <getopt.h>#include <qb/qbipc_common.h>#include <corosync/corotypes.h>
Go to the source code of this file.
Data Structures | |
| struct | crm_option |
| struct | pe_cluster_option_s |
| struct | remote_proxy_s |
Macros | |
| #define | pcmk_option_default 0x00000 |
| #define | pcmk_option_hidden 0x00001 |
| #define | pcmk_option_paragraph 0x00002 |
| #define | pcmk_option_example 0x00004 |
| #define | CRM_OP_FMT "%s_%s_%u" |
| #define | set_bit(word, bit) word = crm_set_bit(__FUNCTION__, __LINE__, NULL, word, bit) |
| #define | clear_bit(word, bit) word = crm_clear_bit(__FUNCTION__, __LINE__, NULL, word, bit) |
| #define | crm_config_err(fmt...) { crm_config_error = TRUE; crm_err(fmt); } |
| #define | crm_config_warn(fmt...) { crm_config_warning = TRUE; crm_warn(fmt); } |
| #define | F_ATTRD_KEY "attr_key" |
| #define | F_ATTRD_ATTRIBUTE "attr_name" |
| #define | F_ATTRD_REGEX "attr_regex" |
| #define | F_ATTRD_TASK "task" |
| #define | F_ATTRD_VALUE "attr_value" |
| #define | F_ATTRD_SET "attr_set" |
| #define | F_ATTRD_IS_REMOTE "attr_is_remote" |
| #define | F_ATTRD_IS_PRIVATE "attr_is_private" |
| #define | F_ATTRD_SECTION "attr_section" |
| #define | F_ATTRD_DAMPEN "attr_dampening" |
| #define | F_ATTRD_HOST "attr_host" |
| #define | F_ATTRD_HOST_ID "attr_host_id" |
| #define | F_ATTRD_USER "attr_user" |
| #define | F_ATTRD_WRITER "attr_writer" |
| #define | F_ATTRD_VERSION "attr_version" |
| #define | F_ATTRD_RESOURCE "attr_resource" |
| #define | F_ATTRD_OPERATION "attr_clear_operation" |
| #define | F_ATTRD_INTERVAL "attr_clear_interval" |
| #define | F_ATTRD_IS_FORCE_WRITE "attrd_is_force_write" |
| #define | ATTRD_OP_PEER_REMOVE "peer-remove" |
| #define | ATTRD_OP_UPDATE "update" |
| #define | ATTRD_OP_UPDATE_BOTH "update-both" |
| #define | ATTRD_OP_UPDATE_DELAY "update-delay" |
| #define | ATTRD_OP_QUERY "query" |
| #define | ATTRD_OP_REFRESH "refresh" |
| #define | ATTRD_OP_FLUSH "flush" |
| #define | ATTRD_OP_SYNC "sync" |
| #define | ATTRD_OP_SYNC_RESPONSE "sync-response" |
| #define | ATTRD_OP_CLEAR_FAILURE "clear-failure" |
| #define | PCMK_ENV_PHYSICAL_HOST "physical_host" |
Typedefs | |
| typedef struct pe_cluster_option_s | pe_cluster_option |
| typedef struct qb_ipc_request_header | cs_ipc_header_request_t |
| typedef struct qb_ipc_response_header | cs_ipc_header_response_t |
| typedef struct remote_proxy_s | remote_proxy_t |
Functions | |
| void * | find_library_function (void **handle, const char *lib, const char *fn, int fatal) |
| char * | uid2username (uid_t uid) |
| const char * | crm_acl_get_set_user (xmlNode *request, const char *field, const char *peer_user) |
| void | crm_set_options (const char *short_options, const char *usage, struct crm_option *long_options, const char *app_desc) |
| int | crm_get_option (int argc, char **argv, int *index) |
| int | crm_get_option_long (int argc, char **argv, int *index, const char **longname) |
| _Noreturn void | crm_help (char cmd, crm_exit_t exit_code) |
| const char * | cluster_option (GHashTable *options, gboolean(*validate)(const char *), const char *name, const char *old_name, const char *def_value) |
| const char * | get_cluster_pref (GHashTable *options, pe_cluster_option *option_list, int len, const char *name) |
| void | config_metadata (const char *name, const char *version, const char *desc_short, const char *desc_long, pe_cluster_option *option_list, int len) |
| void | verify_all_options (GHashTable *options, pe_cluster_option *option_list, int len) |
| gboolean | check_time (const char *value) |
| gboolean | check_timer (const char *value) |
| gboolean | check_boolean (const char *value) |
| gboolean | check_number (const char *value) |
| gboolean | check_positive_number (const char *value) |
| gboolean | check_quorum (const char *value) |
| gboolean | check_script (const char *value) |
| gboolean | check_utilization (const char *value) |
| long | crm_get_sbd_timeout (void) |
| long | crm_auto_watchdog_timeout (void) |
| gboolean | check_sbd_timeout (const char *value) |
| void | crm_args_fini (void) |
| void | crm_make_daemon (const char *name, gboolean daemonize, const char *pidfile) |
| char * | generate_hash_key (const char *crm_msg_reference, const char *sys) |
| const char * | daemon_option (const char *option) |
| void | set_daemon_option (const char *option, const char *value) |
| gboolean | daemon_option_enabled (const char *daemon, const char *option) |
| void | strip_text_nodes (xmlNode *xml) |
| void | pcmk_panic (const char *origin) |
| pid_t | pcmk_locate_sbd (void) |
| void | attrd_ipc_server_init (qb_ipcs_service_t **ipcs, struct qb_ipcs_service_handlers *cb) |
| void | stonith_ipc_server_init (qb_ipcs_service_t **ipcs, struct qb_ipcs_service_handlers *cb) |
| qb_ipcs_service_t * | crmd_ipc_server_init (struct qb_ipcs_service_handlers *cb) |
| void | cib_ipc_servers_init (qb_ipcs_service_t **ipcs_ro, qb_ipcs_service_t **ipcs_rw, qb_ipcs_service_t **ipcs_shm, struct qb_ipcs_service_handlers *ro_cb, struct qb_ipcs_service_handlers *rw_cb) |
| void | cib_ipc_servers_destroy (qb_ipcs_service_t *ipcs_ro, qb_ipcs_service_t *ipcs_rw, qb_ipcs_service_t *ipcs_shm) |
| const char * | crm_xml_add_last_written (xmlNode *xml_node) |
| void | crm_xml_dump (xmlNode *data, int options, char **buffer, int *offset, int *max, int depth) |
| void | crm_buffer_add_char (char **buffer, int *offset, int *max, char c) |
| gboolean | crm_digest_verify (xmlNode *input, const char *expected) |
| char * | crm_compat_realpath (const char *path) |
| remote_proxy_t * | remote_proxy_new (lrmd_t *lrmd, struct ipc_client_callbacks *proxy_callbacks, const char *node_name, const char *session_id, const char *channel) |
| int | remote_proxy_check (lrmd_t *lrmd, GHashTable *hash) |
| void | remote_proxy_cb (lrmd_t *lrmd, const char *node_name, xmlNode *msg) |
| void | remote_proxy_ack_shutdown (lrmd_t *lrmd) |
| Send an acknowledgment of a remote proxy shutdown request. More... | |
| void | remote_proxy_nack_shutdown (lrmd_t *lrmd) |
| We're not going to shutdown as response to a remote proxy shutdown request. More... | |
| int | remote_proxy_dispatch (const char *buffer, ssize_t length, gpointer userdata) |
| void | remote_proxy_disconnected (gpointer data) |
| void | remote_proxy_free (gpointer data) |
| void | remote_proxy_relay_event (remote_proxy_t *proxy, xmlNode *msg) |
| void | remote_proxy_relay_response (remote_proxy_t *proxy, xmlNode *msg, int msg_id) |
Variables | |
| int | node_score_red |
| int | node_score_green |
| int | node_score_yellow |
| #define ATTRD_OP_CLEAR_FAILURE "clear-failure" |
Definition at line 212 of file crm_internal.h.
| #define ATTRD_OP_FLUSH "flush" |
Definition at line 209 of file crm_internal.h.
| #define ATTRD_OP_PEER_REMOVE "peer-remove" |
Definition at line 203 of file crm_internal.h.
| #define ATTRD_OP_QUERY "query" |
Definition at line 207 of file crm_internal.h.
| #define ATTRD_OP_REFRESH "refresh" |
Definition at line 208 of file crm_internal.h.
| #define ATTRD_OP_SYNC "sync" |
Definition at line 210 of file crm_internal.h.
| #define ATTRD_OP_SYNC_RESPONSE "sync-response" |
Definition at line 211 of file crm_internal.h.
| #define ATTRD_OP_UPDATE "update" |
Definition at line 204 of file crm_internal.h.
| #define ATTRD_OP_UPDATE_BOTH "update-both" |
Definition at line 205 of file crm_internal.h.
| #define ATTRD_OP_UPDATE_DELAY "update-delay" |
Definition at line 206 of file crm_internal.h.
| #define clear_bit | ( | word, | |
| bit | |||
| ) | word = crm_clear_bit(__FUNCTION__, __LINE__, NULL, word, bit) |
Definition at line 168 of file crm_internal.h.
| #define crm_config_err | ( | fmt... | ) | { crm_config_error = TRUE; crm_err(fmt); } |
Definition at line 179 of file crm_internal.h.
| #define crm_config_warn | ( | fmt... | ) | { crm_config_warning = TRUE; crm_warn(fmt); } |
Definition at line 180 of file crm_internal.h.
| #define CRM_OP_FMT "%s_%s_%u" |
Definition at line 133 of file crm_internal.h.
| #define F_ATTRD_ATTRIBUTE "attr_name" |
Definition at line 183 of file crm_internal.h.
| #define F_ATTRD_DAMPEN "attr_dampening" |
Definition at line 191 of file crm_internal.h.
| #define F_ATTRD_HOST "attr_host" |
Definition at line 192 of file crm_internal.h.
| #define F_ATTRD_HOST_ID "attr_host_id" |
Definition at line 193 of file crm_internal.h.
| #define F_ATTRD_INTERVAL "attr_clear_interval" |
Definition at line 199 of file crm_internal.h.
| #define F_ATTRD_IS_FORCE_WRITE "attrd_is_force_write" |
Definition at line 200 of file crm_internal.h.
| #define F_ATTRD_IS_PRIVATE "attr_is_private" |
Definition at line 189 of file crm_internal.h.
| #define F_ATTRD_IS_REMOTE "attr_is_remote" |
Definition at line 188 of file crm_internal.h.
| #define F_ATTRD_KEY "attr_key" |
Definition at line 182 of file crm_internal.h.
| #define F_ATTRD_OPERATION "attr_clear_operation" |
Definition at line 198 of file crm_internal.h.
| #define F_ATTRD_REGEX "attr_regex" |
Definition at line 184 of file crm_internal.h.
| #define F_ATTRD_RESOURCE "attr_resource" |
Definition at line 197 of file crm_internal.h.
| #define F_ATTRD_SECTION "attr_section" |
Definition at line 190 of file crm_internal.h.
| #define F_ATTRD_SET "attr_set" |
Definition at line 187 of file crm_internal.h.
| #define F_ATTRD_TASK "task" |
Definition at line 185 of file crm_internal.h.
| #define F_ATTRD_USER "attr_user" |
Definition at line 194 of file crm_internal.h.
| #define F_ATTRD_VALUE "attr_value" |
Definition at line 186 of file crm_internal.h.
| #define F_ATTRD_VERSION "attr_version" |
Definition at line 196 of file crm_internal.h.
| #define F_ATTRD_WRITER "attr_writer" |
Definition at line 195 of file crm_internal.h.
| #define PCMK_ENV_PHYSICAL_HOST "physical_host" |
Definition at line 214 of file crm_internal.h.
| #define pcmk_option_default 0x00000 |
Definition at line 56 of file crm_internal.h.
| #define pcmk_option_example 0x00004 |
Definition at line 59 of file crm_internal.h.
| #define pcmk_option_hidden 0x00001 |
Definition at line 57 of file crm_internal.h.
| #define pcmk_option_paragraph 0x00002 |
Definition at line 58 of file crm_internal.h.
| #define set_bit | ( | word, | |
| bit | |||
| ) | word = crm_set_bit(__FUNCTION__, __LINE__, NULL, word, bit) |
Definition at line 167 of file crm_internal.h.
| typedef struct qb_ipc_request_header cs_ipc_header_request_t |
Definition at line 220 of file crm_internal.h.
| typedef struct qb_ipc_response_header cs_ipc_header_response_t |
Definition at line 221 of file crm_internal.h.
| typedef struct pe_cluster_option_s pe_cluster_option |
| typedef struct remote_proxy_s remote_proxy_t |
| void attrd_ipc_server_init | ( | qb_ipcs_service_t ** | ipcs, |
| struct qb_ipcs_service_handlers * | cb | ||
| ) |
| gboolean check_sbd_timeout | ( | const char * | value | ) |
Definition at line 234 of file watchdog.c.
| void cib_ipc_servers_destroy | ( | qb_ipcs_service_t * | ipcs_ro, |
| qb_ipcs_service_t * | ipcs_rw, | ||
| qb_ipcs_service_t * | ipcs_shm | ||
| ) |
| void cib_ipc_servers_init | ( | qb_ipcs_service_t ** | ipcs_ro, |
| qb_ipcs_service_t ** | ipcs_rw, | ||
| qb_ipcs_service_t ** | ipcs_shm, | ||
| struct qb_ipcs_service_handlers * | ro_cb, | ||
| struct qb_ipcs_service_handlers * | rw_cb | ||
| ) |
| const char* cluster_option | ( | GHashTable * | options, |
| gboolean(*)(const char *) | validate, | ||
| const char * | name, | ||
| const char * | old_name, | ||
| const char * | def_value | ||
| ) |
| void config_metadata | ( | const char * | name, |
| const char * | version, | ||
| const char * | desc_short, | ||
| const char * | desc_long, | ||
| pe_cluster_option * | option_list, | ||
| int | len | ||
| ) |
| const char* crm_acl_get_set_user | ( | xmlNode * | request, |
| const char * | field, | ||
| const char * | peer_user | ||
| ) |
| long crm_auto_watchdog_timeout | ( | void | ) |
Definition at line 226 of file watchdog.c.
| void crm_buffer_add_char | ( | char ** | buffer, |
| int * | offset, | ||
| int * | max, | ||
| char | c | ||
| ) |
| gboolean crm_digest_verify | ( | xmlNode * | input, |
| const char * | expected | ||
| ) |
| int crm_get_option_long | ( | int | argc, |
| char ** | argv, | ||
| int * | index, | ||
| const char ** | longname | ||
| ) |
| long crm_get_sbd_timeout | ( | void | ) |
Definition at line 215 of file watchdog.c.
| _Noreturn void crm_help | ( | char | cmd, |
| crm_exit_t | exit_code | ||
| ) |
| void crm_make_daemon | ( | const char * | name, |
| gboolean | daemonize, | ||
| const char * | pidfile | ||
| ) |
| void crm_set_options | ( | const char * | short_options, |
| const char * | usage, | ||
| struct crm_option * | long_options, | ||
| const char * | app_desc | ||
| ) |
| void crm_xml_dump | ( | xmlNode * | data, |
| int | options, | ||
| char ** | buffer, | ||
| int * | offset, | ||
| int * | max, | ||
| int | depth | ||
| ) |
| qb_ipcs_service_t* crmd_ipc_server_init | ( | struct qb_ipcs_service_handlers * | cb | ) |
| gboolean daemon_option_enabled | ( | const char * | daemon, |
| const char * | option | ||
| ) |
| void* find_library_function | ( | void ** | handle, |
| const char * | lib, | ||
| const char * | fn, | ||
| int | fatal | ||
| ) |
| char* generate_hash_key | ( | const char * | crm_msg_reference, |
| const char * | sys | ||
| ) |
| const char* get_cluster_pref | ( | GHashTable * | options, |
| pe_cluster_option * | option_list, | ||
| int | len, | ||
| const char * | name | ||
| ) |
| pid_t pcmk_locate_sbd | ( | void | ) |
Definition at line 175 of file watchdog.c.
| void pcmk_panic | ( | const char * | origin | ) |
Definition at line 144 of file watchdog.c.
| void remote_proxy_ack_shutdown | ( | lrmd_t * | lrmd | ) |
Send an acknowledgment of a remote proxy shutdown request.
| [in] | lrmd | Connection to proxy |
Definition at line 42 of file proxy_common.c.
| void remote_proxy_cb | ( | lrmd_t * | lrmd, |
| const char * | node_name, | ||
| xmlNode * | msg | ||
| ) |
Definition at line 203 of file proxy_common.c.
| int remote_proxy_check | ( | lrmd_t * | lrmd, |
| GHashTable * | hash | ||
| ) |
Definition at line 874 of file lrmd_client.c.
| void remote_proxy_disconnected | ( | gpointer | data | ) |
Definition at line 145 of file proxy_common.c.
| int remote_proxy_dispatch | ( | const char * | buffer, |
| ssize_t | length, | ||
| gpointer | userdata | ||
| ) |
Definition at line 116 of file proxy_common.c.
| void remote_proxy_free | ( | gpointer | data | ) |
Definition at line 105 of file proxy_common.c.
| void remote_proxy_nack_shutdown | ( | lrmd_t * | lrmd | ) |
We're not going to shutdown as response to a remote proxy shutdown request.
| [in] | lrmd | Connection to proxy |
Definition at line 57 of file proxy_common.c.
| remote_proxy_t* remote_proxy_new | ( | lrmd_t * | lrmd, |
| struct ipc_client_callbacks * | proxy_callbacks, | ||
| const char * | node_name, | ||
| const char * | session_id, | ||
| const char * | channel | ||
| ) |
Definition at line 163 of file proxy_common.c.
| void remote_proxy_relay_event | ( | remote_proxy_t * | proxy, |
| xmlNode * | msg | ||
| ) |
Definition at line 66 of file proxy_common.c.
| void remote_proxy_relay_response | ( | remote_proxy_t * | proxy, |
| xmlNode * | msg, | ||
| int | msg_id | ||
| ) |
Definition at line 79 of file proxy_common.c.
| void set_daemon_option | ( | const char * | option, |
| const char * | value | ||
| ) |
| void stonith_ipc_server_init | ( | qb_ipcs_service_t ** | ipcs, |
| struct qb_ipcs_service_handlers * | cb | ||
| ) |
| char* uid2username | ( | uid_t | uid | ) |
| void verify_all_options | ( | GHashTable * | options, |
| pe_cluster_option * | option_list, | ||
| int | len | ||
| ) |
1.8.17