1
2
3
4
5
6
7
8
9
10 #ifndef XML_CRM_MESSAGES__H
11 # define XML_CRM_MESSAGES__H
12
13 # include <crm/crm.h>
14 # include <crm/common/ipc_internal.h>
15 # include <crm/common/xml.h>
16 # include <crm/cluster/internal.h>
17 # include <controld_fsa.h>
18
19 typedef struct ha_msg_input_s {
20 xmlNode *msg;
21 xmlNode *xml;
22
23 } ha_msg_input_t;
24
25 extern ha_msg_input_t *new_ha_msg_input(xmlNode * orig);
26 extern void delete_ha_msg_input(ha_msg_input_t * orig);
27
28 extern void *fsa_typed_data_adv(fsa_data_t * fsa_data, enum fsa_data_type a_type,
29 const char *caller);
30
31 # define fsa_typed_data(x) fsa_typed_data_adv(msg_data, x, __func__)
32
33 extern void register_fsa_error_adv(enum crmd_fsa_cause cause, enum crmd_fsa_input input,
34 fsa_data_t * cur_data, void *new_data, const char *raised_from);
35
36 #define register_fsa_error(cause, input, new_data) \
37 register_fsa_error_adv(cause, input, msg_data, new_data, __func__)
38
39 extern int register_fsa_input_adv(enum crmd_fsa_cause cause, enum crmd_fsa_input input,
40 void *data, uint64_t with_actions,
41 gboolean prepend, const char *raised_from);
42
43 extern void fsa_dump_queue(int log_level);
44 extern void route_message(enum crmd_fsa_cause cause, xmlNode * input);
45
46 # define crmd_fsa_stall(suppress) do { \
47 if(suppress == FALSE && msg_data != NULL) { \
48 register_fsa_input_adv( \
49 ((fsa_data_t*)msg_data)->fsa_cause, I_WAIT_FOR_EVENT, \
50 ((fsa_data_t*)msg_data)->data, action, TRUE, __func__); \
51 } else { \
52 register_fsa_input_adv( \
53 C_FSA_INTERNAL, I_WAIT_FOR_EVENT, \
54 NULL, action, TRUE, __func__); \
55 } \
56 } while(0)
57
58 #define register_fsa_input(cause, input, data) \
59 register_fsa_input_adv(cause, input, data, A_NOTHING, FALSE, __func__)
60
61 #define register_fsa_input_before(cause, input, data) \
62 register_fsa_input_adv(cause, input, data, A_NOTHING, TRUE, __func__)
63
64 #define register_fsa_input_later(cause, input, data) \
65 register_fsa_input_adv(cause, input, data, A_NOTHING, FALSE, __func__)
66
67 void delete_fsa_input(fsa_data_t * fsa_data);
68
69 fsa_data_t *get_message(void);
70
71 extern gboolean relay_message(xmlNode * relay_message, gboolean originated_locally);
72
73 gboolean crmd_is_proxy_session(const char *session);
74 void crmd_proxy_send(const char *session, xmlNode *msg);
75
76 bool controld_authorize_ipc_message(xmlNode *client_msg,
77 pcmk__client_t *curr_client,
78 const char *proxy_session);
79
80 extern gboolean send_request(xmlNode * msg, char **msg_reference);
81
82 extern ha_msg_input_t *copy_ha_msg_input(ha_msg_input_t * orig);
83
84 void send_remote_state_message(const char *node_name, gboolean node_up);
85
86 #endif