Commit c51fef3f authored by lykos98's avatar lykos98
Browse files

removed OUT_HALO

parent b95d2a26

src/main/main.c

+7 −12
Original line number Diff line number Diff line
@@ -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;
@@ -101,6 +95,7 @@ int main(int argc, char** argv) { 
	

	float_t* data;

    



	/*

	 * Generate a random matrix of lenght of some kind

	 */
@@ -169,10 +164,10 @@ void simulate_master_read_and_scatter(int dims, size_t n, global_context_t *ctx) 


        // 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);