voldemort.rest
Class RestResponseSender

java.lang.Object
  voldemort.rest.RestResponseSender

Direct Known Subclasses:

DeleteResponseSender, GetAllResponseSender, GetMetadataResponseSender, GetResponseSender, GetVersionResponseSender, PutResponseSender

public abstract class RestResponseSender
extends java.lang.Object

Field Summary

protected static long	INVALID_START_TIME_IN_MS
protected org.jboss.netty.channel.MessageEvent	messageEvent
protected static long	NS_PER_MS
protected int	numVectorClockEntries

Constructor Summary

RestResponseSender(org.jboss.netty.channel.MessageEvent messageEvent)

Method Summary

protected void	debugLog(java.lang.String operationType, java.lang.String storeName, java.lang.String keyStr, java.lang.Long originTimeInMS, java.lang.Long responseTimeStampInMS, int totalVectorClockEntries)
protected java.lang.String	getKeysHexString(java.util.Set<ByteArray> keys)
void	recordStats(StoreStats performanceStats, long startTimeInMs, Tracked operation)
void	sendResponse()
abstract void	sendResponse(StoreStats perfomanceStats, boolean isFromLocalZone, long startTimeInMs)

Methods inherited from class java.lang.Object

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

Field Detail

messageEvent

protected org.jboss.netty.channel.MessageEvent messageEvent

NS_PER_MS

protected static final long NS_PER_MS

See Also:

Constant Field Values

INVALID_START_TIME_IN_MS

protected static final long INVALID_START_TIME_IN_MS

See Also:

Constant Field Values

numVectorClockEntries

protected int numVectorClockEntries

Constructor Detail

RestResponseSender

public RestResponseSender(org.jboss.netty.channel.MessageEvent messageEvent)

Method Detail

sendResponse

public void sendResponse()
                  throws java.lang.Exception

Throws:

java.lang.Exception

sendResponse

public abstract void sendResponse(StoreStats perfomanceStats,
                                  boolean isFromLocalZone,
                                  long startTimeInMs)
                           throws java.lang.Exception

Throws:

java.lang.Exception

recordStats

public void recordStats(StoreStats performanceStats,
                        long startTimeInMs,
                        Tracked operation)

debugLog

protected void debugLog(java.lang.String operationType,
                        java.lang.String storeName,
                        java.lang.String keyStr,
                        java.lang.Long originTimeInMS,
                        java.lang.Long responseTimeStampInMS,
                        int totalVectorClockEntries)

getKeysHexString

protected java.lang.String getKeysHexString(java.util.Set<ByteArray> keys)