org.apache.derby.impl.store.replication.net
Class ReplicationMessageTransmit.MasterReceiverThread

java.lang.Object
  extended by java.lang.Thread
      extended by org.apache.derby.impl.store.replication.net.ReplicationMessageTransmit.MasterReceiverThread
All Implemented Interfaces:
java.lang.Runnable
Enclosing class:
ReplicationMessageTransmit

private class ReplicationMessageTransmit.MasterReceiverThread
extends java.lang.Thread

Thread that listens for messages from the slave. A separate thread listening for messages from the slave is needed because the slave may send messages to the master at any time, and these messages require immediate action.


Nested Class Summary
 
Nested classes/interfaces inherited from class java.lang.Thread
java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler
 
Field Summary
private  ReplicationMessage pongMsg
           
 
Fields inherited from class java.lang.Thread
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
 
Constructor Summary
ReplicationMessageTransmit.MasterReceiverThread(java.lang.String dbname)
           
 
Method Summary
private  ReplicationMessage readMessage()
          Used to read a replication message sent by the slave.
 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
 

Field Detail

pongMsg

private final ReplicationMessage pongMsg
Constructor Detail

ReplicationMessageTransmit.MasterReceiverThread

ReplicationMessageTransmit.MasterReceiverThread(java.lang.String dbname)
Method Detail

run

public void run()
Specified by:
run in interface java.lang.Runnable
Overrides:
run in class java.lang.Thread

readMessage

private ReplicationMessage readMessage()
                                throws java.lang.ClassNotFoundException,
                                       java.io.IOException
Used to read a replication message sent by the slave. Hangs until a message is received from the slave

Returns:
the reply message.
Throws:
java.lang.ClassNotFoundException - Class of a serialized object cannot be found.
java.io.IOException - 1) if an exception occurs while reading from the stream. 2) if the connection handle is invalid.

Built on Thu 2012-03-29 21:53:33+0000, from revision ???

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