Package jp.cssj.driver.ctip.v2

Class TLSSocketChannel

java.lang.Object

java.nio.channels.spi.AbstractInterruptibleChannel

java.nio.channels.SelectableChannel

jp.cssj.driver.ctip.v2.TLSSocketChannel

All Implemented Interfaces:

Closeable, AutoCloseable, ByteChannel, Channel, InterruptibleChannel, ReadableByteChannel, WritableByteChannel

public class TLSSocketChannel
extends SelectableChannel
implements ByteChannel

Nonblocking TLS transport. Waiting belongs to ChannelIO, never to an engine lock.

Field Summary

Fields

Modifier and Type	Field	Description
static final long	CLOSE_TIMEOUT
static final long	DEFAULT_CONNECT_TIMEOUT

Constructor Summary

Constructors

Constructor	Description
TLSSocketChannel(SocketChannel sc)

Method Summary

Modifier and Type	Method	Description
void	addWaiter(Selector selector)	ChannelIO wait registration also makes a direct TLS close wake its selectors.
Object	blockingLock()
SelectableChannel	configureBlocking(boolean block)
boolean	connect(SocketAddress remote)
boolean	connect(SocketAddress remote, String host, int port, long timeout)	Connects, then verifies the peer unless the caller asked not to.
boolean	flushOutbound()	Advance pending ciphertext and TLS control output without more application data.
boolean	hasPendingOutbound()
boolean	hasPlaintext()
protected void	implCloseChannel()
boolean	isBlocking()
boolean	isConnected()
boolean	isRegistered()
SelectionKey	keyFor(Selector selector)
SelectorProvider	provider()
int	read(ByteBuffer dst)
SelectionKey	register(Selector selector, int ops, Object attachment)
void	removeWaiter(Selector selector)
int	requiredOps()
int	requiredWriteOps()
int	validOps()
int	write(ByteBuffer src)

Methods inherited from class java.nio.channels.SelectableChannel

register

Methods inherited from class java.nio.channels.spi.AbstractInterruptibleChannel

begin, close, end, isOpen

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.nio.channels.Channel

isOpen

Field Details

DEFAULT_CONNECT_TIMEOUT

public static final long DEFAULT_CONNECT_TIMEOUT

See Also:

• Constant Field Values

CLOSE_TIMEOUT

public static final long CLOSE_TIMEOUT

See Also:

• Constant Field Values

Constructor Details

TLSSocketChannel

public TLSSocketChannel(SocketChannel sc)

Method Details

connect

public boolean connect(SocketAddress remote)
                throws IOException

Throws:

IOException

connect

public boolean connect(SocketAddress remote,
 String host,
 int port,
 long timeout)
                throws IOException

Connects, then verifies the peer unless the caller asked not to.

Throws:

IOException

flushOutbound

public boolean flushOutbound()
                      throws IOException

Advance pending ciphertext and TLS control output without more application data.

Throws:

IOException

write

public int write(ByteBuffer src)
          throws IOException

Specified by:

write in interface WritableByteChannel

Throws:

IOException

read

public int read(ByteBuffer dst)
         throws IOException

Specified by:

read in interface ReadableByteChannel

Throws:

IOException

hasPlaintext

public boolean hasPlaintext()

hasPendingOutbound

public boolean hasPendingOutbound()

requiredOps

public int requiredOps()

requiredWriteOps

public int requiredWriteOps()

isConnected

public boolean isConnected()

configureBlocking

public SelectableChannel configureBlocking(boolean block)
                                    throws IOException

Specified by:

configureBlocking in class SelectableChannel

Throws:

IOException

blockingLock

public Object blockingLock()

Specified by:

blockingLock in class SelectableChannel

isBlocking

public boolean isBlocking()

Specified by:

isBlocking in class SelectableChannel

isRegistered

public boolean isRegistered()

Specified by:

isRegistered in class SelectableChannel

keyFor

public SelectionKey keyFor(Selector selector)

Specified by:

keyFor in class SelectableChannel

provider

public SelectorProvider provider()

Specified by:

provider in class SelectableChannel

register

public SelectionKey register(Selector selector,
 int ops,
 Object attachment)
                      throws ClosedChannelException

Specified by:

register in class SelectableChannel

Throws:

ClosedChannelException

validOps

public int validOps()

Specified by:

validOps in class SelectableChannel

addWaiter

public void addWaiter(Selector selector)

ChannelIO wait registration also makes a direct TLS close wake its selectors.

removeWaiter

public void removeWaiter(Selector selector)

implCloseChannel

protected void implCloseChannel()
                         throws IOException

Specified by:

implCloseChannel in class AbstractInterruptibleChannel

Throws:

IOException