Class ReplicationMessageTransmit.MasterReceiverThread

java.lang.Object

java.lang.Thread

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

All Implemented Interfaces:

Runnable

Enclosing class:

ReplicationMessageTransmit

private class ReplicationMessageTransmit.MasterReceiverThread
extends 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 Thread

Thread.Builder, Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field	Description
private final ReplicationMessage	pongMsg

Fields inherited from class Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor	Description
MasterReceiverThread(String dbname)

Method Summary

Modifier and Type	Method	Description
private ReplicationMessage	readMessage()	Used to read a replication message sent by the slave.
void	run()

Methods inherited from class Thread

activeCount, checkAccess, clone, currentThread, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, isVirtual, join, join, join, join, ofPlatform, ofVirtual, onSpinWait, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, sleep, start, startVirtualThread, stop, threadId, toString, yield

Methods inherited from class Object

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

Field Details

pongMsg

private final ReplicationMessage pongMsg

Constructor Details

MasterReceiverThread

MasterReceiverThread(String dbname)

Method Details

run

public void run()

Specified by:

run in interface Runnable

Overrides:

run in class Thread

readMessage

private ReplicationMessage readMessage()
                                throws ClassNotFoundException,
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:

ClassNotFoundException - Class of a serialized object cannot be found.

IOException - 1) if an exception occurs while reading from the stream. 2) if the connection handle is invalid.