hcq/MaxScale
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Divide monitor.h to internal and interface headers similar to filter.h

Browse Source 
Definitions and function used by core are in
server/core/maxscale/monitor.h
Definitions and function used by plugins are in
include/maxscale/monitor.h
This commit is contained in:
Esa Korhonen
2017-01-18 11:48:12 +02:00
parent 31c8481f6c
commit 7ed7f972b1
8 changed files with 199 additions and 173 deletions
Download Patch File Download Diff File Expand all files Collapse all files

244
include/maxscale/monitor.h
View File

@ -13,25 +13,7 @@
*/ */
/** /**
* @file monitor.h The interface to the monitor module * @file include/maxscale/monitor.h - The public monitor interface
*
* @verbatim
* Revision History
*
* Date Who Description
* 07/07/13 Mark Riddoch Initial implementation
* 25/07/13 Mark Riddoch Addition of diagnotics
* 23/05/14 Mark Riddoch Addition of routine to find monitors by name
* 23/05/14 Massimiliano Pinto Addition of defaultId and setInterval
* 23/06/14 Massimiliano Pinto Addition of replicationHeartbeat
* 28/08/14 Massimiliano Pinto Addition of detectStaleMaster
* 30/10/14 Massimiliano Pinto Addition of disableMasterFailback
* 07/11/14 Massimiliano Pinto Addition of setNetworkTimeout
* 19/02/15 Mark Riddoch Addition of monitorGetList
* 19/11/15 Martin Brampton Automation of event and name declaration, absorption
* of what was formerly monitor_common.h
*
* @endverbatim
*/ */
#include <maxscale/cdefs.h> #include <maxscale/cdefs.h>
@ -47,27 +29,33 @@
MXS_BEGIN_DECLS MXS_BEGIN_DECLS
/**
* The "Module Object" for a monitor module.
*
* The monitor modules are designed to monitor the backend databases that the gateway
* connects to and provide information regarding the status of the databases that
* is used in the routing decisions.
*
* startMonitor is called to start the monitoring process, it is called on the main
* thread of the gateway and is responsible for creating a thread for the monitor
* itself to run on. This should use the entry points defined in the thread.h
* header file rather than make direct calls to the operating system thrading libraries.
* The return from startMonitor is a void * handle that will be passed to all other monitor
* API calls.
*
* stopMonitor is responsible for shutting down and destroying a monitor.
*/
struct mxs_monitor; struct mxs_monitor;
typedef struct mxs_monitor MXS_MONITOR; typedef struct mxs_monitor MXS_MONITOR;
typedef struct /**
* @verbatim
* The "module object" structure for a backend monitor module
*
* Monitor modules monitor the backend databases that MaxScale connects to.
* The information provided by a monitor is used in routing decisions.
*
* The entry points are:
* startMonitor Called by main to start the monitor
* stopMonitor Called by main to shut down and destroy a monitor
* diagnostics Called for diagnostic output
*
* startMonitor is called to start the monitoring process, it is called on the
* MaxScale main thread and is responsible for creating a thread for the monitor
* itself to run on. This should use the entry points defined in the thread.h
* header file rather than make direct calls to the operating system threading
* libraries. The return from startMonitor is a pointer that will be passed to
* all other monitor API calls.
*
* @endverbatim
*
* @see load_module
*/
typedef struct mxs_monitor_object
{ {
void *(*startMonitor)(MXS_MONITOR *monitor, const CONFIG_PARAMETER *params); void *(*startMonitor)(MXS_MONITOR *monitor, const CONFIG_PARAMETER *params);
void (*stopMonitor)(MXS_MONITOR *monitor); void (*stopMonitor)(MXS_MONITOR *monitor);
@ -83,6 +71,15 @@ typedef struct
/** Monitor's poll frequency */ /** Monitor's poll frequency */
#define MXS_MON_BASE_INTERVAL_MS 100 #define MXS_MON_BASE_INTERVAL_MS 100
#define MXS_MONITOR_RUNNING 1
#define MXS_MONITOR_STOPPING 2
#define MXS_MONITOR_STOPPED 3
#define MXS_MONITOR_DEFAULT_ID 1UL // unsigned long value
#define MAX_MONITOR_USER_LEN 512
#define MAX_MONITOR_PASSWORD_LEN 512
/** /**
* Monitor state bit mask values * Monitor state bit mask values
*/ */
@ -95,16 +92,6 @@ typedef enum
MONITOR_STATE_FREED = 0x08 MONITOR_STATE_FREED = 0x08
} monitor_state_t; } monitor_state_t;
/**
* Monitor network timeout types
*/
typedef enum
{
MONITOR_CONNECT_TIMEOUT = 0,
MONITOR_READ_TIMEOUT = 1,
MONITOR_WRITE_TIMEOUT = 2
} monitor_timeouts_t;
/* /*
* Results of attempt at database connection for monitoring * Results of attempt at database connection for monitoring
*/ */
@ -115,23 +102,6 @@ typedef enum
MONITOR_CONN_TIMEOUT MONITOR_CONN_TIMEOUT
} mxs_connect_result_t; } mxs_connect_result_t;
#define MON_ARG_MAX 8192
#define DEFAULT_CONNECT_TIMEOUT 3
#define DEFAULT_READ_TIMEOUT 1
#define DEFAULT_WRITE_TIMEOUT 2
#define MXS_MONITOR_RUNNING 1
#define MXS_MONITOR_STOPPING 2
#define MXS_MONITOR_STOPPED 3
#define MONITOR_DEFAULT_INTERVAL 10000 // in milliseconds
#define MXS_MONITOR_DEFAULT_ID 1UL // unsigned long value
#define MAX_MONITOR_USER_LEN 512
#define MAX_MONITOR_PASSWORD_LEN 512
/** Monitor events */ /** Monitor events */
typedef enum typedef enum
{ {
@ -160,39 +130,6 @@ typedef enum
NEW_NDB_EVENT = (1 << 21), /**< new_ndb */ NEW_NDB_EVENT = (1 << 21), /**< new_ndb */
} mxs_monitor_event_t; } mxs_monitor_event_t;
static const MXS_ENUM_VALUE mxs_monitor_event_enum_values[] =
{
{"master_down", MASTER_DOWN_EVENT},
{"master_up", MASTER_UP_EVENT},
{"slave_down", SLAVE_DOWN_EVENT},
{"slave_up", SLAVE_UP_EVENT},
{"server_down", SERVER_DOWN_EVENT},
{"server_up", SERVER_UP_EVENT},
{"synced_down", SYNCED_DOWN_EVENT},
{"synced_up", SYNCED_UP_EVENT},
{"donor_down", DONOR_DOWN_EVENT},
{"donor_up", DONOR_UP_EVENT},
{"ndb_down", NDB_DOWN_EVENT},
{"ndb_up", NDB_UP_EVENT},
{"lost_master", LOST_MASTER_EVENT},
{"lost_slave", LOST_SLAVE_EVENT},
{"lost_synced", LOST_SYNCED_EVENT},
{"lost_donor", LOST_DONOR_EVENT},
{"lost_ndb", LOST_NDB_EVENT},
{"new_master", NEW_MASTER_EVENT},
{"new_slave", NEW_SLAVE_EVENT},
{"new_synced", NEW_SYNCED_EVENT},
{"new_donor", NEW_DONOR_EVENT},
{"new_ndb", NEW_NDB_EVENT},
{NULL}
};
/** Default value for the `events` parameter */
static const char MXS_MONITOR_EVENT_DEFAULT_VALUE[] = "master_down,master_up,slave_down,"
"slave_up,server_down,server_up,synced_down,synced_up,donor_down,donor_up,"
"ndb_down,ndb_up,lost_master,lost_slave,lost_synced,lost_donor,lost_ndb,"
"new_master,new_slave,new_synced,new_donor,new_ndb";
/** /**
* The linked list of servers that are being monitored by the monitor module. * The linked list of servers that are being monitored by the monitor module.
*/ */
@ -239,40 +176,64 @@ struct mxs_monitor
struct mxs_monitor *next; /**< Next monitor in the linked list */ struct mxs_monitor *next; /**< Next monitor in the linked list */
}; };
extern MXS_MONITOR *monitor_alloc(char *, char *); static const MXS_ENUM_VALUE mxs_monitor_event_enum_values[] =
extern void monitor_free(MXS_MONITOR *); {
extern MXS_MONITOR *monitor_find(const char *); {"master_down", MASTER_DOWN_EVENT},
extern bool monitorAddServer(MXS_MONITOR *mon, SERVER *server); {"master_up", MASTER_UP_EVENT},
extern void monitorRemoveServer(MXS_MONITOR *mon, SERVER *server); {"slave_down", SLAVE_DOWN_EVENT},
extern void monitorAddUser(MXS_MONITOR *, char *, char *); {"slave_up", SLAVE_UP_EVENT},
extern void monitorAddParameters(MXS_MONITOR *monitor, CONFIG_PARAMETER *params); {"server_down", SERVER_DOWN_EVENT},
extern bool monitorRemoveParameter(MXS_MONITOR *monitor, const char *key); {"server_up", SERVER_UP_EVENT},
extern void monitorStop(MXS_MONITOR *); {"synced_down", SYNCED_DOWN_EVENT},
extern void monitorStart(MXS_MONITOR *, void*); {"synced_up", SYNCED_UP_EVENT},
extern void monitorStopAll(); {"donor_down", DONOR_DOWN_EVENT},
extern void monitorStartAll(); {"donor_up", DONOR_UP_EVENT},
extern void monitorShowAll(DCB *); {"ndb_down", NDB_DOWN_EVENT},
extern void monitorShow(DCB *, MXS_MONITOR *); {"ndb_up", NDB_UP_EVENT},
extern void monitorList(DCB *); {"lost_master", LOST_MASTER_EVENT},
extern void monitorSetInterval (MXS_MONITOR *, unsigned long); {"lost_slave", LOST_SLAVE_EVENT},
extern bool monitorSetNetworkTimeout(MXS_MONITOR *, int, int); {"lost_synced", LOST_SYNCED_EVENT},
extern RESULTSET *monitorGetList(); {"lost_donor", LOST_DONOR_EVENT},
extern bool check_monitor_permissions(MXS_MONITOR* monitor, const char* query); {"lost_ndb", LOST_NDB_EVENT},
{"new_master", NEW_MASTER_EVENT},
{"new_slave", NEW_SLAVE_EVENT},
{"new_synced", NEW_SYNCED_EVENT},
{"new_donor", NEW_DONOR_EVENT},
{"new_ndb", NEW_NDB_EVENT},
{NULL}
};
/** Default value for the `events` parameter */
static const char MXS_MONITOR_EVENT_DEFAULT_VALUE[] = "master_down,master_up,slave_down,"
"slave_up,server_down,server_up,synced_down,synced_up,donor_down,donor_up,"
"ndb_down,ndb_up,lost_master,lost_slave,lost_synced,lost_donor,lost_ndb,"
"new_master,new_slave,new_synced,new_donor,new_ndb";
MXS_MONITOR *monitor_find(const char *);
void monitorStop(MXS_MONITOR *);
void monitorStart(MXS_MONITOR *, void*);
void monitorShowAll(DCB *);
void monitorShow(DCB *, MXS_MONITOR *);
void monitorList(DCB *);
RESULTSET *monitorGetList();
bool check_monitor_permissions(MXS_MONITOR* monitor, const char* query);
mxs_monitor_event_t mon_get_event_type(MXS_MONITOR_SERVERS* node);
const char* mon_get_event_name(MXS_MONITOR_SERVERS* node);
void monitor_clear_pending_status(MXS_MONITOR_SERVERS *ptr, int bit); void monitor_clear_pending_status(MXS_MONITOR_SERVERS *ptr, int bit);
void monitor_set_pending_status(MXS_MONITOR_SERVERS *ptr, int bit); void monitor_set_pending_status(MXS_MONITOR_SERVERS *ptr, int bit);
bool mon_status_changed(MXS_MONITOR_SERVERS* mon_srv);
bool mon_print_fail_status(MXS_MONITOR_SERVERS* mon_srv);
mxs_connect_result_t mon_connect_to_db(MXS_MONITOR* mon, MXS_MONITOR_SERVERS *database);
void mon_log_connect_error(MXS_MONITOR_SERVERS* database, mxs_connect_result_t rval);
void mon_log_state_change(MXS_MONITOR_SERVERS *ptr);
void lock_monitor_servers(MXS_MONITOR *monitor);
void release_monitor_servers(MXS_MONITOR *monitor);
void servers_status_pending_to_current(MXS_MONITOR *monitor); void servers_status_pending_to_current(MXS_MONITOR *monitor);
void servers_status_current_to_pending(MXS_MONITOR *monitor); void servers_status_current_to_pending(MXS_MONITOR *monitor);
bool mon_status_changed(MXS_MONITOR_SERVERS* mon_srv);
bool mon_print_fail_status(MXS_MONITOR_SERVERS* mon_srv);
mxs_connect_result_t mon_connect_to_db(MXS_MONITOR* mon, MXS_MONITOR_SERVERS *database);
void mon_log_connect_error(MXS_MONITOR_SERVERS* database, mxs_connect_result_t rval);
void lock_monitor_servers(MXS_MONITOR *monitor);
void release_monitor_servers(MXS_MONITOR *monitor);
/** /**
* @brief Handle state change events * @brief Handle state change events
* *
@ -294,37 +255,4 @@ void mon_process_state_changes(MXS_MONITOR *monitor, const char *script, uint64_
*/ */
void mon_hangup_failed_servers(MXS_MONITOR *monitor); void mon_hangup_failed_servers(MXS_MONITOR *monitor);
/**
* @brief Serialize the servers of a monitor to a file
*
* This partially converts @c monitor into an INI format file. Only the servers
* of the monitor are serialized. This allows the monitor to keep monitoring
* the servers that were added at runtime even after a restart.
*
* NOTE: This does not persist the complete monitor configuration and requires
* that an existing monitor configuration is in the main configuration file.
* Changes to monitor parameters are not persisted.
*
* @param monitor Monitor to serialize
* @return False if the serialization of the monitor fails, true if it was successful
*/
bool monitor_serialize_servers(const MXS_MONITOR *monitor);
/**
* @brief Serialize a monitor to a file
*
* This converts the static configuration of the monitor into an INI format file.
*
* @param monitor Monitor to serialize
* @return True if serialization was successful
*/
bool monitor_serialize(const MXS_MONITOR *monitor);
/**
* Check if a server is being monitored and return the monitor.
* @param server Server that is queried
* @return The monitor watching this server, or NULL if not monitored
*/
MXS_MONITOR* monitor_server_in_use(const SERVER *server);
MXS_END_DECLS MXS_END_DECLS

