1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
|
/*
* Copyright 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.
*/
#include <crm_internal.h>
#include <stdio.h> // NULL
#include <crm/crm.h>
/* Each Pacemaker subdaemon offers an IPC interface, and most exchange cluster
* messages as well. Particular names need to be used for logging, connecting
* IPC, and IPC/cluster message types.
*
* This array is indexed by enum pcmk_ipc_server and gathers all those names for
* easier mapping. Most members are lists with the first value listed being the
* "main" one returned if another value is mapped to it.
*
* @COMPAT Ideally, we'd use a single string (such as the server's
* crm_system_name) as the sole IPC name and sole message type for each server,
* making most of this unnecessary. However, backward compatiblity with older
* nodes involved in a rolling upgrade or Pacemaker Remote connection would
* be a nightmare: we'd have to add duplicate message attributes, struct
* members, and libqb IPC server endpoints for both the old and new names, and
* could drop the old names only after we no longer supported connections with
* older nodes.
*/
static struct {
const char *log_name; // Readable server name for use in logs
const char *system_names[2]; // crm_system_name values (subdaemon names)
const char *ipc_names[3]; // libqb IPC names used to contact server
const char *message_types[3]; // IPC/cluster message types sent to server
} server_info[] = {
[pcmk_ipc_unknown] = {
NULL,
{ NULL, NULL, },
{ NULL, NULL, NULL, },
{ NULL, NULL, NULL, },
},
[pcmk_ipc_attrd] = {
"attribute manager",
{ PCMK__SERVER_ATTRD, NULL, },
{ PCMK__VALUE_ATTRD, NULL, NULL, },
{ PCMK__VALUE_ATTRD, NULL, NULL, },
},
[pcmk_ipc_based] = {
"CIB manager",
{ PCMK__SERVER_BASED, NULL, },
{ PCMK__SERVER_BASED_RW, PCMK__SERVER_BASED_RO,
PCMK__SERVER_BASED_SHM, },
{ CRM_SYSTEM_CIB, NULL, NULL, },
},
[pcmk_ipc_controld] = {
"controller",
{ PCMK__SERVER_CONTROLD, NULL, },
{ PCMK__VALUE_CRMD, NULL, NULL, },
{ PCMK__VALUE_CRMD, CRM_SYSTEM_DC, CRM_SYSTEM_TENGINE, },
},
[pcmk_ipc_execd] = {
"executor",
{ PCMK__SERVER_EXECD, PCMK__SERVER_REMOTED, },
{ PCMK__VALUE_LRMD, NULL, NULL, },
{ PCMK__VALUE_LRMD, NULL, NULL, },
},
[pcmk_ipc_fenced] = {
"fencer",
{ PCMK__SERVER_FENCED, NULL, },
{ PCMK__VALUE_STONITH_NG, NULL, NULL, },
{ PCMK__VALUE_STONITH_NG, NULL, NULL, },
},
[pcmk_ipc_pacemakerd] = {
"launcher",
{ PCMK__SERVER_PACEMAKERD, NULL, },
{ CRM_SYSTEM_MCP, NULL, NULL, },
{ CRM_SYSTEM_MCP, NULL, NULL, },
},
[pcmk_ipc_schedulerd] = {
"scheduler",
{ PCMK__SERVER_SCHEDULERD, NULL, },
{ CRM_SYSTEM_PENGINE, NULL, NULL, },
{ CRM_SYSTEM_PENGINE, NULL, NULL, },
},
};
/*!
* \internal
* \brief Return server's (primary) system name
*
* \param[in] server Server to get system name for
*
* \return System name for server (or NULL if invalid)
* \note If \p server is an \c enum pcmk_ipc_server value other than
* \c pcmk_ipc_unknown, the return value is guaranteed to be non-NULL.
*/
const char *
pcmk__server_name(enum pcmk_ipc_server server)
{
CRM_CHECK((server > 0) && (server < PCMK__NELEM(server_info)),
return NULL);
return server_info[server].system_names[0];
}
/*!
* \internal
* \brief Return a readable description of server for logging
*
* \param[in] server Server to get log name for
*
* \return Log name for server (or NULL if invalid)
* \note If \p server is an \c enum pcmk_ipc_server value other than
* \c pcmk_ipc_unknown, the return value is guaranteed to be non-NULL.
*/
const char *
pcmk__server_log_name(enum pcmk_ipc_server server)
{
CRM_CHECK((server > 0) && (server < PCMK__NELEM(server_info)),
return NULL);
return server_info[server].log_name;
}
/*!
* \internal
* \brief Return the (primary) IPC endpoint name for a server
*
* \param[in] server Server to get IPC endpoint for
*
* \return IPC endpoint for server (or NULL if invalid)
* \note If \p server is an \c enum pcmk_ipc_server value other than
* \c pcmk_ipc_unknown, the return value is guaranteed to be non-NULL.
*/
const char *
pcmk__server_ipc_name(enum pcmk_ipc_server server)
{
CRM_CHECK((server > 0) && (server < PCMK__NELEM(server_info)),
return NULL);
return server_info[server].ipc_names[0];
}
/*!
* \internal
* \brief Return the (primary) message type for a server
*
* \param[in] server Server to get message type for
*
* \return Message type for server (or NULL if invalid)
* \note If \p server is an \c enum pcmk_ipc_server value other than
* \c pcmk_ipc_unknown, the return value is guaranteed to be non-NULL.
*/
const char *
pcmk__server_message_type(enum pcmk_ipc_server server)
{
CRM_CHECK((server > 0) && (server < PCMK__NELEM(server_info)),
return NULL);
return server_info[server].message_types[0];
}
/*!
* \internal
* \brief Get the server corresponding to a name
*
* \param[in] text A system name, IPC endpoint name, or message type
*
* \return Server corresponding to \p text
*/
enum pcmk_ipc_server
pcmk__parse_server(const char *text)
{
if (text == NULL) {
return pcmk_ipc_unknown;
}
for (enum pcmk_ipc_server server = pcmk_ipc_attrd;
server <= pcmk_ipc_schedulerd; ++server) {
int name;
for (name = 0;
(name < 2) && (server_info[server].system_names[name] != NULL);
++name) {
if (strcmp(text, server_info[server].system_names[name]) == 0) {
return server;
}
}
for (name = 0;
(name < 3) && (server_info[server].ipc_names[name] != NULL);
++name) {
if (strcmp(text, server_info[server].ipc_names[name]) == 0) {
return server;
}
}
for (name = 0;
(name < 3) && (server_info[server].message_types[name] != NULL);
++name) {
if (strcmp(text, server_info[server].message_types[name]) == 0) {
return server;
}
}
}
return pcmk_ipc_unknown;
}
|
