com.lambdaworks.redis.protocol

Class RedisStateMachine<K,V>

java.lang.Object

com.lambdaworks.redis.protocol.RedisStateMachine<K,V>

public class RedisStateMachine<K,V>
extends java.lang.Object

State machine that decodes redis server responses encoded according to the Unified Request Protocol.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
(package private) static class	RedisStateMachine.State

Field Summary

Fields

Modifier and Type	Field and Description
private static java.nio.ByteBuffer	QUEUED
private java.util.LinkedList<RedisStateMachine.State>	stack

Constructor Summary

Constructors

Constructor and Description
RedisStateMachine() Initialize a new instance.

Method Summary

Modifier and Type	Method and Description
boolean	decode(org.jboss.netty.buffer.ChannelBuffer buffer, CommandOutput<K,V,?> output) Attempt to decode a redis response and return a flag indicating whether a complete response was read.
private int	findLineEnd(org.jboss.netty.buffer.ChannelBuffer buffer)
private java.nio.ByteBuffer	readBytes(org.jboss.netty.buffer.ChannelBuffer buffer, int count)
private java.nio.ByteBuffer	readLine(org.jboss.netty.buffer.ChannelBuffer buffer)
private long	readLong(org.jboss.netty.buffer.ChannelBuffer buffer, int start, int end)
private RedisStateMachine.State.Type	readReplyType(org.jboss.netty.buffer.ChannelBuffer buffer)

Methods inherited from class java.lang.Object

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

Field Detail

QUEUED

private static final java.nio.ByteBuffer QUEUED

stack

private java.util.LinkedList<RedisStateMachine.State> stack

Constructor Detail

RedisStateMachine

public RedisStateMachine()

Initialize a new instance.

Method Detail

decode

public boolean decode(org.jboss.netty.buffer.ChannelBuffer buffer,
                      CommandOutput<K,V,?> output)

Attempt to decode a redis response and return a flag indicating whether a complete response was read.

Parameters:

buffer - Buffer containing data from the server.

output - Current command output.

Returns:

true if a complete response was read.

findLineEnd

private int findLineEnd(org.jboss.netty.buffer.ChannelBuffer buffer)

readReplyType

private RedisStateMachine.State.Type readReplyType(org.jboss.netty.buffer.ChannelBuffer buffer)

readLong

private long readLong(org.jboss.netty.buffer.ChannelBuffer buffer,
                      int start,
                      int end)

readLine

private java.nio.ByteBuffer readLine(org.jboss.netty.buffer.ChannelBuffer buffer)

readBytes

private java.nio.ByteBuffer readBytes(org.jboss.netty.buffer.ChannelBuffer buffer,
                                      int count)