From: Vladimir Lavor Date: Tue, 13 Jun 2017 11:24:04 +0000 (+0200) Subject: catch and log cluster singleton service registration exceptions X-Git-Tag: release/nitrogen~36 X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=groupbasedpolicy.git;a=commitdiff_plain;h=eccee08635267709954dccc468df2a66c7e9e6e7 catch and log cluster singleton service registration exceptions Change-Id: I0e711439faa8ec726dffa649b992fa05e71c41df Signed-off-by: Vladimir Lavor --- diff --git a/groupbasedpolicy/src/main/java/org/opendaylight/controller/config/yang/config/groupbasedpolicy/DomainSpecificRegistryInstance.java b/groupbasedpolicy/src/main/java/org/opendaylight/controller/config/yang/config/groupbasedpolicy/DomainSpecificRegistryInstance.java index 02653c691..817eec67d 100644 --- a/groupbasedpolicy/src/main/java/org/opendaylight/controller/config/yang/config/groupbasedpolicy/DomainSpecificRegistryInstance.java +++ b/groupbasedpolicy/src/main/java/org/opendaylight/controller/config/yang/config/groupbasedpolicy/DomainSpecificRegistryInstance.java @@ -79,7 +79,12 @@ public class DomainSpecificRegistryInstance implements ClusterSingletonService, public void initialize() { LOG.info("Clustering session initiated for {}", this.getClass().getSimpleName()); - singletonServiceRegistration = clusterSingletonService.registerClusterSingletonService(this); + try { + singletonServiceRegistration = clusterSingletonService.registerClusterSingletonService(this); + } + catch (Exception e) { + LOG.warn("Exception while registering candidate ... ", e); + } } @Override diff --git a/groupbasedpolicy/src/main/java/org/opendaylight/controller/config/yang/config/groupbasedpolicy/EpRendererAugmentationRegistryImplInstance.java b/groupbasedpolicy/src/main/java/org/opendaylight/controller/config/yang/config/groupbasedpolicy/EpRendererAugmentationRegistryImplInstance.java index c498ab370..308bf4f88 100644 --- a/groupbasedpolicy/src/main/java/org/opendaylight/controller/config/yang/config/groupbasedpolicy/EpRendererAugmentationRegistryImplInstance.java +++ b/groupbasedpolicy/src/main/java/org/opendaylight/controller/config/yang/config/groupbasedpolicy/EpRendererAugmentationRegistryImplInstance.java @@ -90,7 +90,12 @@ public class EpRendererAugmentationRegistryImplInstance implements ClusterSingle public void initialize() { LOG.info("Clustering session initiated for {}", this.getClass().getSimpleName()); - singletonServiceRegistration = clusterSingletonService.registerClusterSingletonService(this); + try { + singletonServiceRegistration = clusterSingletonService.registerClusterSingletonService(this); + } + catch (Exception e) { + LOG.warn("Exception while registering candidate ... ", e); + } } @Override diff --git a/neutron-mapper/src/main/java/org/opendaylight/controller/config/yang/config/neutron_mapper/impl/NeutronMapperInstance.java b/neutron-mapper/src/main/java/org/opendaylight/controller/config/yang/config/neutron_mapper/impl/NeutronMapperInstance.java index b761246ed..044ddd77b 100644 --- a/neutron-mapper/src/main/java/org/opendaylight/controller/config/yang/config/neutron_mapper/impl/NeutronMapperInstance.java +++ b/neutron-mapper/src/main/java/org/opendaylight/controller/config/yang/config/neutron_mapper/impl/NeutronMapperInstance.java @@ -76,7 +76,12 @@ public class NeutronMapperInstance implements ClusterSingletonService, AutoClose public void instantiate() { LOG.info("Clustering session initiated for {}", this.getClass().getSimpleName()); - singletonServiceRegistration = clusterSingletonService.registerClusterSingletonService(this); + try { + singletonServiceRegistration = clusterSingletonService.registerClusterSingletonService(this); + } + catch (Exception e) { + LOG.warn("Exception while registering candidate ... ", e); + } } @Override diff --git a/neutron-ovsdb/src/main/java/org/opendaylight/controller/config/yang/config/neutron_ovsdb/impl/NeutronOvsdbInstance.java b/neutron-ovsdb/src/main/java/org/opendaylight/controller/config/yang/config/neutron_ovsdb/impl/NeutronOvsdbInstance.java index 07f3fb460..6e8d74a91 100644 --- a/neutron-ovsdb/src/main/java/org/opendaylight/controller/config/yang/config/neutron_ovsdb/impl/NeutronOvsdbInstance.java +++ b/neutron-ovsdb/src/main/java/org/opendaylight/controller/config/yang/config/neutron_ovsdb/impl/NeutronOvsdbInstance.java @@ -49,7 +49,11 @@ public class NeutronOvsdbInstance implements ClusterSingletonService, AutoClosea public void initialize() { LOG.info("Clustering session initiated for {}", this.getClass().getSimpleName()); - singletonServiceRegistration = clusterSingletonService.registerClusterSingletonService(this); + try { + singletonServiceRegistration = clusterSingletonService.registerClusterSingletonService(this); + } catch (Exception e) { + LOG.warn("Exception thrown while registering cluster singleton service in {}", this.getClass(), e.getMessage()); + } } @Override diff --git a/neutron-vpp-mapper/src/main/java/org/opendaylight/controller/config/yang/config/neutron_vpp_mapper/impl/NeutronVppMapperInstance.java b/neutron-vpp-mapper/src/main/java/org/opendaylight/controller/config/yang/config/neutron_vpp_mapper/impl/NeutronVppMapperInstance.java index 96d9c8a95..0ac9c47c7 100644 --- a/neutron-vpp-mapper/src/main/java/org/opendaylight/controller/config/yang/config/neutron_vpp_mapper/impl/NeutronVppMapperInstance.java +++ b/neutron-vpp-mapper/src/main/java/org/opendaylight/controller/config/yang/config/neutron_vpp_mapper/impl/NeutronVppMapperInstance.java @@ -49,7 +49,11 @@ public class NeutronVppMapperInstance implements ClusterSingletonService, AutoCl public void initialize() { LOG.info("Clustering session initiated for {}", this.getClass().getSimpleName()); - singletonServiceRegistration = clusterSingletonService.registerClusterSingletonService(this); + try { + singletonServiceRegistration = clusterSingletonService.registerClusterSingletonService(this); + } catch (Exception e) { + LOG.warn("Exception thrown while registering cluster singleton service in {}", this.getClass(), e.getMessage()); + } } @Override diff --git a/renderers/faas/src/main/java/org/opendaylight/controller/config/yang/config/faas_provider/impl/FaasProviderInstance.java b/renderers/faas/src/main/java/org/opendaylight/controller/config/yang/config/faas_provider/impl/FaasProviderInstance.java index 544ece9b4..642c702c8 100644 --- a/renderers/faas/src/main/java/org/opendaylight/controller/config/yang/config/faas_provider/impl/FaasProviderInstance.java +++ b/renderers/faas/src/main/java/org/opendaylight/controller/config/yang/config/faas_provider/impl/FaasProviderInstance.java @@ -44,7 +44,11 @@ public class FaasProviderInstance implements ClusterSingletonService, AutoClosea public void initialize() { LOG.info("Clustering session initiated for {}", this.getClass().getSimpleName()); + try { singletonServiceRegistration = clusterSingletonService.registerClusterSingletonService(this); + } catch (Exception e) { + LOG.warn("Exception thrown while registering cluster singleton service in {}", this.getClass(), e.getMessage()); + } } @Override diff --git a/renderers/ios-xe/src/main/java/org/opendaylight/groupbasedpolicy/renderer/ios_xe_provider/impl/config/IosXeProviderInstance.java b/renderers/ios-xe/src/main/java/org/opendaylight/groupbasedpolicy/renderer/ios_xe_provider/impl/config/IosXeProviderInstance.java index 4421bd10c..06601df08 100644 --- a/renderers/ios-xe/src/main/java/org/opendaylight/groupbasedpolicy/renderer/ios_xe_provider/impl/config/IosXeProviderInstance.java +++ b/renderers/ios-xe/src/main/java/org/opendaylight/groupbasedpolicy/renderer/ios_xe_provider/impl/config/IosXeProviderInstance.java @@ -53,7 +53,11 @@ public class IosXeProviderInstance implements ClusterSingletonService, AutoClose public void initialize() { LOG.info("Clustering session initiated for {}", this.getClass().getSimpleName()); + try { singletonServiceRegistration = clusterSingletonService.registerClusterSingletonService(this); + } catch (Exception e) { + LOG.warn("Exception thrown while registering cluster singleton service in {}", this.getClass(), e.getMessage()); + } } @Override diff --git a/renderers/iovisor/src/main/java/org/opendaylight/controller/config/yang/config/iovisor_provider/impl/IovisorProviderInstance.java b/renderers/iovisor/src/main/java/org/opendaylight/controller/config/yang/config/iovisor_provider/impl/IovisorProviderInstance.java index dec8474cb..dbb554028 100644 --- a/renderers/iovisor/src/main/java/org/opendaylight/controller/config/yang/config/iovisor_provider/impl/IovisorProviderInstance.java +++ b/renderers/iovisor/src/main/java/org/opendaylight/controller/config/yang/config/iovisor_provider/impl/IovisorProviderInstance.java @@ -48,7 +48,11 @@ public class IovisorProviderInstance implements ClusterSingletonService, AutoClo public void initialize() { LOG.info("Clustering session initiated for {}", this.getClass().getSimpleName()); + try { singletonServiceRegistration = clusteringServiceProvider.registerClusterSingletonService(this); + } catch (Exception e) { + LOG.warn("Exception thrown while registering cluster singleton service in {}", this.getClass(), e.getMessage()); + } } @Override diff --git a/renderers/ofoverlay/src/main/java/org/opendaylight/controller/config/yang/config/ofoverlay_provider/impl/OFOverlayProviderInstance.java b/renderers/ofoverlay/src/main/java/org/opendaylight/controller/config/yang/config/ofoverlay_provider/impl/OFOverlayProviderInstance.java index c8ff5486e..e5cedb4f2 100644 --- a/renderers/ofoverlay/src/main/java/org/opendaylight/controller/config/yang/config/ofoverlay_provider/impl/OFOverlayProviderInstance.java +++ b/renderers/ofoverlay/src/main/java/org/opendaylight/controller/config/yang/config/ofoverlay_provider/impl/OFOverlayProviderInstance.java @@ -67,7 +67,11 @@ public class OFOverlayProviderInstance implements ClusterSingletonService, AutoC public void initialize() { LOG.info("Clustering session initiated for {}", this.getClass().getSimpleName()); - singletonServiceRegistration = clusterSingletonService.registerClusterSingletonService(this); + try { + singletonServiceRegistration = clusterSingletonService.registerClusterSingletonService(this); + } catch (Exception e) { + LOG.warn("Exception thrown while registering cluster singleton service in {}", this.getClass(), e.getMessage()); + } } @Override diff --git a/renderers/vpp/src/main/java/org/opendaylight/controller/config/yang/config/vpp_provider/impl/GbpVppProviderInstance.java b/renderers/vpp/src/main/java/org/opendaylight/controller/config/yang/config/vpp_provider/impl/GbpVppProviderInstance.java index 29cb5fcdf..0b4f7ce5a 100644 --- a/renderers/vpp/src/main/java/org/opendaylight/controller/config/yang/config/vpp_provider/impl/GbpVppProviderInstance.java +++ b/renderers/vpp/src/main/java/org/opendaylight/controller/config/yang/config/vpp_provider/impl/GbpVppProviderInstance.java @@ -73,7 +73,11 @@ public class GbpVppProviderInstance implements ClusterSingletonService, VppAdapt public void initialize() { LOG.info("Clustering session initiated for {}", this.getClass().getSimpleName()); - singletonServiceRegistration = clusterSingletonService.registerClusterSingletonService(this); + try { + singletonServiceRegistration = clusterSingletonService.registerClusterSingletonService(this); + } catch (Exception e) { + LOG.warn("Exception thrown while registering cluster singleton service in {}", this.getClass(), e.getMessage()); + } } @Override diff --git a/sxp-integration/ip-sgt-distribution-service/src/main/java/org/opendaylight/controller/config/yang/config/ip/sgt/distribution/service/cfg/IpSgtDistributionServiceInstance.java b/sxp-integration/ip-sgt-distribution-service/src/main/java/org/opendaylight/controller/config/yang/config/ip/sgt/distribution/service/cfg/IpSgtDistributionServiceInstance.java index e1f963866..d695aae42 100644 --- a/sxp-integration/ip-sgt-distribution-service/src/main/java/org/opendaylight/controller/config/yang/config/ip/sgt/distribution/service/cfg/IpSgtDistributionServiceInstance.java +++ b/sxp-integration/ip-sgt-distribution-service/src/main/java/org/opendaylight/controller/config/yang/config/ip/sgt/distribution/service/cfg/IpSgtDistributionServiceInstance.java @@ -57,7 +57,11 @@ public class IpSgtDistributionServiceInstance public void initialize() { LOG.info("Clustering session initiated for {}", this.getClass().getSimpleName()); - singletonServiceRegistration = clusterSingletonService.registerClusterSingletonService(this); + try { + singletonServiceRegistration = clusterSingletonService.registerClusterSingletonService(this); + } catch (Exception e) { + LOG.warn("Exception thrown while registering cluster singleton service in {}", this.getClass(), e.getMessage()); + } } @Override diff --git a/sxp-integration/sxp-ep-provider/src/main/java/org/opendaylight/controller/config/yang/config/groupbasedpolicy/sxp_integration/sxp_ep_provider/SxpEpProviderProviderInstance.java b/sxp-integration/sxp-ep-provider/src/main/java/org/opendaylight/controller/config/yang/config/groupbasedpolicy/sxp_integration/sxp_ep_provider/SxpEpProviderProviderInstance.java index 59f18ec86..de7910c18 100644 --- a/sxp-integration/sxp-ep-provider/src/main/java/org/opendaylight/controller/config/yang/config/groupbasedpolicy/sxp_integration/sxp_ep_provider/SxpEpProviderProviderInstance.java +++ b/sxp-integration/sxp-ep-provider/src/main/java/org/opendaylight/controller/config/yang/config/groupbasedpolicy/sxp_integration/sxp_ep_provider/SxpEpProviderProviderInstance.java @@ -55,7 +55,11 @@ public class SxpEpProviderProviderInstance implements SxpEpProviderProvider, Clu public void initialize() { LOG.info("Clustering session initiated for {}", this.getClass().getSimpleName()); - singletonServiceRegistration = clusterSingletonService.registerClusterSingletonService(this); + try { + singletonServiceRegistration = clusterSingletonService.registerClusterSingletonService(this); + } catch (Exception e) { + LOG.warn("Exception thrown while registering cluster singleton service in {}", this.getClass(), e.getMessage()); + } } @Override diff --git a/sxp-integration/sxp-ise-adapter/src/main/java/org/opendaylight/controller/config/yang/config/groupbasedpolicy/sxp_integration/sxp_ise_adapter/SxpIseAdapterProviderInstance.java b/sxp-integration/sxp-ise-adapter/src/main/java/org/opendaylight/controller/config/yang/config/groupbasedpolicy/sxp_integration/sxp_ise_adapter/SxpIseAdapterProviderInstance.java index 520320f35..0bd4601e2 100644 --- a/sxp-integration/sxp-ise-adapter/src/main/java/org/opendaylight/controller/config/yang/config/groupbasedpolicy/sxp_integration/sxp_ise_adapter/SxpIseAdapterProviderInstance.java +++ b/sxp-integration/sxp-ise-adapter/src/main/java/org/opendaylight/controller/config/yang/config/groupbasedpolicy/sxp_integration/sxp_ise_adapter/SxpIseAdapterProviderInstance.java @@ -49,7 +49,11 @@ public class SxpIseAdapterProviderInstance implements ClusterSingletonService, A public void initialize() { LOG.info("Clustering session initiated for {}", this.getClass().getSimpleName()); - singletonServiceRegistration = clusterSingletonService.registerClusterSingletonService(this); + try { + singletonServiceRegistration = clusterSingletonService.registerClusterSingletonService(this); + } catch (Exception e) { + LOG.warn("Exception thrown while registering cluster singleton service in {}", this.getClass(), e.getMessage()); + } } @Override