public class MastersSlavesListener extends AbstractMastersSlavesListener
Modifier and Type | Field and Description |
---|---|
private static DynamicSizedSchedulerInterface |
dynamicSizedScheduler |
private static java.util.concurrent.atomic.AtomicInteger |
listenerCount |
private static Logger |
logger |
protected Protocol |
masterProtocol |
protected Protocol |
secondaryProtocol |
waitNewMasterProtocol, waitNewSecondaryProtocol
currentConnectionAttempts, currentProtocol, currentReadOnlyAsked, explicitClosed, lastQueryNanos, lastRetry, proxy, urlParser
Constructor and Description |
---|
MastersSlavesListener(UrlParser urlParser)
Initialisation.
|
Modifier and Type | Method and Description |
---|---|
private void |
blackListAndCloseConnection(Protocol protocol) |
protected void |
checkInitialConnection(java.sql.SQLException queryException) |
boolean |
checkMasterStatus(SearchFilter searchFilter)
Check master status.
|
void |
checkWaitingConnection()
Verify that there is waiting connection that have to replace failing one.
|
void |
foundActiveMaster(Protocol newMasterProtocol)
Method called when a new Master connection is found after a fallback.
|
void |
foundActiveSecondary(Protocol newSecondaryProtocol)
Method called when a new secondary connection is found after a fallback.
|
void |
handleFailLoop() |
void |
initializeConnection()
Initialize connections.
|
boolean |
isMasterConnected() |
void |
lockAndSwitchMaster(Protocol newMasterProtocol)
Use the parameter newMasterProtocol as new current master connection.
|
void |
lockAndSwitchSecondary(Protocol newSecondaryProtocol)
Use the parameter newSecondaryProtocol as new current secondary connection.
|
private boolean |
pingSecondaryProtocol(Protocol protocol)
Ping secondary protocol.
|
void |
preClose()
Called after a call on Connection.close().
|
void |
preExecute() |
HandleErrorResult |
primaryFail(java.lang.reflect.Method method,
java.lang.Object[] args)
To handle the newly detected failover on the master connection.
|
void |
reconnect()
Reconnect failed connection.
|
void |
reconnectFailedConnection(SearchFilter searchFilter)
Loop to connect.
|
protected void |
removeListenerFromSchedulers() |
void |
rePrepareOnSlave(ServerPrepareResult oldServerPrepareResult,
boolean mustBeOnMaster) |
HandleErrorResult |
secondaryFail(java.lang.reflect.Method method,
java.lang.Object[] args)
To handle the newly detected failover on the secondary connection.
|
void |
switchReadOnlyConnection(java.lang.Boolean mustBeReadOnly)
Switch to a read-only(secondary) or read and write connection(master).
|
getFilterForFailedHost, getSecondaryHostFailNanos, handleFailover, hasHostFail, isMasterHostFailReconnect, isSecondaryHostFail, isSecondaryHostFailReconnect, resetMasterFailoverData, resetSecondaryFailoverData, setSecondaryHostFail
addToBlacklist, canRetryFailLoop, clearBlacklist, closeConnection, getBlacklistKeys, getCurrentProtocol, getLastQueryNanos, getMasterHostFailNanos, getProxy, getRetriesAllDown, getUrlParser, invoke, invoke, isAutoReconnect, isClosed, isExplicitClosed, isMasterHostFail, isQueryRelaunchable, isReadOnly, pingMasterProtocol, preAutoReconnect, relaunchOperation, removeFromBlacklist, resetOldsBlackListHosts, setMasterHostFail, setProxy, setSessionReadOnly, syncConnection, throwFailoverMessage
private static final DynamicSizedSchedulerInterface dynamicSizedScheduler
private static final java.util.concurrent.atomic.AtomicInteger listenerCount
private static Logger logger
protected Protocol masterProtocol
protected Protocol secondaryProtocol
public MastersSlavesListener(UrlParser urlParser)
urlParser
- connection string object.protected void removeListenerFromSchedulers()
removeListenerFromSchedulers
in class AbstractMastersListener
public void initializeConnection() throws java.sql.SQLException
initializeConnection
in interface Listener
initializeConnection
in class AbstractMastersListener
java.sql.SQLException
- if a connection error append.protected void checkInitialConnection(java.sql.SQLException queryException) throws java.sql.SQLException
java.sql.SQLException
public void preClose() throws java.sql.SQLException
preClose
in interface Listener
preClose
in class AbstractMastersListener
java.sql.SQLException
- if error append during closing those connections.public void preExecute() throws java.sql.SQLException
preExecute
in interface Listener
preExecute
in class AbstractMastersListener
java.sql.SQLException
public void checkWaitingConnection() throws java.sql.SQLException
java.sql.SQLException
- if error occurpublic void reconnectFailedConnection(SearchFilter searchFilter) throws java.sql.SQLException
reconnectFailedConnection
in interface Listener
reconnectFailedConnection
in class AbstractMastersListener
java.sql.SQLException
- if there is any error during reconnectionpublic void foundActiveMaster(Protocol newMasterProtocol)
newMasterProtocol
- the new active connectionpublic void lockAndSwitchMaster(Protocol newMasterProtocol) throws ReconnectDuringTransactionException
Lock must be set
newMasterProtocol
- new master connectionReconnectDuringTransactionException
- if there was an active transaction.public void foundActiveSecondary(Protocol newSecondaryProtocol) throws java.sql.SQLException
foundActiveSecondary
in class AbstractMastersSlavesListener
newSecondaryProtocol
- the new active connectionjava.sql.SQLException
- if switch failedpublic void lockAndSwitchSecondary(Protocol newSecondaryProtocol) throws java.sql.SQLException
newSecondaryProtocol
- new secondary connectionjava.sql.SQLException
- if an error occur during setting session read-onlypublic void switchReadOnlyConnection(java.lang.Boolean mustBeReadOnly) throws java.sql.SQLException
switchReadOnlyConnection
in interface Listener
switchReadOnlyConnection
in class AbstractMastersListener
mustBeReadOnly
- the read-only status askedjava.sql.SQLException
- if operation hasn't change protocolpublic HandleErrorResult primaryFail(java.lang.reflect.Method method, java.lang.Object[] args) throws java.lang.Throwable
primaryFail
in interface Listener
primaryFail
in class AbstractMastersListener
method
- the initial called methodargs
- the initial argsjava.lang.Throwable
- if failover has not been catchprivate void blackListAndCloseConnection(Protocol protocol)
public void reconnect() throws java.sql.SQLException
reconnect
in interface Listener
reconnect
in class AbstractMastersListener
java.sql.SQLException
- if reconnection has failedprivate boolean pingSecondaryProtocol(Protocol protocol)
protocol
- socket to pingpublic HandleErrorResult secondaryFail(java.lang.reflect.Method method, java.lang.Object[] args) throws java.lang.Throwable
secondaryFail
in class AbstractMastersSlavesListener
method
- the initial called methodargs
- the initial argsjava.lang.Throwable
- if failover has not catch errorpublic void handleFailLoop()
handleFailLoop
in class AbstractMastersListener
public boolean isMasterConnected()
public boolean checkMasterStatus(SearchFilter searchFilter)
checkMasterStatus
in interface Listener
checkMasterStatus
in class AbstractMastersListener
searchFilter
- search filterpublic void rePrepareOnSlave(ServerPrepareResult oldServerPrepareResult, boolean mustBeOnMaster) throws java.sql.SQLException
java.sql.SQLException