X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;ds=sidebyside;f=sfa%2Fgeneric%2F__init__.py;h=ece7e2b857317051f3aa769b82812a7e37eb0390;hb=047496aae8c0251fb2624f71c1d81b73ac491fa4;hp=363f3dd0f0f3a8097347db86422446470a598e87;hpb=d58bbc6238ee07a3e386b2627aa64ccb2dce352f;p=sfa.git diff --git a/sfa/generic/__init__.py b/sfa/generic/__init__.py index 363f3dd0..ece7e2b8 100644 --- a/sfa/generic/__init__.py +++ b/sfa/generic/__init__.py @@ -35,13 +35,17 @@ class Generic: #mixed = flavour.capitalize() module_path="sfa.generic.%s"%flavour classname="%s"%flavour - logger.info("Generic.the_flavour with flavour=%s"%flavour) + logger.debug("Generic.the_flavour with flavour=%s"%flavour) try: module = __import__ (module_path, globals(), locals(), [classname]) return getattr(module, classname)(flavour,config) except: logger.log_exc("Cannot locate generic instance with flavour=%s"%flavour) + # provide default for importer_class + def importer_class (self): + return None + # in the simplest case these can be redefined to the class/module objects to be used # see pl.py for an example # some descendant of SfaApi @@ -60,22 +64,21 @@ class Generic: if not 'interface' in kwargs: logger.critical("Generic.make_api: no interface found") api = self.api_class()(*args, **kwargs) - manager = self.make_manager(api.interface) - driver = self.make_driver (api.config, api.interface) + # xxx can probably drop support for managers implemented as modules + # which makes it a bit awkward + manager_class_or_module = self.make_manager(api.interface) + driver = self.make_driver (api) ### arrange stuff together # add a manager wrapper - manager_wrap = ManagerWrapper(manager,api.interface) + manager_wrap = ManagerWrapper(manager_class_or_module,api.interface,api.config) api.manager=manager_wrap - # insert driver in manager - logger.info("Setting manager.driver, manager=%s"%manager) - manager.driver=driver - # add it in api as well for convenience + # add it in api as well; driver.api is set too as part of make_driver api.driver=driver return api def make_manager (self, interface): """ - interface expected in ['registry', 'aggregate', 'slice', 'component'] + interface expected in ['registry', 'aggregate', 'slicemgr', 'component'] flavour is e.g. 'pl' or 'max' or whatever """ flavour = self.flavour @@ -83,14 +86,19 @@ class Generic: classname = "%s_manager_class"%interface try: - module = getattr(self,classname)() - logger.debug("%s : %s"%(message,module)) - return module + module_or_class = getattr(self,classname)() + logger.debug("%s : %s"%(message,module_or_class)) + # this gets passed to ManagerWrapper that will call the class constructor + # if it's a class, or use the module as is if it's a module + # so bottom line is, don't try the constructor here + return module_or_class except: logger.log_exc_critical(message) # need interface to select the right driver - def make_driver (self, config, interface): + def make_driver (self, api): + config=api.config + interface=api.interface flavour = self.flavour message="Generic.make_driver for flavour=%s and interface=%s"%(flavour,interface) @@ -101,8 +109,7 @@ class Generic: try: class_obj = getattr(self,classname)() logger.debug("%s : %s"%(message,class_obj)) - return class_obj(config) + return class_obj(api) except: logger.log_exc_critical(message) -