learning switch code(Analysis)


PacketReceived.class

public interface PacketReceived
    extends
    DataObject,
 Augmentable<org.opendaylight.yang.gen.v1.urn.opendaylight.packet.service.rev130709.PacketReceived>,
    RawPacket,
    Notification
{
    
public static final QName QNAME = 
org.opendaylight.yangtools.yang.common.QName.create("urn:opendaylight:packet:service",
        "2013-07-09", "packet-received").intern();
    ConnectionCookie getConnectionCookie();    
    FlowCookie getFlowCookie();    
    TableId getTableId();
    java.lang.Class<? extends org.opendaylight.yang.gen.v1.urn.opendaylight.packet.service.rev130709.PacketInReason> getPacketInReason();   
    Match getMatch();
}

match

This class represents the following YANG schema fragment defined in module packet-processing 
(Source path: META-INF/yang/packet-processing.yang): 
 container match {
     leaf in-port {
         type node-connector-id;
     }
     leaf in-phy-port {
         type node-connector-id;
     }
     container metadata {
         leaf metadata {
             type uint64;
         }
         leaf metadata-mask {
             type uint64;
         }
         uses of-metadata;
     }

 RawPacket.class

/**
 * Basic packet structure.
 *
 * <p>This class represents the following YANG schema fragment defined in module <b>packet-processing</b>
 * <br>(Source path: <i>META-INF/yang/packet-processing.yang</i>):
 * <pre>
 * grouping raw-packet {
 *     leaf ingress {
 *         type node-connector-ref;
 *     }
 *     leaf payload {
 *         type binary;
 *     }
 * }
 * </pre>
 * The schema path to identify an instance is
 * <i>packet-processing/raw-packet</i>
 *
 */
public interface RawPacket  extend DataObject
{
    public static final QName QNAME = org.opendaylight.yangtools.yang.common.QName.create("urn:opendaylight:packet:service",
        "2013-07-09", "raw-packet").intern();

     NodeConnectorRef getIngress();
    
    byte[] getPayload();

 }


InventoryUtils.class


 public final class InventoryUtils {
    public static final String OPENFLOW_NODE_PREFIX = "openflow:";

     public static NodeRef getNodeRef(NodeId nodeId) {
        return new NodeRef(InstanceIdentifier.builder(Nodes.class)
            .child(Node.class, new NodeKey(nodeId))
            .build());
    }

 public static NodeRef getNodeRef(NodeConnectorRef nodeConnectorRef) {//get node reference providing node connector reference
        InstanceIdentifier<Node> nodeIID = nodeConnectorRef.getValue()
    .firstIdentifierOf(Node.class);
        return new NodeRef(nodeIID);
}

public static NodeId getNodeId(NodeConnectorRef nodeConnectorRef) {
return nodeConnectorRef.getValue()
       .firstKeyOf(Node.class, NodeKey.class)
       .getId();
}

    public static NodeId getNodeId(NodeConnectorId nodeConnectorId) {
    if (nodeConnectorId == null)
    return null;
    String[] tokens = nodeConnectorId.getValue().split(":");
    if (tokens.length == 3)
    return new NodeId(OPENFLOW_NODE_PREFIX + Long.parseLong(tokens[1]));
    else
    return null;
    }

     public static NodeConnectorId getNodeConnectorId(NodeId nodeId, long portNumber) {
    if (nodeId == null)
    return null;
    String nodeConnectorIdStr = nodeId.getValue() + ":" + portNumber;
return new NodeConnectorId(nodeConnectorIdStr);
    }

     public static NodeConnectorRef getNodeConnectorRef(NodeConnectorId nodeConnectorId) {
    NodeId nodeId = getNodeId(nodeConnectorId);
        return new NodeConnectorRef(InstanceIdentifier.builder(Nodes.class)
                .child(Node.class, new NodeKey(nodeId))
                .child(NodeConnector.class, new NodeConnectorKey(nodeConnectorId))
                .build());
    }

     public static NodeConnectorBuilder getNodeConnectorBuilder(NodeConnectorId nodeConnectorId) {
        NodeConnectorBuilder builder = new NodeConnectorBuilder()
        .setId(nodeConnectorId)
        .setKey(new NodeConnectorKey(nodeConnectorId));
        return builder;
    }

 public static NodeConnectorId getNodeConnectorId(NodeConnectorRef nodeConnectorRef) {
        return nodeConnectorRef.getValue()
            .firstKeyOf(NodeConnector.class, NodeConnectorKey.class)
            .getId();
}

}

PacketParsingUtils   

package org.sdnhub.odl.tutorial.utils;
import java.util.Arrays;
import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.types.rev100924.MacAddress;
/**
 *
 */
public abstract class PacketParsingUtils {
    /**
     * size of MAC address in octets (6*8 = 48 bits)
     */
    private static final int MAC_ADDRESS_SIZE = 6;
    /**
     * start position of destination MAC address in array
     */
    private static final int DST_MAC_START_POSITION = 0;
    /**
     * end position of destination MAC address in array
     */
    private static final int DST_MAC_END_POSITION = 6;
    /**
     * start position of source MAC address in array
     */
    private static final int SRC_MAC_START_POSITION = 6;
    /**
     * end position of source MAC address in array
     */
    private static final int SRC_MAC_END_POSITION = 12;
    /**
     * start position of ethernet type in array
     */
    private static final int ETHER_TYPE_START_POSITION = 12;
    /**
     * end position of ethernet type in array
     */
    private static final int ETHER_TYPE_END_POSITION = 14;
    private PacketParsingUtils() {
        //prohibite to instantiate this class
    }
    /**
     * @param payload
     * @return destination MAC address
     */
    public static byte[] extractDstMac(final byte[] payload) {
        return Arrays.copyOfRange(payload, DST_MAC_START_POSITION, DST_MAC_END_POSITION);
    }

     /**
     * @param payload
     * @return source MAC address
     */
    public static byte[] extractSrcMac(final byte[] payload) {
        return Arrays.copyOfRange(payload, SRC_MAC_START_POSITION, SRC_MAC_END_POSITION);
    }

     /**
     * @param payload
     * @return source MAC address
     */
    public static byte[] extractEtherType(final byte[] payload) {
        return Arrays.copyOfRange(payload, ETHER_TYPE_START_POSITION, ETHER_TYPE_END_POSITION);
    }

     /**
     * @param rawMac
     * @return {@link MacAddress} wrapping string value, baked upon binary MAC
     *         address
     */
    public static MacAddress rawMacToMac(final byte[] rawMac) {
        MacAddress mac = null;
        if (rawMac != null && rawMac.length == MAC_ADDRESS_SIZE) {
            StringBuilder sb = new StringBuilder();
            for (byte octet : rawMac) {
                sb.append(String.format(":%02X", octet));
            }
            mac = new MacAddress(sb.substring(1));
        }
        return mac;
    }
    
    public static String rawMacToString(byte[] rawMac) {
        if (rawMac != null && rawMac.length == 6) {
            StringBuffer sb = new StringBuffer();
            for (byte octet : rawMac) {
                sb.append(String.format(":%02X", octet));
            }
            return sb.substring(1);
        }
        return null;
    }

     public static byte[] stringMacToRawMac(String address) {
        String[] elements = address.split(":");
        if (elements.length != MAC_ADDRESS_SIZE) {
            throw new IllegalArgumentException(
                    "Specified MAC Address must contain 12 hex digits" +
                    " separated pairwise by :'s.");
        }

         byte[] addressInBytes = new byte[MAC_ADDRESS_SIZE];
        for (int i = 0; i < MAC_ADDRESS_SIZE; i++) {
            String element = elements[i];
            addressInBytes[i] = (byte)Integer.parseInt(element, 16);
        }
        return addressInBytes;
    }

}


 TransmitPacketInputBuilder.class

 public class TransmitPacketInputBuilder implements Builder <org.opendaylight.yang.gen.v1.urn.opendaylight.packet.service.rev130709.TransmitPacketInput> {

     private List<Action> _action;
    private java.lang.Long _bufferId;
    private ConnectionCookie _connectionCookie;
    private NodeConnectorRef _egress;
    private NodeConnectorRef _ingress;
    private NodeRef _node;

    private byte[] _payload;

      
    public TransmitPacketInputBuilder setIngress(final NodeConnectorRef value) {
        this._ingress = value;
        return this;
    }
    
     
    public TransmitPacketInputBuilder setNode(final NodeRef value) {
        this._node = value;
        return this;
    }
    
     
    public TransmitPacketInputBuilder setPayload(final byte[] value) {
        this._payload = value;
        return this;
    }

     public TransmitPacketInput build() {
        return new TransmitPacketInputImpl(this);
    }

 private static final class TransmitPacketInputImpl implements TransmitPacketInput {}



PacketProcessingService.class

public interface PacketProcessingService
    extends
    RpcService
{
    /**
     * Sending packet out through openflow device.
     *
     */
    Future<RpcResult<java.lang.Void>> transmitPacket(TransmitPacketInput input);

 }


评论

发表评论

此博客中的热门博文

openflow switch(I)

图片
一、基础概念图： 　　首先我们先看下Open Flow Switch的整体结构，以便有一个初步的感性认识，如下图所示： 从上面架构图中，我们可以看到Open Flow Switch主要是由以下几个部分构成： 1、Remote Controller：我们知道，SDN网络将传统的网络结构划分成了Control Plane和Data Plane两部分，这里的Remote Controller正是Control Plane部分，通过约定的通信协议来远程控制管理OpenFlow Switch，增加、删除或者修改OpenFlow Switch的Flow Entries。 2、OpenFlow Channel：它可以被认为是OpenFlow Switch对外开放的接口，接受来自于Remote Controller的通信协议，进而来操纵OpenFlow Switch。 3、OpenFlow Protocol：一种通信协议规范，用于Remote Controller和OpenFlow Switch之间的消息交换。 4、Flow Table：包含多个Flow Entry记录，控制数据包的流向，具体过程可参考下文。 5、Group Table：相对于Flow Table，控制着数据包更高级的转发特性，比如Flooding、Multipath、Fast Reroute、Link Aggregation等。 6、Pipeline：由多个Flow Table链接而成，控制数据包的一系列行为。 OpenFlow Ports 1、Standard Ports（标准端口）：  　　OpenFlow Standard Ports通常被定义为是 Physical ports, logical ports和支持的 LOCAL Reserved ports （不包括其他的Reserved ports）。它们可被用于 ingress port，也可被用于 output port，同样可以用于 Group 里，它们都有 port counters。 2、Physical Ports（物理端口）： 　　OpenFlow Physical Ports是OpenFlow Switch定义的、 对应于物理交换机的一个硬件接口的port。 比如在一个以太网交...
阅读全文

YANG Tools:YANG to Java Mapping

1   YANG to JAVA mapping 1.1   Package name 1.1.1   Other package names 1.2   Class and interface name 1.3   Getters and setters name 1.4   Module 1.4.1   Data Interface 1.4.2   Service Interface 1.5   Typedef 1.5.1   Type's valid arguments 1.5.1.1   Enumeration's substatement enum 1.5.1.2   Bits's substatement bit 1.5.1.3   Union's substatement type 1.5.2   String mapping 1.6   Container 1.7   Leaf 1.8   Leaf-list 1.9   List 1.10   Choice and case 1.11   Grouping and uses 1.12   Rpc 1.13   Notification 1.14   Augment 1.15   Identity Package name The package name consists from following parts: opendaylight prefix  - every package name starts with prefix  org.opendaylight.yang.gen.v1  which is hardcoded in  BindingGeneratorUtil.moduleNamespaceToPackageName() . YANG version  - is specified through...
阅读全文

OpenDaylight架构简介

图片
在我们跳入代码之前，需要对OpenDaylight控制器进行高级概述。 OpenDaylight是一个模块化平台，大多数模块 reusing  一些常见的服务和接口。 每个模块都是在多供应商子项目下开发的。 你可以在这里找到项目的列表。 在OpenDaylight平台上构建应用程序的想法是利用其他平台包中的功能，每个平台包都通过Java接口导出重要的服务。 许多这些服务是在称为MD-SAL的适应层上在提供者 - 消费者模型中构建的。 在OpenDaylight的核心编程中的MD-SAL数据存储涉及采用用于SDN应用开发的模型 - 视图 - 控制方法： 1. YANG Model for  数据，RPC和通知 （ YANG Model for data, RPC and notifications ） 2.REST API视图通过RESTconf实现自动生成和访问 3.Java编码处理数据更改，通知和RPC回调 （ Java Implementation coded to handle data changes, notifications and RPC call backs） 3.1模型驱动的SAL（MD-SAL） 模型驱动的服务适配层（MD-SAL）是平台的内核，不同的 层和模块通过API互连 。 以下是关于MD-SAL的一些重要注意事项：    1. 每个API都 是在构建期间从 YANG语言中定义的模型生成的 ，并且当模型包（ model bundle ）装入到Karaf平台时 加载到控制器中 。   2.在平台的核心是逻辑集中的数据存储，其将相关状态保持在两个桶中 - 1）配置数据存储，2）操作数据存储。   3.使用MD-SAL映射逻辑， 所有事件调用和数据通过此中央数据存储区从“提供者”到“消费者” 。 3.2  YANG  模型 OpenDaylight大量使用YANG来 建模在不同模块间的数据 ，通知或  remote procedure call  （RPC）。 对于那些不熟悉YANG的学生，我们建议您通过Tail-F系统学习YANG教程。 简而言之，YANG是一种用于描述存储在容器...
阅读全文