Class

Tree

Deprecated

Index

Help

PREV CLASS NEXT CLASS

FRAMES NO FRAMES

SUMMARY: INNER | FIELD | CONSTR | METHOD

DETAIL: FIELD | CONSTR | METHOD

com.newstep.solid.replication

All Implemented Interfaces:
ReplicationMessageListener

public class Replicator

Replicator handles communication between nodes particpating in a "replication cluster". It provides brokering of
replication services and establishes and maintanis the replication structure. There is only one replicator per
replication node and each replicant residing on the node must register with the replicator in order to participate in
the "replication cluster".

ReplicationMessageListener

Kernel Association Association Link

Client navigability:

Supplier cardinality:

Supplier navigability:

Supplier visibility:

Kernel Association Association Link

Client navigability:

Supplier cardinality:

Supplier navigability:

Supplier visibility:

com.newstep.solid.replication.ReplicationPeer

Kernel Association Association Link

to Class AccessPoint

Client navigability:

Supplier cardinality:

Supplier navigability:

Supplier visibility:

Kernel Association Association Link

Client navigability:

Supplier cardinality:

Supplier navigability:

Supplier visibility:

Implementation Implementation Link

Field Summary
String	replicatorName
private AccessPoint	cap
private String	channelAccessPointFactoryName
private final static String	className
private boolean	initialized
private String	localAddressString
private ChannelEndpoint	localEndpoint
protected static Logger	logger
protected LinkedBlockingQueue	messageQueue
private HashMap	peers
Replicant	replicant
ReplicationRequest	request
List	responses
protected boolean	processMessages
private int	replicantIds
private HashMap	replicants
private Thread	replicationMessageProcessor
private ReplicationService	replicationService
private int	replicatorId
private String	replicatorName
private HashMap	requests
private Timer	timer

Constructor Summary
void	PendingRequest(Replicant rep, ReplicationRequest req)
protected void	Replicator(ReplicationService repService)

Method Summary
protected synchronized void	addPendingRequest(Replicant replicant, ReplicationRequest request)
private void	addPendingRequest(Replicant replicant)
protected void	checkResponses(Replicator.PendingRequest pr)
protected synchronized long	deregisterReplicant(Replicant replicant)
public int	getReplicationClientId()
public String	getReplicatorName()
private void	handleFailedPeer(Integer peerId)
protected void	initialize(ReplicatorConfig config)
public void	onMessage(ReplicationMessage message)
public void	peerUnreachable(ReplicationPeer peer)
void	addResponse(ReplicationResponse resp)
ReplicationResponse	getResponses()
protected synchronized void	processMessage(ReplicationMessage message)
protected synchronized long	registerReplicant(Replicant replicant)
private ReplicationResponse	selectResponse(Replicator.PendingRequest pr)
public void	setReplicatorName(String replicatorName)
public void	start()
private synchronized boolean	startReplication(Replicant replicant, ReplicationResponse response)
private void	startReplicationMessageProcessor()
public void	stop()
private void	stopReplicationMessageProcessor()

private AccessPoint cap

channelAccessPointFactoryName

private String channelAccessPointFactoryName

private final static String className

private boolean initialized

private String localAddressString

private ChannelEndpoint localEndpoint

protected static Logger logger

protected LinkedBlockingQueue messageQueue

private HashMap peers

com.newstep.solid.replication.ReplicationPeer

protected boolean processMessages

private int replicantIds

private HashMap replicants

com.newstep.replication.Replicant

replicationMessageProcessor

private Thread replicationMessageProcessor

private ReplicationService replicationService

private int replicatorId

String replicatorName

private String replicatorName

private HashMap requests

protected void Replicator (ReplicationService repService)

private void addPendingRequest (Replicant replicant)

protected synchronized void addPendingRequest (Replicant replicant, ReplicationRequest request)

protected void checkResponses (Replicator.PendingRequest pr)

protected synchronized long deregisterReplicant (Replicant replicant)

Stops client replicants and ends replication service provided by server replicants. As a side effect, removes the
replication peer associated with the repliacnt if there are neither server nor client replicants remaining
associated with the peer.

replicant
to be deregistered

the id of the deregistered replicant

getReplicationClientId

public int getReplicationClientId ()

public String getReplicatorName ()

private void handleFailedPeer (Integer peerId)

protected void initialize (ReplicatorConfig config)

It is intended that initialize is invoked during the ReplicationService startup. Actual users of this class
should never bother with the initalization. Multiple invocations of initialize have no effect

config
Configuration holding all the necessary parameters

ConfigurationException

public void onMessage (ReplicationMessage message)

public void peerUnreachable (ReplicationPeer peer)

protected synchronized void processMessage (ReplicationMessage message)

protected synchronized long registerReplicant (Replicant replicant)

Replicants have to be registered with the Replicator in order to offer or take advantage of replication services.
Each replicant is instantiated and given its copy of the replication strategy by the management/config subsystem.

replicant
to be registered with the Replicator

the unique id of the newly registered replicant