Skip to content

PowerClientIntel ¤

PowerClientIntel()

Bases: PowerLinux

Source code in ea2p/src/intel.py 
15
16
17
18
19
20
def __init__(self):
    super().__init__()
    self.cpu_sub_doms = self.get_cpu_sub_domains()
    self.power_draws = []
    self.record = {}
    self.start_time = None

__get_cpu_domains staticmethod ¤

__get_cpu_domains()

Get CPU domains from entries in POWERLOG_PATH_LINUX.

Returns: - List of tuples containing CPU domain information.

Source code in ea2p/src/power.py 
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
@staticmethod
def __get_cpu_domains():
    """
    Get CPU domains from entries in POWERLOG_PATH_LINUX.

    Returns:
    - List of tuples containing CPU domain information.
    """
    cpu_doms = []
    for entry in os.scandir(POWERLOG_PATH_LINUX):
        if (entry.is_dir() and ("intel-rapl:" in entry.name)):
            dom = (entry.name.split(":"))[1]
            file = Path(READ_RAPL_PATH.format(int(dom))) / RAPL_DEVICENAME_FILE
            cpu_doms.append((int(dom), file.read_text().replace('\n','')))
    return cpu_doms

__get_cpu_ids staticmethod ¤

__get_cpu_ids()

Get CPU identifiers from files in CPU_IDS_DIR.

Returns: - List of CPU identifiers.

Source code in ea2p/src/power.py 
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
@staticmethod
def __get_cpu_ids():
    """
    Get CPU identifiers from files in CPU_IDS_DIR.

    Returns:
    - List of CPU identifiers.
    """
    cpu_ids = []
    for filename in glob.glob(CPU_IDS_DIR):
        with open(filename, "r") as f:
            package_id = int(f.read())
        if package_id not in cpu_ids:
            cpu_ids.append(package_id)
    return cpu_ids

__get_powerlog_file ¤

__get_powerlog_file()

Retrieve the log file where PowerLog logs are written.

Source code in ea2p/src/power.py 
34
35
36
37
def __get_powerlog_file(self):
    """
    Retrieve the log file where PowerLog logs are written.
    """

append_energy_usage ¤

append_energy_usage()

Append CPU energy usage. Returns: Dictionary containing CPU energy usage.

Source code in ea2p/src/intel.py 
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
def append_energy_usage(self):
    """
    Append CPU energy usage.
    Returns:
    	Dictionary containing CPU energy usage.
    """
    energy_usage = {}
    energies = [self.get_cpu_energy_package(cpu_domain, cpu_sub_domain)
            for cpu_domain, cpu_sub_domain, subdom_name in self.cpu_sub_doms]

    energies_2 = [self.get_cpu_energy(dom) for dom, name in self.cpu_doms]
    i = 0
    for cpu_domain, cpu_sub_domain, subdom_name in self.cpu_sub_doms:
        energy_usage[subdom_name] = energies[i] / JOULE_TO_WATT
        i += 1
    i = 0
    for dom, name in self.cpu_doms:
        energy_usage[name] = energies_2[i] / JOULE_TO_WATT
        i += 1

    return energy_usage

get_cpu_energy ¤

get_cpu_energy(cpu)

Get CPU energy usage for a specific CPU.

Parameters:

  • cpu (int) –

    CPU identifier.

Returns: Energy usage for the specified CPU.

Source code in ea2p/src/intel.py 
81
82
83
84
85
86
87
88
89
90
91
92
def get_cpu_energy(self, cpu):
    """
    Get CPU energy usage for a specific CPU.

    Parameters:
    	cpu (int): CPU identifier.
    Returns:
    	Energy usage for the specified CPU.
    """
    cpu_energy_file = Path(READ_RAPL_PATH.format(cpu)) / RAPL_ENERGY_FILE
    energy = int(cpu_energy_file.read_text())
    return energy

get_cpu_energy_package ¤

get_cpu_energy_package(domain, sub_domain)

Get CPU energy usage for a specific sub-domain.

