Package org.opends.server.replication.protocol

Class ReplServerStartDSMsg

java.lang.Object

org.opends.server.replication.protocol.ReplicationMsg

org.opends.server.replication.protocol.StartMsg

org.opends.server.replication.protocol.ReplServerStartDSMsg

public final class ReplServerStartDSMsg
extends StartMsg

Message sent by a replication server to a directory server in reply to the ServerStartMsg.

Field Summary

Fields inherited from class org.opends.server.replication.protocol.StartMsg

generationId, groupId, MAX_WINDOW_SIZE, protocolVersion

Fields inherited from class org.opends.server.replication.protocol.ReplicationMsg

COMPACT_MASK, COMPACT_TYPE_ADD, COMPACT_TYPE_DELETE, COMPACT_TYPE_MODIFY, COMPACT_TYPE_MODIFY_DN, COMPACT_TYPE_REPLICA_OFFLINE, MSG_TYPE_DISK_ENCODING

Constructor Summary

Constructors

Constructor	Description
ReplServerStartDSMsg(ReplicationServerId rsId, com.forgerock.opendj.util.HostPort changelogEndpoint, Dn baseDN, ServerState serverState, GenerationId generationId, boolean sslEncryption, com.forgerock.opendj.discovery.GroupId groupId, int weight, int connectedDSNumber)	Create a ReplServerStartDSMsg.

Method Summary

Modifier and Type	Method	Description
Dn	getBaseDN()	Get the base DN from this ReplServerStartDSMsg.
byte[]	getBytes(short protocolVersion)	Serializes the PDU using the provided replication protocol version.
int	getConnectedDSNumber()	Gets the number of directory servers connected to the replication server.
int	getDegradedStatusThreshold()	Get the degraded status threshold value.
ReplicationServerId	getServerId()	Get the Server Id.
ServerState	getServerState()	Get the serverState.
boolean	getSSLEncryption()	Get the SSL encryption value for the server that created the message.
int	getWeight()	Gets the weight of the replication server.
String	toString()

Methods inherited from class org.opends.server.replication.protocol.StartMsg

getGenerationId, getGroupId, getVersion, setGroupId

Methods inherited from class org.opends.server.replication.protocol.ReplicationMsg

decodeMsg, isRetryable

Methods inherited from class java.lang.Object

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

Constructor Details

ReplServerStartDSMsg

public ReplServerStartDSMsg(ReplicationServerId rsId,
 com.forgerock.opendj.util.HostPort changelogEndpoint,
 Dn baseDN,
 ServerState serverState,
 GenerationId generationId,
 boolean sslEncryption,
 com.forgerock.opendj.discovery.GroupId groupId,
 int weight,
 int connectedDSNumber)

Create a ReplServerStartDSMsg.

Parameters:

rsId - replication server id

changelogEndpoint - replication server host port

baseDN - base DN for which the ReplServerStartDSMsg is created.

serverState - our ServerState for this baseDN.

generationId - The generationId for this server.

sslEncryption - Whether to continue using SSL to encrypt messages after the start messages have been exchanged.

groupId - The group id of the RS

weight - The weight affected to the replication server.

connectedDSNumber - Number of currently connected DS to the replication server.

Method Details

getServerId

public ReplicationServerId getServerId()

Get the Server Id.

Returns:

the server id

getBaseDN

public Dn getBaseDN()

Get the base DN from this ReplServerStartDSMsg.

Returns:

the base DN from this ReplServerStartDSMsg.

getServerState

public ServerState getServerState()

Get the serverState.

Returns:

Returns the serverState.

getBytes

public byte[] getBytes(short protocolVersion)

Description copied from class: ReplicationMsg

Serializes the PDU using the provided replication protocol version. WARNING: should be overwritten by a PDU (sub class) we want to support older protocol version serialization for.

Specified by:

getBytes in class ReplicationMsg

Parameters:

protocolVersion - The protocol version to use for serialization. The version should normally be older than the current one.

Returns:

The encoded PDU, or null if the message isn't supported in that protocol version.

getSSLEncryption

public boolean getSSLEncryption()

Get the SSL encryption value for the server that created the message.

Returns:

The SSL encryption value for the server that created the message.

getDegradedStatusThreshold

public int getDegradedStatusThreshold()

Get the degraded status threshold value.

Returns:

The degraded status threshold value.

toString

public String toString()

Overrides:

toString in class Object

getWeight

public int getWeight()

Gets the weight of the replication server.

Returns:

The weight of the replication server.

getConnectedDSNumber

public int getConnectedDSNumber()

Gets the number of directory servers connected to the replication server.

Returns:

The number of directory servers connected to the replication server.