com.gigaspaces.lrmi.nio

Class Reader

java.lang.Object

com.gigaspaces.lrmi.nio.Reader

public class Reader
extends Object

A Reader is capable of reading Request Packets and Reply Packets from a Socket Channel. An NIO Client Peer uses an instance of a Reader to read Reply Packets while an NIO Server uses an instance of a Reader to read Request Packets.

Since:

4.0

Author:

Igor Goldenberg

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	Reader.Context
static class	Reader.ProtocolValidationContext

Field Summary

Fields

Modifier and Type	Field and Description
static long	SUSPICIOUS_THRESHOLD

Constructor Summary

Constructors

Constructor and Description
Reader(SocketChannel sockChannel, int slowConsumerRetries)
Reader(SocketChannel sockChannel, SystemRequestHandler systemRequestHandler)

Method Summary

Modifier and Type	Method and Description
void	closeContext()
long	getReceivedTraffic()
static LongAdder	getReceivedTrafficCounter()
ByteBuffer	readBytesFromChannelBlocking(boolean createNewBuffer, int slowConsumerLatency, int sizeLimit)
String	readProtocolValidationHeader(Reader.ProtocolValidationContext context)
<T> ReplyPacket<T>	readReply()
<T> ReplyPacket<T>	readReply(boolean createNewBuffer)
<T> ReplyPacket<T>	readReply(int slowConsumerTimeout, int sizeLimit)
MarshalInputStream	readReply(Reader.Context ctx)
<T> void	readReply(ReplyPacket<T> packet)
RequestPacket	readRequest()
RequestPacket	readRequest(boolean createNewBuffer)
MarshalInputStream	readRequest(Reader.Context ctx)
void	resetContext()
void	setFilterManager(IOFilterManager filterManager)
<T> ReplyPacket<T>	unmarshallReply(MarshalInputStream stream)
RequestPacket	unmarshallRequest(MarshalInputStream stream)

Methods inherited from class java.lang.Object

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

Field Detail

SUSPICIOUS_THRESHOLD

public static final long SUSPICIOUS_THRESHOLD

Constructor Detail

Reader

public Reader(SocketChannel sockChannel,
              int slowConsumerRetries)

Reader

public Reader(SocketChannel sockChannel,
              SystemRequestHandler systemRequestHandler)

Method Detail

getReceivedTrafficCounter

public static LongAdder getReceivedTrafficCounter()

readRequest

public MarshalInputStream readRequest(Reader.Context ctx)
                               throws IOException,
                                      IOFilterException

Throws:

IOException

IOFilterException

readRequest

public RequestPacket readRequest(boolean createNewBuffer)
                          throws IOException,
                                 ClassNotFoundException,
                                 IOFilterException

Throws:

IOException

ClassNotFoundException

IOFilterException

readRequest

public RequestPacket readRequest()
                          throws IOException,
                                 ClassNotFoundException,
                                 IOFilterException

Throws:

IOException

ClassNotFoundException

IOFilterException

readReply

public MarshalInputStream readReply(Reader.Context ctx)
                             throws IOException,
                                    IOFilterException

Throws:

IOException

IOFilterException

readReply

public <T> ReplyPacket<T> readReply(boolean createNewBuffer)
                             throws IOException,
                                    ClassNotFoundException,
                                    IOFilterException

Throws:

IOException

ClassNotFoundException

IOFilterException

readReply

public <T> ReplyPacket<T> readReply()
                             throws IOException,
                                    ClassNotFoundException,
                                    IOFilterException

Throws:

IOException

ClassNotFoundException

IOFilterException

readReply

public <T> void readReply(ReplyPacket<T> packet)
                   throws IOException,
                          ClassNotFoundException,
                          IOFilterException

Throws:

IOException

ClassNotFoundException

IOFilterException

readReply

public <T> ReplyPacket<T> readReply(int slowConsumerTimeout,
                                    int sizeLimit)
                             throws IOException,
                                    ClassNotFoundException,
                                    IOFilterException

Throws:

IOException

ClassNotFoundException

IOFilterException

setFilterManager

public void setFilterManager(IOFilterManager filterManager)

readBytesFromChannelBlocking

public ByteBuffer readBytesFromChannelBlocking(boolean createNewBuffer,
                                               int slowConsumerLatency,
                                               int sizeLimit)
                                        throws IOException

Throws:

IOException

unmarshallRequest

public RequestPacket unmarshallRequest(MarshalInputStream stream)
                                throws ClassNotFoundException,
                                       NoSuchObjectException

Throws:

ClassNotFoundException

NoSuchObjectException

unmarshallReply

public <T> ReplyPacket<T> unmarshallReply(MarshalInputStream stream)
                                   throws ClassNotFoundException,
                                          NoSuchObjectException

Throws:

ClassNotFoundException

NoSuchObjectException

closeContext

public void closeContext()

resetContext

public void resetContext()

getReceivedTraffic

public long getReceivedTraffic()

readProtocolValidationHeader

public String readProtocolValidationHeader(Reader.ProtocolValidationContext context)
                                    throws IOException

Throws:

IOException