b434c94563
If a monitor is started and stopped before the external monitoring thread has had time to start, a deadlock will occur. The first thing that the monitoring threads do is read the monitor handle from the monitor object. This handle is given as the return value of startMonitor and it is stored in the monitor object. As this can still be NULL when the monitor thread starts, the threads use locks to prevent this. The correct way to prevent this is to pass the handle as the thread parameter so that no locks are required.
119 lines
4.1 KiB
C
119 lines
4.1 KiB
C
#pragma once
|
|
#ifndef _MYSQLMON_H
|
|
#define _MYSQLMON_H
|
|
/*
|
|
* Copyright (c) 2016 MariaDB Corporation Ab
|
|
*
|
|
* Use of this software is governed by the Business Source License included
|
|
* in the LICENSE.TXT file and at www.mariadb.com/bsl11.
|
|
*
|
|
* Change Date: 2019-07-01
|
|
*
|
|
* On the date above, in accordance with the Business Source License, use
|
|
* of this software will be governed by version 2 or later of the General
|
|
* Public License.
|
|
*/
|
|
|
|
/**
|
|
* @file mysqlmon.h - The MySQL monitor
|
|
*
|
|
* @verbatim
|
|
* Revision History
|
|
*
|
|
* Date Who Description
|
|
* 08/07/13 Mark Riddoch Initial implementation
|
|
* 26/05/14 Massimiliano Pinto Default values for MONITOR_INTERVAL
|
|
* 28/05/14 Massimiliano Pinto Addition of new fields in MYSQL_MONITOR struct
|
|
* 24/06/14 Massimiliano Pinto Addition of master field in MYSQL_MONITOR struct and MONITOR_MAX_NUM_SLAVES
|
|
* 28/08/14 Massimiliano Pinto Addition of detectStaleMaster
|
|
* 30/10/14 Massimiliano Pinto Addition of disableMasterFailback
|
|
* 07/11/14 Massimiliano Pinto Addition of NetworkTimeout: connect, read, write
|
|
* 20/04/15 Guillaume Lefranc Addition of availableWhenDonor
|
|
* 22/04/15 Martin Brampton Addition of disableMasterRoleSetting
|
|
* 07/05/15 Markus Makela Addition of command execution on Master server failure
|
|
* @endverbatim
|
|
*/
|
|
|
|
#include <maxscale/cdefs.h>
|
|
#include <stdio.h>
|
|
#include <stdlib.h>
|
|
#include <string.h>
|
|
#include <maxscale/monitor.h>
|
|
#include <maxscale/spinlock.h>
|
|
#include <maxscale/thread.h>
|
|
#include <mysql.h>
|
|
#include <mysqld_error.h>
|
|
#include <maxscale/log_manager.h>
|
|
#include <maxscale/secrets.h>
|
|
#include <maxscale/dcb.h>
|
|
#include <maxscale/modinfo.h>
|
|
#include <maxscale/config.h>
|
|
#include <maxscale/hashtable.h>
|
|
|
|
MXS_BEGIN_DECLS
|
|
|
|
/**
|
|
* The handle for an instance of a MySQL Monitor module
|
|
*/
|
|
typedef struct
|
|
{
|
|
THREAD thread; /**< Monitor thread */
|
|
int shutdown; /**< Flag to shutdown the monitor thread */
|
|
int status; /**< Monitor status */
|
|
unsigned long id; /**< Monitor ID */
|
|
int replicationHeartbeat; /**< Monitor flag for MySQL replication heartbeat */
|
|
bool detectStaleMaster; /**< Monitor flag for MySQL replication Stale Master detection */
|
|
bool detectStaleSlave; /**< Monitor flag for MySQL replication Stale Master detection */
|
|
bool multimaster; /**< Detect and handle multi-master topologies */
|
|
int disableMasterFailback; /**< Monitor flag for Galera Cluster Master failback */
|
|
int availableWhenDonor; /**< Monitor flag for Galera Cluster Donor availability */
|
|
int disableMasterRoleSetting; /**< Monitor flag to disable setting master role */
|
|
bool mysql51_replication; /**< Use MySQL 5.1 replication */
|
|
MXS_MONITOR_SERVERS *master; /**< Master server for MySQL Master/Slave replication */
|
|
char* script; /*< Script to call when state changes occur on servers */
|
|
uint64_t events; /*< enabled events */
|
|
HASHTABLE *server_info; /**< Contains server specific information */
|
|
bool detect_standalone_master; /**< If standalone master are detected */
|
|
int failcount; /**< How many monitoring cycles servers must be
|
|
down before failover is initiated */
|
|
bool allow_cluster_recovery; /**< Allow failed servers to rejoin the cluster */
|
|
bool warn_failover; /**< Log a warning when failover happens */
|
|
bool load_journal; /**< Whether journal file should be loaded */
|
|
time_t journal_max_age; /**< Maximum age of journal file */
|
|
MXS_MONITOR* monitor;
|
|
} MYSQL_MONITOR;
|
|
|
|
/**
|
|
* @brief Store a journal of server states
|
|
*
|
|
* @param monitor Monitor to journal
|
|
*/
|
|
void store_server_journal(MXS_MONITOR *monitor);
|
|
|
|
/**
|
|
* @brief Load a journal of server states
|
|
*
|
|
* @param monitor Monitor where journal is loaded
|
|
*/
|
|
void load_server_journal(MXS_MONITOR *monitor);
|
|
|
|
/**
|
|
* @brief Remove stored journal file
|
|
*
|
|
* @param monitor Monitor whose journal is removed
|
|
*/
|
|
void remove_server_journal(MXS_MONITOR *monitor);
|
|
|
|
/**
|
|
* @brief Check whether the journal is too old
|
|
*
|
|
* @param monitor Monitor to check
|
|
* @return True if journal is stale or an error occurred while reading the file.
|
|
* False if the file is still valid.
|
|
*/
|
|
bool journal_is_stale(MXS_MONITOR *monitor, time_t max_age);
|
|
|
|
MXS_END_DECLS
|
|
|
|
#endif
|