Rietveld Code Review Tool
Help | Bug tracker | Discussion group | Source code | Sign in
(907)

Unified Diff: ycsb/ycsb_post_processing.py

Issue 321640043: ongoing changes for review
Patch Set: Created 6 years, 6 months ago
Use n/p to move between diff chunks; N/P to move between comments. Please Sign in to add in-line comments.
Jump to:
View side-by-side diff with in-line comments
Download patch
« no previous file with comments | « ycsb/ycsb.py ('k') | ycsb/ycsb_results_aggregator_lvl1.py » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
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 """
« no previous file with comments | « ycsb/ycsb.py ('k') | ycsb/ycsb_results_aggregator_lvl1.py » ('j') | no next file with comments »

Powered by Google App Engine
RSS Feeds Recent Issues | This issue
This is Rietveld f62528b