34 struct dirent **namelist;
39 char buffer[FILENAME_MAX + 1];
42 if (
'.' == namelist[file_num]->d_name[0]) {
43 free(namelist[file_num]);
48 free(namelist[file_num]);
53 namelist[file_num]->d_name);
54 if (stat(buffer, &prop) == 0 && S_ISREG(prop.st_mode)) {
56 namelist[file_num]->d_name);
60 free(namelist[file_num]);
68 stonith_rhcs_parameter_not_required(xmlNode *metadata,
const char *parameter)
71 xmlXPathObject *xpathObj = NULL;
80 if (numXpathResults(xpathObj) > 0) {
99 stonith__rhcs_get_metadata(
const char *agent,
int timeout, xmlNode **metadata)
103 xmlNode *actions = NULL;
104 xmlXPathObject *xpathObj = NULL;
106 5, NULL, NULL, NULL);
110 crm_warn(
"Could not execute metadata action for %s: %s " 125 if (buffer == NULL) {
126 crm_warn(
"Metadata action for %s returned no data", agent);
134 crm_warn(
"Metadata for %s is invalid", agent);
139 if (numXpathResults(xpathObj) > 0) {
146 if (numXpathResults(xpathObj) <= 0) {
160 stonith_rhcs_parameter_not_required(xml,
"action");
161 stonith_rhcs_parameter_not_required(xml,
"plug");
162 stonith_rhcs_parameter_not_required(xml,
"port");
189 int rc = stonith__rhcs_get_metadata(agent, timeout, &xml);
198 if (buffer == NULL) {
214 int rc = stat(buffer, &prop);
217 return (rc >= 0) && S_ISREG(prop.st_mode);
222 const char *agent, GHashTable *params,
223 const char * host_arg,
int timeout,
224 char **output,
char **error_output)
227 int remaining_timeout = timeout;
228 xmlNode *metadata = NULL;
231 if (host_arg == NULL) {
232 time_t start_time = time(NULL);
234 rc = stonith__rhcs_get_metadata(agent, remaining_timeout, &metadata);
249 remaining_timeout -= time(NULL) - start_time;
251 if (rc == -
ETIME || remaining_timeout <= 0 ) {
260 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
bool stonith__agent_is_rhcs(const char *agent)
void stonith__action_result(stonith_action_t *action, int *rc, char **output, char **error_output)
int stonith__execute(stonith_action_t *action)
const char * pcmk_strerror(int rc)
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)
bool crm_starts_with(const char *str, const char *prefix)
Check whether a string starts with a certain sequence.
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...)
#define pcmk_err_schema_validation
xmlNode * create_xml_node(xmlNode *parent, const char *name)
#define CRM_DEFAULT_OP_TIMEOUT_S
#define RH_STONITH_PREFIX
void free_xml(xmlNode *child)
int stonith__list_rhcs_agents(stonith_key_value_t **devices)
xmlXPathObjectPtr xpath_search(xmlNode *xml_top, const char *path)
long long stonith__device_parameter_flags(xmlNode *metadata)
xmlNode * getXpathResult(xmlXPathObjectPtr xpathObj, int index)
#define safe_str_eq(a, b)
char * crm_strdup_printf(char const *format,...) __attribute__((__format__(__printf__
void freeXpathObject(xmlXPathObjectPtr xpathObj)
char * dump_xml_formatted_with_text(xmlNode *msg)