voldemort.store.socket.clientrequest
Class ProtocolNegotiatorClientRequest

java.lang.Object
  extended by voldemort.store.socket.clientrequest.AbstractClientRequest<java.lang.String>
      extended by voldemort.store.socket.clientrequest.ProtocolNegotiatorClientRequest
All Implemented Interfaces:
ClientRequest<java.lang.String>

public class ProtocolNegotiatorClientRequest
extends AbstractClientRequest<java.lang.String>


Constructor Summary
ProtocolNegotiatorClientRequest(RequestFormatType requestFormatType)
           
 
Method Summary
protected  void formatRequestInternal(java.io.DataOutputStream outputStream)
           
 boolean isCompleteResponse(java.nio.ByteBuffer buffer)
          isCompleteResponse determines if the response that the ClientRequestExecutor's received thus far is inclusive of the entire response.
protected  java.lang.String parseResponseInternal(java.io.DataInputStream inputStream)
           
 
Methods inherited from class voldemort.store.socket.clientrequest.AbstractClientRequest
complete, formatRequest, getResult, isComplete, isTimedOut, parseResponse, timeOut
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

ProtocolNegotiatorClientRequest

public ProtocolNegotiatorClientRequest(RequestFormatType requestFormatType)
Method Detail

isCompleteResponse

public boolean isCompleteResponse(java.nio.ByteBuffer buffer)
Description copied from interface: ClientRequest
isCompleteResponse determines if the response that the ClientRequestExecutor's received thus far is inclusive of the entire response. This relies on the RequestFormat instance's isCompleteXxxResponse methods.

This is used internally by the ClientRequest logic and should not be invoked by users of the sub-system.

Parameters:
buffer - ByteBuffer containing the data received thus far
Returns:
True if the buffer contains the complete response, false if it only includes part of the response.

formatRequestInternal

protected void formatRequestInternal(java.io.DataOutputStream outputStream)
                              throws java.io.IOException
Specified by:
formatRequestInternal in class AbstractClientRequest<java.lang.String>
Throws:
java.io.IOException

parseResponseInternal

protected java.lang.String parseResponseInternal(java.io.DataInputStream inputStream)
                                          throws java.io.IOException
Specified by:
parseResponseInternal in class AbstractClientRequest<java.lang.String>
Throws:
java.io.IOException


Jay Kreps, Roshan Sumbaly, Alex Feinberg, Bhupesh Bansal, Lei Gao, Chinmay Soman, Vinoth Chandar, Zhongjie Wu