Changeset 45e880d for fedd/federation

Timestamp:

Nov 23, 2011 2:47:06 PM (13 years ago)

Author:

Ted Faber <faber@…>

Branches:

compt_changes, info-ops, master

Children:

6e33086

Parents:

c6f867c

Message:

More initial info edits

File:

• fedd/federation/emulab_access.py (modified) (1 diff)

fedd/federation/emulab_access.py

@@ -1199 +1199 @@
         stopper(self, user, proj, ename, gid, nonce)
         return { 'allocID': req['allocID'], 'proof': proof.to_dict() }
+
+    def InfoSegment(self, req, fid):
+        try:
+            req = req['InfoSegmentRequestBody']
+        except KeyError:
+            raise service_error(server_error.req, "Badly formed request")
+
+        auth_attr = req['allocID']['fedid']
+        aid = "%s" % auth_attr
+
+        access_ok, proof = self.auth.check_attribute(fid, auth_attr, 
+                with_proof=True)
+        if not access_ok:
+            raise service_error(service_error.access, "Access denied")
+
+        self.state_lock.acquire()
+        if aid in self.allocation:
+            topo = self.allocation[aid].get('topo', None)
+            if topo: topo = topo.clone()
+            proj = self.allocation[aid].get('project', None)
+            if not proj: 
+                proj = self.allocation[aid].get('sproject', None)
+            user = self.allocation[aid].get('user', None)
+            ename = self.allocation[aid].get('experiment', None)
+            nonce = self.allocation[aid].get('nonce', False)
+        else:
+            proj = None
+            user = None
+            ename = None
+            nonce = False
+        self.state_lock.release()
+
+        if not proj:
+            raise service_error(service_error.internal, 
+                    "Can't find project for %s" % aid)
+        else:
+            if '/' in proj: proj, gid = proj.split('/')
+            else: gid = None
+
+        if not user:
+            raise service_error(service_error.internal, 
+                    "Can't find creation user for %s" % aid)
+        if not ename:
+            raise service_error(service_error.internal, 
+                    "Can't find experiment name for %s" % aid)
+        info = self.info_segment(keyfile=self.ssh_privkey_file,
+                debug=self.create_debug, boss=self.boss, cert=self.xmlrpc_cert)
+        info(self, user, proj, ename, gid, nonce)
+        return { 
+                'allocID': req['allocID'], 
+                'experimentdescription' { 'topdldescription' : topo.to_dict() },
+                'proof': proof.to_dict(),
+                }
+