voldemort.store.routed.action
Class AbstractAction<K,V,PD extends PipelineData<K,V>>

java.lang.Object
  voldemort.store.routed.action.AbstractAction<K,V,PD>

All Implemented Interfaces:

Action

Direct Known Subclasses:

AbstractConfigureNodes, AbstractKeyBasedAction, AbstractReadRepair, IncrementClock, PerformParallelGetAllRequests, PerformSerialGetAllRequests

public abstract class AbstractAction<K,V,PD extends PipelineData<K,V>>
extends java.lang.Object
implements Action

Field Summary

protected Pipeline.Event	completeEvent
protected org.apache.log4j.Logger	logger
protected PD	pipelineData

Constructor Summary

protected

AbstractAction(PD pipelineData, Pipeline.Event completeEvent)

Method Summary

protected boolean	handleResponseError(java.lang.Exception e, Node node, long requestTime, Pipeline pipeline, FailureDetector failureDetector)
protected boolean	handleResponseError(Response<?,?> response, Pipeline pipeline, FailureDetector failureDetector)

Methods inherited from class java.lang.Object

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

Methods inherited from interface voldemort.store.routed.action.Action

execute

Field Detail

pipelineData

protected final PD extends PipelineData<K,V> pipelineData

completeEvent

protected final Pipeline.Event completeEvent

logger

protected final org.apache.log4j.Logger logger

Constructor Detail

AbstractAction

protected AbstractAction(PD pipelineData,
                         Pipeline.Event completeEvent)

Method Detail

handleResponseError

protected boolean handleResponseError(Response<?,?> response,
                                      Pipeline pipeline,
                                      FailureDetector failureDetector)

handleResponseError

protected boolean handleResponseError(java.lang.Exception e,
                                      Node node,
                                      long requestTime,
                                      Pipeline pipeline,
                                      FailureDetector failureDetector)