org.opendaylight.controller.config.manager.impl

Class ConfigRegistryImpl

java.lang.Object

org.opendaylight.controller.config.manager.impl.ConfigRegistryImpl

All Implemented Interfaces:

AutoCloseable, ConfigRegistry, LookupRegistry, ServiceReferenceReadableRegistry, ConfigRegistryImplMXBean

@ThreadSafe
public class ConfigRegistryImpl
extends Object
implements AutoCloseable, ConfigRegistryImplMXBean

Singleton that is responsible for creating and committing Config Transactions. It is registered in Platform MBean Server.

Field Summary

Fields inherited from interface org.opendaylight.controller.config.api.ConfigRegistry

OBJECT_NAME, OBJECT_NAME_NO_NOTIFICATIONS

Constructor Summary

Constructors

Constructor and Description
ConfigRegistryImpl(ModuleFactoriesResolver resolver, MBeanServer configMBeanServer, BaseJMXRegistrator baseJMXRegistrator, BindingContextProvider bindingContextProvider)
ConfigRegistryImpl(ModuleFactoriesResolver resolver, MBeanServer configMBeanServer, BindingContextProvider bindingContextProvider)

Method Summary

Modifier and Type	Method and Description
ObjectName	beginConfig() Create new ConfigTransactionControllerImpl.
ObjectName	beginConfig(boolean blankTransaction) It returns true if this transaction is created automatically by org.opendaylight.controller.config.manager.impl.osgi.BlankTransactionServiceTracker.
void	checkConfigBeanExists(ObjectName objectName) Check that object name corresponds with existing module.
void	checkServiceReferenceExists(ObjectName objectName)
void	close() Abort open transactions and unregister read only modules.
CommitStatus	commitConfig(ObjectName transactionControllerON) Verifies and commits transaction.
Set<String>	getAvailableModuleFactoryQNames() Get the qNames of all ModuleFactory instances in the system.
Set<String>	getAvailableModuleNames() Get the module names available in the system.
List<ObjectName>	getOpenConfigs() List of open configuration transactions.
String	getServiceInterfaceName(String namespace, String localName) Get the name of the service interface.
Map<String,Map<String,ObjectName>>	getServiceMapping() Get mapping of services to reference names and module object names.
ObjectName	getServiceReference(String serviceInterfaceQName, String refName) Get the reference to that service.
long	getVersion() Get the version of last committed transaction that is now used as base version.
boolean	isHealthy() Will return true unless there was a transaction that succeeded during validation but failed in second phase of commit.
ObjectName	lookupConfigBean(String moduleName, String instanceName) Find read module.
ObjectName	lookupConfigBeanByServiceInterfaceName(String serviceInterfaceQName, String refName) Lookup object name by fully qualified service interface name and service reference name.
Set<ObjectName>	lookupConfigBeans() Find all modules.
Set<ObjectName>	lookupConfigBeans(String moduleName) Find modules with given module name.
Set<ObjectName>	lookupConfigBeans(String moduleName, String instanceName) Find read modules.
Set<ObjectName>	lookupRuntimeBeans() Find all runtime beans.
Set<ObjectName>	lookupRuntimeBeans(String moduleName, String instanceName) Find all runtime of specified module.
Set<String>	lookupServiceInterfaceNames(ObjectName objectName) Find all available service interface names of a module.
Map<String,ObjectName>	lookupServiceReferencesByServiceInterfaceName(String serviceInterfaceQName) Get current mapping between reference names and module object names for given service interface name.
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

ConfigRegistryImpl

public ConfigRegistryImpl(ModuleFactoriesResolver resolver,
                          MBeanServer configMBeanServer,
                          BindingContextProvider bindingContextProvider)

ConfigRegistryImpl

public ConfigRegistryImpl(ModuleFactoriesResolver resolver,
                          MBeanServer configMBeanServer,
                          BaseJMXRegistrator baseJMXRegistrator,
                          BindingContextProvider bindingContextProvider)

