Uses of Class
org.apache.drill.exec.rpc.control.ControlConnection

Packages that use ControlConnection

Package	Description
org.apache.drill.exec.rpc.control
org.apache.drill.exec.work.batch

Uses of ControlConnection in org.apache.drill.exec.rpc.control

Methods in org.apache.drill.exec.rpc.control that return ControlConnection

Modifier and Type	Method and Description
protected ControlConnection	ControlClient.initRemoteConnection(io.netty.channel.socket.SocketChannel channel)
protected ControlConnection	ControlServer.initRemoteConnection(io.netty.channel.socket.SocketChannel channel)

Methods in org.apache.drill.exec.rpc.control that return types with arguments of type ControlConnection

Modifier and Type	Method and Description
protected abstract BasicClient<?,ControlConnection,BitControl.BitControlHandshake,?>	ControlConnectionManager.getNewClient()
protected BasicClient<?,ControlConnection,BitControl.BitControlHandshake,?>	LocalControlConnectionManager.getNewClient()
protected BasicClient<?,ControlConnection,BitControl.BitControlHandshake,?>	RemoteControlConnectionManager.getNewClient()

Methods in org.apache.drill.exec.rpc.control with parameters of type ControlConnection

Modifier and Type	Method and Description
void	ControlTunnel.CustomMessageSender.doRpcCall(RpcOutcomeListener<BitControl.CustomMessage> outcomeListener, ControlConnection connection)
void	ControlTunnel.SyncCustomMessageSender.doRpcCall(RpcOutcomeListener<BitControl.CustomMessage> outcomeListener, ControlConnection connection)
void	ControlTunnel.SendFragmentStatus.doRpcCall(RpcOutcomeListener<GeneralRPCProtos.Ack> outcomeListener, ControlConnection connection)
void	ControlTunnel.ReceiverFinished.doRpcCall(RpcOutcomeListener<GeneralRPCProtos.Ack> outcomeListener, ControlConnection connection)
void	ControlTunnel.SignalFragment.doRpcCall(RpcOutcomeListener<GeneralRPCProtos.Ack> outcomeListener, ControlConnection connection)
void	ControlTunnel.SendFragment.doRpcCall(RpcOutcomeListener<GeneralRPCProtos.Ack> outcomeListener, ControlConnection connection)
void	ControlTunnel.CancelQuery.doRpcCall(RpcOutcomeListener<GeneralRPCProtos.Ack> outcomeListener, ControlConnection connection)
void	ControlTunnel.RequestProfile.doRpcCall(RpcOutcomeListener<UserBitShared.QueryProfile> outcomeListener, ControlConnection connection)
protected void	ControlClient.finalizeConnection(BitControl.BitControlHandshake handshake, ControlConnection connection)
protected io.netty.util.concurrent.GenericFutureListener<io.netty.channel.ChannelFuture>	ControlClient.getCloseHandler(io.netty.channel.socket.SocketChannel ch, ControlConnection clientConnection)
protected io.netty.util.concurrent.GenericFutureListener<io.netty.channel.ChannelFuture>	ControlServer.getCloseHandler(io.netty.channel.socket.SocketChannel ch, ControlConnection connection)
protected BasicServer.ServerHandshakeHandler<BitControl.BitControlHandshake>	ControlServer.getHandshakeHandler(ControlConnection connection)
protected void	ControlClient.handle(ControlConnection connection, int rpcType, io.netty.buffer.ByteBuf pBody, io.netty.buffer.ByteBuf dBody, ResponseSender sender)

Method parameters in org.apache.drill.exec.rpc.control with type arguments of type ControlConnection

Modifier and Type	Method and Description
protected void	ControlClient.prepareSaslHandshake(RpcConnectionHandler<ControlConnection> connectionHandler, List<String> serverAuthMechanisms)

Uses of ControlConnection in org.apache.drill.exec.work.batch

Methods in org.apache.drill.exec.work.batch with parameters of type ControlConnection

Modifier and Type	Method and Description
void	ControlMessageHandler.handle(ControlConnection connection, int rpcType, io.netty.buffer.ByteBuf pBody, io.netty.buffer.ByteBuf dBody, ResponseSender sender)