From c51fef3f5cbda81b222a63c7daac2a7722555abf Mon Sep 17 00:00:00 2001 From: lykos98 <francy273998@gmail.com> Date: Wed, 22 Jan 2025 12:37:07 +0100 Subject: [PATCH] removed OUT_HALO --- src/main/main.c | 19 +++++++------------ 1 file changed, 7 insertions(+), 12 deletions(-) diff --git a/src/main/main.c b/src/main/main.c index eb75a32..c17df28 100644 --- a/src/main/main.c +++ b/src/main/main.c @@ -4,6 +4,7 @@ #include "../common/common.h" #include "../tree/tree.h" #include "../adp/adp.h" +#include <argp.h> #ifdef AMONRA @@ -15,33 +16,26 @@ #ifdef LEONARDO #define OUT_CLUSTER_ASSIGN "/leonardo_scratch/large/userexternal/ftomba00/out_dadp/final_assignment.npy" - #define OUT_HALO_FLAGS "/leonardo_scratch/large/userexternal/ftomba00/out_dadp/halo_flags.npy" #define OUT_DATA "/leonardo_scratch/large/userexternal/ftomba00/out_dadp/ordered_data.npy" #endif #ifdef LUMI #define OUT_CLUSTER_ASSIGN "~/scratch_dadp/out_dadp/final_assignment.npy" - #define OUT_HALO_FLAGS "~/scratch_dadp/out_dadp/halo_flags.npy" #define OUT_DATA "~/scratch_dadp/out_dadp/ordered_data.npy" #endif #ifndef OUT_CLUSTER_ASSIGN #define OUT_CLUSTER_ASSIGN "final_assignment.npy" - #define OUT_HALO_FLAGS "halo_flags.npy" #define OUT_DATA "ordered_data.npy" #endif - -// - #ifdef THREAD_FUNNELED #define THREAD_LEVEL MPI_THREAD_FUNNELED #else #define THREAD_LEVEL MPI_THREAD_MULTIPLE #endif - int main(int argc, char** argv) { #if defined (_OPENMP) int mpi_provided_thread_level; @@ -100,6 +94,7 @@ int main(int argc, char** argv) { int d = 5; float_t* data; + /* * Generate a random matrix of lenght of some kind @@ -144,7 +139,7 @@ void simulate_master_read_and_scatter(int dims, size_t n, global_context_t *ctx) test_distributed_file_path(ctx, OUT_DATA); test_distributed_file_path(ctx, OUT_CLUSTER_ASSIGN); } - + TIME_START; if (ctx->mpi_rank == 0) @@ -165,14 +160,14 @@ void simulate_master_read_and_scatter(int dims, size_t n, global_context_t *ctx) //1B points // data = read_data_file(ctx,"../norm_data/eds_box_acc_normalized",5,MY_FALSE); - //data = read_data_file(ctx,"../norm_data/eds_box_6d",6,MY_FALSE); + // data = read_data_file(ctx,"../norm_data/eds_box_6d",6,MY_FALSE); // 190M points // std_g2980844_091_0000 - data = read_data_file(ctx,"../norm_data/std_g2980844_091_0000",5,MY_TRUE); + // data = read_data_file(ctx,"../norm_data/std_g2980844_091_0000",5,MY_TRUE); /* 1M points ca.*/ - // data = read_data_file(ctx,"../norm_data/std_LR_091_0001",5,MY_TRUE); + data = read_data_file(ctx,"../norm_data/std_LR_091_0001",5,MY_TRUE); /* BOX */ // data = read_data_file(ctx,"../norm_data/std_Box_256_30_092_0000",MY_TRUE); @@ -189,7 +184,7 @@ void simulate_master_read_and_scatter(int dims, size_t n, global_context_t *ctx) //data = read_data_file(ctx,"../norm_data/std_g1212639_091_0001",MY_TRUE); //for weak scalability - // ctx->n_points = ctx->n_points / 2; + ctx->n_points = ctx->n_points / 4; //ctx->n_points = (ctx->n_points / 32) * ctx -> world_size; get_dataset_diagnostics(ctx, data); -- GitLab