Commit c566198d authored by lykos98's avatar lykos98
Browse files

removed ipynbs

parent 536e0993

.gitignore

+1 −1
Original line number Diff line number Diff line 
main

sync.sh

bb

.ipy*

*.ipynb

scalability_results

Untitled.ipynb

deleted100644 → 0
+0 −6

File deleted.

Contains only whitespace changes.

bb_plot.ipynb

deleted100644 → 0
+0 −342

File deleted.

Preview size limit exceeded, changes collapsed.

coherency_tests.ipynb

deleted100644 → 0
+0 −1068

File deleted.

Preview size limit exceeded, changes collapsed.

src/tree/tree.c

+22 −4
Original line number Diff line number Diff line
@@ -22,7 +22,7 @@ 
//#define WRITE_NGBH

//#define WRITE_TOP_NODES

//#define WRITE_DENSITY

#define WRITE_CLUSTER_ASSIGN_H1

//#define WRITE_CLUSTER_ASSIGN_H1



/* 

 * Maximum bytes to send with a single mpi send/recv, used
@@ -2280,12 +2280,14 @@ void find_foreign_nodes(global_context_t* ctx, datapoint_info_t* dp, datapoint_i 
    if(!heap_buffer_to_send)

    {

        printf("Rank %d cannot allocate heap to send aborting\n",ctx -> mpi_rank);

        printf("Required %d for %d bytes\n", tot_count_send, tot_count_send * 16);

        exit(1);

    }



    if(!heap_buffer_to_recv)

    {

        printf("Rank %d cannot allocate heap to send aborting\n",ctx -> mpi_rank);

        printf("Rank %d cannot allocate heap to recieve aborting\n",ctx -> mpi_rank);

        printf("Required %d for %d bytes\n", tot_count_recv, tot_count_recv * 16);

        exit(1);

    }
@@ -3129,6 +3131,20 @@ clusters_t Heuristic1(global_context_t *ctx, int verbose) 
    qsort(dp_info_ptrs, n, sizeof(datapoint_info_t*), cmpPP);



    /* check into internal nodes */



    /* 

     * to remove 

     * and to reimplement it using rma

     * for dp in datapoints:

     *  for nghb in neighbors:

     *   if ngbh its_mine

     *      no_problems, do it as always

     *   else:

     *      ngbh is an external node

     *      do rma things,

     *      in particular, acquire a lock on the window, read and write things

     *      then close

     */

    #pragma omp parallel shared(to_remove_mask)

    {

		#pragma omp for
@@ -3596,10 +3612,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",MY_TRUE);

        data = read_data_file(ctx,"../norm_data/std_g2980844_091_0000",MY_TRUE);

        

        /* 1M points ca.*/

        data = read_data_file(ctx,"../norm_data/std_LR_091_0001",MY_TRUE);

        //data = read_data_file(ctx,"../norm_data/std_LR_091_0001",MY_TRUE);



        /* BOX */

        // data = read_data_file(ctx,"../norm_data/std_Box_256_30_092_0000",MY_TRUE);
@@ -3635,6 +3651,8 @@ void simulate_master_read_and_scatter(int dims, size_t n, global_context_t *ctx) 
    int *send_counts = (int *)malloc(ctx->world_size * sizeof(int));

    int *displacements = (int *)malloc(ctx->world_size * sizeof(int));



    HERE



    displacements[0] = 0;

    send_counts[0] = ctx->n_points / ctx->world_size;

    send_counts[0] += (ctx->n_points % ctx->world_size) > 0 ? 1 : 0;