org.fusesource.hawtdispatch.transport

Class SslProtocolCodec

java.lang.Object

org.fusesource.hawtdispatch.transport.SslProtocolCodec

All Implemented Interfaces:

ProtocolCodec, SecuredSession, WrappingProtocolCodec

public class SslProtocolCodec
extends java.lang.Object
implements WrappingProtocolCodec, SecuredSession

Implements the SSL protocol as a WrappingProtocolCodec. Useful for when you want to switch to the SSL protocol on a regular TCP Transport.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SslProtocolCodec.ClientAuth
class	SslProtocolCodec.SSLReadChannel
class	SslProtocolCodec.SSLWriteChannel

Nested classes/interfaces inherited from interface org.fusesource.hawtdispatch.transport.ProtocolCodec

ProtocolCodec.BufferState

Field Summary

Fields

Modifier and Type	Field and Description
private javax.net.ssl.SSLEngine	engine
(package private) int	lastReadSize
(package private) int	lastWriteSize
(package private) ProtocolCodec	next
private java.nio.ByteBuffer	readBuffer
private java.nio.channels.ReadableByteChannel	readChannel
(package private) long	readCounter
private java.nio.ByteBuffer	readOverflowBuffer
private boolean	readUnderflow
private javax.net.ssl.SSLContext	sslContext
(package private) SslProtocolCodec.SSLReadChannel	sslReadChannel
(package private) SslProtocolCodec.SSLWriteChannel	sslWriteChannel
(package private) Transport	transport
private java.nio.ByteBuffer	writeBuffer
private java.nio.channels.WritableByteChannel	writeChannel
(package private) long	writeCounter
private boolean	writeFlushing

Constructor Summary

Constructors

Constructor and Description
SslProtocolCodec()

Method Summary

Modifier and Type	Method and Description
SslProtocolCodec	client()
ProtocolCodec.BufferState	flush() Attempts to complete the previous write which did not complete.
boolean	full() Is the codec's buffer full?
long	getLastReadSize()
long	getLastWriteSize()
ProtocolCodec	getNext()
java.security.cert.X509Certificate[]	getPeerX509Certificates() Gets the X509Certificate associated withe the peer.
int	getReadBufferSize()
long	getReadCounter()
javax.net.ssl.SSLSession	getSSLSession()
int	getWriteBufferSize()
long	getWriteCounter()
void	handshake()
protected void	initializeEngine()
private void	initNext()
java.lang.Object	read() Non-blocking channel based decoding.
private int	secure_read(java.nio.ByteBuffer plain)
private int	secure_write(java.nio.ByteBuffer plain)
SslProtocolCodec	server(SslProtocolCodec.ClientAuth clientAuth)
void	setNext(ProtocolCodec next)
void	setSSLContext(javax.net.ssl.SSLContext ctx)
void	setTransport(Transport transport)
protected boolean	transportFlush()
void	unread(byte[] buffer) Pushes back a buffer as being unread.
ProtocolCodec.BufferState	write(java.lang.Object value) Non-blocking channel based encoding.

Methods inherited from class java.lang.Object

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

Field Detail

readChannel

private java.nio.channels.ReadableByteChannel readChannel

writeChannel

private java.nio.channels.WritableByteChannel writeChannel

sslContext

private javax.net.ssl.SSLContext sslContext

engine

private javax.net.ssl.SSLEngine engine

readBuffer

private java.nio.ByteBuffer readBuffer

readUnderflow

private boolean readUnderflow

writeBuffer

private java.nio.ByteBuffer writeBuffer

writeFlushing

private boolean writeFlushing

readOverflowBuffer

private java.nio.ByteBuffer readOverflowBuffer

transport

Transport transport

lastReadSize

int lastReadSize

lastWriteSize

int lastWriteSize

readCounter

long readCounter

writeCounter

long writeCounter

next

ProtocolCodec next

sslReadChannel

