org.apache.drill.exec.rpc

Class ReconnectingConnection<C extends ClientConnection,HS extends com.google.protobuf.MessageLite>

java.lang.Object

org.apache.drill.exec.rpc.ReconnectingConnection<C,HS>

All Implemented Interfaces:

Closeable, AutoCloseable

Direct Known Subclasses:

ControlConnectionManager, DataConnectionManager

public abstract class ReconnectingConnection<C extends ClientConnection,HS extends com.google.protobuf.MessageLite>
extends Object
implements Closeable

Manager all connections between two particular bits.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	ReconnectingConnection.CloseHandler Listens for connection closes and clears connection holder.
class	ReconnectingConnection.CloseHandlerCreator Factory for close handlers
class	ReconnectingConnection.ConnectionListeningFuture<R extends com.google.protobuf.MessageLite,E extends com.google.protobuf.Internal.EnumLite,M extends com.google.protobuf.MessageLite>

Constructor Summary

Constructors

Constructor and Description
ReconnectingConnection(HS handshake, String host, int port)

Method Summary

Modifier and Type	Method and Description
void	addExternalConnection(C connection)
void	close()
ReconnectingConnection.CloseHandlerCreator	getCloseHandlerCreator()
protected abstract BasicClient<?,C,HS,?>	getNewClient()
<T extends com.google.protobuf.MessageLite,E extends com.google.protobuf.Internal.EnumLite,M extends com.google.protobuf.MessageLite,R extends RpcCommand<T,C,E,M>> void	runCommand(R cmd)

Methods inherited from class java.lang.Object

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

Constructor Detail

ReconnectingConnection

public ReconnectingConnection(HS handshake,
                              String host,
                              int port)

Method Detail

getNewClient

protected abstract BasicClient<?,C,HS,?> getNewClient()

runCommand

public <T extends com.google.protobuf.MessageLite,E extends com.google.protobuf.Internal.EnumLite,M extends com.google.protobuf.MessageLite,R extends RpcCommand<T,C,E,M>> void runCommand(R cmd)

getCloseHandlerCreator

public ReconnectingConnection.CloseHandlerCreator getCloseHandlerCreator()

addExternalConnection

public void addExternalConnection(C connection)

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable