Package org.apache.flink.runtime.jobmaster.slotpool

Class AbstractServiceConnectionManager<S>

java.lang.Object

org.apache.flink.runtime.jobmaster.slotpool.AbstractServiceConnectionManager<S>

All Implemented Interfaces:

ServiceConnectionManager<S>

public class AbstractServiceConnectionManager<S>
extends Object
implements ServiceConnectionManager<S>

Base class for service connection managers, taking care of the connection handling.

Field Summary

Fields

Modifier and Type	Field	Description
protected Object	lock
protected S	service

Constructor Summary

Constructors

Constructor	Description
AbstractServiceConnectionManager()

Method Summary

Modifier and Type	Method	Description
protected void	checkNotClosed()
void	close()	Close the service connection manager.
void	connect(S service)	Connect to the given service.
void	disconnect()	Disconnect from the current service.
protected boolean	isConnected()

Methods inherited from class java.lang.Object

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

Field Detail

lock

protected final Object lock

service

@Nullable
protected S service

Constructor Detail

AbstractServiceConnectionManager

public AbstractServiceConnectionManager()

Method Detail

connect

public final void connect(S service)

Description copied from interface: ServiceConnectionManager

Connect to the given service.

Specified by:

connect in interface ServiceConnectionManager<S>

Parameters:

service - service to connect to

disconnect

public final void disconnect()

Description copied from interface: ServiceConnectionManager

Disconnect from the current service.

Specified by:

disconnect in interface ServiceConnectionManager<S>

close

public final void close()

Description copied from interface: ServiceConnectionManager

Close the service connection manager. A closed manager must not be used again.

Specified by:

close in interface ServiceConnectionManager<S>

checkNotClosed

protected final void checkNotClosed()

isConnected

protected final boolean isConnected()