Skip to content

New loader #146

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
wants to merge 8 commits into
base: master
Choose a base branch
from
Open

New loader #146

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
8 commits
Select commit Hold shift + click to select a range
da7bba3
First version of uc2 for loader
janniclas Nov 30, 2016
47cf1f7
added UC2 demo package. Small changes to loader to start mininet script.
janniclas Nov 30, 2016
fd99c9a
Merge branch 'master' into new-loader
janniclas Nov 30, 2016
2b0eb85
Fixed typo
janniclas Dec 4, 2016
0eaaea1
Merge commit '9737f95bcc1503f3cc70c62ef8e2ff4a4db3735d' into new-loader
janniclas Dec 4, 2016
7effac0
Typo in create Config param
janniclas Dec 7, 2016
4497c41
Updated the loader to support param generation for python config files
janniclas Dec 19, 2016
df8a05b
Merge commit '9b7319df9764998d7d98afda558aafb79c3e001f' into new-loader
janniclas Dec 19, 2016
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
238 changes: 238 additions & 0 deletions loader/UC2/Topology/UC2_IITSystem.py
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,238 @@
#!/usr/bin/python

"""
Copyright (c) 2014, NetIDE Consortium (Create-Net (CN), Telefonica Investigacion Y Desarrollo SA (TID), Fujitsu
Technology Solutions GmbH (FTS), Thales Communications & Security SAS (THALES), Fundacion Imdea Networks (IMDEA),
Universitaet Paderborn (UPB), Intel Research & Innovation Ireland Ltd (IRIIL) )

All rights reserved. This program and the accompanying materials
are made available under the terms of the Eclipse Public License v1.0
which accompanies this distribution, and is available at
http://www.eclipse.org/legal/epl-v10.html

Authors:
Elisa Rojas
"""


###############################################################################################
### Name: UC2_IITSystem.py
### Author: Elisa Rojas - [email protected]
### Description: NetIDE UC2 Topology
###############################################################################################

from os import popen
import logging
import sys

# Mininet libraries
from mininet.cli import CLI
from mininet.net import Mininet
from mininet.topo import Topo
from mininet.util import errRun
from mininet.node import Controller, OVSKernelSwitch, RemoteController
from mininet.log import setLogLevel

# Configuration Files
IPCONFIG = './IPCONFIG.dat'

class IITSTopology (Topo):

### Topology class members
Devices = dict()

### Topology constructor
def __init__ (self, of_version):
## Initialize Topology
super(IITSTopology, self).__init__()

logger = logging.getLogger('NetIDE Logger')

#OpenFlow version
if of_version == 'of13':
sconfig = {'protocols': 'OpenFlow13'}
else:
sconfig = {'protocols': 'OpenFlow10'}
# Switches
SW1 = self.addSwitch('s1', **sconfig)
SW2 = self.addSwitch('s2', **sconfig)
SW3 = self.addSwitch('s3', **sconfig)
SW4 = self.addSwitch('s4', **sconfig)
SW1b = self.addSwitch('s5', **sconfig)
SW2b = self.addSwitch('s6', **sconfig)
SW3b = self.addSwitch('s7', **sconfig)
SW4b = self.addSwitch('s8', **sconfig)

# Hosts
H1 = self.addHost('h1')
H2 = self.addHost('h2')
H3 = self.addHost('h3')
H4 = self.addHost('h4')
H5 = self.addHost('h5')

# Hypervisors
HH1 = self.addSwitch('s11', **sconfig)
HH2 = self.addSwitch('s12', **sconfig)
HH3 = self.addSwitch('s13', **sconfig)
HH4 = self.addSwitch('s14', **sconfig)
HH5 = self.addSwitch('s15', **sconfig)

# Add links
#from hosts (H1,H2,H3,H4) to hosts-hypervisors (HH1,HH2,HH3,HH4)
#from down hosts-hypervisors (HH1,HH2,HH3,HH4) to SW1 and SW2
self.addLink(H1, HH1)
self.addLink(H3, HH3)
self.addLink(H2, HH2)
self.addLink(H4, HH4)
self.addLink(H5, HH5)
#from hosts-hypervisors (HH1,HH2,HH3,HH4) to SW1, SW2 and SW4
self.addLink(HH1, SW1)
self.addLink(HH1, SW1b)
self.addLink(HH3, SW1)
self.addLink(HH3, SW1b)
self.addLink(HH2, SW2)
self.addLink(HH2, SW2b)
self.addLink(HH4, SW2)
self.addLink(HH4, SW2b)
self.addLink(HH5, SW4)
self.addLink(HH5, SW4b)

