LaColla.core.components
Class RA

java.lang.Object
  LaColla.core.components.Compo
      LaColla.core.components.RA

public class RA
extends Compo

Field Summary

Fields inherited from class LaColla.core.components.Compo

purgeSessionPeriodicity, timeRemainingBeforeObjectIsResend

Constructor Summary

RA(int listenPort_, java.util.ArrayList groupIdList, java.lang.String idFilename)

Method Summary

void	connectRA(java.lang.String host, int port, java.lang.String groupId, java.lang.String username, java.lang.String password)
void	connectRA(java.lang.String groupId, java.lang.String username, java.lang.String password)
java.lang.String	createNewGroup(GroupInfo groupInfo, java.util.concurrent.Semaphore sem, InfoConnectedAgent agent)
java.lang.String	createNewGroup(GroupInfo info, java.lang.String newId, java.util.concurrent.Semaphore sem, InfoConnectedAgent agent)
void	disconnectRA(java.lang.String groupId)
void	doAcceptAuthenticationOfParticipant(Msg msg)
void	doDeleteObject(Msg msg)
void	doEventsAcceptConsistencyRequest(Msg msg)
void	doEventsInvokeConsistencyRequest(Msg msg)
void	doEventsInvokeSynchronizationRequest(Msg msg)
void	doGetObject(Msg msg)
void	doNewEvent(Msg msg)
void	doNewGroup(Event evt, java.lang.String username, java.lang.String password)
void	doNewGroup(Msg msg)
void	doNewGroupAck(Msg msg)
void	doNewObject(Msg msg)
void	doPresenceAgentAlive(Msg msg)
void	doPresenceAgentDisconnected(Msg msg)
void	doPurgeSession()
void	doReplicationNewReplica(Msg msg)
void	doServiceEventsConsistency()
void	doServiceNewIteration(Msg msg)
void	doServiceObjectsReplicationChecking()
void	doServiceTimer()
void	doUpdatePresenceInformation(Msg msg)
RA	getRA()
void	msgReplicationAck(Msg msg)
void	request_consistency(java.lang.String address_, java.lang.String host, int port, java.lang.String groupId)
void	start(java.lang.String host, int port, java.lang.String groupId, java.lang.String username, java.lang.String password)

Methods inherited from class LaColla.core.components.Compo

createNewGroup, createNewGroup, decrementConnectedAgentsTimeBeforeBeingDiscarted, decrementConnectedAgentsTimeBeforeBeingDiscarted, doAcceptPresenceConsistencyRequest, doInvokePresenceConsistencyRequest, doPartitionsAcceptConsistencyRequest, doPartitionsAcceptSynchronizationRequest, doPartitionsInvokeConsistencyRequest, doPartitionsInvokeSynchronizationRequest, doPresenceAreYouAlive, doPresenceNewConnectedAgent, doServiceEventsSynchronization, doServicePartitionsChecking, doServicePartitionsConsistency, doServicePartitionsSynchronization, doServicePresenceConsistency, getAddress, getConnecting, getEventsConsistency, getEventsSynchronization, getGroupId, getGroups, getHp, getKindOfAgent, getListenPort, getObjectsReplicationChecking, getOwnerId, getPartitionsChecking, getPartitionsConsistency, getPartitionsSynchronization, getPresenceConsistency, getPurge, getSeqNumGroup, getSequenceNumber, getSequenceNumberInfoAgent, getSequenceNumberObjects, getServiceConnecting, getServiceEventsConsistency, getServiceEventsSynchronization, getServiceObjectsReplicationChecking, getServicePartitionsChecking, getServicePartitionsConsistency, getServicePartitionsSynchronization, getServicePresenceConsistency, getServicePurge, getServiceTimer, getSimulationAgentHp, getSimulationTime, getTime, getTimeBeforeSendingAgentAliveMsg, getTimeRemainingBeforeEventIsResend, getTimeRemainingBeforeObjectIsResend, getTimestampLOCALlocation, goMsg_Dest, isSimulation, presenceConsistencySession, sendEventToConnectedUAandRA, sendToEveryAgent, sendToEveryAgent, setAddress, setConnecting, setEventsConsistency, setEventsSynchronization, setGroupId, setHP, setKindOfAgent, setListenPort, setObjectsReplicationChecking, setOwnerId, setPartitionsChecking, setPartitionsConsistency, setPartitionsSynchronization, setPresenceConsistency, setPurge, setSeqNumGroup, setSequenceNumber, setSequenceNumberInfoAgent, setSequenceNumberObjects, setServiceConnecting, setServiceEventsConsistency, setServiceEventsSynchronization, setServiceObjectsReplicationChecking, setServicePartitionsChecking, setServicePartitionsConsistency, setServicePartitionsSynchronization, setServicePresenceConsistency, setServicePurge, setServiceTimer, setTimeBeforeSendingAgentAliveMsg, setTimer, setTimeRemainingBeforeEventIsResend, setTimeRemainingBeforeObjectIsResend, setTimestampLOCALlocation, start

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RA

