X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=sfa%2Fmethods%2Fstop_slice.py;h=e111098398da605321e4614b1a58cc0507f4f178;hb=11d02cbfd5e91784119bb9377fceb4fa6adae621;hp=93a43f8e76b87df1a63d3538dc5bf6b4631192b2;hpb=19517e8624d6b3ec3cdcaf51f647b72581941243;p=sfa.git diff --git a/sfa/methods/stop_slice.py b/sfa/methods/stop_slice.py index 93a43f8e..e1110983 100644 --- a/sfa/methods/stop_slice.py +++ b/sfa/methods/stop_slice.py @@ -2,7 +2,7 @@ ### $URL$ from sfa.util.faults import * -from sfa.util.misc import * +from sfa.util.namespace import * from sfa.util.method import Method from sfa.util.parameter import Parameter, Mixed from sfa.trust.auth import Auth @@ -13,7 +13,7 @@ class stop_slice(Method): Stop the specified slice @param cred credential string specifying the rights of the caller - @param hrn human readable name of slice to instantiate + @param xrn human readable name of slice to instantiate (hrn or urn) @return 1 is successful, faults otherwise """ @@ -21,27 +21,23 @@ class stop_slice(Method): accepts = [ Parameter(str, "Credential string"), - Parameter(str, "Human readable name of slice to instantiate"), - Mixed(Parameter(str, "Request hash"), - Parameter(None, "Request hash not specified")) + Parameter(str, "Human readable name of slice to instantiate (hrn or urn)"), + Mixed(Parameter(str, "Human readable name of the original caller"), + Parameter(None, "Origin hrn not specified")) ] returns = Parameter(int, "1 if successful") - def call(self, cred, hrn, request_hash=None): + def call(self, cred, xrn, origin_hrn=None): + hrn, type = urn_to_hrn(xrn) user_cred = Credential(string=cred) #log the call - gid_origin_caller = user_cred.get_gid_origin_caller() - origin_hrn = gid_origin_caller.get_hrn() + if not origin_hrn: + origin_hrn = user_cred.get_gid_caller().get_hrn() self.api.logger.info("interface: %s\tcaller-hrn: %s\ttarget-hrn: %s\tmethod-name: %s"%(self.api.interface, origin_hrn, hrn, self.name)) - # This cred will be an slice cred, not a user, so we cant use it to - # authenticate the caller's request_hash. Let just get the caller's gid - # from the cred and authenticate using that - client_gid = Credential(string=cred).get_gid_caller() - client_gid_str = client_gid.save_to_string(save_parents=True) - self.api.auth.authenticateGid(client_gid_str, [cred, hrn], request_hash) + # validate the cred self.api.auth.check(cred, 'stopslice') # send the call to the right manager @@ -50,16 +46,16 @@ class stop_slice(Method): mgr_type = self.api.config.SFA_CM_TYPE manager_module = manager_base + ".component_manager_%s" % mgr_type manager = __import__(manager_module, fromlist=[manager_base]) - manager.stop_slice(self.api, hrn) + manager.stop_slice(self.api, xrn) elif self.api.interface in ['aggregate']: mgr_type = self.api.config.SFA_AGGREGATE_TYPE manager_module = manager_base + ".aggregate_manager_%s" % mgr_type manager = __import__(manager_module, fromlist=[manager_base]) - manager.stop_slice(self.api, hrn) + manager.stop_slice(self.api, xrn) elif self.api.interface in ['slicemgr']: mgr_type = self.api.config.SFA_SM_TYPE manager_module = manager_base + ".slice_manager_%s" % mgr_type manager = __import__(manager_module, fromlist=[manager_base]) - manager.stop_slice(self.api, hrn) + manager.stop_slice(self.api, xrn) return 1