return slices['hrn']
-def get_rspec(api, hrn=None):
+def get_rspec(api, hrn=None, caller_cred=None):
from sfa.plc.nodes import Nodes
- nodes = Nodes(api)
+ nodes = Nodes(api, caller_cred=caller_cred)
if hrn:
rspec = nodes.get_rspec(hrn)
else:
slices.refresh()
return slices['hrn']
-def get_rspec(api, hrn=None):
+def get_rspec(api, hrn=None, caller_cred=None):
from sfa.plc.nodes import Nodes
- nodes = Nodes(api)
+ nodes = Nodes(api, caller_cred=caller_cred)
if hrn:
rspec = nodes.get_rspec(hrn)
else:
mgr_type = self.api.config.SFA_AGGREGATE_TYPE
manager_module = manager_base + ".aggregate_manager_%s" % mgr_type
manager = __import__(manager_module, fromlist=[manager_base])
- rspec = manager.get_rspec(self.api, hrn)
+ rspec = manager.get_rspec(self.api, hrn, caller_cred)
outgoing_rules = SFATablesRules('OUTGOING')
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])
- rspec = manager.get_rspec(self.api, hrn)
+ rspec = manager.get_rspec(self.api, hrn, caller_cred)
outgoing_rules = SFATablesRules('FORWARD-OUTGOING')
filtered_rspec = rspec
caller_cred = self.caller_cred
# get the rspec from the aggregate
try:
- request_hash=None
+ request_hash=None
agg_rspec = aggregates[aggregate].get_resources(credential, hrn, request_hash, caller_cred)
except:
arg_list = [credential, hrn]