2 common system utilities
4 Copyright (C) Amitay Isaacs 2014
5 Copyright (C) Martin Schwenke 2014
7 This program is free software; you can redistribute it and/or modify
8 it under the terms of the GNU General Public License as published by
9 the Free Software Foundation; either version 3 of the License, or
10 (at your option) any later version.
12 This program is distributed in the hope that it will be useful,
13 but WITHOUT ANY WARRANTY; without even the implied warranty of
14 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
15 GNU General Public License for more details.
17 You should have received a copy of the GNU General Public License
18 along with this program; if not, see <http://www.gnu.org/licenses/>.
22 #include "system/filesys.h"
23 #include "system/shmem.h"
24 #include "system/network.h"
29 #include "lib/util/debug.h"
31 #include "protocol/protocol.h"
33 #include "common/logging.h"
34 #include "common/system.h"
45 if possible, make this task real time
47 bool set_scheduler(void)
50 #if HAVE_THREAD_SETSCHED
51 struct thrdentry64 te;
55 if (getthrds64(getpid(), &te, sizeof(te), &ti, 1) != 1) {
56 DEBUG(DEBUG_ERR, ("Unable to get thread information\n"));
60 if (thread_setsched(te.ti_tid, 0, SCHED_RR) == -1) {
61 DEBUG(DEBUG_ERR, ("Unable to set scheduler to SCHED_RR (%s)\n",
69 #if HAVE_SCHED_SETSCHEDULER
74 if (sched_setscheduler(0, SCHED_FIFO, &p) == -1) {
75 DEBUG(DEBUG_CRIT,("Unable to set scheduler to SCHED_FIFO (%s)\n",
83 DEBUG(DEBUG_CRIT,("No way to set real-time priority.\n"));
88 reset scheduler from real-time to normal scheduling
90 void reset_scheduler(void)
93 #if HAVE_THREAD_SETSCHED
94 struct thrdentry64 te;
98 if (getthrds64(getpid(), &te, sizeof(te), &ti, 1) != 1) {
99 DEBUG(DEBUG_ERR, ("Unable to get thread information\n"));
101 if (thread_setsched(te.ti_tid, 0, SCHED_OTHER) == -1) {
102 DEBUG(DEBUG_ERR, ("Unable to set scheduler to SCHED_OTHER\n"));
106 #if HAVE_SCHED_SETSCHEDULER
107 struct sched_param p;
109 p.sched_priority = 0;
110 if (sched_setscheduler(0, SCHED_OTHER, &p) == -1) {
111 DEBUG(DEBUG_ERR, ("Unable to set scheduler to SCHED_OTHER\n"));
117 bool parse_ipv4(const char *s, unsigned port, struct sockaddr_in *sin)
119 sin->sin_family = AF_INET;
120 sin->sin_port = htons(port);
122 if (inet_pton(AF_INET, s, &sin->sin_addr) != 1) {
123 DEBUG(DEBUG_ERR, (__location__ " Failed to translate %s into sin_addr\n", s));
127 #ifdef HAVE_SOCK_SIN_LEN
128 sin->sin_len = sizeof(*sin);
133 static bool parse_ipv6(const char *s, const char *ifaces, unsigned port, ctdb_sock_addr *saddr)
135 saddr->ip6.sin6_family = AF_INET6;
136 saddr->ip6.sin6_port = htons(port);
137 saddr->ip6.sin6_flowinfo = 0;
138 saddr->ip6.sin6_scope_id = 0;
140 if (inet_pton(AF_INET6, s, &saddr->ip6.sin6_addr) != 1) {
141 DEBUG(DEBUG_ERR, (__location__ " Failed to translate %s into sin6_addr\n", s));
145 if (ifaces && IN6_IS_ADDR_LINKLOCAL(&saddr->ip6.sin6_addr)) {
146 if (strchr(ifaces, ',')) {
147 DEBUG(DEBUG_ERR, (__location__ " Link local address %s "
148 "is specified for multiple ifaces %s\n",
152 saddr->ip6.sin6_scope_id = if_nametoindex(ifaces);
155 #ifdef HAVE_SOCK_SIN_LEN
156 saddr->ip6.sin6_len = sizeof(*saddr);
164 bool parse_ip(const char *addr, const char *ifaces, unsigned port, ctdb_sock_addr *saddr)
169 ZERO_STRUCTP(saddr); /* valgrind :-) */
171 /* now is this a ipv4 or ipv6 address ?*/
172 p = index(addr, ':');
174 ret = parse_ipv4(addr, port, &saddr->ip);
176 ret = parse_ipv6(addr, ifaces, port, saddr);
185 bool parse_ip_mask(const char *str, const char *ifaces, ctdb_sock_addr *addr, unsigned *mask)
188 char s[64]; /* Much longer than INET6_ADDRSTRLEN */
196 if (len >= sizeof(s)) {
197 DEBUG(DEBUG_ERR, ("Address %s is unreasonably long\n", str));
201 strncpy(s, str, len+1);
205 DEBUG(DEBUG_ERR, (__location__ " This addr: %s does not contain a mask\n", s));
209 *mask = strtoul(p+1, &endp, 10);
210 if (endp == NULL || *endp != 0) {
211 /* trailing garbage */
212 DEBUG(DEBUG_ERR, (__location__ " Trailing garbage after the mask in %s\n", s));
218 /* now is this a ipv4 or ipv6 address ?*/
219 ret = parse_ip(s, ifaces, 0, addr);
227 bool parse_ip_port(const char *addr, ctdb_sock_addr *saddr)
230 char s[64]; /* Much longer than INET6_ADDRSTRLEN */
237 if (len >= sizeof(s)) {
238 DEBUG(DEBUG_ERR, ("Address %s is unreasonably long\n", addr));
242 strncpy(s, addr, len+1);
246 DEBUG(DEBUG_ERR, (__location__ " This addr: %s does not contain a port number\n", s));
250 port = strtoul(p+1, &endp, 10);
251 if (endp == NULL || *endp != 0) {
252 /* trailing garbage */
253 DEBUG(DEBUG_ERR, (__location__ " Trailing garbage after the port in %s\n", s));
258 /* now is this a ipv4 or ipv6 address ?*/
259 ret = parse_ip(s, NULL, port, saddr);
264 /* we don't lock future pages here; it would increase the chance that
265 * we'd fail to mmap later on. */
266 void lockdown_memory(bool valgrinding)
268 #if defined(HAVE_MLOCKALL) && !defined(_AIX_)
269 /* Extra stack, please! */
271 memset(dummy, 0, sizeof(dummy));
277 /* Ignore when running in local daemons mode */
282 /* Avoid compiler optimizing out dummy. */
283 mlock(dummy, sizeof(dummy));
284 if (mlockall(MCL_CURRENT) != 0) {
285 DEBUG(DEBUG_WARNING,("Failed to lockdown memory: %s'\n",
291 int mkdir_p(const char *dir, int mode)
297 if (strcmp(dir, "/") == 0) {
301 if (strcmp(dir, ".") == 0) {
305 /* Try to create directory */
306 ret = mkdir(dir, mode);
307 /* Succeed if that worked or if it already existed */
308 if (ret == 0 || errno == EEXIST) {
311 /* Fail on anything else except ENOENT */
312 if (errno != ENOENT) {
316 /* Create ancestors */
318 if (len >= PATH_MAX) {
319 errno = ENAMETOOLONG;
322 strncpy(t, dir, len+1);
324 ret = mkdir_p(dirname(t), mode);
329 /* Create directory */
330 ret = mkdir(dir, mode);
331 if ((ret == -1) && (errno == EEXIST)) {
338 void mkdir_p_or_die(const char *dir, int mode)
342 ret = mkdir_p(dir, mode);
345 ("ctdb exiting with error: "
346 "failed to create directory \"%s\" (%s)\n",
347 dir, strerror(errno)));
352 void ctdb_wait_for_process_to_exit(pid_t pid)
354 while (kill(pid, 0) == 0 || errno != ESRCH) {
359 int ctdb_parse_connections(FILE *fp, TALLOC_CTX *mem_ctx,
360 int *num_conn, struct ctdb_connection **out)
362 struct ctdb_connection *conn = NULL;
363 char line[128], src[128], dst[128]; /* long enough for IPv6 */
365 int num = 0, max = 0;
369 if (fgets(line, sizeof(line), fp) == NULL) {
374 /* Skip empty lines */
375 if (line[0] == '\n') {
379 ret = sscanf(line, "%s %s\n", src, dst);
381 DEBUG(DEBUG_ERR, ("Bad line [%d]: %s\n",
389 conn = talloc_realloc(mem_ctx, conn,
390 struct ctdb_connection, max);
396 if (! parse_ip_port(src, &conn[num].src)) {
397 DEBUG(DEBUG_ERR, ("Invalid IP address %s\n", src));
402 if (! parse_ip_port(dst, &conn[num].dst)) {
403 DEBUG(DEBUG_ERR, ("Invalid IP address %s\n", dst));