This source file includes following definitions.
- pe__rsc_bool_str
- pe__current_node
- pe_hash_table_lookup
- pe_base_name_eq
1
2
3
4
5
6
7
8
9
10 #ifndef PE_INTERNAL__H
11 # define PE_INTERNAL__H
12 # include <string.h>
13 # include <crm/pengine/status.h>
14 # include <crm/pengine/remote_internal.h>
15 # include <crm/common/internal.h>
16 # include <crm/common/output_internal.h>
17
18 # define pe_rsc_info(rsc, fmt, args...) crm_log_tag(LOG_INFO, rsc ? rsc->id : "<NULL>", fmt, ##args)
19 # define pe_rsc_debug(rsc, fmt, args...) crm_log_tag(LOG_DEBUG, rsc ? rsc->id : "<NULL>", fmt, ##args)
20 # define pe_rsc_trace(rsc, fmt, args...) crm_log_tag(LOG_TRACE, rsc ? rsc->id : "<NULL>", fmt, ##args)
21
22 # define pe_err(fmt...) do { \
23 was_processing_error = TRUE; \
24 pcmk__config_err(fmt); \
25 } while (0)
26
27 # define pe_warn(fmt...) do { \
28 was_processing_warning = TRUE; \
29 pcmk__config_warn(fmt); \
30 } while (0)
31
32 # define pe_proc_err(fmt...) { was_processing_error = TRUE; crm_err(fmt); }
33 # define pe_proc_warn(fmt...) { was_processing_warning = TRUE; crm_warn(fmt); }
34
35 #define pe__set_working_set_flags(working_set, flags_to_set) do { \
36 (working_set)->flags = pcmk__set_flags_as(__func__, __LINE__, \
37 LOG_TRACE, "Working set", crm_system_name, \
38 (working_set)->flags, (flags_to_set), #flags_to_set); \
39 } while (0)
40
41 #define pe__clear_working_set_flags(working_set, flags_to_clear) do { \
42 (working_set)->flags = pcmk__clear_flags_as(__func__, __LINE__, \
43 LOG_TRACE, "Working set", crm_system_name, \
44 (working_set)->flags, (flags_to_clear), #flags_to_clear); \
45 } while (0)
46
47 #define pe__set_resource_flags(resource, flags_to_set) do { \
48 (resource)->flags = pcmk__set_flags_as(__func__, __LINE__, \
49 LOG_TRACE, "Resource", (resource)->id, (resource)->flags, \
50 (flags_to_set), #flags_to_set); \
51 } while (0)
52
53 #define pe__clear_resource_flags(resource, flags_to_clear) do { \
54 (resource)->flags = pcmk__clear_flags_as(__func__, __LINE__, \
55 LOG_TRACE, "Resource", (resource)->id, (resource)->flags, \
56 (flags_to_clear), #flags_to_clear); \
57 } while (0)
58
59 #define pe__set_action_flags(action, flags_to_set) do { \
60 (action)->flags = pcmk__set_flags_as(__func__, __LINE__, \
61 LOG_TRACE, \
62 "Action", (action)->uuid, \
63 (action)->flags, \
64 (flags_to_set), \
65 #flags_to_set); \
66 } while (0)
67
68 #define pe__clear_action_flags(action, flags_to_clear) do { \
69 (action)->flags = pcmk__clear_flags_as(__func__, __LINE__, \
70 LOG_TRACE, \
71 "Action", (action)->uuid, \
72 (action)->flags, \
73 (flags_to_clear), \
74 #flags_to_clear); \
75 } while (0)
76
77 #define pe__set_raw_action_flags(action_flags, action_name, flags_to_set) do { \
78 action_flags = pcmk__set_flags_as(__func__, __LINE__, \
79 LOG_TRACE, "Action", action_name, \
80 (action_flags), \
81 (flags_to_set), #flags_to_set); \
82 } while (0)
83
84 #define pe__clear_raw_action_flags(action_flags, action_name, flags_to_clear) do { \
85 action_flags = pcmk__clear_flags_as(__func__, __LINE__, \
86 LOG_TRACE, \
87 "Action", action_name, \
88 (action_flags), \
89 (flags_to_clear), \
90 #flags_to_clear); \
91 } while (0)
92
93 #define pe__set_action_flags_as(function, line, action, flags_to_set) do { \
94 (action)->flags = pcmk__set_flags_as((function), (line), \
95 LOG_TRACE, \
96 "Action", (action)->uuid, \
97 (action)->flags, \
98 (flags_to_set), \
99 #flags_to_set); \
100 } while (0)
101
102 #define pe__clear_action_flags_as(function, line, action, flags_to_clear) do { \
103 (action)->flags = pcmk__clear_flags_as((function), (line), \
104 LOG_TRACE, \
105 "Action", (action)->uuid, \
106 (action)->flags, \
107 (flags_to_clear), \
108 #flags_to_clear); \
109 } while (0)
110
111 #define pe__set_order_flags(order_flags, flags_to_set) do { \
112 order_flags = pcmk__set_flags_as(__func__, __LINE__, LOG_TRACE, \
113 "Ordering", "constraint", \
114 order_flags, (flags_to_set), \
115 #flags_to_set); \
116 } while (0)
117
118 #define pe__clear_order_flags(order_flags, flags_to_clear) do { \
119 order_flags = pcmk__clear_flags_as(__func__, __LINE__, LOG_TRACE, \
120 "Ordering", "constraint", \
121 order_flags, (flags_to_clear), \
122 #flags_to_clear); \
123 } while (0)
124
125 #define pe__set_graph_flags(graph_flags, gr_action, flags_to_set) do { \
126 graph_flags = pcmk__set_flags_as(__func__, __LINE__, \
127 LOG_TRACE, "Graph", \
128 (gr_action)->uuid, graph_flags, \
129 (flags_to_set), #flags_to_set); \
130 } while (0)
131
132 #define pe__clear_graph_flags(graph_flags, gr_action, flags_to_clear) do { \
133 graph_flags = pcmk__clear_flags_as(__func__, __LINE__, \
134 LOG_TRACE, "Graph", \
135 (gr_action)->uuid, graph_flags, \
136 (flags_to_clear), #flags_to_clear); \
137 } while (0)
138
139
140
141 enum pe_warn_once_e {
142 pe_wo_blind = (1 << 0),
143 pe_wo_restart_type = (1 << 1),
144 pe_wo_role_after = (1 << 2),
145 pe_wo_poweroff = (1 << 3),
146 pe_wo_require_all = (1 << 4),
147 pe_wo_order_score = (1 << 5),
148 pe_wo_neg_threshold = (1 << 6),
149 pe_wo_remove_after = (1 << 7),
150 };
151
152 extern uint32_t pe_wo;
153
154 #define pe_warn_once(pe_wo_bit, fmt...) do { \
155 if (!pcmk_is_set(pe_wo, pe_wo_bit)) { \
156 if (pe_wo_bit == pe_wo_blind) { \
157 crm_warn(fmt); \
158 } else { \
159 pe_warn(fmt); \
160 } \
161 pe_wo = pcmk__set_flags_as(__func__, __LINE__, LOG_TRACE, \
162 "Warn-once", "logging", pe_wo, \
163 (pe_wo_bit), #pe_wo_bit); \
164 } \
165 } while (0);
166
167
168 typedef struct pe__location_constraint_s {
169 char *id;
170 pe_resource_t *rsc_lh;
171 enum rsc_role_e role_filter;
172 enum pe_discover_e discover_mode;
173 GList *node_list_rh;
174 } pe__location_t;
175
176 typedef struct pe__order_constraint_s {
177 int id;
178 enum pe_ordering type;
179
180 void *lh_opaque;
181 pe_resource_t *lh_rsc;
182 pe_action_t *lh_action;
183 char *lh_action_task;
184
185 void *rh_opaque;
186 pe_resource_t *rh_rsc;
187 pe_action_t *rh_action;
188 char *rh_action_task;
189 } pe__ordering_t;
190
191 typedef struct notify_data_s {
192 GSList *keys;
193
194 const char *action;
195
196 pe_action_t *pre;
197 pe_action_t *post;
198 pe_action_t *pre_done;
199 pe_action_t *post_done;
200
201 GList *active;
202 GList *inactive;
203 GList *start;
204 GList *stop;
205 GList *demote;
206 GList *promote;
207 GList *promoted;
208 GList *unpromoted;
209 GHashTable *allowed_nodes;
210
211 } notify_data_t;
212
213 bool pe_can_fence(pe_working_set_t *data_set, pe_node_t *node);
214
215 int pe__add_scores(int score1, int score2);
216 void add_hash_param(GHashTable * hash, const char *name, const char *value);
217
218 char *native_parameter(pe_resource_t * rsc, pe_node_t * node, gboolean create, const char *name,
219 pe_working_set_t * data_set);
220 pe_node_t *native_location(const pe_resource_t *rsc, GList **list, int current);
221
222 void pe_metadata(void);
223 void verify_pe_options(GHashTable * options);
224
225 void common_update_score(pe_resource_t * rsc, const char *id, int score);
226 void native_add_running(pe_resource_t * rsc, pe_node_t * node, pe_working_set_t * data_set, gboolean failed);
227
228 gboolean native_unpack(pe_resource_t * rsc, pe_working_set_t * data_set);
229 gboolean group_unpack(pe_resource_t * rsc, pe_working_set_t * data_set);
230 gboolean clone_unpack(pe_resource_t * rsc, pe_working_set_t * data_set);
231 gboolean pe__unpack_bundle(pe_resource_t *rsc, pe_working_set_t *data_set);
232
233 pe_resource_t *native_find_rsc(pe_resource_t *rsc, const char *id, const pe_node_t *node,
234 int flags);
235
236 gboolean native_active(pe_resource_t * rsc, gboolean all);
237 gboolean group_active(pe_resource_t * rsc, gboolean all);
238 gboolean clone_active(pe_resource_t * rsc, gboolean all);
239 gboolean pe__bundle_active(pe_resource_t *rsc, gboolean all);
240
241 void native_print(pe_resource_t * rsc, const char *pre_text, long options, void *print_data);
242 void group_print(pe_resource_t * rsc, const char *pre_text, long options, void *print_data);
243 void clone_print(pe_resource_t * rsc, const char *pre_text, long options, void *print_data);
244 void pe__print_bundle(pe_resource_t *rsc, const char *pre_text, long options,
245 void *print_data);
246
247 gchar * pcmk__native_output_string(pe_resource_t *rsc, const char *name, pe_node_t *node,
248 long options, const char *target_role, bool show_nodes);
249
250 int pe__name_and_nvpairs_xml(pcmk__output_t *out, bool is_list, const char *tag_name
251 , size_t pairs_count, ...);
252 char *pe__node_display_name(pe_node_t *node, bool print_detail);
253
254 static inline const char *
255 pe__rsc_bool_str(pe_resource_t *rsc, uint64_t rsc_flag)
256 {
257 return pcmk__btoa(pcmk_is_set(rsc->flags, rsc_flag));
258 }
259
260 int pe__clone_xml(pcmk__output_t *out, va_list args);
261 int pe__clone_html(pcmk__output_t *out, va_list args);
262 int pe__clone_text(pcmk__output_t *out, va_list args);
263 int pe__group_xml(pcmk__output_t *out, va_list args);
264 int pe__group_html(pcmk__output_t *out, va_list args);
265 int pe__group_text(pcmk__output_t *out, va_list args);
266 int pe__bundle_xml(pcmk__output_t *out, va_list args);
267 int pe__bundle_html(pcmk__output_t *out, va_list args);
268 int pe__bundle_text(pcmk__output_t *out, va_list args);
269 int pe__node_html(pcmk__output_t *out, va_list args);
270 int pe__node_text(pcmk__output_t *out, va_list args);
271 int pe__node_xml(pcmk__output_t *out, va_list args);
272 int pe__resource_xml(pcmk__output_t *out, va_list args);
273 int pe__resource_html(pcmk__output_t *out, va_list args);
274 int pe__resource_text(pcmk__output_t *out, va_list args);
275
276
277 int pe__ban_text(pcmk__output_t *out, va_list args);
278 int pe__cluster_counts_text(pcmk__output_t *out, va_list args);
279 int pe__cluster_dc_text(pcmk__output_t *out, va_list args);
280 int pe__cluster_maint_mode_text(pcmk__output_t *out, va_list args);
281 int pe__cluster_options_text(pcmk__output_t *out, va_list args);
282 int pe__cluster_stack_text(pcmk__output_t *out, va_list args);
283 int pe__cluster_summary(pcmk__output_t *out, va_list args);
284 int pe__cluster_times_text(pcmk__output_t *out, va_list args);
285 int pe__failed_action_text(pcmk__output_t *out, va_list args);
286 int pe__node_attribute_text(pcmk__output_t *out, va_list args);
287 int pe__node_list_text(pcmk__output_t *out, va_list args);
288 int pe__op_history_text(pcmk__output_t *out, va_list args);
289 int pe__resource_history_text(pcmk__output_t *out, va_list args);
290 int pe__ticket_text(pcmk__output_t *out, va_list args);
291
292 void native_free(pe_resource_t * rsc);
293 void group_free(pe_resource_t * rsc);
294 void clone_free(pe_resource_t * rsc);
295 void pe__free_bundle(pe_resource_t *rsc);
296
297 enum rsc_role_e native_resource_state(const pe_resource_t * rsc, gboolean current);
298 enum rsc_role_e group_resource_state(const pe_resource_t * rsc, gboolean current);
299 enum rsc_role_e clone_resource_state(const pe_resource_t * rsc, gboolean current);
300 enum rsc_role_e pe__bundle_resource_state(const pe_resource_t *rsc,
301 gboolean current);
302
303 void pe__count_common(pe_resource_t *rsc);
304 void pe__count_bundle(pe_resource_t *rsc);
305
306 gboolean common_unpack(xmlNode * xml_obj, pe_resource_t ** rsc, pe_resource_t * parent,
307 pe_working_set_t * data_set);
308 void common_free(pe_resource_t * rsc);
309
310 pe_node_t *pe__copy_node(const pe_node_t *this_node);
311 extern time_t get_effective_time(pe_working_set_t * data_set);
312
313
314
315
316 enum pe_fc_flags_e {
317 pe_fc_default = (1 << 0),
318 pe_fc_effective = (1 << 1),
319 pe_fc_fillers = (1 << 2),
320 };
321
322 int pe_get_failcount(pe_node_t *node, pe_resource_t *rsc, time_t *last_failure,
323 uint32_t flags, xmlNode *xml_op,
324 pe_working_set_t *data_set);
325
326 pe_action_t *pe__clear_failcount(pe_resource_t *rsc, pe_node_t *node,
327 const char *reason,
328 pe_working_set_t *data_set);
329
330
331
332 pe_node_t *pe__find_active_on(const pe_resource_t *rsc,
333 unsigned int *count_all,
334 unsigned int *count_clean);
335 pe_node_t *pe__find_active_requires(const pe_resource_t *rsc,
336 unsigned int *count);
337
338 static inline pe_node_t *
339 pe__current_node(const pe_resource_t *rsc)
340 {
341 return pe__find_active_on(rsc, NULL, NULL);
342 }
343
344
345
346 extern void node_list_exclude(GHashTable * list, GList *list2, gboolean merge_scores);
347
348 GHashTable *pe__node_list2table(GList *list);
349
350 static inline gpointer
351 pe_hash_table_lookup(GHashTable * hash, gconstpointer key)
352 {
353 if (hash) {
354 return g_hash_table_lookup(hash, key);
355 }
356 return NULL;
357 }
358
359 extern pe_action_t *get_pseudo_op(const char *name, pe_working_set_t * data_set);
360 extern gboolean order_actions(pe_action_t * lh_action, pe_action_t * rh_action, enum pe_ordering order);
361
362
363 extern void print_str_str(gpointer key, gpointer value, gpointer user_data);
364 extern void pe__output_node(pe_node_t * node, gboolean details, pcmk__output_t *out);
365
366 void pe__show_node_weights_as(const char *file, const char *function,
367 int line, bool to_log, pe_resource_t *rsc,
368 const char *comment, GHashTable *nodes,
369 pe_working_set_t *data_set);
370
371 #define pe__show_node_weights(level, rsc, text, nodes, data_set) \
372 pe__show_node_weights_as(__FILE__, __func__, __LINE__, \
373 (level), (rsc), (text), (nodes), (data_set))
374
375
376 extern gint sort_rsc_priority(gconstpointer a, gconstpointer b);
377 extern gint sort_rsc_index(gconstpointer a, gconstpointer b);
378
379 extern xmlNode *find_rsc_op_entry(pe_resource_t * rsc, const char *key);
380
381 extern pe_action_t *custom_action(pe_resource_t * rsc, char *key, const char *task, pe_node_t * on_node,
382 gboolean optional, gboolean foo, pe_working_set_t * data_set);
383
384 # define delete_key(rsc) pcmk__op_key(rsc->id, CRMD_ACTION_DELETE, 0)
385 # define delete_action(rsc, node, optional) custom_action( \
386 rsc, delete_key(rsc), CRMD_ACTION_DELETE, node, \
387 optional, TRUE, data_set);
388
389 # define stopped_key(rsc) pcmk__op_key(rsc->id, CRMD_ACTION_STOPPED, 0)
390 # define stopped_action(rsc, node, optional) custom_action( \
391 rsc, stopped_key(rsc), CRMD_ACTION_STOPPED, node, \
392 optional, TRUE, data_set);
393
394 # define stop_key(rsc) pcmk__op_key(rsc->id, CRMD_ACTION_STOP, 0)
395 # define stop_action(rsc, node, optional) custom_action( \
396 rsc, stop_key(rsc), CRMD_ACTION_STOP, node, \
397 optional, TRUE, data_set);
398
399 # define reload_key(rsc) pcmk__op_key(rsc->id, CRMD_ACTION_RELOAD_AGENT, 0)
400 # define start_key(rsc) pcmk__op_key(rsc->id, CRMD_ACTION_START, 0)
401 # define start_action(rsc, node, optional) custom_action( \
402 rsc, start_key(rsc), CRMD_ACTION_START, node, \
403 optional, TRUE, data_set)
404
405 # define started_key(rsc) pcmk__op_key(rsc->id, CRMD_ACTION_STARTED, 0)
406 # define started_action(rsc, node, optional) custom_action( \
407 rsc, started_key(rsc), CRMD_ACTION_STARTED, node, \
408 optional, TRUE, data_set)
409
410 # define promote_key(rsc) pcmk__op_key(rsc->id, CRMD_ACTION_PROMOTE, 0)
411 # define promote_action(rsc, node, optional) custom_action( \
412 rsc, promote_key(rsc), CRMD_ACTION_PROMOTE, node, \
413 optional, TRUE, data_set)
414
415 # define promoted_key(rsc) pcmk__op_key(rsc->id, CRMD_ACTION_PROMOTED, 0)
416 # define promoted_action(rsc, node, optional) custom_action( \
417 rsc, promoted_key(rsc), CRMD_ACTION_PROMOTED, node, \
418 optional, TRUE, data_set)
419
420 # define demote_key(rsc) pcmk__op_key(rsc->id, CRMD_ACTION_DEMOTE, 0)
421 # define demote_action(rsc, node, optional) custom_action( \
422 rsc, demote_key(rsc), CRMD_ACTION_DEMOTE, node, \
423 optional, TRUE, data_set)
424
425 # define demoted_key(rsc) pcmk__op_key(rsc->id, CRMD_ACTION_DEMOTED, 0)
426 # define demoted_action(rsc, node, optional) custom_action( \
427 rsc, demoted_key(rsc), CRMD_ACTION_DEMOTED, node, \
428 optional, TRUE, data_set)
429
430 extern int pe_get_configured_timeout(pe_resource_t *rsc, const char *action,
431 pe_working_set_t *data_set);
432
433 extern pe_action_t *find_first_action(GList *input, const char *uuid, const char *task,
434 pe_node_t * on_node);
435 extern enum action_tasks get_complex_task(pe_resource_t * rsc, const char *name,
436 gboolean allow_non_atomic);
437
438 extern GList *find_actions(GList *input, const char *key, const pe_node_t *on_node);
439 GList *find_actions_exact(GList *input, const char *key,
440 const pe_node_t *on_node);
441 extern GList *find_recurring_actions(GList *input, pe_node_t * not_on_node);
442 GList *pe__resource_actions(const pe_resource_t *rsc, const pe_node_t *node,
443 const char *task, bool require_node);
444
445 extern void pe_free_action(pe_action_t * action);
446
447 extern void resource_location(pe_resource_t * rsc, pe_node_t * node, int score, const char *tag,
448 pe_working_set_t * data_set);
449
450 extern gint sort_op_by_callid(gconstpointer a, gconstpointer b);
451 extern gboolean get_target_role(pe_resource_t * rsc, enum rsc_role_e *role);
452 void pe__set_next_role(pe_resource_t *rsc, enum rsc_role_e role,
453 const char *why);
454
455 extern pe_resource_t *find_clone_instance(pe_resource_t * rsc, const char *sub_id,
456 pe_working_set_t * data_set);
457
458 extern void destroy_ticket(gpointer data);
459 extern pe_ticket_t *ticket_new(const char *ticket_id, pe_working_set_t * data_set);
460
461
462 const char *pe_base_name_end(const char *id);
463 char *clone_strip(const char *last_rsc_id);
464 char *clone_zero(const char *last_rsc_id);
465
466 static inline bool
467 pe_base_name_eq(pe_resource_t *rsc, const char *id)
468 {
469 if (id && rsc && rsc->id) {
470
471 size_t base_len = pe_base_name_end(rsc->id) - rsc->id + 1;
472
473 return (strlen(id) == base_len) && !strncmp(id, rsc->id, base_len);
474 }
475 return FALSE;
476 }
477
478 int pe__target_rc_from_xml(xmlNode *xml_op);
479
480 gint sort_node_uname(gconstpointer a, gconstpointer b);
481 bool is_set_recursive(pe_resource_t * rsc, long long flag, bool any);
482
483 enum rsc_digest_cmp_val {
484
485 RSC_DIGEST_MATCH = 0,
486
487 RSC_DIGEST_RESTART,
488
489 RSC_DIGEST_ALL,
490
491
492 RSC_DIGEST_UNKNOWN,
493 };
494
495 typedef struct op_digest_cache_s {
496 enum rsc_digest_cmp_val rc;
497 xmlNode *params_all;
498 xmlNode *params_secure;
499 xmlNode *params_restart;
500 char *digest_all_calc;
501 char *digest_secure_calc;
502 char *digest_restart_calc;
503 } op_digest_cache_t;
504
505 op_digest_cache_t *pe__calculate_digests(pe_resource_t *rsc, const char *task,
506 guint *interval_ms, pe_node_t *node,
507 xmlNode *xml_op, GHashTable *overrides,
508 bool calc_secure,
509 pe_working_set_t *data_set);
510
511 void pe__free_digests(gpointer ptr);
512
513 op_digest_cache_t *rsc_action_digest_cmp(pe_resource_t * rsc, xmlNode * xml_op, pe_node_t * node,
514 pe_working_set_t * data_set);
515
516 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);
517 void trigger_unfencing(
518 pe_resource_t * rsc, pe_node_t *node, const char *reason, pe_action_t *dependency, pe_working_set_t * data_set);
519
520 void pe_action_set_reason(pe_action_t *action, const char *reason, bool overwrite);
521 void pe_action_set_flag_reason(const char *function, long line, pe_action_t *action, pe_action_t *reason, const char *text, enum pe_action_flags flags, bool overwrite);
522
523 #define pe_action_required(action, reason, text) \
524 pe_action_set_flag_reason(__func__, __LINE__, action, reason, text, \
525 pe_action_optional, FALSE)
526 #define pe_action_implies(action, reason, flag) \
527 pe_action_set_flag_reason(__func__, __LINE__, action, reason, NULL, \
528 flag, FALSE)
529
530 void pe__set_resource_flags_recursive(pe_resource_t *rsc, uint64_t flags);
531 void pe__clear_resource_flags_recursive(pe_resource_t *rsc, uint64_t flags);
532 void pe__clear_resource_flags_on_all(pe_working_set_t *data_set, uint64_t flag);
533
534 gboolean add_tag_ref(GHashTable * tags, const char * tag_name, const char * obj_ref);
535
536 void print_rscs_brief(GList *rsc_list, const char * pre_text, long options,
537 void * print_data, gboolean print_all);
538 int pe__rscs_brief_output(pcmk__output_t *out, GList *rsc_list, long options, gboolean print_all);
539 void pe_fence_node(pe_working_set_t * data_set, pe_node_t * node, const char *reason, bool priority_delay);
540
541 pe_node_t *pe_create_node(const char *id, const char *uname, const char *type,
542 const char *score, pe_working_set_t * data_set);
543 void common_print(pe_resource_t * rsc, const char *pre_text, const char *name, pe_node_t *node, long options, void *print_data);
544 int pe__common_output_text(pcmk__output_t *out, pe_resource_t * rsc, const char *name, pe_node_t *node, long options);
545 int pe__common_output_html(pcmk__output_t *out, pe_resource_t * rsc, const char *name, pe_node_t *node, long options);
546 pe_resource_t *pe__find_bundle_replica(const pe_resource_t *bundle,
547 const pe_node_t *node);
548 bool pe__bundle_needs_remote_name(pe_resource_t *rsc,
549 pe_working_set_t *data_set);
550 const char *pe__add_bundle_remote_name(pe_resource_t *rsc,
551 pe_working_set_t *data_set,
552 xmlNode *xml, const char *field);
553 const char *pe_node_attribute_calculated(const pe_node_t *node,
554 const char *name,
555 const pe_resource_t *rsc);
556 const char *pe_node_attribute_raw(pe_node_t *node, const char *name);
557 bool pe__is_universal_clone(pe_resource_t *rsc,
558 pe_working_set_t *data_set);
559 void pe__add_param_check(xmlNode *rsc_op, pe_resource_t *rsc, pe_node_t *node,
560 enum pe_check_parameters, pe_working_set_t *data_set);
561 void pe__foreach_param_check(pe_working_set_t *data_set,
562 void (*cb)(pe_resource_t*, pe_node_t*, xmlNode*,
563 enum pe_check_parameters,
564 pe_working_set_t*));
565 void pe__free_param_checks(pe_working_set_t *data_set);
566
567 bool pe__shutdown_requested(pe_node_t *node);
568 void pe__update_recheck_time(time_t recheck, pe_working_set_t *data_set);
569
570
571
572
573
574 void pe__register_messages(pcmk__output_t *out);
575
576 void pe__unpack_dataset_nvpairs(xmlNode *xml_obj, const char *set_name,
577 pe_rule_eval_data_t *rule_data, GHashTable *hash,
578 const char *always_first, gboolean overwrite,
579 pe_working_set_t *data_set);
580
581 bool pe__resource_is_disabled(pe_resource_t *rsc);
582 pe_action_t *pe__clear_resource_history(pe_resource_t *rsc, pe_node_t *node,
583 pe_working_set_t *data_set);
584
585 GList *pe__rscs_with_tag(pe_working_set_t *data_set, const char *tag_name);
586 GList *pe__unames_with_tag(pe_working_set_t *data_set, const char *tag_name);
587 bool pe__rsc_has_tag(pe_working_set_t *data_set, const char *rsc, const char *tag);
588 bool pe__uname_has_tag(pe_working_set_t *data_set, const char *node, const char *tag);
589
590 bool pe__rsc_running_on_any_node_in_list(pe_resource_t *rsc, GList *node_list);
591 GList *pe__filter_rsc_list(GList *rscs, GList *filter);
592 GList * pe__build_node_name_list(pe_working_set_t *data_set, const char *s);
593 GList * pe__build_rsc_list(pe_working_set_t *data_set, const char *s);
594
595 bool pcmk__rsc_filtered_by_node(pe_resource_t *rsc, GList *only_node);
596
597 gboolean pe__bundle_is_filtered(pe_resource_t *rsc, GList *only_rsc, gboolean check_parent);
598 gboolean pe__clone_is_filtered(pe_resource_t *rsc, GList *only_rsc, gboolean check_parent);
599 gboolean pe__group_is_filtered(pe_resource_t *rsc, GList *only_rsc, gboolean check_parent);
600 gboolean pe__native_is_filtered(pe_resource_t *rsc, GList *only_rsc, gboolean check_parent);
601
602 #endif