libpengine3-dev 1.1.6-2ubuntu3 / usr / include / pacemaker / crm / pengine / status.h

/* 
 * Copyright (C) 2004 Andrew Beekhof <andrew@beekhof.net>
 * 
 * This program is free software; you can redistribute it and/or
 * modify it under the terms of the GNU General Public
 * License as published by the Free Software Foundation; either
 * version 2 of the License, or (at your option) any later version.
 * 
 * This software is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
 * General Public License for more details.
 * 
 * You should have received a copy of the GNU General Public
 * License along with this library; if not, write to the Free Software
 * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA
 */
#ifndef PENGINE_STATUS__H
#define PENGINE_STATUS__H

#include <glib.h>
#include <crm/common/iso8601.h>
#include <crm/pengine/common.h>

typedef struct node_s node_t;
typedef struct pe_action_s action_t;
typedef struct pe_action_s pe_action_t;
typedef struct resource_s resource_t;
typedef struct ticket_s ticket_t;

typedef enum no_quorum_policy_e {
	no_quorum_freeze,
	no_quorum_stop,
	no_quorum_ignore,
	no_quorum_suicide
} no_quorum_policy_t;

enum node_type {
	node_ping,
	node_member
};

enum pe_restart {
	pe_restart_restart,
	pe_restart_ignore
};

enum pe_find {
    pe_find_renamed  = 0x001,
    pe_find_partial  = 0x002,
    pe_find_clone    = 0x004,
    pe_find_current  = 0x008,
    pe_find_inactive = 0x010,
};

#define pe_flag_have_quorum		0x00000001ULL
#define pe_flag_symmetric_cluster	0x00000002ULL
#define pe_flag_is_managed_default	0x00000004ULL
#define pe_flag_maintenance_mode	0x00000008ULL

#define pe_flag_stonith_enabled		0x00000010ULL
#define pe_flag_have_stonith_resource	0x00000020ULL

#define pe_flag_stop_rsc_orphans	0x00000100ULL
#define pe_flag_stop_action_orphans	0x00000200ULL
#define pe_flag_stop_everything		0x00000400ULL

#define pe_flag_start_failure_fatal	0x00001000ULL
#define pe_flag_remove_after_stop	0x00002000ULL

#define pe_flag_startup_probes		0x00010000ULL
#define pe_flag_have_status		0x00020000ULL

typedef struct pe_working_set_s 
{
		xmlNode *input;
		ha_time_t *now;

		/* options extracted from the input */
		char *dc_uuid;
		node_t *dc_node;
		const char *stonith_action;
		const char *placement_strategy;

		unsigned long long flags;

		int stonith_timeout;
		int default_resource_stickiness;
		no_quorum_policy_t no_quorum_policy;

		GHashTable *config_hash;
		GHashTable *domains;
		GHashTable *tickets;
		
		GListPtr nodes;
		GListPtr resources;
		GListPtr placement_constraints;
		GListPtr ordering_constraints;
		GListPtr colocation_constraints;
		GListPtr ticket_constraints;
		
		GListPtr actions;
		xmlNode *failed;
		xmlNode *op_defaults;
		xmlNode *rsc_defaults;

		/* stats */
		int num_synapse;
		int max_valid_nodes;
		int order_id;
		int action_id;

		/* final output */
		xmlNode *graph;

} pe_working_set_t;

struct node_shared_s { 
		const char *id; 
		const char *uname; 
		gboolean online;
		gboolean standby;
		gboolean standby_onfail;
		gboolean pending;
		gboolean unclean;
		gboolean shutdown;
		gboolean expected_up;
		gboolean is_dc;
		int	 num_resources;
		GListPtr running_rsc;	/* resource_t* */
		GListPtr allocated_rsc;	/* resource_t* */
		
		GHashTable *attrs;	/* char* => char* */
		enum node_type type;

		GHashTable *utilization;
}; 

struct node_s { 
		int	weight; 
		gboolean fixed;
		int      count;
		struct node_shared_s *details;
};

#include <crm/pengine/complex.h>

#define pe_rsc_orphan		0x00000001ULL
#define pe_rsc_managed		0x00000002ULL

#define pe_rsc_notify		0x00000010ULL
#define pe_rsc_unique		0x00000020ULL
#define pe_rsc_can_migrate	0x00000040ULL

#define pe_rsc_provisional	0x00000100ULL
#define pe_rsc_allocating	0x00000200ULL
#define pe_rsc_merging		0x00000400ULL

#define pe_rsc_failed		0x00010000ULL
#define pe_rsc_shutdown		0x00020000ULL
#define pe_rsc_runnable		0x00040000ULL
#define pe_rsc_start_pending	0x00080000ULL

