Changeset 88dbe63 for fedd/federation

Timestamp:

Aug 25, 2010 1:14:50 AM (14 years ago)

Author:

Ted Faber <faber@…>

Branches:

axis_example, compt_changes, info-ops, master, version-3.01, version-3.02

Children:

208797c

Parents:

4875e93

Message:

Expand the protogeni_proxy class for derivation

File:

• fedd/federation/protogeni_access.py (modified) (14 diffs)

fedd/federation/protogeni_access.py

@@ -100 +100 @@
                 return "%s XML blob" % method
 
+    def clearinghouse_call(self, method, params, context):
+        return self.pg_call(self.ch_url, method, params, context)
+
+    def slice_authority_call(self, method, params, context):
+        return self.pg_call(self.sa_url, method, params, context)
+
+    def component_manager_call(self, method, params, context):
+        return self.pg_call(self.cm_url, method, params, context)
+
+
+
 
 
@@ -878 +889 @@
 
         try:
-            gcred = segment_commands.pg_call(self.sa_url, 
-                    'GetCredential', {}, ctxt)
-        except self.ProtoGENIError, e:
+            gcred = segment_commands.slice_authority_call('GetCredential', 
+                    {}, ctxt)
+        except segment_commands.ProtoGENIError, e:
             raise service_error(service_error.federant,
                     "ProtoGENI: %s" % e)
@@ -909 +920 @@
                         'type': 'Slice'
                         }
-                segment_commands.pg_call(self.sa_url, 'Resolve', param, ctxt)
+                segment_commands.slice_authority_call('Resolve', param, ctxt)
             except segment_commands.ProtoGENIError, e:
                 print e
@@ -929 +940 @@
                     'type': 'Slice'
                     }
-            slice_cred = segment_commands.pg_call(self.sa_url, 'Register',
+            slice_cred = segment_commands.slice_authority_call('Register',
                     param, ctxt)
             # Resolve the slice to get the URN that PG has assigned it.
@@ -937 +948 @@
                     'hrn': slicename
                     }
-            data = segment_commands.pg_call(self.sa_url, 'Resolve', param,
+            data = segment_commands.slice_authority_call('Resolve', param,
                     ctxt)
             if 'urn' in data:
@@ -954 +965 @@
                     'credential': gcred, 
                     }
-            keys =  segment_commands.pg_call(self.sa_url, 'GetKeys', param, 
+            keys =  segment_commands.slice_authority_call('GetKeys', param, 
                     ctxt)
             # Create a Sliver
@@ -967 +978 @@
                     'slice_urn': slice_urn,
                     }
-            sliver_cred, manifest = segment_commands.pg_call(self.cm_url, 
+            sliver_cred, manifest = segment_commands.component_manager_call(
                     'CreateSliver', param, ctxt)
         except segment_commands.ProtoGENIError, e:
@@ -991 +1002 @@
                         'slice_urn': slice_urn,
                         }
-                r = segment_commands.pg_call(self.cm_url,
+                r = segment_commands.component_manager_call(
                         'SliverStatus', param, ctxt)
                 status = r.get('status', 'changing')
@@ -1014 +1025 @@
                     'slice_urn': slice_urn,
                     }
-            segment_commands.pg_call(self.cm_url, 'DeleteSlice',
+            segment_commands.component_manager_call('DeleteSlice',
                     param, ctxt)
         except segment_commands.ProtoGENIError, e:
@@ -1428 +1439 @@
             expiration = time.strftime("%Y%m%dT%H:%M:%S",
                     time.gmtime(time.time() + interval))
-            cred = segment_commands.pg_call(self.sa_url, 'GetCredential', 
+            cred = segment_commands.slice_authority_call('GetCredential', 
                     {}, ctxt)
 
@@ -1435 +1446 @@
                     'expiration': expiration
                     }
-            r = segment_commands.pg_call(self.sa_url, 'RenewSlice', param, ctxt)
+            r = segment_commands.slice_authority_call('RenewSlice', param, ctxt)
             param = {
                     'credential': cred,
@@ -1441 +1452 @@
                     'type': 'Slice',
                     }
-            slice = segment_commands.pg_call(self.sa_url, 'Resolve', 
+            slice = segment_commands.slice_authority_call('Resolve', 
                     param, ctxt)
             uuid = slice.get('uuid', None)
@@ -1453 +1464 @@
                     'type': 'Slice',
                     }
-            new_scred = segment_commands.pg_call(self.sa_url, 'GetCredential',
+            new_scred = segment_commands.slice_authority_call('GetCredential',
                     param, ctxt)
 
@@ -1465 +1476 @@
                     'slice_urn': slice_urn,
                     }
-            r = segment_commands.pg_call(self.cm_url, 'RenewSlice', param, ctxt)
+            r = segment_commands.component_manager_call('RenewSlice', param, 
+                    ctxt)
         except segment_commands.ProtoGENIError, e:
             self.log.warn("Failed to renew sliver for %s: %s" % (name, e))