main.cpp

#include "Grid/grid_dist_id.hpp"
#include "data_type/aggregate.hpp"
#include "Decomposition/CartDecomposition.hpp"
#include "VCluster/VCluster.hpp"
 
#define N_NEXT 3
#define N_NUMBERS 5
 
int main(int argc, char* argv[])
{
 
    openfpm_init(&argc,&argv);
    Vcluster<> & v_cl = create_vcluster();
    
 
 
    // id of the processor calling this function
    long int proc_id = v_cl.getProcessUnitID();
 
    // number of processors executing this program
    long int n_proc = v_cl.getProcessingUnits();
 
    // List of processors we communicate with
    openfpm::vector<size_t> prc_send;
 
    // For each processor we want to send a vector of doubles
    // in this case each processor send N_NEXT vectors.
    // In general we can think to openfpm::vector<T> as a set of objects T.
    // where we want to send one object T to each processor in out sending list.
    // In this case T is a list of double or (openfpm::vector<double>)
    openfpm::vector<openfpm::vector<double>> messages_send(N_NEXT);
 
    // Here we prepare the senbding buffer
    for (size_t i = 0, m = 0 ; i < N_NEXT ; i++, m++)
    {
        // create the sending processor list
        prc_send.add(openfpm::math::positive_modulo(proc_id + i + 1,n_proc));
 
        // Fill with soma data the vectors
        for (size_t j = 0 ; j < N_NUMBERS ; j++)
            messages_send.get(m).add(j+N_NUMBERS*proc_id);
 
    }
 
    // Buffer that receive messages
    openfpm::vector<double> messages_recv2;
 
    // List of processor from which we receove
    openfpm::vector<size_t> prc_recv2;
 
    // number of elements we receive from each processors
    openfpm::vector<size_t> sz_recv2;
 
    v_cl.SSendRecv(messages_send,messages_recv2,prc_send,prc_recv2,sz_recv2);
 
    // here each processor print the received message
 
    std::cout << "Processor " << proc_id << " received ";
    for (size_t i = 0 ; i < messages_recv2.size() ; i++)
        std::cout << messages_recv2.get(i) << "   ";
 
    std::cout << std::endl;
 
 
 
    openfpm_finalize();
 
}