pacemaker
2.1.5-b7adf64e51
Scalable High-Availability cluster resource manager
|
#include <stdint.h>
#include <string.h>
#include <crm/pengine/status.h>
#include <crm/pengine/remote_internal.h>
#include <crm/common/internal.h>
#include <crm/common/options_internal.h>
#include <crm/common/output_internal.h>
Go to the source code of this file.
Data Structures | |
struct | pe__location_constraint_s |
struct | pe__order_constraint_s |
struct | notify_data_s |
struct | op_digest_cache_s |
Macros | |
#define | pe_rsc_info(rsc, fmt, args...) crm_log_tag(LOG_INFO, rsc ? rsc->id : "<NULL>", fmt, ##args) |
#define | pe_rsc_debug(rsc, fmt, args...) crm_log_tag(LOG_DEBUG, rsc ? rsc->id : "<NULL>", fmt, ##args) |
#define | pe_rsc_trace(rsc, fmt, args...) crm_log_tag(LOG_TRACE, rsc ? rsc->id : "<NULL>", fmt, ##args) |
#define | pe_err(fmt...) |
#define | pe_warn(fmt...) |
#define | pe_proc_err(fmt...) { was_processing_error = TRUE; crm_err(fmt); } |
#define | pe_proc_warn(fmt...) { was_processing_warning = TRUE; crm_warn(fmt); } |
#define | pe__set_working_set_flags(working_set, flags_to_set) |
#define | pe__clear_working_set_flags(working_set, flags_to_clear) |
#define | pe__set_resource_flags(resource, flags_to_set) |
#define | pe__clear_resource_flags(resource, flags_to_clear) |
#define | pe__set_action_flags(action, flags_to_set) |
#define | pe__clear_action_flags(action, flags_to_clear) |
#define | pe__set_raw_action_flags(action_flags, action_name, flags_to_set) |
#define | pe__clear_raw_action_flags(action_flags, action_name, flags_to_clear) |
#define | pe__set_action_flags_as(function, line, action, flags_to_set) |
#define | pe__clear_action_flags_as(function, line, action, flags_to_clear) |
#define | pe__set_order_flags(order_flags, flags_to_set) |
#define | pe__clear_order_flags(order_flags, flags_to_clear) |
#define | pe_warn_once(pe_wo_bit, fmt...) |
#define | pe__show_node_weights(level, rsc, text, nodes, data_set) |
#define | delete_key(rsc) pcmk__op_key(rsc->id, CRMD_ACTION_DELETE, 0) |
#define | delete_action(rsc, node, optional) |
#define | stopped_key(rsc) pcmk__op_key(rsc->id, CRMD_ACTION_STOPPED, 0) |
#define | stopped_action(rsc, node, optional) |
#define | stop_key(rsc) pcmk__op_key(rsc->id, CRMD_ACTION_STOP, 0) |
#define | stop_action(rsc, node, optional) |
#define | reload_key(rsc) pcmk__op_key(rsc->id, CRMD_ACTION_RELOAD_AGENT, 0) |
#define | start_key(rsc) pcmk__op_key(rsc->id, CRMD_ACTION_START, 0) |
#define | start_action(rsc, node, optional) |
#define | started_key(rsc) pcmk__op_key(rsc->id, CRMD_ACTION_STARTED, 0) |
#define | started_action(rsc, node, optional) |
#define | promote_key(rsc) pcmk__op_key(rsc->id, CRMD_ACTION_PROMOTE, 0) |
#define | promote_action(rsc, node, optional) |
#define | promoted_key(rsc) pcmk__op_key(rsc->id, CRMD_ACTION_PROMOTED, 0) |
#define | promoted_action(rsc, node, optional) |
#define | demote_key(rsc) pcmk__op_key(rsc->id, CRMD_ACTION_DEMOTE, 0) |
#define | demote_action(rsc, node, optional) |
#define | demoted_key(rsc) pcmk__op_key(rsc->id, CRMD_ACTION_DEMOTED, 0) |
#define | demoted_action(rsc, node, optional) |
Typedefs | |
typedef struct pe__location_constraint_s | pe__location_t |
typedef struct pe__order_constraint_s | pe__ordering_t |
typedef struct notify_data_s | notify_data_t |
typedef struct op_digest_cache_s | op_digest_cache_t |
Enumerations | |
enum | pe__clone_flags { pe__clone_ordered = (1 << 0), pe__clone_promotion_added = (1 << 1), pe__clone_promotion_constrained = (1 << 2) } |
enum | pe__group_flags { pe__group_ordered = (1 << 0), pe__group_colocated = (1 << 1) } |
enum | pe_warn_once_e { pe_wo_blind = (1 << 0), pe_wo_restart_type = (1 << 1), pe_wo_role_after = (1 << 2), pe_wo_poweroff = (1 << 3), pe_wo_require_all = (1 << 4), pe_wo_order_score = (1 << 5), pe_wo_neg_threshold = (1 << 6), pe_wo_remove_after = (1 << 7), pe_wo_ping_node = (1 << 8), pe_wo_order_inst = (1 << 9), pe_wo_coloc_inst = (1 << 10), pe_wo_group_order = (1 << 11), pe_wo_group_coloc = (1 << 12) } |
enum | pe_fc_flags_e { pe_fc_default = (1 << 0), pe_fc_effective = (1 << 1), pe_fc_fillers = (1 << 2) } |
enum | rsc_digest_cmp_val { RSC_DIGEST_MATCH = 0, RSC_DIGEST_RESTART, RSC_DIGEST_ALL, RSC_DIGEST_UNKNOWN } |
Functions | |
bool | pe__clone_is_ordered (pe_resource_t *clone) |
int | pe__set_clone_flag (pe_resource_t *clone, enum pe__clone_flags flag) |
bool | pe__group_flag_is_set (const pe_resource_t *group, uint32_t flags) |
pe_resource_t * | pe__last_group_member (const pe_resource_t *group) |
int | pe__clone_promoted_max (pe_resource_t *clone) |
int | pe__clone_promoted_node_max (pe_resource_t *clone) |
pe_action_t * | pe__new_rsc_pseudo_action (pe_resource_t *rsc, const char *task, bool optional, bool runnable) |
void | pe__create_promotable_pseudo_ops (pe_resource_t *clone, bool any_promoting, bool any_demoting) |
bool | pe_can_fence (pe_working_set_t *data_set, pe_node_t *node) |
void | add_hash_param (GHashTable *hash, const char *name, const char *value) |
char * | native_parameter (pe_resource_t *rsc, pe_node_t *node, gboolean create, const char *name, pe_working_set_t *data_set) |
pe_node_t * | native_location (const pe_resource_t *rsc, GList **list, int current) |
void | pe_metadata (pcmk__output_t *out) |
void | verify_pe_options (GHashTable *options) |
void | common_update_score (pe_resource_t *rsc, const char *id, int score) |
void | native_add_running (pe_resource_t *rsc, pe_node_t *node, pe_working_set_t *data_set, gboolean failed) |
gboolean | native_unpack (pe_resource_t *rsc, pe_working_set_t *data_set) |
gboolean | group_unpack (pe_resource_t *rsc, pe_working_set_t *data_set) |
gboolean | clone_unpack (pe_resource_t *rsc, pe_working_set_t *data_set) |
gboolean | pe__unpack_bundle (pe_resource_t *rsc, pe_working_set_t *data_set) |
pe_resource_t * | native_find_rsc (pe_resource_t *rsc, const char *id, const pe_node_t *node, int flags) |
gboolean | native_active (pe_resource_t *rsc, gboolean all) |
gboolean | group_active (pe_resource_t *rsc, gboolean all) |
gboolean | clone_active (pe_resource_t *rsc, gboolean all) |
gboolean | pe__bundle_active (pe_resource_t *rsc, gboolean all) |
void | native_print (pe_resource_t *rsc, const char *pre_text, long options, void *print_data) |
void | group_print (pe_resource_t *rsc, const char *pre_text, long options, void *print_data) |
void | clone_print (pe_resource_t *rsc, const char *pre_text, long options, void *print_data) |
void | pe__print_bundle (pe_resource_t *rsc, const char *pre_text, long options, void *print_data) |
gchar * | pcmk__native_output_string (pe_resource_t *rsc, const char *name, pe_node_t *node, uint32_t show_opts, const char *target_role, bool show_nodes) |
int | pe__name_and_nvpairs_xml (pcmk__output_t *out, bool is_list, const char *tag_name, size_t pairs_count,...) |
char * | pe__node_display_name (pe_node_t *node, bool print_detail) |
void | pe__create_notifications (pe_resource_t *rsc, notify_data_t *n_data) |
notify_data_t * | pe__clone_notif_pseudo_ops (pe_resource_t *rsc, const char *task, pe_action_t *action, pe_action_t *complete) |
void | pe__free_notification_data (notify_data_t *n_data) |
void | pe__order_notifs_after_fencing (pe_action_t *action, pe_resource_t *rsc, pe_action_t *stonith_op) |
int | pe__clone_xml (pcmk__output_t *out, va_list args) |
int | pe__clone_default (pcmk__output_t *out, va_list args) |
int | pe__group_xml (pcmk__output_t *out, va_list args) |
int | pe__group_default (pcmk__output_t *out, va_list args) |
int | pe__bundle_xml (pcmk__output_t *out, va_list args) |
int | pe__bundle_html (pcmk__output_t *out, va_list args) |
int | pe__bundle_text (pcmk__output_t *out, va_list args) |
int | pe__node_html (pcmk__output_t *out, va_list args) |
int | pe__node_text (pcmk__output_t *out, va_list args) |
int | pe__node_xml (pcmk__output_t *out, va_list args) |
int | pe__resource_xml (pcmk__output_t *out, va_list args) |
int | pe__resource_html (pcmk__output_t *out, va_list args) |
int | pe__resource_text (pcmk__output_t *out, va_list args) |
void | native_free (pe_resource_t *rsc) |
void | group_free (pe_resource_t *rsc) |
void | clone_free (pe_resource_t *rsc) |
void | pe__free_bundle (pe_resource_t *rsc) |
enum rsc_role_e | native_resource_state (const pe_resource_t *rsc, gboolean current) |
enum rsc_role_e | group_resource_state (const pe_resource_t *rsc, gboolean current) |
enum rsc_role_e | clone_resource_state (const pe_resource_t *rsc, gboolean current) |
enum rsc_role_e | pe__bundle_resource_state (const pe_resource_t *rsc, gboolean current) |
void | pe__count_common (pe_resource_t *rsc) |
void | pe__count_bundle (pe_resource_t *rsc) |
void | common_free (pe_resource_t *rsc) |
pe_node_t * | pe__copy_node (const pe_node_t *this_node) |
time_t | get_effective_time (pe_working_set_t *data_set) |
int | pe_get_failcount (pe_node_t *node, pe_resource_t *rsc, time_t *last_failure, uint32_t flags, xmlNode *xml_op, pe_working_set_t *data_set) |
pe_action_t * | pe__clear_failcount (pe_resource_t *rsc, pe_node_t *node, const char *reason, pe_working_set_t *data_set) |
Schedule a controller operation to clear a fail count. More... | |
pe_node_t * | pe__find_active_on (const pe_resource_t *rsc, unsigned int *count_all, unsigned int *count_clean) |
pe_node_t * | pe__find_active_requires (const pe_resource_t *rsc, unsigned int *count) |
void | node_list_exclude (GHashTable *list, GList *list2, gboolean merge_scores) |
GHashTable * | pe__node_list2table (GList *list) |
pe_action_t * | get_pseudo_op (const char *name, pe_working_set_t *data_set) |
gboolean | order_actions (pe_action_t *lh_action, pe_action_t *rh_action, enum pe_ordering order) |
void | pe__show_node_weights_as (const char *file, const char *function, int line, bool to_log, pe_resource_t *rsc, const char *comment, GHashTable *nodes, pe_working_set_t *data_set) |
xmlNode * | find_rsc_op_entry (const pe_resource_t *rsc, const char *key) |
pe_action_t * | custom_action (pe_resource_t *rsc, char *key, const char *task, const pe_node_t *on_node, gboolean optional, gboolean foo, pe_working_set_t *data_set) |
Create or update an action object. More... | |
int | pe_get_configured_timeout (pe_resource_t *rsc, const char *action, pe_working_set_t *data_set) |
pe_action_t * | find_first_action (const GList *input, const char *uuid, const char *task, const pe_node_t *on_node) |
enum action_tasks | get_complex_task (pe_resource_t *rsc, const char *name, gboolean allow_non_atomic) |
GList * | find_actions (GList *input, const char *key, const pe_node_t *on_node) |
GList * | find_actions_exact (GList *input, const char *key, const pe_node_t *on_node) |
GList * | pe__resource_actions (const pe_resource_t *rsc, const pe_node_t *node, const char *task, bool require_node) |
Find all actions of given type for a resource. More... | |
void | pe_free_action (pe_action_t *action) |
void | resource_location (pe_resource_t *rsc, pe_node_t *node, int score, const char *tag, pe_working_set_t *data_set) |
int | pe__is_newer_op (const xmlNode *xml_a, const xmlNode *xml_b, bool same_node_default) |
gint | sort_op_by_callid (gconstpointer a, gconstpointer b) |
gboolean | get_target_role (pe_resource_t *rsc, enum rsc_role_e *role) |
void | pe__set_next_role (pe_resource_t *rsc, enum rsc_role_e role, const char *why) |
pe_resource_t * | find_clone_instance (pe_resource_t *rsc, const char *sub_id, pe_working_set_t *data_set) |
void | destroy_ticket (gpointer data) |
pe_ticket_t * | ticket_new (const char *ticket_id, pe_working_set_t *data_set) |
const char * | pe_base_name_end (const char *id) |
char * | clone_strip (const char *last_rsc_id) |
char * | clone_zero (const char *last_rsc_id) |
int | pe__target_rc_from_xml (xmlNode *xml_op) |
gint | pe__cmp_node_name (gconstpointer a, gconstpointer b) |
bool | is_set_recursive (const pe_resource_t *rsc, long long flag, bool any) |
op_digest_cache_t * | pe__calculate_digests (pe_resource_t *rsc, const char *task, guint *interval_ms, pe_node_t *node, xmlNode *xml_op, GHashTable *overrides, bool calc_secure, pe_working_set_t *data_set) |
void | pe__free_digests (gpointer ptr) |
op_digest_cache_t * | rsc_action_digest_cmp (pe_resource_t *rsc, xmlNode *xml_op, pe_node_t *node, pe_working_set_t *data_set) |
pe_action_t * | pe_fence_op (pe_node_t *node, const char *op, bool optional, const char *reason, bool priority_delay, pe_working_set_t *data_set) |
void | trigger_unfencing (pe_resource_t *rsc, pe_node_t *node, const char *reason, pe_action_t *dependency, pe_working_set_t *data_set) |
char * | pe__action2reason (pe_action_t *action, enum pe_action_flags flag) |
void | pe_action_set_reason (pe_action_t *action, const char *reason, bool overwrite) |
void | pe__add_action_expected_result (pe_action_t *action, int expected_result) |
void | pe__set_resource_flags_recursive (pe_resource_t *rsc, uint64_t flags) |
void | pe__clear_resource_flags_recursive (pe_resource_t *rsc, uint64_t flags) |
void | pe__clear_resource_flags_on_all (pe_working_set_t *data_set, uint64_t flag) |
gboolean | add_tag_ref (GHashTable *tags, const char *tag_name, const char *obj_ref) |
void | print_rscs_brief (GList *rsc_list, const char *pre_text, long options, void *print_data, gboolean print_all) |
int | pe__rscs_brief_output (pcmk__output_t *out, GList *rsc_list, unsigned int options) |
void | pe_fence_node (pe_working_set_t *data_set, pe_node_t *node, const char *reason, bool priority_delay) |
Schedule a fence action for a node. More... | |
pe_node_t * | pe_create_node (const char *id, const char *uname, const char *type, const char *score, pe_working_set_t *data_set) |
void | common_print (pe_resource_t *rsc, const char *pre_text, const char *name, pe_node_t *node, long options, void *print_data) |
int | pe__common_output_text (pcmk__output_t *out, pe_resource_t *rsc, const char *name, pe_node_t *node, unsigned int options) |
int | pe__common_output_html (pcmk__output_t *out, pe_resource_t *rsc, const char *name, pe_node_t *node, unsigned int options) |
pe_resource_t * | pe__find_bundle_replica (const pe_resource_t *bundle, const pe_node_t *node) |
bool | pe__bundle_needs_remote_name (pe_resource_t *rsc, pe_working_set_t *data_set) |
const char * | pe__add_bundle_remote_name (pe_resource_t *rsc, pe_working_set_t *data_set, xmlNode *xml, const char *field) |
const char * | pe_node_attribute_calculated (const pe_node_t *node, const char *name, const pe_resource_t *rsc) |
const char * | pe_node_attribute_raw (const pe_node_t *node, const char *name) |
bool | pe__is_universal_clone (pe_resource_t *rsc, pe_working_set_t *data_set) |
void | pe__add_param_check (xmlNode *rsc_op, pe_resource_t *rsc, pe_node_t *node, enum pe_check_parameters, pe_working_set_t *data_set) |
void | pe__foreach_param_check (pe_working_set_t *data_set, void(*cb)(pe_resource_t *, pe_node_t *, xmlNode *, enum pe_check_parameters, pe_working_set_t *)) |
void | pe__free_param_checks (pe_working_set_t *data_set) |
bool | pe__shutdown_requested (pe_node_t *node) |
void | pe__update_recheck_time (time_t recheck, pe_working_set_t *data_set) |
void | pe__register_messages (pcmk__output_t *out) |
void | pe__unpack_dataset_nvpairs (const xmlNode *xml_obj, const char *set_name, pe_rule_eval_data_t *rule_data, GHashTable *hash, const char *always_first, gboolean overwrite, pe_working_set_t *data_set) |
bool | pe__resource_is_disabled (pe_resource_t *rsc) |
pe_action_t * | pe__clear_resource_history (pe_resource_t *rsc, pe_node_t *node, pe_working_set_t *data_set) |
GList * | pe__rscs_with_tag (pe_working_set_t *data_set, const char *tag_name) |
GList * | pe__unames_with_tag (pe_working_set_t *data_set, const char *tag_name) |
bool | pe__rsc_has_tag (pe_working_set_t *data_set, const char *rsc, const char *tag) |
bool | pe__uname_has_tag (pe_working_set_t *data_set, const char *node, const char *tag) |
bool | pe__rsc_running_on_any (pe_resource_t *rsc, GList *node_list) |
GList * | pe__filter_rsc_list (GList *rscs, GList *filter) |
GList * | pe__build_node_name_list (pe_working_set_t *data_set, const char *s) |
GList * | pe__build_rsc_list (pe_working_set_t *data_set, const char *s) |
bool | pcmk__rsc_filtered_by_node (pe_resource_t *rsc, GList *only_node) |
gboolean | pe__bundle_is_filtered (pe_resource_t *rsc, GList *only_rsc, gboolean check_parent) |
gboolean | pe__clone_is_filtered (pe_resource_t *rsc, GList *only_rsc, gboolean check_parent) |
gboolean | pe__group_is_filtered (pe_resource_t *rsc, GList *only_rsc, gboolean check_parent) |
gboolean | pe__native_is_filtered (pe_resource_t *rsc, GList *only_rsc, gboolean check_parent) |
xmlNode * | pe__failed_probe_for_rsc (pe_resource_t *rsc, const char *name) |
const char * | pe__clone_child_id (pe_resource_t *rsc) |
int | pe__sum_node_health_scores (const pe_node_t *node, int base_health) |
int | pe__node_health (pe_node_t *node) |
Variables | |
uint32_t | pe_wo |
#define delete_action | ( | rsc, | |
node, | |||
optional | |||
) |
Definition at line 405 of file internal.h.
#define delete_key | ( | rsc | ) | pcmk__op_key(rsc->id, CRMD_ACTION_DELETE, 0) |
Definition at line 404 of file internal.h.
#define demote_action | ( | rsc, | |
node, | |||
optional | |||
) |
Definition at line 441 of file internal.h.
#define demote_key | ( | rsc | ) | pcmk__op_key(rsc->id, CRMD_ACTION_DEMOTE, 0) |
Definition at line 440 of file internal.h.
#define demoted_action | ( | rsc, | |
node, | |||
optional | |||
) |
Definition at line 446 of file internal.h.
#define demoted_key | ( | rsc | ) | pcmk__op_key(rsc->id, CRMD_ACTION_DEMOTED, 0) |
Definition at line 445 of file internal.h.
#define pe__clear_action_flags | ( | action, | |
flags_to_clear | |||
) |
Definition at line 95 of file internal.h.
#define pe__clear_action_flags_as | ( | function, | |
line, | |||
action, | |||
flags_to_clear | |||
) |
Definition at line 129 of file internal.h.
#define pe__clear_order_flags | ( | order_flags, | |
flags_to_clear | |||
) |
Definition at line 145 of file internal.h.
#define pe__clear_raw_action_flags | ( | action_flags, | |
action_name, | |||
flags_to_clear | |||
) |
Definition at line 111 of file internal.h.
#define pe__clear_resource_flags | ( | resource, | |
flags_to_clear | |||
) |
Definition at line 80 of file internal.h.
#define pe__clear_working_set_flags | ( | working_set, | |
flags_to_clear | |||
) |
Definition at line 68 of file internal.h.
#define pe__set_action_flags | ( | action, | |
flags_to_set | |||
) |
Definition at line 86 of file internal.h.
#define pe__set_action_flags_as | ( | function, | |
line, | |||
action, | |||
flags_to_set | |||
) |
Definition at line 120 of file internal.h.
#define pe__set_order_flags | ( | order_flags, | |
flags_to_set | |||
) |
Definition at line 138 of file internal.h.
#define pe__set_raw_action_flags | ( | action_flags, | |
action_name, | |||
flags_to_set | |||
) |
Definition at line 104 of file internal.h.
#define pe__set_resource_flags | ( | resource, | |
flags_to_set | |||
) |
Definition at line 74 of file internal.h.
#define pe__set_working_set_flags | ( | working_set, | |
flags_to_set | |||
) |
Definition at line 62 of file internal.h.
#define pe__show_node_weights | ( | level, | |
rsc, | |||
text, | |||
nodes, | |||
data_set | |||
) |
Definition at line 394 of file internal.h.
#define pe_err | ( | fmt... | ) |
Definition at line 49 of file internal.h.
#define pe_proc_err | ( | fmt... | ) | { was_processing_error = TRUE; crm_err(fmt); } |
Definition at line 59 of file internal.h.
#define pe_proc_warn | ( | fmt... | ) | { was_processing_warning = TRUE; crm_warn(fmt); } |
Definition at line 60 of file internal.h.
#define pe_rsc_debug | ( | rsc, | |
fmt, | |||
args... | |||
) | crm_log_tag(LOG_DEBUG, rsc ? rsc->id : "<NULL>", fmt, ##args) |
Definition at line 46 of file internal.h.
#define pe_rsc_info | ( | rsc, | |
fmt, | |||
args... | |||
) | crm_log_tag(LOG_INFO, rsc ? rsc->id : "<NULL>", fmt, ##args) |
Definition at line 45 of file internal.h.
#define pe_rsc_trace | ( | rsc, | |
fmt, | |||
args... | |||
) | crm_log_tag(LOG_TRACE, rsc ? rsc->id : "<NULL>", fmt, ##args) |
Definition at line 47 of file internal.h.
#define pe_warn | ( | fmt... | ) |
Definition at line 54 of file internal.h.
#define pe_warn_once | ( | pe_wo_bit, | |
fmt... | |||
) |
Definition at line 172 of file internal.h.
#define promote_action | ( | rsc, | |
node, | |||
optional | |||
) |
Definition at line 431 of file internal.h.
#define promote_key | ( | rsc | ) | pcmk__op_key(rsc->id, CRMD_ACTION_PROMOTE, 0) |
Definition at line 430 of file internal.h.
#define promoted_action | ( | rsc, | |
node, | |||
optional | |||
) |
Definition at line 436 of file internal.h.
#define promoted_key | ( | rsc | ) | pcmk__op_key(rsc->id, CRMD_ACTION_PROMOTED, 0) |
Definition at line 435 of file internal.h.
#define reload_key | ( | rsc | ) | pcmk__op_key(rsc->id, CRMD_ACTION_RELOAD_AGENT, 0) |
Definition at line 419 of file internal.h.
#define start_action | ( | rsc, | |
node, | |||
optional | |||
) |
Definition at line 421 of file internal.h.
#define start_key | ( | rsc | ) | pcmk__op_key(rsc->id, CRMD_ACTION_START, 0) |
Definition at line 420 of file internal.h.
#define started_action | ( | rsc, | |
node, | |||
optional | |||
) |
Definition at line 426 of file internal.h.
#define started_key | ( | rsc | ) | pcmk__op_key(rsc->id, CRMD_ACTION_STARTED, 0) |
Definition at line 425 of file internal.h.
#define stop_action | ( | rsc, | |
node, | |||
optional | |||
) |
Definition at line 415 of file internal.h.
#define stop_key | ( | rsc | ) | pcmk__op_key(rsc->id, CRMD_ACTION_STOP, 0) |
Definition at line 414 of file internal.h.
#define stopped_action | ( | rsc, | |
node, | |||
optional | |||
) |
Definition at line 410 of file internal.h.
#define stopped_key | ( | rsc | ) | pcmk__op_key(rsc->id, CRMD_ACTION_STOPPED, 0) |
Definition at line 409 of file internal.h.
typedef struct notify_data_s notify_data_t |
typedef struct op_digest_cache_s op_digest_cache_t |
typedef struct pe__location_constraint_s pe__location_t |
typedef struct pe__order_constraint_s pe__ordering_t |
enum pe__clone_flags |
Enumerator | |
---|---|
pe__clone_ordered | |
pe__clone_promotion_added | |
pe__clone_promotion_constrained |
Definition at line 21 of file internal.h.
enum pe__group_flags |
Enumerator | |
---|---|
pe__group_ordered | |
pe__group_colocated |
Definition at line 36 of file internal.h.
enum pe_fc_flags_e |
Enumerator | |
---|---|
pe_fc_default | |
pe_fc_effective | |
pe_fc_fillers |
Definition at line 343 of file internal.h.
enum pe_warn_once_e |
Definition at line 154 of file internal.h.
enum rsc_digest_cmp_val |
Definition at line 504 of file internal.h.
void add_hash_param | ( | GHashTable * | hash, |
const char * | name, | ||
const char * | value | ||
) |
gboolean add_tag_ref | ( | GHashTable * | tags, |
const char * | tag_name, | ||
const char * | obj_ref | ||
) |
gboolean clone_active | ( | pe_resource_t * | rsc, |
gboolean | all | ||
) |
void clone_free | ( | pe_resource_t * | rsc | ) |
void clone_print | ( | pe_resource_t * | rsc, |
const char * | pre_text, | ||
long | options, | ||
void * | print_data | ||
) |
enum rsc_role_e clone_resource_state | ( | const pe_resource_t * | rsc, |
gboolean | current | ||
) |
gboolean clone_unpack | ( | pe_resource_t * | rsc, |
pe_working_set_t * | data_set | ||
) |
void common_free | ( | pe_resource_t * | rsc | ) |
void common_print | ( | pe_resource_t * | rsc, |
const char * | pre_text, | ||
const char * | name, | ||
pe_node_t * | node, | ||
long | options, | ||
void * | print_data | ||
) |
void common_update_score | ( | pe_resource_t * | rsc, |
const char * | id, | ||
int | score | ||
) |
pe_action_t* custom_action | ( | pe_resource_t * | rsc, |
char * | key, | ||
const char * | task, | ||
const pe_node_t * | on_node, | ||
gboolean | optional, | ||
gboolean | save_action, | ||
pe_working_set_t * | data_set | ||
) |
Create or update an action object.
[in] | rsc | Resource that action is for (if any) |
[in] | key | Action key (must be non-NULL) |
[in] | task | Action name (must be non-NULL) |
[in] | on_node | Node that action is on (if any) |
[in] | optional | Whether action should be considered optional |
[in] | save_action | Whether action should be recorded in transition graph |
[in] | data_set | Cluster working set |
key
. If save_action
is true, data_set
will own the returned action, otherwise it is the caller's responsibility to free the return value with pe_free_action(). Definition at line 940 of file pe_actions.c.
GList* find_actions | ( | GList * | input, |
const char * | key, | ||
const pe_node_t * | on_node | ||
) |
Definition at line 1325 of file pe_actions.c.
GList* find_actions_exact | ( | GList * | input, |
const char * | key, | ||
const pe_node_t * | on_node | ||
) |
Definition at line 1359 of file pe_actions.c.
pe_resource_t* find_clone_instance | ( | pe_resource_t * | rsc, |
const char * | sub_id, | ||
pe_working_set_t * | data_set | ||
) |
pe_action_t* find_first_action | ( | const GList * | input, |
const char * | uuid, | ||
const char * | task, | ||
const pe_node_t * | on_node | ||
) |
Definition at line 1296 of file pe_actions.c.
xmlNode* find_rsc_op_entry | ( | const pe_resource_t * | rsc, |
const char * | key | ||
) |
Definition at line 145 of file pe_actions.c.
enum action_tasks get_complex_task | ( | pe_resource_t * | rsc, |
const char * | name, | ||
gboolean | allow_non_atomic | ||
) |
Definition at line 1262 of file pe_actions.c.
time_t get_effective_time | ( | pe_working_set_t * | data_set | ) |
pe_action_t* get_pseudo_op | ( | const char * | name, |
pe_working_set_t * | data_set | ||
) |
Definition at line 977 of file pe_actions.c.
gboolean get_target_role | ( | pe_resource_t * | rsc, |
enum rsc_role_e * | role | ||
) |
gboolean group_active | ( | pe_resource_t * | rsc, |
gboolean | all | ||
) |
void group_free | ( | pe_resource_t * | rsc | ) |
void group_print | ( | pe_resource_t * | rsc, |
const char * | pre_text, | ||
long | options, | ||
void * | print_data | ||
) |
enum rsc_role_e group_resource_state | ( | const pe_resource_t * | rsc, |
gboolean | current | ||
) |
gboolean group_unpack | ( | pe_resource_t * | rsc, |
pe_working_set_t * | data_set | ||
) |
bool is_set_recursive | ( | const pe_resource_t * | rsc, |
long long | flag, | ||
bool | any | ||
) |
gboolean native_active | ( | pe_resource_t * | rsc, |
gboolean | all | ||
) |
void native_add_running | ( | pe_resource_t * | rsc, |
pe_node_t * | node, | ||
pe_working_set_t * | data_set, | ||
gboolean | failed | ||
) |
pe_resource_t* native_find_rsc | ( | pe_resource_t * | rsc, |
const char * | id, | ||
const pe_node_t * | node, | ||
int | flags | ||
) |
void native_free | ( | pe_resource_t * | rsc | ) |
pe_node_t* native_location | ( | const pe_resource_t * | rsc, |
GList ** | list, | ||
int | current | ||
) |
char* native_parameter | ( | pe_resource_t * | rsc, |
pe_node_t * | node, | ||
gboolean | create, | ||
const char * | name, | ||
pe_working_set_t * | data_set | ||
) |
void native_print | ( | pe_resource_t * | rsc, |
const char * | pre_text, | ||
long | options, | ||
void * | print_data | ||
) |
enum rsc_role_e native_resource_state | ( | const pe_resource_t * | rsc, |
gboolean | current | ||
) |
gboolean native_unpack | ( | pe_resource_t * | rsc, |
pe_working_set_t * | data_set | ||
) |
void node_list_exclude | ( | GHashTable * | list, |
GList * | list2, | ||
gboolean | merge_scores | ||
) |
gboolean order_actions | ( | pe_action_t * | lh_action, |
pe_action_t * | rh_action, | ||
enum pe_ordering | order | ||
) |
gchar* pcmk__native_output_string | ( | pe_resource_t * | rsc, |
const char * | name, | ||
pe_node_t * | node, | ||
uint32_t | show_opts, | ||
const char * | target_role, | ||
bool | show_nodes | ||
) |
bool pcmk__rsc_filtered_by_node | ( | pe_resource_t * | rsc, |
GList * | only_node | ||
) |
char* pe__action2reason | ( | pe_action_t * | action, |
enum pe_action_flags | flag | ||
) |
Definition at line 1424 of file pe_actions.c.
void pe__add_action_expected_result | ( | pe_action_t * | action, |
int | expected_result | ||
) |
Definition at line 1673 of file pe_actions.c.
const char* pe__add_bundle_remote_name | ( | pe_resource_t * | rsc, |
pe_working_set_t * | data_set, | ||
xmlNode * | xml, | ||
const char * | field | ||
) |
void pe__add_param_check | ( | xmlNode * | rsc_op, |
pe_resource_t * | rsc, | ||
pe_node_t * | node, | ||
enum | pe_check_parameters, | ||
pe_working_set_t * | data_set | ||
) |
GList* pe__build_node_name_list | ( | pe_working_set_t * | data_set, |
const char * | s | ||
) |
GList* pe__build_rsc_list | ( | pe_working_set_t * | data_set, |
const char * | s | ||
) |
gboolean pe__bundle_active | ( | pe_resource_t * | rsc, |
gboolean | all | ||
) |
int pe__bundle_html | ( | pcmk__output_t * | out, |
va_list | args | ||
) |
gboolean pe__bundle_is_filtered | ( | pe_resource_t * | rsc, |
GList * | only_rsc, | ||
gboolean | check_parent | ||
) |
bool pe__bundle_needs_remote_name | ( | pe_resource_t * | rsc, |
pe_working_set_t * | data_set | ||
) |
enum rsc_role_e pe__bundle_resource_state | ( | const pe_resource_t * | rsc, |
gboolean | current | ||
) |
int pe__bundle_text | ( | pcmk__output_t * | out, |
va_list | args | ||
) |
int pe__bundle_xml | ( | pcmk__output_t * | out, |
va_list | args | ||
) |
op_digest_cache_t* pe__calculate_digests | ( | pe_resource_t * | rsc, |
const char * | task, | ||
guint * | interval_ms, | ||
pe_node_t * | node, | ||
xmlNode * | xml_op, | ||
GHashTable * | overrides, | ||
bool | calc_secure, | ||
pe_working_set_t * | data_set | ||
) |
Definition at line 298 of file pe_digest.c.
pe_action_t* pe__clear_failcount | ( | pe_resource_t * | rsc, |
pe_node_t * | node, | ||
const char * | reason, | ||
pe_working_set_t * | data_set | ||
) |
Schedule a controller operation to clear a fail count.
[in] | rsc | Resource with failure |
[in] | node | Node failure occurred on |
[in] | reason | Readable description why needed (for logging) |
[in] | data_set | Working set for cluster |
Definition at line 360 of file failcounts.c.
void pe__clear_resource_flags_on_all | ( | pe_working_set_t * | data_set, |
uint64_t | flag | ||
) |
void pe__clear_resource_flags_recursive | ( | pe_resource_t * | rsc, |
uint64_t | flags | ||
) |
pe_action_t* pe__clear_resource_history | ( | pe_resource_t * | rsc, |
pe_node_t * | node, | ||
pe_working_set_t * | data_set | ||
) |
Definition at line 1473 of file pe_actions.c.
const char* pe__clone_child_id | ( | pe_resource_t * | rsc | ) |
int pe__clone_default | ( | pcmk__output_t * | out, |
va_list | args | ||
) |
gboolean pe__clone_is_filtered | ( | pe_resource_t * | rsc, |
GList * | only_rsc, | ||
gboolean | check_parent | ||
) |
bool pe__clone_is_ordered | ( | pe_resource_t * | clone | ) |
notify_data_t* pe__clone_notif_pseudo_ops | ( | pe_resource_t * | rsc, |
const char * | task, | ||
pe_action_t * | action, | ||
pe_action_t * | complete | ||
) |
Definition at line 428 of file pe_notif.c.
int pe__clone_promoted_max | ( | pe_resource_t * | clone | ) |
int pe__clone_promoted_node_max | ( | pe_resource_t * | clone | ) |
int pe__clone_xml | ( | pcmk__output_t * | out, |
va_list | args | ||
) |
int pe__common_output_html | ( | pcmk__output_t * | out, |
pe_resource_t * | rsc, | ||
const char * | name, | ||
pe_node_t * | node, | ||
unsigned int | options | ||
) |
int pe__common_output_text | ( | pcmk__output_t * | out, |
pe_resource_t * | rsc, | ||
const char * | name, | ||
pe_node_t * | node, | ||
unsigned int | options | ||
) |
void pe__count_bundle | ( | pe_resource_t * | rsc | ) |
void pe__count_common | ( | pe_resource_t * | rsc | ) |
void pe__create_notifications | ( | pe_resource_t * | rsc, |
notify_data_t * | n_data | ||
) |
Definition at line 928 of file pe_notif.c.
void pe__create_promotable_pseudo_ops | ( | pe_resource_t * | clone, |
bool | any_promoting, | ||
bool | any_demoting | ||
) |
xmlNode* pe__failed_probe_for_rsc | ( | pe_resource_t * | rsc, |
const char * | name | ||
) |
pe_node_t* pe__find_active_on | ( | const pe_resource_t * | rsc, |
unsigned int * | count_all, | ||
unsigned int * | count_clean | ||
) |
pe_node_t* pe__find_active_requires | ( | const pe_resource_t * | rsc, |
unsigned int * | count | ||
) |
pe_resource_t* pe__find_bundle_replica | ( | const pe_resource_t * | bundle, |
const pe_node_t * | node | ||
) |
void pe__foreach_param_check | ( | pe_working_set_t * | data_set, |
void(*)(pe_resource_t *, pe_node_t *, xmlNode *, enum pe_check_parameters, pe_working_set_t *) | cb | ||
) |
void pe__free_bundle | ( | pe_resource_t * | rsc | ) |
void pe__free_digests | ( | gpointer | ptr | ) |
Definition at line 34 of file pe_digest.c.
void pe__free_notification_data | ( | notify_data_t * | n_data | ) |
Definition at line 945 of file pe_notif.c.
void pe__free_param_checks | ( | pe_working_set_t * | data_set | ) |
int pe__group_default | ( | pcmk__output_t * | out, |
va_list | args | ||
) |
bool pe__group_flag_is_set | ( | const pe_resource_t * | group, |
uint32_t | flags | ||
) |
gboolean pe__group_is_filtered | ( | pe_resource_t * | rsc, |
GList * | only_rsc, | ||
gboolean | check_parent | ||
) |
int pe__group_xml | ( | pcmk__output_t * | out, |
va_list | args | ||
) |
int pe__is_newer_op | ( | const xmlNode * | xml_a, |
const xmlNode * | xml_b, | ||
bool | same_node_default | ||
) |
Definition at line 1494 of file pe_actions.c.
bool pe__is_universal_clone | ( | pe_resource_t * | rsc, |
pe_working_set_t * | data_set | ||
) |
pe_resource_t* pe__last_group_member | ( | const pe_resource_t * | group | ) |
int pe__name_and_nvpairs_xml | ( | pcmk__output_t * | out, |
bool | is_list, | ||
const char * | tag_name, | ||
size_t | pairs_count, | ||
... | |||
) |
Definition at line 544 of file pe_output.c.
gboolean pe__native_is_filtered | ( | pe_resource_t * | rsc, |
GList * | only_rsc, | ||
gboolean | check_parent | ||
) |
pe_action_t* pe__new_rsc_pseudo_action | ( | pe_resource_t * | rsc, |
const char * | task, | ||
bool | optional, | ||
bool | runnable | ||
) |
Definition at line 1647 of file pe_actions.c.
char* pe__node_display_name | ( | pe_node_t * | node, |
bool | print_detail | ||
) |
Definition at line 491 of file pe_output.c.
int pe__node_health | ( | pe_node_t * | node | ) |
Definition at line 112 of file pe_health.c.
int pe__node_html | ( | pcmk__output_t * | out, |
va_list | args | ||
) |
int pe__node_text | ( | pcmk__output_t * | out, |
va_list | args | ||
) |
int pe__node_xml | ( | pcmk__output_t * | out, |
va_list | args | ||
) |
void pe__order_notifs_after_fencing | ( | pe_action_t * | action, |
pe_resource_t * | rsc, | ||
pe_action_t * | stonith_op | ||
) |
Definition at line 977 of file pe_notif.c.
void pe__print_bundle | ( | pe_resource_t * | rsc, |
const char * | pre_text, | ||
long | options, | ||
void * | print_data | ||
) |
void pe__register_messages | ( | pcmk__output_t * | out | ) |
Definition at line 3010 of file pe_output.c.
GList* pe__resource_actions | ( | const pe_resource_t * | rsc, |
const pe_node_t * | node, | ||
const char * | task, | ||
bool | require_node | ||
) |
Find all actions of given type for a resource.
[in] | rsc | Resource to search |
[in] | node | Find only actions scheduled on this node |
[in] | task | Action name to search for |
[in] | require_node | If TRUE, NULL node or action node will not match |
Definition at line 1398 of file pe_actions.c.
int pe__resource_html | ( | pcmk__output_t * | out, |
va_list | args | ||
) |
bool pe__resource_is_disabled | ( | pe_resource_t * | rsc | ) |
int pe__resource_text | ( | pcmk__output_t * | out, |
va_list | args | ||
) |
int pe__resource_xml | ( | pcmk__output_t * | out, |
va_list | args | ||
) |
bool pe__rsc_has_tag | ( | pe_working_set_t * | data_set, |
const char * | rsc, | ||
const char * | tag | ||
) |
bool pe__rsc_running_on_any | ( | pe_resource_t * | rsc, |
GList * | node_list | ||
) |
int pe__rscs_brief_output | ( | pcmk__output_t * | out, |
GList * | rsc_list, | ||
unsigned int | options | ||
) |
GList* pe__rscs_with_tag | ( | pe_working_set_t * | data_set, |
const char * | tag_name | ||
) |
int pe__set_clone_flag | ( | pe_resource_t * | clone, |
enum pe__clone_flags | flag | ||
) |
void pe__set_next_role | ( | pe_resource_t * | rsc, |
enum rsc_role_e | role, | ||
const char * | why | ||
) |
void pe__set_resource_flags_recursive | ( | pe_resource_t * | rsc, |
uint64_t | flags | ||
) |
void pe__show_node_weights_as | ( | const char * | file, |
const char * | function, | ||
int | line, | ||
bool | to_log, | ||
pe_resource_t * | rsc, | ||
const char * | comment, | ||
GHashTable * | nodes, | ||
pe_working_set_t * | data_set | ||
) |
int pe__sum_node_health_scores | ( | const pe_node_t * | node, |
int | base_health | ||
) |
Definition at line 94 of file pe_health.c.
bool pe__uname_has_tag | ( | pe_working_set_t * | data_set, |
const char * | node, | ||
const char * | tag | ||
) |
GList* pe__unames_with_tag | ( | pe_working_set_t * | data_set, |
const char * | tag_name | ||
) |
gboolean pe__unpack_bundle | ( | pe_resource_t * | rsc, |
pe_working_set_t * | data_set | ||
) |
void pe__unpack_dataset_nvpairs | ( | const xmlNode * | xml_obj, |
const char * | set_name, | ||
pe_rule_eval_data_t * | rule_data, | ||
GHashTable * | hash, | ||
const char * | always_first, | ||
gboolean | overwrite, | ||
pe_working_set_t * | data_set | ||
) |
void pe__update_recheck_time | ( | time_t | recheck, |
pe_working_set_t * | data_set | ||
) |
void pe_action_set_reason | ( | pe_action_t * | action, |
const char * | reason, | ||
bool | overwrite | ||
) |
Definition at line 1447 of file pe_actions.c.
bool pe_can_fence | ( | pe_working_set_t * | data_set, |
pe_node_t * | node | ||
) |
pe_node_t* pe_create_node | ( | const char * | id, |
const char * | uname, | ||
const char * | type, | ||
const char * | score, | ||
pe_working_set_t * | data_set | ||
) |
void pe_fence_node | ( | pe_working_set_t * | data_set, |
pe_node_t * | node, | ||
const char * | reason, | ||
bool | priority_delay | ||
) |
pe_action_t* pe_fence_op | ( | pe_node_t * | node, |
const char * | op, | ||
bool | optional, | ||
const char * | reason, | ||
bool | priority_delay, | ||
pe_working_set_t * | data_set | ||
) |
Definition at line 1081 of file pe_actions.c.
void pe_free_action | ( | pe_action_t * | action | ) |
Definition at line 1193 of file pe_actions.c.
int pe_get_configured_timeout | ( | pe_resource_t * | rsc, |
const char * | action, | ||
pe_working_set_t * | data_set | ||
) |
Definition at line 1215 of file pe_actions.c.
int pe_get_failcount | ( | pe_node_t * | node, |
pe_resource_t * | rsc, | ||
time_t * | last_failure, | ||
uint32_t | flags, | ||
xmlNode * | xml_op, | ||
pe_working_set_t * | data_set | ||
) |
Definition at line 251 of file failcounts.c.
void pe_metadata | ( | pcmk__output_t * | out | ) |
const char* pe_node_attribute_calculated | ( | const pe_node_t * | node, |
const char * | name, | ||
const pe_resource_t * | rsc | ||
) |
const char* pe_node_attribute_raw | ( | const pe_node_t * | node, |
const char * | name | ||
) |
void print_rscs_brief | ( | GList * | rsc_list, |
const char * | pre_text, | ||
long | options, | ||
void * | print_data, | ||
gboolean | print_all | ||
) |
void resource_location | ( | pe_resource_t * | rsc, |
pe_node_t * | node, | ||
int | score, | ||
const char * | tag, | ||
pe_working_set_t * | data_set | ||
) |
op_digest_cache_t* rsc_action_digest_cmp | ( | pe_resource_t * | rsc, |
xmlNode * | xml_op, | ||
pe_node_t * | node, | ||
pe_working_set_t * | data_set | ||
) |
Definition at line 380 of file pe_digest.c.
gint sort_op_by_callid | ( | gconstpointer | a, |
gconstpointer | b | ||
) |
Definition at line 1627 of file pe_actions.c.
pe_ticket_t* ticket_new | ( | const char * | ticket_id, |
pe_working_set_t * | data_set | ||
) |
void trigger_unfencing | ( | pe_resource_t * | rsc, |
pe_node_t * | node, | ||
const char * | reason, | ||
pe_action_t * | dependency, | ||
pe_working_set_t * | data_set | ||
) |