voldemort.store.routed
Class PutPipelineData

java.lang.Object
  voldemort.store.routed.PipelineData<ByteArray,V>
      voldemort.store.routed.BasicPipelineData<java.lang.Void>
          voldemort.store.routed.PutPipelineData

public class PutPipelineData
extends BasicPipelineData<java.lang.Void>

This is used only by the "put" operation as it includes data specific only to that operation.

Field Summary

Fields inherited from class voldemort.store.routed.PipelineData

failedNodes, failures, fatalError, replicationSet, stats, storeName

Constructor Summary

PutPipelineData()

Method Summary

Node	getMaster() Returns the previously determined "master" node.
long	getStartTimeNs() Get start time to perform timeout correctly
AsyncPutSynchronizer	getSynchronizer()
Versioned<byte[]>	getVersionedCopy() Returns the copy of the Versioned as determined by PerformSerialPutRequests.
void	setMaster(Node master) Assigns the "master" Node as determined by PerformSerialPutRequests.
void	setStartTimeNs(long startTimeNs) Set start time to perform timeout correctly
void	setVersionedCopy(Versioned<byte[]> versionedCopy) The copy of the Versioned instance that was incremented before attempting to put on the remote Voldemort node.

Methods inherited from class voldemort.store.routed.BasicPipelineData

getNodeIndex, getNodes, getSuccesses, getZoneResponses, getZonesRequired, incrementNodeIndex, incrementSuccesses, setNodes, setZonesRequired

Methods inherited from class voldemort.store.routed.PipelineData

addFailedNode, getFailedNodes, getFailures, getFatalError, getReplicationSet, getResponses, getStoreName, recordFailure, reportException, setFatalError, setReplicationSet, setStats, setStoreName

Methods inherited from class java.lang.Object

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

Constructor Detail

PutPipelineData

public PutPipelineData()

Method Detail

getMaster

public Node getMaster()

Returns the previously determined "master" node. This is the first node in the preference list that succeeded in "putting" the value.

Returns:

Master Node, or null if not yet assigned

setMaster

public void setMaster(Node master)

Assigns the "master" Node as determined by PerformSerialPutRequests. This is the first node in the preference list that "put" the value successfully.

Parameters:

master - "Master" Node

getVersionedCopy

public Versioned<byte[]> getVersionedCopy()

Returns the copy of the Versioned as determined by PerformSerialPutRequests.

Returns:

Versioned copy

setVersionedCopy

public void setVersionedCopy(Versioned<byte[]> versionedCopy)

The copy of the Versioned instance that was incremented before attempting to put on the remote Voldemort node.

Parameters:

versionedCopy -

setStartTimeNs

public void setStartTimeNs(long startTimeNs)

Set start time to perform timeout correctly

Parameters:

startTimeNs -

getStartTimeNs

public long getStartTimeNs()

Get start time to perform timeout correctly

getSynchronizer

public AsyncPutSynchronizer getSynchronizer()