root/daemons/controld/controld_cib.h

/* */

INCLUDED FROM

DEFINITIONS

1. fsa_cib_anon_update
2. fsa_cib_anon_update_discard_reply
3. controld_action_is_recordable

   1 /*
   2  * Copyright 2004-2024 the Pacemaker project contributors
   3  *
   4  * The version control history for this file may have further details.
   5  *
   6  * This source code is licensed under the GNU Lesser General Public License
   7  * version 2.1 or later (LGPLv2.1+) WITHOUT ANY WARRANTY.
   8  */
   9 
  10 #ifndef PCMK__CONTROLD_CIB__H
  11 #define PCMK__CONTROLD_CIB__H
  12 
  13 #include <crm_internal.h>
  14 
  15 #include <glib.h>
  16 
  17 #include <crm/crm.h>
  18 #include <crm/common/xml.h>
  19 #include <crm/cib/internal.h>   // cib__*
  20 #include "controld_globals.h"   // controld_globals.cib_conn
  21 
  22 static inline void
  23 fsa_cib_anon_update(const char *section, xmlNode *data) {
     /*  */
  24     if (controld_globals.cib_conn == NULL) {
  25         crm_err("No CIB connection available");
  26     } else {
  27         controld_globals.cib_conn->cmds->modify(controld_globals.cib_conn,
  28                                                 section, data, cib_can_create);
  29     }
  30 }
  31 
  32 static inline void
  33 fsa_cib_anon_update_discard_reply(const char *section, xmlNode *data) {
     /*  */
  34     if (controld_globals.cib_conn == NULL) {
  35         crm_err("No CIB connection available");
  36     } else {
  37         controld_globals.cib_conn->cmds->modify(controld_globals.cib_conn,
  38                                                 section, data,
  39                                                 cib_can_create
  40                                                 |cib_discard_reply);
  41     }
  42 }
  43 
  44 int controld_update_cib(const char *section, xmlNode *data, int options,
  45                         void (*callback)(xmlNode *, int, int, xmlNode *,
  46                                          void *));
  47 unsigned int cib_op_timeout(void);
  48 
  49 // Subsections of PCMK__XE_NODE_STATE
  50 enum controld_section_e {
  51     controld_section_lrm,
  52     controld_section_lrm_unlocked,
  53     controld_section_attrs,
  54     controld_section_all,
  55     controld_section_all_unlocked
  56 };
  57 
  58 void controld_node_state_deletion_strings(const char *uname,
  59                                           enum controld_section_e section,
  60                                           char **xpath, char **desc);
  61 void controld_delete_node_state(const char *uname,
  62                                 enum controld_section_e section, int options);
  63 int controld_delete_resource_history(const char *rsc_id, const char *node,
  64                                      const char *user_name, int call_options);
  65 
  66 /* Convenience macro for registering a CIB callback
  67  * (assumes that data can be freed with free())
  68  */
  69 #  define fsa_register_cib_callback(id, data, fn) do {                      \
  70     cib_t *cib_conn = controld_globals.cib_conn;                            \
  71                                                                             \
  72     pcmk__assert(cib_conn != NULL);                                         \
  73     cib_conn->cmds->register_callback_full(cib_conn, id, cib_op_timeout(),  \
  74                                            FALSE, data, #fn, fn, free);     \
  75     } while(0)
  76 
  77 void controld_add_resource_history_xml_as(const char *func, xmlNode *parent,
  78                                           const lrmd_rsc_info_t *rsc,
  79                                           lrmd_event_data_t *op,
  80                                           const char *node_name);
  81 
  82 #define controld_add_resource_history_xml(parent, rsc, op, node_name)   \
  83     controld_add_resource_history_xml_as(__func__, (parent), (rsc),     \
  84                                          (op), (node_name))
  85 
  86 bool controld_record_pending_op(const char *node_name,
  87                                 const lrmd_rsc_info_t *rsc,
  88                                 lrmd_event_data_t *op);
  89 
  90 void controld_update_resource_history(const char *node_name,
  91                                       const lrmd_rsc_info_t *rsc,
  92                                       lrmd_event_data_t *op, time_t lock_time);
  93 
  94 void controld_delete_action_history(const lrmd_event_data_t *op);
  95 
  96 void controld_cib_delete_last_failure(const char *rsc_id, const char *node,
  97                                       const char *action, guint interval_ms);
  98 
  99 void controld_delete_action_history_by_key(const char *rsc_id, const char *node,
 100                                            const char *key, int call_id);
 101 
 102 void controld_disconnect_cib_manager(void);
 103 
 104 int crmd_cib_smart_opt(void);
 105 
 106 /*!
 107  * \internal
 108  * \brief Check whether an action type should be recorded in the CIB
 109  *
 110  * \param[in] action  Action type
 111  *
 112  * \return true if action should be recorded, false otherwise
 113  */
 114 static inline bool
 115 controld_action_is_recordable(const char *action)
     /*  */
 116 {
 117     return !pcmk__str_any_of(action, PCMK_ACTION_CANCEL, PCMK_ACTION_DELETE,
 118                              PCMK_ACTION_NOTIFY, PCMK_ACTION_META_DATA, NULL);
 119 }
 120 
 121 #endif // PCMK__CONTROLD_CIB__H

/* */