Add new topos with "p4utiles.mininetlib.network_API"

ip-routing-pro/Readme.md

@@ -0,0 +1,70 @@
+### Introduction ###
+
+This demo shows how to implement a basic IP routers with static routing entries using P4, BMv2 and Mininet. 
+
+The basic functionality of IP router is:
+
+- determine the output port for packet based on destination IP (Longest Prefix Match)
+- decrement TTL value for IP protocol
+- update destination MAC address based on next-hop IP address
+- update source MAC address according to output port
+
+We have implemented the functionality of IP router as P4 program (router.p4). The program design is as follows:
+
+- We have used V1Model of P4_16 composed of Ingress and Egress control pipelines
+- For Ingress control pipeline there is one table defined:
+  - **routing_table** - it determines the output port based on IPv4 LPM. When packet is matched the *ipv4_forward* action is invoked. It sets next-hop IP address in the routing_metadata, decrements IPv4 TTL and sets output port.
+- For Egress control pipeline we have defined two tables:
+  - **switching_table** - it is responsible for setting destination MAC based on next-hop IP address, which is retrieved from routing metadata.
+  - **mac_rewriting_table** - it updates source MAC address according to the output port for the packet.
+
+The router.p4 program defines the data plane of IP routers. Note that the control plane in this demo is realized by populating static rules.
+
+The structure of the test network is shown below. Each network device has been configured with the **router.p4** program. 
+
+<p align="center">
+  <img src="images/NodeIpAndMACInfo.png" />
+</p>
+
+<p align="center">
+  <img src="images/Networks.png" />
+</p>
+
+The choice of this topology results from the following **paper[1]**
+
+```
+.
+├── basic.p4                # for p4 switch
+├── network.py              # Try with "sudo python3 FatTree.py" boost mininet with CLI 
+├── r1-commands.txt         # commands file for router 1
+├── r2-commands.txt         # commands file for router 2
+├── Readme.md               # YOU ARE HERE!
+├── router.p4               # for p4 router
+├── s1-commands.txt         # commands file for switch &1.2.3.4
+├── s2-commands.txt
+├── s3-commands.txt
+└── s4-commands.txt
+```
+
+### Demo ###
+
+1. First of all you need to setup the environment on your Linux machine.
+2. Enter the ip-routing/ directory.
+
+`cd ip-routing/`
+
+3. Run the Mininet topology.
+
+`sudo python3 network.py`
+
+4. In the Mininet console, check if ping between h1 and h2 works
+
+`h1 ping h2`
+or `h1 ping h6` etc.
+
+5. Have a nice day!
+
+
+## Reference
+
+**[1]** Anagnostakis K G, Greenwald M B, Ryger R S. On the sensitivity of network simulation to topology[C]//Proceedings. 10th IEEE International Symposium on Modeling, Analysis and Simulation of Computer and Telecommunications Systems. IEEE, 2002: 117-126.

ip-routing-pro/basic.p4

