org.apache.drill.exec.rpc

Class AbstractServerConnection<S extends ServerConnection<S>>

java.lang.Object

org.apache.drill.exec.rpc.AbstractRemoteConnection

org.apache.drill.exec.rpc.AbstractServerConnection<S>

All Implemented Interfaces:

AutoCloseable, ConnectionThrottle, EncryptionContext, RemoteConnection, ServerConnection<S>

Direct Known Subclasses:

ControlConnection, DataServerConnection, UserServer.BitToUserConnection

public abstract class AbstractServerConnection<S extends ServerConnection<S>>
extends AbstractRemoteConnection
implements ServerConnection<S>

Field Summary

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

saslCodec

Constructor Summary

Constructors

Constructor and Description
AbstractServerConnection(io.netty.channel.socket.SocketChannel channel, ConnectionConfig config, RequestHandler<S> handler)
AbstractServerConnection(io.netty.channel.socket.SocketChannel channel, String name, ConnectionConfig config, RequestHandler<S> handler)

Method Summary

Modifier and Type	Method and Description
void	changeHandlerTo(RequestHandler<S> handler)
void	channelClosed(RpcException ex) Called from the RpcBus's channel close handler to close all remaining resources associated with this connection.
void	disposeSaslServer()
void	finalizeSaslSession()
BufferAllocator	getAllocator()
RequestHandler<S>	getCurrentHandler()
protected abstract org.slf4j.Logger	getLogger()
SaslServer	getSaslServer()
void	initSaslServer(String mechanismName)
void	setEncryption(boolean encrypted)
void	setMaxWrappedSize(int maxWrappedSize)

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, 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.RemoteConnection

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

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, setWrapSizeLimit

Constructor Detail

AbstractServerConnection

public AbstractServerConnection(io.netty.channel.socket.SocketChannel channel,
                                String name,
                                ConnectionConfig config,
                                RequestHandler<S> handler)

AbstractServerConnection

public AbstractServerConnection(io.netty.channel.socket.SocketChannel channel,
                                ConnectionConfig config,
                                RequestHandler<S> handler)

Method Detail

getAllocator

public BufferAllocator getAllocator()

Specified by:

getAllocator in interface RemoteConnection

getLogger

protected abstract org.slf4j.Logger getLogger()

initSaslServer

public void initSaslServer(String mechanismName)
                    throws SaslException

Specified by:

initSaslServer in interface ServerConnection<S extends ServerConnection<S>>

Throws:

SaslException

getSaslServer

public SaslServer getSaslServer()

Specified by:

getSaslServer in interface ServerConnection<S extends ServerConnection<S>>

finalizeSaslSession

public void finalizeSaslSession()
                         throws IOException

Specified by:

finalizeSaslSession in interface ServerConnection<S extends ServerConnection<S>>

Throws:

IOException

getCurrentHandler

public RequestHandler<S> getCurrentHandler()

Specified by:

getCurrentHandler in interface ServerConnection<S extends ServerConnection<S>>

changeHandlerTo

public void changeHandlerTo(RequestHandler<S> handler)

Specified by:

changeHandlerTo in interface ServerConnection<S extends ServerConnection<S>>

setEncryption

public void setEncryption(boolean encrypted)

Specified by:

setEncryption in interface EncryptionContext

Overrides:

setEncryption in class AbstractRemoteConnection

setMaxWrappedSize

public void setMaxWrappedSize(int maxWrappedSize)

Specified by:

setMaxWrappedSize in interface EncryptionContext

Overrides:

setMaxWrappedSize in class AbstractRemoteConnection

disposeSaslServer

public void disposeSaslServer()

Specified by:

disposeSaslServer in interface ServerConnection<S extends ServerConnection<S>>

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.