org.infinispan.server.memcached

Class TextProtocolUtil

java.lang.Object

org.infinispan.server.memcached.TextProtocolUtil

public class TextProtocolUtil
extends Object

Memcached text protocol utilities.

Since:

4.1

Author:

Galder Zamarreño

Constructor Summary

Constructors

Constructor and Description
TextProtocolUtil()

Method Summary

Methods

Modifier and Type	Method and Description
static String	CHARSET()
static String	CLIENT_ERROR_BAD_FORMAT()
static byte[]	concat(byte[] a, byte[] b)
static int	CR()
static String	CRLF()
static byte[]	CRLFBytes()
static byte[]	DELETED()
static int	END_SIZE()
static byte[]	END()
static byte[]	ERROR()
static byte[]	EXISTS()
static String	extractString(ByteArrayOutputStream byteBuffer)
static int	LF()
static scala.math.BigInt	MAX_UNSIGNED_LONG()
static scala.math.BigInt	MIN_UNSIGNED()
static byte[]	NOT_FOUND()
static byte[]	NOT_STORED()
static byte[]	OK()
static int	readableBytes(org.jboss.netty.buffer.ChannelBuffer buffer)
static String	readDiscardedLine(org.jboss.netty.buffer.ChannelBuffer buffer)
static boolean	readElement(org.jboss.netty.buffer.ChannelBuffer buffer, OutputStream byteBuffer) In the particular case of Memcached, the end of operation/command is signaled by "\r\n" characters.
static scala.collection.Seq<String>	readSplitLine(org.jboss.netty.buffer.ChannelBuffer buffer)
static String	SERVER_ERROR()
static void	skipLine(org.jboss.netty.buffer.ChannelBuffer buffer)
static int	SP()
static byte[]	STORED()
static int	VALUE_SIZE()
static byte[]	VALUE()
static byte[]	ZERO()

Methods inherited from class java.lang.Object

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

Constructor Detail

TextProtocolUtil

public TextProtocolUtil()

Method Detail

CRLF

public static String CRLF()

CRLFBytes

public static byte[] CRLFBytes()

END

public static byte[] END()

END_SIZE

public static int END_SIZE()

DELETED

public static byte[] DELETED()

NOT_FOUND

public static byte[] NOT_FOUND()

EXISTS

public static byte[] EXISTS()

STORED

public static byte[] STORED()

NOT_STORED

public static byte[] NOT_STORED()

OK

public static byte[] OK()

ERROR

public static byte[] ERROR()

CLIENT_ERROR_BAD_FORMAT

public static String CLIENT_ERROR_BAD_FORMAT()

SERVER_ERROR

public static String SERVER_ERROR()

VALUE

public static byte[] VALUE()

VALUE_SIZE

public static int VALUE_SIZE()

ZERO

public static byte[] ZERO()

SP

public static int SP()

CR

public static int CR()

LF

public static int LF()

MAX_UNSIGNED_LONG

public static scala.math.BigInt MAX_UNSIGNED_LONG()

MIN_UNSIGNED

public static scala.math.BigInt MIN_UNSIGNED()

CHARSET

public static String CHARSET()

readElement

public static boolean readElement(org.jboss.netty.buffer.ChannelBuffer buffer,
                  OutputStream byteBuffer)

In the particular case of Memcached, the end of operation/command is signaled by "\r\n" characters. So, if end of operation is found, this method would return true. On the contrary, if space was found instead of end of operation character, then it'd return the element and false.

extractString

public static String extractString(ByteArrayOutputStream byteBuffer)

readDiscardedLine

public static String readDiscardedLine(org.jboss.netty.buffer.ChannelBuffer buffer)

readableBytes

public static int readableBytes(org.jboss.netty.buffer.ChannelBuffer buffer)

skipLine

public static void skipLine(org.jboss.netty.buffer.ChannelBuffer buffer)

concat

public static byte[] concat(byte[] a,
            byte[] b)

readSplitLine

public static scala.collection.Seq<String> readSplitLine(org.jboss.netty.buffer.ChannelBuffer buffer)