#from SW3 to SW1 and SW2
self.addLink(SW3, SW1)
self.addLink(SW3, SW1b)
self.addLink(SW3, SW2)
self.addLink(SW3, SW2b)
self.addLink(SW3b, SW1)
self.addLink(SW3b, SW1b)
self.addLink(SW3b, SW2)
self.addLink(SW3b, SW2b)
#from SW3 to SW4
self.addLink(SW3, SW4)
self.addLink(SW3, SW4b)
self.addLink(SW3b, SW4)
self.addLink(SW3b, SW4b)
#between peers
self.addLink(SW1, SW2)
self.addLink(SW1b, SW2b)
self.addLink(SW3, SW3b)

logger.info('NetIDE - UC2 Topology created')

### Mutator for Devices
def SetDevices(self, Devices):
self.Devices = Devices

### Assign IPs, Masks and Routes to devices
def SetIPConfiguration(self, Devices, net):

## Internal configuration for Mininet (so that pingall and other Mininet's commands work ok and use correct IPs and so)
net.get("h1").setIP("10.0.1.11")
#net.get("h1").setIP("10.0.1.11", "24", "h1-eth0")
#net.get("h1").setIP("10.1.1.11", "24", "h1-eth1")
net.get("h2").setIP("10.0.1.12")
#net.get("h2").setIP("10.0.1.12", "24", "h2-eth0")
#net.get("h2").setIP("10.1.1.12", "24", "h2-eth1")
net.get("h3").setIP("10.0.1.13", "24")
#net.get("h3").setIP("10.0.1.13", "24", "h3-eth0")
#net.get("h3").setIP("10.1.1.13", "24", "h3-eth1")
net.get("h4").setIP("10.0.1.14", "24")
#net.get("h4").setIP("10.0.1.14", "24", "h4-eth0")
#net.get("h4").setIP("10.1.1.14", "24", "h4-eth1")
net.get("h5").setIP("10.0.1.15", "24")
#net.get("h5").setIP("10.0.1.15", "24", "h5-eth0")
#net.get("h5").setIP("10.1.1.15", "24", "h5-eth1")

## Hosts configuration (ipconfig/ifconfig)
try:
with open(IPCONFIG, 'r') as f:
for command in f:
if( len(command.split()) == 0):
break

token = command.split('#')
for host in Devices:
if token[0] == host.name:
for tok in token[1:len(token)]:
tok.replace("\n", "")
host.popen(tok) #popen() opens a process by creating a pipe, forking, and invoking the shell
break

logger.info('Successfully enforced initial ip settings to the UC topology')
f.close()

except EnvironmentError:
logger.error("Couldn't load config file for ip addresses, check whether %s exists" % IPCONFIG)

### Create a logger and configure it
def ConfigureLogger():
# Create a log instance
logger = logging.getLogger('NetIDE Logger')

# Set logging level
logger.setLevel(logging.INFO)

handler = logging.StreamHandler()
handler.setLevel(logging.INFO)

# Create a logging format
formatter = logging.Formatter('%(asctime)s - %(name)s - %(levelname)s - %(message)s')
handler.setFormatter(formatter)

# Add the handlers to the logger
logger.addHandler(handler)

return logger

### Network Emulator method
def UC2_IITS_Network(of_version):

logger.info('=================== Mininet Topology SetUp ===================')

# Create UC Topology instance
IITSTopo = IITSTopology(of_version)

# Start mininet and load the topology
net = Mininet( topo=IITSTopo, controller=RemoteController, autoSetMacs = True )
net.start()
setLogLevel( 'info' ) #setLogLevel( 'info' | 'debug' | 'output' )

# Get the devices
Devices = dict()
Devices = net.get('h1', 'h2', 'h3', 'h4', 'h5', 's1', 's2', 's3', 's4', 's5', 's6', 's7', 's8')
IITSTopo.SetDevices(Devices)
logger.info('==============================================================\n')

