services.h

Go to the documentation of this file.

/*
 * Copyright 2010-2024 the Pacemaker project contributors
 *
 * The version control history for this file may have further details.
 *
 * This source code is licensed under the GNU Lesser General Public License
 * version 2.1 or later (LGPLv2.1+) WITHOUT ANY WARRANTY.
 */
 
#ifndef PCMK__CRM_SERVICES__H
#  define PCMK__CRM_SERVICES__H
 
 
#  include <glib.h>
#  include <stdio.h>
#  include <stdint.h>
#  include <string.h>
#  include <stdbool.h>
#  include <sys/types.h>
 
#  include <crm_config.h>       // OCF_ROOT_DIR
#  include <crm/common/agents.h>
#  include <crm/common/results.h>
 
#ifdef __cplusplus
extern "C" {
#endif
 
// NOTE: booth (as of at least 1.1) checks for the existence of this header
 
/* TODO: Autodetect these two ?*/
#  ifndef SYSTEMCTL
#    define SYSTEMCTL "/bin/systemctl"
#  endif
 
/* This is the string passed in the OCF_EXIT_REASON_PREFIX environment variable.
 * The stderr output that occurs after this prefix is encountered is considered
 * the exit reason for a completed operation.
 */
#define PCMK_OCF_REASON_PREFIX "ocf-exit-reason:"
 
// Agent version to use if agent doesn't specify one
#define PCMK_DEFAULT_AGENT_VERSION "0.1"
 
enum lsb_exitcode {
    PCMK_LSB_OK                  = 0,
 
    // NOTE: booth (as of at least 1.1) uses this value
    PCMK_LSB_UNKNOWN_ERROR       = 1,
 
    PCMK_LSB_INVALID_PARAM       = 2,
    PCMK_LSB_UNIMPLEMENT_FEATURE = 3,
    PCMK_LSB_INSUFFICIENT_PRIV   = 4,
    PCMK_LSB_NOT_INSTALLED       = 5,
    PCMK_LSB_NOT_CONFIGURED      = 6,
    PCMK_LSB_NOT_RUNNING         = 7,
};
 
// LSB uses different return codes for status actions
enum lsb_status_exitcode {
    PCMK_LSB_STATUS_OK             = 0,
    PCMK_LSB_STATUS_VAR_PID        = 1,
    PCMK_LSB_STATUS_VAR_LOCK       = 2,
    PCMK_LSB_STATUS_NOT_RUNNING    = 3,
    PCMK_LSB_STATUS_UNKNOWN        = 4,
 
    /* custom codes should be in the 150-199 range reserved for application use */
    PCMK_LSB_STATUS_NOT_INSTALLED      = 150,
    PCMK_LSB_STATUS_INSUFFICIENT_PRIV  = 151,
};
 
enum svc_action_flags {
    /* On timeout, only kill pid, do not kill entire pid group */
    SVC_ACTION_LEAVE_GROUP = 0x01,
    SVC_ACTION_NON_BLOCKED = 0x02,
};
 
typedef struct svc_action_private_s svc_action_private_t;
 
/*
 * NOTE: Internally, services__create_resource_action() is preferable to
 * resources_action_create().
 */
typedef struct svc_action_s {
    char *id;
 
    char *rsc;
 
    char *action;
 
    guint interval_ms;
 
    char *standard;
 
    char *provider;
 
    char *agent;
 
    int timeout;    
 
    GHashTable *params;
 
    int rc;         
 
    int pid;        // Process ID of child
    int cancel;     // Whether this is a cancellation of a recurring action
 
    int status;     
 
    int sequence;
 
    int expected_rc;    // Unused
    int synchronous;    // Whether execution should be synchronous (blocking)
 
    enum svc_action_flags flags;    
    char *stderr_data;              
    char *stdout_data;              
    void *cb_data;                  
 
    svc_action_private_t *opaque;
} svc_action_t;
 
GList *get_directory_list(const char *root, gboolean files,
                          gboolean executable);
 
GList *resources_list_providers(const char *standard);
 
GList *resources_list_agents(const char *standard, const char *provider);
 
GList *resources_list_standards(void);
 
gboolean resources_agent_exists(const char *standard, const char *provider,
                                const char *agent);
 
svc_action_t *resources_action_create(const char *name, const char *standard,
                                      const char *provider, const char *agent,
                                      const char *action, guint interval_ms,
                                      int timeout, GHashTable *params,
                                      enum svc_action_flags flags);
 
gboolean services_action_kick(const char *name, const char *action,
                              guint interval_ms);
 
const char *resources_find_service_class(const char *agent);
 
svc_action_t *services_action_create_generic(const char *exec,
                                             const char *args[]);
 
void services_action_cleanup(svc_action_t *op);
void services_action_free(svc_action_t *op);
int services_action_user(svc_action_t *op, const char *user);
gboolean services_action_sync(svc_action_t *op);
 
gboolean services_action_async_fork_notify(svc_action_t *op,
        void (*action_callback) (svc_action_t *),
        void (*action_fork_callback) (svc_action_t *));
 
gboolean services_action_async(svc_action_t *op,
                               void (*action_callback) (svc_action_t *));
 
gboolean services_action_cancel(const char *name, const char *action,
                                guint interval_ms);
 
/* functions for alert agents */
svc_action_t *services_alert_create(const char *id, const char *exec,
                                   int timeout, GHashTable *params,
                                   int sequence, void *cb_data);
gboolean services_alert_async(svc_action_t *action,
                              void (*cb)(svc_action_t *op));
 
enum ocf_exitcode services_result2ocf(const char *standard, const char *action,
                                      int exit_status);
 
#  ifdef __cplusplus
}
#  endif
 
#if !defined(PCMK_ALLOW_DEPRECATED) || (PCMK_ALLOW_DEPRECATED == 1)
#include <crm/services_compat.h>
#endif
 
#endif                          /* __PCMK_SERVICES__ */