LaColla.core.components
Class Compo

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

Direct Known Subclasses:

GAPA, RA, SA, UA

public class Compo
extends java.lang.Object

Field Summary

long	purgeSessionPeriodicity
long	timeRemainingBeforeObjectIsResend

Constructor Summary

Compo(int kindOfAgent_, int listenPort_, java.util.ArrayList groupIdList, java.lang.String address)

Method Summary

java.lang.String	createNewGroup(GroupInfo groupInfo)
java.lang.String	createNewGroup(GroupInfo info, java.lang.String newId)
void	decrementConnectedAgentsTimeBeforeBeingDiscarted(long STEP)
void	decrementConnectedAgentsTimeBeforeBeingDiscarted(long STEP, ObjectLaCOLLASummary objSummary)
void	doAcceptPresenceConsistencyRequest(Msg msg)
void	doInvokePresenceConsistencyRequest(Msg msg)
void	doNewGroup(Msg msg)
void	doPartitionsAcceptConsistencyRequest(Msg msg)
void	doPartitionsAcceptSynchronizationRequest(Msg msg)
void	doPartitionsInvokeConsistencyRequest(Msg msg)
void	doPartitionsInvokeSynchronizationRequest(Msg msg)
void	doPresenceAgentAlive(Msg msg)
void	doPresenceAgentDisconnected(Msg msg)
void	doPresenceAreYouAlive(Msg msg)
void	doPresenceNewConnectedAgent(Msg msg)
void	doServiceEventsConsistency()
void	doServiceEventsSynchronization()
void	doServiceNewIteration(Msg msg)
void	doServiceObjectsReplicationChecking()
void	doServicePartitionsChecking()
void	doServicePartitionsConsistency()
void	doServicePartitionsSynchronization()
void	doServicePresenceConsistency()
void	doServiceTimer()
java.lang.String	getAddress()
java.util.concurrent.ScheduledFuture	getConnecting()
java.util.concurrent.ScheduledFuture	getEventsConsistency()
java.util.concurrent.ScheduledFuture	getEventsSynchronization()
java.lang.String	getGroupId()
java.util.Hashtable	getGroups()
Hp	getHp()
int	getKindOfAgent()
int	getListenPort()
java.util.concurrent.ScheduledFuture	getObjectsReplicationChecking()
java.lang.String	getOwnerId()
java.util.concurrent.ScheduledFuture	getPartitionsChecking()
java.util.concurrent.ScheduledFuture	getPartitionsConsistency()
java.util.concurrent.ScheduledFuture	getPartitionsSynchronization()
java.util.concurrent.ScheduledFuture	getPresenceConsistency()
java.util.concurrent.ScheduledFuture	getPurge()
long	getSeqNumGroup(java.lang.String groupId)
long	getSequenceNumber(java.lang.String groupId)
long	getSequenceNumberInfoAgent()
long	getSequenceNumberObjects(java.lang.String groupId)
ServiceConnecting	getServiceConnecting()
ServiceEventsConsistency	getServiceEventsConsistency()
ServiceEventsSynchronization	getServiceEventsSynchronization()
ServiceObjectsReplicationChecking	getServiceObjectsReplicationChecking()
ServicePartitionsChecking	getServicePartitionsChecking()
ServicePartitionsConsistency	getServicePartitionsConsistency()
ServicePartitionsSynchronization	getServicePartitionsSynchronization()
ServicePresenceConsistency	getServicePresenceConsistency()
ServicePurge	getServicePurge()
ServiceTimer	getServiceTimer()
Hp	getSimulationAgentHp()
SimulationTimeManager	getSimulationTime()
TimeManager	getTime()
long	getTimeBeforeSendingAgentAliveMsg()
long	getTimeRemainingBeforeEventIsResend()
long	getTimeRemainingBeforeObjectIsResend()
Timestamp	getTimestampLOCALlocation()
void	goMsg_Dest(int msgType, Msg msg, Hp hp_)
boolean	isSimulation()
void	presenceConsistencySession()
void	sendEventToConnectedUAandRA(Event event, java.lang.String groupId)
void	sendToEveryAgent(int msgType, Msg msg, java.lang.String groupId)
void	sendToEveryAgent(int msgType, java.lang.String groupId)
void	setAddress(java.lang.String address)
void	setConnecting(java.util.concurrent.ScheduledFuture connecting)
void	setEventsConsistency(java.util.concurrent.ScheduledFuture eventsConsistency)
void	setEventsSynchronization(java.util.concurrent.ScheduledFuture eventsSynchronization)
void	setGroupId(java.lang.String groupId)
void	setHP(int kindOfAgent_, java.net.InetAddress addr, int port)
void	setKindOfAgent(int kindOfAgent)
void	setListenPort(int listenPort)
void	setObjectsReplicationChecking(java.util.concurrent.ScheduledFuture objectsReplicationChecking)
void	setOwnerId(java.lang.String ownerId)
void	setPartitionsChecking(java.util.concurrent.ScheduledFuture partitionsChecking)
void	setPartitionsConsistency(java.util.concurrent.ScheduledFuture partitionsConsistency)
void	setPartitionsSynchronization(java.util.concurrent.ScheduledFuture partitionsSynchronization)
void	setPresenceConsistency(java.util.concurrent.ScheduledFuture presenceConsistency)
void	setPurge(java.util.concurrent.ScheduledFuture purge)
void	setSeqNumGroup(java.lang.String groupId, long seqNumGroup)
void	setSequenceNumber(java.lang.String groupId, long seqNum)
void	setSequenceNumberInfoAgent(java.lang.String groupId, long seqNum)
void	setSequenceNumberObjects(java.lang.String groupId, long seqNum)
void	setServiceConnecting(ServiceConnecting connecting)
void	setServiceEventsConsistency(ServiceEventsConsistency serviceEventsConsistency)
void	setServiceEventsSynchronization(ServiceEventsSynchronization serviceEventsSynchronization)
void	setServiceObjectsReplicationChecking(ServiceObjectsReplicationChecking serviceObjectsReplicationChecking)
void	setServicePartitionsChecking(ServicePartitionsChecking servicePartitionsChecking)
void	setServicePartitionsConsistency(ServicePartitionsConsistency servicePartitionsConsistency)
void	setServicePartitionsSynchronization(ServicePartitionsSynchronization servicePartitionsSynchronization)
void	setServicePresenceConsistency(ServicePresenceConsistency servicePresenceConsistency)
void	setServicePurge(ServicePurge servicePurge)
void	setServiceTimer(ServiceTimer timer)
void	setTimeBeforeSendingAgentAliveMsg(long timeBeforeSendingAgentAliveMsg)
void	setTimer(java.util.concurrent.ScheduledFuture future)
void	setTimeRemainingBeforeEventIsResend(long timeRemainingBeforeEventIsResend)
void	setTimeRemainingBeforeObjectIsResend(long timeRemainingBeforeObjectIsResend)
void	setTimestampLOCALlocation(Timestamp timestampLOCALlocation)
void	start(java.lang.String groupId2)

