Class SlaveController.SlaveLogReceiverThread

java.lang.Object
java.lang.Thread
org.apache.derby.impl.store.replication.slave.SlaveController.SlaveLogReceiverThread
All Implemented Interfaces:
Runnable
Enclosing class:
SlaveController

private class SlaveController.SlaveLogReceiverThread extends Thread
Thread that listens for incoming messages from the master and applies chunks of log records to the local log files.
  • Constructor Details

    • SlaveLogReceiverThread

      SlaveLogReceiverThread()
      Creates a new instance of SlaveLogReceiverThread with a debugging-friendly thread name.
  • Method Details

    • run

      public void run()
      Specified by:
      run in interface Runnable
      Overrides:
      run in class 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.