org.restlet.ext.nio.internal.channel

Class ReadableSslChannel

java.lang.Object

org.restlet.ext.nio.internal.channel.WrapperChannel<T>

org.restlet.ext.nio.internal.channel.WrapperSelectionChannel<T>

org.restlet.ext.nio.internal.channel.BufferedSelectionChannel<ReadableSelectionChannel>

org.restlet.ext.nio.internal.channel.ReadableBufferedChannel

org.restlet.ext.nio.internal.channel.ReadableSslChannel

All Implemented Interfaces:

Closeable, AutoCloseable, Channel, ReadableByteChannel, BlockableChannel, ReadableSelectionChannel, SelectionChannel, BufferProcessor, CompletionListener, TasksListener

public class ReadableSslChannel
extends ReadableBufferedChannel
implements TasksListener

SSL byte channel that unwraps all read data using the SSL/TLS protocols. It is important to implement SelectionChannel as some framework classes rely on this down the processing chain.

Author:

Jerome Louvel

Constructor Summary

Constructors

Constructor and Description
ReadableSslChannel(ReadableSelectionChannel source, SslConnection<?> connection, WakeupListener wakeupListener) Constructor.

Method Summary

Modifier and Type	Method and Description
protected SslConnection<?>	getConnection() Returns the parent SSL connection.
void	onCompleted() Callback method invoked upon delegated tasks completion.
int	onDrain(Buffer buffer, int maxDrained, Object... args) Drains the byte buffer.
void	postProcess(int drained) Does nothing by default.

Methods inherited from class org.restlet.ext.nio.internal.channel.ReadableBufferedChannel

couldDrain, couldFill, isEndReached, onFill, onMessageCompleted, read, setEndReached

Methods inherited from class org.restlet.ext.nio.internal.channel.BufferedSelectionChannel

canLoop, close, getBuffer, onFillEof, preProcess

Methods inherited from class org.restlet.ext.nio.internal.channel.WrapperSelectionChannel

getRegistration, isBlocking, setRegistration, toString

Methods inherited from class org.restlet.ext.nio.internal.channel.WrapperChannel

getWrappedChannel, isOpen

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.restlet.engine.io.SelectionChannel

getRegistration

Methods inherited from interface org.restlet.engine.io.BlockableChannel

isBlocking

Methods inherited from interface java.nio.channels.Channel

close, isOpen

Constructor Detail

ReadableSslChannel

public ReadableSslChannel(ReadableSelectionChannel source,
                          SslConnection<?> connection,
                          WakeupListener wakeupListener)

Constructor.

Parameters:

source - The source channel.

connection - The parent SSL connection.

wakeupListener - The wakeup listener that will be notified.

Method Detail

getConnection

protected SslConnection<?> getConnection()

Returns the parent SSL connection.

Returns:

The parent SSL connection.

onCompleted

public void onCompleted()

Callback method invoked upon delegated tasks completion.

Specified by:

onCompleted in interface TasksListener

onDrain

public int onDrain(Buffer buffer,
                   int maxDrained,
                   Object... args)
            throws IOException

Drains the byte buffer. By default, it decrypts the SSL data and copies as many byte as possible to the target buffer, with no modification.

Specified by:

onDrain in interface BufferProcessor

Overrides:

onDrain in class ReadableBufferedChannel

Parameters:

buffer - The IO buffer to drain.

maxDrained - The maximum number of bytes drained by this call.

args - The optional arguments to pass back to the callbacks.

Returns:

The number of bytes drained.

Throws:

IOException

postProcess

public void postProcess(int drained)
                 throws IOException

Description copied from class: BufferedSelectionChannel

Does nothing by default.

Specified by:

postProcess in interface BufferProcessor

Overrides:

postProcess in class BufferedSelectionChannel<ReadableSelectionChannel>

Parameters:

drained - The number of bytes drained or -1 if the filling source has ended.

Throws:

IOException