Methods inherited from class java.lang.Object

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

Field Detail

timeRemainingBeforeObjectIsResend

public long timeRemainingBeforeObjectIsResend

purgeSessionPeriodicity

public long purgeSessionPeriodicity

Constructor Detail

Compo

public Compo(int kindOfAgent_,
             int listenPort_,
             java.util.ArrayList groupIdList,
             java.lang.String address)

Method Detail

start

public void start(java.lang.String groupId2)

setHP

public void setHP(int kindOfAgent_,
                  java.net.InetAddress addr,
                  int port)

getHp

public Hp getHp()

goMsg_Dest

public void goMsg_Dest(int msgType,
                       Msg msg,
                       Hp hp_)

decrementConnectedAgentsTimeBeforeBeingDiscarted

public void decrementConnectedAgentsTimeBeforeBeingDiscarted(long STEP,
                                                             ObjectLaCOLLASummary objSummary)

decrementConnectedAgentsTimeBeforeBeingDiscarted

public void decrementConnectedAgentsTimeBeforeBeingDiscarted(long STEP)

sendToEveryAgent

public void sendToEveryAgent(int msgType,
                             Msg msg,
                             java.lang.String groupId)

sendToEveryAgent

public void sendToEveryAgent(int msgType,
                             java.lang.String groupId)

sendEventToConnectedUAandRA

public void sendEventToConnectedUAandRA(Event event,
                                        java.lang.String groupId)

doInvokePresenceConsistencyRequest

public void doInvokePresenceConsistencyRequest(Msg msg)

doPresenceNewConnectedAgent

public void doPresenceNewConnectedAgent(Msg msg)

doPresenceAgentDisconnected

public void doPresenceAgentDisconnected(Msg msg)

doAcceptPresenceConsistencyRequest

