X-Git-Url: https://osm.etsi.org/gitweb/?a=blobdiff_plain;f=src%2Femuvim%2Fdcemulator%2Fnode.py;h=3587aff9f8c957f338b1cf1f7722d928e70d8c3c;hb=86e64a08ca267ebd033ed87be5eef683d93e6c1d;hp=c5ac9b368d49ea34e93bacfe81db3c4a415320f7;hpb=139b0bee04cd9336bcd7acb6728d0cf6976d6f5d;p=osm%2Fvim-emu.git diff --git a/src/emuvim/dcemulator/node.py b/src/emuvim/dcemulator/node.py index c5ac9b3..3587aff 100755 --- a/src/emuvim/dcemulator/node.py +++ b/src/emuvim/dcemulator/node.py @@ -25,18 +25,18 @@ the Horizon 2020 and 5G-PPP programmes. The authors would like to acknowledge the contributions of their colleagues of the SONATA partner consortium (www.sonata-nfv.eu). """ -from mininet.node import Docker +from mininet.node import Docker, OVSBridge from mininet.link import Link from emuvim.dcemulator.resourcemodel import NotEnoughResourcesAvailable import logging -import time -import json + LOG = logging.getLogger("dcemulator.node") LOG.setLevel(logging.DEBUG) DCDPID_BASE = 1000 # start of switch dpid's used for data center switches +EXTSAPDPID_BASE = 2000 # start of switch dpid's used for external SAP switches class EmulatorCompute(Docker): """ @@ -91,8 +91,10 @@ class EmulatorCompute(Docker): status["state"] = self.dcli.inspect_container(self.dc)["State"] status["id"] = self.dcli.inspect_container(self.dc)["Id"] status["short_id"] = self.dcli.inspect_container(self.dc)["Id"][:12] + status["hostname"] = self.dcli.inspect_container(self.dc)["Config"]['Hostname'] status["datacenter"] = (None if self.datacenter is None else self.datacenter.label) + return status @@ -133,6 +135,11 @@ class Datacenter(object): DCDPID_BASE += 1 return DCDPID_BASE + def _get_next_extSAP_dpid(self): + global EXTSAPDPID_BASE + EXTSAPDPID_BASE += 1 + return EXTSAPDPID_BASE + def create(self): """ Each data center is represented by a single switch to which @@ -246,6 +253,18 @@ class Datacenter(object): return True + def attachExternalSAP(self, sap_name, sap_net, **params): + # create SAP as separate OVS switch with an assigned ip address + sap_ip = str(sap_net[1]) + '/' + str(sap_net.prefixlen) + sap_switch = self.net.addExtSAP(sap_name, sap_ip, dpid=hex(self._get_next_extSAP_dpid())[2:], **params) + sap_switch.start() + + # link SAP to the DC switch + self.net.addLink(sap_switch, self.switch, cls=Link) + + # allow connection to the external internet through the host + self.net.addSAPNAT(sap_switch, str(sap_net)) + def listCompute(self): """ Return a list of all running containers assigned to this