X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=PLC%2FMethods%2FGetSlivers.py;h=745b0fc0c53677d19811d136d9107ec017beff04;hb=3dfe7a1b32434ca886aa65326641c4df8bfab94d;hp=a8ee408cc8162a6148b9ccd051be97658170cf32;hpb=29d91c387fae61de70b591ec877e6e3526ab51f1;p=plcapi.git diff --git a/PLC/Methods/GetSlivers.py b/PLC/Methods/GetSlivers.py index a8ee408..745b0fc 100644 --- a/PLC/Methods/GetSlivers.py +++ b/PLC/Methods/GetSlivers.py @@ -1,5 +1,3 @@ -# $Id$ -# $URL$ import time from PLC.Faults import * @@ -28,7 +26,7 @@ from PLC.Accessors.Accessors_standard import * MAXINT = 2L**31-1 # slice_filter essentially contains the slice_ids for the relevant slices (on the node + system & delegated slices) -def get_slivers(api, auth, slice_filter, node = None): +def get_slivers(api, caller, auth, slice_filter, node = None): # Get slice information slices = Slices(api, slice_filter, ['slice_id', 'name', 'instantiation', 'expires', 'person_ids', 'slice_tag_ids']) @@ -109,7 +107,7 @@ def get_slivers(api, auth, slice_filter, node = None): if slice['expires'] > MAXINT: slice['expires']= MAXINT # expose the slice vref as computed by GetSliceFamily - family = GetSliceFamily (api).call(auth, slice['slice_id']) + family = GetSliceFamily (api,caller).call(auth, slice['slice_id']) slivers.append({ 'name': slice['name'], @@ -123,6 +121,24 @@ def get_slivers(api, auth, slice_filter, node = None): return slivers +### The pickle module, used in conjunction with caching has a restriction that it does not +### work on "connection objects." It doesn't matter if the connection object has +### an 'str' or 'repr' method, there is a taint check that throws an exception if +### the pickled class is found to derive from a connection. +### (To be moved to Method.py) + +def sanitize_for_pickle (obj): + if (isinstance(obj, dict)): + parent = dict(obj) + for k in parent.keys(): parent[k] = sanitize_for_pickle (parent[k]) + return parent + elif (isinstance(obj, list)): + parent = list(obj) + parent = map(sanitize_for_pickle, parent) + return parent + else: + return obj + class GetSlivers(Method): """ Returns a struct containing information about the specified node @@ -254,7 +270,7 @@ class GetSlivers(Method): controller_and_delegated_slice_ids = controller_and_delegated_slices.keys() slice_ids = system_slice_ids + controller_and_delegated_slice_ids + node['slice_ids'] - slivers = get_slivers(self.api, auth, slice_ids, node) + slivers = get_slivers(self.api, self.caller, auth, slice_ids, node) # get the special accounts and keys needed for the node # root @@ -296,7 +312,7 @@ class GetSlivers(Method): personsitekeys=get_all_admin_keys(self.api) accounts.append({'name':'root','keys':personsitekeys}) - hrn = GetNodeHrn(self.api).call(auth,node['node_id']) + hrn = GetNodeHrn(self.api,self.caller).call(auth,node['node_id']) # XMPP config for omf federation try: