diff options
Diffstat (limited to 'glustolibs-io/shared_files')
| -rwxr-xr-x | glustolibs-io/shared_files/scripts/fd_writes.py | 2 | ||||
| -rwxr-xr-x | glustolibs-io/shared_files/scripts/file_dir_ops.py | 2 | ||||
| -rwxr-xr-x[-rw-r--r--] | glustolibs-io/shared_files/scripts/generate_io.py | 30 |
3 files changed, 17 insertions, 17 deletions
diff --git a/glustolibs-io/shared_files/scripts/fd_writes.py b/glustolibs-io/shared_files/scripts/fd_writes.py index 0911c3f11..87358f45a 100755 --- a/glustolibs-io/shared_files/scripts/fd_writes.py +++ b/glustolibs-io/shared_files/scripts/fd_writes.py @@ -34,7 +34,7 @@ def is_root(path): Returns: True if path is '/' , False otherwise """ - if os.path.realpath(os.path.abspath(path)) is '/': + if os.path.realpath(os.path.abspath(path)) == '/': print ("Directory '%s' is the root of filesystem. " "Not performing any operations on the root of filesystem" % os.path.abspath(path)) diff --git a/glustolibs-io/shared_files/scripts/file_dir_ops.py b/glustolibs-io/shared_files/scripts/file_dir_ops.py index 2ea6a96ab..96e53262d 100755 --- a/glustolibs-io/shared_files/scripts/file_dir_ops.py +++ b/glustolibs-io/shared_files/scripts/file_dir_ops.py @@ -48,7 +48,7 @@ def is_root(path): Returns: True if path is '/' , False otherwise """ - if os.path.realpath(os.path.abspath(path)) is '/': + if os.path.realpath(os.path.abspath(path)) == '/': print ("Directory '%s' is the root of filesystem. " "Not performing any operations on the root of filesystem" % os.path.abspath(path)) diff --git a/glustolibs-io/shared_files/scripts/generate_io.py b/glustolibs-io/shared_files/scripts/generate_io.py index c9836ba80..d07bda7b0 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, |