Method Detail

beginConfig

public ObjectName beginConfig()

Create new ConfigTransactionControllerImpl.

Specified by:

beginConfig in interface ConfigRegistry

Returns:

ObjectName of ConfigTransactionControllerMXBean

beginConfig

public ObjectName beginConfig(boolean blankTransaction)

It returns true if this transaction is created automatically by org.opendaylight.controller.config.manager.impl.osgi.BlankTransactionServiceTracker.

Parameters:

blankTransaction - true if this transaction is created automatically by org.opendaylight.controller.config.manager.impl.osgi.BlankTransactionServiceTracker

Returns:

object name

commitConfig

public CommitStatus commitConfig(ObjectName transactionControllerON)
                          throws ValidationException,
                                 ConflictingVersionException

Description copied from interface: ConfigRegistry

Verifies and commits transaction.

Specified by:

commitConfig in interface ConfigRegistry

Parameters:

transactionControllerON - ObjectName of ConfigTransactionControllerMXBean that was received in ConfigRegistry.beginConfig() method call.

Returns:

CommitStatus

Throws:

ValidationException - if validation fails

ConflictingVersionException - if configuration state was changed

getOpenConfigs

public List<ObjectName> getOpenConfigs()

List of open configuration transactions.

Specified by:

getOpenConfigs in interface ConfigRegistry

Returns:

list of open configuration transactions.

close

public void close()

Abort open transactions and unregister read only modules. Since this class is not responsible for registering itself under ConfigRegistry.OBJECT_NAME, it will not unregister itself here.

Specified by:

close in interface AutoCloseable

getVersion

public long getVersion()

Get the version of last committed transaction that is now used as base version. Transactions can only be committed if their parent version matches this value, that means, transaction must be started after last one has been committed.

Specified by:

getVersion in interface ConfigRegistryImplMXBean

Returns:

version

getAvailableModuleNames

public Set<String> getAvailableModuleNames()

Get the module names available in the system.

Specified by:

getAvailableModuleNames in interface ConfigRegistry

Returns:

module factory names available in the system

isHealthy

public boolean isHealthy()

Will return true unless there was a transaction that succeeded during validation but failed in second phase of commit. In this case the server is unstable and its state is undefined.

Specified by:

isHealthy in interface ConfigRegistry

lookupConfigBeans

public Set<ObjectName> lookupConfigBeans()

Find all modules. Same Module can be registered multiple times.

Specified by:

lookupConfigBeans in interface LookupRegistry

Returns:

objectNames

lookupConfigBeans

public Set<ObjectName> lookupConfigBeans(String moduleName)

Find modules with given module name.

Specified by:

lookupConfigBeans in interface LookupRegistry

Parameters:

moduleName - name of module

Returns:

objectNames

lookupConfigBeans

public Set<ObjectName> lookupConfigBeans(String moduleName,
                                         String instanceName)

Find read modules.

Specified by:

lookupConfigBeans in interface LookupRegistry

Parameters:

moduleName - exact match for searched module name, can contain '*' to match all values.

instanceName - exact match for searched instance name, can contain '*' to match all values.

Returns:

objectNames

lookupConfigBean

public ObjectName lookupConfigBean(String moduleName,
                                   String instanceName)
                            throws InstanceNotFoundException

Find read module.

Specified by:

lookupConfigBean in interface LookupRegistry

Parameters:

moduleName - exact match for searched module name, can contain '*' to match all values.

instanceName - exact match for searched instance name, can contain '*' to match all values.

Returns:

objectNames

Throws:

InstanceNotFoundException - if search did not find exactly one instance

lookupRuntimeBeans

public Set<ObjectName> lookupRuntimeBeans()

Find all runtime beans.

Specified by:

lookupRuntimeBeans in interface LookupRegistry

Returns:

objectNames

lookupRuntimeBeans

