com.oy.shared.lw.samples.mysqlrepl.impl
Class MySqlReplThread

java.lang.Object
  java.lang.Thread
      com.oy.shared.lw.misc.PoliteThread
          com.oy.shared.lw.samples.mysqlrepl.impl.MySqlReplThread

All Implemented Interfaces:

java.lang.Runnable

public class MySqlReplThread

extends PoliteThread

Field Summary

private MySqlReplCmd	cmd
private MySqlReplContext	ctx
private long	lastPurgeTick
private MySqlReplStatusMonitor	monitor
private java.util.Random	rand
private ITrace	trace
private int	uid

Fields inherited from class com.oy.shared.lw.misc.PoliteThread

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

MySqlReplThread(ITrace trace, MySqlReplContext ctx, MySqlReplStatusMonitor monitor, MySqlReplCmd cmd)

Method Summary

private MySqlReplDbStatus	getSlaveStatus(MySqlReplDbStatus masterStatus)
private MySqlReplDbStatus	incMasterStatus()
private void	purgeMasterBinLogs(MySqlReplDbStatus slaveStatus)
void	run()
private void	waitForReplicationToWork()

Methods inherited from class com.oy.shared.lw.misc.PoliteThread

isTerminated, terminate

Methods inherited from class java.lang.Thread

activeCount, checkAccess, countStackFrames, currentThread, destroy, dumpStack, enumerate, getContextClassLoader, getName, getPriority, getThreadGroup, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setName, setPriority, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

lastPurgeTick

private long lastPurgeTick

trace

private ITrace trace

ctx

private MySqlReplContext ctx

monitor

private MySqlReplStatusMonitor monitor

cmd

private MySqlReplCmd cmd

rand

private java.util.Random rand

uid

private int uid

Constructor Detail

MySqlReplThread

public MySqlReplThread(ITrace trace,
                       MySqlReplContext ctx,
                       MySqlReplStatusMonitor monitor,
                       MySqlReplCmd cmd)

Method Detail

run

public void run()

Specified by:

run in interface java.lang.Runnable

Specified by:

run in class PoliteThread

incMasterStatus

private MySqlReplDbStatus incMasterStatus()

waitForReplicationToWork

private void waitForReplicationToWork()

getSlaveStatus

private MySqlReplDbStatus getSlaveStatus(MySqlReplDbStatus masterStatus)

purgeMasterBinLogs

private void purgeMasterBinLogs(MySqlReplDbStatus slaveStatus)