edu.umass.cs.nio

Class SSLDataProcessingWorker

java.lang.Object

edu.umass.cs.nio.SSLDataProcessingWorker

All Implemented Interfaces:

DataProcessingWorker, InterfaceMessageExtractor

public class SSLDataProcessingWorker
extends java.lang.Object
implements InterfaceMessageExtractor

Author:

arun This class does SSL wrap/unwrap functions respectively right before NIO performs an (unencrypted) outgoing network write and right after NIO receives (encrypted) incoming network reads. It is really not a "message extractor", just an InterfaceDataProcessingWorker + wrap functionality, but it implements InterfaceMessageExtractor so that it is easy for MessageNIOTransport to conduct its functions without worrying about whether NIOTransport.worker is InterfaceMessageExtractor or not. Nevertheless, this class can be used simply with NIOTransport for secure byte stream communication as InterfaceMessageExtractor is also an InterfaceDataProcessingWorker.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SSLDataProcessingWorker.SSL_MODES SSL modes supported.

Field Summary

Fields

Modifier and Type	Field and Description
protected SSLDataProcessingWorker.SSL_MODES	sslMode

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	SSLDataProcessingWorker(DataProcessingWorker worker, SSLDataProcessingWorker.SSL_MODES sslMode, java.lang.String myID)

Method Summary

Modifier and Type	Method and Description
void	addPacketDemultiplexer(AbstractPacketDemultiplexer<?> pd)
void	demultiplexMessage(java.lang.Object message)
java.lang.String	getMyID()
protected boolean	isHandshakeComplete(java.nio.channels.SocketChannel socketChannel)
protected void	poke()
void	precedePacketDemultiplexer(AbstractPacketDemultiplexer<?> pd)
void	processData(java.nio.channels.SocketChannel channel, java.nio.ByteBuffer encrypted)
void	processLocalMessage(java.net.InetSocketAddress sockAddr, byte[] msg)
protected boolean	register(java.nio.channels.SelectionKey key, boolean isClient)
protected void	remove(java.nio.channels.SelectionKey key)
protected SSLDataProcessingWorker	setHandshakeCallback(HandshakeCallback callback)
protected void	setMyID(java.lang.String id)
void	stop()
java.lang.String	toString()
protected int	wrap(java.nio.channels.SocketChannel channel, java.nio.ByteBuffer unencrypted)

Methods inherited from class java.lang.Object

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

Field Detail

sslMode

protected final SSLDataProcessingWorker.SSL_MODES sslMode

Constructor Detail

SSLDataProcessingWorker

protected SSLDataProcessingWorker(DataProcessingWorker worker,
                                  SSLDataProcessingWorker.SSL_MODES sslMode,
                                  java.lang.String myID)
                           throws java.security.NoSuchAlgorithmException,
                                  javax.net.ssl.SSLException

Parameters:

worker -

sslMode -

Throws:

java.security.NoSuchAlgorithmException

javax.net.ssl.SSLException

Method Detail

setHandshakeCallback

protected SSLDataProcessingWorker setHandshakeCallback(HandshakeCallback callback)

processData

public void processData(java.nio.channels.SocketChannel channel,
                        java.nio.ByteBuffer encrypted)

Specified by:

processData in interface DataProcessingWorker

Parameters:

channel - The socket channel on which the bytes were received.

encrypted - The bytes received.

wrap

protected int wrap(java.nio.channels.SocketChannel channel,
                   java.nio.ByteBuffer unencrypted)

isHandshakeComplete

protected boolean isHandshakeComplete(java.nio.channels.SocketChannel socketChannel)

register

protected boolean register(java.nio.channels.SelectionKey key,
                           boolean isClient)
                    throws java.io.IOException

Throws:

java.io.IOException

poke

protected void poke()

remove

protected void remove(java.nio.channels.SelectionKey key)

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

getMyID

public java.lang.String getMyID()

Returns:

My ID, primarily for logging purposes.

setMyID

protected void setMyID(java.lang.String id)

stop

public void stop()

Specified by:

stop in interface InterfaceMessageExtractor

addPacketDemultiplexer

public void addPacketDemultiplexer(AbstractPacketDemultiplexer<?> pd)

Specified by:

addPacketDemultiplexer in interface InterfaceMessageExtractor

precedePacketDemultiplexer

public void precedePacketDemultiplexer(AbstractPacketDemultiplexer<?> pd)

Specified by:

precedePacketDemultiplexer in interface InterfaceMessageExtractor

processLocalMessage

public void processLocalMessage(java.net.InetSocketAddress sockAddr,
                                byte[] msg)

Specified by:

processLocalMessage in interface InterfaceMessageExtractor

demultiplexMessage

public void demultiplexMessage(java.lang.Object message)

Specified by:

demultiplexMessage in interface DataProcessingWorker

Specified by:

demultiplexMessage in interface InterfaceMessageExtractor