Revision ec5af888
| b/lib/cmdlib.py | ||
|---|---|---|
| 6530 | 6530 |
drain_flag = NotImplemented |
| 6531 | 6531 |
|
| 6532 | 6532 |
if query.CQ_WATCHER_PAUSE in self.requested_data: |
| 6533 |
watcher_pause = utils.ReadWatcherPauseFile(pathutils.WATCHER_PAUSEFILE) |
|
| 6533 |
master_name = lu.cfg.GetMasterNode() |
|
| 6534 |
|
|
| 6535 |
result = lu.rpc.call_get_watcher_pause(master_name) |
|
| 6536 |
result.Raise("Can't retrieve watcher pause from master node '%s'" %
|
|
| 6537 |
master_name) |
|
| 6538 |
|
|
| 6539 |
watcher_pause = result.payload |
|
| 6534 | 6540 |
else: |
| 6535 | 6541 |
watcher_pause = NotImplemented |
| 6536 | 6542 |
|
| b/lib/rpc_defs.py | ||
|---|---|---|
| 505 | 505 |
("hvname", None, "Hypervisor name"),
|
| 506 | 506 |
("hvfull", None, "Parameters to be validated"),
|
| 507 | 507 |
], None, None, "Validate hypervisor params"), |
| 508 |
("get_watcher_pause", SINGLE, None, constants.RPC_TMO_URGENT, [],
|
|
| 509 |
None, None, "Get watcher pause end"), |
|
| 508 | 510 |
("set_watcher_pause", MULTI, None, constants.RPC_TMO_URGENT, [
|
| 509 | 511 |
("until", None, None),
|
| 510 | 512 |
], None, None, "Set watcher pause end"), |
| b/lib/server/noded.py | ||
|---|---|---|
| 828 | 828 |
return ssconf.WriteSsconfFiles(values) |
| 829 | 829 |
|
| 830 | 830 |
@staticmethod |
| 831 |
def perspective_get_watcher_pause(params): |
|
| 832 |
"""Get watcher pause end. |
|
| 833 |
|
|
| 834 |
""" |
|
| 835 |
return utils.ReadWatcherPauseFile(pathutils.WATCHER_PAUSEFILE) |
|
| 836 |
|
|
| 837 |
@staticmethod |
|
| 831 | 838 |
def perspective_set_watcher_pause(params): |
| 832 | 839 |
"""Set watcher pause. |
| 833 | 840 |
|
Also available in: Unified diff