Grizzly NIO 5.0.2 · org.glassfish.grizzly.nio.tmpselectors.TemporarySelectorReader

Modifier and Type	Field and Description
private static final int	DEFAULT_BUFFER_SIZE
protected final TemporarySelectorsEnabledTransport	transport

Access	Constructor and Description
public	TemporarySelectorReader(TemporarySelectorsEnabledTransport transport)

Method Summary

Modifier and Type	Method and Description
protected Buffer	acquireBuffer(Connection<L> connection)
private static void	failure(final Throwable failure, final CompletionHandler<ReadResult<Buffer, SocketAddress>> completionHandler)
public TemporarySelectorsEnabledTransport	getTransport()
public void	read(Connection<SocketAddress> connection, Buffer message, CompletionHandler<ReadResult<Buffer, SocketAddress>> completionHandler, Interceptor<ReadResult<K, L>> interceptor) Implements org.glassfish.grizzly.Reader.read. Method reads data to the `buffer`.
public void	Returns: `Future`, using which it's possible to check the result read(final Connection<SocketAddress> the `Connection` to read from connection, final Buffer the message, where data will be read message, final CompletionHandler<ReadResult<Buffer, SocketAddress>> `CompletionHandler`, which will get notified, when read will be completed completionHandler, final Interceptor<ReadResult<K, L>> intercept to invoke on operation interceptor, final long operation timeout value value timeout, final TimeUnit the timeout unit timeunit) Method reads data to the `message`.
private int	read0(NIOConnection connection, Interceptor<ReadResult<K, L>> interceptor, ReadResult<Buffer, SocketAddress> currentResult, Buffer buffer, long timeout, TimeUnit timeunit)
protected final int	read0(final NIOConnection connection, final ReadResult<Buffer, SocketAddress> currentResult, final Buffer buffer, final long timeout, final TimeUnit timeunit)
protected abstract int	readNow0(NIOConnection connection, Buffer buffer, ReadResult<Buffer, SocketAddress> currentResult)

Inherited from org.glassfish.grizzly.AbstractReader:: read read read

DEFAULT_BUFFER_SIZE	back to summary
private static final int DEFAULT_BUFFER_SIZE

transport	back to summary
protected final TemporarySelectorsEnabledTransport transport

TemporarySelectorReader	back to summary
public TemporarySelectorReader(TemporarySelectorsEnabledTransport transport)

Method Detail

acquireBuffer	back to summary
protected Buffer acquireBuffer(Connection<L> connection)

failure	back to summary
private static void failure(final Throwable failure, final CompletionHandler<ReadResult<Buffer, SocketAddress>> completionHandler)

getTransport	back to summary
public TemporarySelectorsEnabledTransport getTransport()

read back to summary

read	back to summary
public void read(Connection<SocketAddress> connection, Buffer message, CompletionHandler<ReadResult<Buffer, SocketAddress>> completionHandler, Interceptor<ReadResult<K, L>> interceptor) Implements org.glassfish.grizzly.Reader.read. Doc from org.glassfish.grizzly.Reader.read. Method reads data to the `buffer`. Annotations @Override

public void read(Connection<SocketAddress> connection, Buffer message, CompletionHandler<ReadResult<Buffer, SocketAddress>> completionHandler, Interceptor<ReadResult<K, L>> interceptor)

Implements org.glassfish.grizzly.Reader.read.

Doc from org.glassfish.grizzly.Reader.read.

Method reads data to the buffer.

Annotations

@Override

read back to summary

read	back to summary
public void read(final Connection<SocketAddress> connection, final Buffer message, final CompletionHandler<ReadResult<Buffer, SocketAddress>> completionHandler, final Interceptor<ReadResult<K, L>> interceptor, final long timeout, final TimeUnit timeunit) Method reads data to the `message`. Parameters connection:Connection<SocketAddress> the `Connection` to read from message:Buffer the message, where data will be read completionHandler:CompletionHandler<ReadResult<Buffer, SocketAddress>> `CompletionHandler`, which will get notified, when read will be completed interceptor:Interceptor<ReadResult<K, L>> intercept to invoke on operation timeout:long operation timeout value value timeunit:TimeUnit the timeout unit Returns:void `Future`, using which it's possible to check the result

public void read(final Connection<SocketAddress> connection, final Buffer message, final CompletionHandler<ReadResult<Buffer, SocketAddress>> completionHandler, final Interceptor<ReadResult<K, L>> interceptor, final long timeout, final TimeUnit timeunit)

Method reads data to the message.

Parameters

connection:Connection<SocketAddress>: the Connection to read from
message:Buffer: the message, where data will be read
completionHandler:CompletionHandler<ReadResult<Buffer, SocketAddress>>: CompletionHandler, which will get notified, when read will be completed
interceptor:Interceptor<ReadResult<K, L>>: intercept to invoke on operation
timeout:long: operation timeout value value
timeunit:TimeUnit: the timeout unit

Returns:void

Future, using which it's possible to check the result

read0	back to summary
private int read0(NIOConnection connection, Interceptor<ReadResult<K, L>> interceptor, ReadResult<Buffer, SocketAddress> currentResult, Buffer buffer, long timeout, TimeUnit timeunit) throws IOException

read0	back to summary
protected final int read0(final NIOConnection connection, final ReadResult<Buffer, SocketAddress> currentResult, final Buffer buffer, final long timeout, final TimeUnit timeunit) throws IOException

readNow0	back to summary
protected abstract int readNow0(NIOConnection connection, Buffer buffer, ReadResult<Buffer, SocketAddress> currentResult) throws IOException

public abstract Class TemporarySelectorReader

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail