Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Added ip_power control for BareMetal platform #3550

Open
wants to merge 6 commits into
base: main
Choose a base branch
from
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
68 changes: 68 additions & 0 deletions lisa/sut_orchestrator/baremetal/ip_power.py
Original file line number Diff line number Diff line change
@@ -0,0 +1,68 @@
# Copyright (c) Microsoft Corporation.
# Licensed under the MIT license.

from typing import Type

import requests

from lisa import schema
from lisa.util import ContextMixin, InitializableMixin, LisaException, subclasses
from lisa.util.logger import get_logger

from .schema import IPPowerSchema

REQUEST_TIMEOUT = 3
REQUEST_SUCCESS_CODE = 200


class IPPower(subclasses.BaseClassWithRunbookMixin, ContextMixin, InitializableMixin):
Copy link
Member

@squirrelsc squirrelsc Dec 9, 2024

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Follow SerialConsole's design, implement the logic in the feature, and call it in cluster, when it's needed.

def __init__(self, runbook: IPPowerSchema) -> None:
super().__init__(runbook=runbook)
self._log = get_logger("cluster", self.__class__.__name__)

@classmethod
def type_schema(cls) -> Type[schema.TypedSchema]:
return IPPowerSchema

def on(self, port: str) -> None:
raise NotImplementedError()

def off(self, port: str) -> None:
raise NotImplementedError()


class Ip9285(IPPower):
def __init__(self, runbook: IPPowerSchema) -> None:
super().__init__(runbook)
self._request_cmd = (
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

What does the P6 mean? If it's part of the port, move it to on/off, so it's clearer.

f"http://{runbook.host}/set.cmd?"
f"user={runbook.username}+pass="
f"{runbook.password}+cmd=setpower+P6"
)

@classmethod
def type_name(cls) -> str:
return "Ip9285"

@classmethod
def type_schema(cls) -> Type[schema.TypedSchema]:
return IPPowerSchema

def on(self, port: str) -> None:
request_on = f"{self._request_cmd}{port}=1"
self._set_ip_power(request_on)

def off(self, port: str) -> None:
request_off = f"{self._request_cmd}{port}=0"
self._set_ip_power(request_off)

def _set_ip_power(self, power_cmd: str) -> None:
try:
response = requests.get(power_cmd, timeout=REQUEST_TIMEOUT)
response.raise_for_status()
except requests.HTTPError as http_err:
raise LisaException(f"HTTP error: {http_err} in set_ip_power occurred")
except Exception as err:
raise LisaException(f"Other Error: {err} in set_ip_power occurred")
else:
self._log.debug(f"Command {power_cmd} in set_ip_power done")
12 changes: 12 additions & 0 deletions lisa/sut_orchestrator/baremetal/schema.py
Original file line number Diff line number Diff line change
Expand Up @@ -72,6 +72,18 @@ class BootConfigSchema(schema.TypedSchema, schema.ExtendableSchemaMixin):
type: str = field(default="boot_config", metadata=field_metadata(required=True))


@dataclass_json()
@dataclass
class IPPowerSchema(schema.TypedSchema, schema.ExtendableSchemaMixin):
type: str = field(default="Ip9285", metadata=field_metadata(required=True))
host: str = ""
username: str = ""
password: str = ""

def __post_init__(self, *args: Any, **kwargs: Any) -> None:
add_secret(self.password)


@dataclass_json()
@dataclass
class ClusterSchema(schema.TypedSchema, schema.ExtendableSchemaMixin):
Expand Down
Loading