-
Notifications
You must be signed in to change notification settings - Fork 376
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Recover primary nic if down after publishing hostname in RedhatOSUtil (…
…#3024) * Check nic state and recover if down: * Fix typo * Fix state comparison * Fix pylint errors * Fix string comparison * Report publish hostname failure in calling thread * Add todo to check nic state for all distros where we reset network * Update detection to check connection state and separate recover from publish * Pylint unused argument * refactor recover_nic argument * Network interface e2e test * e2e test for recovering the network interface on redhat distros * Only run scenario on distros which use RedhatOSUtil * Fix call to parent publish_hostname to include recover_nic arg * Update comments in default os util * Remove comment * Fix comment * Do not do detection/recover on RedhatOSMOdernUtil * Resolve PR comments * Make script executable * Revert pypy change * Fix publish hostname paramters
- Loading branch information
1 parent
25d7103
commit 0cd8617
Showing
11 changed files
with
308 additions
and
14 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,17 @@ | ||
| # | ||
| # Brings the primary network interface down and checks that the agent can recover the network. | ||
| # | ||
| name: "RecoverNetworkInterface" | ||
| tests: | ||
| - "recover_network_interface/recover_network_interface.py" | ||
| images: | ||
| # TODO: This scenario should be run on all distros which bring the network interface down to publish hostname. Currently, only RedhatOSUtil attempts to recover the network interface if down after hostname publishing. | ||
| - "centos_79" | ||
| - "centos_75" | ||
| - "centos_82" | ||
| - "rhel_75" | ||
| - "rhel_79" | ||
| - "rhel_82" | ||
| - "oracle_75" | ||
| - "oracle_79" | ||
| - "oracle_82" |
143 changes: 143 additions & 0 deletions
143
tests_e2e/tests/recover_network_interface/recover_network_interface.py
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,143 @@ | ||
| #!/usr/bin/env python3 | ||
|
|
||
| # Microsoft Azure Linux Agent | ||
| # | ||
| # Copyright 2018 Microsoft Corporation | ||
| # | ||
| # Licensed under the Apache License, Version 2.0 (the "License"); | ||
| # you may not use this file except in compliance with the License. | ||
| # You may obtain a copy of the License at | ||
| # | ||
| # http://www.apache.org/licenses/LICENSE-2.0 | ||
| # | ||
| # Unless required by applicable law or agreed to in writing, software | ||
| # distributed under the License is distributed on an "AS IS" BASIS, | ||
| # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. | ||
| # See the License for the specific language governing permissions and | ||
| # limitations under the License. | ||
| # | ||
|
|
||
| # | ||
| # This test uses CSE to bring the network down and call check_and_recover_nic_state to bring the network back into an | ||
| # 'up' and 'connected' state. The intention of the test is to alert us if there is some change in newer distros which | ||
| # affects this logic. | ||
| # | ||
|
|
||
| import json | ||
| from typing import List, Dict, Any | ||
|
|
||
| from assertpy import fail, assert_that | ||
| from time import sleep | ||
|
|
||
| from tests_e2e.tests.lib.agent_test import AgentVmTest, TestSkipped | ||
| from tests_e2e.tests.lib.agent_test_context import AgentVmTestContext | ||
| from tests_e2e.tests.lib.logging import log | ||
| from tests_e2e.tests.lib.virtual_machine_extension_client import VirtualMachineExtensionClient | ||
| from tests_e2e.tests.lib.vm_extension_identifier import VmExtensionIds | ||
|
|
||
|
|
||
| class RecoverNetworkInterface(AgentVmTest): | ||
| def __init__(self, context: AgentVmTestContext): | ||
| super().__init__(context) | ||
| self._context = context | ||
| self._ssh_client = context.create_ssh_client() | ||
| self._private_ip = context.vm.get_private_ip_address() | ||
| self._vm_password = "" | ||
|
|
||
| def add_vm_password(self): | ||
| # Add password to VM to help with debugging in case of failure | ||
| # REMOVE PWD FROM LOGS IF WE EVER MAKE THESE RUNS/LOGS PUBLIC | ||
| username = self._ssh_client.username | ||
| pwd = self._ssh_client.run_command("openssl rand -base64 32 | tr : .").rstrip() | ||
| self._vm_password = pwd | ||
| log.info("VM Username: {0}; VM Password: {1}".format(username, pwd)) | ||
| self._ssh_client.run_command("echo '{0}:{1}' | sudo -S chpasswd".format(username, pwd)) | ||
|
|
||
| def check_agent_reports_status(self): | ||
| status_updated = False | ||
| last_agent_status_time = self._context.vm.get_instance_view().vm_agent.statuses[0].time | ||
| log.info("Agent reported status at {0}".format(last_agent_status_time)) | ||
| retries = 3 | ||
|
|
||
| while retries > 0 and not status_updated: | ||
| agent_status_time = self._context.vm.get_instance_view().vm_agent.statuses[0].time | ||
| if agent_status_time != last_agent_status_time: | ||
| status_updated = True | ||
| log.info("Agent reported status at {0}".format(last_agent_status_time)) | ||
| else: | ||
| retries -= 1 | ||
| sleep(60) | ||
|
|
||
| if not status_updated: | ||
| fail("Agent hasn't reported status since {0} and ssh connection failed. Use the serial console in portal " | ||
| "to debug".format(last_agent_status_time)) | ||
|
|
||
| def run(self): | ||
| # Add password to VM and log. This allows us to debug with serial console if necessary | ||
| log.info("") | ||
| log.info("Adding password to the VM to use for debugging in case necessary...") | ||
| self.add_vm_password() | ||
|
|
||
| # Skip the test if NM_CONTROLLED=n. The current recover logic does not work in this case | ||
| result = self._ssh_client.run_command("recover_network_interface-get_nm_controlled.py", use_sudo=True) | ||
| if "Interface is NOT NM controlled" in result: | ||
| raise TestSkipped("Current recover method will not work on interfaces where NM_Controlled=n") | ||
|
|
||
| # Get the primary network interface name | ||
| ifname = self._ssh_client.run_command("pypy3 -c 'from azurelinuxagent.common.osutil.redhat import RedhatOSUtil; print(RedhatOSUtil().get_if_name())'").rstrip() | ||
| # The interface name needs to be in double quotes for the pypy portion of the script | ||
| formatted_ifname = f'"{ifname}"' | ||
|
|
||
| # The script should bring the primary network interface down and use the agent to recover the interface. These | ||
| # commands will bring the network down, so they should be executed on the machine using CSE instead of ssh. | ||
| script = f""" | ||
| set -euxo pipefail | ||
| ifdown {ifname}; | ||
| nic_state=$(nmcli -g general.state device show {ifname}) | ||
| echo Primary network interface state before recovering: $nic_state | ||
| source /home/{self._context.username}/bin/set-agent-env; | ||
| pypy3 -c 'from azurelinuxagent.common.osutil.redhat import RedhatOSUtil; RedhatOSUtil().check_and_recover_nic_state({formatted_ifname})'; | ||
| nic_state=$(nmcli -g general.state device show {ifname}); | ||
| echo Primary network interface state after recovering: $nic_state | ||
| """ | ||
| log.info("") | ||
| log.info("Using CSE to bring the primary network interface down and call the OSUtil to bring the interface back up. Command to execute: {0}".format(script)) | ||
| custom_script = VirtualMachineExtensionClient(self._context.vm, VmExtensionIds.CustomScript, resource_name="CustomScript") | ||
| custom_script.enable( | ||
| protected_settings={ | ||
| 'commandToExecute': script | ||
| } | ||
| ) | ||
|
|
||
| # Check that the interface was down and brought back up in instance view | ||
| log.info("") | ||
| log.info("Checking the instance view to confirm the primary network interface was brought down and successfully recovered by the agent...") | ||
| instance_view = custom_script.get_instance_view() | ||
| log.info("Instance view for custom script after enable is: {0}".format(json.dumps(instance_view.serialize(), indent=4))) | ||
| assert_that(len(instance_view.statuses)).described_as("Instance view should have a status for CustomScript").is_greater_than(0) | ||
| assert_that(instance_view.statuses[0].message).described_as("The primary network interface should be in a disconnected state before the attempt to recover").contains("Primary network interface state before recovering: 30 (disconnected)") | ||
| assert_that(instance_view.statuses[0].message).described_as("The primary network interface should be in a connected state after the attempt to recover").contains("Primary network interface state after recovering: 100 (connected)") | ||
|
|
||
| # Check that the agent is successfully reporting status after recovering the network | ||
| log.info("") | ||
| log.info("Checking that the agent is reporting status after recovering the network...") | ||
| self.check_agent_reports_status() | ||
|
|
||
| log.info("") | ||
| log.info("The primary network interface was successfully recovered by the agent.") | ||
|
|
||
| def get_ignore_error_rules(self) -> List[Dict[str, Any]]: | ||
| ignore_rules = [ | ||
| # | ||
| # We may see temporary network unreachable warnings since we are bringing the network interface down | ||
| # 2024-02-01T23:40:03.563499Z ERROR ExtHandler ExtHandler Error fetching the goal state: [ProtocolError] GET vmSettings [correlation ID: ac21bdd7-1a7a-4bba-b307-b9d5bc30da33 eTag: 941323814975149980]: Request failed: [Errno 101] Network is unreachable | ||
| # | ||
| { | ||
| 'message': r"Error fetching the goal state: \[ProtocolError\] GET vmSettings.*Request failed: \[Errno 101\] Network is unreachable" | ||
| } | ||
| ] | ||
| return ignore_rules | ||
|
|
||
|
|
||
| if __name__ == "__main__": | ||
| RecoverNetworkInterface.run_from_command_line() |
Oops, something went wrong.