37 #define LRMD_PROTOCOL_VERSION "1.0"
40 #define DEFAULT_REMOTE_KEY_LOCATION "/etc/pacemaker/authkey"
41 #define ALT_REMOTE_KEY_LOCATION "/etc/corosync/authkey"
42 #define DEFAULT_REMOTE_PORT 3121
43 #define DEFAULT_REMOTE_USERNAME "lrmd"
45 #define F_LRMD_OPERATION "lrmd_op"
46 #define F_LRMD_CLIENTNAME "lrmd_clientname"
47 #define F_LRMD_IS_IPC_PROVIDER "lrmd_is_ipc_provider"
48 #define F_LRMD_CLIENTID "lrmd_clientid"
49 #define F_LRMD_PROTOCOL_VERSION "lrmd_protocol_version"
50 #define F_LRMD_REMOTE_MSG_TYPE "lrmd_remote_msg_type"
51 #define F_LRMD_REMOTE_MSG_ID "lrmd_remote_msg_id"
52 #define F_LRMD_CALLBACK_TOKEN "lrmd_async_id"
53 #define F_LRMD_CALLID "lrmd_callid"
54 #define F_LRMD_CANCEL_CALLID "lrmd_cancel_callid"
55 #define F_LRMD_CALLOPTS "lrmd_callopt"
56 #define F_LRMD_CALLDATA "lrmd_calldata"
57 #define F_LRMD_RC "lrmd_rc"
58 #define F_LRMD_EXEC_RC "lrmd_exec_rc"
59 #define F_LRMD_OP_STATUS "lrmd_exec_op_status"
60 #define F_LRMD_TIMEOUT "lrmd_timeout"
61 #define F_LRMD_CLASS "lrmd_class"
62 #define F_LRMD_PROVIDER "lrmd_provider"
63 #define F_LRMD_TYPE "lrmd_type"
64 #define F_LRMD_ORIGIN "lrmd_origin"
66 #define F_LRMD_RSC_RUN_TIME "lrmd_run_time"
67 #define F_LRMD_RSC_RCCHANGE_TIME "lrmd_rcchange_time"
68 #define F_LRMD_RSC_EXEC_TIME "lrmd_exec_time"
69 #define F_LRMD_RSC_QUEUE_TIME "lrmd_queue_time"
71 #define F_LRMD_RSC_ID "lrmd_rsc_id"
72 #define F_LRMD_RSC_ACTION "lrmd_rsc_action"
73 #define F_LRMD_RSC_USERDATA_STR "lrmd_rsc_userdata_str"
74 #define F_LRMD_RSC_OUTPUT "lrmd_rsc_output"
75 #define F_LRMD_RSC_START_DELAY "lrmd_rsc_start_delay"
76 #define F_LRMD_RSC_INTERVAL "lrmd_rsc_interval"
77 #define F_LRMD_RSC_METADATA "lrmd_rsc_metadata_res"
78 #define F_LRMD_RSC_DELETED "lrmd_rsc_deleted"
79 #define F_LRMD_RSC "lrmd_rsc"
81 #define LRMD_OP_RSC_CHK_REG "lrmd_rsc_check_register"
82 #define LRMD_OP_RSC_REG "lrmd_rsc_register"
83 #define LRMD_OP_RSC_EXEC "lrmd_rsc_exec"
84 #define LRMD_OP_RSC_CANCEL "lrmd_rsc_cancel"
85 #define LRMD_OP_RSC_UNREG "lrmd_rsc_unregister"
86 #define LRMD_OP_RSC_INFO "lrmd_rsc_info"
87 #define LRMD_OP_RSC_METADATA "lrmd_rsc_metadata"
88 #define LRMD_OP_POKE "lrmd_rsc_poke"
89 #define LRMD_OP_NEW_CLIENT "lrmd_rsc_new_client"
91 #define F_LRMD_IPC_OP "lrmd_ipc_op"
92 #define F_LRMD_IPC_IPC_SERVER "lrmd_ipc_server"
93 #define F_LRMD_IPC_SESSION "lrmd_ipc_session"
94 #define F_LRMD_IPC_CLIENT "lrmd_ipc_client"
95 #define F_LRMD_IPC_PROXY_NODE "lrmd_ipc_proxy_node"
96 #define F_LRMD_IPC_USER "lrmd_ipc_user"
97 #define F_LRMD_IPC_MSG "lrmd_ipc_msg"
98 #define F_LRMD_IPC_MSG_ID "lrmd_ipc_msg_id"
99 #define F_LRMD_IPC_MSG_FLAGS "lrmd_ipc_msg_flags"
101 #define T_LRMD "lrmd"
102 #define T_LRMD_REPLY "lrmd_reply"
103 #define T_LRMD_NOTIFY "lrmd_notify"
104 #define T_LRMD_IPC_PROXY "lrmd_ipc_proxy"
356 int (*
exec) (
lrmd_t * lrmd,
const char *rsc_id,
const char *action,
const char *userdata,
385 int (*
cancel) (
lrmd_t * lrmd,
const char *rsc_id,
const char *action,
int interval);
397 const char *provider,
410 const char *provider);
441 static inline const char *
450 return "exec_complete";
struct lrmd_rsc_info_s lrmd_rsc_info_t
int(* cancel)(lrmd_t *lrmd, const char *rsc_id, const char *action, int interval)
Cancel a recurring command.
int(* exec)(lrmd_t *lrmd, const char *rsc_id, const char *action, const char *userdata, int interval, int timeout, int start_delay, enum lrmd_call_options options, lrmd_key_value_t *params)
Issue a command on a resource.
int(* poke_connection)(lrmd_t *lrmd)
Poke lrmd connection to verify it is still capable of serving requests.
void(* set_callback)(lrmd_t *lrmd, lrmd_event_callback callback)
Sets the callback to receive lrmd events on.
int(* is_connected)(lrmd_t *lrmd)
Is connected to lrmd daemon?
void lrmd_list_freeall(lrmd_list_t *head)
void lrmd_free_event(lrmd_event_data_t *event)
void(* lrmd_event_callback)(lrmd_event_data_t *event)
struct lrmd_event_data_s lrmd_event_data_t
lrmd_t * lrmd_remote_api_new(const char *nodename, const char *server, int port)
Create a new remote lrmd connection using tls backend.
int(* disconnect)(lrmd_t *lrmd)
Disconnect from the lrmd.
struct lrmd_api_operations_s lrmd_api_operations_t
int(* list_ocf_providers)(lrmd_t *lrmd, const char *agent, lrmd_list_t **providers)
Retrieve a list of resource agent providers.
lrmd_rsc_info_t * lrmd_copy_rsc_info(lrmd_rsc_info_t *rsc_info)
int(* get_metadata)(lrmd_t *lrmd, const char *class, const char *provider, const char *agent, char **output, enum lrmd_call_options options)
Get the metadata documentation for a resource.
struct lrmd_list_s * next
lrmd_t * lrmd_api_new(void)
Create a new local lrmd connection.
bool lrmd_dispatch(lrmd_t *lrmd)
Use after lrmd_poll returns 1.
lrmd_key_value_t * lrmd_key_value_add(lrmd_key_value_t *kvp, const char *key, const char *value)
struct lrmd_key_value_s * next
int(* connect_async)(lrmd_t *lrmd, const char *client_name, int timeout)
Establish an connection to lrmd, don't block while connecting.
void lrmd_key_value_freeall(lrmd_key_value_t *head)
struct lrmd_key_value_s lrmd_key_value_t
int(* connect)(lrmd_t *lrmd, const char *client_name, int *fd)
Connect from the lrmd.
const char * remote_nodename
lrmd_api_operations_t * cmds
enum lrmd_callback_event type
int(* list_agents)(lrmd_t *lrmd, lrmd_list_t **agents, const char *class, const char *provider)
Retrieve a list of installed resource agents.
int(* unregister_rsc)(lrmd_t *lrmd, const char *rsc_id, enum lrmd_call_options options)
Unregister a resource from the lrmd.
lrmd_event_data_t * lrmd_copy_event(lrmd_event_data_t *event)
int lrmd_poll(lrmd_t *lrmd, int timeout)
Poll for a specified timeout period to determine if a message is ready for dispatch.
struct lrmd_list_s lrmd_list_t
void lrmd_free_rsc_info(lrmd_rsc_info_t *rsc_info)
void lrmd_api_delete(lrmd_t *lrmd)
Destroy lrmd object.
int(* register_rsc)(lrmd_t *lrmd, const char *rsc_id, const char *class, const char *provider, const char *agent, enum lrmd_call_options options)
Register a resource with the lrmd.
int(* list_standards)(lrmd_t *lrmd, lrmd_list_t **standards)
Retrieve a list of standards supported by this machine/installation.
enum crm_ais_msg_types type