From fe76ff14e52ec0225d2f9cb36387d379d489ff97 Mon Sep 17 00:00:00 2001 From: Suryansh Gupta Date: Thu, 30 Jan 2025 00:25:47 +0530 Subject: [PATCH] Change to read in batch of 5 --- apps/benchmark_reads.cpp | 11 ++++++----- 1 file changed, 6 insertions(+), 5 deletions(-) diff --git a/apps/benchmark_reads.cpp b/apps/benchmark_reads.cpp index be6280fb0..79c755dd3 100644 --- a/apps/benchmark_reads.cpp +++ b/apps/benchmark_reads.cpp @@ -38,13 +38,14 @@ void do_multiple_reads_with_threads(int thread_count) string file_name = "F:\\indices\\turing_10m\\disk_index_disk.index"; auto reader = new WindowsAlignedFileReader(); reader->open(file_name.c_str()); - int batches_of = 100; + int total_reads = 1000000; + int batches_of = 5; vector buffers(thread_count); - omp_set_num_threads(thread_count); + // omp_set_num_threads(thread_count); -#pragma omp parallel for num_threads((int)thread_count) +// #pragma omp parallel for num_threads((int)thread_count) for (int i = 0; i < thread_count; i++) { char *buf = nullptr; @@ -53,9 +54,9 @@ void do_multiple_reads_with_threads(int thread_count) reader->register_thread(); } - int no_of_reads = 10000; + int no_of_reads = total_reads / batches_of; Timer timer; -#pragma omp parallel for schedule(dynamic, 1) +// #pragma omp parallel for schedule(dynamic, 1) for (int i = 0; i < no_of_reads; i++) { char *buf = buffers[omp_get_thread_num()];