Parameters:

  • domain (int) –

    CPU domain.

  • sub_domain (int) –

    CPU sub-domain.

Returns: Energy usage for the specified CPU sub-domain.

Source code in ea2p/src/intel.py 
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
def get_cpu_energy_package(self, domain, sub_domain):
    """
    Get CPU energy usage for a specific sub-domain.

    Parameters:
    	domain (int): CPU domain.
    	sub_domain (int): CPU sub-domain.
    Returns:
    	Energy usage for the specified CPU sub-domain.
    """
    energy_file = (
        Path(READ_RAPL_PATH.format(domain))
        / (RAPL_PATH_SUB_DOMS.format(domain, sub_domain))
        / RAPL_ENERGY_FILE
    )
    energy = int(energy_file.read_text())
    return energy

get_cpu_sub_domains ¤

get_cpu_sub_domains()

Get the list of CPU sub-domains. Returns: List of tuples containing CPU domain information.

Source code in ea2p/src/intel.py 
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
def get_cpu_sub_domains(self):
    """
    Get the list of CPU sub-domains.
    Returns:
    	List of tuples containing CPU domain information.
    """
    cpu_sub_doms = []
    for dom, name in self.cpu_doms:
        dom_paths = glob.glob(
            READ_RAPL_PATH.format(dom)
            + RAPL_PATH_SUB_DOMS.format(dom, "*")
            + RAPL_DEVICENAME_FILE
        )
        for i, file in enumerate(dom_paths):
            file = Path(file)
            subdom_name = file.read_text().replace('\n','')
            cpu_sub_doms.append((dom, i, subdom_name))
    return cpu_sub_doms

start ¤

start()

Starts the recording process.

Source code in ea2p/src/power.py 
39
40
41
42
def start(self):
    """
    Starts the recording process.
    """

stop ¤

stop()

Stops the recording process.

Source code in ea2p/src/power.py 
51
52
53
54
def stop(self):
    """
    Stops the recording process.
    """

stop_thread ¤

stop_thread()

Stops the recording thread.

Source code in ea2p/src/power.py 
44
45
46
47
48
49
def stop_thread(self):
    """
    Stops the recording thread.
    """
    self.thread.do_run = False
    self.thread.join()

PowerServerIntel ¤

PowerServerIntel()

Bases: PowerLinux

Source code in ea2p/src/intel.py 
 96
 97
 98
 99
100
101
def __init__(self):
    super().__init__()
    self.dram_ids = self.__get_drams_ids()
    self.power_draws = []
    self.record = {}
    self.start_time = None

__get_cpu_domains staticmethod ¤

__get_cpu_domains()

Get CPU domains from entries in POWERLOG_PATH_LINUX.

Returns: - List of tuples containing CPU domain information.

Source code in ea2p/src/power.py 
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
@staticmethod
def __get_cpu_domains():
    """
    Get CPU domains from entries in POWERLOG_PATH_LINUX.

    Returns:
    - List of tuples containing CPU domain information.
    """
    cpu_doms = []
    for entry in os.scandir(POWERLOG_PATH_LINUX):
        if (entry.is_dir() and ("intel-rapl:" in entry.name)):
            dom = (entry.name.split(":"))[1]
            file = Path(READ_RAPL_PATH.format(int(dom))) / RAPL_DEVICENAME_FILE
            cpu_doms.append((int(dom), file.read_text().replace('\n','')))
    return cpu_doms

__get_cpu_energy ¤

__get_cpu_energy(cpu)

Get CPU energy usage for a specific CPU.

Parameters:

  • cpu (int) –

    CPU identifier.

Returns: Energy usage for the specified CPU.

Source code in ea2p/src/intel.py 
134
135
136
137
138
139
140
141
142
143
144
145
def __get_cpu_energy(self, cpu):
    """
    Get CPU energy usage for a specific CPU.

    Parameters:
    	cpu (int): CPU identifier.
    Returns:
    	Energy usage for the specified CPU.
    """
    cpu_energy_file = Path(READ_RAPL_PATH.format(cpu)) / RAPL_ENERGY_FILE
    energy = int(cpu_energy_file.read_text())
    return energy

