org.infinispan.remoting.responses

Class KeysValidateFilter

java.lang.Object

org.infinispan.remoting.responses.KeysValidateFilter

All Implemented Interfaces:

TimeoutValidationResponseFilter, ResponseFilter

public class KeysValidateFilter
extends Object
implements TimeoutValidationResponseFilter

Used in Total Order based commit protocol in Distributed Mode

This filter awaits for one valid response for each key to be validated. This way, it avoids waiting for the reply of all nodes involved in the transaction without compromise consistency

Since:

5.3

Author:

Pedro Ruivo

Constructor Summary

Constructors

Constructor and Description
KeysValidateFilter(Address localAddress, Set<Object> keysAwaitingValidation)

Method Summary

Modifier and Type	Method and Description
boolean	isAcceptable(Response response, Address sender) Determines whether a response from a given sender should be added to the response list of the request
boolean	needMoreResponses() Right after calling ResponseFilter.isAcceptable(Response, Address), this method is called to see whether we are done with the request and can unblock the caller
void	validate() Validates the filter state.

Methods inherited from class java.lang.Object

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

Constructor Detail

KeysValidateFilter

public KeysValidateFilter(Address localAddress,
                          Set<Object> keysAwaitingValidation)

Method Detail

isAcceptable

public boolean isAcceptable(Response response,
                            Address sender)

Description copied from interface: ResponseFilter

Determines whether a response from a given sender should be added to the response list of the request

Specified by:

isAcceptable in interface ResponseFilter

Parameters:

response - The response (usually a serializable value)

sender - The sender of response

Returns:

True if we should add the response to the response list of a request, otherwise false. In the latter case, we don't add the response to the response list.

needMoreResponses

public boolean needMoreResponses()

Description copied from interface: ResponseFilter

Right after calling ResponseFilter.isAcceptable(Response, Address), this method is called to see whether we are done with the request and can unblock the caller

Specified by:

needMoreResponses in interface ResponseFilter

Returns:

False if the request is done, otherwise true

validate

public void validate()
              throws TimeoutException

Description copied from interface: TimeoutValidationResponseFilter

Validates the filter state. If it has no responses or some member didn't reply, it must throw a TimeoutException

Specified by:

validate in interface TimeoutValidationResponseFilter

Throws:

TimeoutException - when a member didn't give a response.