Revision f4484122 lib/luxi.py
| b/lib/luxi.py | ||
|---|---|---|
| 372 | 372 |
timeout = (DEF_RWTO - 1) / 2 |
| 373 | 373 |
return self.CallMethod(REQ_AUTOARCHIVE_JOBS, (age, timeout)) |
| 374 | 374 |
|
| 375 |
def WaitForJobChange(self, job_id, fields, prev_job_info, prev_log_serial): |
|
| 375 |
def WaitForJobChangeOnce(self, job_id, fields, |
|
| 376 |
prev_job_info, prev_log_serial): |
|
| 376 | 377 |
timeout = (DEF_RWTO - 1) / 2 |
| 378 |
return self.CallMethod(REQ_WAIT_FOR_JOB_CHANGE, |
|
| 379 |
(job_id, fields, prev_job_info, |
|
| 380 |
prev_log_serial, timeout)) |
|
| 381 |
|
|
| 382 |
def WaitForJobChange(self, job_id, fields, prev_job_info, prev_log_serial): |
|
| 377 | 383 |
while True: |
| 378 |
result = self.CallMethod(REQ_WAIT_FOR_JOB_CHANGE, |
|
| 379 |
(job_id, fields, prev_job_info, |
|
| 380 |
prev_log_serial, timeout)) |
|
| 384 |
result = self.WaitForJobChangeOnce(job_id, fields, |
|
| 385 |
prev_job_info, prev_log_serial) |
|
| 381 | 386 |
if result != constants.JOB_NOTCHANGED: |
| 382 | 387 |
break |
| 383 | 388 |
return result |
| ... | ... | |
| 402 | 407 |
|
| 403 | 408 |
def QueryTags(self, kind, name): |
| 404 | 409 |
return self.CallMethod(REQ_QUERY_TAGS, (kind, name)) |
| 405 |
|
|
| 406 |
|
|
| 407 |
# TODO: class Server(object) |
|
Also available in: Unified diff