X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=sfa%2Fmethods%2FListResources.py;h=b8d7e2d06e6e80c8473ca85a2928a0af17e37aba;hb=57b6a99255d4a88be9c0f910f8524677e34ff4bc;hp=80b483e1ad60d4a783734f685253bdb5baa714cb;hpb=c84915a8afc1d64a238686935577b0e84ed8a567;p=sfa.git diff --git a/sfa/methods/ListResources.py b/sfa/methods/ListResources.py index 80b483e1..b8d7e2d0 100644 --- a/sfa/methods/ListResources.py +++ b/sfa/methods/ListResources.py @@ -1,11 +1,10 @@ -from sfa.util.faults import * -from sfa.util.namespace import * +import zlib + +from sfa.util.xrn import urn_to_hrn from sfa.util.method import Method from sfa.util.parameter import Parameter, Mixed from sfa.trust.credential import Credential from sfa.util.sfatablesRuntime import run_sfatables -import sys -import zlib class ListResources(Method): """ @@ -18,16 +17,17 @@ class ListResources(Method): accepts = [ Mixed(Parameter(str, "Credential string"), Parameter(type([str]), "List of credentials")), - Parameter(dict, "Options") + Parameter(dict, "Options"), + Parameter(str, "call_id"), ] returns = Parameter(str, "List of resources") - def call(self, creds, options): + def call(self, creds, options, call_id=""): self.api.logger.info("interface: %s\tmethod-name: %s" % (self.api.interface, self.name)) # get slice's hrn from options - xrn = options.get('geni_slice_urn', None) - hrn, _ = urn_to_hrn(xrn) + xrn = options.get('geni_slice_urn', '') + (hrn, _) = urn_to_hrn(xrn) # Find the valid credentials valid_creds = self.api.auth.checkCredentials(creds, 'listnodes', hrn) @@ -38,13 +38,14 @@ class ListResources(Method): origin_hrn = Credential(string=valid_creds[0]).get_gid_caller().get_hrn() # get manager for this interface manager = self.api.get_interface_manager() - rspec = manager.get_rspec(self.api, creds, options) + rspec = manager.ListResources(self.api, creds, options, call_id) # filter rspec through sfatables if self.api.interface in ['aggregate']: chain_name = 'OUTGOING' elif self.api.interface in ['slicemgr']: chain_name = 'FORWARD-OUTGOING' + self.api.logger.debug("ListResources: sfatables on chain %s"%chain_name) filtered_rspec = run_sfatables(chain_name, hrn, origin_hrn, rspec) if options.has_key('geni_compressed') and options['geni_compressed'] == True: