24 #define RH_STONITH_PREFIX "fence_" 40 struct dirent **namelist;
43 #if _POSIX_C_SOURCE < 200809L && !(defined(O_SEARCH) || defined(O_PATH)) 44 char buffer[FILENAME_MAX + 1];
45 #elif defined(O_SEARCH) 51 for (i = 0; i < file_num; i++) {
55 #if _POSIX_C_SOURCE < 200809L && !(defined(O_SEARCH) || defined(O_PATH)) 58 if (stat(buffer, &prop) == 0 && S_ISREG(prop.st_mode)) {
71 if (fstatat(dirfd, namelist[i]->d_name, &prop, 0) == 0
72 && S_ISREG(prop.st_mode)) {
84 #if _POSIX_C_SOURCE >= 200809L || defined(O_SEARCH) || defined(O_PATH) 93 stonith_rhcs_parameter_not_required(xmlNode *metadata,
const char *parameter)
96 xmlXPathObject *xpathObj = NULL;
105 if (numXpathResults(xpathObj) > 0) {
124 stonith__rhcs_get_metadata(
const char *agent,
int timeout, xmlNode **metadata)
128 xmlNode *actions = NULL;
129 xmlXPathObject *xpathObj = NULL;
131 5, NULL, NULL, NULL);
135 crm_warn(
"Could not execute metadata action for %s: %s " 150 if (buffer == NULL) {
151 crm_warn(
"Metadata action for %s returned no data", agent);
159 crm_warn(
"Metadata for %s is invalid", agent);
164 if (numXpathResults(xpathObj) > 0) {
171 if (numXpathResults(xpathObj) <= 0) {
185 stonith_rhcs_parameter_not_required(xml,
"action");
186 stonith_rhcs_parameter_not_required(xml,
"plug");
187 stonith_rhcs_parameter_not_required(xml,
"port");
214 int rc = stonith__rhcs_get_metadata(agent,
timeout, &xml);
223 if (buffer == NULL) {
239 int rc = stat(buffer, &prop);
242 return (
rc >= 0) && S_ISREG(prop.st_mode);
247 const char *agent, GHashTable *params,
248 const char * host_arg,
int timeout,
249 char **output,
char **error_output)
252 int remaining_timeout =
timeout;
253 xmlNode *metadata = NULL;
256 if (host_arg == NULL) {
257 time_t start_time = time(NULL);
259 rc = stonith__rhcs_get_metadata(agent, remaining_timeout, &metadata);
262 uint32_t device_flags = 0;
276 remaining_timeout -= time(NULL) - start_time;
278 if (
rc == -
ETIME || remaining_timeout <= 0 ) {
287 target, 0, remaining_timeout, params,
void stonith__destroy_action(stonith_action_t *action)
#define CRM_CHECK(expr, failure_action)
struct stonith_action_s stonith_action_t
#define pcmk_err_schema_validation
#define crm_notice(fmt, args...)
bool stonith__agent_is_rhcs(const char *agent)
const char * pcmk_strerror(int rc)
void stonith__action_result(stonith_action_t *action, int *rc, char **output, char **error_output)
#define PCMK__FENCE_BINDIR
int alphasort(const void *dirent1, const void *dirent2)
const char * crm_xml_add(xmlNode *node, const char *name, const char *value)
Create an XML attribute with specified name and value.
stonith_action_t * stonith_action_create(const char *agent, const char *_action, const char *victim, uint32_t victim_nodeid, int timeout, GHashTable *device_args, GHashTable *port_map, const char *host_arg)
int stonith__rhcs_metadata(const char *agent, int timeout, char **output)
Execute RHCS-compatible agent's meta-data action.
int stonith__rhcs_validate(stonith_t *st, int call_options, const char *target, const char *agent, GHashTable *params, const char *host_arg, int timeout, char **output, char **error_output)
xmlNode * string2xml(const char *input)
stonith_key_value_t * stonith_key_value_add(stonith_key_value_t *kvp, const char *key, const char *value)
#define crm_warn(fmt, args...)
void stonith__device_parameter_flags(uint32_t *device_flags, const char *device_name, xmlNode *metadata)
char * crm_strdup_printf(char const *format,...) G_GNUC_PRINTF(1
#define pcmk_is_set(g, f)
Convenience alias for pcmk_all_flags_set(), to check single flag.
xmlNode * create_xml_node(xmlNode *parent, const char *name)
#define CRM_DEFAULT_OP_TIMEOUT_S
void free_xml(xmlNode *child)
#define RH_STONITH_PREFIX
int stonith__list_rhcs_agents(stonith_key_value_t **devices)
xmlXPathObjectPtr xpath_search(xmlNode *xml_top, const char *path)
xmlNode * getXpathResult(xmlXPathObjectPtr xpathObj, int index)
bool pcmk__starts_with(const char *str, const char *prefix)
Check whether a string starts with a certain sequence.
void freeXpathObject(xmlXPathObjectPtr xpathObj)
char * dump_xml_formatted_with_text(xmlNode *msg)
G_GNUC_INTERNAL int stonith__execute(stonith_action_t *action)