Package org.apache.derby.impl.store.replication.slave

Class 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

      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

      • Methods inherited from class java.lang.Object

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

    • Constructor Detail

      • SlaveLogReceiverThread

        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.