Skip to content

Commit 722285e

Browse files
GioeleB00GioeleB00
authored
Feature/multi processing event loop 3 (#25)
* added metric for server, added logic to collect them + tests * add kpi to collect in settings default * added metric plot for server and tests * Sweep introduction + MM1 heory vs observation + tests * analysis for sweep results + tests * mm1 notebook complete + server latency
1 parent ce37e7c commit 722285e

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

43 files changed

+3191
-93
lines changed

‎asyncflow_queue_limit/asyncflow_mm1_notebook.ipynb‎

Lines changed: 650 additions & 0 deletions
Large diffs are not rendered by default.

‎examples/builder_input/event_injection/lb_two_servers.py‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -37,8 +37,8 @@
3737
from asyncflow.workload import RqsGenerator
3838

3939
# Runner + Analyzer
40-
from asyncflow.metrics.analyzer import ResultsAnalyzer
41-
from asyncflow.runtime.simulation_runner import SimulationRunner
40+
from asyncflow.metrics.simulation_analyzer import ResultsAnalyzer
41+
from asyncflow.runner.simulation import SimulationRunner
4242

4343

4444
def build_and_run() -> ResultsAnalyzer:

‎examples/builder_input/event_injection/single_server.py‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -45,8 +45,8 @@
4545
from asyncflow.workload import RqsGenerator
4646

4747
# Runner + Analyzer
48-
from asyncflow.runtime.simulation_runner import SimulationRunner
49-
from asyncflow.metrics.analyzer import ResultsAnalyzer
48+
from asyncflow.runner.simulation import SimulationRunner
49+
from asyncflow.metrics.simulation_analyzer import ResultsAnalyzer
5050

5151

5252
def build_and_run() -> ResultsAnalyzer:

‎examples/builder_input/load_balancer/two_servers.py‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -51,8 +51,8 @@
5151
from asyncflow.workload import RqsGenerator
5252

5353
# Runner + Analyzer
54-
from asyncflow.runtime.simulation_runner import SimulationRunner
55-
from asyncflow.metrics.analyzer import ResultsAnalyzer
54+
from asyncflow.runner.simulation import SimulationRunner
55+
from asyncflow.metrics.simulation_analyzer import ResultsAnalyzer
5656

5757

5858
def main() -> None:

‎examples/builder_input/single_server/builder_service_plots.png‎

-6.22 KB
Loading

‎examples/builder_input/single_server/single_server.py‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -40,8 +40,8 @@
4040
from asyncflow.workload import RqsGenerator
4141

4242
# Runner + Analyzer
43-
from asyncflow.runtime.simulation_runner import SimulationRunner
44-
from asyncflow.metrics.analyzer import ResultsAnalyzer
43+
from asyncflow.runner.simulation import SimulationRunner
44+
from asyncflow.metrics.simulation_analyzer import ResultsAnalyzer
4545

4646

4747
def build_and_run() -> ResultsAnalyzer:

‎examples/yaml_input/event_injections/heavy_single_server.py‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -19,8 +19,8 @@
1919
import matplotlib.pyplot as plt
2020
import simpy
2121

22-
from asyncflow.metrics.analyzer import ResultsAnalyzer
23-
from asyncflow.runtime.simulation_runner import SimulationRunner
22+
from asyncflow.metrics.simulation_analyzer import ResultsAnalyzer
23+
from asyncflow.runner.simulation import SimulationRunner
2424

2525

2626
def main() -> None:

‎examples/yaml_input/event_injections/lb_two_servers.py‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -15,8 +15,8 @@
1515
import matplotlib.pyplot as plt
1616
import simpy
1717

18-
from asyncflow.metrics.analyzer import ResultsAnalyzer
19-
from asyncflow.runtime.simulation_runner import SimulationRunner
18+
from asyncflow.metrics.simulation_analyzer import ResultsAnalyzer
19+
from asyncflow.runner.simulation import SimulationRunner
2020

2121

2222
def main() -> None:

‎examples/yaml_input/event_injections/single_server.py‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -19,8 +19,8 @@
1919
import matplotlib.pyplot as plt
2020
import simpy
2121

22-
from asyncflow.metrics.analyzer import ResultsAnalyzer
23-
from asyncflow.runtime.simulation_runner import SimulationRunner
22+
from asyncflow.metrics.simulation_analyzer import ResultsAnalyzer
23+
from asyncflow.runner.simulation import SimulationRunner
2424

2525

2626
def main() -> None:

‎examples/yaml_input/load_balancer/two_servers.py‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -23,8 +23,8 @@
2323
import simpy
2424
import matplotlib.pyplot as plt
2525

26-
from asyncflow.runtime.simulation_runner import SimulationRunner
27-
from asyncflow.metrics.analyzer import ResultsAnalyzer
26+
from asyncflow.runner.simulation import SimulationRunner
27+
from asyncflow.metrics.simulation_analyzer import ResultsAnalyzer
2828

2929

3030
def main() -> None:

0 commit comments

Comments
 (0)