X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=sfa%2Fserver%2Fsfaapi.py;h=a76637dfbd24a8d471f1b84562957ee650396ab6;hb=0cf261b285ee1bdd4c651bd79238d4dde23140d4;hp=242979cbace74e7f4d97137af2edb0dd581b142a;hpb=e6c8a0a5061bae7e646851b6f265a02cdfb57f22;p=sfa.git diff --git a/sfa/server/sfaapi.py b/sfa/server/sfaapi.py index 242979cb..a76637df 100644 --- a/sfa/server/sfaapi.py +++ b/sfa/server/sfaapi.py @@ -20,12 +20,18 @@ class SfaApi (XmlrpcApi): """ An SfaApi instance is a basic xmlrcp service augmented with the local cryptographic material and hrn - It also has the notion of neighbour sfa services - as defined in /etc/sfa/{aggregates,registries}.xml + + It also has the notion of its own interface (a string describing + whether we run a registry, aggregate or slicemgr) and has + the notion of neighbour sfa services as defined + in /etc/sfa/{aggregates,registries}.xml + Finally it contains a cache instance + It gets augmented by the generic layer with (*) an instance of manager (actually a manager module for now) (*) which in turn holds an instance of a testbed driver + For convenience api.manager.driver == api.driver """ def __init__ (self, encoding="utf-8", methods='sfa.methods', @@ -63,11 +69,7 @@ class SfaApi (XmlrpcApi): # filled later on by generic/Generic self.manager=None - # tmp - def get_interface_manager(self, manager_base = 'sfa.managers'): - return self.manager - - def get_server(self, interface, cred, timeout=30): + def server_proxy(self, interface, cred, timeout=30): """ Returns a connection to the specified interface. Use the specified credential to determine the caller and look for the caller's key/cert @@ -83,7 +85,7 @@ class SfaApi (XmlrpcApi): auth_info = hierarchy.get_auth_info(caller_gid.get_hrn()) key_file = auth_info.get_privkey_filename() cert_file = auth_info.get_gid_filename() - server = interface.get_server(key_file, cert_file, timeout) + server = interface.server_proxy(key_file, cert_file, timeout) return server @@ -136,7 +138,7 @@ class SfaApi (XmlrpcApi): """ from sfa.server.registry import Registries registries = Registries() - registry = registries.get_server(self.hrn, self.key_file, self.cert_file) + registry = registries.server_proxy(self.hrn, self.key_file, self.cert_file) cert_string=self.cert.save_to_string(save_parents=True) # get self credential self_cred = registry.GetSelfCredential(cert_string, self.hrn, 'authority')