internal.h File Reference

#include <crm/cluster.h>

Include dependency graph for internal.h:

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Data Structures
struct	crm_ais_host_s
struct	crm_ais_msg_s

Macros
#define	ais_data_len(msg)   (msg->is_compressed?msg->compressed_size:msg->size)

Typedefs
typedef struct crm_ais_host_s	AIS_Host
typedef struct crm_ais_msg_s	AIS_Message

Enumerations
enum	crm_proc_flag {   crm_proc_none = 0x00000001, crm_proc_cpg = 0x04000000, crm_proc_execd = 0x00000010, crm_proc_based = 0x00000100,   crm_proc_controld = 0x00000200, crm_proc_attrd = 0x00001000, crm_proc_schedulerd = 0x00010000, crm_proc_fenced = 0x00100000 }

Functions
struct crm_ais_host_s	__attribute__ ((packed))
cs_ipc_header_response_t header	__attribute__ ((aligned(8)))
gboolean	check_message_sanity (const AIS_Message *msg, const char *data)
crm_node_t *	crm_update_peer_proc (const char *source, crm_node_t *peer, uint32_t flag, const char *status)
crm_node_t *	crm_update_peer_state (const char *source, crm_node_t *node, const char *state, int membership)
	Update a node's state and membership information. More...
void	crm_update_peer_uname (crm_node_t *node, const char *uname)
void	crm_update_peer_expected (const char *source, crm_node_t *node, const char *expected)
void	crm_reap_unseen_nodes (uint64_t ring_id)
gboolean	cluster_connect_quorum (gboolean(*dispatch)(unsigned long long, gboolean), void(*destroy)(gpointer))
gboolean	node_name_is_valid (const char *key, const char *name)
crm_node_t *	crm_find_peer_full (unsigned int id, const char *uname, int flags)
crm_node_t *	crm_find_peer (unsigned int id, const char *uname)
void	crm_peer_caches_refresh (xmlNode *cib)
crm_node_t *	crm_find_known_peer_full (unsigned int id, const char *uname, int flags)

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
AIS_Host	host
AIS_Host	sender
uint32_t	compressed_size
char	data [0]
enum crm_proc_flag	__attribute__

Macro Definition Documentation

#define ais_data_len

(

msg

)

(msg->is_compressed?msg->compressed_size:msg->size)

Definition at line 125 of file internal.h.

Typedef Documentation

typedef struct crm_ais_host_s AIS_Host

Definition at line 15 of file internal.h.

typedef struct crm_ais_msg_s AIS_Message

Definition at line 16 of file internal.h.

Enumeration Type Documentation

enum crm_proc_flag

Enumerator
crm_proc_none
crm_proc_cpg
crm_proc_execd
crm_proc_based
crm_proc_controld
crm_proc_attrd
crm_proc_schedulerd
crm_proc_fenced

Definition at line 44 of file internal.h.

Function Documentation

struct crm_ais_host_s __attribute__

(

(packed)

)

cs_ipc_header_response_t header __attribute__::__attribute__

(

(aligned(8))

)

gboolean check_message_sanity	(	const AIS_Message *	msg,
		const char *	data
	)

Definition at line 421 of file corosync.c.

gboolean cluster_connect_quorum	(	gboolean(*)(unsigned long long, gboolean)	dispatch,
		void(*)(gpointer)	destroy
	)

Definition at line 271 of file corosync.c.

crm_node_t* crm_find_known_peer_full	(	unsigned int	id,
		const char *	uname,
		int	flags
	)

Definition at line 1156 of file membership.c.

crm_node_t* crm_find_peer	(	unsigned int	id,
		const char *	uname
	)

Definition at line 522 of file membership.c.

crm_node_t* crm_find_peer_full	(	unsigned int	id,
		const char *	uname,
		int	flags
	)

Definition at line 484 of file membership.c.

void crm_peer_caches_refresh

(

xmlNode *

cib

)

Definition at line 1149 of file membership.c.

void crm_reap_unseen_nodes

(

uint64_t

ring_id

)

Definition at line 977 of file membership.c.

void crm_update_peer_expected	(	const char *	source,
		crm_node_t *	node,
		const char *	expected
	)

Definition at line 852 of file membership.c.

crm_node_t* crm_update_peer_proc	(	const char *	source,
		crm_node_t *	peer,
		uint32_t	flag,
		const char *	status
	)

Definition at line 785 of file membership.c.

crm_node_t* crm_update_peer_state	(	const char *	source,
		crm_node_t *	node,
		const char *	state,
		int	membership
	)

Update a node's state and membership information.

Parameters

[in]	source	Caller's function name (for log messages)
[in]	node	Node object to update
[in]	state	Node's new state
[in]	membership	Node's new membership ID

Returns

NULL if any node was reaped, value of node otherwise

Note

If this function returns NULL, the supplied node object was likely freed and should not be used again. This function should not be called within a cache iteration if reaping is possible, otherwise reaping could invalidate the iterator.

Definition at line 965 of file membership.c.

void crm_update_peer_uname	(	crm_node_t *	node,
		const char *	uname
	)

Definition at line 732 of file membership.c.

gboolean node_name_is_valid	(	const char *	key,
		const char *	name
	)

Definition at line 334 of file cluster.c.

Variable Documentation

struct crm_ais_msg_s __attribute__

uint32_t compressed_size

Definition at line 90 of file internal.h.

char data[0]

Definition at line 92 of file internal.h.

AIS_Host host

Definition at line 86 of file internal.h.

uint32_t id

Definition at line 82 of file internal.h.

gboolean is_compressed

Definition at line 84 of file internal.h.

gboolean local

Definition at line 84 of file internal.h.

uint32_t pid

Definition at line 83 of file internal.h.

AIS_Host sender

Definition at line 87 of file internal.h.

uint32_t size

Definition at line 86 of file internal.h.

enum crm_ais_msg_types type

Definition at line 85 of file internal.h.

char uname[MAX_NAME]

Definition at line 87 of file internal.h.