# Copyright (c) Microsoft Corporation.
# Licensed under the MIT license.

from typing import List, Set

from maro.backends.frame import NodeAttribute, NodeBase, node

from .enums import PmState
from .virtual_machine import VirtualMachine


@node("pms")
class PhysicalMachine(NodeBase):
    """Physical machine node definition in frame."""

    # Initial parameters.
    id = NodeAttribute("i")
    cpu_cores_capacity = NodeAttribute("i2")
    memory_capacity = NodeAttribute("i2")
    pm_type = NodeAttribute("i2")
    # Statistical features.
    cpu_cores_allocated = NodeAttribute("i2")
    memory_allocated = NodeAttribute("i2")

    cpu_utilization = NodeAttribute("f")
    energy_consumption = NodeAttribute("f")

    # PM type: non-oversubscribable is -1, empty: 0, oversubscribable is 1.
    oversubscribable = NodeAttribute("i2")

    region_id = NodeAttribute("i2")
    zone_id = NodeAttribute("i2")
    data_center_id = NodeAttribute("i2")
    cluster_id = NodeAttribute("i2")
    rack_id = NodeAttribute("i")

    def __init__(self):
        """Internal use for reset."""
        self._id = 0
        self._init_cpu_cores_capacity = 0
        self._init_memory_capacity = 0
        self._init_pm_type = 0
        self._init_pm_state = 0

        self._region_id = 0
        self._zone_id = 0
        self._data_center_id = 0
        self._cluster_id = 0
        self._rack_id = 0

        # PM resource.
        self._live_vms: Set[int] = set()

    def update_cpu_utilization(self, vm: VirtualMachine = None, cpu_utilization: float = None):
        if vm is None and cpu_utilization is None:
            raise Exception(f"Wrong calling method {self.update_cpu_utilization.__name__}")

        if vm is not None:
            cpu_utilization = (
                self.cpu_cores_capacity * self.cpu_utilization + vm.cpu_cores_requirement * vm.cpu_utilization
            ) / self.cpu_cores_capacity

        self.cpu_utilization = round(max(0, cpu_utilization), 2)

    def set_init_state(
        self,
        id: int,
        cpu_cores_capacity: int,
        memory_capacity: int,
        pm_type: int,
        region_id: int,
        zone_id: int,
        data_center_id: int,
        cluster_id: int,
        rack_id: int,
        oversubscribable: PmState = 0,
        idle_energy_consumption: float = 0,
    ):
        """Set initialize state, that will be used after frame reset.

        Args:
            id (int): PM id, from 0 to N. N means the amount of PM, which can be set in config.
            cpu_cores_capacity (int): The capacity of cores of the PM, which can be set in config.
            memory_capacity (int): The capacity of memory of the PM, which can be set in config.
            pm_type (int): The type of the PM.
            region_id (int): The region's id where the PM locates in.
            zone_id (int): The zone's id where the PM locates in.
            data_center_id (int): The data center's id where the PM locates in.
            cluster_id (int): The cluster's id where the PM locates in.
            rack_id (int): The rack's id where the PM locates in.
            oversubscribable (int): The state of the PM:
                                    - non-oversubscribable: -1.
                                    - empty: 0.
                                    - oversubscribable: 1.
        """
        self._id = id
        self._init_cpu_cores_capacity = cpu_cores_capacity
        self._init_memory_capacity = memory_capacity
        self._init_pm_type = pm_type
        self._init_pm_state = oversubscribable

        self._region_id = region_id
        self._zone_id = zone_id
        self._data_center_id = data_center_id
        self._cluster_id = cluster_id
        self._rack_id = rack_id

        self._idle_energy_consumption = idle_energy_consumption

        self.reset()

    def reset(self):
        """Reset to default value.

        Note:
            Since frame reset will reset all the node's attributes to 0, we need to
            call set_init_state to store correct initial value.
        """
        # When we reset frame, all the value will be set to 0, so we need these lines.
        self.id = self._id
        self.cpu_cores_capacity = self._init_cpu_cores_capacity
        self.memory_capacity = self._init_memory_capacity
        self.pm_type = self._init_pm_type
        self.oversubscribable = self._init_pm_state

        self.region_id = self._region_id
        self.zone_id = self._zone_id
        self.data_center_id = self._data_center_id
        self.cluster_id = self._cluster_id
        self.rack_id = self._rack_id

        self._live_vms.clear()

        self.cpu_cores_allocated = 0
        self.memory_allocated = 0

        self.cpu_utilization = 0.0
        self.energy_consumption = self._idle_energy_consumption

    @property
    def live_vms(self) -> Set[int]:
        return self._live_vms

    def allocate_vms(self, vm_ids: List[int]):
        for vm_id in vm_ids:
            self._live_vms.add(vm_id)

    def deallocate_vms(self, vm_ids: List[int]):
        for vm_id in vm_ids:
            self._live_vms.remove(vm_id)

98fd42d7b0907510fcff11d42a1598f76c8d6e07
<mask token>


@node('pms')
class PhysicalMachine(NodeBase):
    <mask token>
    <mask token>
    <mask token>
    <mask token>
    <mask token>
    <mask token>
    <mask token>
    <mask token>
    <mask token>
    <mask token>
    <mask token>
    <mask token>
    <mask token>
    <mask token>
    <mask token>
    <mask token>

    def update_cpu_utilization(self, vm: VirtualMachine=None,
        cpu_utilization: float=None):
        if vm is None and cpu_utilization is None:
            raise Exception(
                f'Wrong calling method {self.update_cpu_utilization.__name__}')
        if vm is not None:
            cpu_utilization = (self.cpu_cores_capacity * self.
                cpu_utilization + vm.cpu_cores_requirement * vm.cpu_utilization
                ) / self.cpu_cores_capacity
        self.cpu_utilization = round(max(0, cpu_utilization), 2)
    <mask token>

    def reset(self):
        """Reset to default value.

        Note:
            Since frame reset will reset all the node's attributes to 0, we need to
            call set_init_state to store correct initial value.
        """
        self.id = self._id
        self.cpu_cores_capacity = self._init_cpu_cores_capacity
        self.memory_capacity = self._init_memory_capacity
        self.pm_type = self._init_pm_type
        self.oversubscribable = self._init_pm_state
        self.region_id = self._region_id
        self.zone_id = self._zone_id
        self.data_center_id = self._data_center_id
        self.cluster_id = self._cluster_id
        self.rack_id = self._rack_id
        self._live_vms.clear()
        self.cpu_cores_allocated = 0
        self.memory_allocated = 0
        self.cpu_utilization = 0.0
        self.energy_consumption = self._idle_energy_consumption

    @property
    def live_vms(self) ->Set[int]:
        return self._live_vms
    <mask token>

    def deallocate_vms(self, vm_ids: List[int]):
        for vm_id in vm_ids:
            self._live_vms.remove(vm_id)

<mask token>


@node('pms')
class PhysicalMachine(NodeBase):
    <mask token>
    <mask token>
    <mask token>
    <mask token>
    <mask token>
    <mask token>
    <mask token>
    <mask token>
    <mask token>
    <mask token>
    <mask token>
    <mask token>
    <mask token>
    <mask token>
    <mask token>

    def __init__(self):
        """Internal use for reset."""
        self._id = 0
        self._init_cpu_cores_capacity = 0
        self._init_memory_capacity = 0
        self._init_pm_type = 0
        self._init_pm_state = 0
        self._region_id = 0
        self._zone_id = 0
        self._data_center_id = 0
        self._cluster_id = 0
        self._rack_id = 0
        self._live_vms: Set[int] = set()

    def update_cpu_utilization(self, vm: VirtualMachine=None,
        cpu_utilization: float=None):
        if vm is None and cpu_utilization is None:
            raise Exception(
                f'Wrong calling method {self.update_cpu_utilization.__name__}')
        if vm is not None:
            cpu_utilization = (self.cpu_cores_capacity * self.
                cpu_utilization + vm.cpu_cores_requirement * vm.cpu_utilization
                ) / self.cpu_cores_capacity
        self.cpu_utilization = round(max(0, cpu_utilization), 2)

    def set_init_state(self, id: int, cpu_cores_capacity: int,
        memory_capacity: int, pm_type: int, region_id: int, zone_id: int,
        data_center_id: int, cluster_id: int, rack_id: int,
        oversubscribable: PmState=0, idle_energy_consumption: float=0):
        """Set initialize state, that will be used after frame reset.

        Args:
            id (int): PM id, from 0 to N. N means the amount of PM, which can be set in config.
            cpu_cores_capacity (int): The capacity of cores of the PM, which can be set in config.
            memory_capacity (int): The capacity of memory of the PM, which can be set in config.
            pm_type (int): The type of the PM.
            region_id (int): The region's id where the PM locates in.
            zone_id (int): The zone's id where the PM locates in.
            data_center_id (int): The data center's id where the PM locates in.
            cluster_id (int): The cluster's id where the PM locates in.
            rack_id (int): The rack's id where the PM locates in.
            oversubscribable (int): The state of the PM:
                                    - non-oversubscribable: -1.
                                    - empty: 0.
                                    - oversubscribable: 1.
        """
        self._id = id
        self._init_cpu_cores_capacity = cpu_cores_capacity
        self._init_memory_capacity = memory_capacity
        self._init_pm_type = pm_type
        self._init_pm_state = oversubscribable
        self._region_id = region_id
        self._zone_id = zone_id
        self._data_center_id = data_center_id
        self._cluster_id = cluster_id
        self._rack_id = rack_id
        self._idle_energy_consumption = idle_energy_consumption
        self.reset()

    def reset(self):
        """Reset to default value.

        Note:
            Since frame reset will reset all the node's attributes to 0, we need to
            call set_init_state to store correct initial value.
        """
        self.id = self._id
        self.cpu_cores_capacity = self._init_cpu_cores_capacity
        self.memory_capacity = self._init_memory_capacity
        self.pm_type = self._init_pm_type
        self.oversubscribable = self._init_pm_state
        self.region_id = self._region_id
        self.zone_id = self._zone_id
        self.data_center_id = self._data_center_id
        self.cluster_id = self._cluster_id
        self.rack_id = self._rack_id
        self._live_vms.clear()
        self.cpu_cores_allocated = 0
        self.memory_allocated = 0
        self.cpu_utilization = 0.0
        self.energy_consumption = self._idle_energy_consumption

    @property
    def live_vms(self) ->Set[int]:
        return self._live_vms

    def allocate_vms(self, vm_ids: List[int]):
        for vm_id in vm_ids:
            self._live_vms.add(vm_id)

    def deallocate_vms(self, vm_ids: List[int]):
        for vm_id in vm_ids:
            self._live_vms.remove(vm_id)

<mask token>


