org.jredis.ri.alphazero.protocol

Class SyncProtocol.SyncResponseBase

java.lang.Object

org.jredis.ri.alphazero.protocol.ResponseSupport

org.jredis.ri.alphazero.protocol.SyncProtocol.SyncResponseBase

All Implemented Interfaces:

Message, Response

Direct Known Subclasses:

SyncProtocol.SyncLineResponse, SyncProtocol.SyncMultiLineResponseBase

Enclosing class:

SyncProtocol

public abstract class SyncProtocol.SyncResponseBase
extends ResponseSupport

Synchronous responses are guaranteed to be contiguous chunks (if the client of this class is respecting its contract) -- meaning, it can go ahead and read as much as it can in its first read without busy waiting or reading one byte at a time. After that initial read, specialized response types can go head and read/parse as they please.

Since:

alpha.0

Version:

alpha.0, 04/02/09

Nested Class Summary

Nested classes/interfaces inherited from interface org.jredis.protocol.Response

Response.Type

Field Summary

Fields

Modifier and Type	Field and Description
(package private) byte[]	buffer
(package private) int	offset

Fields inherited from class org.jredis.ri.alphazero.protocol.ResponseSupport

cmd, didRead, isError, status, type

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	SyncResponseBase(byte[] buffer, Command cmd, Response.Type type)

Method Summary

Modifier and Type	Method and Description
(package private) void	readSingleLineResponse(java.io.InputStream in) Makes blocking calls to input stream until it gets crlf.
protected void	reset(Command cmd, Response.Type type)

Methods inherited from class org.jredis.ri.alphazero.protocol.ResponseSupport

assertResponseRead, didRead, didRead, getStatus, getType, isError, write

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.jredis.connector.Message

read

Field Detail

buffer

byte[] buffer

offset

int offset

Constructor Detail

SyncResponseBase

protected SyncResponseBase(byte[] buffer,
                           Command cmd,
                           Response.Type type)

Method Detail

reset

protected void reset(Command cmd,
                     Response.Type type)

readSingleLineResponse

void readSingleLineResponse(java.io.InputStream in)

Makes blocking calls to input stream until it gets crlf. Should not be used for size/count lines.

Parameters:

in -