diff options
Diffstat (limited to 'TestUnits/cli/volume/top/testcases.py')
| -rw-r--r-- | TestUnits/cli/volume/top/testcases.py | 243 |
1 files changed, 155 insertions, 88 deletions
diff --git a/TestUnits/cli/volume/top/testcases.py b/TestUnits/cli/volume/top/testcases.py index 182f29d..5fea54c 100644 --- a/TestUnits/cli/volume/top/testcases.py +++ b/TestUnits/cli/volume/top/testcases.py @@ -11,9 +11,11 @@ import atfutils volume_top_usage = "Usage: volume top <VOLNAME> {[open|read|write|opendir|readdir] |[read-perf|write-perf bs <size> count <count>]} [brick <brick>] [list-cnt <count>]" def reset_testenv(): - return_status = 1 - if clientutils.umountall(): - return return_status + output = clientutils.umountall() + assert_success_status = atfutils.assert_success(output["exitstatus"]) + if assert_success_status is not 0: + return assert_success_status + glusterutils.volume_stop("server1", force=True) glusterutils.volume_delete("server1") glusterutils.glusterd_stop_allservers() @@ -24,146 +26,217 @@ def reset_testenv(): def setup_testenv(): """ """ - return_status = 1 - if glusterutils.glusterd_start_allservers(force=True): - return return_status - if glusterutils.peer_probe("server1"): - return return_status - if glusterutils.create_brick_allservers(): - return return_status - if glusterutils.volume_create("server1"): - return return_status - if glusterutils.volume_start("server1"): - return return_status - if clientutils.mount("mount1"): - return return_status - return 0 + output = glusterutils.glusterd_start_allservers(force=True) + assert_success_status = atfutils.assert_success(output["exitstatus"]) + if assert_success_status is not 0: + return assert_success_status + + output = glusterutils.peer_probe("server1") + assert_success_status = atfutils.assert_success(output["exitstatus"]) + if assert_success_status is not 0: + return assert_success_status + + output = glusterutils.create_brick_allservers() + assert_success_status = atfutils.assert_success(output["exitstatus"]) + if assert_success_status is not 0: + return assert_success_status + + output = glusterutils.volume_create("server1") + assert_success_status = atfutils.assert_success(output["exitstatus"]) + if assert_success_status is not 0: + return assert_success_status + + output = glusterutils.volume_start("server1") + assert_success_status = atfutils.assert_success(output["exitstatus"]) + if assert_success_status is not 0: + return assert_success_status + + output = clientutils.mount("mount1") + assert_success_status = atfutils.assert_success(output["exitstatus"]) + if assert_success_status is not 0: + return assert_success_status -def validate_output(output, expected_exit_status, expected_output): - """ - """ - if expected_exit_status is 1: - exit_status = atfutils.assert_failure(output['exitstatus']) - else: - exit_status = atfutils.assert_success(output['exitstatus']) - - output_status = atfutils.expect(str(output['stdoutdata']), - expected_output) - if output_status is True and (not exit_status): - return 0 - else: - return 1 + return 0 def bug2645a(): """ """ - command = "gluster volume top <volume1.volumename> write-perf bs 0 count 100" + operation = "write-perf bs 0 count 100" expected_output = "block size should be an integer greater than zero" - expected_exit_status = 1 - output = hostutils.execute_command("server1", command) - return validate_output(output, expected_exit_status, expected_output) + expected_exit_status = 1 + output = glusterutils.volume_top("server1", operation) + return_status = atfutils.validate_output(output, expected_exit_status, + expected_output) + if return_status is not 0: + return return_status + + return 0 def bug2645b(): """ """ - command = "gluster volume top <volume1.volumename> write-perf bs 1024 count 0" + operation = "write-perf bs 1024 count 0" expected_output = "count should be an integer greater than zero" expected_exit_status = 1 - output = hostutils.execute_command("server1", command) - return validate_output(output, expected_exit_status, expected_output) + output = glusterutils.volume_top("server1", operation) + return_status = atfutils.validate_output(output, expected_exit_status, + expected_output) + if return_status is not 0: + return return_status + + return 0 def bug2645c(): """ """ - command = "gluster volume top <volume1.volumename> write-perf bs 1024 count 100" + operation = "write-perf bs 1024 count 100" expected_output = "" expected_exit_status = 0 - output = hostutils.execute_command("server1", command) - return validate_output(output, expected_exit_status, expected_output) + output = glusterutils.volume_top("server1", operation) + return_status = atfutils.validate_output(output, expected_exit_status, + expected_output) + if return_status is not 0: + return return_status + + return 0 def bug2771a(): """ """ - command = "gluster volume top <volume1.volumename> write-perf list-cnt 10 brick <brick1.hostname>:<brick1.path> bs 2048" + operation = "write-perf bs 2048" expected_output = volume_top_usage expected_exit_status = 1 - output = hostutils.execute_command("server1", command) - return validate_output(output, expected_exit_status, expected_output) + output = glusterutils.volume_top("server1", operation, brick="brick1", + list_cnt="10") + return_status = atfutils.validate_output(output, expected_exit_status, + expected_output) + if return_status is not 0: + return return_status + + return 0 def bug2771b(): """ """ - command = "gluster volume top <volume1.volumename> read-perf list-cnt 99 bs 37 brick <brick1.hostname>:<brick1.path>" + operation = "read-perf bs 37" expected_output = volume_top_usage expected_exit_status = 1 - output = hostutils.execute_command("server1", command) - return validate_output(output, expected_exit_status, expected_output) + output = glusterutils.volume_top("server1", operation, brick="brick1", + list_cnt="99") + return_status = atfutils.validate_output(output, expected_exit_status, + expected_output) + if return_status is not 0: + return return_status + + return 0 def bug2771c(): """ """ - command = "gluster volume top <volume1.volumename> read-perf list-cnt 99 bs 37 brick <brick1.hostname>:<brick1.path> bs 1024" + operation = "read-perf bs 37 bs 1024" expected_output = volume_top_usage expected_exit_status = 1 - output = hostutils.execute_command("server1", command) - return validate_output(output, expected_exit_status, expected_output) + output = glusterutils.volume_top("server1", operation, brick="brick1", + list_cnt="99") + return_status = atfutils.validate_output(output, expected_exit_status, + expected_output) + if return_status is not 0: + return return_status + + return 0 def bug2771d(): """ """ - command = "gluster volume top <volume1.volumename> read-perf list-cnt 99 count 37 brick <brick1.hostname>:<brick1.path> count 10" + operation = "read-perf count 37 count 10" expected_output = volume_top_usage expected_exit_status = 1 - output = hostutils.execute_command("server1", command) - return validate_output(output, expected_exit_status, expected_output) + output = glusterutils.volume_top("server1", operation, brick="brick1", + list_cnt="99") + return_status = atfutils.validate_output(output, expected_exit_status, + expected_output) + if return_status is not 0: + return return_status + + return 0 def bug2771e(): - command = "gluster volume top <volume1.volumename> read-perf bs 1024 count 37 brick <brick1.hostname>:<brick1.path> list-cnt 10" + operation = "read-perf bs 1024 count 37" expected_output = "" expected_exit_status = 0 - output = hostutils.execute_command("server1", command) - return validate_output(output, expected_exit_status, expected_output) + output = glusterutils.volume_top("server1", operation, brick="brick1", + list_cnt="10") + return_status = atfutils.validate_output(output, expected_exit_status, + expected_output) + if return_status is not 0: + return return_status + + return 0 def bug2771f(): """ """ - command = "gluster volume top <volume1.volumename> read-perf list-cnt 10 count 37 brick <brick1.hostname>:<brick1.path> bs 1024" + operation = "read-perf count 37 bs 1024" expected_output = "" expected_exit_status = 0 - output = hostutils.execute_command("server1", command) - return validate_output(output, expected_exit_status, expected_output) + + output = glusterutils.volume_top("server1", operation, brick="brick1", + list_cnt="10") + return_status = atfutils.validate_output(output, expected_exit_status, + expected_output) + if return_status is not 0: + return return_status + + return 0 def bug2725a(): """ """ + testcase_failed = False dir_name = 'a' for i in range(1, 255): dir_name += 'a' - pass commands = [] commands.append("echo 'Hello World' > " + dir_name) commands.append("find . | xargs touch") for command in commands: output = clientutils.execute_on_mount("mount1", command) - if output["exitstatus"]: - return 1 + assert_success_status = atfutils.assert_success(output["exitstatus"]) + if assert_success_status is not 0: + return assert_success_status - command = "gluster volume top <volume1.volumename> open" + operation = "write-perf bs 2048 count 1000" expected_output = "" expected_exit_status = 0 - output = hostutils.execute_command("server1", command) - return validate_output(output, expected_exit_status, expected_output) + output = glusterutils.volume_top("server1", operation, list_cnt="100") + return_status = atfutils.validate_output(output, expected_exit_status, + expected_output) + if return_status is not 0: + return return_status + + operations = ['open', 'read', 'write'] + for operation in operations: + output = glusterutils.volume_top("server1", operation) + return_status = atfutils.validate_output(output, expected_exit_status, + expected_output) + if return_status is not 0: + testcase_failed = True + + if testcase_failed is True: + return 1 + else: + return 0 def bug2725b(): """ @@ -172,40 +245,34 @@ def bug2725b(): dir_name = 'a' for i in range(1, 255): dir_name += 'a' - pass commands = [] commands.append("echo 'Hello World' > " + dir_name) commands.append("find . | xargs touch") for command in commands: output = clientutils.execute_on_mount("mount1", command) - if output["exitstatus"]: - return 1 + assert_success_status = atfutils.assert_success(output["exitstatus"]) + if assert_success_status is not 0: + return assert_success_status - commands = [] - commands.append("gluster volume top <volume1.volumename> open") - commands.append("gluster volume top <volume1.volumename> read") - commands.append("gluster volume top <volume1.volumename> write-perf bs 2048 count 1000 list-cnt 100") + operation = "write-perf bs 2048 count 1000" expected_output = "Unable to decode response" expected_exit_status = 1 - for command in commands: - output = hostutils.execute_command("server1", command) - return_status = validate_output(output, expected_exit_status, expected_output) - if return_status: + output = glusterutils.volume_top("server1", operation, list_cnt="100") + return_status = atfutils.validate_output(output, expected_exit_status, + expected_output) + if return_status is not 0: + return return_status + + operations = ['open', 'read', 'write'] + for operation in operations: + output = glusterutils.volume_top("server1", operation) + return_status = atfutils.validate_output(output, expected_exit_status, + expected_output) + if return_status is not 0: testcase_failed = True - if testcase_failed: + if testcase_failed is True: return 1 else: return 0 - - - - - - - - - - - |