public void doAcceptPresenceConsistencyRequest(Msg msg)

doPresenceAgentAlive

public void doPresenceAgentAlive(Msg msg)

doPresenceAreYouAlive

public void doPresenceAreYouAlive(Msg msg)

presenceConsistencySession

public void presenceConsistencySession()

doPartitionsInvokeConsistencyRequest

public void doPartitionsInvokeConsistencyRequest(Msg msg)

doPartitionsAcceptConsistencyRequest

public void doPartitionsAcceptConsistencyRequest(Msg msg)

doPartitionsInvokeSynchronizationRequest

public void doPartitionsInvokeSynchronizationRequest(Msg msg)

doPartitionsAcceptSynchronizationRequest

public void doPartitionsAcceptSynchronizationRequest(Msg msg)

createNewGroup

public java.lang.String createNewGroup(GroupInfo groupInfo)

doNewGroup

public void doNewGroup(Msg msg)

createNewGroup

public java.lang.String createNewGroup(GroupInfo info,
                                       java.lang.String newId)

Parameters:

info -

string -

getGroupId

public java.lang.String getGroupId()

setGroupId

public void setGroupId(java.lang.String groupId)

getKindOfAgent

public int getKindOfAgent()

setKindOfAgent

public void setKindOfAgent(int kindOfAgent)

getListenPort

public int getListenPort()

setListenPort

public void setListenPort(int listenPort)

getAddress

public java.lang.String getAddress()

setAddress

public void setAddress(java.lang.String address)

getGroups

public java.util.Hashtable getGroups()

getSeqNumGroup

public long getSeqNumGroup(java.lang.String groupId)

setSeqNumGroup

public void setSeqNumGroup(java.lang.String groupId,
                           long seqNumGroup)

getSequenceNumberInfoAgent

public long getSequenceNumberInfoAgent()

setSequenceNumberInfoAgent

public void setSequenceNumberInfoAgent(java.lang.String groupId,
                                       long seqNum)

getSequenceNumber

public long getSequenceNumber(java.lang.String groupId)

setSequenceNumber

public void setSequenceNumber(java.lang.String groupId,
                              long seqNum)

getSequenceNumberObjects

public long getSequenceNumberObjects(java.lang.String groupId)

setSequenceNumberObjects

public void setSequenceNumberObjects(java.lang.String groupId,
                                     long seqNum)

getTimestampLOCALlocation

public Timestamp getTimestampLOCALlocation()

setTimestampLOCALlocation

public void setTimestampLOCALlocation(Timestamp timestampLOCALlocation)

getTimeRemainingBeforeEventIsResend

public long getTimeRemainingBeforeEventIsResend()

Returns:

getOwnerId

public java.lang.String getOwnerId()

setOwnerId

public void setOwnerId(java.lang.String ownerId)

getTime

public TimeManager getTime()

setServiceConnecting

public void setServiceConnecting(ServiceConnecting connecting)

getServiceConnecting

public ServiceConnecting getServiceConnecting()

getConnecting

public java.util.concurrent.ScheduledFuture getConnecting()

setConnecting

public void setConnecting(java.util.concurrent.ScheduledFuture connecting)

doServiceTimer

public void doServiceTimer()

setServiceTimer

public void setServiceTimer(ServiceTimer timer)

Parameters:

timer -

getServiceTimer

public ServiceTimer getServiceTimer()

Returns:

Returns the serviceTimer.

setTimer

public void setTimer(java.util.concurrent.ScheduledFuture future)

Parameters:

future -

getTimeBeforeSendingAgentAliveMsg

public long getTimeBeforeSendingAgentAliveMsg()

Returns:

Returns the timeBeforeSendingAgentAliveMsg.

setTimeBeforeSendingAgentAliveMsg

public void setTimeBeforeSendingAgentAliveMsg(long timeBeforeSendingAgentAliveMsg)

Parameters:

timeBeforeSendingAgentAliveMsg - The timeBeforeSendingAgentAliveMsg to set.

getTimeRemainingBeforeObjectIsResend

public long getTimeRemainingBeforeObjectIsResend()

Returns:

setTimeRemainingBeforeObjectIsResend

public void setTimeRemainingBeforeObjectIsResend(long timeRemainingBeforeObjectIsResend)

Parameters:

timeRemainingBeforeObjectIsResend - The timeRemainingBeforeObjectIsResend to set.

getEventsConsistency

