org.opends.server.replication.server
Class ServerWriter

java.lang.Object
  java.lang.Thread
      org.opends.server.api.DirectoryThread
          org.opends.server.replication.server.ServerWriter

All Implemented Interfaces:

java.lang.Runnable

public class ServerWriter
extends DirectoryThread

This class defines a server writer, which is used to send changes to a directory server.

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

ServerWriter(ProtocolSession session, short serverId, ServerHandler handler, ReplicationServerDomain replicationServerDomain)
Create a ServerWriter.

Method Summary

void	run() Run method for the ServerWriter.

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

getAssociatedTask, getCreationStackTrace, getDebugProperties, getParentThread, setAssociatedTask

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

Constructor Detail

ServerWriter

public ServerWriter(ProtocolSession session,
                    short serverId,
                    ServerHandler handler,
                    ReplicationServerDomain replicationServerDomain)

Create a ServerWriter. Then ServerWriter then waits on the ServerHandler for new updates and forward them to the server

Parameters:

session - the ProtocolSession that will be used to send updates.

serverId - the Identifier of the server.

handler - handler for which the ServerWriter is created.

replicationServerDomain - The ReplicationServerDomain of this ServerWriter.

Method Detail

run

public void run()

Run method for the ServerWriter. Loops waiting for changes from the ReplicationServerDomain and forward them to the other servers

Specified by:

run in interface java.lang.Runnable

Overrides:

run in class java.lang.Thread