From ba1c72cedb56512f52c48ee947a2b11fa8a90c4d Mon Sep 17 00:00:00 2001 From: bd Date: Mon, 8 Sep 2025 13:25:22 -0400 Subject: Perform speedups at coroutine granularity --- nemesis/experiment.py | 14 +++++++------- 1 file changed, 7 insertions(+), 7 deletions(-) (limited to 'nemesis/experiment.py') 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.''' -- cgit v1.2.3