@node('pms')
class PhysicalMachine(NodeBase):
    """Physical machine node definition in frame."""
    id = NodeAttribute('i')
    cpu_cores_capacity = NodeAttribute('i2')
    memory_capacity = NodeAttribute('i2')
    pm_type = NodeAttribute('i2')
    cpu_cores_allocated = NodeAttribute('i2')
    memory_allocated = NodeAttribute('i2')
    cpu_utilization = NodeAttribute('f')
    energy_consumption = NodeAttribute('f')
    oversubscribable = NodeAttribute('i2')
    region_id = NodeAttribute('i2')
    zone_id = NodeAttribute('i2')
    data_center_id = NodeAttribute('i2')
    cluster_id = NodeAttribute('i2')
    rack_id = NodeAttribute('i')

    def __init__(self):
        """Internal use for reset."""
        self._id = 0
        self._init_cpu_cores_capacity = 0
        self._init_memory_capacity = 0
        self._init_pm_type = 0
        self._init_pm_state = 0
        self._region_id = 0
        self._zone_id = 0
        self._data_center_id = 0
        self._cluster_id = 0
        self._rack_id = 0
        self._live_vms: Set[int] = set()

    def update_cpu_utilization(self, vm: VirtualMachine=None,
        cpu_utilization: float=None):
        if vm is None and cpu_utilization is None:
            raise Exception(
                f'Wrong calling method {self.update_cpu_utilization.__name__}')
        if vm is not None:
            cpu_utilization = (self.cpu_cores_capacity * self.
                cpu_utilization + vm.cpu_cores_requirement * vm.cpu_utilization
                ) / self.cpu_cores_capacity
        self.cpu_utilization = round(max(0, cpu_utilization), 2)

    def set_init_state(self, id: int, cpu_cores_capacity: int,
        memory_capacity: int, pm_type: int, region_id: int, zone_id: int,
        data_center_id: int, cluster_id: int, rack_id: int,
        oversubscribable: PmState=0, idle_energy_consumption: float=0):
        """Set initialize state, that will be used after frame reset.

        Args:
            id (int): PM id, from 0 to N. N means the amount of PM, which can be set in config.
            cpu_cores_capacity (int): The capacity of cores of the PM, which can be set in config.
            memory_capacity (int): The capacity of memory of the PM, which can be set in config.
            pm_type (int): The type of the PM.
            region_id (int): The region's id where the PM locates in.
            zone_id (int): The zone's id where the PM locates in.
            data_center_id (int): The data center's id where the PM locates in.
            cluster_id (int): The cluster's id where the PM locates in.
            rack_id (int): The rack's id where the PM locates in.
            oversubscribable (int): The state of the PM:
                                    - non-oversubscribable: -1.
                                    - empty: 0.
                                    - oversubscribable: 1.
        """
        self._id = id
        self._init_cpu_cores_capacity = cpu_cores_capacity
        self._init_memory_capacity = memory_capacity
        self._init_pm_type = pm_type
        self._init_pm_state = oversubscribable
        self._region_id = region_id
        self._zone_id = zone_id
        self._data_center_id = data_center_id
        self._cluster_id = cluster_id
        self._rack_id = rack_id
        self._idle_energy_consumption = idle_energy_consumption
        self.reset()

    def reset(self):
        """Reset to default value.

        Note:
            Since frame reset will reset all the node's attributes to 0, we need to
            call set_init_state to store correct initial value.
        """
        self.id = self._id
        self.cpu_cores_capacity = self._init_cpu_cores_capacity
        self.memory_capacity = self._init_memory_capacity
        self.pm_type = self._init_pm_type
        self.oversubscribable = self._init_pm_state
        self.region_id = self._region_id
        self.zone_id = self._zone_id
        self.data_center_id = self._data_center_id
        self.cluster_id = self._cluster_id
        self.rack_id = self._rack_id
        self._live_vms.clear()
        self.cpu_cores_allocated = 0
        self.memory_allocated = 0
        self.cpu_utilization = 0.0
        self.energy_consumption = self._idle_energy_consumption

    @property
    def live_vms(self) ->Set[int]:
        return self._live_vms

    def allocate_vms(self, vm_ids: List[int]):
        for vm_id in vm_ids:
            self._live_vms.add(vm_id)

    def deallocate_vms(self, vm_ids: List[int]):
        for vm_id in vm_ids:
            self._live_vms.remove(vm_id)

from typing import List, Set
from maro.backends.frame import NodeAttribute, NodeBase, node
from .enums import PmState
from .virtual_machine import VirtualMachine


@node('pms')
class PhysicalMachine(NodeBase):
    """Physical machine node definition in frame."""
    id = NodeAttribute('i')
    cpu_cores_capacity = NodeAttribute('i2')
    memory_capacity = NodeAttribute('i2')
    pm_type = NodeAttribute('i2')
    cpu_cores_allocated = NodeAttribute('i2')
    memory_allocated = NodeAttribute('i2')
    cpu_utilization = NodeAttribute('f')
    energy_consumption = NodeAttribute('f')
    oversubscribable = NodeAttribute('i2')
    region_id = NodeAttribute('i2')
    zone_id = NodeAttribute('i2')
    data_center_id = NodeAttribute('i2')
    cluster_id = NodeAttribute('i2')
    rack_id = NodeAttribute('i')

    def __init__(self):
        """Internal use for reset."""
        self._id = 0
        self._init_cpu_cores_capacity = 0
        self._init_memory_capacity = 0
        self._init_pm_type = 0
        self._init_pm_state = 0
        self._region_id = 0
        self._zone_id = 0
        self._data_center_id = 0
        self._cluster_id = 0
        self._rack_id = 0
        self._live_vms: Set[int] = set()

    def update_cpu_utilization(self, vm: VirtualMachine=None,
        cpu_utilization: float=None):
        if vm is None and cpu_utilization is None:
            raise Exception(
                f'Wrong calling method {self.update_cpu_utilization.__name__}')
        if vm is not None:
            cpu_utilization = (self.cpu_cores_capacity * self.
                cpu_utilization + vm.cpu_cores_requirement * vm.cpu_utilization
                ) / self.cpu_cores_capacity
        self.cpu_utilization = round(max(0, cpu_utilization), 2)

    def set_init_state(self, id: int, cpu_cores_capacity: int,
        memory_capacity: int, pm_type: int, region_id: int, zone_id: int,
        data_center_id: int, cluster_id: int, rack_id: int,
        oversubscribable: PmState=0, idle_energy_consumption: float=0):
        """Set initialize state, that will be used after frame reset.

        Args:
            id (int): PM id, from 0 to N. N means the amount of PM, which can be set in config.
            cpu_cores_capacity (int): The capacity of cores of the PM, which can be set in config.
            memory_capacity (int): The capacity of memory of the PM, which can be set in config.
            pm_type (int): The type of the PM.
            region_id (int): The region's id where the PM locates in.
            zone_id (int): The zone's id where the PM locates in.
            data_center_id (int): The data center's id where the PM locates in.
            cluster_id (int): The cluster's id where the PM locates in.
            rack_id (int): The rack's id where the PM locates in.
            oversubscribable (int): The state of the PM:
                                    - non-oversubscribable: -1.
                                    - empty: 0.
                                    - oversubscribable: 1.
        """
        self._id = id
        self._init_cpu_cores_capacity = cpu_cores_capacity
        self._init_memory_capacity = memory_capacity
        self._init_pm_type = pm_type
        self._init_pm_state = oversubscribable
        self._region_id = region_id
        self._zone_id = zone_id
        self._data_center_id = data_center_id
        self._cluster_id = cluster_id
        self._rack_id = rack_id
        self._idle_energy_consumption = idle_energy_consumption
        self.reset()

    def reset(self):
        """Reset to default value.

        Note:
            Since frame reset will reset all the node's attributes to 0, we need to
            call set_init_state to store correct initial value.
        """
        self.id = self._id
        self.cpu_cores_capacity = self._init_cpu_cores_capacity
        self.memory_capacity = self._init_memory_capacity
        self.pm_type = self._init_pm_type
        self.oversubscribable = self._init_pm_state
        self.region_id = self._region_id
        self.zone_id = self._zone_id
        self.data_center_id = self._data_center_id
        self.cluster_id = self._cluster_id
        self.rack_id = self._rack_id
        self._live_vms.clear()
        self.cpu_cores_allocated = 0
        self.memory_allocated = 0
        self.cpu_utilization = 0.0
        self.energy_consumption = self._idle_energy_consumption

    @property
    def live_vms(self) ->Set[int]:
        return self._live_vms

    def allocate_vms(self, vm_ids: List[int]):
        for vm_id in vm_ids:
            self._live_vms.add(vm_id)

    def deallocate_vms(self, vm_ids: List[int]):
        for vm_id in vm_ids:
            self._live_vms.remove(vm_id)

# Copyright (c) Microsoft Corporation.
# Licensed under the MIT license.

from typing import List, Set

from maro.backends.frame import NodeAttribute, NodeBase, node

from .enums import PmState
from .virtual_machine import VirtualMachine