SslProtocolCodec.SSLReadChannel sslReadChannel

sslWriteChannel

SslProtocolCodec.SSLWriteChannel sslWriteChannel

Constructor Detail

SslProtocolCodec

public SslProtocolCodec()

Method Detail

getNext

public ProtocolCodec getNext()

Specified by:

getNext in interface WrappingProtocolCodec

setNext

public void setNext(ProtocolCodec next)

Specified by:

setNext in interface WrappingProtocolCodec

initNext

private void initNext()

setSSLContext

public void setSSLContext(javax.net.ssl.SSLContext ctx)

client

public SslProtocolCodec client()
                        throws java.lang.Exception

Throws:

java.lang.Exception

server

public SslProtocolCodec server(SslProtocolCodec.ClientAuth clientAuth)
                        throws java.lang.Exception

Throws:

java.lang.Exception

initializeEngine

protected void initializeEngine()
                         throws java.lang.Exception

Throws:

java.lang.Exception

getSSLSession

public javax.net.ssl.SSLSession getSSLSession()

getPeerX509Certificates

public java.security.cert.X509Certificate[] getPeerX509Certificates()

Description copied from interface: SecuredSession

Gets the X509Certificate associated withe the peer.

Specified by:

getPeerX509Certificates in interface SecuredSession

Returns:

setTransport

public void setTransport(Transport transport)

Specified by:

setTransport in interface ProtocolCodec

handshake

public void handshake()
               throws java.io.IOException

Throws:

java.io.IOException

transportFlush

protected boolean transportFlush()
                          throws java.io.IOException

Returns:

true if fully flushed.

Throws:

java.io.IOException

secure_read

private int secure_read(java.nio.ByteBuffer plain)
                 throws java.io.IOException

Throws:

java.io.IOException

secure_write

private int secure_write(java.nio.ByteBuffer plain)
                  throws java.io.IOException

Throws:

java.io.IOException

unread

public void unread(byte[] buffer)

Description copied from interface: ProtocolCodec

Pushes back a buffer as being unread.

Specified by:

unread in interface ProtocolCodec

read

public java.lang.Object read()
                      throws java.io.IOException

Description copied from interface: ProtocolCodec

Non-blocking channel based decoding.

Specified by:

read in interface ProtocolCodec

Returns:

Throws:

java.io.IOException

write

public ProtocolCodec.BufferState write(java.lang.Object value)
                                throws java.io.IOException

Description copied from interface: ProtocolCodec

Non-blocking channel based encoding.

Specified by:

write in interface ProtocolCodec

Returns:

true if the write completed.

Throws:

java.io.IOException

flush

public ProtocolCodec.BufferState flush()
                                throws java.io.IOException

Description copied from interface: ProtocolCodec

Attempts to complete the previous write which did not complete.

Specified by:

flush in interface ProtocolCodec

Returns:

Throws:

java.io.IOException

full

public boolean full()

Description copied from interface: ProtocolCodec

Is the codec's buffer full?

Specified by:

full in interface ProtocolCodec

Returns:

getWriteCounter

public long getWriteCounter()

Specified by:

getWriteCounter in interface ProtocolCodec

Returns:

The number of bytes written.

getLastWriteSize

public long getLastWriteSize()

Specified by:

getLastWriteSize in interface ProtocolCodec

Returns:

The number of bytes read in the last write io performed.

getReadCounter

public long getReadCounter()

Specified by:

getReadCounter in interface ProtocolCodec

Returns:

The number of bytes received.

getLastReadSize

public long getLastReadSize()

Specified by:

getLastReadSize in interface ProtocolCodec

Returns:

The number of bytes read in the last read io performed.

getReadBufferSize

public int getReadBufferSize()

Specified by:

getReadBufferSize in interface ProtocolCodec

getWriteBufferSize

public int getWriteBufferSize()

Specified by:

getWriteBufferSize in interface ProtocolCodec