Changeset 8cab4c2 for fedd/federation/experiment_control.py
- Timestamp:
- Mar 4, 2012 6:45:19 PM (12 years ago)
- Branches:
- compt_changes, master
- Children:
- 6527d60
- Parents:
- 2bb8b35
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
fedd/federation/experiment_control.py
r2bb8b35 r8cab4c2 1661 1661 self.auth.save() 1662 1662 1663 access_ok, proof = self.auth.check_attribute(fid, 'new', 1664 with_proof=True) 1663 try: 1664 access_ok, proof = self.auth.check_attribute(fid, 'new', 1665 with_proof=True) 1666 except service_error, e: 1667 self.log.info("New experiment call for %s: access denied" % fid) 1668 raise e 1669 1665 1670 1666 1671 if not access_ok: … … 1998 2003 raise service_error(service_error.req, "No request?") 1999 2004 2000 proof = self.check_experiment_access(fid, key) 2005 try: 2006 proof = self.check_experiment_access(fid, key) 2007 except service_error, e: 2008 self.log.info("vtopo call failed for %s: access denied" % fid) 2009 raise e 2001 2010 2002 2011 self.state_lock.acquire() … … 2053 2062 raise service_error(service_error.req, "No request?") 2054 2063 2055 proof = self.check_experiment_access(fid, key) 2064 try: 2065 proof = self.check_experiment_access(fid, key) 2066 except service_error, e: 2067 self.log.info("vis call failed for %s: access denied" % fid) 2068 raise e 2056 2069 2057 2070 self.state_lock.acquire() … … 2155 2168 self.auth.save() 2156 2169 2157 # Make sure that the caller can talk to us 2158 proof = self.check_experiment_access(fid, key) 2170 try: 2171 # Make sure that the caller can talk to us 2172 proof = self.check_experiment_access(fid, key) 2173 except service_error, e: 2174 self.log.info("Create experiment call failed for %s: access denied"\ 2175 % fid) 2176 raise e 2177 2159 2178 2160 2179 # Install the testbed map entries supplied with the request into a copy … … 2398 2417 raise service_error(service_error.req, "No request?") 2399 2418 2400 proof = self.check_experiment_access(fid, key) 2419 try: 2420 proof = self.check_experiment_access(fid, key) 2421 except service_error, e: 2422 self.log.info("Info call failed for %s: access denied" % fid) 2423 2401 2424 2402 2425 self.update_info(key, fresh) … … 2498 2521 else: return None 2499 2522 2523 self.log.info("Operation call started for %s" % fid) 2500 2524 req = req.get('OperationRequestBody', None) 2501 2525 if not req: … … 2522 2546 raise service_error(service_error.req, "No request?") 2523 2547 2524 proof = self.check_experiment_access(fid, key) 2548 try: 2549 proof = self.check_experiment_access(fid, key) 2550 except service_error, e: 2551 self.log.info("Operation call failed for %s: access denied" % fid) 2552 raise e 2553 2525 2554 self.state_lock.acquire() 2526 2555 if key in self.state: … … 2534 2563 2535 2564 if top is None: 2565 self.log.info("Operation call failed for %s: not active" % fid) 2536 2566 raise service_error(service_error.partial, "No topology yet", 2537 2567 proof=proof) … … 2558 2588 results) 2559 2589 2590 self.log.info("Operation call succeeded for %s" % fid) 2560 2591 return { 2561 2592 'experiment': exp, … … 2720 2751 2721 2752 key = self.get_experiment_key(req, 'experiment') 2722 proof = self.check_experiment_access(fid, key) 2753 try: 2754 proof = self.check_experiment_access(fid, key) 2755 except service_error, e: 2756 self.log.info( 2757 "Terminate experiment call failed for %s: access denied" \ 2758 % fid) 2759 raise e 2723 2760 exp = req.get('experiment', False) 2724 2761 force = req.get('force', False)
Note: See TracChangeset
for help on using the changeset viewer.