org.jredis.ri.alphazero.protocol

Class SyncProtocol

java.lang.Object

org.jredis.ri.alphazero.protocol.ProtocolBase

org.jredis.ri.alphazero.protocol.SyncProtocol

All Implemented Interfaces:

Protocol

Direct Known Subclasses:

ConcurrentSyncProtocol

public class SyncProtocol
extends ProtocolBase

[TODO: document me!]

Since:

alpha.0

Version:

alpha.0, Apr 10, 2009

Author:

Joubin Houshyar (alphazero@sensesay.net)

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	SyncProtocol.SyncBulkResponse
class	SyncProtocol.SyncLineResponse
class	SyncProtocol.SyncMultiBulkResponse
class	SyncProtocol.SyncMultiLineResponseBase Abstract base for all multiline responses (as of now, Bulk and MultBulk).
class	SyncProtocol.SyncResponseBase 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.
protected static class	SyncProtocol.ValueType

Nested classes/interfaces inherited from class org.jredis.ri.alphazero.protocol.ProtocolBase

ProtocolBase.StreamBufferRequest

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

Protocol.Factory

Field Summary

Fields

Modifier and Type	Field and Description
protected static int	INPUT_STREAM_BUFFER_SIZE
protected static int	PREFERRED_LINE_BUFFER_SIZE Initial size of the shared line buffer
protected static int	PREFERRED_REQUEST_BUFFER_SIZE Preferred size of request data buffer

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

ASCII_ZERO, COUNT_BYTE, CRLF, CRLF_LEN, DELIMETER_LEN, ERR_BYTE, NUM_BYTE, OK_BYTE, SIZE_BYTE, SPACE

Constructor Summary

Constructors

Constructor and Description
SyncProtocol()

Method Summary

Modifier and Type	Method and Description
protected Response	createBooleanResponse(Command cmd)
protected Response	createBulkResponse(Command cmd)
protected Response	createMultiBulkResponse(Command cmd)
protected Response	createNumberResponse(Command cmd)
protected Request	createRequest(ByteArrayOutputStream buffer)
protected ByteArrayOutputStream	createRequestBufffer(Command cmd)
protected Response	createStatusResponse(Command cmd)
protected Response	createStringResponse(Command cmd)

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

createRequest, createRequestBuffer, createResponse, isCompatibleWithVersion

Methods inherited from class java.lang.Object

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

Field Detail

PREFERRED_REQUEST_BUFFER_SIZE

protected static final int PREFERRED_REQUEST_BUFFER_SIZE

Preferred size of request data buffer

See Also:

Constant Field Values

PREFERRED_LINE_BUFFER_SIZE

protected static final int PREFERRED_LINE_BUFFER_SIZE

Initial size of the shared line buffer

See Also:

Constant Field Values

INPUT_STREAM_BUFFER_SIZE

protected static final int INPUT_STREAM_BUFFER_SIZE

See Also:

Constant Field Values

Constructor Detail

SyncProtocol

public SyncProtocol()

Method Detail

createRequestBufffer

protected ByteArrayOutputStream createRequestBufffer(Command cmd)

Specified by:

createRequestBufffer in class ProtocolBase

Parameters:

cmd - Command for this request - potentially useful for optimizing buffers.

Returns:

the shared instance of ByteArrayOutputStream that is used by all requests created by this Protocol implementation.

createRequest

protected Request createRequest(ByteArrayOutputStream buffer)

Specified by:

createRequest in class ProtocolBase

createStatusResponse

protected Response createStatusResponse(Command cmd)

Specified by:

createStatusResponse in class ProtocolBase

createBooleanResponse

protected Response createBooleanResponse(Command cmd)

Specified by:

createBooleanResponse in class ProtocolBase

createStringResponse

protected Response createStringResponse(Command cmd)

Specified by:

createStringResponse in class ProtocolBase

createNumberResponse

protected Response createNumberResponse(Command cmd)

Specified by:

createNumberResponse in class ProtocolBase

createBulkResponse

protected Response createBulkResponse(Command cmd)

Specified by:

createBulkResponse in class ProtocolBase

createMultiBulkResponse

protected Response createMultiBulkResponse(Command cmd)

Specified by:

createMultiBulkResponse in class ProtocolBase