1 from sfa.util.sfalogging import logger
2 from sfa.util.config import Config
4 from sfa.managers.managerwrapper import ManagerWrapper
6 # a bundle is the combination of
7 # (*) an api that reacts on the incoming requests to trigger the API methods
8 # (*) a manager that implements the function of the service,
9 # either aggregate, registry, or slicemgr
10 # (*) a driver that controls the underlying testbed
13 # The Generic class is a utility that uses the configuration to figure out
14 # which combination of these pieces need to be put together
16 # this extra indirection is needed to adapt to the current naming scheme
17 # where we have 'pl' and 'plc' and components and the like, that does not
18 # yet follow a sensible scheme
20 # needs refinements to cache more efficiently, esp. wrt the config
24 def __init__ (self, flavour, config):
29 # example flavour='pl' -> sfa.generic.pl.pl()
31 def the_flavour (flavour=None, config=None):
32 if config is None: config=Config()
33 if flavour is None: flavour=config.SFA_GENERIC_FLAVOUR
34 flavour = flavour.lower()
35 #mixed = flavour.capitalize()
36 module_path="sfa.generic.%s"%flavour
37 classname="%s"%flavour
38 logger.info("Generic.the_flavour with flavour=%s"%flavour)
40 module = __import__ (module_path, globals(), locals(), [classname])
41 return getattr(module, classname)(flavour,config)
43 logger.log_exc("Cannot locate generic instance with flavour=%s"%flavour)
45 # in the simplest case these can be redefined to the class/module objects to be used
46 # see pl.py for an example
47 # some descendant of SfaApi
48 def api_class (self) : pass
49 # in practical terms these are modules for now
50 def registry_class (self) : pass
51 def slicemgr_class (self) : pass
52 def aggregate_class (self) : pass
53 def component_class (self) : pass
57 # insert a manager instance
58 def make_api (self, *args, **kwargs):
59 # interface is a required arg
60 if not 'interface' in kwargs:
61 logger.fatal("Generic.make_api: no interface found")
62 api = self.api_class()(*args, **kwargs)
63 interface=kwargs['interface']
64 # or simpler, interface=api.interface
65 manager = self.make_manager(interface)
66 api.manager = ManagerWrapper(manager,interface)
69 def make_manager (self, interface):
71 interface expected in ['registry', 'aggregate', 'slice', 'component']
72 flavour is e.g. 'pl' or 'max' or whatever
74 flavour = self.flavour
75 message="Generic.make_manager for interface=%s and flavour=%s"%(interface,flavour)
77 classname = "%s_class"%interface
79 module = getattr(self,classname)()
80 logger.info("%s : %s"%(message,module))
83 logger.log_exc(message)
84 logger.fatal("Aborting")
87 # basepath = 'sfa.managers'
88 # qualified = "%s.%s_manager_%s"%(basepath,interface,flavour)
89 # generic = "%s.%s_manager"%(basepath,interface)
92 # manager = __import__(qualified, fromlist=[basepath])
93 # logger.info ("%s: loaded %s"%(message,qualified))
96 # manager = __import__ (generic, fromlist=[basepath])
97 # if flavour != 'pl' :
98 # logger.warn ("%s: using generic with flavour!='pl'"%(message))
99 # logger.info("%s: loaded %s"%(message,generic))
101 # logger.log_exc("%s: unable to import either %s or %s"%(message,qualified,generic))
102 # logger.fatal("Aborted")