LEFT | RIGHT |
1 #!/usr/bin/python | 1 #!/usr/bin/python |
2 import argparse | 2 import argparse |
3 import json | 3 import json |
4 import os | 4 import os |
5 import logging | 5 import logging |
6 | 6 |
7 import pytools.experiments.job_generator as jobgen | 7 import pytools.experiments.job_generator as jobgen |
8 from pytools.ycsb.ycsb_runner import generate_sub_exp_folder_based_on_args | 8 from pytools.ycsb.ycsb_runner import generate_sub_exp_folder_based_on_args |
9 from pytools.common.common import print_generic_exception | 9 from pytools.common.common import print_generic_exception |
10 from common.lx3.common import get_config_json | 10 from common.lx3.common import get_config_json |
(...skipping 131 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
142 :param FLAGS: | 142 :param FLAGS: |
143 :param conf: | 143 :param conf: |
144 :return: | 144 :return: |
145 """ | 145 """ |
146 # We need the folders where these outputs are stored | 146 # We need the folders where these outputs are stored |
147 exp_out_folder = os.path.join(conf["env"]["out_exp_dir"], 'exp_outs') | 147 exp_out_folder = os.path.join(conf["env"]["out_exp_dir"], 'exp_outs') |
148 conf['workload_1']['threads'] = 4 # Default | 148 conf['workload_1']['threads'] = 4 # Default |
149 jitter_level_results = [] | 149 jitter_level_results = [] |
150 for jitter_level in conf['multiconf_jitter_levels']: | 150 for jitter_level in conf['multiconf_jitter_levels']: |
151 result_for_jitter = { | 151 result_for_jitter = { |
152 'label': 'thread count', | 152 'label': 'jitter level', |
153 'key': jitter_level, | 153 'key': jitter_level, |
154 'result': None | 154 'result': None |
155 } | 155 } |
156 # Modify jitter level here with value | 156 # Modify jitter level here with value |
157 api.execute_update_jitter( | 157 api.execute_update_jitter( |
158 FLAGS, conf, net, jitter_level, distribution="normal" | 158 FLAGS, conf, net, jitter_level, distribution="normal" |
159 ) | 159 ) |
160 | 160 |
161 output_folder = api.experiment_run(FLAGS, conf, net) | 161 output_folder = api.experiment_run(FLAGS, conf, net) |
162 | 162 |
(...skipping 106 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
269 | 269 |
270 execute_ping_nodes_generate_output(conf=conf, net=net) | 270 execute_ping_nodes_generate_output(conf=conf, net=net) |
271 # start pinging and saving data here (so that we dont have to do it | 271 # start pinging and saving data here (so that we dont have to do it |
272 # again later) | 272 # again later) |
273 | 273 |
274 | 274 |
275 # Here we should execute further changes to testbed and plot | 275 # Here we should execute further changes to testbed and plot |
276 | 276 |
277 api.execute_update_latencies(FLAGS, conf, net, frequency=10) | 277 api.execute_update_latencies(FLAGS, conf, net, frequency=10) |
278 print("Exit") | 278 print("Exit") |
LEFT | RIGHT |