openstack/net-virt/src/main/java/org/opendaylight/netvirt/openstack/netvirt/NeutronModelsDataStoreHelper.java

   1 /*
   2  * Copyright (c) 2015 Brocade Communications Systems, Inc. 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.netvirt.openstack.netvirt;
   9
  10 import org.opendaylight.controller.md.sal.binding.api.DataBroker;
  11 import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
  12 import org.opendaylight.netvirt.utils.mdsal.utils.MdsalUtils;
  13 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.types.rev130715.Uuid;
  14 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.l3.rev150712.routers.attributes.Routers;
  15 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.networks.rev150712.networks.attributes.Networks;
  16 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.networks.rev150712.networks.attributes.networks.Network;
  17 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.networks.rev150712.networks.attributes.networks.NetworkKey;
  18 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.ports.rev150712.ports.attributes.Ports;
  19 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.ports.rev150712.ports.attributes.ports.Port;
  20 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.ports.rev150712.ports.attributes.ports.PortKey;
  21 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.rev150712.Neutron;
  22 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
  23 import org.slf4j.Logger;
  24 import org.slf4j.LoggerFactory;
  25
  26 public class NeutronModelsDataStoreHelper {
  27
  28     private static final Logger LOG = LoggerFactory.getLogger(MdsalUtils.class);
  29     private DataBroker databroker = null;
  30     private MdsalUtils mdsalClient = null;
  31
  32     /**
  33      * Class constructor setting the data broker.
  34      *
  35      * @param dataBroker the {@link org.opendaylight.controller.md.sal.binding.api.DataBroker}
  36      */
  37     public NeutronModelsDataStoreHelper(DataBroker dataBroker) {
  38         this.databroker = dataBroker;
  39         this.mdsalClient = new MdsalUtils(this.databroker);
  40     }
  41
  42     public Routers readAllNeutronRouters() {
  43         Routers routers = this.mdsalClient.read(LogicalDatastoreType.CONFIGURATION, getNeutrounRoutersPath());
  44         if(routers != null ) {
  45             LOG.debug("{} routers present in data store", routers.getRouter()!=null? routers.getRouter().size():0);
  46         }
  47         return routers;
  48     }
  49
  50     public Ports readAllNeutronPorts() {
  51         Ports ports = this.mdsalClient.read(LogicalDatastoreType.CONFIGURATION, getNeutrounPortsPath());
  52         if(ports != null ) {
  53             LOG.debug("{} ports present in data store", ports.getPort()!=null? ports.getPort().size():0);
  54         }
  55         return ports;
  56     }
  57     public Port readNeutronPort(Uuid portId) {
  58         Port mdsalPort = this.mdsalClient.read(LogicalDatastoreType.CONFIGURATION, getNeutronPortPath(portId));
  59         if (mdsalPort != null) {
  60             LOG.debug("Port {} fetched from config data store for router interface {}",mdsalPort, portId);
  61         }
  62         return mdsalPort;
  63     }
  64
  65     public InstanceIdentifier<Routers> getNeutrounRoutersPath() {
  66         return InstanceIdentifier
  67                 .create(Neutron.class)
  68                 .child(Routers.class);
  69     }
  70
  71     public InstanceIdentifier<Ports> getNeutrounPortsPath() {
  72         return InstanceIdentifier
  73                 .create(Neutron.class)
  74                 .child(Ports.class);
  75     }
  76
  77     public InstanceIdentifier<Port> getNeutronPortPath(Uuid portId) {
  78         return InstanceIdentifier
  79                 .create(Neutron.class)
  80                 .child(Ports.class)
  81                 .child(Port.class,new PortKey(portId));
  82     }
  83
  84     public InstanceIdentifier<Network> getNeutronNetworkPath(Uuid networkId) {
  85         return InstanceIdentifier
  86                 .create(Neutron.class)
  87                 .child(Networks.class)
  88                 .child(Network.class,new NetworkKey(networkId));
  89     }
  90 }