netvirt/src/main/java/org/opendaylight/unimgr/mef/netvirt/MefUtils.java

   1 /*
   2  * Copyright (c) 2016 Hewlett Packard Enterprise, Co. 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
   9 package org.opendaylight.unimgr.mef.netvirt;
  10
  11 import org.opendaylight.controller.md.sal.binding.api.DataBroker;
  12 import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
  13 import org.opendaylight.yang.gen.v1.http.metroethernetforum.org.ns.yang.mef.interfaces.rev150526.MefInterfaces;
  14 import org.opendaylight.yang.gen.v1.http.metroethernetforum.org.ns.yang.mef.interfaces.rev150526.mef.interfaces.Unis;
  15 import org.opendaylight.yang.gen.v1.http.metroethernetforum.org.ns.yang.mef.interfaces.rev150526.mef.interfaces.unis.Uni;
  16 import org.opendaylight.yang.gen.v1.http.metroethernetforum.org.ns.yang.mef.interfaces.rev150526.mef.interfaces.unis.UniKey;
  17 import org.opendaylight.yang.gen.v1.http.metroethernetforum.org.ns.yang.mef.interfaces.rev150526.mef.interfaces.unis.uni.PhysicalLayers;
  18 import org.opendaylight.yang.gen.v1.http.metroethernetforum.org.ns.yang.mef.interfaces.rev150526.mef.interfaces.unis.uni.physical.layers.Links;
  19 import org.opendaylight.yang.gen.v1.http.metroethernetforum.org.ns.yang.mef.interfaces.rev150526.mef.interfaces.unis.uni.physical.layers.links.Link;
  20 import org.opendaylight.yang.gen.v1.http.metroethernetforum.org.ns.yang.mef.interfaces.rev150526.mef.interfaces.unis.uni.physical.layers.links.LinkKey;
  21 import org.opendaylight.yang.gen.v1.http.metroethernetforum.org.ns.yang.mef.services.rev150526.MefServices;
  22 import org.opendaylight.yang.gen.v1.http.metroethernetforum.org.ns.yang.mef.services.rev150526.mef.services.MefService;
  23 import org.opendaylight.yang.gen.v1.http.metroethernetforum.org.ns.yang.mef.services.rev150526.mef.services.MefServiceKey;
  24 import org.opendaylight.yang.gen.v1.http.metroethernetforum.org.ns.yang.mef.services.rev150526.mef.services.mef.service.Evc;
  25 import org.opendaylight.yang.gen.v1.http.metroethernetforum.org.ns.yang.mef.services.rev150526.mef.services.mef.service.EvcBuilder;
  26 import org.opendaylight.yang.gen.v1.http.metroethernetforum.org.ns.yang.mef.services.rev150526.mef.services.mef.service.evc.unis.uni.EvcUniCeVlans;
  27 import org.opendaylight.yang.gen.v1.http.metroethernetforum.org.ns.yang.mef.services.rev150526.mef.services.mef.service.evc.unis.uni.evc.uni.ce.vlans.EvcUniCeVlan;
  28 import org.opendaylight.yang.gen.v1.http.metroethernetforum.org.ns.yang.mef.services.rev150526.mef.services.mef.service.evc.unis.uni.evc.uni.ce.vlans.EvcUniCeVlanBuilder;
  29 import org.opendaylight.yang.gen.v1.http.metroethernetforum.org.ns.yang.mef.topology.rev150526.MefTopology;
  30 import org.opendaylight.yang.gen.v1.http.metroethernetforum.org.ns.yang.mef.topology.rev150526.mef.topology.Devices;
  31 import org.opendaylight.yang.gen.v1.http.metroethernetforum.org.ns.yang.mef.topology.rev150526.mef.topology.devices.Device;
  32 import org.opendaylight.yang.gen.v1.http.metroethernetforum.org.ns.yang.mef.topology.rev150526.mef.topology.devices.DeviceKey;
  33 import org.opendaylight.yang.gen.v1.http.metroethernetforum.org.ns.yang.mef.topology.rev150526.mef.topology.devices.device.Interfaces;
  34 import org.opendaylight.yang.gen.v1.http.metroethernetforum.org.ns.yang.mef.topology.rev150526.mef.topology.devices.device.interfaces.Interface;
  35 import org.opendaylight.yang.gen.v1.http.metroethernetforum.org.ns.yang.mef.topology.rev150526.mef.topology.devices.device.interfaces.InterfaceKey;
  36 import org.opendaylight.yang.gen.v1.http.metroethernetforum.org.ns.yang.mef.types.rev150526.EvcIdType;
  37 import org.opendaylight.yang.gen.v1.http.metroethernetforum.org.ns.yang.mef.types.rev150526.EvcType;
  38 import org.opendaylight.yang.gen.v1.http.metroethernetforum.org.ns.yang.mef.types.rev150526.Identifier45;
  39 import org.opendaylight.yang.gen.v1.http.metroethernetforum.org.ns.yang.mef.types.rev150526.RetailSvcIdType;
  40 import org.opendaylight.yang.gen.v1.http.metroethernetforum.org.ns.yang.mef.types.rev150526.EvcStatusType;
  41 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
  42 import org.slf4j.Logger;
  43 import org.slf4j.LoggerFactory;
  44
  45 import com.google.common.base.Optional;
  46
  47 public final class MefUtils {
  48     @SuppressWarnings("unused")
  49     private static final Logger logger = LoggerFactory.getLogger(MefUtils.class);
  50
  51     public static InstanceIdentifier<Interface> getDeviceInterfaceInstanceIdentifier(String deviceId,
  52             String interfaceId) {
  53         return InstanceIdentifier.builder(MefTopology.class).child(Devices.class)
  54                 .child(Device.class, new DeviceKey(new Identifier45(deviceId))).child(Interfaces.class)
  55                 .child(Interface.class, new InterfaceKey(new Identifier45(interfaceId))).build();
  56     }
  57
  58     public static InstanceIdentifier<Uni> getUniInstanceIdentifier(String uniId) {
  59         return InstanceIdentifier.builder(MefInterfaces.class).child(Unis.class)
  60                 .child(Uni.class, new UniKey(new Identifier45(uniId))).build();
  61     }
  62
  63     public static InstanceIdentifier<Uni> getUniListInterfaceInstanceIdentifier() {
  64         return InstanceIdentifier.builder(MefInterfaces.class).child(Unis.class).child(Uni.class).build();
  65     }
  66
  67     public static InstanceIdentifier<org.opendaylight.yang.gen.v1.http.metroethernetforum.org.ns.yang.mef.services.rev150526.mef.services.mef.service.evc.Unis> getUnisInstanceIdentifier(
  68             String evcId) {
  69         return InstanceIdentifier.builder(MefServices.class)
  70                 .child(MefService.class, new MefServiceKey(RetailSvcIdType.getDefaultInstance(evcId))).child(Evc.class)
  71                 .child(org.opendaylight.yang.gen.v1.http.metroethernetforum.org.ns.yang.mef.services.rev150526.mef.services.mef.service.evc.Unis.class)
  72                 .build();
  73     }
  74
  75     public static InstanceIdentifier<org.opendaylight.yang.gen.v1.http.metroethernetforum.org.ns.yang.mef.services.rev150526.mef.services.mef.service.evc.unis.Uni> getEvcUniInstanceIdentifier(
  76             String uniId) {
  77         return InstanceIdentifier.builder(MefServices.class).child(MefService.class).child(Evc.class)
  78                 .child(org.opendaylight.yang.gen.v1.http.metroethernetforum.org.ns.yang.mef.services.rev150526.mef.services.mef.service.evc.Unis.class)
  79                 .child(org.opendaylight.yang.gen.v1.http.metroethernetforum.org.ns.yang.mef.services.rev150526.mef.services.mef.service.evc.unis.Uni.class,
  80                         new org.opendaylight.yang.gen.v1.http.metroethernetforum.org.ns.yang.mef.services.rev150526.mef.services.mef.service.evc.unis.UniKey(
  81                                 new Identifier45(uniId)))
  82                 .build();
  83     }
  84
  85     public static InstanceIdentifier<Link> getUniLinkInstanceIdentifier(String uniId, String deviceId,
  86             String interfaceId) {
  87         return InstanceIdentifier.builder(MefInterfaces.class).child(Unis.class)
  88                 .child(Uni.class, new UniKey(new Identifier45(uniId))).child(PhysicalLayers.class).child(Links.class)
  89                 .child(Link.class, new LinkKey(new Identifier45(deviceId), interfaceId)).build();
  90     }
  91
  92     public static InstanceIdentifier<Evc> getEvcInstanceIdentifier() {
  93         return getMefServiceInstanceIdentifier().child(Evc.class);
  94     }
  95
  96     public static InstanceIdentifier<MefService> getMefServiceInstanceIdentifier() {
  97         return InstanceIdentifier.create(MefServices.class).child(MefService.class);
  98     }
  99
 100     public static InstanceIdentifier<MefService> getMefServiceInstanceIdentifier(
 101             RetailSvcIdType retailSvcIdType) {
 102         return InstanceIdentifier.create(MefServices.class).child(MefService.class, new MefServiceKey(retailSvcIdType));
 103     }
 104
 105     public static InstanceIdentifier<MefServices> getMefServicesInstanceIdentifier() {
 106         return InstanceIdentifier.create(MefServices.class);
 107     }
 108
 109     public static void createEvcInstance(DataBroker dataBroker, String instanceName) {
 110         Evc einst = createEvcInstance(instanceName);
 111
 112         MdsalUtils.syncWrite(dataBroker, LogicalDatastoreType.CONFIGURATION,
 113                 getEvcInstanceInstanceIdentifier(instanceName), einst);
 114     }
 115
 116     private static InstanceIdentifier<Evc> getEvcInstanceInstanceIdentifier(String instanceName) {
 117         return InstanceIdentifier.builder(MefServices.class)
 118                 .child(MefService.class, new MefServiceKey(RetailSvcIdType.getDefaultInstance(instanceName)))
 119                 .child(Evc.class).build();
 120     }
 121
 122     private static InstanceIdentifier<org.opendaylight.yang.gen.v1.http.metroethernetforum.org.ns.yang.mef.services.rev150526.mef.services.mef.service.evc.unis.Uni> getEvcUniInstanceIdentifier(
 123             String serviceName, String uniId) {
 124         return InstanceIdentifier.builder(MefServices.class)
 125                 .child(MefService.class, new MefServiceKey(RetailSvcIdType.getDefaultInstance(serviceName)))
 126                 .child(Evc.class)
 127                 .child(org.opendaylight.yang.gen.v1.http.metroethernetforum.org.ns.yang.mef.services.rev150526.mef.services.mef.service.evc.Unis.class)
 128                 .child(org.opendaylight.yang.gen.v1.http.metroethernetforum.org.ns.yang.mef.services.rev150526.mef.services.mef.service.evc.unis.Uni.class, //
 129                         new org.opendaylight.yang.gen.v1.http.metroethernetforum.org.ns.yang.mef.services.rev150526.mef.services.mef.service.evc.unis.UniKey(
 130                                 Identifier45.getDefaultInstance(uniId)))
 131                 .build();
 132     }
 133
 134     private static Evc createEvcInstance(String instanceName) {
 135         EvcBuilder evcBuilder = new EvcBuilder();
 136         evcBuilder.setAdminStateEnabled(false);
 137         evcBuilder.setEvcId(EvcIdType.getDefaultInstance(instanceName));
 138         evcBuilder.setEvcType(EvcType.MultipointToMultipoint);
 139         return evcBuilder.build();
 140     }
 141
 142     public static Boolean EvcExists(DataBroker dataBroker, String instanceName) {
 143         Optional<Evc> evc = getEvc(dataBroker, instanceName);
 144         return evc.isPresent();
 145     }
 146
 147     public static Boolean isEvcAdminStateEnabled(DataBroker dataBroker, String instanceName) {
 148         Optional<Evc> evc = getEvc(dataBroker, instanceName);
 149         return evc.isPresent() && evc.get().isAdminStateEnabled();
 150
 151     }
 152
 153     public static Optional<Evc> getEvc(DataBroker dataBroker, String instanceName) {
 154         Optional<Evc> evc = MdsalUtils.read(dataBroker, LogicalDatastoreType.CONFIGURATION,
 155                 getEvcInstanceInstanceIdentifier(instanceName));
 156         return evc;
 157     }
 158
 159     public static Boolean EvcUniExists(DataBroker dataBroker, String instanceName, String uniId) {
 160         logger.info("searching for uni id {} in service {}", uniId, instanceName);
 161         Optional<org.opendaylight.yang.gen.v1.http.metroethernetforum.org.ns.yang.mef.services.rev150526.mef.services.mef.service.evc.unis.Uni> uni = MdsalUtils
 162                 .read(dataBroker, LogicalDatastoreType.CONFIGURATION, getEvcUniInstanceIdentifier(instanceName, uniId));
 163         if (uni.isPresent()) {
 164             logger.info("found uni");
 165         } else {
 166             logger.info("no uni");
 167         }
 168         return uni.isPresent();
 169     }
 170
 171 }