summaryrefslogtreecommitdiffstats
path: root/glustolibs-io/shared_files/scripts/generate_io.py
diff options
context:
space:
mode:
Diffstat (limited to 'glustolibs-io/shared_files/scripts/generate_io.py')
-rwxr-xr-x[-rw-r--r--]glustolibs-io/shared_files/scripts/generate_io.py30
1 files changed, 15 insertions, 15 deletions
diff --git a/glustolibs-io/shared_files/scripts/generate_io.py b/glustolibs-io/shared_files/scripts/generate_io.py
index c9836ba..d07bda7 100644..100755
--- a/glustolibs-io/shared_files/scripts/generate_io.py
+++ b/glustolibs-io/shared_files/scripts/generate_io.py
@@ -275,21 +275,21 @@ def start_populate_data(mount_point, io_dict,
proc_queue = []
for each_io in io_dict.keys():
- q = multiprocessing.Queue()
- proc_queue.append(q)
- workload_type = io_dict[each_io]['workload_type']
- proc = multiprocessing.Process(target=(io_dict[each_io]
- ['function_addr']),
- args=(q,
- (io_dict[each_io]
- ['script_path']),
- dirname,
- (io_dict[each_io]['job_files']
- [workload_type]),
- io_dict[each_io]['log_file']))
- proc_list.append(proc)
- time.sleep(5)
- proc.start()
+ q = multiprocessing.Queue()
+ proc_queue.append(q)
+ workload_type = io_dict[each_io]['workload_type']
+ proc = multiprocessing.Process(target=(io_dict[each_io]
+ ['function_addr']),
+ args=(q,
+ (io_dict[each_io]
+ ['script_path']),
+ dirname,
+ (io_dict[each_io]['job_files']
+ [workload_type]),
+ io_dict[each_io]['log_file']))
+ proc_list.append(proc)
+ time.sleep(5)
+ proc.start()
p = multiprocessing.Process(
target=run_check_if_percent_to_fill_or_timeout_is_met,