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