Merge branch 'main' into feature/UpdateDuckdb

Author: whzruc

run_benchmark_simple.py

@@ -9,6 +9,7 @@ def clean_page_cache():
     Clean the system page cache using the sync command and writing to /proc/sys/vm/drop_caches
     Requires root privileges (sudo) to execute successfully
     """
+
     cmd = "sudo bash -c \"sync; echo 3 > /proc/sys/vm/drop_caches\""
     if verbose:
         print(cmd)
@@ -23,25 +24,31 @@ def run_benchmark(benchmark_path, draw=0):
         draw (int): Flag to enable result plotting (1 = enable, 0 = disable)
     """
     # Verify the provided path is a valid directory
+
     if not os.path.isdir(benchmark_path):
-        print(f"Error: {benchmark_path} is not a valid directory")
+        print(f"错误: {benchmark_path} 不是一个有效的目录")
         return
 
+
     # Get last two parts of the path to use as output filename
+
     path_parts = os.path.normpath(benchmark_path).split(os.sep)
     output_name = f"{path_parts[-2]}_{path_parts[-1]}"
     output_csv = "output/"+f"{output_name}.csv"
 
     results = []
 
+
     # Traverse through all files in the directory
     for root, dirs, files in os.walk(benchmark_path):
         # Sort files ending with .benchmark by numeric part in filename
+
         files = sorted([file for file in files if file.endswith('.benchmark')],
                        key=lambda x: int(x[1:3]))
         print(files)
         for file in files:
             if file.endswith('.benchmark'):
+
                 # Construct full file path
                 benchmark_file = os.path.join(root, file)
 
@@ -53,14 +60,17 @@ def run_benchmark(benchmark_path, draw=0):
                         print(cmd)
                     output = subprocess.getoutput(cmd)
 
+
                     # Collect all run results
+
                     run_times = []
                     print(output)
                     for line in output.splitlines():
                         if line.startswith('Result:'):
                             time = float(line.split()[1])
                             run_times.append(time)
                             if verbose:
+
                                 print(f"File {file} runtime: {time}")
 
                     # Save all run times if results exist
@@ -72,8 +82,10 @@ def run_benchmark(benchmark_path, draw=0):
                     else:
                         if verbose:
                             print(f"No results found for file {file}")
+
                 except Exception as e:
-                    print(f"Error running {benchmark_file}: {e}")
+                    print(f"运行 {benchmark_file} 时出错: {e}")
+
 
     # Save results to CSV file
     with open(output_csv, 'w', newline='') as csvfile:
@@ -86,16 +98,20 @@ def run_benchmark(benchmark_path, draw=0):
         # Write all run results for each benchmark
         for file, times in results:
             # Ensure consistent column count per row
+
             row = [file] + times + [''] * (max_runs - len(times))
             writer.writerow(row)
 
-    print(f"Results saved to {output_csv}")
+    print(f"结果已保存到 {output_csv}")
+
 
     # Generate plot if requested
+
     if draw:
         plot_results(output_name, results)
 
 def plot_results(title, results):
+
     """
     Generate a bar chart from benchmark results showing average run times
 
@@ -118,14 +134,17 @@ def plot_results(title, results):
     plt.tight_layout()
     plt.savefig("output/"+f"{title}.png")
     plt.show()
+
     print(f"Chart saved as {title}.png")
 
+
 if __name__ == "__main__":
     # Global variables for configuration
     global pixels_home
     global verbose
     global nRuns
 
+
     # Get PIXELS_SRC environment variable
     pixels_home = os.environ.get('PIXELS_SRC')
     current_dir = os.getcwd()
@@ -151,8 +170,11 @@ def plot_results(title, results):
 
 
     # Clean page cache if not reading from cache
+
     if not from_page_cache:
         clean_page_cache()
 
     # Run benchmarks with provided arguments
     run_benchmark(args.dir, args.draw)
+
+