2
server/core/config.c
View File

@ -59,7 +59,6 @@
#include <maxscale/limits.h> #include <maxscale/limits.h>
#include <maxscale/log_manager.h> #include <maxscale/log_manager.h>
#include <maxscale/modules.h> #include <maxscale/modules.h>
#include <maxscale/monitor.h>
#include <maxscale/notification.h> #include <maxscale/notification.h>
#include <maxscale/pcre2.h> #include <maxscale/pcre2.h>
#include <maxscale/spinlock.h> #include <maxscale/spinlock.h>
@ -69,6 +68,7 @@
#include "maxscale/config.h" #include "maxscale/config.h"
#include "maxscale/filter.h" #include "maxscale/filter.h"
#include "maxscale/service.h" #include "maxscale/service.h"
#include "maxscale/monitor.h"
typedef struct duplicate_context typedef struct duplicate_context
{ {

1
server/core/config_runtime.c
View File

@ -20,6 +20,7 @@
#include "maxscale/config.h" #include "maxscale/config.h"
#include "maxscale/service.h" #include "maxscale/service.h"
#include "maxscale/monitor.h"
static SPINLOCK crt_lock = SPINLOCK_INIT; static SPINLOCK crt_lock = SPINLOCK_INIT;

2
server/core/gateway.cc
View File

@ -61,7 +61,6 @@
#include <maxscale/maxscale.h> #include <maxscale/maxscale.h>
#include <maxscale/memlog.h> #include <maxscale/memlog.h>
#include <maxscale/modules.h> #include <maxscale/modules.h>
#include <maxscale/monitor.h>
#include <maxscale/poll.h> #include <maxscale/poll.h>
#include <maxscale/query_classifier.h> #include <maxscale/query_classifier.h>
#include <maxscale/server.h> #include <maxscale/server.h>
@ -73,6 +72,7 @@
#include "maxscale/config.h" #include "maxscale/config.h"
#include "maxscale/service.h" #include "maxscale/service.h"
#include "maxscale/statistics.h" #include "maxscale/statistics.h"
#include "maxscale/monitor.h"
#define STRING_BUFFER_SIZE 1024 #define STRING_BUFFER_SIZE 1024
#define PIDFD_CLOSED -1 #define PIDFD_CLOSED -1

94
server/core/maxscale/monitor.h Normal file
View File

@ -0,0 +1,94 @@
#pragma once
/*
* 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/bsl.
*
* 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 core/maxscale/monitor.h - The private monitor interface
*/
#include <maxscale/monitor.h>
MXS_BEGIN_DECLS
#define MON_ARG_MAX 8192
#define DEFAULT_CONNECT_TIMEOUT 3
#define DEFAULT_READ_TIMEOUT 1
#define DEFAULT_WRITE_TIMEOUT 2
#define MONITOR_DEFAULT_INTERVAL 10000 // in milliseconds
/**
* Monitor network timeout types
*/
typedef enum
{
MONITOR_CONNECT_TIMEOUT = 0,
MONITOR_READ_TIMEOUT = 1,
MONITOR_WRITE_TIMEOUT = 2
} monitor_timeouts_t;
extern MXS_MONITOR *monitor_alloc(char *, char *);
extern void monitor_free(MXS_MONITOR *);
extern void monitorStopAll();
extern void monitorStartAll();
extern bool monitorAddServer(MXS_MONITOR *mon, SERVER *server);
extern void monitorRemoveServer(MXS_MONITOR *mon, SERVER *server);
extern void monitorAddUser(MXS_MONITOR *, char *, char *);
extern void monitorAddParameters(MXS_MONITOR *monitor, CONFIG_PARAMETER *params);
extern bool monitorRemoveParameter(MXS_MONITOR *monitor, const char *key);
extern void monitorSetInterval (MXS_MONITOR *, unsigned long);
extern bool monitorSetNetworkTimeout(MXS_MONITOR *, int, int);
mxs_monitor_event_t mon_get_event_type(MXS_MONITOR_SERVERS* node);
const char* mon_get_event_name(MXS_MONITOR_SERVERS* node);
void mon_log_state_change(MXS_MONITOR_SERVERS *ptr);
/**
* @brief Serialize the servers of a monitor to a file
*
* This partially converts @c monitor into an INI format file. Only the servers
* of the monitor are serialized. This allows the monitor to keep monitoring
* the servers that were added at runtime even after a restart.
*
* NOTE: This does not persist the complete monitor configuration and requires
* that an existing monitor configuration is in the main configuration file.
* Changes to monitor parameters are not persisted.
*
* @param monitor Monitor to serialize
* @return False if the serialization of the monitor fails, true if it was successful
*/
bool monitor_serialize_servers(const MXS_MONITOR *monitor);
/**
* @brief Serialize a monitor to a file
*
* This converts the static configuration of the monitor into an INI format file.
*
* @param monitor Monitor to serialize
* @return True if serialization was successful
*/
bool monitor_serialize(const MXS_MONITOR *monitor);
/**
* Check if a server is being monitored and return the monitor.
* @param server Server that is queried
* @return The monitor watching this server, or NULL if not monitored
*/
MXS_MONITOR* monitor_server_in_use(const SERVER *server);
MXS_END_DECLS

2
server/core/monitor.c
View File

@ -30,7 +30,6 @@
#include <stdio.h> #include <stdio.h>
#include <stdlib.h> #include <stdlib.h>
#include <string.h> #include <string.h>
#include <maxscale/monitor.h>
#include <maxscale/spinlock.h> #include <maxscale/spinlock.h>
#include <maxscale/modules.h> #include <maxscale/modules.h>
#include <maxscale/log_manager.h> #include <maxscale/log_manager.h>
@ -42,6 +41,7 @@
#include <maxscale/alloc.h> #include <maxscale/alloc.h>
#include <maxscale/gwdirs.h> #include <maxscale/gwdirs.h>
#include "maxscale/monitor.h"
#include "maxscale/config.h" #include "maxscale/config.h"
static MXS_MONITOR *allMonitors = NULL; static MXS_MONITOR *allMonitors = NULL;

3
server/core/server.c
View File

@ -39,7 +39,6 @@
#include <sys/stat.h> #include <sys/stat.h>
#include <fcntl.h> #include <fcntl.h>
#include <maxscale/service.h> #include <maxscale/service.h>
#include <maxscale/monitor.h>
#include <maxscale/session.h> #include <maxscale/session.h>
#include <maxscale/server.h> #include <maxscale/server.h>
#include <maxscale/spinlock.h> #include <maxscale/spinlock.h>
@ -51,6 +50,8 @@
#include <maxscale/modules.h> #include <maxscale/modules.h>
#include <maxscale/gwdirs.h> #include <maxscale/gwdirs.h>
#include "maxscale/monitor.h"
/** The latin1 charset */ /** The latin1 charset */
#define SERVER_DEFAULT_CHARSET 0x08 #define SERVER_DEFAULT_CHARSET 0x08

2
server/core/test/testmodulecmd.c
View File

@ -21,6 +21,8 @@
#include <maxscale/modulecmd.h> #include <maxscale/modulecmd.h>
#include <maxscale/session.h> #include <maxscale/session.h>
#include "../maxscale/monitor.h"
#define TEST(a, b) do{if (!(a)){printf("%s:%d "b"\n", __FILE__, __LINE__);return 1;}}while(false) #define TEST(a, b) do{if (!(a)){printf("%s:%d "b"\n", __FILE__, __LINE__);return 1;}}while(false)
static bool ok = false; static bool ok = false;