- Timestamp:
- Jul 24, 2009 7:10:29 PM (15 years ago)
- Branches:
- axis_example, compt_changes, info-ops, master, version-1.30, version-2.00, version-3.01, version-3.02
- Children:
- 281c0ca
- Parents:
- bd3e314
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
fedd/federation/experiment_control.py
rbd3e314 ra74ea78 530 530 def ssh_cmd(self, user, host, cmd, wname=None, timeout=None): 531 531 """ 532 Run a remote command on host as user. If debug is set, the action is 533 only logged. 532 Run a remote command on host as user. If debug is set, the action 533 is only logged. Commands are run without stdin, to avoid stray 534 SIGTTINs. 534 535 """ 535 sh_str = ("%s - o 'IdentitiesOnly yes' -o " + \536 sh_str = ("%s -n -o 'IdentitiesOnly yes' -o " + \ 536 537 "'StrictHostKeyChecking yes' -i %s %s@%s %s") % \ 537 538 (self.ssh_exec, self.ssh_privkey_file, … … 2033 2034 {'localname' : eid }, { 'fedid': copy.copy(expid) } 2034 2035 ], 2035 'experimentStatus': 'start ed',2036 'experimentStatus': 'starting', 2036 2037 'experimentAccess': { 'X509' : expcert } 2037 2038 } … … 2218 2219 rv['allocationLog'] = "".join(rv['log']) 2219 2220 del rv['log'] 2221 else: 2222 rv['allocationLog'] = "" 2220 2223 2221 2224 if rv['experimentStatus'] != 'active': … … 2266 2269 2267 2270 # First make sure that the experiment creation is complete. 2268 if fed_exp.has_key('experimentStatus'): 2269 if fed_exp['experimentStatus'] == 'started': 2271 status = fed_exp.get('experimentStatus', None) 2272 if status: 2273 if status == 'starting': 2270 2274 self.state_lock.release() 2271 2275 raise service_error(service_error.partial, … … 2330 2334 thread_pool.wait_for_all_done() 2331 2335 2332 # release the allocations 2333 for tb in tbparams.keys(): 2334 self.release_access(tb, tbparams[tb]['aid']) 2336 # release the allocations (failed experiments have done this 2337 # already) 2338 if status != 'failed': 2339 for tb in tbparams.keys(): 2340 self.release_access(tb, tbparams[tb]['aid']) 2335 2341 2336 2342 # Remove the terminated experiment
Note: See TracChangeset
for help on using the changeset viewer.