Package org.ovirt.vdsm.jsonrpc.client.reactors

Class SSLClient

java.lang.Object

org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient

org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompCommonClient

org.ovirt.vdsm.jsonrpc.client.reactors.SSLClient

Direct Known Subclasses:

SSLStompClient

public abstract class SSLClient
extends StompCommonClient

ReactorClient implementation to provide encrypted communication.

Nested Class Summary

Nested classes/interfaces inherited from class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient

ReactorClient.MessageListener

Field Summary

Fields

Modifier and Type	Field	Description
private boolean	client
protected static org.slf4j.Logger	log
protected SSLEngineNioHelper	nioEngine
protected final Selector	selector
private SSLContext	sslContext

Fields inherited from class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompCommonClient

connected, DEFAULT_REQUEST_QUEUE, DEFAULT_RESPONSE_QUEUE, headerBuffer, message, subscribed, subscriptionIds

Fields inherited from class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient

BUFFER_SIZE, channel, CLIENT_CLOSED, eventListeners, half, ibuff, key, outbox, PEER_CERTIFICATE_EMPTY_LIST, policy, reactor

Constructor Summary

Constructors

Constructor	Description
SSLClient(Reactor reactor, Selector selector, String hostname, int port, SSLContext sslctx)
SSLClient(Reactor reactor, Selector selector, String hostname, int port, SSLContext sslctx, SocketChannel socketChannel)

Method Summary

Modifier and Type	Method	Description
protected SSLEngine	createSSLEngine(boolean clientMode)
List<Certificate>	getPeerCertificates()
private Runnable	pendingOperations()
protected void	postConnect(OneTimeCallback callback)	Transport specific post connection functionality.
void	postDisconnect()	Cleans resources after disconnect.
void	process()
protected int	read(ByteBuffer buff)	Reads provided buffer.
void	updateInterestedOps()	Updates selection key's operation set.
protected void	write(ByteBuffer buff)	Writes provided buffer.

Methods inherited from class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompCommonClient

buildNetworkResponse, clean, close, emitOnMessageReceived, getEventQueue, getRequestQueue, getResponseQueue, processIncoming, send, sendHeartbeat, sendNow, updatePolicyWithHeartbeat, validate

Methods inherited from class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient

addEventListener, closeChannel, connect, disconnect, emitOnMessageReceived, getClientId, getConnectionId, getHostname, getPostConnectCallback, getRetryPolicy, getSelectionKey, isInInit, isOpen, now, performAction, processOutgoing, removeEventListener, scheduleTask, sendMessage, setClientPolicy, updateLastIncomingHeartbeat, updateLastOutgoingHeartbeat

Methods inherited from class java.lang.Object

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

Field Details

log

protected static org.slf4j.Logger log

selector

protected final Selector selector

nioEngine

protected SSLEngineNioHelper nioEngine

sslContext

private SSLContext sslContext

client

private boolean client

Constructor Details

SSLClient

public SSLClient(Reactor reactor,
 Selector selector,
 String hostname,
 int port,
 SSLContext sslctx)

SSLClient

public SSLClient(Reactor reactor,
 Selector selector,
 String hostname,
 int port,
 SSLContext sslctx,
 SocketChannel socketChannel)
          throws ClientConnectionException

Throws:

ClientConnectionException

Method Details

createSSLEngine

protected SSLEngine createSSLEngine(boolean clientMode)

updateInterestedOps

public void updateInterestedOps()

Description copied from class: ReactorClient

Updates selection key's operation set.

Specified by:

updateInterestedOps in class ReactorClient

pendingOperations

private Runnable pendingOperations()
                            throws IOException,
ClientConnectionException

Throws:

IOException

ClientConnectionException

read

protected int read(ByteBuffer buff)
            throws IOException

Description copied from class: ReactorClient

Reads provided buffer.

Specified by:

read in class ReactorClient

Parameters:

buff - provided buffer to be read.

Returns:

Number of bytes read.

Throws:

IOException - when networking issue occurs.

write

protected void write(ByteBuffer buff)
              throws IOException

Description copied from class: ReactorClient

Writes provided buffer.

Specified by:

write in class ReactorClient

Parameters:

buff - provided buffer to be written.

Throws:

IOException - when networking issue occurs.

process

public void process()
             throws IOException,
ClientConnectionException

Overrides:

process in class ReactorClient

Throws:

IOException

ClientConnectionException

postConnect

protected void postConnect(OneTimeCallback callback)
                    throws ClientConnectionException

Description copied from class: ReactorClient

Transport specific post connection functionality.

Specified by:

postConnect in class ReactorClient

Parameters:

callback - - callback which is executed after connection is estabilished.

Throws:

ClientConnectionException - when issues with connection.

postDisconnect

public void postDisconnect()

Description copied from class: ReactorClient

Cleans resources after disconnect.

Specified by:

postDisconnect in class ReactorClient

getPeerCertificates

public List<Certificate> getPeerCertificates()

Overrides:

getPeerCertificates in class ReactorClient

Returns:

the peer certificates of the current session