com.goldencode.p2j.net

Class BlockingSSL

java.lang.Object

com.goldencode.p2j.net.SSL

com.goldencode.p2j.net.BlockingSSL

All Implemented Interfaces:

java.lang.Runnable

public abstract class BlockingSSL
extends SSL

Implements SSL support over the SocketChannel.

Field Summary

Fields

Modifier and Type	Field and Description
protected java.nio.ByteBuffer	buffer Input buffer
protected java.nio.channels.SocketChannel	channel Underlying SocketChannel
protected static CentralLogger	LOG Logger

Fields inherited from class com.goldencode.p2j.net.SSL

AFTER_HANDSHAKE, appBufferMax, checkSeqNo, cSeqNo, done, engine, fsmWorkers, hex, incomingBuffers, inpGuard, inpSeqNo, inpUnwrap, inpWrap, netBufferMax, outGuard, outSeqNo, outUnwrap, outWrap

Constructor Summary

Constructors

Constructor and Description
BlockingSSL(java.nio.channels.SocketChannel channel, javax.net.ssl.SSLEngine engine, java.util.concurrent.ExecutorService fsmWorkers) Constructor

Method Summary

Modifier and Type	Method and Description
void	checkInput() Check if more input is available for processing
void	onClosed() Called on the SSL session close
void	onFailure(java.lang.Exception ex) Report the handshake failure
void	onOutput(java.nio.ByteBuffer encrypted) Process the next portion of the encrypted output
private boolean	processInput() Try to get new portion of the input
void	send(java.nio.ByteBuffer data) Process the next portion of the output

Methods inherited from class com.goldencode.p2j.net.SSL

getMaxMessageSize, handshakeDone, log, log, nextChunk, notify, onInput, onSuccess, run, tryLock

Methods inherited from class java.lang.Object

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

Field Detail

LOG

protected static final CentralLogger LOG

Logger

channel

protected final java.nio.channels.SocketChannel channel

Underlying SocketChannel

buffer

protected final java.nio.ByteBuffer buffer

Input buffer

Constructor Detail

BlockingSSL

public BlockingSSL(java.nio.channels.SocketChannel channel,
                   javax.net.ssl.SSLEngine engine,
                   java.util.concurrent.ExecutorService fsmWorkers)

Constructor

Parameters:

channel - underlying SocketChannel

engine - the SSLEngine instance

fsmWorkers - ExecutorService for internal tasks' execution

Method Detail

checkInput

public void checkInput()
                throws java.io.IOException

Check if more input is available for processing

Specified by:

checkInput in class SSL

Throws:

java.io.IOException - on network failure

onOutput

public void onOutput(java.nio.ByteBuffer encrypted)

Process the next portion of the encrypted output

Specified by:

onOutput in class SSL

Parameters:

encrypted - the next portion of the encrypted output

onClosed

public void onClosed()

Called on the SSL session close

Specified by:

onClosed in class SSL

send

public void send(java.nio.ByteBuffer data)

Process the next portion of the output

Overrides:

send in class SSL

Parameters:

data - the next portion of the output

onFailure

public void onFailure(java.lang.Exception ex)

Report the handshake failure

Specified by:

onFailure in class SSL

Parameters:

ex - The exception which caused the failure

processInput

private boolean processInput()

Try to get new portion of the input

Returns:

true if more input is available