Revision 685ee993 daemons/ganeti-masterd
| b/daemons/ganeti-masterd | ||
|---|---|---|
| 1 |
#!/usr/bin/python |
|
| 1 |
#!/usr/bin/python -u
|
|
| 2 | 2 |
# |
| 3 | 3 |
|
| 4 | 4 |
# Copyright (C) 2006, 2007 Google Inc. |
| ... | ... | |
| 264 | 264 |
if item is None: |
| 265 | 265 |
break |
| 266 | 266 |
print "worker %s processing job %s" % (worker_id, item.data.job_id) |
| 267 |
utils.Lock('cmd')
|
|
| 267 |
#utils.Lock('cmd')
|
|
| 268 | 268 |
try: |
| 269 | 269 |
proc = mcpu.Processor(feedback=lambda x: None) |
| 270 | 270 |
try: |
| ... | ... | |
| 272 | 272 |
except errors.GenericError, err: |
| 273 | 273 |
print "ganeti exception %s" % err |
| 274 | 274 |
finally: |
| 275 |
utils.Unlock('cmd')
|
|
| 276 |
utils.LockCleanup() |
|
| 275 |
#utils.Unlock('cmd')
|
|
| 276 |
#utils.LockCleanup() |
|
| 277 |
pass |
|
| 277 | 278 |
print "worker %s finish job %s" % (worker_id, item.data.job_id) |
| 278 | 279 |
print "worker %s exiting" % worker_id |
| 279 | 280 |
|
Also available in: Unified diff