Class SlaveController.SlaveLogReceiverThread
- java.lang.Object
-
- java.lang.Thread
-
- org.apache.derby.impl.store.replication.slave.SlaveController.SlaveLogReceiverThread
-
- All Implemented Interfaces:
java.lang.Runnable
- Enclosing class:
- SlaveController
private class SlaveController.SlaveLogReceiverThread extends java.lang.Thread
Thread that listens for incoming messages from the master and applies chunks of log records to the local log files.
-
-
Constructor Summary
Constructors Constructor Description SlaveLogReceiverThread()
Creates a new instance of SlaveLogReceiverThread with a debugging-friendly thread name.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description private void
handleLogChunk(byte[] logChunk)
Parses a chunk of log received from the master, and applies the individual log records to the local log file.void
run()
-
Methods inherited from class java.lang.Thread
activeCount, checkAccess, clone, countStackFrames, currentThread, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, onSpinWait, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, suspend, toString, yield
-
-
-
-
Method Detail
-
run
public void run()
- Specified by:
run
in interfacejava.lang.Runnable
- Overrides:
run
in classjava.lang.Thread
-
handleLogChunk
private void handleLogChunk(byte[] logChunk) throws StandardException
Parses a chunk of log received from the master, and applies the individual log records to the local log file.- Parameters:
logChunk
- A chunk of log records received from the master- Throws:
StandardException
- If the chunk of log records could not be parsed or the local log file is out of synch with the master log file.
-
-