Package org.opends.server.replication.server

Class ServerReader

java.lang.Object

java.lang.Thread

org.opends.server.api.DirectoryThread

org.opends.server.replication.server.ServerReader

All Implemented Interfaces:

Runnable

public class ServerReader
extends DirectoryThread

This class implement the part of the replicationServer that is reading the connection from the LDAP servers to get all the updates that were done on this replica and forward them to other servers. A single thread is dedicated to this work. It waits in a blocking mode on the connection from the LDAP server and upon receiving an update puts in into the replicationServer cache from where the other servers will grab it.

Nested Class Summary

Nested classes/interfaces inherited from class org.opends.server.api.DirectoryThread

DirectoryThread.Factory

Nested classes/interfaces inherited from class java.lang.Thread

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields inherited from class org.opends.server.api.DirectoryThread

DIRECTORY_THREAD_GROUP

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor	Description
ServerReader(Session session, ServerHandler handler)	Constructor for the LDAP server reader part of the replicationServer.

Method Summary

Modifier and Type	Method	Description
void	run()	Create a loop that reads changes and hands them off to be processed.

Methods inherited from class org.opends.server.api.DirectoryThread

getAssociatedTask, getCreationStackTrace, getDebugProperties, getParentThread, initiateShutdown, isShutdownInitiated, setAssociatedTask, startWork, stopWork

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

ServerReader

public ServerReader(Session session,
                    ServerHandler handler)

Constructor for the LDAP server reader part of the replicationServer.

Parameters:

session - The Session from which to read the data.

handler - The server handler for this server reader.

Method Detail

run

public void run()

Create a loop that reads changes and hands them off to be processed.

Specified by:

run in interface Runnable

Overrides:

run in class Thread