mirror of
https://github.com/codership/wsrep-lib.git
synced 2025-04-19 21:02:17 +03:00
7d108eb870
MySQL defines a macro log_msg in one of its headers, which causes log_msg to be replaced with different symbol in some compilation units. Fix by renaming the struct to log_msg_t to avoid the conflict.
135 lines
4.1 KiB
C++
135 lines
4.1 KiB
C++
/*
|
|
* Copyright (C) 2021 Codership Oy <info@codership.com>
|
|
*
|
|
* This file is part of wsrep-lib.
|
|
*
|
|
* Wsrep-lib 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, either version 2 of the License, or
|
|
* (at your option) any later version.
|
|
*
|
|
* Wsrep-lib 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 wsrep-lib. If not, see <https://www.gnu.org/licenses/>.
|
|
*/
|
|
|
|
/** @file info.hpp
|
|
*
|
|
* Interface to report application status to external programs
|
|
* via JSON file.
|
|
*/
|
|
|
|
#ifndef WSREP_REPORTER_HPP
|
|
#define WSREP_REPORTER_HPP
|
|
|
|
#include "mutex.hpp"
|
|
#include "server_state.hpp"
|
|
|
|
#include <string>
|
|
#include <deque>
|
|
|
|
namespace wsrep
|
|
{
|
|
class reporter
|
|
{
|
|
public:
|
|
reporter(mutex& mutex,
|
|
const std::string& file_name,
|
|
size_t max_msg);
|
|
|
|
virtual ~reporter();
|
|
|
|
void report_state(enum server_state::state state);
|
|
|
|
/**
|
|
* Report progres in the form of a JSON string (all values integers):
|
|
* {
|
|
* "from": FROM, // from wsrep API state number
|
|
* "to": TO, // to wsrep API state number
|
|
* "total": TOTAL, // total work to do
|
|
* "done": DONE, // work already done
|
|
* "indefinite": INDEFINITE // indefinite value of work constant
|
|
* }
|
|
*/
|
|
void report_progress(const std::string& json);
|
|
|
|
/**
|
|
* Report provider event.
|
|
* {
|
|
* "status": "Status string",
|
|
* "message": "Message from the provider"
|
|
* }
|
|
*/
|
|
void report_event(const std::string& json);
|
|
|
|
enum log_level
|
|
{
|
|
error,
|
|
warning
|
|
};
|
|
|
|
// undefined timestamp value
|
|
static double constexpr undefined = 0.0;
|
|
|
|
void report_log_msg(log_level, const std::string& msg,
|
|
double timestamp = undefined);
|
|
|
|
private:
|
|
enum substates {
|
|
s_disconnected_disconnected,
|
|
s_disconnected_initializing,
|
|
s_disconnected_initialized,
|
|
s_connected_waiting, // to become joiner
|
|
s_joining_initialized,
|
|
s_joining_sst,
|
|
s_joining_initializing,
|
|
s_joining_ist,
|
|
s_joined_syncing,
|
|
s_synced_running,
|
|
s_donor_sending,
|
|
s_disconnecting_disconnecting,
|
|
substates_max
|
|
};
|
|
|
|
wsrep::mutex& mutex_;
|
|
std::string const file_name_;
|
|
std::string progress_;
|
|
char* template_;
|
|
substates state_;
|
|
bool initialized_;
|
|
|
|
typedef struct {
|
|
double tstamp;
|
|
std::string msg;
|
|
} log_msg_t ;
|
|
|
|
std::deque<log_msg_t> err_msg_;
|
|
std::deque<log_msg_t> warn_msg_;
|
|
std::deque<log_msg_t> events_;
|
|
size_t const max_msg_;
|
|
|
|
static void write_log_msg(std::ostream& os,
|
|
const log_msg_t& msg);
|
|
static void write_event(std::ostream& os,
|
|
const log_msg_t& msg);
|
|
static void write_array(std::ostream& os, const std::string& label,
|
|
const std::deque<log_msg_t>& events,
|
|
void (*element_writer)(std::ostream& os,
|
|
const log_msg_t& msg));
|
|
substates substate_map(enum server_state::state state);
|
|
float progress_map(float progress) const;
|
|
void write_file(double timestamp);
|
|
|
|
// make uncopyable
|
|
reporter(const wsrep::reporter&);
|
|
void operator=(const wsrep::reporter&);
|
|
}; /* reporter */
|
|
|
|
} /* wsrep */
|
|
|
|
#endif /* WSREP_REPORTER_HPP */
|