ops_filters = None
filters = None
apply_interval_us = None
+ target_nid = None
dests = None
idx = None
context = None
def __init__(self, action='stat', access_pattern=DamosAccessPattern(),
quota=DamosQuota(), watermarks=DamosWatermarks(),
- core_filters=[], ops_filters=[], filters=[],
+ core_filters=[], ops_filters=[], filters=[], target_nid=0,
dests=DamosDests(), apply_interval_us=0):
self.action = action
self.access_pattern = access_pattern
self.filters = DamosFilters(name='filters', filters=filters)
self.filters.scheme = self
+ self.target_nid = target_nid
self.dests = dests
self.dests.scheme = self
if err is not None:
return err
+ err = write_file(os.path.join(self.sysfs_dir(), 'target_nid'), '%d' %
+ self.target_nid)
+ if err is not None:
+ return err
+
err = self.dests.stage()
if err is not None:
return err