Changeset cd06678 for fedd/federation/protogeni_access.py

Timestamp:

Mar 18, 2010 11:39:59 AM (14 years ago)

Author:

Ted Faber <faber@…>

Branches:

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

Children:

1627c3d

Parents:

bdf00d5

Message:

Handle replayed StartSegment? calls. SSL sometimes kills the response and this is needed to get the response to the controller w/o redoing the allocation

File:

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

fedd/federation/protogeni_access.py

@@ -905 +905 @@
         if not self.auth.check_attribute(fid, auth_attr):
             raise service_error(service_error.access, "Access denied")
+        else:
+            # See if this is a replay of an earlier succeeded StartSegment -
+            # sometimes SSL kills 'em.  If so, replay the response rather than
+            # redoing the allocation.
+            self.state_lock.acquire()
+            retval = self.allocation[aid].get('started', None)
+            self.state_lock.release()
+            if retval:
+                self.log.warning("Duplicate StartSegment for %s: " % aid + \
+                        "replaying response")
+                return retval
 
 
@@ -1069 +1080 @@
             self.state_lock.acquire()
             logv = "".join(self.allocation[aid]['log'])
+            # It's possible that the StartSegment call gets retried (!). 
+            # if the 'started' key is in the allocation, we'll return it rather
+            # than redo the setup.
+            self.allocation[aid]['started'] = { 
+                    'allocID': req['allocID'],
+                    'allocationLog': logv,
+                    }
+            retval = self.allocation[aid]['started']
             self.state_lock.release()
 
-            return { 'allocID': req['allocID'], 'allocationLog': logv }
+            return retval
         elif err:
             raise service_error(service_error.federant,