org.apache.derby.impl.store.replication.slave
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.

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler

Field Summary

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

SlaveController.SlaveLogReceiverThread()
Creates a new instance of SlaveLogReceiverThread with a debugging-friendly thread name.

Method Summary

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, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Constructor Detail

SlaveController.SlaveLogReceiverThread

SlaveController.SlaveLogReceiverThread()

Creates a new instance of SlaveLogReceiverThread with a debugging-friendly thread name.

Method Detail

run

public void run()

Specified by:

run in interface java.lang.Runnable

Overrides:

run in class java.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.