vpnmanager/vpnmanager-impl/src/main/java/org/opendaylight/vpnservice/VpnserviceProvider.java

   1 /*
   2  * Copyright (c) 2015 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.vpnservice;
   9
  10 import java.math.BigInteger;
  11 import java.util.Collections;
  12 import java.util.concurrent.ExecutionException;
  13 import java.util.concurrent.Future;
  14
  15 import org.opendaylight.bgpmanager.api.IBgpManager;
  16 import org.opendaylight.controller.md.sal.binding.api.DataBroker;
  17 import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.ProviderContext;
  18 import org.opendaylight.controller.sal.binding.api.BindingAwareProvider;
  19 import org.opendaylight.vpnservice.interfacemgr.interfaces.IInterfaceManager;
  20 import org.opendaylight.vpnservice.mdsalutil.interfaces.IMdsalApiManager;
  21 import org.opendaylight.yang.gen.v1.urn.opendaylight.vpnservice.idmanager.rev150403.CreateIdPoolInput;
  22 import org.opendaylight.yang.gen.v1.urn.opendaylight.vpnservice.idmanager.rev150403.CreateIdPoolInputBuilder;
  23 import org.opendaylight.yang.gen.v1.urn.opendaylight.vpnservice.idmanager.rev150403.IdManagerService;
  24 import org.opendaylight.yangtools.yang.common.RpcResult;
  25 import org.slf4j.Logger;
  26 import org.slf4j.LoggerFactory;
  27
  28 public class VpnserviceProvider implements BindingAwareProvider,
  29                                                        AutoCloseable {
  30
  31     private static final Logger LOG = LoggerFactory.getLogger(VpnserviceProvider.class);
  32     private VpnInterfaceManager vpnInterfaceManager;
  33     private VpnManager vpnManager;
  34     private IBgpManager bgpManager;
  35     private IMdsalApiManager mdsalManager;
  36     private IInterfaceManager interfaceManager;
  37     private IdManagerService idManager;
  38
  39     @Override
  40     public void onSessionInitiated(ProviderContext session) {
  41         LOG.info("VpnserviceProvider Session Initiated");
  42         try {
  43             final  DataBroker dataBroker = session.getSALService(DataBroker.class);
  44             vpnManager = new VpnManager(dataBroker, bgpManager);
  45             vpnManager.setIdManager(idManager);
  46             vpnInterfaceManager = new VpnInterfaceManager(dataBroker, bgpManager);
  47             vpnInterfaceManager.setMdsalManager(mdsalManager);
  48             vpnInterfaceManager.setInterfaceManager(interfaceManager);
  49             vpnInterfaceManager.setIdManager(idManager);
  50             createIdPool();
  51         } catch (Exception e) {
  52             LOG.error("Error initializing services", e);
  53         }
  54     }
  55
  56     public void setBgpManager(IBgpManager bgpManager) {
  57         LOG.debug("BGP Manager reference initialized");
  58         this.bgpManager = bgpManager;
  59     }
  60
  61     public void setMdsalManager(IMdsalApiManager mdsalManager) {
  62         this.mdsalManager = mdsalManager;
  63     }
  64
  65     public void setInterfaceManager(IInterfaceManager interfaceManager) {
  66         this.interfaceManager = interfaceManager;
  67     }
  68
  69     public void setIdManager(IdManagerService idManager) {
  70         this.idManager = idManager;
  71     }
  72
  73     private void createIdPool() {
  74         CreateIdPoolInput createPool = new CreateIdPoolInputBuilder()
  75             .setPoolName(VpnConstants.VPN_IDPOOL_NAME)
  76             .setIdStart(VpnConstants.VPN_IDPOOL_START)
  77             .setPoolSize(new BigInteger(VpnConstants.VPN_IDPOOL_SIZE))
  78             .build();
  79         try {
  80            Future<RpcResult<Void>> result = idManager.createIdPool(createPool);
  81            if ((result != null) && (result.get().isSuccessful())) {
  82                 LOG.info("Created IdPool for VPN Service");
  83             }
  84         } catch (InterruptedException | ExecutionException e) {
  85             LOG.error("Failed to create idPool for VPN Service",e);
  86         }
  87     }
  88
  89     @Override
  90     public void close() throws Exception {
  91         vpnManager.close();
  92         vpnInterfaceManager.close();
  93     }
  94 }