Coverity error reader: /pacemaker/daemons/controld/controld

1    	/*
2    	 * Copyright 2004-2026 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 General Public License version 2
7    	 * or later (GPLv2+) WITHOUT ANY WARRANTY.
8    	 */
9    	
10   	#include <crm_internal.h>
11   	
12   	#include <stdbool.h>
13   	#include <sys/param.h>
14   	#include <sys/types.h>
15   	#include <sys/stat.h>
16   	
17   	#include <crm/crm.h>
18   	#include <crm/common/xml.h>
19   	#include <crm/cluster/internal.h>
20   	#include <crm/cluster/election_internal.h>
21   	
22   	#include <pacemaker-controld.h>
23   	
24   	static qb_ipcs_service_t *ipcs = NULL;
25   	
26   	static crm_trigger_t *config_read_trigger = NULL;
27   	
28   	#if SUPPORT_COROSYNC
29   	extern gboolean crm_connect_corosync(pcmk_cluster_t *cluster);
30   	#endif
31   	
32   	static void crm_shutdown(int nsig);
33   	static gboolean crm_read_options(gpointer user_data);
34   	
35   	// A_HA_CONNECT
36   	void
37   	do_ha_control(long long action, enum crmd_fsa_cause cause,
38   	              enum crmd_fsa_state cur_state, enum crmd_fsa_input current_input,
39   	              fsa_data_t *msg_data)
40   	{
41   	    bool connected = false;
42   	
43   	    if (controld_globals.cluster == NULL) {
44   	        controld_globals.cluster = pcmk_cluster_new();
45   	    }
46   	
47   	    if (pcmk__is_set(action, A_HA_DISCONNECT)) {
48   	        pcmk_cluster_disconnect(controld_globals.cluster);
49   	        controld_set_fsa_input_flags(R_HA_DISCONNECTED);
50   	        pcmk__info("Disconnected from the cluster");
51   	    }
52   	
53   	    if (pcmk__is_set(action, A_HA_CONNECT)) {
54   	        pcmk__cluster_set_status_callback(&peer_update_callback);
55   	        pcmk__cluster_set_autoreap(false);
56   	
57   	#if SUPPORT_COROSYNC
58   	        if (pcmk_get_cluster_layer() == pcmk_cluster_layer_corosync) {
59   	            connected = crm_connect_corosync(controld_globals.cluster);
60   	        }
61   	#endif // SUPPORT_COROSYNC
62   	
63   	        if (connected) {
64   	            pcmk__node_status_t *node = controld_get_local_node_status();
65   	
66   	            controld_election_init();
67   	
68   	            pcmk__str_update(&(controld_globals.our_uuid),
69   	                             pcmk__cluster_get_xml_id(node));
70   	
71   	            if (controld_globals.our_uuid == NULL) {
72   	                pcmk__err("Could not obtain local node UUID");
73   	                connected = false;
74   	            }
75   	        }
76   	
77   	        if (!connected) {
78   	            controld_set_fsa_input_flags(R_HA_DISCONNECTED);
79   	            register_fsa_error(I_ERROR, msg_data);
80   	            return;
81   	        }
82   	
83   	        populate_cib_nodes(controld_node_update_none, __func__);
84   	        controld_clear_fsa_input_flags(R_HA_DISCONNECTED);
85   	        pcmk__info("Connected to the cluster");
86   	    }
87   	
88   	    if ((action & ~(A_HA_CONNECT|A_HA_DISCONNECT)) != 0) {
89   	        pcmk__err("Unexpected action %s in %s", fsa_action2string(action),
90   	                  __func__);
91   	    }
92   	}
93   	
94   	// A_SHUTDOWN
95   	void
96   	do_shutdown(long long action, enum crmd_fsa_cause cause,
97   	            enum crmd_fsa_state cur_state, enum crmd_fsa_input current_input,
98   	            fsa_data_t *msg_data)
99   	{
100  	    // Just in case
101  	    controld_set_fsa_input_flags(R_SHUTDOWN);
102  	    controld_disconnect_fencer(false);
103  	}
104  	
105  	// A_SHUTDOWN_REQ
106  	void
107  	do_shutdown_req(long long action, enum crmd_fsa_cause cause,
108  	                enum crmd_fsa_state cur_state,
109  	                enum crmd_fsa_input current_input, fsa_data_t *msg_data)
110  	{
111  	    xmlNode *msg = NULL;
112  	
113  	    pcmk__info("Sending shutdown request to all peers (DC is %s)",
114  	               pcmk__s(controld_globals.dc_name, "not set"));
115  	
116  	    controld_set_fsa_input_flags(R_SHUTDOWN);
117  	    msg = pcmk__new_request(pcmk_ipc_controld, CRM_SYSTEM_CRMD, NULL,
118  	                            CRM_SYSTEM_CRMD, CRM_OP_SHUTDOWN_REQ, NULL);
119  	
120  	    if (!pcmk__cluster_send_message(NULL, pcmk_ipc_controld, msg)) {
121  	        register_fsa_error(I_ERROR, msg_data);
122  	    }
123  	    pcmk__xml_free(msg);
124  	}
125  	
126  	void
127  	crmd_fast_exit(crm_exit_t exit_code)
128  	{
129  	    if (pcmk__is_set(controld_globals.fsa_input_register, R_STAYDOWN)) {
130  	        pcmk__warn("Inhibiting respawn " QB_XS " remapping exit code %d to %d",
131  	                   exit_code, CRM_EX_FATAL);
132  	        exit_code = CRM_EX_FATAL;
133  	
134  	    } else if ((exit_code == CRM_EX_OK)
135  	               && pcmk__is_set(controld_globals.fsa_input_register,
136  	                               R_IN_RECOVERY)) {
137  	        pcmk__err("Could not recover from internal error");
138  	        exit_code = CRM_EX_ERROR;
139  	    }
140  	
141  	    if (controld_globals.logger_out != NULL) {
142  	        controld_globals.logger_out->finish(controld_globals.logger_out,
143  	                                            exit_code, true, NULL);
144  	        g_clear_pointer(&controld_globals.logger_out, pcmk__output_free);
145  	    }
146  	
147  	    crm_exit(exit_code);
148  	}
149  	
150  	crm_exit_t
151  	crmd_exit(crm_exit_t exit_code)
152  	{
153  	    GMainLoop *mloop = controld_globals.mainloop;
154  	
155  	    static bool in_progress = FALSE;
156

(1) Event path:

Condition "in_progress", taking false branch.

157  	    if (in_progress && (exit_code == CRM_EX_OK)) {
158  	        pcmk__debug("Exit is already in progress");
159  	        return exit_code;
160

(2) Event path:

Condition "in_progress", taking false branch.

161  	    } else if(in_progress) {
162  	        pcmk__notice("Error during shutdown process, exiting now with status "
163  	                     "%d (%s)",
164  	                     exit_code, crm_exit_str(exit_code));
165  	        crm_write_blackbox(SIGTRAP, NULL);
166  	        crmd_fast_exit(exit_code);
167  	    }
168  	
169  	    in_progress = TRUE;

(3) Event path:	Switch case default.
(4) Event path:	Condition "trace_cs == NULL", taking true branch.
(5) Event path:	Condition "crm_is_callsite_active(trace_cs, _level, 0)", taking false branch.
(6) Event path:	Breaking from switch.

170  	    pcmk__trace("Preparing to exit with status %d (%s)", exit_code,
171  	                crm_exit_str(exit_code));
172  	
173  	    /* Suppress secondary errors resulting from us disconnecting everything */
174  	    controld_set_fsa_input_flags(R_HA_DISCONNECTED);
175  	
176  	/* Close all IPC servers and clients to ensure any and all shared memory files are cleaned up */
177

(7) Event path:

Condition "ipcs", taking true branch.

178  	    if(ipcs) {

(8) Event path:	Switch case default.
(9) Event path:	Condition "trace_cs == NULL", taking true branch.
(10) Event path:	Condition "crm_is_callsite_active(trace_cs, _level, 0)", taking false branch.
(11) Event path:	Breaking from switch.

179  	        pcmk__trace("Closing IPC server");
180  	        mainloop_del_ipc_server(ipcs);
181  	        ipcs = NULL;
182  	    }
183  	
184  	    controld_close_attrd_ipc();
185  	    controld_shutdown_schedulerd_ipc();
186  	    controld_disconnect_fencer(TRUE);
187

(12) Event path:	Condition "exit_code == CRM_EX_OK", taking true branch.
(13) Event path:	Condition "controld_globals.mainloop == NULL", taking false branch.

188  	    if ((exit_code == CRM_EX_OK) && (controld_globals.mainloop == NULL)) {
189  	        pcmk__debug("No mainloop detected");
190  	        exit_code = CRM_EX_ERROR;
191  	    }
192  	
193  	    /* On an error, just get out.
194  	     *
195  	     * Otherwise, make the effort to have mainloop exit gracefully so
196  	     * that it (mostly) cleans up after itself and valgrind has less
197  	     * to report on - allowing real errors stand out
198  	     */

(14) Event path:

Condition "exit_code != CRM_EX_OK", taking false branch.

199  	    if (exit_code != CRM_EX_OK) {
200  	        pcmk__notice("Forcing immediate exit with status %d (%s)", exit_code,
201  	                     crm_exit_str(exit_code));
202  	        crm_write_blackbox(SIGTRAP, NULL);
203  	        crmd_fast_exit(exit_code);
204  	    }
205  	
206  	/* Clean up as much memory as possible for valgrind */
207  	
208  	    controld_clear_fsa_input_flags(R_MEMBERSHIP);
209  	
210  	    g_queue_free_full(controld_globals.fsa_message_queue,
211  	                      (GDestroyNotify) delete_fsa_input);
212  	    controld_globals.fsa_message_queue = NULL;
213  	
214  	    controld_free_node_pending_timers();
215  	    election_reset(controld_globals.cluster); // Stop any election timer
216  	
217  	    /* Tear down the CIB manager connection, but don't free it yet -- it could
218  	     * be used when we drain the mainloop later.
219  	     */
220  	
221  	    controld_disconnect_cib_manager();
222  	
223  	    verify_stopped(controld_globals.fsa_state, LOG_WARNING);
224  	    controld_clear_fsa_input_flags(R_LRM_CONNECTED);
225  	
226  	    controld_execd_state_table_free();
227  	    controld_remote_proxy_table_free();
228

(15) Event path: