Changeset e07c8f3 for fedd/federation/experiment_control.py
- Timestamp:
- Jun 1, 2010 8:02:00 AM (14 years ago)
- Branches:
- axis_example, compt_changes, info-ops, master, version-3.01, version-3.02
- Children:
- 1502580
- Parents:
- 5767b20
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
fedd/federation/experiment_control.py
r5767b20 re07c8f3 2134 2134 return rv 2135 2135 2136 def remove_dirs(self, dir): 2137 """ 2138 Remove the directory tree and all files rooted at dir. Log any errors, 2139 but continue. 2140 """ 2141 self.log.debug("[removedirs]: removing %s" % dir) 2142 try: 2143 for path, dirs, files in os.walk(dir, topdown=False): 2144 for f in files: 2145 os.remove(os.path.join(path, f)) 2146 for d in dirs: 2147 os.rmdir(os.path.join(path, d)) 2148 os.rmdir(dir) 2149 except EnvironmentError, e: 2150 self.log.error("Error deleting directory tree in %s" % e); 2151 2136 2152 def terminate_experiment(self, req, fid): 2137 2153 """ … … 2175 2191 self.state_lock.acquire() 2176 2192 fed_exp = self.state.get(key, None) 2193 repo = None 2177 2194 2178 2195 if fed_exp: … … 2205 2222 # keys of self.state - and puts them into ids. 2206 2223 for id in fed_exp.get('experimentID', []): 2207 if id.has_key('fedid'): ids.append(id['fedid']) 2224 if id.has_key('fedid'): 2225 ids.append(id['fedid']) 2226 repo = "%s" % id['fedid'] 2208 2227 if id.has_key('localname'): ids.append(id['localname']) 2209 2228 … … 2276 2295 pass 2277 2296 self.write_store() 2297 2298 # Remove software and other cached stuff from the filesystem. 2299 if repo: 2300 self.remove_dirs("%s/%s" % (self.repodir, repo)) 2278 2301 2279 2302 return {
Note: See TracChangeset
for help on using the changeset viewer.