FilesExpand file tree

 master

/

cpufreq.chart.py

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

113 lines (88 loc) · 3.75 KB

 master

/

cpufreq.chart.py

Copy path

Top

File metadata and controls

• Code
• Blame

113 lines (88 loc) · 3.75 KB

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

44

45

46

47

48

49

50

51

52

53

54

55

56

57

58

59

60

61

62

63

64

65

66

67

68

69

70

71

72

73

74

75

76

77

78

79

80

81

82

83

84

85

86

87

88

89

90

91

92

93

94

95

96

97

98

99

100

101

102

103

104

105

106

107

108

109

110

111

112

# -*- coding: utf-8 -*-

# Description: cpufreq netdata python.d module

# Author: Pawel Krupa (paulfantom) and Steven Noonan (tycho)

import glob

import os

from bases.FrameworkServices.SimpleService import SimpleService

# default module values (can be overridden per job in `config`)

# update_every = 2

ORDER = ['cpufreq']

CHARTS = {

'cpufreq': {

'options': [None, 'CPU Clock', 'MHz', 'cpufreq', 'cpufreq.cpufreq', 'line'],

'lines': [

# lines are created dynamically in `check()` method

]}

}

class Service(SimpleService):

def __init__(self, configuration=None, name=None):

prefix = os.getenv('NETDATA_HOST_PREFIX', "")

if prefix.endswith('/'):

prefix = prefix[:-1]

self.sys_dir = prefix + "/sys/devices"

SimpleService.__init__(self, configuration=configuration, name=name)

self.order = ORDER

self.definitions = CHARTS

self.fake_name = 'cpu'

self.assignment = {}

self.accurate_exists = True

self.accurate_last = {}

def _get_data(self):

data = {}

if self.accurate_exists:

accurate_ok = True

for name, paths in self.assignment.items():

last = self.accurate_last[name]

current = {}

deltas = {}

ticks_since_last = 0

for line in open(paths['accurate'], 'r'):

line = list(map(int, line.split()))

current[line[0]] = line[1]

ticks = line[1] - last.get(line[0], 0)

ticks_since_last += ticks

deltas[line[0]] = line[1] - last.get(line[0], 0)

avg_freq = 0

if ticks_since_last != 0:

for frequency, ticks in deltas.items():

avg_freq += frequency * ticks

avg_freq /= ticks_since_last

data[name] = avg_freq

self.accurate_last[name] = current

if avg_freq == 0 or ticks_since_last == 0:

# Delta is either too large or nonexistent, fall back to

# less accurate reading. This can happen if we switch

# to/from the 'schedutil' governor, which doesn't report

# stats.

accurate_ok = False

if accurate_ok:

return data

for name, paths in self.assignment.items():

data[name] = open(paths['inaccurate'], 'r').read()

return data

def check(self):

try:

self.sys_dir = str(self.configuration['sys_dir'])

except (KeyError, TypeError):

self.error("No path specified. Using: '" + self.sys_dir + "'")

for path in glob.glob(self.sys_dir + '/system/cpu/cpu*/cpufreq/stats/time_in_state'):

path_elem = path.split('/')

cpu = path_elem[-4]

if cpu not in self.assignment:

self.assignment[cpu] = {}

self.assignment[cpu]['accurate'] = path

self.accurate_last[cpu] = {}

if len(self.assignment) == 0:

self.accurate_exists = False

for path in glob.glob(self.sys_dir + '/system/cpu/cpu*/cpufreq/scaling_cur_freq'):

path_elem = path.split('/')

cpu = path_elem[-3]

if cpu not in self.assignment:

self.assignment[cpu] = {}

self.assignment[cpu]['inaccurate'] = path

if len(self.assignment) == 0:

self.error("couldn't find a method to read cpufreq statistics")

return False

for name in sorted(self.assignment, key=lambda v: int(v[3:])):

self.definitions[ORDER[0]]['lines'].append([name, name, 'absolute', 1, 1000])

return True