@@ -0,0 +1,196 @@
+/* -*- P4_16 -*- */
+#include <core.p4>
+#include <v1model.p4>
+
+const bit<16> TYPE_IPV4 = 0x800;
+
+/*************************************************************************
+*********************** H E A D E R S  ***********************************
+*************************************************************************/
+
+typedef bit<9>  egressSpec_t;
+typedef bit<48> macAddr_t;
+typedef bit<32> ip4Addr_t;
+
+header ethernet_t {
+    macAddr_t dstAddr;
+    macAddr_t srcAddr;
+    bit<16>   etherType;
+}
+
+header ipv4_t {
+    bit<4>    version;
+    bit<4>    ihl;
+    bit<8>    diffserv;
+    bit<16>   totalLen;
+    bit<16>   identification;
+    bit<3>    flags;
+    bit<13>   fragOffset;
+    bit<8>    ttl;
+    bit<8>    protocol;
+    bit<16>   hdrChecksum;
+    ip4Addr_t srcAddr;
+    ip4Addr_t dstAddr;
+}
+
+struct metadata {
+    /* empty */
+}
+
+struct headers {
+    ethernet_t   ethernet;
+    ipv4_t       ipv4;
+}
+
+/*************************************************************************
+*********************** P A R S E R  ***********************************
+*************************************************************************/
+
+parser MyParser(packet_in packet,
+                out headers hdr,
+                inout metadata meta,
+                inout standard_metadata_t standard_metadata) {
+
+    state start {
+
+        packet.extract(hdr.ethernet);
+        transition select(hdr.ethernet.etherType){
+
+            TYPE_IPV4: ipv4;
+            default: accept;
+
+        }
+
+    }
+
+    state ipv4 {
+
+        packet.extract(hdr.ipv4);
+        transition accept;
+    }
+
+}
+
+
+/*************************************************************************
+************   C H E C K S U M    V E R I F I C A T I O N   *************
+*************************************************************************/
+
+control MyVerifyChecksum(inout headers hdr, inout metadata meta) {
+    apply {  }
+}
+
+
+/*************************************************************************
+**************  I N G R E S S   P R O C E S S I N G   *******************
+*************************************************************************/
+
+control MyIngress(inout headers hdr,
+                  inout metadata meta,
+                  inout standard_metadata_t standard_metadata) {
+
+    action drop() {
+        mark_to_drop(standard_metadata);
+    }
+
+    action ipv4_forward(macAddr_t dstAddr, egressSpec_t port) {
+
+        //set the src mac address as the previous dst
+        hdr.ethernet.srcAddr = hdr.ethernet.dstAddr;
+
+       //set the destination mac address that we got from the match in the table
+        hdr.ethernet.dstAddr = dstAddr;
+
+        //set the output port that we also get from the table
+        standard_metadata.egress_spec = port;
+
+        //decrease ttl by 1
+        hdr.ipv4.ttl = hdr.ipv4.ttl -1;
+
+    }
+
+    table ipv4_lpm {
+        key = {
+            hdr.ipv4.dstAddr: lpm;
+        }
+        actions = {
+            ipv4_forward;
+            drop;
+            NoAction;
+        }
+        size = 1024;
+        default_action = NoAction();
+    }
+
+    apply {
+
+        //only if IPV4 the rule is applied. Therefore other packets will not be forwarded.
+        if (hdr.ipv4.isValid()){
+            ipv4_lpm.apply();
+
+        }
+    }
+}
+
+/*************************************************************************
+****************  E G R E S S   P R O C E S S I N G   *******************
+*************************************************************************/
+
+control MyEgress(inout headers hdr,
+                 inout metadata meta,
+                 inout standard_metadata_t standard_metadata) {
+    apply {  }
+}
+
+/*************************************************************************
+*************   C H E C K S U M    C O M P U T A T I O N   **************
+*************************************************************************/
+
+control MyComputeChecksum(inout headers hdr, inout metadata meta) {
+     apply {
+	update_checksum(
+	    hdr.ipv4.isValid(),
+            { hdr.ipv4.version,
+	      hdr.ipv4.ihl,
+              hdr.ipv4.diffserv,
+              hdr.ipv4.totalLen,
+              hdr.ipv4.identification,
+              hdr.ipv4.flags,
+              hdr.ipv4.fragOffset,
+              hdr.ipv4.ttl,
+              hdr.ipv4.protocol,
+              hdr.ipv4.srcAddr,
+              hdr.ipv4.dstAddr },
+            hdr.ipv4.hdrChecksum,
+            HashAlgorithm.csum16);
+    }
+}
+
+
+/*************************************************************************
+***********************  D E P A R S E R  *******************************
+*************************************************************************/
+
+control MyDeparser(packet_out packet, in headers hdr) {
+    apply {
+
+        //parsed headers have to be added again into the packet.
+        packet.emit(hdr.ethernet);
+        packet.emit(hdr.ipv4);
+
+    }
+}
+
+/*************************************************************************
+***********************  S W I T C H  *******************************
+*************************************************************************/
+
+//switch architecture
+V1Switch(
+MyParser(),
+MyVerifyChecksum(),
+MyIngress(),
+MyEgress(),
+MyComputeChecksum(),
+MyDeparser()
+) main;