 |
pacemaker
2.0.4-2deceaa3ae
Scalable High-Availability cluster resource manager
|
Go to the documentation of this file.
17 #include <libxml/tree.h>
24 static GMainLoop *mainloop = NULL;
52 value = strchr(
target,
'=');
56 }
else if (*
target ==
'@') {
65 name, value, fence_level,
69 name, value, fence_level);
85 async_fence_data.rc = e->
result;
86 g_main_loop_quit(mainloop);
93 async_fence_data.rc =
data->rc;
95 g_main_loop_quit(mainloop);
99 async_fence_helper(gpointer user_data)
106 fprintf(stderr,
"Could not connect to fencer: %s\n",
pcmk_strerror(
rc));
107 g_main_loop_quit(mainloop);
115 async_fence_data.target,
116 async_fence_data.action,
117 async_fence_data.timeout/1000,
118 async_fence_data.tolerance/1000,
119 async_fence_data.delay);
122 g_main_loop_quit(mainloop);
128 async_fence_data.timeout/1000,
141 async_fence_data.st =
st;
142 async_fence_data.name = strdup(
name);
143 async_fence_data.target =
target;
144 async_fence_data.action =
action;
145 async_fence_data.timeout =
timeout;
147 async_fence_data.delay =
delay;
153 mainloop = g_main_loop_new(NULL, FALSE);
154 g_main_loop_run(mainloop);
156 free(async_fence_data.name);
161 #ifdef BUILD_PUBLIC_LIBPACEMAKER
173 unsigned int timeout,
bool quiet,
int verbose,
174 bool broadcast,
bool cleanup) {
180 out->
info(out,
"cleaning up fencing-history%s%s",
184 out->
info(out,
"gather fencing-history from all nodes");
199 out->
begin_list(out,
"event",
"events",
"Fencing history");
202 for (hp = history; hp; hp = hp->
next) {
207 if (quiet || !verbose) {
217 out->
info(out,
"%lld", (
long long) latest->completed);
218 }
else if (!verbose) {
219 out->
message(out,
"stonith-event", latest, 0, FALSE);
230 #ifdef BUILD_PUBLIC_LIBPACEMAKER
233 bool quiet,
int verbose,
bool broadcast,
bool cleanup) {
260 out->
begin_list(out,
"fence device",
"fence devices",
"Installed fence devices");
262 out->
list_item(out,
"device",
"%s", dIter->value);
270 #ifdef BUILD_PUBLIC_LIBPACEMAKER
304 #ifdef BUILD_PUBLIC_LIBPACEMAKER
306 pcmk_fence_last(xmlNodePtr *xml,
const char *
target,
bool as_nodeid) {
323 const char *device_id,
unsigned int timeout) {
324 GList *targets = NULL;
335 out->
begin_list(out,
"fence target",
"fence targets",
"Fence Targets");
336 while (targets != NULL) {
337 out->
list_item(out, NULL,
"%s", (
const char *) targets->data);
338 targets = targets->next;
346 #ifdef BUILD_PUBLIC_LIBPACEMAKER
348 pcmk_fence_list_targets(xmlNodePtr *xml,
stonith_t *
st,
const char *device_id,
380 #ifdef BUILD_PUBLIC_LIBPACEMAKER
382 pcmk_fence_metadata(xmlNodePtr *xml,
stonith_t *
st,
char *agent,
410 out->
begin_list(out,
"fence device",
"fence devices",
"Registered fence devices");
412 out->
list_item(out,
"device",
"%s", dIter->value);
424 #ifdef BUILD_PUBLIC_LIBPACEMAKER
445 return handle_level(
st,
target, fence_level, devices,
true);
448 #ifdef BUILD_PUBLIC_LIBPACEMAKER
458 return handle_level(
st,
target, fence_level, NULL,
false);
461 #ifdef BUILD_PUBLIC_LIBPACEMAKER
473 char *error_output = NULL;
477 timeout/1000, &output, &error_output);
478 out->
message(out,
"validate", agent,
id, output, error_output,
rc);
482 #ifdef BUILD_PUBLIC_LIBPACEMAKER
484 pcmk_fence_validate(xmlNodePtr *xml,
stonith_t *
st,
const char *agent,
Function and executable result codes.
int(* register_notification)(stonith_t *st, const char *event, void(*notify)(stonith_t *st, stonith_event_t *e))
int pcmk__fence_action(stonith_t *st, const char *target, const char *action, const char *name, unsigned int timeout, unsigned int tolerance, int delay)
Perform a STONITH action.
void(*) void(*) void(* output_xml)(pcmk__output_t *out, const char *name, const char *buf)
int pcmk__fence_installed(pcmk__output_t *out, stonith_t *st, unsigned int timeout)
List all installed STONITH agents.
int(* metadata)(stonith_t *st, int options, const char *device, const char *provider, char **output, int timeout)
Get the metadata documentation for a resource.
int pcmk__fence_unregister_level(stonith_t *st, char *target, int fence_level)
Unregister a fencing level for a specific node, node regex, or attribute.
const char * pcmk_strerror(int rc)
int(* list)(stonith_t *st, int options, const char *id, char **list_output, int timeout)
Retrieve string listing hosts and port assignments from a local stonith device.
void(*) void(* list_item)(pcmk__output_t *out, const char *name, const char *format,...) G_GNUC_PRINTF(3
int pcmk__fence_last(pcmk__output_t *out, const char *target, bool as_nodeid)
When was a device last fenced?
#define safe_str_eq(a, b)
int pcmk__fence_history(pcmk__output_t *out, stonith_t *st, char *target, unsigned int timeout, bool quiet, int verbose, bool broadcast, bool cleanup)
List the fencing operations that have occurred for a specific node.
GList * stonith__parse_targets(const char *hosts)
int(* register_level_full)(stonith_t *st, int options, const char *node, const char *pattern, const char *attr, const char *value, int level, stonith_key_value_t *device_list)
Register fencing level for specific node, node regex or attribute.
int(* message)(pcmk__output_t *out, const char *message_id,...)
int(* history)(stonith_t *st, int options, const char *node, stonith_history_t **output, int timeout)
Retrieve a list of fencing operations that have occurred for a specific node.
int(* fence_with_delay)(stonith_t *st, int options, const char *node, const char *action, int timeout, int tolerance, int delay)
Issue a fencing action against a node with requested fencing delay.
struct stonith_key_value_s * next
int(* validate)(stonith_t *st, int call_options, const char *rsc_id, const char *namespace_s, const char *agent, stonith_key_value_t *params, int timeout, char **output, char **error_output)
Validate an arbitrary stonith device configuration.
Wrappers for and extensions to glib mainloop.
struct stonith_history_s * next
int(* remove_level_full)(stonith_t *st, int options, const char *node, const char *pattern, const char *attr, const char *value, int level)
Remove fencing level for specific node, node regex or attribute.
crm_trigger_t * mainloop_add_trigger(int priority, int(*dispatch)(gpointer user_data), gpointer userdata)
int pcmk__fence_register_level(stonith_t *st, char *target, int fence_level, stonith_key_value_t *devices)
Register a fencing level for a specific node, node regex, or attribute.
stonith_history_t * stonith__sort_history(stonith_history_t *history)
void pcmk__out_epilogue(pcmk__output_t *out, xmlNodePtr *xml, int retval)
void(* end_list)(pcmk__output_t *out)
int pcmk__out_prologue(pcmk__output_t **out, xmlNodePtr *xml)
int(* query)(stonith_t *st, int options, const char *node, stonith_key_value_t **devices, int timeout)
Retrieve a list of registered stonith devices.
struct trigger_s crm_trigger_t
void(*) void(*) void(* increment_list)(pcmk__output_t *out)
int pcmk__fence_validate(pcmk__output_t *out, stonith_t *st, const char *agent, const char *id, stonith_key_value_t *params, unsigned int timeout)
Validate a STONITH device configuration.
void stonith_key_value_freeall(stonith_key_value_t *kvp, int keys, int values)
void mainloop_set_trigger(crm_trigger_t *source)
void(* begin_list)(pcmk__output_t *out, const char *singular_noun, const char *plural_noun, const char *format,...) G_GNUC_PRINTF(4
int pcmk__fence_registered(pcmk__output_t *out, stonith_t *st, char *target, unsigned int timeout)
List registered fence devices.
int pcmk__fence_metadata(pcmk__output_t *out, stonith_t *st, char *agent, unsigned int timeout)
Get metadata for a resource.
int pcmk_legacy2rc(int legacy_rc)
gboolean stonith__later_succeeded(stonith_history_t *event, stonith_history_t *top_history)
#define T_STONITH_NOTIFY_FENCE
This structure contains everything that makes up a single output formatter.
stonith_api_operations_t * cmds
bool supports_quiet
Does this formatter support a special quiet mode?
int pcmk__fence_list_targets(pcmk__output_t *out, stonith_t *st, const char *device_id, unsigned int timeout)
List nodes that can be fenced.
int(* register_callback)(stonith_t *st, int call_id, int timeout, int options, void *userdata, const char *callback_name, void(*callback)(stonith_t *st, stonith_callback_data_t *data))
Register a callback to receive the result of an asynchronous call.
void(* info)(pcmk__output_t *out, const char *format,...) G_GNUC_PRINTF(2
time_t stonith_api_time(uint32_t nodeid, const char *uname, bool in_progress)
void stonith_history_free(stonith_history_t *history)
int(* list_agents)(stonith_t *stonith, int call_options, const char *provider, stonith_key_value_t **devices, int timeout)
Retrieve a list of installed stonith agents.
Formatted output for pacemaker tools.
int stonith_api_connect_retry(stonith_t *st, const char *name, int max_attempts)
Make a blocking connection attempt to the fencer.