summaryrefslogtreecommitdiff
path: root/nemesis/experiment.py
diff options
context:
space:
mode:
Diffstat (limited to 'nemesis/experiment.py')
-rw-r--r--nemesis/experiment.py14
1 files changed, 7 insertions, 7 deletions
diff --git a/nemesis/experiment.py b/nemesis/experiment.py
index 87a0103..9d179ea 100644
--- a/nemesis/experiment.py
+++ b/nemesis/experiment.py
@@ -10,7 +10,7 @@ class BadLoopTypeException(Exception):
class Experiment:
# the selected task for this experiment
- _task = None
+ _coro = None
# the selected speedup for this experiment
_speedup = None
# event loops participating in this this experiment
@@ -19,21 +19,21 @@ class Experiment:
# represent number of times sampled.
_samples = None
- def __init__(self, task, speedup):
- self._task = task
+ def __init__(self, coro, speedup):
+ self._coro = coro
self._speedup = speedup
self._samples = defaultdict(lambda: 0)
self._set_loops()
- def get_task(self):
- return self._task
+ def get_coro(self):
+ return self._coro
def get_speedup(self):
return self._speedup
def get_results(self):
- ret = f"Results for {self._task} at {self._speedup} times speedup:\n"
+ ret = f"Results for {self._coro} at {self._speedup} times speedup:\n"
if len(self._samples) > 0:
ret += (f" {'HANDLE':<30} {'LOOP':<10} {'SEC':<10}")
for key in self._sort_samples(self._samples):
@@ -54,7 +54,7 @@ class Experiment:
for l in self._loops:
if not isinstance(l, CausalEventLoop):
raise BadLoopTypeException("Nemesis requires a custom event loop to insert slowdowns. It does not work on programs which change the event loop policy.")
- l._set_experiment(self._task, 1.0 / self._speedup)
+ l._set_dilation(1.0 / self._speedup)
def _get_event_loops(self):
'''Returns each thread's event loop, if it exists.'''