mirror of
				https://github.com/MariaDB/server.git
				synced 2025-10-31 10:56:12 +01:00 
			
		
		
		
	 b2429e2025
			
		
	
	
	b2429e2025
	
	
	
		
			
			The crash report terminates prematurely when Galera library was not loaded. As a fix, check whether the provider is loaded before shutting down Galera connections. Signed-off-by: Julius Goryavsky <julius.goryavsky@mariadb.com>
		
			
				
	
	
		
			107 lines
		
	
	
	
		
			4 KiB
		
	
	
	
		
			C++
		
	
	
	
	
	
			
		
		
	
	
			107 lines
		
	
	
	
		
			4 KiB
		
	
	
	
		
			C++
		
	
	
	
	
	
| /* Copyright 2018 Codership Oy <info@codership.com>
 | |
| 
 | |
|    This program is free software; you can redistribute it and/or modify
 | |
|    it under the terms of the GNU General Public License as published by
 | |
|    the Free Software Foundation; version 2 of the License.
 | |
| 
 | |
|    This program is distributed in the hope that it will be useful,
 | |
|    but WITHOUT ANY WARRANTY; without even the implied warranty of
 | |
|    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 | |
|    GNU General Public License for more details.
 | |
| 
 | |
|    You should have received a copy of the GNU General Public License
 | |
|    along with this program; if not, write to the Free Software
 | |
|    Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301  USA */
 | |
| 
 | |
| #include "my_global.h"
 | |
| #include "wsrep_api.h"
 | |
| #include "wsrep_server_state.h"
 | |
| #include "wsrep_binlog.h" /* init/deinit group commit */
 | |
| 
 | |
| #include "my_stacktrace.h" /* my_safe_printf_stderr() */
 | |
| 
 | |
| mysql_mutex_t LOCK_wsrep_server_state;
 | |
| mysql_cond_t  COND_wsrep_server_state;
 | |
| 
 | |
| #ifdef HAVE_PSI_INTERFACE
 | |
| PSI_mutex_key key_LOCK_wsrep_server_state;
 | |
| PSI_cond_key  key_COND_wsrep_server_state;
 | |
| #endif
 | |
| 
 | |
| Wsrep_server_state::Wsrep_server_state(const std::string& name,
 | |
|                                        const std::string& incoming_address,
 | |
|                                        const std::string& address,
 | |
|                                        const std::string& working_dir,
 | |
|                                        const wsrep::gtid& initial_position,
 | |
|                                        int max_protocol_version)
 | |
|   : wsrep::server_state(m_mutex,
 | |
|                         m_cond,
 | |
|                         m_service,
 | |
|                         NULL,
 | |
|                         name,
 | |
|                         incoming_address,
 | |
|                         address,
 | |
|                         working_dir,
 | |
|                         initial_position,
 | |
|                         max_protocol_version,
 | |
|                         wsrep::server_state::rm_sync)
 | |
|   , m_mutex(&LOCK_wsrep_server_state)
 | |
|   , m_cond(&COND_wsrep_server_state)
 | |
|   , m_service(*this)
 | |
| { }
 | |
| 
 | |
| Wsrep_server_state::~Wsrep_server_state() = default;
 | |
| 
 | |
| void Wsrep_server_state::init_once(const std::string& name,
 | |
|                                    const std::string& incoming_address,
 | |
|                                    const std::string& address,
 | |
|                                    const std::string& working_dir,
 | |
|                                    const wsrep::gtid& initial_position,
 | |
|                                    int max_protocol_version)
 | |
| {
 | |
|   if (m_instance == 0)
 | |
|   {
 | |
|     mysql_mutex_init(key_LOCK_wsrep_server_state, &LOCK_wsrep_server_state,
 | |
|                      MY_MUTEX_INIT_FAST);
 | |
|     mysql_cond_init(key_COND_wsrep_server_state, &COND_wsrep_server_state, 0);
 | |
|     m_instance = new Wsrep_server_state(name,
 | |
|                                         incoming_address,
 | |
|                                         address,
 | |
|                                         working_dir,
 | |
|                                         initial_position,
 | |
|                                         max_protocol_version);
 | |
|   }
 | |
| }
 | |
| 
 | |
| void Wsrep_server_state::destroy()
 | |
| {
 | |
| 
 | |
|   if (m_instance)
 | |
|   {
 | |
|     delete m_instance;
 | |
|     m_instance= 0;
 | |
|     mysql_mutex_destroy(&LOCK_wsrep_server_state);
 | |
|     mysql_cond_destroy(&COND_wsrep_server_state);
 | |
|   }
 | |
| }
 | |
| 
 | |
| void Wsrep_server_state::handle_fatal_signal()
 | |
| {
 | |
|   if (m_instance && m_instance->is_provider_loaded())
 | |
|   {
 | |
|     /* Galera background threads are still running and the logging may be
 | |
|        relatively verbose in case of networking error. Silence all wsrep
 | |
|        logging before shutting down networking to avoid garbling signal
 | |
|        handler output. */
 | |
|     my_safe_printf_stderr("WSREP: Suppressing further logging\n");
 | |
|     wsrep_suppress_error_logging();
 | |
| 
 | |
|     /* Shut down all communication with other nodes to fail silently. */
 | |
|     my_safe_printf_stderr("WSREP: Shutting down network communications\n");
 | |
|     if (m_instance->provider().set_node_isolation(
 | |
|           wsrep::provider::node_isolation::isolated)) {
 | |
|       my_safe_printf_stderr("WSREP: Galera library does not support node isolation\n");
 | |
|     }
 | |
|     my_safe_printf_stderr("\n");
 | |
|   }
 | |
| }
 |