voldemort.store.socket.clientrequest
Class ProtocolNegotiatorClientRequest

java.lang.Object
  voldemort.store.socket.clientrequest.AbstractClientRequest<java.lang.String>
      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