diff --git a/man/corosync-cfgtool.8 b/man/corosync-cfgtool.8 index 07e63b42..5c537918 100644 --- a/man/corosync-cfgtool.8 +++ b/man/corosync-cfgtool.8 @@ -1,96 +1,95 @@ .\" .\" * Copyright (C) 2010-2018 Red Hat, Inc. .\" * .\" * All rights reserved. .\" * .\" * Author: Angus Salkeld .\" * .\" * This software licensed under BSD license, the text of which follows: .\" * .\" * Redistribution and use in source and binary forms, with or without .\" * modification, are permitted provided that the following conditions are met: .\" * .\" * - Redistributions of source code must retain the above copyright notice, .\" * this list of conditions and the following disclaimer. .\" * - Redistributions in binary form must reproduce the above copyright notice, .\" * this list of conditions and the following disclaimer in the documentation .\" * and/or other materials provided with the distribution. .\" * - Neither the name of the MontaVista Software, Inc. nor the names of its .\" * contributors may be used to endorse or promote products derived from this .\" * software without specific prior written permission. .\" * .\" * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" .\" * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE .\" * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE .\" * ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE .\" * LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR .\" * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF .\" * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS .\" * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN .\" * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) .\" * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF .\" * THE POSSIBILITY OF SUCH DAMAGE. .\" */ -.TH "COROSYNC-CFGTOOL" "8" "2019-02-13" "" "" +.TH "COROSYNC-CFGTOOL" "8" "2019-07-04" "" "" .SH "NAME" corosync-cfgtool \- An administrative tool for corosync. .SH "SYNOPSIS" .B corosync\-cfgtool [[\-i IP_address] [\-b] \-s] [\-R] [\-L] [\-k nodeid] [\-a nodeid] [\-h] [\-H] .SH "DESCRIPTION" .B corosync\-cfgtool A tool for displaying and configuring active parameters within corosync. .SH "OPTIONS" .TP .B -i Finds only information about the specified interface IP address or link id with -s. .TP .B -s Displays the status of the current links on this node for UDP/UDPU, with extended status -for KNET. If any interfaces are faulty, 1 is returned by the binary. If all interfaces are -active 0 is returned to the shell. +for KNET. After each link, the nodes on that link are displayed in order with their status, for example there are 3 nodes with KNET transportation: LINK ID 0: id = 192.168.100.80 status: node 0: link enabled: 1 link connected: 1 node 1: link enabled: 1 link connected: 1 node 2: link enabled: 1 link connected: 1 .TP .B -b Displays the brief status of the current links on this node (KNET only) when used with "-s". If any interfaces are faulty, 1 is returned by the binary. If all interfaces are active 0 is returned to the shell. After each link, the nodes on that link are displayed in order with their status encoded into a single digit. 1=link enabled, 2=link connected, So a 3 in a node position indicates that the link is both enabled and connected. The local link (which will only ever be enabled on link 0) shows as enabled but not connected for internal reasons. The output will be: LINK ID 0: id = 192.168.100.80 status = 333 .TP .B -R Tell all instances of corosync in this cluster to reload corosync.conf. .TP .B -L Tell corosync to reopen all logging files. In contrast to other subcommands, nothing is displayed on terminal if call is successful. .TP .B -k Kill a node identified by node id. .TP .B -a Display the IP address(es) of a node. .TP .B -h Print basic usage. .TP .B -H Shutdown corosync cleanly on this node. .SH "SEE ALSO" .BR corosync_overview (7), .SH "AUTHOR" Angus Salkeld .PP diff --git a/tools/corosync-cfgtool.c b/tools/corosync-cfgtool.c index 57c120fc..52aa6f9d 100644 --- a/tools/corosync-cfgtool.c +++ b/tools/corosync-cfgtool.c @@ -1,455 +1,455 @@ /* * Copyright (c) 2006-2019 Red Hat, Inc. * * All rights reserved. * * Author: Steven Dake * * This software licensed under BSD license, the text of which follows: * * Redistribution and use in source and binary forms, with or without * modification, are permitted provided that the following conditions are met: * * - Redistributions of source code must retain the above copyright notice, * this list of conditions and the following disclaimer. * - Redistributions in binary form must reproduce the above copyright notice, * this list of conditions and the following disclaimer in the documentation * and/or other materials provided with the distribution. * - Neither the name of the MontaVista Software, Inc. nor the names of its * contributors may be used to endorse or promote products derived from this * software without specific prior written permission. * * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE * ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE * LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF * THE POSSIBILITY OF SUCH DAMAGE. */ #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #define cs_repeat(result, max, code) \ do { \ int counter = 0; \ do { \ result = code; \ if (result == CS_ERR_TRY_AGAIN) { \ sleep(1); \ counter++; \ } else { \ break; \ } \ } while (counter < max); \ } while (0) enum user_action { ACTION_NOOP=0, ACTION_LINKSTATUS_GET, ACTION_RELOAD_CONFIG, ACTION_REOPEN_LOG_FILES, ACTION_SHUTDOW, ACTION_SHOWADDR, ACTION_KILL_NODE, }; static int node_compare(const void *aptr, const void *bptr) { uint32_t a,b; a = *(uint32_t *)aptr; b = *(uint32_t *)bptr; return a > b; } static int linkstatusget_do (char *interface_name, int brief) { cs_error_t result; corosync_cfg_handle_t handle; cmap_handle_t cmap_handle; unsigned int interface_count; char **interface_names; char **interface_status; uint32_t nodeid_list[KNET_MAX_HOST]; char iter_key[CMAP_KEYNAME_MAXLEN]; unsigned int i; cmap_iter_handle_t iter; unsigned int nodeid; int nodeid_match_guard; cmap_value_types_t type; size_t value_len; int rc = 0; int len, s = 0, t; printf ("Printing link status.\n"); result = corosync_cfg_initialize (&handle, NULL); if (result != CS_OK) { printf ("Could not initialize corosync configuration API error %d\n", result); exit (1); } result = cmap_initialize (&cmap_handle); if (result != CS_OK) { printf ("Could not initialize corosync cmap API error %d\n", result); exit (1); } /* Get a list of nodes. We do it this way rather than using votequorum as cfgtool * needs to be independent of quorum type */ result = cmap_iter_init(cmap_handle, "nodelist.node.", &iter); if (result != CS_OK) { printf ("Could not get nodelist from cmap. error %d\n", result); exit (1); } while ((cmap_iter_next(cmap_handle, iter, iter_key, &value_len, &type)) == CS_OK) { nodeid_match_guard = 0; if (sscanf(iter_key, "nodelist.node.%*u.nodeid%n", &nodeid_match_guard) != 0) { continue; } /* check for exact match */ if (nodeid_match_guard != strlen(iter_key)) { continue; } if (cmap_get_uint32(cmap_handle, iter_key, &nodeid) == CS_OK) { nodeid_list[s++] = nodeid; } } /* totemknet returns nodes in nodeid order - even though it doesn't tell us what the nodeid is. So sort our node list and we can then look up knet node pos to get an actual nodeid. Yep, I really should have totally rewritten the cfg interface for this. */ qsort(nodeid_list, s, sizeof(uint32_t), node_compare); result = corosync_cfg_local_get(handle, &nodeid); if (result != CS_OK) { printf ("Could not get the local node id, the error is: %d\n", result); } else { printf ("Local node ID " CS_PRI_NODE_ID "\n", nodeid); } result = corosync_cfg_ring_status_get (handle, &interface_names, &interface_status, &interface_count); if (result != CS_OK) { printf ("Could not get the link status, the error is: %d\n", result); } else { for (i = 0; i < interface_count; i++) { char *cur_iface_name_space = strchr(interface_names[i], ' '); int show_current_iface; s = 0; /* * Interface_name is " " * separate them out */ if (!cur_iface_name_space) { continue; } *cur_iface_name_space = '\0'; show_current_iface = 1; if (interface_name != NULL && interface_name[0] != '\0' && strcmp(interface_name, interface_names[i]) != 0 && strcmp(interface_name, cur_iface_name_space + 1) != 0) { show_current_iface = 0; } if (show_current_iface) { printf ("LINK ID %s\n", interface_names[i]); printf ("\taddr\t= %s\n", cur_iface_name_space + 1); - if((!brief) && (strcmp(interface_status[i], "OK") != 0) && - (!strstr(interface_status[i], "FAULTY"))) { + /* + * UDP(U) interface_status is always OK and doesn't contain + * detailed information (only knet does). + */ + if ((!brief) && (strcmp(interface_status[i], "OK") != 0)) { len = strlen(interface_status[i]); printf ("\tstatus:\n"); while (s < len) { nodeid = nodeid_list[s]; t = interface_status[i][s] - '0'; s++; printf("\t\tnodeid %2d:\t", nodeid); printf("link enabled:%d\t", t&1? 1 : 0); printf("link connected:%d\n", t&2? 1: 0); } } else { printf ("\tstatus\t= %s\n", interface_status[i]); - if (strstr(interface_status[i], "FAULTY")) { - rc = 1; - } } } } for (i = 0; i < interface_count; i++) { free(interface_status[i]); free(interface_names[i]); } free(interface_status); free(interface_names); } (void)cmap_finalize (cmap_handle); (void)corosync_cfg_finalize (handle); return rc; } static int reload_config_do (void) { cs_error_t result; corosync_cfg_handle_t handle; int rc; rc = 0; printf ("Reloading corosync.conf...\n"); result = corosync_cfg_initialize (&handle, NULL); if (result != CS_OK) { printf ("Could not initialize corosync configuration API error %s\n", cs_strerror(result)); exit (1); } result = corosync_cfg_reload_config (handle); if (result != CS_OK) { printf ("Could not reload configuration. Error %s\n", cs_strerror(result)); rc = (int)result; } else { printf ("Done\n"); } (void)corosync_cfg_finalize (handle); return (rc); } static int reopen_log_files_do (void) { cs_error_t result; corosync_cfg_handle_t handle; int rc; rc = 0; result = corosync_cfg_initialize (&handle, NULL); if (result != CS_OK) { fprintf (stderr, "Could not initialize corosync configuration API error %s\n", cs_strerror(result)); exit (1); } result = corosync_cfg_reopen_log_files (handle); if (result != CS_OK) { fprintf (stderr, "Could not reopen corosync logging files. Error %s\n", cs_strerror(result)); rc = (int)result; } (void)corosync_cfg_finalize (handle); return (rc); } static void shutdown_do(void) { cs_error_t result; corosync_cfg_handle_t handle; corosync_cfg_callbacks_t callbacks; callbacks.corosync_cfg_shutdown_callback = NULL; result = corosync_cfg_initialize (&handle, &callbacks); if (result != CS_OK) { printf ("Could not initialize corosync configuration API error %d\n", result); exit (1); } printf ("Shutting down corosync\n"); cs_repeat(result, 30, corosync_cfg_try_shutdown (handle, COROSYNC_CFG_SHUTDOWN_FLAG_REQUEST)); if (result != CS_OK) { printf ("Could not shutdown (error = %d)\n", result); } (void)corosync_cfg_finalize (handle); } static void showaddrs_do(unsigned int nodeid) { cs_error_t result; corosync_cfg_handle_t handle; corosync_cfg_callbacks_t callbacks; int numaddrs; int i; corosync_cfg_node_address_t addrs[INTERFACE_MAX]; result = corosync_cfg_initialize (&handle, &callbacks); if (result != CS_OK) { printf ("Could not initialize corosync configuration API error %d\n", result); exit (1); } if (corosync_cfg_get_node_addrs(handle, nodeid, INTERFACE_MAX, &numaddrs, addrs) == CS_OK) { for (i=0; iss_family) { continue; } if (ss->ss_family == AF_INET6) { saddr = &sin6->sin6_addr; } else { saddr = &sin->sin_addr; } inet_ntop(ss->ss_family, saddr, buf, sizeof(buf)); if (i != 0) { printf(" "); } printf("%s", buf); } printf("\n"); } (void)corosync_cfg_finalize (handle); } static void killnode_do(unsigned int nodeid) { cs_error_t result; corosync_cfg_handle_t handle; printf ("Killing node " CS_PRI_NODE_ID "\n", nodeid); result = corosync_cfg_initialize (&handle, NULL); if (result != CS_OK) { printf ("Could not initialize corosync configuration API error %d\n", result); exit (1); } result = corosync_cfg_kill_node (handle, nodeid, "Killed by corosync-cfgtool"); if (result != CS_OK) { printf ("Could not kill node (error = %d)\n", result); } (void)corosync_cfg_finalize (handle); } static void usage_do (void) { printf ("corosync-cfgtool [[-i ] [-b] -s] [-R] [-L] [-k nodeid] [-a nodeid] [-h] [-H]\n\n"); printf ("A tool for displaying and configuring active parameters within corosync.\n"); printf ("options:\n"); printf ("\t-i\tFinds only information about the specified interface IP address or link id when used with -s..\n"); printf ("\t-s\tDisplays the status of the current links on this node(UDP/UDPU), with extended status for KNET.\n"); printf ("\t-b\tDisplays the brief status of the current links on this node when used with -s.(KNET only)\n"); printf ("\t-R\tTell all instances of corosync in this cluster to reload corosync.conf.\n"); printf ("\t-L\tTell corosync to reopen all logging files.\n"); printf ("\t-k\tKill a node identified by node id.\n"); printf ("\t-a\tDisplay the IP address(es) of a node\n"); printf ("\t-h\tPrint basic usage.\n"); printf ("\t-H\tShutdown corosync cleanly on this node.\n"); } int main (int argc, char *argv[]) { const char *options = "i:sbrRLk:a:hH"; int opt; unsigned int nodeid = 0; char interface_name[128] = ""; int rc = 0; enum user_action action = ACTION_NOOP; int brief = 0; while ( (opt = getopt(argc, argv, options)) != -1 ) { switch (opt) { case 'i': strncpy(interface_name, optarg, sizeof(interface_name)); interface_name[sizeof(interface_name) - 1] = '\0'; break; case 's': action = ACTION_LINKSTATUS_GET; break; case 'b': brief = 1; break; case 'R': action = ACTION_RELOAD_CONFIG; break; case 'L': action = ACTION_REOPEN_LOG_FILES; break; case 'k': nodeid = atoi (optarg); action = ACTION_KILL_NODE; break; case 'H': action = ACTION_SHUTDOW; break; case 'a': nodeid = atoi (optarg); action = ACTION_SHOWADDR; break; case '?': return (EXIT_FAILURE); break; case 'h': default: break; } } switch(action) { case ACTION_LINKSTATUS_GET: rc = linkstatusget_do(interface_name, brief); break; case ACTION_RELOAD_CONFIG: rc = reload_config_do(); break; case ACTION_REOPEN_LOG_FILES: rc = reopen_log_files_do(); break; case ACTION_KILL_NODE: killnode_do(nodeid); break; case ACTION_SHUTDOW: shutdown_do(); break; case ACTION_SHOWADDR: showaddrs_do(nodeid); break; case ACTION_NOOP: default: usage_do(); break; } return (rc); }