@node("pms")
class PhysicalMachine(NodeBase):
    """Physical machine node definition in frame."""

    # Initial parameters.
    id = NodeAttribute("i")
    cpu_cores_capacity = NodeAttribute("i2")
    memory_capacity = NodeAttribute("i2")
    pm_type = NodeAttribute("i2")
    # Statistical features.
    cpu_cores_allocated = NodeAttribute("i2")
    memory_allocated = NodeAttribute("i2")

    cpu_utilization = NodeAttribute("f")
    energy_consumption = NodeAttribute("f")

    # PM type: non-oversubscribable is -1, empty: 0, oversubscribable is 1.
    oversubscribable = NodeAttribute("i2")

    region_id = NodeAttribute("i2")
    zone_id = NodeAttribute("i2")
    data_center_id = NodeAttribute("i2")
    cluster_id = NodeAttribute("i2")
    rack_id = NodeAttribute("i")

    def __init__(self):
        """Internal use for reset."""
        self._id = 0
        self._init_cpu_cores_capacity = 0
        self._init_memory_capacity = 0
        self._init_pm_type = 0
        self._init_pm_state = 0

        self._region_id = 0
        self._zone_id = 0
        self._data_center_id = 0
        self._cluster_id = 0
        self._rack_id = 0

        # PM resource.
        self._live_vms: Set[int] = set()

    def update_cpu_utilization(self, vm: VirtualMachine = None, cpu_utilization: float = None):
        if vm is None and cpu_utilization is None:
            raise Exception(f"Wrong calling method {self.update_cpu_utilization.__name__}")

        if vm is not None:
            cpu_utilization = (
                self.cpu_cores_capacity * self.cpu_utilization + vm.cpu_cores_requirement * vm.cpu_utilization
            ) / self.cpu_cores_capacity

        self.cpu_utilization = round(max(0, cpu_utilization), 2)

    def set_init_state(
        self,
        id: int,
        cpu_cores_capacity: int,
        memory_capacity: int,
        pm_type: int,
        region_id: int,
        zone_id: int,
        data_center_id: int,
        cluster_id: int,
        rack_id: int,
        oversubscribable: PmState = 0,
        idle_energy_consumption: float = 0,
    ):
        """Set initialize state, that will be used after frame reset.

        Args:
            id (int): PM id, from 0 to N. N means the amount of PM, which can be set in config.
            cpu_cores_capacity (int): The capacity of cores of the PM, which can be set in config.
            memory_capacity (int): The capacity of memory of the PM, which can be set in config.
            pm_type (int): The type of the PM.
            region_id (int): The region's id where the PM locates in.
            zone_id (int): The zone's id where the PM locates in.
            data_center_id (int): The data center's id where the PM locates in.
            cluster_id (int): The cluster's id where the PM locates in.
            rack_id (int): The rack's id where the PM locates in.
            oversubscribable (int): The state of the PM:
                                    - non-oversubscribable: -1.
                                    - empty: 0.
                                    - oversubscribable: 1.
        """
        self._id = id
        self._init_cpu_cores_capacity = cpu_cores_capacity
        self._init_memory_capacity = memory_capacity
        self._init_pm_type = pm_type
        self._init_pm_state = oversubscribable

        self._region_id = region_id
        self._zone_id = zone_id
        self._data_center_id = data_center_id
        self._cluster_id = cluster_id
        self._rack_id = rack_id

        self._idle_energy_consumption = idle_energy_consumption

        self.reset()

    def reset(self):
        """Reset to default value.

        Note:
            Since frame reset will reset all the node's attributes to 0, we need to
            call set_init_state to store correct initial value.
        """
        # When we reset frame, all the value will be set to 0, so we need these lines.
        self.id = self._id
        self.cpu_cores_capacity = self._init_cpu_cores_capacity
        self.memory_capacity = self._init_memory_capacity
        self.pm_type = self._init_pm_type
        self.oversubscribable = self._init_pm_state

        self.region_id = self._region_id
        self.zone_id = self._zone_id
        self.data_center_id = self._data_center_id
        self.cluster_id = self._cluster_id
        self.rack_id = self._rack_id

        self._live_vms.clear()

        self.cpu_cores_allocated = 0
        self.memory_allocated = 0

        self.cpu_utilization = 0.0
        self.energy_consumption = self._idle_energy_consumption

    @property
    def live_vms(self) -> Set[int]:
        return self._live_vms

    def allocate_vms(self, vm_ids: List[int]):
        for vm_id in vm_ids:
            self._live_vms.add(vm_id)

    def deallocate_vms(self, vm_ids: List[int]):
        for vm_id in vm_ids:
            self._live_vms.remove(vm_id)
