com.goldencode.p2j.net

Class NIOSslSocket

java.lang.Object

com.goldencode.p2j.net.NetSocketBase

com.goldencode.p2j.net.NIONetSocketBase

com.goldencode.p2j.net.NIOSslSocket

All Implemented Interfaces:

NetSocket

class NIOSslSocket
extends NIONetSocketBase

Implements NetSocket operations which are specific for SSL channels

Nested Class Summary

Nested classes/interfaces inherited from interface com.goldencode.p2j.net.NetSocket

NetSocket.NetSocketFactory

Field Summary

Fields

Modifier and Type	Field and Description
protected ByteArrayHandler	byteArrayHandler Input byte stream splitter
protected javax.net.ssl.SSLEngine	engine SSLEngine
protected static CentralLogger	LOG Logger
protected java.util.concurrent.BlockingQueue<byte[]>	queue Input chunks' queue
protected SSL	ssl SSL Provider
protected java.util.concurrent.ExecutorService	sslFsmWorkers Auxiliary executor service
protected static java.util.concurrent.atomic.AtomicInteger	THREAD_COUNT

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

channel

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

TRACE_LM

Fields inherited from interface com.goldencode.p2j.net.NetSocket

BUF_SIZE, FACTORY, handshakeTimeout

Constructor Summary

Constructors

Constructor and Description
NIOSslSocket(javax.net.ssl.SSLEngine engine, java.nio.channels.SocketChannel channel) Constructor

Method Summary

Modifier and Type	Method and Description
void	close() Closes the socket.
protected int	getMaxMessageSize() Get maximal message size
javax.net.ssl.SSLSession	getSession() Gets the SSL session.
protected byte[]	readFully() Read next data chunk from the channel
protected void	write(java.nio.ByteBuffer bb) Send the data to the channel

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

getLocalAddr, getLocalSockAddr, getRemoteAddr, getRemoteSockAddr, isClosed, read, readBoolean, readBytes, readInt, readUTF, write, writeBoolean, writeBytes, writeInt, writeUTF

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

addSessionListener, getSessionListeners

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.goldencode.p2j.net.NetSocket

addSessionListener, flush, getSessionListeners, tracef, traceln

Field Detail

LOG

protected static final CentralLogger LOG

Logger

THREAD_COUNT

protected static final java.util.concurrent.atomic.AtomicInteger THREAD_COUNT

engine

protected final javax.net.ssl.SSLEngine engine

SSLEngine

ssl

protected final SSL ssl

SSL Provider

queue

protected final java.util.concurrent.BlockingQueue<byte[]> queue

Input chunks' queue

sslFsmWorkers

protected final java.util.concurrent.ExecutorService sslFsmWorkers

Auxiliary executor service

byteArrayHandler

protected final ByteArrayHandler byteArrayHandler

Input byte stream splitter

Constructor Detail

NIOSslSocket

public NIOSslSocket(javax.net.ssl.SSLEngine engine,
                    java.nio.channels.SocketChannel channel)
             throws java.io.IOException

Constructor

Parameters:

engine - SSL Engine

channel - underlying SocketChannel

Throws:

java.io.IOException - on error

Method Detail

close

public void close()

Closes the socket.

Specified by:

close in interface NetSocket

Overrides:

close in class NIONetSocketBase

getSession

public javax.net.ssl.SSLSession getSession()

Gets the SSL session.

Returns:

The SSL session or null if the socket is not secure.

write

protected void write(java.nio.ByteBuffer bb)
              throws java.io.IOException

Send the data to the channel

Specified by:

write in class NIONetSocketBase

Parameters:

bb - data to be sent

Throws:

java.io.IOException - on error

readFully

protected byte[] readFully()
                    throws java.io.IOException,
                           java.io.EOFException

Read next data chunk from the channel

Specified by:

readFully in class NIONetSocketBase

Returns:

next data chunk

Throws:

java.io.IOException - on error

java.io.EOFException - if no data can be read

getMaxMessageSize

protected int getMaxMessageSize()

Get maximal message size

Overrides:

getMaxMessageSize in class NIONetSocketBase

Returns:

maximal message size;