com.grey.naf.reactor

Class CM_Stream

java.lang.Object

com.grey.naf.reactor.ChannelMonitor

com.grey.naf.reactor.CM_Stream

Direct Known Subclasses:

CM_TCP

public abstract class CM_Stream
extends ChannelMonitor

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	CM_Stream.BrokenPipeException

Constructor Summary

Constructors

Constructor and Description
CM_Stream(Dispatcher d, BufferSpec rbufspec, BufferSpec wbufspec)

Method Summary

Modifier and Type	Method and Description
protected void	disconnectLingerDone(boolean ok, CharSequence info, Throwable ex)
protected X509Certificate	getPeerCertificate()
protected Certificate[]	getPeerChain()
protected IOExecReaderStream	getReader()
protected SSLConfig	getSSLConfig()
protected IOExecWriter	getWriter()
protected abstract void	ioReceived(ByteArrayRef rcvdata)
boolean	isBrokenPipe()
boolean	isConnected()
protected void	registerConnectedChannel(SelectableChannel chan, boolean takeOwnership)
protected void	startedSSL()
void	startSSL()
protected boolean	usingSSL()

Methods inherited from class com.grey.naf.reactor.ChannelMonitor

disconnect, disconnect, dumpAppState, dumpState, eventError, getChannel, getCMID, getDatagramChannel, getDispatcher, getLogger, getReaper, getSocketChannel, getStartTime, getSystemTime, initChannelMonitor, ioDisconnected, setReaper, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

CM_Stream

public CM_Stream(Dispatcher d,
                 BufferSpec rbufspec,
                 BufferSpec wbufspec)

Method Detail

ioReceived

protected abstract void ioReceived(ByteArrayRef rcvdata)
                            throws IOException

Throws:

IOException

getSSLConfig

protected SSLConfig getSSLConfig()

startedSSL

protected void startedSSL()
                   throws IOException

Throws:

IOException

usingSSL

protected boolean usingSSL()

getPeerChain

protected Certificate[] getPeerChain()

getPeerCertificate

protected X509Certificate getPeerCertificate()

isConnected

public boolean isConnected()

isBrokenPipe

public boolean isBrokenPipe()

getReader

protected IOExecReaderStream getReader()

getWriter

protected IOExecWriter getWriter()

disconnectLingerDone

protected void disconnectLingerDone(boolean ok,
                                    CharSequence info,
                                    Throwable ex)

registerConnectedChannel

protected void registerConnectedChannel(SelectableChannel chan,
                                        boolean takeOwnership)
                                 throws IOException

Throws:

IOException

startSSL

public void startSSL()
              throws IOException

Throws:

IOException