Package org.apache.thrift.transport

Class TNonblockingSSLSocket

java.lang.Object

org.apache.thrift.transport.TTransport

org.apache.thrift.transport.TEndpointTransport

org.apache.thrift.transport.TNonblockingTransport

org.apache.thrift.transport.TNonblockingSocket

org.apache.thrift.transport.TNonblockingSSLSocket

All Implemented Interfaces:

Closeable, AutoCloseable, SocketAddressProvider

public class TNonblockingSSLSocket
extends TNonblockingSocket
implements SocketAddressProvider

Transport for use with async ssl client.

Field Summary

Fields inherited from class org.apache.thrift.transport.TEndpointTransport

knownMessageSize, remainingMessageSize

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	TNonblockingSSLSocket(String host, int port, int timeout, SSLContext sslContext)

Method Summary

Modifier and Type	Method	Description
void	close()	Closes the socket.
boolean	finishConnect()	Non-blocking connection completion.
boolean	isOpen()	Checks whether the socket is connected.
void	open()	Do not call, the implementation provides its own lazy non-blocking connect.
int	read(ByteBuffer buffer)	Perform a nonblocking read into buffer.
SelectionKey	registerSelector(Selector selector, int interests)	Register the new SocketChannel with our Selector, indicating we'd like to be notified when it's ready for I/O.
boolean	startConnect()	Non-blocking connection initialization.
int	write(ByteBuffer buffer)	Perform a nonblocking write of the data in buffer;

Methods inherited from class org.apache.thrift.transport.TNonblockingSocket

flush, getLocalSocketAddress, getRemoteSocketAddress, getSocketChannel, read, setTimeout, toString, write

Methods inherited from class org.apache.thrift.transport.TEndpointTransport

checkReadBytesAvailable, countConsumedMessageBytes, getConfiguration, getMaxFrameSize, getMaxMessageSize, resetConsumedMessageSize, setMaxFrameSize, setMaxMessageSize, updateKnownMessageSize

Methods inherited from class org.apache.thrift.transport.TTransport

consumeBuffer, getBuffer, getBufferPosition, getBytesRemainingInBuffer, peek, readAll, write

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.thrift.transport.SocketAddressProvider

getLocalSocketAddress, getRemoteSocketAddress

Constructor Details

TNonblockingSSLSocket

protected TNonblockingSSLSocket(String host,
 int port,
 int timeout,
 SSLContext sslContext)
                         throws IOException,
TTransportException

Throws:

IOException

TTransportException

Method Details

registerSelector

public SelectionKey registerSelector(Selector selector,
 int interests)
                              throws IOException

Register the new SocketChannel with our Selector, indicating we'd like to be notified when it's ready for I/O.

Overrides:

registerSelector in class TNonblockingSocket

Returns:

the selection key for this socket.

Throws:

IOException

isOpen

public boolean isOpen()

Checks whether the socket is connected.

Overrides:

isOpen in class TNonblockingSocket

Returns:

True if the transport is open.

open

public void open()
          throws TTransportException

Do not call, the implementation provides its own lazy non-blocking connect.

Overrides:

open in class TNonblockingSocket

Throws:

TTransportException - if the transport could not be opened

read

public int read(ByteBuffer buffer)
         throws TTransportException

Perform a nonblocking read into buffer.

Overrides:

read in class TNonblockingSocket

Parameters:

buffer - The buffer into which bytes are to be transferred

Returns:

The number of bytes read, possibly zero, or -1 if the channel has reached end-of-stream

Throws:

TTransportException - if there was an error reading data

write

public int write(ByteBuffer buffer)
          throws TTransportException

Perform a nonblocking write of the data in buffer;

Overrides:

write in class TNonblockingSocket

Parameters:

buffer - The buffer from which bytes are to be retrieved

Returns:

The number of bytes written, possibly zero

Throws:

TTransportException - if there was an error writing data

close

public void close()

Closes the socket.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Overrides:

close in class TNonblockingSocket

startConnect

public boolean startConnect()
                     throws IOException

Non-blocking connection initialization.

Overrides:

startConnect in class TNonblockingSocket

Throws:

IOException

See Also:

• SocketChannel.connect(SocketAddress remote)

finishConnect

public boolean finishConnect()
                      throws IOException

Non-blocking connection completion.

Overrides:

finishConnect in class TNonblockingSocket

Throws:

IOException

See Also:

• SocketChannel.finishConnect()