#define pe_rsc_starting		0x00100000ULL
#define pe_rsc_stopping		0x00200000ULL

#define pe_rsc_failure_ignored  0x01000000ULL

enum pe_graph_flags 
{
    pe_graph_none			= 0x00000,
    pe_graph_updated_first		= 0x00001,
    pe_graph_updated_then		= 0x00002,
    pe_graph_disable			= 0x00004,
};

enum pe_action_flags 
{
    pe_action_pseudo			= 0x00001,
    pe_action_runnable			= 0x00002,
    pe_action_optional			= 0x00004,
    pe_action_print_always		= 0x00008,

    pe_action_have_node_attrs		= 0x00010,
    pe_action_failure_is_fatal		= 0x00020,
    pe_action_implied_by_stonith	= 0x00040,
    pe_action_allow_reload_conversion	= 0x00080,

    pe_action_dumped			= 0x00100,
    pe_action_processed			= 0x00200,
    pe_action_clear			= 0x00400,
    pe_action_dangle			= 0x00800,
};

struct resource_s { 
		char *id; 
		char *clone_name; 
		char *long_name; 
		xmlNode *xml; 
		xmlNode *orig_xml;
		xmlNode *ops_xml; 

		resource_t *parent;
		void *variant_opaque;
		enum pe_obj_types variant;
		resource_object_functions_t *fns;
 		resource_alloc_functions_t  *cmds;

		enum rsc_recovery_type recovery_type;
		enum pe_restart        restart_type;

		int	 priority; 
		int	 stickiness; 
		int	 sort_index; 
		int	 failure_timeout;
		int	 effective_priority; 
		int	 migration_threshold;

		unsigned long long flags;
	
		GListPtr rsc_cons_lhs;     /* rsc_colocation_t* */
		GListPtr rsc_cons;         /* rsc_colocation_t* */
		GListPtr rsc_location;     /* rsc_to_node_t*    */
		GListPtr actions;	   /* action_t*         */
		GListPtr rsc_tickets;	   /* rsc_ticket*       */

		node_t *allocated_to;
		GListPtr running_on;       /* node_t*   */
		GHashTable *known_on;	   /* node_t*   */
		GHashTable *allowed_nodes; /* node_t*   */

		enum rsc_role_e role;
		enum rsc_role_e next_role;

		GHashTable *meta;	   
		GHashTable *parameters;
		GHashTable *utilization;

		GListPtr children;	      /* resource_t*   */	
		GListPtr dangling_migrations; /* node_t*       */
};

struct pe_action_s 
{
		int         id;
		int         priority;
	
		resource_t *rsc;
		node_t     *node;
		xmlNode    *op_entry;
	
		char	   *task;
		char	   *uuid;

		enum pe_action_flags flags;
		enum rsc_start_requirement needs;
		enum action_fail_response  on_fail;
		enum rsc_role_e fail_role;
		
		action_t *pre_notify;
		action_t *pre_notified;
		action_t *post_notify;
		action_t *post_notified;
		
		int seen_count;

		GHashTable *meta;
		GHashTable *extra;
		
		GListPtr actions_before; /* action_warpper_t* */
		GListPtr actions_after;  /* action_warpper_t* */
};

typedef struct notify_data_s {
	GHashTable *keys;

	const char *action;
	
	action_t *pre;
	action_t *post;
	action_t *pre_done;
	action_t *post_done;

	GListPtr active;   /* notify_entry_t*  */
	GListPtr inactive; /* notify_entry_t*  */
	GListPtr start;    /* notify_entry_t*  */
	GListPtr stop;     /* notify_entry_t*  */
	GListPtr demote;   /* notify_entry_t*  */
	GListPtr promote;  /* notify_entry_t*  */
	GListPtr master;   /* notify_entry_t*  */
	GListPtr slave;    /* notify_entry_t*  */
		
} notify_data_t;

struct ticket_s {
	char *id;
	gboolean granted;
	time_t last_granted;
};

gboolean cluster_status(pe_working_set_t *data_set);
extern void set_working_set_defaults(pe_working_set_t *data_set);
extern void cleanup_calculations(pe_working_set_t *data_set);
extern resource_t *pe_find_resource(GListPtr rsc_list, const char *id_rh);
extern node_t *pe_find_node(GListPtr node_list, const char *uname);
extern node_t *pe_find_node_id(GListPtr node_list, const char *id);
extern GListPtr find_operations(
    const char *rsc, const char *node, gboolean active_filter, pe_working_set_t *data_set);

#endif