org.apache.derby.impl.store.replication.slave
Class SlaveController.SlaveLogReceiverThread

java.lang.Object
  extended by java.lang.Thread
      extended by 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, 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
clone, 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.

Built on Thu 2010-12-23 20:49:13+0000, from revision ???

Apache Derby V10.6 Internals - Copyright © 2004,2007 The Apache Software Foundation. All Rights Reserved.