org.jredis.ri.alphazero.protocol

Class SyncProtocol.SyncMultiLineResponseBase

java.lang.Object

org.jredis.ri.alphazero.protocol.ResponseSupport

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

org.jredis.ri.alphazero.protocol.SyncProtocol.SyncMultiLineResponseBase

All Implemented Interfaces:

Message, Response

Direct Known Subclasses:

SyncProtocol.SyncBulkResponse, SyncProtocol.SyncMultiBulkResponse

Enclosing class:

SyncProtocol

public abstract class SyncProtocol.SyncMultiLineResponseBase
extends SyncProtocol.SyncResponseBase

Abstract base for all multiline responses (as of now, Bulk and MultBulk).

Since:

alpha.0 TODO: Use overflow buffers to increase read efficiency.

Version:

alpha.0, Sep 2, 2009

Nested Class Summary

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

Response.Type

Field Summary

Fields inherited from class org.jredis.ri.alphazero.protocol.SyncProtocol.SyncResponseBase

buffer, offset

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

cmd, didRead, isError, status, type

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
byte[]	readBulkData(java.io.InputStream in, int length) Will read up expected bulkdata bytes from the input stream.
(package private) int	readControlLine(java.io.InputStream in, boolean checkForError, byte ctlByte)
(package private) void	seekToCRLF(java.io.InputStream in)

Methods inherited from class org.jredis.ri.alphazero.protocol.SyncProtocol.SyncResponseBase

readSingleLineResponse, reset

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

Constructor Detail

SyncMultiLineResponseBase

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

Method Detail

seekToCRLF

void seekToCRLF(java.io.InputStream in)

Parameters:

in -

readControlLine

int readControlLine(java.io.InputStream in,
                    boolean checkForError,
                    byte ctlByte)

Parameters:

in -

checkForError -

ctlByte -

Returns:

readBulkData

public final byte[] readBulkData(java.io.InputStream in,
                                 int length)
                          throws java.io.IOException,
                                 java.lang.RuntimeException

Will read up expected bulkdata bytes from the input stream. Routine will also read in the last two bytes and will check that they are indeed CRLF.

Parameters:

in - the stream to read from.

length - expected bulk data length (NOT including the trailing CRLF).

Returns:

a byte[] of length.

Throws:

java.io.IOException

java.lang.IllegalArgumentException - if could not read the bulk data

java.lang.RuntimeException