org.hypergraphdb.peer.replication
Class RememberTaskClient

java.lang.Object
  org.hypergraphdb.peer.workflow.AbstractActivity<StateType>
      org.hypergraphdb.peer.workflow.TaskActivity<org.hypergraphdb.peer.replication.RememberTaskClient.State>
          org.hypergraphdb.peer.replication.RememberTaskClient

All Implemented Interfaces:

java.lang.Runnable, ActivityStateListener

public class RememberTaskClient
extends TaskActivity<org.hypergraphdb.peer.replication.RememberTaskClient.State>

Author:

Cipri Costa A task that performs the "client" side of the REMEMBER action. At the start of the task, it will send "call for proposal" messages to peers using a PeerFilter. Any peer that decides to answer the call for proposal with a proposal will establish a conversation. The task will only use ProposalConversation conversations.

Nested Class Summary

static class

RememberTaskClient.RememberEntity

Constructor Summary

RememberTaskClient(HyperGraphPeer thisPeer, LogEntry entry, java.lang.Object targetPeer, Log log)

RememberTaskClient(HyperGraphPeer thisPeer, Log log, java.lang.Object targetPeer, java.util.List<java.lang.Object> batch)

RememberTaskClient(HyperGraphPeer thisPeer, java.lang.Object value, Log log, HGPersistentHandle handle, java.lang.Object targetPeer, StorageService.Operation operation)

RememberTaskClient(HyperGraphPeer thisPeer, java.lang.Object value, Log log, HyperGraph hg, HGPersistentHandle handle, StorageService.Operation operation)

Method Summary

HGHandle	getResult()
java.util.List<HGHandle>	getResults()
org.hypergraphdb.peer.replication.RememberTaskClient.State	handleConfirm(AbstractActivity<?> fromActivity) Called when one of the conversations enters the Confirmed state while the task is in the Accepted state.
org.hypergraphdb.peer.replication.RememberTaskClient.State	handleDisconfirm(AbstractActivity<?> fromActivity)
org.hypergraphdb.peer.replication.RememberTaskClient.State	handleProposal(AbstractActivity<?> fromActivity) Called when one of the conversations enters the Proposed state while the task is in the Started state.

Methods inherited from class org.hypergraphdb.peer.workflow.TaskActivity

getPeerInterface, getTaskId, getThisPeer, handleMessage, setTaskId, stateChanged

Methods inherited from class org.hypergraphdb.peer.workflow.AbstractActivity

getEndState, getStartState, run, setStateListener

Methods inherited from class java.lang.Object

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

Constructor Detail

RememberTaskClient

public RememberTaskClient(HyperGraphPeer thisPeer,
                          Log log,
                          java.lang.Object targetPeer,
                          java.util.List<java.lang.Object> batch)

RememberTaskClient

public RememberTaskClient(HyperGraphPeer thisPeer,
                          java.lang.Object value,
                          Log log,
                          HyperGraph hg,
                          HGPersistentHandle handle,
                          StorageService.Operation operation)

RememberTaskClient

public RememberTaskClient(HyperGraphPeer thisPeer,
                          java.lang.Object value,
                          Log log,
                          HGPersistentHandle handle,
                          java.lang.Object targetPeer,
                          StorageService.Operation operation)

RememberTaskClient

public RememberTaskClient(HyperGraphPeer thisPeer,
                          LogEntry entry,
                          java.lang.Object targetPeer,
                          Log log)

Method Detail

handleProposal

public org.hypergraphdb.peer.replication.RememberTaskClient.State handleProposal(AbstractActivity<?> fromActivity)

Called when one of the conversations enters the Proposed state while the task is in the Started state.

Parameters:

fromActivity -

Returns:

handleConfirm

public org.hypergraphdb.peer.replication.RememberTaskClient.State handleConfirm(AbstractActivity<?> fromActivity)

Called when one of the conversations enters the Confirmed state while the task is in the Accepted state.

Parameters:

fromActivity -

Returns:

handleDisconfirm

public org.hypergraphdb.peer.replication.RememberTaskClient.State handleDisconfirm(AbstractActivity<?> fromActivity)

getResult

public HGHandle getResult()

getResults

public java.util.List<HGHandle> getResults()