Changeset 7a011e9

Timestamp:

Mar 1, 2010 4:39:36 AM (14 years ago)

Author:

Ted Faber <faber@…>

Branches:

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

Children:

b78c9ea

Parents:

8353ac6

Message:

Use self organizing store

File:

• fedd/federation/dragon_access.py (modified) (7 diffs)

fedd/federation/dragon_access.py

@@ -109 +109 @@
         self.trusted_certs = config.get("access", "trusted_certs") or \
                 config.get("globals", "trusted_certs")
+
+        self.call_GetValue= service_caller('GetValue')
+        self.call_SetValue= service_caller('SetValue')
 
         self.soap_services = {\
@@ -687 +690 @@
                 break
 
+        self.log.debug("made reservation %s %s" % (gri, vlan_no))
+
         if (rv == 0 and gri and vlan_no and status == 'ACTIVE'):
             return gri, vlan_no
@@ -709 +714 @@
                         "Failed to open /dev/null: %s" % e)
 
+    def export_store_info(self, cf, vlan, connInfo):
+        """
+        For the export requests in the connection info, install the peer names
+        at the experiment controller via SetValue calls.
+        """
+
+        for c in connInfo:
+            for p in [ p for p in c.get('parameter', []) \
+                    if p.get('type', '') == 'output']:
+
+                if p.get('name', '') != 'vlan_id':
+                    self.log.error("Unknown export parameter: %s" % \
+                            p.get('name'))
+                    continue
+
+                k = p.get('key', None)
+                surl = p.get('store', None)
+                if surl and k:
+                    value = "%s" % vlan
+                    req = { 'name': k, 'value': value }
+                    print "calling SetValue %s %s" % (surl, req)
+                    self.call_SetValue(surl, req, cf)
+                else:
+                    self.log.error("Bad export request: %s" % p)
+
+    def import_store_info(self, cf, connInfo):
+        """
+        Pull any import parameters in connInfo in.  We translate them either
+        into known member names or fedAddrs.
+        """
+
+        for c in connInfo:
+            for p in [ p for p in c.get('parameter', []) \
+                    if p.get('type', '') == 'input']:
+                name = p.get('name', None)
+                key = p.get('key', None)
+                store = p.get('store', None)
+
+                if name and key and store :
+                    req = { 'name': key, 'wait': True }
+                    r = self.call_GetValue(store, req, cf)
+                    r = r.get('GetValueResponseBody', None)
+                    if r :
+                        if r.get('name', '') == key:
+                            v = r.get('value', None)
+                            if v is not None:
+                                if name == 'peer':
+                                    c['peer'] = v
+                                else:
+                                    if c.has_key('fedAttr'):
+                                        c['fedAttr'].append({
+                                            'attribute': name, 'value': value})
+                                    else:
+                                        c['fedAttr']= [{
+                                            'attribute': name, 'value': value}]
+                            else:
+                                raise service_error(service_error.internal, 
+                                        'None value exported for %s'  % key)
+                        else:
+                            raise service_error(service_error.internal, 
+                                    'Different name returned for %s: %s' \
+                                            % (key, r.get('name','')))
+                    else:
+                        raise service_error(service_error.internal, 
+                            'Badly formatted response: no GetValueResponseBody')
+                else:
+                    raise service_error(service_error.internal, 
+                        'Bad Services missing info for import %s' % c)
+
+
     def StartSegment(self, req, fid):
         err = None  # Any service_error generated after tmpdir is created
@@ -723 +798 @@
         if not self.auth.check_attribute(fid, auth_attr):
             raise service_error(service_error.access, "Access denied")
+        else:
+            certfile = "%s/%s.pem" % (self.certdir, aid)
 
         if req.has_key('segmentdescription') and \
@@ -731 +808 @@
             raise service_error(service_error.req, 
                     "Request missing segmentdescription'")
+
+        connInfo = req.get('connection', [])
 
         cap, src, dest, vlans = self.extract_parameters(topo)
@@ -765 +844 @@
                 log=alloc_log)
 
+        self.export_store_info(certfile, vlan_no, connInfo)
+
         if gri:
             # Grab the log (this is some anal locking, but better safe than
@@ -777 +858 @@
                     'allocID': req['allocID'],
                     'allocationLog': logv,
-                    'fedAttr': [
-                        {'attribute': 'vlan', 'value': '%d' % vlan_no }
-                        ]
                     }
         elif err: