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

Merge branch '2.3' into develop

Browse Source
This commit is contained in:
Markus Mäkelä
2019-01-07 10:52:07 +02:00
parent cf9ac9004e 0859f3caff
commit f0f9c21d1c
67 changed files with 777 additions and 469 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
server/modules/routing/readwritesplit/readwritesplit.cc
View File

@ -106,9 +106,9 @@ const Stats& RWSplit::stats() const
return m_stats;
}
ServerStats& RWSplit::server_stats(SERVER* server)
SrvStatMap& RWSplit::local_server_stats()
{
return (*m_server_stats)[server];
return *m_server_stats;
}
maxscale::SrvStatMap RWSplit::all_server_stats() const

2
server/modules/routing/readwritesplit/readwritesplit.hh
View File

@ -261,7 +261,7 @@ public:
const Config& config() const;
Stats& stats();
const Stats& stats() const;
ServerStats& server_stats(SERVER* server);
SrvStatMap& local_server_stats();
SrvStatMap all_server_stats() const;
int max_slave_count() const;

38
server/modules/routing/readwritesplit/rwsplit_route_stmt.cc
View File

@ -41,23 +41,25 @@ void RWSplitSession::handle_connection_keepalive(RWBackend* target)
mxb_assert(target);
MXB_AT_DEBUG(int nserv = 0);
/** Each heartbeat is 1/10th of a second */
int keepalive = m_config.connection_keepalive * 10;
int64_t keepalive = m_config.connection_keepalive * 10;
int64_t now = mxs_clock();
for (auto it = m_raw_backends.begin(); it != m_raw_backends.end(); it++)
if (now - m_last_keepalive_check > keepalive)
{
RWBackend* backend = *it;
if (backend->in_use() && backend != target && !backend->is_waiting_result())
for (const auto& backend : m_raw_backends)
{
MXB_AT_DEBUG(nserv++);
int diff = mxs_clock() - backend->dcb()->last_read;
if (diff > keepalive)
if (backend->in_use() && backend != target && !backend->is_waiting_result())
{
MXS_INFO("Pinging %s, idle for %ld seconds",
backend->name(),
MXS_CLOCK_TO_SEC(diff));
modutil_ignorable_ping(backend->dcb());
MXB_AT_DEBUG(nserv++);
int64_t diff = now - backend->dcb()->last_read;
if (diff > keepalive)
{
MXS_INFO("Pinging %s, idle for %ld seconds",
backend->name(),
MXS_CLOCK_TO_SEC(diff));
modutil_ignorable_ping(backend->dcb());
}
}
}
}
@ -473,8 +475,8 @@ bool RWSplitSession::route_session_write(GWBUF* querybuf, uint8_t command, uint3
{
nsucc += 1;
mxb::atomic::add(&backend->server()->stats.packets, 1, mxb::atomic::RELAXED);
m_router->server_stats(backend->server()).total++;
m_router->server_stats(backend->server()).read++;
m_server_stats[backend->server()].total++;
m_server_stats[backend->server()].read++;
if (expecting_response)
{
@ -849,7 +851,7 @@ RWBackend* RWSplitSession::handle_slave_is_target(uint8_t cmd, uint32_t stmt_id)
if (target)
{
mxb::atomic::add(&m_router->stats().n_slave, 1, mxb::atomic::RELAXED);
m_router->server_stats(target->server()).read++;
m_server_stats[target->server()].read++;
mxb_assert(target->in_use() || target->can_connect());
}
else
@ -986,7 +988,7 @@ bool RWSplitSession::handle_master_is_target(RWBackend** dest)
if (target && target == m_current_master)
{
mxb::atomic::add(&m_router->stats().n_master, 1, mxb::atomic::RELAXED);
m_router->server_stats(target->server()).write++;
m_server_stats[target->server()].write++;
}
else
{
@ -1166,7 +1168,7 @@ bool RWSplitSession::handle_got_target(GWBUF* querybuf, RWBackend* target, bool
mxb::atomic::add(&m_router->stats().n_queries, 1, mxb::atomic::RELAXED);
mxb::atomic::add(&target->server()->stats.packets, 1, mxb::atomic::RELAXED);
m_router->server_stats(target->server()).total++;
m_server_stats[target->server()].total++;
if (!m_qc.large_query() && response == mxs::Backend::EXPECT_RESPONSE)
{

14
server/modules/routing/readwritesplit/rwsplitsession.cc
View File

@ -17,6 +17,7 @@
#include <maxscale/modutil.hh>
#include <maxscale/poll.hh>
#include <maxscale/clock.h>
using namespace maxscale;
@ -29,11 +30,11 @@ RWSplitSession::RWSplitSession(RWSplit* instance,
, m_raw_backends(sptr_vec_to_ptr_vec(m_backends))
, m_current_master(master)
, m_config(instance->config())
, m_last_keepalive_check(mxs_clock())
, m_nbackends(instance->service()->n_dbref)
, m_client(session->client_dcb)
, m_sescmd_count(1)
, // Needs to be a positive number to work
m_expected_responses(0)
, m_expected_responses(0)
, m_query_queue(NULL)
, m_router(instance)
, m_sent_sescmd(0)
@ -45,6 +46,7 @@ RWSplitSession::RWSplitSession(RWSplit* instance,
, m_retry_duration(0)
, m_is_replay_active(false)
, m_can_replay_trx(true)
, m_server_stats(instance->local_server_stats())
{
if (m_config.rw_max_slave_conn_percent)
{
@ -86,7 +88,7 @@ RWSplitSession* RWSplitSession::create(RWSplit* router, MXS_SESSION* session)
for (auto& b : backends)
{
router->server_stats(b->server()).start_session();
rses->m_server_stats[b->server()].start_session();
}
}
}
@ -124,9 +126,9 @@ void RWSplitSession::close()
}
backend->response_stat().reset();
m_router->server_stats(backend->server()).end_session(backend->session_timer().split(),
backend->select_timer().total(),
backend->num_selects());
m_server_stats[backend->server()].end_session(backend->session_timer().split(),
backend->select_timer().total(),
backend->num_selects());
}
}

5
server/modules/routing/readwritesplit/rwsplitsession.hh
View File

@ -274,6 +274,7 @@ private:
mxs::RWBackend* m_target_node; /**< The currently locked target node */
mxs::RWBackend* m_prev_target; /**< The previous target where a query was sent */
Config m_config; /**< Configuration for this session */
int m_last_keepalive_check; /**< When the last ping was done */
int m_nbackends; /**< Number of backend servers (obsolete) */
DCB* m_client; /**< The client DCB */
uint64_t m_sescmd_count; /**< Number of executed session commands */
@ -305,6 +306,10 @@ private:
mxs::Buffer m_orig_stmt; /**< The backup of the statement that was interrupted */
otrx_state m_otrx_state = OTRX_INACTIVE; /**< Optimistic trx state*/
SrvStatMap& m_server_stats; /**< The server stats local to this thread, cached in the session object.
* This avoids the lookup involved in getting the worker-local value from
* the worker's container.*/
};
/**