public Set<ObjectName> lookupRuntimeBeans(String moduleName,
                                          String instanceName)

Find all runtime of specified module.

Specified by:

lookupRuntimeBeans in interface LookupRegistry

Parameters:

moduleName - of bean

instanceName - of bean

Returns:

objectNames

checkConfigBeanExists

public void checkConfigBeanExists(ObjectName objectName)
                           throws InstanceNotFoundException

Description copied from interface: LookupRegistry

Check that object name corresponds with existing module.

Specified by:

checkConfigBeanExists in interface LookupRegistry

Throws:

InstanceNotFoundException - if search did not find exactly one instance

lookupConfigBeanByServiceInterfaceName

public ObjectName lookupConfigBeanByServiceInterfaceName(String serviceInterfaceQName,
                                                         String refName)

Description copied from interface: ServiceReferenceReadableRegistry

Lookup object name by fully qualified service interface name and service reference name.

Specified by:

lookupConfigBeanByServiceInterfaceName in interface ServiceReferenceReadableRegistry

Parameters:

serviceInterfaceQName - service interface name

refName - service reference name supplied in .api .ConfigTransactionController#saveServiceReference(String, String, javax.management.ObjectName)

getServiceMapping

public Map<String,Map<String,ObjectName>> getServiceMapping()

Description copied from interface: ServiceReferenceReadableRegistry

Get mapping of services to reference names and module object names.

Specified by:

getServiceMapping in interface ServiceReferenceReadableRegistry

lookupServiceReferencesByServiceInterfaceName

public Map<String,ObjectName> lookupServiceReferencesByServiceInterfaceName(String serviceInterfaceQName)

Description copied from interface: ServiceReferenceReadableRegistry

Get current mapping between reference names and module object names for given service interface name.

Specified by:

lookupServiceReferencesByServiceInterfaceName in interface ServiceReferenceReadableRegistry

Parameters:

serviceInterfaceQName - service interface name

lookupServiceInterfaceNames

public Set<String> lookupServiceInterfaceNames(ObjectName objectName)
                                        throws InstanceNotFoundException

Description copied from interface: ServiceReferenceReadableRegistry

Find all available service interface names of a module.

Specified by:

lookupServiceInterfaceNames in interface ServiceReferenceReadableRegistry

Parameters:

objectName - module object name

Throws:

InstanceNotFoundException - if search did not find exactly one instance

getServiceInterfaceName

public String getServiceInterfaceName(String namespace,
                                      String localName)

Description copied from interface: ServiceReferenceReadableRegistry

Get the name of the service interface.

Specified by:

getServiceInterfaceName in interface ServiceReferenceReadableRegistry

Parameters:

namespace - service interface namespace

localName - service interface local name

Returns:

fully qualified name needed by all other service reference mapping methods.

checkServiceReferenceExists

public void checkServiceReferenceExists(ObjectName objectName)
                                 throws InstanceNotFoundException

Specified by:

checkServiceReferenceExists in interface ServiceReferenceReadableRegistry

Throws:

InstanceNotFoundException

getServiceReference

public ObjectName getServiceReference(String serviceInterfaceQName,
                                      String refName)
                               throws InstanceNotFoundException

Description copied from interface: ServiceReferenceReadableRegistry

Get the reference to that service.

Specified by:

getServiceReference in interface ServiceReferenceReadableRegistry

Returns:

ObjectName with type=Service that was created using .config .api.ServiceReferenceWritableRegistry#saveServiceReference(String, String, javax.management.ObjectName)

Throws:

InstanceNotFoundException

getAvailableModuleFactoryQNames

public Set<String> getAvailableModuleFactoryQNames()

Description copied from interface: LookupRegistry

Get the qNames of all ModuleFactory instances in the system.

Specified by:

getAvailableModuleFactoryQNames in interface LookupRegistry

Returns:

qNames of all ModuleFactory instances in the system

toString

public String toString()

Overrides:

toString in class Object