Lines Matching refs:self
32 def __init__(self, size=None, nr_accesses=None, age=None):
33 self.size = size
34 self.nr_accesses = nr_accesses
35 self.age = age
37 if self.size == None:
38 self.size = [0, 2**64 - 1]
39 if self.nr_accesses == None:
40 self.nr_accesses = [0, 2**64 - 1]
41 if self.age == None:
42 self.age = [0, 2**64 - 1]
44 def sysfs_dir(self):
45 return os.path.join(self.scheme.sysfs_dir(), 'access_pattern')
47 def stage(self):
49 os.path.join(self.sysfs_dir(), 'sz', 'min'), self.size[0])
53 os.path.join(self.sysfs_dir(), 'sz', 'max'), self.size[1])
56 err = write_file(os.path.join(self.sysfs_dir(), 'nr_accesses', 'min'),
57 self.nr_accesses[0])
60 err = write_file(os.path.join(self.sysfs_dir(), 'nr_accesses', 'max'),
61 self.nr_accesses[1])
65 os.path.join(self.sysfs_dir(), 'age', 'min'), self.age[0])
69 os.path.join(self.sysfs_dir(), 'age', 'max'), self.age[1])
79 def __init__(self, sz=0, ms=0, reset_interval_ms=0):
80 self.sz = sz
81 self.ms = ms
82 self.reset_interval_ms = reset_interval_ms
84 def sysfs_dir(self):
85 return os.path.join(self.scheme.sysfs_dir(), 'quotas')
87 def stage(self):
88 err = write_file(os.path.join(self.sysfs_dir(), 'bytes'), self.sz)
91 err = write_file(os.path.join(self.sysfs_dir(), 'ms'), self.ms)
94 err = write_file(os.path.join(self.sysfs_dir(), 'reset_interval_ms'),
95 self.reset_interval_ms)
106 def __init__(self, nr_tried, sz_tried, nr_applied, sz_applied, qt_exceeds):
107 self.nr_tried = nr_tried
108 self.sz_tried = sz_tried
109 self.nr_applied = nr_applied
110 self.sz_applied = sz_applied
111 self.qt_exceeds = qt_exceeds
124 def __init__(self, action='stat', access_pattern=DamosAccessPattern(),
126 self.action = action
127 self.access_pattern = access_pattern
128 self.access_pattern.scheme = self
129 self.quota = quota
130 self.quota.scheme = self
131 self.apply_interval_us = apply_interval_us
133 def sysfs_dir(self):
135 self.context.sysfs_dir(), 'schemes', '%d' % self.idx)
137 def stage(self):
138 err = write_file(os.path.join(self.sysfs_dir(), 'action'), self.action)
141 err = self.access_pattern.stage()
144 err = write_file(os.path.join(self.sysfs_dir(), 'apply_interval_us'),
145 '%d' % self.apply_interval_us)
149 err = self.quota.stage()
155 os.path.join(self.sysfs_dir(), 'watermarks', 'metric'), 'none')
161 os.path.join(self.sysfs_dir(), 'filters', 'nr_filters'), '0')
171 def __init__(self, pid):
172 self.pid = pid
174 def sysfs_dir(self):
176 self.context.sysfs_dir(), 'targets', '%d' % self.idx)
178 def stage(self):
180 os.path.join(self.sysfs_dir(), 'regions', 'nr_regions'), '0')
184 os.path.join(self.sysfs_dir(), 'pid_target'), self.pid)
194 def __init__(self, sample_us=5000, aggr_us=100000, update_us=1000000,
196 self.sample_us = sample_us
197 self.aggr_us = aggr_us
198 self.update_us = update_us
199 self.min_nr_regions = min_nr_regions
200 self.max_nr_regions = max_nr_regions
202 def interval_sysfs_dir(self):
203 return os.path.join(self.context.sysfs_dir(), 'monitoring_attrs',
206 def nr_regions_range_sysfs_dir(self):
207 return os.path.join(self.context.sysfs_dir(), 'monitoring_attrs',
210 def stage(self):
211 err = write_file(os.path.join(self.interval_sysfs_dir(), 'sample_us'),
212 self.sample_us)
215 err = write_file(os.path.join(self.interval_sysfs_dir(), 'aggr_us'),
216 self.aggr_us)
219 err = write_file(os.path.join(self.interval_sysfs_dir(), 'update_us'),
220 self.update_us)
225 os.path.join(self.nr_regions_range_sysfs_dir(), 'min'),
226 self.min_nr_regions)
231 os.path.join(self.nr_regions_range_sysfs_dir(), 'max'),
232 self.max_nr_regions)
244 def __init__(self, ops='paddr', monitoring_attrs=DamonAttrs(), targets=[],
246 self.ops = ops
247 self.monitoring_attrs = monitoring_attrs
248 self.monitoring_attrs.context = self
250 self.targets = targets
251 for idx, target in enumerate(self.targets):
253 target.context = self
255 self.schemes = schemes
256 for idx, scheme in enumerate(self.schemes):
258 scheme.context = self
260 def sysfs_dir(self):
261 return os.path.join(self.kdamond.sysfs_dir(), 'contexts',
262 '%d' % self.idx)
264 def stage(self):
266 os.path.join(self.sysfs_dir(), 'operations'), self.ops)
269 err = self.monitoring_attrs.stage()
274 self.sysfs_dir(), 'targets', 'nr_targets')
278 if int(content) != len(self.targets):
279 err = write_file(nr_targets_file, '%d' % len(self.targets))
282 for target in self.targets:
288 self.sysfs_dir(), 'schemes', 'nr_schemes')
290 if int(content) != len(self.schemes):
291 err = write_file(nr_schemes_file, '%d' % len(self.schemes))
294 for scheme in self.schemes:
307 def __init__(self, contexts=[]):
308 self.contexts = contexts
309 for idx, context in enumerate(self.contexts):
311 context.kdamond = self
313 def sysfs_dir(self):
314 return os.path.join(self.kdamonds.sysfs_dir(), '%d' % self.idx)
316 def start(self):
317 nr_contexts_file = os.path.join(self.sysfs_dir(),
322 if int(content) != len(self.contexts):
323 err = write_file(nr_contexts_file, '%d' % len(self.contexts))
327 for context in self.contexts:
331 err = write_file(os.path.join(self.sysfs_dir(), 'state'), 'on')
334 def update_schemes_tried_bytes(self):
335 err = write_file(os.path.join(self.sysfs_dir(), 'state'),
339 for context in self.contexts:
347 def update_schemes_stats(self):
348 err = write_file(os.path.join(self.sysfs_dir(), 'state'),
352 for context in self.contexts:
367 def __init__(self, kdamonds=[]):
368 self.kdamonds = kdamonds
369 for idx, kdamond in enumerate(self.kdamonds):
371 kdamond.kdamonds = self
373 def sysfs_dir(self):
376 def start(self):
377 err = write_file(os.path.join(self.sysfs_dir(), 'nr_kdamonds'),
378 '%s' % len(self.kdamonds))
381 for kdamond in self.kdamonds: