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

Class Replicant

Direct Known Subclasses:
ReplicantServer

public abstract class Replicant

Author:

dpetroni

Abstract.

Links:

Kernel Association Association Link

to Class ReplicationStrategy

Associates type:

association

Client cardinality:

Client navigability:

NOT NAVIGABLE

Client visibility:

private

Supplier cardinality:

Supplier navigability:

NAVIGABLE

Supplier visibility:

private

Kernel Association Association Link

to Interface ReplicationTarget

Associates type:

aggregation

Client cardinality:

Client navigability:

NOT NAVIGABLE

Client visibility:

private

Directed.

Supplier cardinality:

Supplier navigability:

NAVIGABLE

Supplier visibility:

private

Custom properties

link:

aggregation

Nested Class Summary
protected class	Replicant.DirtyBacklogCleaner

Field Summary
ReplicationTarget	replicationTarget
ReplicationStrategy	replicationStrategy
long	replicantId
String	serviceName
long	serverReplicantId
private HashMap	activeClients
final static String	className
private HashMap	clients
private boolean	immediateActivation
final static Logger	logger
private long	replicantId
private int	replicatedId
protected ConcurrentHashMap	replicatedObjects
private ReplicationStrategy	replicationStrategy
private ReplicationTarget	replicationTarget
private long	serverReplicantId
private String	serviceName

Constructor Summary
protected void	Replicant()

Method Summary
protected final void	activate(Long clientReplicantId)
protected final void	activate(Long clientReplicantId, Integer capsuleId)
protected final void	addActive(Replicated obj)
protected final void	addClient(Long clientReplicantId)
protected abstract void	addReplicatedObject(Replicated obj)
protected void	clearDirtyBacklog()
public void	run()
protected void	dirtyContents()
public long	getReplicantId()
public ReplicationStrategy	getReplicationStrategy()
public ReplicationTarget	getReplicationTarget()
public long	getServerReplicantId()
public String	getServiceName()
protected final void	removeActive(Replicated obj)
protected abstract void	removeReplicatedObject(Replicated obj)
protected final void	replicate(Replicated source)
public void	setReplicantId(Long id)
public void	setReplicationStrategy(ReplicationStrategy replicationStrategy)
public void	setReplicationTarget(ReplicationTarget replicationTarget)
public void	setServerReplicantId(Long serverReplicantId)
public void	setServiceName(String serviceName)
protected final void	update(Capsule newState)

Field Detail

activeClients

private HashMap activeClients

Multiplicity:

Custom properties

associates:

com.newstep.replication.Replicated

className

final static String className

Final.

Multiplicity:

Static.

clients

private HashMap clients

Multiplicity:

Custom properties

associates:

com.newstep.solid.test.replication.Capsule

immediateActivation

private boolean immediateActivation

Multiplicity:

logger

final static Logger logger

Final.

Multiplicity:

Static.

replicantId

long replicantId

replicantId

private long replicantId

Multiplicity:

replicatedId

private int replicatedId

Multiplicity:

replicatedObjects

protected ConcurrentHashMap replicatedObjects

Multiplicity:

replicationStrategy

ReplicationStrategy replicationStrategy

replicationStrategy

private ReplicationStrategy replicationStrategy

Multiplicity:

replicationTarget

ReplicationTarget replicationTarget

replicationTarget

private ReplicationTarget replicationTarget

Multiplicity:

serverReplicantId

private long serverReplicantId

Multiplicity:

serverReplicantId

long serverReplicantId

serviceName

private String serviceName

Multiplicity:

serviceName

String serviceName

Constructor Detail

Replicant

protected void Replicant ()

Stereotype:

create

Method Detail

activate

protected final void activate (Long clientReplicantId)

Activate all replicated objects originating from the remote replicant
idenfied by its id. This is invoked when the remote replicant fails and
this replicant is instructed to take over

Parameters:

clientReplicantId

Final.

activate

protected final void activate (Long clientReplicantId, Integer capsuleId)

Activate a single replicated object

Parameters:

clientReplicantId
capsuleId

Final.

addActive

protected final void addActive (Replicated obj)

Final.

addClient

protected final void addClient (Long clientReplicantId)

Final.

addReplicatedObject

protected abstract void addReplicatedObject (Replicated obj)

Abstract.

clearDirtyBacklog

protected void clearDirtyBacklog ()

dirtyContents

protected void dirtyContents ()

getReplicantId

public long getReplicantId ()

IMPORTANT: replicant ids are longs consisting of the replicator id in the
upper 32 bits and a unique integer in the lower 32 bits

Return:

Returns the replicantId.

getReplicationStrategy

public ReplicationStrategy getReplicationStrategy ()

getReplicationTarget

public ReplicationTarget getReplicationTarget ()

getServerReplicantId

public long getServerReplicantId ()

getServiceName

public String getServiceName ()

Get the unique name of the service this replicant provides. This name is
used when advertising or requesting for replication

Return:

Returns the serviceName.

removeActive

protected final void removeActive (Replicated obj)

Final.

removeReplicatedObject

protected abstract void removeReplicatedObject (Replicated obj)

Abstract.

replicate

protected final void replicate (Replicated source)

Parameters:

source

Final.

setReplicantId

public void setReplicantId (Long id)

IMPORTANT: replicant ids are longs consisting of the replicator id in the
upper 32 bits and a unique integer in the lower 32 bits

This operation is ment to be invoked only from the Replicator. Only
replicator can determine the proper id for the replicant

Parameters:

setReplicationStrategy

public void setReplicationStrategy (ReplicationStrategy replicationStrategy)

setReplicationTarget

public void setReplicationTarget (ReplicationTarget replicationTarget)

setServerReplicantId

public void setServerReplicantId (Long serverReplicantId)

setServiceName

public void setServiceName (String serviceName)

Set the unique name of the service this replicant provides. This name
will be used when advertising or requesting for replication

Parameters:

serviceName
The serviceName to set.