LaColla.core.components
Class GAPA

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

public class GAPA
extends Compo

Field Summary

Fields inherited from class LaColla.core.components.Compo

purgeSessionPeriodicity, timeRemainingBeforeObjectIsResend

Constructor Summary

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

Method Summary

void	connectGAPA(java.lang.String host, int port, java.lang.String groupId, java.lang.String username, java.lang.String password)
void	connectGAPA(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	disconnectGAPA(java.lang.String groupId)
void	doAcceptAuthenticationOfParticipant(Msg msg)
void	doAuthenticationOfParticipant(Msg msg)
void	doGetInfoMember(Msg msg)
void	doInfoGroup(Msg msg)
void	doMembersAndGroupsAcceptConsistencyRequest(Msg msg)
void	doMembersAndGroupsInvokeConsistencyRequest(Msg msg)
void	doNewGroup(Msg msg)
void	doNewMember(Msg msg)
void	doServiceMembersAndGroupsConsistencySession()
void	doServiceNewIteration(Msg msg)
void	doServicePartitionsChecking()
void	doServicePartitionsConsistency()
void	doServiceTimer()
void	doUpdatePresenceInformation(Msg msg)
Compo	getGapa()
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, doPresenceAgentAlive, doPresenceAgentDisconnected, doPresenceAreYouAlive, doPresenceNewConnectedAgent, doServiceEventsConsistency, doServiceEventsSynchronization, doServiceObjectsReplicationChecking, 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

GAPA

public GAPA(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)

connectGAPA

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

connectGAPA

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

disconnectGAPA

public void disconnectGAPA(java.lang.String groupId)

doAuthenticationOfParticipant

public void doAuthenticationOfParticipant(Msg msg)

doAcceptAuthenticationOfParticipant

public void doAcceptAuthenticationOfParticipant(Msg msg)

getGapa

public Compo getGapa()

doUpdatePresenceInformation

public void doUpdatePresenceInformation(Msg msg)

doServicePartitionsChecking

public void doServicePartitionsChecking()

Overrides:

doServicePartitionsChecking in class Compo

doServicePartitionsConsistency

public void doServicePartitionsConsistency()

Overrides:

doServicePartitionsConsistency in class Compo

doNewMember

public void doNewMember(Msg msg)

doGetInfoMember

public void doGetInfoMember(Msg msg)

doMembersAndGroupsInvokeConsistencyRequest

public void doMembersAndGroupsInvokeConsistencyRequest(Msg msg)

Parameters:

msg -

doMembersAndGroupsAcceptConsistencyRequest

public void doMembersAndGroupsAcceptConsistencyRequest(Msg msg)

doServiceMembersAndGroupsConsistencySession

public void doServiceMembersAndGroupsConsistencySession()

doNewGroup

public void doNewGroup(Msg msg)

Overrides:

doNewGroup in class Compo

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)

doInfoGroup

public void doInfoGroup(Msg msg)

doServiceTimer

public void doServiceTimer()

Overrides:

doServiceTimer in class Compo

doServiceNewIteration

public void doServiceNewIteration(Msg msg)

Overrides:

doServiceNewIteration in class Compo