TrueCloudLab/frostfs-testlib
25
0
Fork 20
Code Issues Pull requests 2 Releases 1 Activity Actions

Add optional parameter "no wait for return" in panic_reboot_host #20

Merged
abereziny merged 1 commit from yadro-vavdeev/frostfs-testlib:panic_reboot_wait into master 2023-05-18 08:15:14 +00:00
Conversation 0 Commits 1 Files changed 1 +7 -6
1 changed files with 7 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

13
src/frostfs_testlib/storage/controllers/cluster_state_controller.py
View file

@ -94,18 +94,19 @@ class ClusterStateController:
@run_optionally(optionals.OPTIONAL_FAILOVER_ENABLED) @run_optionally(optionals.OPTIONAL_FAILOVER_ENABLED)
@reporter.step_deco("Hard reboot host {node} via magic SysRq option") @reporter.step_deco("Hard reboot host {node} via magic SysRq option")
def panic_reboot_host(self, node: ClusterNode): def panic_reboot_host(self, node: ClusterNode, wait_for_return: bool = True):
shell = node.host.get_shell() shell = node.host.get_shell()
shell.exec('sudo sh -c "echo 1 > /proc/sys/kernel/sysrq"') shell.exec('sudo sh -c "echo 1 > /proc/sys/kernel/sysrq"')
options = CommandOptions(close_stdin=True, timeout=1, check=False) options = CommandOptions(close_stdin=True, timeout=1, check=False)
shell.exec('sudo sh -c "echo b > /proc/sysrq-trigger"', options) shell.exec('sudo sh -c "echo b > /proc/sysrq-trigger"', options)
# Let the things to be settled if wait_for_return:
# A little wait here to prevent ssh stuck during panic # Let the things to be settled
time.sleep(10) # A little wait here to prevent ssh stuck during panic
wait_for_host_online(self.shell, node.storage_node) time.sleep(10)
wait_for_node_online(node.storage_node) wait_for_host_online(self.shell, node.storage_node)
wait_for_node_online(node.storage_node)
@reporter.step_deco("Wait up to {timeout} seconds for nodes on cluster to align epochs") @reporter.step_deco("Wait up to {timeout} seconds for nodes on cluster to align epochs")
def wait_for_epochs_align(self, timeout=60): def wait_for_epochs_align(self, timeout=60):