32     def __init__(self, size=None, nr_accesses=None, age=None):  argument
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):  argument
45         return os.path.join(self.scheme.sysfs_dir(), 'access_pattern')
47     def stage(self):  argument
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])
81     def __init__(self, action='stat', access_pattern=DamosAccessPattern()):  argument
82         self.action = action
83         self.access_pattern = access_pattern
84         self.access_pattern.scheme = self
86     def sysfs_dir(self):  argument
88                 self.context.sysfs_dir(), 'schemes', '%d' % self.idx)
90     def stage(self):  argument
91         err = write_file(os.path.join(self.sysfs_dir(), 'action'), self.action)
94         err = self.access_pattern.stage()
99         err = write_file(os.path.join(self.sysfs_dir(), 'quotas', 'ms'), '0')
103                 os.path.join(self.sysfs_dir(), 'quotas', 'bytes'), '0')
109                 os.path.join(self.sysfs_dir(), 'watermarks', 'metric'), 'none')
115                 os.path.join(self.sysfs_dir(), 'filters', 'nr_filters'), '0')
125     def __init__(self, pid):  argument
126         self.pid = pid
128     def sysfs_dir(self):  argument
130                 self.context.sysfs_dir(), 'targets', '%d' % self.idx)
132     def stage(self):  argument
134                 os.path.join(self.sysfs_dir(), 'regions', 'nr_regions'), '0')
138                 os.path.join(self.sysfs_dir(), 'pid_target'), self.pid)
148     def __init__(self, sample_us=5000, aggr_us=100000, update_us=1000000,  argument
150         self.sample_us = sample_us
151         self.aggr_us = aggr_us
152         self.update_us = update_us
153         self.min_nr_regions = min_nr_regions
154         self.max_nr_regions = max_nr_regions
156     def interval_sysfs_dir(self):  argument
157         return os.path.join(self.context.sysfs_dir(), 'monitoring_attrs',
160     def nr_regions_range_sysfs_dir(self):  argument
161         return os.path.join(self.context.sysfs_dir(), 'monitoring_attrs',
164     def stage(self):  argument
165         err = write_file(os.path.join(self.interval_sysfs_dir(), 'sample_us'),
166                 self.sample_us)
169         err = write_file(os.path.join(self.interval_sysfs_dir(), 'aggr_us'),
170                 self.aggr_us)
173         err = write_file(os.path.join(self.interval_sysfs_dir(), 'update_us'),
174                 self.update_us)
179                 os.path.join(self.nr_regions_range_sysfs_dir(), 'min'),
180                 self.min_nr_regions)
185                 os.path.join(self.nr_regions_range_sysfs_dir(), 'max'),
186                 self.max_nr_regions)
198     def __init__(self, ops='paddr', monitoring_attrs=DamonAttrs(), targets=[],  argument
200         self.ops = ops
201         self.monitoring_attrs = monitoring_attrs
202         self.monitoring_attrs.context = self
204         self.targets = targets
205         for idx, target in enumerate(self.targets):
207             target.context = self
209         self.schemes = schemes
210         for idx, scheme in enumerate(self.schemes):
212             scheme.context = self
214     def sysfs_dir(self):  argument
215         return os.path.join(self.kdamond.sysfs_dir(), 'contexts',
216                 '%d' % self.idx)
218     def stage(self):  argument
220                 os.path.join(self.sysfs_dir(), 'operations'), self.ops)
223         err = self.monitoring_attrs.stage()
228                 self.sysfs_dir(), 'targets', 'nr_targets')
232         if int(content) != len(self.targets):
233             err = write_file(nr_targets_file, '%d' % len(self.targets))
236         for target in self.targets:
242                 self.sysfs_dir(), 'schemes', 'nr_schemes')
244         if int(content) != len(self.schemes):
245             err = write_file(nr_schemes_file, '%d' % len(self.schemes))
248         for scheme in self.schemes:
261     def __init__(self, contexts=[]):  argument
262         self.contexts = contexts
263         for idx, context in enumerate(self.contexts):
265             context.kdamond = self
267     def sysfs_dir(self):  argument
268         return os.path.join(self.kdamonds.sysfs_dir(), '%d' % self.idx)
270     def start(self):  argument
271         nr_contexts_file = os.path.join(self.sysfs_dir(),
276         if int(content) != len(self.contexts):
277             err = write_file(nr_contexts_file, '%d' % len(self.contexts))
281         for context in self.contexts:
285         err = write_file(os.path.join(self.sysfs_dir(), 'state'), 'on')
288     def update_schemes_tried_bytes(self):  argument
289         err = write_file(os.path.join(self.sysfs_dir(), 'state'),
293         for context in self.contexts:
304     def __init__(self, kdamonds=[]):  argument
305         self.kdamonds = kdamonds
306         for idx, kdamond in enumerate(self.kdamonds):
308             kdamond.kdamonds = self
310     def sysfs_dir(self):  argument
313     def start(self):  argument
314         err = write_file(os.path.join(self.sysfs_dir(),  'nr_kdamonds'),
315                 '%s' % len(self.kdamonds))
318         for kdamond in self.kdamonds: