Package org.glassfish.grizzly.nio.tmpselectors

Class TemporarySelectorReader

java.lang.Object

org.glassfish.grizzly.AbstractReader<java.net.SocketAddress>

org.glassfish.grizzly.nio.tmpselectors.TemporarySelectorReader

All Implemented Interfaces:

Reader<java.net.SocketAddress>

Direct Known Subclasses:

TCPNIOTemporarySelectorReader, UDPNIOTemporarySelectorReader

public abstract class TemporarySelectorReader
extends AbstractReader<java.net.SocketAddress>

Author:

oleksiys

Field Summary

Fields

Modifier and Type	Field	Description
protected TemporarySelectorsEnabledTransport	transport

Fields inherited from interface org.glassfish.grizzly.Reader

COMPLETE_EVENT, INCOMPLETE_EVENT, READ_EVENT

Constructor Summary

Constructors

Constructor	Description
TemporarySelectorReader(TemporarySelectorsEnabledTransport transport)

Method Summary

Modifier and Type	Method	Description
protected Buffer	acquireBuffer(Connection connection)
TemporarySelectorsEnabledTransport	getTransport()
void	read(Connection<java.net.SocketAddress> connection, Buffer message, CompletionHandler<ReadResult<Buffer,java.net.SocketAddress>> completionHandler, Interceptor<ReadResult> interceptor)	Method reads data to the buffer.
void	read(Connection<java.net.SocketAddress> connection, Buffer message, CompletionHandler<ReadResult<Buffer,java.net.SocketAddress>> completionHandler, Interceptor<ReadResult> interceptor, long timeout, java.util.concurrent.TimeUnit timeunit)	Method reads data to the message.
protected int	read0(NIOConnection connection, ReadResult<Buffer,java.net.SocketAddress> currentResult, Buffer buffer, long timeout, java.util.concurrent.TimeUnit timeunit)
protected abstract int	readNow0(NIOConnection connection, Buffer buffer, ReadResult<Buffer,java.net.SocketAddress> currentResult)

Methods inherited from class org.glassfish.grizzly.AbstractReader

read, read, read

Methods inherited from class java.lang.Object

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

Field Detail

transport

protected final TemporarySelectorsEnabledTransport transport

Constructor Detail

TemporarySelectorReader

public TemporarySelectorReader(TemporarySelectorsEnabledTransport transport)

Method Detail

read

public void read(Connection<java.net.SocketAddress> connection,
                 Buffer message,
                 CompletionHandler<ReadResult<Buffer,java.net.SocketAddress>> completionHandler,
                 Interceptor<ReadResult> interceptor)

Description copied from interface: Reader

Method reads data to the buffer.

Parameters:

connection - the Connection to read from

message - the Buffer to which data will be read

completionHandler - CompletionHandler, which will get notified, when read will be completed

interceptor - Interceptor, which will be able to intercept control each time new portion of a data was read to a buffer. The interceptor can decide, whether asynchronous read is completed or not, or provide other processing instructions.

read

public void read(Connection<java.net.SocketAddress> connection,
                 Buffer message,
                 CompletionHandler<ReadResult<Buffer,java.net.SocketAddress>> completionHandler,
                 Interceptor<ReadResult> interceptor,
                 long timeout,
                 java.util.concurrent.TimeUnit timeunit)

Method reads data to the message.

Parameters:

connection - the Connection to read from

message - the message, where data will be read

completionHandler - CompletionHandler, which will get notified, when read will be completed

interceptor - intercept to invoke on operation

timeout - operation timeout value value

timeunit - the timeout unit

Throws:

java.io.IOException

read0

protected final int read0(NIOConnection connection,
                          ReadResult<Buffer,java.net.SocketAddress> currentResult,
                          Buffer buffer,
                          long timeout,
                          java.util.concurrent.TimeUnit timeunit)
                   throws java.io.IOException

Throws:

java.io.IOException

readNow0

protected abstract int readNow0(NIOConnection connection,
                                Buffer buffer,
                                ReadResult<Buffer,java.net.SocketAddress> currentResult)
                         throws java.io.IOException

Throws:

java.io.IOException

acquireBuffer

protected Buffer acquireBuffer(Connection connection)

getTransport

public TemporarySelectorsEnabledTransport getTransport()