org.opendaylight.openflowplugin.impl.mastership

Class MastershipChangeServiceManagerImpl

java.lang.Object

org.opendaylight.openflowplugin.impl.mastership.MastershipChangeServiceManagerImpl

All Implemented Interfaces:

AutoCloseable, OwnershipChangeListener, ReconciliationFrameworkRegistrar, MastershipChangeServiceManager

public final class MastershipChangeServiceManagerImpl
extends Object
implements MastershipChangeServiceManager

Constructor Summary

Constructors

Constructor and Description
MastershipChangeServiceManagerImpl()

Method Summary

Modifier and Type	Method and Description
void	becomeMaster(DeviceInfo deviceInfo) This event is called when device is fully mastered.
com.google.common.util.concurrent.ListenableFuture<ResultState>	becomeMasterBeforeSubmittedDS(DeviceInfo deviceInfo) Should be called when device is being mastered as in OwnershipChangeListener.becomeMaster(DeviceInfo).
void	becomeSlaveOrDisconnect(DeviceInfo deviceInfo) Should be called when device is disconnected or going to be slaved.
void	close()
boolean	isReconciliationFrameworkRegistered() Check if reconciliation framework is registered.
ReconciliationFrameworkRegistration	reconciliationFrameworkRegistration(ReconciliationFrameworkEvent reconciliationFrameworkEvent) Setter for reconciliation framework event listener.
MastershipChangeRegistration	register(MastershipChangeService service) Register of mastership change listener.
void	setMasterChecker(MasterChecker masterChecker) Set the device mastership checker.

Methods inherited from class java.lang.Object

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

Constructor Detail

MastershipChangeServiceManagerImpl

public MastershipChangeServiceManagerImpl()

Method Detail

register

@Nonnull
public MastershipChangeRegistration register(@Nonnull
                                                      MastershipChangeService service)

Description copied from interface: MastershipChangeServiceManager

Register of mastership change listener. Returned registration need to be closed by client. It doesn't contain event for reconciliation framework event.

Specified by:

register in interface MastershipChangeServiceManager

Parameters:

service - implementation of MastershipChangeService

Returns:

registration

See Also:

ReconciliationFrameworkEvent

reconciliationFrameworkRegistration

public ReconciliationFrameworkRegistration reconciliationFrameworkRegistration(@Nonnull
                                                                               ReconciliationFrameworkEvent reconciliationFrameworkEvent)
                                                                        throws MastershipChangeException

Description copied from interface: MastershipChangeServiceManager

Setter for reconciliation framework event listener. It can be registered only once. Another registrations will throw an exception

Specified by:

reconciliationFrameworkRegistration in interface MastershipChangeServiceManager

Parameters:

reconciliationFrameworkEvent - reconciliation framework

Returns:

registration object, which can be closed to unregister

Throws:

MastershipChangeException - if already reconciliation framework registered

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface MastershipChangeServiceManager

becomeMaster

public void becomeMaster(@Nonnull
                         DeviceInfo deviceInfo)

Description copied from interface: OwnershipChangeListener

This event is called when device is fully mastered. All condition have to been done successful.

• Transaction chain created
• RPC services started
• Initial statistics gathering.
• Initial DS submit.
• Flow registry filled. - this step is not mandatory

Specified by:

becomeMaster in interface OwnershipChangeListener

Parameters:

deviceInfo - connected switch identification

becomeSlaveOrDisconnect

public void becomeSlaveOrDisconnect(@Nonnull
                                    DeviceInfo deviceInfo)

Description copied from interface: OwnershipChangeListener

Should be called when device is disconnected or going to be slaved.

Specified by:

becomeSlaveOrDisconnect in interface OwnershipChangeListener

Parameters:

deviceInfo - connected switch identification

becomeMasterBeforeSubmittedDS

public com.google.common.util.concurrent.ListenableFuture<ResultState> becomeMasterBeforeSubmittedDS(@Nonnull
                                                                                                     DeviceInfo deviceInfo)

Description copied from interface: OwnershipChangeListener

Should be called when device is being mastered as in OwnershipChangeListener.becomeMaster(DeviceInfo).

But before: Initial DS submit

This is special call designed only for reconciliation framework.

Specified by:

becomeMasterBeforeSubmittedDS in interface OwnershipChangeListener

Parameters:

deviceInfo - connected switch identification

Returns:

future to be able handle device after reconciliation

See Also:

OwnershipChangeListener.becomeMaster(DeviceInfo), ReconciliationFrameworkRegistrar.isReconciliationFrameworkRegistered()

setMasterChecker

public void setMasterChecker(@Nonnull
                             MasterChecker masterChecker)

Description copied from interface: OwnershipChangeListener

Set the device mastership checker.

Specified by:

setMasterChecker in interface OwnershipChangeListener

Parameters:

masterChecker - MasterChecker

isReconciliationFrameworkRegistered

public boolean isReconciliationFrameworkRegistered()

Description copied from interface: ReconciliationFrameworkRegistrar

Check if reconciliation framework is registered. If not the event OwnershipChangeListener.becomeMasterBeforeSubmittedDS(DeviceInfo) will not be triggered.

Specified by:

isReconciliationFrameworkRegistered in interface ReconciliationFrameworkRegistrar

Returns:

true if there exists any reconciliation framework registration