public java.util.concurrent.ScheduledFuture getEventsConsistency()

setEventsConsistency

public void setEventsConsistency(java.util.concurrent.ScheduledFuture eventsConsistency)

getEventsSynchronization

public java.util.concurrent.ScheduledFuture getEventsSynchronization()

setEventsSynchronization

public void setEventsSynchronization(java.util.concurrent.ScheduledFuture eventsSynchronization)

getObjectsReplicationChecking

public java.util.concurrent.ScheduledFuture getObjectsReplicationChecking()

setObjectsReplicationChecking

public void setObjectsReplicationChecking(java.util.concurrent.ScheduledFuture objectsReplicationChecking)

getPartitionsChecking

public java.util.concurrent.ScheduledFuture getPartitionsChecking()

setPartitionsChecking

public void setPartitionsChecking(java.util.concurrent.ScheduledFuture partitionsChecking)

getPartitionsConsistency

public java.util.concurrent.ScheduledFuture getPartitionsConsistency()

setPartitionsConsistency

public void setPartitionsConsistency(java.util.concurrent.ScheduledFuture partitionsConsistency)

getPartitionsSynchronization

public java.util.concurrent.ScheduledFuture getPartitionsSynchronization()

setPartitionsSynchronization

public void setPartitionsSynchronization(java.util.concurrent.ScheduledFuture partitionsSynchronization)

getPresenceConsistency

public java.util.concurrent.ScheduledFuture getPresenceConsistency()

setPresenceConsistency

public void setPresenceConsistency(java.util.concurrent.ScheduledFuture presenceConsistency)

getServiceEventsConsistency

public ServiceEventsConsistency getServiceEventsConsistency()

setServiceEventsConsistency

public void setServiceEventsConsistency(ServiceEventsConsistency serviceEventsConsistency)

getServiceEventsSynchronization

public ServiceEventsSynchronization getServiceEventsSynchronization()

setServiceEventsSynchronization

public void setServiceEventsSynchronization(ServiceEventsSynchronization serviceEventsSynchronization)

getServiceObjectsReplicationChecking

public ServiceObjectsReplicationChecking getServiceObjectsReplicationChecking()

setServiceObjectsReplicationChecking

public void setServiceObjectsReplicationChecking(ServiceObjectsReplicationChecking serviceObjectsReplicationChecking)

getServicePartitionsChecking

public ServicePartitionsChecking getServicePartitionsChecking()

setServicePartitionsChecking

public void setServicePartitionsChecking(ServicePartitionsChecking servicePartitionsChecking)

getServicePartitionsConsistency

public ServicePartitionsConsistency getServicePartitionsConsistency()

setServicePartitionsConsistency

public void setServicePartitionsConsistency(ServicePartitionsConsistency servicePartitionsConsistency)

getServicePartitionsSynchronization

public ServicePartitionsSynchronization getServicePartitionsSynchronization()

setServicePartitionsSynchronization

public void setServicePartitionsSynchronization(ServicePartitionsSynchronization servicePartitionsSynchronization)

getServicePresenceConsistency

public ServicePresenceConsistency getServicePresenceConsistency()

setServicePresenceConsistency

public void setServicePresenceConsistency(ServicePresenceConsistency servicePresenceConsistency)

setTimeRemainingBeforeEventIsResend

public void setTimeRemainingBeforeEventIsResend(long timeRemainingBeforeEventIsResend)

doServicePresenceConsistency

public void doServicePresenceConsistency()

doServiceEventsSynchronization

public void doServiceEventsSynchronization()

doServicePartitionsSynchronization

public void doServicePartitionsSynchronization()

doServiceEventsConsistency

public void doServiceEventsConsistency()

doServiceObjectsReplicationChecking

public void doServiceObjectsReplicationChecking()

doServicePartitionsChecking

public void doServicePartitionsChecking()

doServicePartitionsConsistency

public void doServicePartitionsConsistency()

isSimulation

public boolean isSimulation()

getSimulationTime

public SimulationTimeManager getSimulationTime()

getSimulationAgentHp

public Hp getSimulationAgentHp()

doServiceNewIteration

public void doServiceNewIteration(Msg msg)

getPurge

public java.util.concurrent.ScheduledFuture getPurge()

setPurge

public void setPurge(java.util.concurrent.ScheduledFuture purge)

getServicePurge

public ServicePurge getServicePurge()

setServicePurge

public void setServicePurge(ServicePurge servicePurge)