__get_cpu_ids staticmethod ¤

__get_cpu_ids()

Get CPU identifiers from files in CPU_IDS_DIR.

Returns: - List of CPU identifiers.

Source code in ea2p/src/power.py 
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
@staticmethod
def __get_cpu_ids():
    """
    Get CPU identifiers from files in CPU_IDS_DIR.

    Returns:
    - List of CPU identifiers.
    """
    cpu_ids = []
    for filename in glob.glob(CPU_IDS_DIR):
        with open(filename, "r") as f:
            package_id = int(f.read())
        if package_id not in cpu_ids:
            cpu_ids.append(package_id)
    return cpu_ids

__get_dram_energy ¤

__get_dram_energy(cpu, dram)

Get DRAM energy usage for a specific CPU and DRAM.

Parameters:

  • cpu (int) –

    CPU identifier.

  • dram (int) –

    DRAM identifier.

Returns: Energy usage for the specified DRAM.

Source code in ea2p/src/intel.py 
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
def __get_dram_energy(self, cpu, dram):
    """
    Get DRAM energy usage for a specific CPU and DRAM.

    Parameters:
    	cpu (int): CPU identifier.
    	dram (int): DRAM identifier.
    Returns:
    	Energy usage for the specified DRAM.
    """
    dram_energy_file = (
        Path(READ_RAPL_PATH.format(cpu))
        / (RAPL_DRAM_PATH.format(cpu, dram))
        / RAPL_ENERGY_FILE
    )
    energy = int(dram_energy_file.read_text())
    return energy

__get_drams_ids ¤

__get_drams_ids()

Get the list of DRAM IDs. Returns: List of tuples containing CPU and DRAM IDs.

Source code in ea2p/src/intel.py 
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
def __get_drams_ids(self):
    """
    Get the list of DRAM IDs.
    Returns:
    	List of tuples containing CPU and DRAM IDs.
    """
    dram_id_list = []
    for cpu in self.cpu_ids:
        dram_paths = glob.glob(
            READ_RAPL_PATH.format(cpu)
            + RAPL_DRAM_PATH.format(cpu, "*")
            + RAPL_DEVICENAME_FILE
        )
        for i, dram_file in enumerate(dram_paths):
            dram_file = Path(dram_file)
            if "dram" in dram_file.read_text():
                dram_id_list.append((cpu, i))
                break
    return dram_id_list

__get_powerlog_file ¤

__get_powerlog_file()

Retrieve the log file where PowerLog logs are written.

Source code in ea2p/src/power.py 
34
35
36
37
def __get_powerlog_file(self):
    """
    Retrieve the log file where PowerLog logs are written.
    """

append_energy_usage ¤

append_energy_usage()

Append CPU and memory energy usage. Returns: Dictionary containing CPU and memory energy usage.

Source code in ea2p/src/intel.py 
123
124
125
126
127
128
129
130
131
132
def append_energy_usage(self):
    """
    Append CPU and memory energy usage.
    Returns:
    	Dictionary containing CPU and memory energy usage.
    """
    energy_usage = {}
    energy_usage["energy_cpu"] = sum([self.__get_cpu_energy(cpu_id) for cpu_id in self.cpu_ids]) / JOULE_TO_WATT
    energy_usage["energy_memory"] = sum([self.__get_dram_energy(cpu_id, dram_id) for cpu_id, dram_id in self.dram_ids ]) / JOULE_TO_WATT
    return energy_usage

start ¤

start()

Starts the recording process.

Source code in ea2p/src/power.py 
39
40
41
42
def start(self):
    """
    Starts the recording process.
    """

stop ¤

stop()

Stops the recording process.

Source code in ea2p/src/power.py 
51
52
53
54
def stop(self):
    """
    Stops the recording process.
    """

stop_thread ¤

stop_thread()

Stops the recording thread.

Source code in ea2p/src/power.py 
44
45
46
47
48
49
def stop_thread(self):
    """
    Stops the recording thread.
    """
    self.thread.do_run = False
    self.thread.join()