Field Detail

• ADDITIONAL_TIMEOUT_CLUSTER_SHAPE

  public static final int ADDITIONAL_TIMEOUT_CLUSTER_SHAPE

  See Also:

  Constant Field Values

Constructor Detail

• ODistributedResponseManager

  public ODistributedResponseManager(ODistributedServerManager iManager,
                                     ODistributedRequest iRequest,
                                     Collection<String> expectedResponses,
                                     Set<String> iNodesConcurInQuorum,
                                     int iTotalExpectedResponses,
                                     int iQuorum,
                                     boolean iWaitForLocalNode,
                                     long iSynchTimeout,
                                     long iTotalTimeout,
                                     boolean iGroupResponsesByResult)

Method Detail

• collectResponse

  public boolean collectResponse(ODistributedResponse response)

  Not synchronized, it's called when a message arrives

  Parameters:

  response - Received response to collect

  Returns:

  True if all the nodes responded, otherwise false

• notifyWaiters

  public void notifyWaiters()

• getMessageId

  public ODistributedRequestId getMessageId()

• getSentOn

  public long getSentOn()

• merge

  public ODistributedResponse merge(ODistributedResponse merged)

• getQuorum

  public int getQuorum()

• waitForSynchronousResponses

  public boolean waitForSynchronousResponses()
                                      throws InterruptedException

  Waits until the minimum responses are collected or timeout occurs. If "waitForLocalNode" wait also for local node.

  Returns:

  True if the received responses are major or equals then the expected synchronous responses, otherwise false

  Throws:

  InterruptedException

• isWaitForLocalNode

  public boolean isWaitForLocalNode()

• isReceivedCurrentNode

  public boolean isReceivedCurrentNode()

• getFinalResponse

  public ODistributedResponse getFinalResponse()

• getDatabaseName

  public String getDatabaseName()

• getSynchTimeout

  public long getSynchTimeout()

• timeout

  public void timeout()

• getMissingNodes

  public List<String> getMissingNodes()

  Returns the list of node names that didn't provide a response.

• getExpectedNodes

  public Set<String> getExpectedNodes()

• getRespondingNodes

  public List<String> getRespondingNodes()

  Returns the list of node names that provided a response.

• getConflictResponses

  protected List<ODistributedResponse> getConflictResponses()

  Returns all the responses in conflict.

  Returns:

• getExpectedResponses

  protected int getExpectedResponses()

• getMissingResponses

  protected int getMissingResponses()

• getReceivedResponsesCount

  protected int getReceivedResponsesCount()

• getTotalTimeout

  protected long getTotalTimeout()

• getBestResponsesGroup

  protected int getBestResponsesGroup()

  Returns the biggest response group.

  Returns:

• isMinimumQuorumReached

  protected boolean isMinimumQuorumReached()

• getReceivedResponses

  protected List<ODistributedResponse> getReceivedResponses()

  Returns the received response objects.

• manageConflicts

  protected RuntimeException manageConflicts()

• undoRequest

  protected void undoRequest()

• fixNodesInConflict

  protected boolean fixNodesInConflict(List<ODistributedResponse> bestResponsesGroup,
                                       int conflicts)

• checkNoWinnerCase

  protected boolean checkNoWinnerCase(List<ODistributedResponse> bestResponsesGroup)