pacemaker  2.0.1-9e909a5bdd
Scalable High-Availability cluster resource manager
internal.h
Go to the documentation of this file.
1 /*
2  * Copyright 2015-2018 Andrew Beekhof <andrew@beekhof.net>
3  *
4  * This source code is licensed under the GNU Lesser General Public License
5  * version 2.1 or later (LGPLv2.1+) WITHOUT ANY WARRANTY.
6  */
7 
8 #ifndef CRM_COMMON_INTERNAL__H
9 #define CRM_COMMON_INTERNAL__H
10 
11 #include <glib.h> /* for gboolean */
12 #include <dirent.h> /* for struct dirent */
13 #include <unistd.h> /* for getpid() */
14 #include <sys/types.h> /* for uid_t and gid_t */
15 
16 #include <crm/common/logging.h>
17 
18 /* internal I/O utilities (from io.c) */
19 
20 char *generate_series_filename(const char *directory, const char *series, int sequence,
21  gboolean bzip);
22 int get_last_sequence(const char *directory, const char *series);
23 void write_last_sequence(const char *directory, const char *series, int sequence, int max);
24 int crm_chown_last_sequence(const char *directory, const char *series, uid_t uid, gid_t gid);
25 
26 bool pcmk__daemon_can_write(const char *dir, const char *file);
27 void crm_sync_directory(const char *name);
28 
29 char *crm_read_contents(const char *filename);
30 int crm_write_sync(int fd, const char *contents);
31 int crm_set_nonblocking(int fd);
32 const char *crm_get_tmpdir(void);
33 
34 
35 /* internal procfs utilities (from procfs.c) */
36 
37 int crm_procfs_process_info(struct dirent *entry, char *name, int *pid);
38 int crm_procfs_pid_of(const char *name);
39 unsigned int crm_procfs_num_cores(void);
40 
41 
42 /* internal XML schema functions (from xml.c) */
43 
44 void crm_schema_init(void);
45 void crm_schema_cleanup(void);
46 
47 
48 /* internal functions related to process IDs (from pid.c) */
49 
50 int crm_pid_active(long pid, const char *daemon);
51 long crm_pidfile_inuse(const char *filename, long mypid, const char *daemon);
52 long crm_read_pidfile(const char *filename);
53 int crm_lock_pidfile(const char *filename, const char *name);
54 
55 
56 /* interal functions related to resource operations (from operations.c) */
57 
58 char *generate_op_key(const char *rsc_id, const char *op_type,
59  guint interval_ms);
60 char *generate_notify_key(const char *rsc_id, const char *notify_type,
61  const char *op_type);
62 char *generate_transition_magic(const char *transition_key, int op_status,
63  int op_rc);
64 char *generate_transition_key(int action, int transition_id, int target_rc,
65  const char *node);
66 void filter_action_parameters(xmlNode *param_set, const char *version);
67 xmlNode *create_operation_update(xmlNode *parent, lrmd_event_data_t *event,
68  const char *caller_version, int target_rc,
69  const char *node, const char *origin,
70  int level);
71 
72 
73 // miscellaneous utilities (from utils.c)
74 
75 const char *pcmk_message_name(const char *name);
76 
77 
78 /* internal generic string functions (from strings.c) */
79 
80 long long crm_int_helper(const char *text, char **end_text);
81 guint crm_parse_ms(const char *text);
82 bool crm_starts_with(const char *str, const char *prefix);
83 gboolean crm_ends_with(const char *s, const char *match);
84 gboolean crm_ends_with_ext(const char *s, const char *match);
85 char *add_list_element(char *list, const char *value);
86 bool crm_compress_string(const char *data, int length, int max, char **result,
87  unsigned int *result_len);
88 gint crm_alpha_sort(gconstpointer a, gconstpointer b);
89 
90 static inline char *
91 crm_concat(const char *prefix, const char *suffix, char join)
92 {
93  CRM_ASSERT(prefix && suffix);
94  return crm_strdup_printf("%s%c%s", prefix, join, suffix);
95 }
96 
97 static inline int
98 crm_strlen_zero(const char *s)
99 {
100  return !s || *s == '\0';
101 }
102 
103 static inline char *
104 crm_getpid_s()
105 {
106  return crm_strdup_printf("%lu", (unsigned long) getpid());
107 }
108 
109 /* convenience functions for failure-related node attributes */
110 
111 #define CRM_FAIL_COUNT_PREFIX "fail-count"
112 #define CRM_LAST_FAILURE_PREFIX "last-failure"
113 
131 static inline char *
132 crm_fail_attr_name(const char *prefix, const char *rsc_id, const char *op,
133  guint interval_ms)
134 {
135  CRM_CHECK(prefix && rsc_id && op, return NULL);
136  return crm_strdup_printf("%s-%s#%s_%u", prefix, rsc_id, op, interval_ms);
137 }
138 
139 static inline char *
140 crm_failcount_name(const char *rsc_id, const char *op, guint interval_ms)
141 {
142  return crm_fail_attr_name(CRM_FAIL_COUNT_PREFIX, rsc_id, op, interval_ms);
143 }
144 
145 static inline char *
146 crm_lastfailure_name(const char *rsc_id, const char *op, guint interval_ms)
147 {
148  return crm_fail_attr_name(CRM_LAST_FAILURE_PREFIX, rsc_id, op, interval_ms);
149 }
150 
151 #endif /* CRM_COMMON_INTERNAL__H */
#define CRM_CHECK(expr, failure_action)
Definition: logging.h:165
const char * crm_get_tmpdir(void)
Definition: io.c:500
void crm_schema_init(void)
Definition: schemas.c:372
int crm_lock_pidfile(const char *filename, const char *name)
Definition: pid.c:150
int get_last_sequence(const char *directory, const char *series)
Definition: io.c:102
#define CRM_LAST_FAILURE_PREFIX
Definition: internal.h:112
long long crm_int_helper(const char *text, char **end_text)
Definition: strings.c:32
void crm_schema_cleanup(void)
Definition: schemas.c:544
uint32_t pid
Definition: internal.h:81
char * generate_series_filename(const char *directory, const char *series, int sequence, gboolean bzip)
Definition: io.c:75
bool crm_starts_with(const char *str, const char *prefix)
Check whether a string starts with a certain sequence.
Definition: strings.c:243
Wrappers for and extensions to libqb logging.
char * crm_read_contents(const char *filename)
Definition: io.c:410
char * generate_transition_key(int action, int transition_id, int target_rc, const char *node)
Definition: operations.c:169
op_status
Definition: services.h:116
int daemon(int nochdir, int noclose)
#define CRM_FAIL_COUNT_PREFIX
Definition: internal.h:111
char * add_list_element(char *list, const char *value)
Definition: strings.c:392
const char * pcmk_message_name(const char *name)
Get name to be used as identifier for cluster messages.
Definition: utils.c:1097
gint crm_alpha_sort(gconstpointer a, gconstpointer b)
Compare two strings alphabetically (case-insensitive)
Definition: strings.c:473
xmlNode * create_operation_update(xmlNode *parent, lrmd_event_data_t *event, const char *caller_version, int target_rc, const char *node, const char *origin, int level)
Definition: operations.c:377
int crm_set_nonblocking(int fd)
Definition: io.c:486
bool pcmk__daemon_can_write(const char *dir, const char *file)
Definition: io.c:305
char * generate_notify_key(const char *rsc_id, const char *notify_type, const char *op_type)
Definition: operations.c:126
long crm_pidfile_inuse(const char *filename, long mypid, const char *daemon)
Definition: pid.c:123
gboolean crm_ends_with_ext(const char *s, const char *match)
Definition: strings.c:322
gboolean crm_ends_with(const char *s, const char *match)
Definition: strings.c:293
int crm_procfs_process_info(struct dirent *entry, char *name, int *pid)
Definition: procfs.c:39
int crm_pid_active(long pid, const char *daemon)
Definition: pid.c:21
void write_last_sequence(const char *directory, const char *series, int sequence, int max)
Definition: io.c:168
bool crm_compress_string(const char *data, int length, int max, char **result, unsigned int *result_len)
Definition: strings.c:411
guint crm_parse_ms(const char *text)
Definition: strings.c:127
unsigned int crm_procfs_num_cores(void)
Definition: procfs.c:144
#define CRM_ASSERT(expr)
Definition: results.h:20
int crm_write_sync(int fd, const char *contents)
Definition: io.c:456
char data[0]
Definition: internal.h:90
int crm_chown_last_sequence(const char *directory, const char *series, uid_t uid, gid_t gid)
Definition: io.c:217
void filter_action_parameters(xmlNode *param_set, const char *version)
Definition: operations.c:203
void crm_sync_directory(const char *name)
Definition: io.c:373
char * generate_transition_magic(const char *transition_key, int op_status, int op_rc)
Definition: operations.c:136
int crm_procfs_pid_of(const char *name)
Definition: procfs.c:110
char * crm_strdup_printf(char const *format,...) __attribute__((__format__(__printf__
char * generate_op_key(const char *rsc_id, const char *op_type, guint interval_ms)
Generate an operation key.
Definition: operations.c:37
uint32_t version
Definition: remote.c:146
long crm_read_pidfile(const char *filename)
Definition: pid.c:85