Index: ycsb/ycsb_post_processing.py |
diff --git a/ycsb/ycsb_post_processing.py b/ycsb/ycsb_post_processing.py |
index 9f1b285ddf82b4329bd41a697274655471591af5..961df68357369c4bf81d91d7286be46590d752d8 100644 |
--- a/ycsb/ycsb_post_processing.py |
+++ b/ycsb/ycsb_post_processing.py |
@@ -116,6 +116,65 @@ def postproc_model_logs(out_fldr): |
os.chdir(old_dir) |
+ |
+def postproc_rates_plot_variance(out_fldr): |
+ |
+ fname = sys._getframe().f_code.co_name |
+ separator(fname) |
+ |
+ old_dir = os.getcwd() |
+ os.chdir(out_fldr) |
+ |
+ try: |
+ rate_log_files = get_files_matching_mask(where="./", mask="*_rate*.log") |
+ |
+ cmd = "post_rate_plot_variance.py --src_files {files}".format( |
+ files=" ".join(rate_log_files)) |
+ |
+ logging.info("Executing [%s] \n cmd[%s]", fname, cmd) |
+ proc = subprocess.Popen(cmd, |
+ stdout=subprocess.PIPE, stderr=subprocess.PIPE, shell=True) |
+ check_pid_output(proc) |
+ |
+ except: |
+ print_generic_exception() |
+ |
+ finally: |
+ os.chdir(old_dir) |
+ |
+ |
+def postproc_rates_plot_redirected_requests(out_fldr): |
+ |
+ fname = sys._getframe().f_code.co_name |
+ separator(fname) |
+ |
+ old_dir = os.getcwd() |
+ os.chdir(out_fldr) |
+ |
+ try: |
+ |
+ rate_log_files = get_files_matching_mask(where="./", mask="*_rate*.log") |
+ |
+ cmd = "post_rate_plot_redirected_requests.py --src_files {files}".format( |
+ files=" ".join(rate_log_files)) |
+ |
+ logging.info("Executing [%s] \n cmd[%s]", fname, cmd) |
+ proc = subprocess.Popen(cmd, |
+ stdout=subprocess.PIPE, stderr=subprocess.PIPE, shell=True) |
+ check_pid_output(proc) |
+ |
+ |
+ except: |
+ print_generic_exception() |
+ |
+ finally: |
+ os.chdir(old_dir) |
+ |
+ |
+ |
+ |
+ |
+ |
def postproc_plot_all_individual_cdfs(out_fldr, target_slo_us, minutes2skip_from_ycsb_trace): |
""" This function searches for ycsb files in the target directory and plots a one .png |
file per one .ycsb file """ |