Package one.nio.rpc

Class RpcPacket

java.lang.Object

one.nio.rpc.RpcPacket

class RpcPacket
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field	Description
private static int	ERROR_PACKET_SIZE
(package private) static int	HTTP_GET
(package private) static int	HTTP_HEAD
(package private) static int	HTTP_POST
private static org.slf4j.Logger	log
(package private) static int	STREAM_HEADER
(package private) static byte[]	STREAM_HEADER_ARRAY
private static int	WARN_PACKET_SIZE

Constructor Summary

Constructors

Constructor	Description
RpcPacket()

Method Summary

Modifier and Type	Method	Description
(package private) static void	checkReadSize(int size, Socket socket)
(package private) static void	checkWriteSize(int size)
(package private) static int	getSize(byte[] buffer)
(package private) static boolean	isHttpHeader(int header)

Methods inherited from class java.lang.Object

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

Field Detail

log

private static final org.slf4j.Logger log

WARN_PACKET_SIZE

private static final int WARN_PACKET_SIZE

See Also:

Constant Field Values

ERROR_PACKET_SIZE

private static final int ERROR_PACKET_SIZE

See Also:

Constant Field Values

STREAM_HEADER

static final int STREAM_HEADER

See Also:

Constant Field Values

STREAM_HEADER_ARRAY

static final byte[] STREAM_HEADER_ARRAY

HTTP_GET

static final int HTTP_GET

See Also:

Constant Field Values

HTTP_POST

static final int HTTP_POST

See Also:

Constant Field Values

HTTP_HEAD

static final int HTTP_HEAD

See Also:

Constant Field Values

Constructor Detail

RpcPacket

RpcPacket()

Method Detail

isHttpHeader

static boolean isHttpHeader(int header)

getSize

static int getSize(byte[] buffer)

checkWriteSize

static void checkWriteSize(int size)
                    throws java.io.IOException

Throws:

java.io.IOException

checkReadSize

static void checkReadSize(int size,
                          Socket socket)
                   throws java.io.IOException

Throws:

java.io.IOException