vpnservice/sfc/classifier/impl/src/main/java/org/opendaylight/netvirt/sfc/classifier/service/domain/impl/OpenflowRenderer.java

   1 /*
   2  * Copyright (c) 2017 Ericsson 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
   9 package org.opendaylight.netvirt.sfc.classifier.service.domain.impl;
  10
  11 import java.util.ArrayList;
  12 import java.util.List;
  13 import org.opendaylight.controller.md.sal.binding.api.DataBroker;
  14 import org.opendaylight.controller.md.sal.binding.api.WriteTransaction;
  15 import org.opendaylight.netvirt.sfc.classifier.providers.GeniusProvider;
  16 import org.opendaylight.netvirt.sfc.classifier.providers.OpenFlow13Provider;
  17 import org.opendaylight.netvirt.sfc.classifier.service.domain.api.ClassifierEntryRenderer;
  18 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.access.control.list.rev160218.access.lists.acl.access.list.entries.ace.Matches;
  19 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.InterfaceKey;
  20 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.tables.table.Flow;
  21 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeId;
  22 import org.slf4j.Logger;
  23 import org.slf4j.LoggerFactory;
  24
  25 public class OpenflowRenderer implements ClassifierEntryRenderer {
  26
  27     private static final Logger LOG = LoggerFactory.getLogger(OpenflowRenderer.class);
  28
  29     private final OpenFlow13Provider openFlow13Provider;
  30     private final GeniusProvider geniusProvider;
  31     private final DataBroker dataBroker;
  32
  33     public OpenflowRenderer(OpenFlow13Provider openFlow13Provider, GeniusProvider geniusProvider,
  34         DataBroker dataBroker) {
  35         this.openFlow13Provider = openFlow13Provider;
  36         this.geniusProvider = geniusProvider;
  37         this.dataBroker = dataBroker;
  38     }
  39
  40     @Override
  41     public void renderIngress(InterfaceKey interfaceKey) {
  42         // noop
  43     }
  44
  45     @Override
  46     public void renderNode(NodeId nodeId) {
  47         List<Flow> flows = new ArrayList<>();
  48         flows.add(this.openFlow13Provider.createIngressClassifierFilterVxgpeNshFlow(nodeId));
  49         flows.add(this.openFlow13Provider.createIngressClassifierFilterEthNshFlow(nodeId));
  50         flows.add(this.openFlow13Provider.createIngressClassifierFilterNoNshFlow(nodeId));
  51         flows.add(this.openFlow13Provider.createIngressClassifierAclNoMatchFlow(nodeId));
  52
  53         flows.add(this.openFlow13Provider.createEgressClassifierFilterNshFlow(nodeId));
  54         flows.add(this.openFlow13Provider.createEgressClassifierFilterNoNshFlow(nodeId));
  55
  56         flows.add(this.openFlow13Provider.createEgressClassifierNextHopC1C2Flow(nodeId));
  57         flows.add(this.openFlow13Provider.createEgressClassifierNextHopNoC1C2Flow(nodeId));
  58
  59         WriteTransaction tx = this.dataBroker.newWriteOnlyTransaction();
  60         flows.forEach(flow -> this.openFlow13Provider.appendFlowForCreate(nodeId, flow, tx));
  61         tx.submit();
  62     }
  63
  64     @Override
  65     public void renderPath(NodeId nodeId, Long nsp, String firstHopIp) {
  66         Long port = geniusProvider.getEgressVxlanPortForNode(OpenFlow13Provider.getDpnIdFromNodeId(nodeId))
  67                 .orElse(null);
  68
  69         if (port == null) {
  70             LOG.error("OpenflowRenderer: cant get egressPort for nodeId [{}]", nodeId.getValue());
  71             return;
  72         }
  73
  74         Flow flow = firstHopIp == null
  75                 ? openFlow13Provider.createEgressClassifierTransportEgressLocalFlow(nodeId, nsp)
  76                 : openFlow13Provider.createEgressClassifierTransportEgressRemoteFlow(nodeId, nsp, port, firstHopIp);
  77
  78         WriteTransaction tx = this.dataBroker.newWriteOnlyTransaction();
  79         this.openFlow13Provider.appendFlowForCreate(nodeId, flow, tx);
  80         tx.submit();
  81     }
  82
  83     @Override
  84     public void renderMatch(NodeId nodeId, String connector, Matches matches, Long nsp, Short nsi) {
  85         Long port = OpenFlow13Provider.getPortNoFromNodeConnector(connector);
  86         Flow flow = this.openFlow13Provider.createIngressClassifierAclFlow(
  87                 nodeId, this.openFlow13Provider.getMatchBuilderFromAceMatches(matches), port, nsp, nsi);
  88
  89         WriteTransaction tx = this.dataBroker.newWriteOnlyTransaction();
  90         this.openFlow13Provider.appendFlowForCreate(nodeId, flow, tx);
  91         tx.submit();
  92     }
  93
  94     @Override
  95     public void renderEgress(InterfaceKey interfaceKey, String destinationIp) {
  96         // noop
  97     }
  98
  99     @Override
 100     public void suppressIngress(InterfaceKey interfaceKey) {
 101         // noop
 102     }
 103
 104     @Override
 105     public void suppressNode(NodeId nodeId) {
 106         List<Flow> flows = new ArrayList<>();
 107         flows.add(this.openFlow13Provider.createIngressClassifierFilterVxgpeNshFlow(nodeId));
 108         flows.add(this.openFlow13Provider.createIngressClassifierFilterEthNshFlow(nodeId));
 109         flows.add(this.openFlow13Provider.createIngressClassifierFilterNoNshFlow(nodeId));
 110
 111         flows.add(this.openFlow13Provider.createEgressClassifierFilterNshFlow(nodeId));
 112         flows.add(this.openFlow13Provider.createEgressClassifierFilterNoNshFlow(nodeId));
 113
 114         flows.add(this.openFlow13Provider.createEgressClassifierNextHopC1C2Flow(nodeId));
 115         flows.add(this.openFlow13Provider.createEgressClassifierNextHopNoC1C2Flow(nodeId));
 116
 117         WriteTransaction tx = this.dataBroker.newWriteOnlyTransaction();
 118         flows.forEach(flow -> this.openFlow13Provider.appendFlowForDelete(nodeId, flow, tx));
 119         tx.submit();
 120     }
 121
 122     @Override
 123     public void suppressPath(NodeId nodeId, Long nsp, String firstHopIp) {
 124         Long port = geniusProvider.getEgressVxlanPortForNode(OpenFlow13Provider.getDpnIdFromNodeId(nodeId))
 125                 .orElse(null);
 126
 127         if (port == null) {
 128             LOG.error("OpenflowRenderer: cant get egressPort for nodeId [{}]", nodeId.getValue());
 129             return;
 130         }
 131
 132         Flow flow = firstHopIp == null
 133                 ? openFlow13Provider.createEgressClassifierTransportEgressLocalFlow(nodeId, nsp)
 134                 : openFlow13Provider.createEgressClassifierTransportEgressRemoteFlow(nodeId, nsp, port, firstHopIp);
 135
 136         WriteTransaction tx = this.dataBroker.newWriteOnlyTransaction();
 137         this.openFlow13Provider.appendFlowForCreate(nodeId, flow, tx);
 138         tx.submit();
 139     }
 140
 141     @Override
 142     public void suppressMatch(NodeId nodeId, String connector, Matches matches, Long nsp, Short nsi) {
 143         Long port = OpenFlow13Provider.getPortNoFromNodeConnector(connector);
 144         Flow flow = this.openFlow13Provider.createIngressClassifierAclFlow(
 145                 nodeId, this.openFlow13Provider.getMatchBuilderFromAceMatches(matches), port, nsp, nsi);
 146
 147         WriteTransaction tx = this.dataBroker.newWriteOnlyTransaction();
 148         this.openFlow13Provider.appendFlowForDelete(nodeId, flow, tx);
 149         tx.submit();
 150     }
 151
 152     @Override
 153     public void suppressEgress(InterfaceKey interfaceKey, String destinationIp) {
 154         // noop
 155     }
 156 }