X-Git-Url: https://osm.etsi.org/gitweb/?a=blobdiff_plain;ds=inline;f=src%2Femuvim%2Fdcemulator%2Fnode.py;h=c5ac9b368d49ea34e93bacfe81db3c4a415320f7;hb=139b0bee04cd9336bcd7acb6728d0cf6976d6f5d;hp=8e7a63ac08a88ca254661b7f7d19139e85d322e9;hpb=7062cee83ca95f51b9f43987e61a434e9e5e32f4;p=osm%2Fvim-emu.git diff --git a/src/emuvim/dcemulator/node.py b/src/emuvim/dcemulator/node.py index 8e7a63a..c5ac9b3 100755 --- a/src/emuvim/dcemulator/node.py +++ b/src/emuvim/dcemulator/node.py @@ -82,14 +82,15 @@ class EmulatorCompute(Docker): status["docker_network"] = self.dcinfo['NetworkSettings']['IPAddress'] status["image"] = self.dimage status["flavor_name"] = self.flavor_name - status["cpu_quota"] = self.cpu_quota - status["cpu_period"] = self.cpu_period - status["cpu_shares"] = self.cpu_shares - status["cpuset"] = self.cpuset - status["mem_limit"] = self.mem_limit - status["memswap_limit"] = self.memswap_limit + status["cpu_quota"] = self.resources.get('cpu_quota') + status["cpu_period"] = self.resources.get('cpu_period') + status["cpu_shares"] = self.resources.get('cpu_shares') + status["cpuset"] = self.resources.get('cpuset_cpus') + status["mem_limit"] = self.resources.get('mem_limit') + status["memswap_limit"] = self.resources.get('memswap_limit') 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["datacenter"] = (None if self.datacenter is None else self.datacenter.label) return status @@ -112,7 +113,7 @@ class Datacenter(object): self.name = "dc%d" % Datacenter.DC_COUNTER Datacenter.DC_COUNTER += 1 # use this for user defined names that can be longer than self.name - self.label = label + self.label = label # dict to store arbitrary metadata (e.g. latitude and longitude) self.metadata = metadata # path to which resource information should be logged (e.g. for experiments). None = no logging @@ -147,7 +148,7 @@ class Datacenter(object): def start(self): pass - def startCompute(self, name, image=None, command=None, network=None, flavor_name="tiny", **kwargs): + def startCompute(self, name, image=None, command=None, network=None, flavor_name="tiny", **params): """ Create a new container as compute resource and connect it to this data center. @@ -174,13 +175,10 @@ class Datacenter(object): network.append({}) # apply hard-set resource limits=0 - cpu_percentage = kwargs.get('cpu_percent') + cpu_percentage = params.get('cpu_percent') if cpu_percentage: - cpu_period = self.net.cpu_period - cpu_quota = self.net.cpu_period * float(cpu_percentage) - else: - cpu_quota = None - cpu_period = None + params['cpu_period'] = self.net.cpu_period + params['cpu_quota'] = self.net.cpu_period * float(cpu_percentage) # create the container d = self.net.addDocker( @@ -189,8 +187,8 @@ class Datacenter(object): dcmd=command, datacenter=self, flavor_name=flavor_name, - cpu_period = cpu_period, - cpu_quota = cpu_quota + environment = {'VNF_NAME':name}, + **params )