public RA(int listenPort_,
          java.util.ArrayList groupIdList,
          java.lang.String idFilename)

Method Detail

start

public void start(java.lang.String host,
                  int port,
                  java.lang.String groupId,
                  java.lang.String username,
                  java.lang.String password)

connectRA

public void connectRA(java.lang.String host,
                      int port,
                      java.lang.String groupId,
                      java.lang.String username,
                      java.lang.String password)

connectRA

public final void connectRA(java.lang.String groupId,
                            java.lang.String username,
                            java.lang.String password)

disconnectRA

public void disconnectRA(java.lang.String groupId)

doUpdatePresenceInformation

public void doUpdatePresenceInformation(Msg msg)

request_consistency

public void request_consistency(java.lang.String address_,
                                java.lang.String host,
                                int port,
                                java.lang.String groupId)

doAcceptAuthenticationOfParticipant

public void doAcceptAuthenticationOfParticipant(Msg msg)

doPresenceAgentAlive

public void doPresenceAgentAlive(Msg msg)

Overrides:

doPresenceAgentAlive in class Compo

doPresenceAgentDisconnected

public void doPresenceAgentDisconnected(Msg msg)

Overrides:

doPresenceAgentDisconnected in class Compo

doNewEvent

public void doNewEvent(Msg msg)

doEventsInvokeConsistencyRequest

public void doEventsInvokeConsistencyRequest(Msg msg)

doEventsAcceptConsistencyRequest

public void doEventsAcceptConsistencyRequest(Msg msg)

doEventsInvokeSynchronizationRequest

public void doEventsInvokeSynchronizationRequest(Msg msg)

doPurgeSession

public void doPurgeSession()

doNewGroup

public void doNewGroup(Msg msg)

Overrides:

doNewGroup in class Compo

doNewGroup

public void doNewGroup(Event evt,
                       java.lang.String username,
                       java.lang.String password)

createNewGroup

public java.lang.String createNewGroup(GroupInfo groupInfo,
                                       java.util.concurrent.Semaphore sem,
                                       InfoConnectedAgent agent)

createNewGroup

public java.lang.String createNewGroup(GroupInfo info,
                                       java.lang.String newId,
                                       java.util.concurrent.Semaphore sem,
                                       InfoConnectedAgent agent)

doNewGroupAck

public void doNewGroupAck(Msg msg)

doNewObject

public void doNewObject(Msg msg)

doReplicationNewReplica

public void doReplicationNewReplica(Msg msg)

msgReplicationAck

public void msgReplicationAck(Msg msg)

doGetObject

public void doGetObject(Msg msg)

doDeleteObject

public void doDeleteObject(Msg msg)

getRA

public RA getRA()

doServiceTimer

public void doServiceTimer()

Overrides:

doServiceTimer in class Compo

doServiceEventsConsistency

public void doServiceEventsConsistency()

Overrides:

doServiceEventsConsistency in class Compo

doServiceObjectsReplicationChecking

public void doServiceObjectsReplicationChecking()

Overrides:

doServiceObjectsReplicationChecking in class Compo

doServiceNewIteration

public void doServiceNewIteration(Msg msg)

Overrides:

doServiceNewIteration in class Compo