# Enforce IP configuration
logger.info('====================== IP Configuration ======================')
IITSTopo.SetIPConfiguration(Devices, net)
logger.info('==============================================================\n')

# Start mininet CLI
CLI( net )

# Destroy network after exiting the CLI
net.stop()


#########################################################################################################
### Main
#########################################################################################################
if __name__ == '__main__':
if (len(sys.argv) > 1):
of_version = sys.argv[1]
else:
of_version = 'of10'
# Setup the logger
logger = ConfigureLogger()

# Start network
UC2_IITS_Network(of_version)
#########################################################################################################


#########################################################################################################
### Load this module from mininet externally
#########################################################################################################
logger = ConfigureLogger()
topos = { 'IITS': ( lambda: UC2_IITS_Network() ) }
#########################################################################################################
136 changes: 136 additions & 0 deletions loader/UC2/Usecase_2.topology
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,136 @@
<?xml version="1.0" encoding="UTF-8"?>
<eu.netide.configuration:NetworkEnvironment xmi:version="2.0" xmlns:xmi="http://www.omg.org/XMI" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:eu.netide.configuration="eu.netide.configuration.topology">
<networks name="I">
<networkelements xsi:type="eu.netide.configuration:Switch" name="SW1" ip="" dpid="1" controller="//@controllers.0">
<ports id="1" connector="//@networks.0/@connectors.5"/>
<ports id="2" connector="//@networks.0/@connectors.7"/>
<ports id="3" connector="//@networks.0/@connectors.15"/>
<ports id="4" connector="//@networks.0/@connectors.16"/>
<ports id="5" connector="//@networks.0/@connectors.13"/>
</networkelements>
<networkelements xsi:type="eu.netide.configuration:Switch" name="SW1b" dpid="5" controller="//@controllers.0">
<ports id="1" connector="//@networks.0/@connectors.18"/>
<ports id="2" connector="//@networks.0/@connectors.6"/>
<ports id="3" connector="//@networks.0/@connectors.8"/>
<ports id="4" connector="//@networks.0/@connectors.17"/>
<ports id="5" connector="//@networks.0/@connectors.14"/>
</networkelements>
<networkelements xsi:type="eu.netide.configuration:Switch" name="SW3" dpid="3" controller="//@controllers.0">
<ports id="1" connector="//@networks.0/@connectors.15"/>
<ports id="2" connector="//@networks.0/@connectors.23"/>
<ports id="3" connector="//@networks.0/@connectors.0"/>
<ports id="4" connector="//@networks.0/@connectors.17"/>
<ports id="5" connector="//@networks.0/@connectors.20"/>
<ports id="6" connector="//@networks.0/@connectors.19"/>
<ports id="7" connector="//@networks.0/@connectors.24"/>
</networkelements>
<networkelements xsi:type="eu.netide.configuration:Switch" name="SW3b" ip="" dpid="7" controller="//@controllers.0">
<ports id="1" connector="//@networks.1/@connectors.1"/>
<ports id="2" connector="//@networks.0/@connectors.16"/>
<ports id="3" connector="//@networks.0/@connectors.0"/>
<ports id="4" connector="//@networks.0/@connectors.18"/>
<ports id="5" connector="//@networks.0/@connectors.21"/>
<ports id="6" connector="//@networks.0/@connectors.22"/>
<ports id="7" connector="//@networks.0/@connectors.25"/>
</networkelements>
<networkelements xsi:type="eu.netide.configuration:Switch" name="HH1" dpid="11" controller="//@controllers.0">
<ports id="1" connector="//@networks.0/@connectors.5"/>
<ports id="2" connector="//@networks.0/@connectors.6"/>
<ports id="3" connector="//@networks.0/@connectors.1"/>
</networkelements>
<networkelements xsi:type="eu.netide.configuration:Switch" name="HH4" dpid="14" controller="//@controllers.0">
<ports id="1" connector="//@networks.0/@connectors.11"/>
<ports id="2" connector="//@networks.0/@connectors.12"/>
<ports id="3" connector="//@networks.0/@connectors.4"/>
</networkelements>
<networkelements xsi:type="eu.netide.configuration:Host" name="H1" ip="10.0.1.11">
<ports id="1" connector="//@networks.0/@connectors.1"/>
</networkelements>
<networkelements xsi:type="eu.netide.configuration:Host" name="H2" ip="10.0.1.12">
<ports id="1" connector="//@networks.0/@connectors.3"/>
</networkelements>
<networkelements xsi:type="eu.netide.configuration:Host" name="H3" ip="10.0.1.13" prefix="24">
<ports id="1" connector="//@networks.0/@connectors.2"/>
</networkelements>
<networkelements xsi:type="eu.netide.configuration:Host" name="H4" ip="10.0.1.14" prefix="24">
<ports id="1" connector="//@networks.0/@connectors.4"/>
</networkelements>
<networkelements xsi:type="eu.netide.configuration:Switch" name="HH3" dpid="13" controller="//@controllers.0">
<ports id="1" connector="//@networks.0/@connectors.2"/>
<ports id="2" connector="//@networks.0/@connectors.7"/>
<ports id="3" connector="//@networks.0/@connectors.8"/>
</networkelements>
<networkelements xsi:type="eu.netide.configuration:Switch" name="HH2" dpid="12" controller="//@controllers.0">
<ports id="1" connector="//@networks.0/@connectors.3"/>
<ports id="2" connector="//@networks.0/@connectors.9"/>
<ports id="3" connector="//@networks.0/@connectors.10"/>
</networkelements>
<networkelements xsi:type="eu.netide.configuration:Switch" name="SW2" ip="" dpid="2" controller="//@controllers.0">
<ports id="1" connector="//@networks.0/@connectors.11"/>
<ports id="2" connector="//@networks.0/@connectors.21"/>
<ports id="3" connector="//@networks.0/@connectors.9"/>
<ports id="4" connector="//@networks.0/@connectors.13"/>
<ports id="5" connector="//@networks.0/@connectors.19"/>
</networkelements>
<networkelements xsi:type="eu.netide.configuration:Switch" name="SW2b" dpid="6" controller="//@controllers.0">
<ports id="1" connector="//@networks.0/@connectors.12"/>
<ports id="2" connector="//@networks.0/@connectors.20"/>
<ports id="3" connector="//@networks.0/@connectors.10"/>
<ports id="4" connector="//@networks.0/@connectors.14"/>
<ports id="5" connector="//@networks.0/@connectors.22"/>
</networkelements>
<connectors connectedports="//@networks.0/@networkelements.2/@ports.2 //@networks.0/@networkelements.3/@ports.2"/>
<connectors connectedports="//@networks.0/@networkelements.6/@ports.0 //@networks.0/@networkelements.4/@ports.2"/>
<connectors connectedports="//@networks.0/@networkelements.8/@ports.0 //@networks.0/@networkelements.10/@ports.0"/>
<connectors connectedports="//@networks.0/@networkelements.7/@ports.0 //@networks.0/@networkelements.11/@ports.0"/>
<connectors connectedports="//@networks.0/@networkelements.9/@ports.0 //@networks.0/@networkelements.5/@ports.2"/>
<connectors connectedports="//@networks.0/@networkelements.4/@ports.0 //@networks.0/@networkelements.0/@ports.0"/>
<connectors connectedports="//@networks.0/@networkelements.4/@ports.1 //@networks.0/@networkelements.1/@ports.1"/>
<connectors connectedports="//@networks.0/@networkelements.10/@ports.1 //@networks.0/@networkelements.0/@ports.1"/>
<connectors connectedports="//@networks.0/@networkelements.10/@ports.2 //@networks.0/@networkelements.1/@ports.2"/>
<connectors connectedports="//@networks.0/@networkelements.11/@ports.1 //@networks.0/@networkelements.12/@ports.2"/>
<connectors connectedports="//@networks.0/@networkelements.11/@ports.2 //@networks.0/@networkelements.13/@ports.2"/>
<connectors connectedports="//@networks.0/@networkelements.12/@ports.0 //@networks.0/@networkelements.5/@ports.0"/>
<connectors connectedports="//@networks.0/@networkelements.13/@ports.0 //@networks.0/@networkelements.5/@ports.1"/>
<connectors connectedports="//@networks.0/@networkelements.0/@ports.4 //@networks.0/@networkelements.12/@ports.3"/>
<connectors connectedports="//@networks.0/@networkelements.1/@ports.4 //@networks.0/@networkelements.13/@ports.3"/>
<connectors connectedports="//@networks.0/@networkelements.0/@ports.2 //@networks.0/@networkelements.2/@ports.0"/>
<connectors connectedports="//@networks.0/@networkelements.0/@ports.3 //@networks.0/@networkelements.3/@ports.1"/>
<connectors connectedports="//@networks.0/@networkelements.1/@ports.3 //@networks.0/@networkelements.2/@ports.3"/>
<connectors connectedports="//@networks.0/@networkelements.1/@ports.0 //@networks.0/@networkelements.3/@ports.3"/>
<connectors connectedports="//@networks.0/@networkelements.2/@ports.5 //@networks.0/@networkelements.12/@ports.4"/>
<connectors connectedports="//@networks.0/@networkelements.2/@ports.4 //@networks.0/@networkelements.13/@ports.1"/>
<connectors connectedports="//@networks.0/@networkelements.3/@ports.4 //@networks.0/@networkelements.12/@ports.1"/>
<connectors connectedports="//@networks.0/@networkelements.3/@ports.5 //@networks.0/@networkelements.13/@ports.4"/>
<connectors connectedports="//@networks.0/@networkelements.2/@ports.1 //@networks.1/@networkelements.0/@ports.2"/>
<connectors connectedports="//@networks.0/@networkelements.2/@ports.6 //@networks.1/@networkelements.1/@ports.1"/>
<connectors connectedports="//@networks.0/@networkelements.3/@ports.6 //@networks.1/@networkelements.1/@ports.2"/>
</networks>
<networks name="C">
<networkelements xsi:type="eu.netide.configuration:Switch" name="SW4" dpid="4" controller="//@controllers.0">
<ports id="2" connector="//@networks.1/@connectors.0"/>
<ports id="3" connector="//@networks.1/@connectors.1"/>
<ports id="4" connector="//@networks.0/@connectors.23"/>
</networkelements>
<networkelements xsi:type="eu.netide.configuration:Switch" name="SW4b" dpid="8" controller="//@controllers.0">
<ports id="2" connector="//@networks.2/@connectors.1"/>
<ports id="3" connector="//@networks.0/@connectors.24"/>
<ports id="4" connector="//@networks.0/@connectors.25"/>
</networkelements>
<connectors connectedports="//@networks.1/@networkelements.0/@ports.0 //@networks.2/@networkelements.1/@ports.0"/>
<connectors connectedports="//@networks.1/@networkelements.0/@ports.1 //@networks.0/@networkelements.3/@ports.0"/>
</networks>
<networks name="IN">
<networkelements xsi:type="eu.netide.configuration:Host" name="H5" ip="10.0.1.15" prefix="24">
<ports id="1" connector="//@networks.2/@connectors.0"/>
</networkelements>
<networkelements xsi:type="eu.netide.configuration:Switch" name="HH5" dpid="15" controller="//@controllers.0">
<ports id="1" connector="//@networks.1/@connectors.0"/>
<ports id="2" connector="//@networks.2/@connectors.0"/>
<ports id="3" connector="//@networks.2/@connectors.1"/>
</networkelements>
<connectors connectedports="//@networks.2/@networkelements.1/@ports.1 //@networks.2/@networkelements.0/@ports.0"/>
<connectors connectedports="//@networks.2/@networkelements.1/@ports.2 //@networks.1/@networkelements.1/@ports.0"/>
</networks>
<controllers name="c1 " switches="//@networks.2/@networkelements.1 //@networks.1/@networkelements.1 //@networks.1/@networkelements.0 //@networks.0/@networkelements.2 //@networks.0/@networkelements.3 //@networks.0/@networkelements.0 //@networks.0/@networkelements.1 //@networks.0/@networkelements.12 //@networks.0/@networkelements.13 //@networks.0/@networkelements.4 //@networks.0/@networkelements.10 //@networks.0/@networkelements.11 //@networks.0/@networkelements.5" ip="127.0.0.1" portNo="6644"/>
</eu.netide.configuration:NetworkEnvironment>
Loading