applications/forwardingrules-manager/src/main/java/org/opendaylight/openflowplugin/applications/frm/recovery/impl/OpenflowServiceRecoveryHandlerImpl.java

   1 /*
   2  * Copyright (c) 2018 Ericsson India Global Services Pvt Ltd. and others.  All rights reserved.
   3  *
   4  * This program and the accompanying materials are made available under the
   5  * terms of the Eclipse Public License v1.0 which accompanies this distribution,
   6  * and is available at http://www.eclipse.org/legal/epl-v10.html
   7  */
   8 package org.opendaylight.openflowplugin.applications.frm.recovery.impl;
   9
  10 import javax.inject.Inject;
  11 import javax.inject.Singleton;
  12 import org.opendaylight.openflowplugin.applications.frm.recovery.OpenflowServiceRecoveryHandler;
  13 import org.opendaylight.serviceutils.srm.RecoverableListener;
  14 import org.opendaylight.serviceutils.srm.ServiceRecoveryInterface;
  15 import org.opendaylight.serviceutils.srm.ServiceRecoveryRegistry;
  16 import org.opendaylight.yang.gen.v1.urn.opendaylight.serviceutils.srm.types.rev180626.Ofplugin;
  17 import org.slf4j.Logger;
  18 import org.slf4j.LoggerFactory;
  19
  20 @Singleton
  21 public class OpenflowServiceRecoveryHandlerImpl implements ServiceRecoveryInterface,
  22         OpenflowServiceRecoveryHandler {
  23
  24     private static final Logger LOG = LoggerFactory.getLogger(OpenflowServiceRecoveryHandlerImpl.class);
  25
  26     private final ServiceRecoveryRegistry serviceRecoveryRegistry;
  27
  28     @Inject
  29     public OpenflowServiceRecoveryHandlerImpl(final ServiceRecoveryRegistry serviceRecoveryRegistry) {
  30         LOG.info("Registering openflowplugin service recovery handlers");
  31         this.serviceRecoveryRegistry = serviceRecoveryRegistry;
  32         serviceRecoveryRegistry.registerServiceRecoveryRegistry(buildServiceRegistryKey(), this);
  33     }
  34
  35     private void deregisterListeners() {
  36         serviceRecoveryRegistry.getRecoverableListeners(buildServiceRegistryKey())
  37                 .forEach(RecoverableListener::deregisterListener);
  38     }
  39
  40     private void registerListeners() {
  41         serviceRecoveryRegistry.getRecoverableListeners(buildServiceRegistryKey())
  42                 .forEach(RecoverableListener::registerListener);
  43     }
  44
  45     @Override
  46     public void recoverService(final String entityId) {
  47         LOG.info("Recover Openflowplugin service by deregistering and registering all relevant listeners");
  48         deregisterListeners();
  49         //FIXME: device group registry cache to be cleared before starting the listeners
  50         registerListeners();
  51     }
  52
  53     @Override
  54     public String buildServiceRegistryKey() {
  55         return Ofplugin.class.toString();
  56     }
  57 }