openflowplugin/src/main/java/org/opendaylight/openflowplugin/openflow/md/util/PortTranslatorUtil.java

   1 /**
   2  * Copyright (c) 2013 Cisco 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.openflowplugin.openflow.md.util;
   9
  10 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.FlowCapableNodeConnectorUpdated;
  11 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.FlowCapableNodeConnectorUpdatedBuilder;
  12 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.port.rev130925.flow.capable.port.State;
  13 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.port.rev130925.flow.capable.port.StateBuilder;
  14 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeConnectorUpdated;
  15 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeConnectorUpdatedBuilder;
  16 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.PortConfig;
  17 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.PortConfigV10;
  18 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.PortFeatures;
  19 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.PortFeaturesV10;
  20 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.PortState;
  21 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.PortStateV10;
  22 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.PortGrouping;
  23
  24 import java.math.BigInteger;
  25
  26 public abstract class PortTranslatorUtil {
  27     public static  org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.port.rev130925.PortFeatures translatePortFeatures(PortFeatures apf) {
  28         org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.port.rev130925.PortFeatures napf = null;
  29         if(apf != null){
  30                 napf = new org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.port.rev130925.PortFeatures(
  31                         apf.is_100gbFd(),apf.is_100mbFd(),apf.is_100mbHd(),apf.is_10gbFd(),apf.is_10mbFd(),apf.is_10mbHd(),
  32                         apf.is_1gbFd(),apf.is_1gbHd(),apf.is_1tbFd(),apf.is_40gbFd(),apf.isAutoneg(),apf.isCopper(),apf.isFiber(),apf.isOther(),
  33                         apf.isPause(), apf.isPauseAsym());
  34         }
  35         return napf;
  36     }
  37
  38     public static org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.port.rev130925.PortFeatures translatePortFeatures(
  39             PortFeaturesV10 apf) {
  40         org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.port.rev130925.PortFeatures napf = null;
  41         if(apf != null){
  42                 napf = new org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.port.rev130925.PortFeatures(
  43                         false,apf.is_100mbFd(),apf.is_100mbHd(),apf.is_10gbFd(),apf.is_10mbFd(),apf.is_10mbHd(),
  44                         apf.is_1gbFd(),apf.is_1gbHd(),false,false,apf.isAutoneg(),apf.isCopper(),apf.isFiber(),false,
  45                         apf.isPause(), apf.isPauseAsym());
  46         }
  47         return napf;
  48     }
  49
  50     public static  State translatePortState(PortState state) {
  51         StateBuilder nstate = new StateBuilder();
  52         if(state !=null) {
  53             nstate.setBlocked(state.isBlocked());
  54             nstate.setLinkDown(state.isLinkDown());
  55             nstate.setLive(state.isLive());
  56         }
  57         return nstate.build();
  58     }
  59
  60     public static State translatePortState(PortStateV10 state) {
  61         StateBuilder nstate = new StateBuilder();
  62         if(state !=null) {
  63             nstate.setBlocked(state.isBlocked());
  64             nstate.setLinkDown(state.isLinkDown());
  65             nstate.setLive(state.isLive());
  66         }
  67         return nstate.build();
  68     }
  69
  70     public static org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.port.rev130925.PortConfig translatePortConfig(PortConfig pc) {
  71         org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.port.rev130925.PortConfig npc = null;
  72         if(pc != null) {
  73                 npc = new org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.port.rev130925.PortConfig(pc.isNoFwd(),
  74                         pc.isNoPacketIn(), pc.isNoRecv(), pc.isPortDown());
  75         }
  76         return npc;
  77     }
  78
  79     public static org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.port.rev130925.PortConfig translatePortConfig(
  80             PortConfigV10 pc) {
  81         org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.port.rev130925.PortConfig npc = null;
  82         if(pc != null) {
  83                 npc = new org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.port.rev130925.PortConfig(pc.isNoFwd(),
  84                         pc.isNoPacketIn(), pc.isNoRecv(), pc.isPortDown());
  85         }
  86         return npc;
  87     }
  88
  89     public static NodeConnectorUpdated translatePort(Short version, BigInteger datapathId,Long portNumber, PortGrouping port) {
  90         OpenflowVersion ofVersion =  OpenflowVersion.get(version);
  91         NodeConnectorUpdatedBuilder builder = InventoryDataServiceUtil
  92                 .nodeConnectorUpdatedBuilderFromDatapathIdPortNo(datapathId, port.getPortNo(), ofVersion);
  93         FlowCapableNodeConnectorUpdatedBuilder fcncub = new FlowCapableNodeConnectorUpdatedBuilder();
  94         if(ofVersion == OpenflowVersion.OF13) {
  95             fcncub.setAdvertisedFeatures(PortTranslatorUtil.translatePortFeatures(port.getAdvertisedFeatures()));
  96             fcncub.setConfiguration(PortTranslatorUtil.translatePortConfig(port.getConfig()));
  97             fcncub.setCurrentFeature(PortTranslatorUtil.translatePortFeatures(port.getCurrentFeatures()));
  98             fcncub.setPeerFeatures(PortTranslatorUtil.translatePortFeatures(port.getPeerFeatures()));
  99             fcncub.setState(PortTranslatorUtil.translatePortState(port.getState()));
 100             fcncub.setSupported(PortTranslatorUtil.translatePortFeatures(port.getSupportedFeatures()));
 101
 102         } else if (ofVersion == OpenflowVersion.OF10) {
 103             fcncub.setAdvertisedFeatures(PortTranslatorUtil.translatePortFeatures(port.getAdvertisedFeaturesV10()));
 104             fcncub.setConfiguration(PortTranslatorUtil.translatePortConfig(port.getConfigV10()));
 105             fcncub.setCurrentFeature(PortTranslatorUtil.translatePortFeatures(port.getCurrentFeaturesV10()));
 106             fcncub.setPeerFeatures(PortTranslatorUtil.translatePortFeatures(port.getPeerFeaturesV10()));
 107             fcncub.setState(PortTranslatorUtil.translatePortState(port.getStateV10()));
 108             fcncub.setSupported(PortTranslatorUtil.translatePortFeatures(port.getSupportedFeaturesV10()));
 109         }
 110         fcncub.setCurrentSpeed(port.getCurrSpeed());
 111         fcncub.setHardwareAddress(port.getHwAddr());
 112         fcncub.setMaximumSpeed(port.getMaxSpeed());
 113         fcncub.setName(port.getName());
 114         fcncub.setPortNumber(OpenflowPortsUtil.getProtocolAgnosticPort(ofVersion, portNumber));
 115         builder.addAugmentation(FlowCapableNodeConnectorUpdated.class, fcncub.build());
 116         return builder.build();
 117     }
 118 }