Package org.apache.drill.exec.rpc

Class AbstractClientConnection

java.lang.Object

org.apache.drill.exec.rpc.AbstractRemoteConnection

org.apache.drill.exec.rpc.AbstractClientConnection

All Implemented Interfaces:

AutoCloseable, ClientConnection, ConnectionThrottle, EncryptionContext, RemoteConnection

Direct Known Subclasses:

DataClientConnection, UserClient.UserToBitConnection

public abstract class AbstractClientConnection
extends AbstractRemoteConnection
implements ClientConnection

Field Summary

Fields inherited from class org.apache.drill.exec.rpc.AbstractRemoteConnection

saslCodec

Constructor Summary

Constructors

Constructor	Description
AbstractClientConnection(io.netty.channel.socket.SocketChannel channel, String name)
AbstractClientConnection(io.netty.channel.socket.SocketChannel channel, String name, EncryptionContext encryptContext)

Method Summary

Modifier and Type	Method	Description
void	channelClosed(RpcException ex)	Called from the RpcBus's channel close handler to close all remaining resources associated with this connection.
void	disposeSaslClient()
protected abstract org.slf4j.Logger	getLogger()
SaslClient	getSaslClient()
void	setSaslClient(SaslClient saslClient)

Methods inherited from class org.apache.drill.exec.rpc.AbstractRemoteConnection

addSecurityHandlers, blockOnNotWritable, close, createNewRpcListener, decConnectionCounter, getAndRemoveRpcOutcome, getChannel, getEncryptionCtxtString, getMaxWrappedSize, getName, getRemoteAddress, getWrapSizeLimit, incConnectionCounter, inEventLoop, isActive, isEncryptionEnabled, recordRemoteFailure, setAutoRead, setEncryption, setMaxWrappedSize, setWrapSizeLimit

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.drill.exec.rpc.ConnectionThrottle

setAutoRead

Methods inherited from interface org.apache.drill.exec.rpc.EncryptionContext

getEncryptionCtxtString, getMaxWrappedSize, getWrapSizeLimit, isEncryptionEnabled, setEncryption, setMaxWrappedSize, setWrapSizeLimit

Methods inherited from interface org.apache.drill.exec.rpc.RemoteConnection

addSecurityHandlers, blockOnNotWritable, close, createNewRpcListener, getAllocator, getAndRemoveRpcOutcome, getChannel, getName, getRemoteAddress, inEventLoop, isActive, recordRemoteFailure

Constructor Details

AbstractClientConnection

public AbstractClientConnection(io.netty.channel.socket.SocketChannel channel,
 String name,
 EncryptionContext encryptContext)

AbstractClientConnection

public AbstractClientConnection(io.netty.channel.socket.SocketChannel channel,
 String name)

Method Details

getLogger

protected abstract org.slf4j.Logger getLogger()

setSaslClient

public void setSaslClient(SaslClient saslClient)

Specified by:

setSaslClient in interface ClientConnection

getSaslClient

public SaslClient getSaslClient()

Specified by:

getSaslClient in interface ClientConnection

disposeSaslClient

public void disposeSaslClient()

Specified by:

disposeSaslClient in interface ClientConnection

channelClosed

public void channelClosed(RpcException ex)

Description copied from class: AbstractRemoteConnection

Called from the RpcBus's channel close handler to close all remaining resources associated with this connection. Ensures that any pending back-pressure items are also unblocked so they can be thrown away.

Specified by:

channelClosed in interface RemoteConnection

Overrides:

channelClosed in class AbstractRemoteConnection

Parameters:

ex - The exception that caused the channel to close.