org.neo4j.com

Class Protocol

java.lang.Object

org.neo4j.com.Protocol

Direct Known Subclasses:

Protocol214

public abstract class Protocol
extends Object

Contains the logic for serializing requests and deserializing responses. Still missing the inverse, serializing responses and deserializing requests, which is hard-coded in the server class. That should be moved over eventually.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	Protocol.FileStreamsDeserializer210
static class	Protocol.FileStreamsDeserializer310
static class	Protocol.TransactionRepresentationDeserializer
static class	Protocol.TransactionSerializer

Field Summary

Fields

Modifier and Type	Field and Description
static int	DEFAULT_FRAME_LENGTH
static Serializer	EMPTY_SERIALIZER
static Deserializer<Integer>	INTEGER_DESERIALIZER
static ObjectSerializer<Integer>	INTEGER_SERIALIZER
static ObjectSerializer<Long>	LONG_SERIALIZER
static int	MEGA
static Deserializer<Void>	VOID_DESERIALIZER
static ObjectSerializer<Void>	VOID_SERIALIZER

Constructor Summary

Constructors

Constructor and Description
Protocol(int chunkSize, byte applicationProtocolVersion, byte internalProtocolVersion)

Method Summary

Modifier and Type	Method and Description
static void	addLengthFieldPipes(org.jboss.netty.channel.ChannelPipeline pipeline, int frameLength)
static void	assertChunkSizeIsWithinFrameSize(int chunkSize, int frameLength)
<PAYLOAD> Response<PAYLOAD>	deserializeResponse(org.jboss.netty.handler.queue.BlockingReadHandler<org.jboss.netty.buffer.ChannelBuffer> reader, ByteBuffer input, long timeout, Deserializer<PAYLOAD> payloadDeserializer, ResourceReleaser channelReleaser, org.neo4j.kernel.impl.transaction.log.entry.LogEntryReader<org.neo4j.kernel.impl.transaction.log.ReadableClosablePositionAwareChannel> entryReader)
static boolean	readBoolean(org.jboss.netty.buffer.ChannelBuffer buffer)
static String	readString(org.jboss.netty.buffer.ChannelBuffer buffer)
static String	readString(org.jboss.netty.buffer.ChannelBuffer buffer, int length)
void	serializeRequest(org.jboss.netty.channel.Channel channel, org.jboss.netty.buffer.ChannelBuffer buffer, RequestType<?> type, RequestContext ctx, Serializer payload)
static void	writeChars(org.jboss.netty.buffer.ChannelBuffer buffer, char[] chars)
static void	writeString(org.jboss.netty.buffer.ChannelBuffer buffer, String name)

Methods inherited from class java.lang.Object

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

Field Detail

MEGA

public static final int MEGA

See Also:

Constant Field Values

DEFAULT_FRAME_LENGTH

public static final int DEFAULT_FRAME_LENGTH

See Also:

Constant Field Values

INTEGER_SERIALIZER

public static final ObjectSerializer<Integer> INTEGER_SERIALIZER

LONG_SERIALIZER

public static final ObjectSerializer<Long> LONG_SERIALIZER

VOID_SERIALIZER

public static final ObjectSerializer<Void> VOID_SERIALIZER

INTEGER_DESERIALIZER

public static final Deserializer<Integer> INTEGER_DESERIALIZER

VOID_DESERIALIZER

public static final Deserializer<Void> VOID_DESERIALIZER

EMPTY_SERIALIZER

public static final Serializer EMPTY_SERIALIZER

Constructor Detail

Protocol

public Protocol(int chunkSize,
                byte applicationProtocolVersion,
                byte internalProtocolVersion)

Method Detail

addLengthFieldPipes

public static void addLengthFieldPipes(org.jboss.netty.channel.ChannelPipeline pipeline,
                                       int frameLength)

writeString

public static void writeString(org.jboss.netty.buffer.ChannelBuffer buffer,
                               String name)

writeChars

public static void writeChars(org.jboss.netty.buffer.ChannelBuffer buffer,
                              char[] chars)

readString

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

readBoolean

public static boolean readBoolean(org.jboss.netty.buffer.ChannelBuffer buffer)

readString

public static String readString(org.jboss.netty.buffer.ChannelBuffer buffer,
                                int length)

assertChunkSizeIsWithinFrameSize

public static void assertChunkSizeIsWithinFrameSize(int chunkSize,
                                                    int frameLength)

serializeRequest

public void serializeRequest(org.jboss.netty.channel.Channel channel,
                             org.jboss.netty.buffer.ChannelBuffer buffer,
                             RequestType<?> type,
                             RequestContext ctx,
                             Serializer payload)
                      throws IOException

Throws:

IOException

deserializeResponse

public <PAYLOAD> Response<PAYLOAD> deserializeResponse(org.jboss.netty.handler.queue.BlockingReadHandler<org.jboss.netty.buffer.ChannelBuffer> reader,
                                                       ByteBuffer input,
                                                       long timeout,
                                                       Deserializer<PAYLOAD> payloadDeserializer,
                                                       ResourceReleaser channelReleaser,
                                                       org.neo4j.kernel.impl.transaction.log.entry.LogEntryReader<org.neo4j.kernel.impl.transaction.log.ReadableClosablePositionAwareChannel> entryReader)
                                                throws IOException

Throws:

IOException