X-Git-Url: https://osm.etsi.org/gitweb/?p=osm%2Fvim-emu.git;a=blobdiff_plain;f=src%2Femuvim%2Fdcemulator%2Fresourcemodel%2Fupb%2Fsimple.py;h=beb3fbea8d9c7d5d48107a0e89cc535dbe201c01;hp=f4ec9ad68a2ab552f0cf072f1114b7884b2b0e9f;hb=e3e034e3124ea755e924dc667fd1232323cff70c;hpb=bf59d27a58448cb33b29e19c5ed611df23775a89 diff --git a/src/emuvim/dcemulator/resourcemodel/upb/simple.py b/src/emuvim/dcemulator/resourcemodel/upb/simple.py old mode 100644 new mode 100755 index f4ec9ad..beb3fbe --- a/src/emuvim/dcemulator/resourcemodel/upb/simple.py +++ b/src/emuvim/dcemulator/resourcemodel/upb/simple.py @@ -4,7 +4,7 @@ Playground for resource models created by University of Paderborn. import time import json import logging -from emuvim.dcemulator.resourcemodel import BaseResourceModel +from emuvim.dcemulator.resourcemodel import BaseResourceModel, NotEnoughResourcesAvailable LOG = logging.getLogger("rm.upb.simple") LOG.setLevel(logging.DEBUG) @@ -66,7 +66,7 @@ class UpbSimpleCloudDcRM(BaseResourceModel): fl_cu = self._get_flavor(d).get("compute") # check for over provisioning if self.dc_alloc_cu + fl_cu > self.dc_max_cu and self.raise_no_cpu_resources_left: - raise Exception("Not enough compute resources left.") + raise NotEnoughResourcesAvailable("Not enough compute resources left.") self.dc_alloc_cu += fl_cu def _allocate_mem(self, d): @@ -78,7 +78,7 @@ class UpbSimpleCloudDcRM(BaseResourceModel): fl_mu = self._get_flavor(d).get("memory") # check for over provisioning if self.dc_alloc_mu + fl_mu > self.dc_max_mu and self.raise_no_mem_resources_left: - raise Exception("Not enough memory resources left.") + raise NotEnoughResourcesAvailable("Not enough memory resources left.") self.dc_alloc_mu += fl_mu def free(self, d): @@ -271,6 +271,7 @@ class UpbOverprovisioningCloudDcRM(UpbSimpleCloudDcRM): Allows over provisioning. Might result in reducing resources of single containers whenever a data-center is over provisioned. """ + # TODO add parts for memory def __init__(self, *args, **kvargs): super(UpbOverprovisioningCloudDcRM, self).__init__(*args, **kvargs) self.raise_no_cpu_resources_left = False @@ -288,3 +289,16 @@ class UpbOverprovisioningCloudDcRM(UpbSimpleCloudDcRM): # calculate return float(e_cpu) / sum([rm.dc_max_cu for rm in list(self.registrar.resource_models)]) * self.cpu_op_factor + +class UpbDummyRM(UpbSimpleCloudDcRM): + """ + No limits. But log allocations. + """ + def __init__(self, *args, **kvargs): + super(UpbDummyRM, self).__init__(*args, **kvargs) + self.raise_no_cpu_resources_left = False + + def _apply_limits(self): + # do nothing here + pass +