main.cpp

#include "Grid/grid_dist_id.hpp"
#include "data_type/aggregate.hpp"
#include "Decomposition/CartDecomposition.hpp"
#include "VCluster/VCluster.hpp"
 
int main(int argc, char* argv[])
{
 
    openfpm_init(&argc,&argv);
    
 
 
    Vcluster<> & v_cl = create_vcluster();
    long int N_prc = v_cl.getProcessingUnits();
 
 
 
    long int id = v_cl.getProcessUnitID();
 
    v_cl.max(id);
    v_cl.execute();
    if (v_cl.getProcessUnitID() == 0)
        std::cout << "Maximum processor rank: " << id << "\n";
 
 
 
    size_t id2 = v_cl.getProcessUnitID();
 
    v_cl.sum(id2);
    v_cl.execute();
    if (v_cl.getProcessUnitID() == 0)
        std::cout << "Sum of all processors rank: " << id2 << "\n";
 
 
 
    long int id3 = v_cl.getProcessUnitID();
    openfpm::vector<long int> v;
    
    v_cl.allGather(id3,v);
    v_cl.execute();
    
    if (v_cl.getProcessUnitID() == 0)
    {
        std::cout << "Collected ids: ";
        for(size_t i = 0 ; i < v.size() ; i++)
            std::cout << " " << v.get(i) << " ";
 
        std::cout << "\n";
    }
 
 
 
    // Create 2 messages with and hello message inside
    std::stringstream ss_message_1;
    std::stringstream ss_message_2;
    ss_message_1 << "Hello from " << std::setw(8) << v_cl.getProcessUnitID() << "\n";
    ss_message_2 << "Hello from " << std::setw(8) << v_cl.getProcessUnitID() << "\n";
    std::string message_1 = ss_message_1.str();
    std::string message_2 = ss_message_2.str();
    size_t msg_size = message_1.size();
    
    // Processor 0 send to processors 1,2 , 1 to 2,1, 2 to 0,1
 
    // send the message
    v_cl.send(((id3+1)%N_prc + N_prc)%N_prc,0,message_1.c_str(),msg_size);
    v_cl.send(((id3+2)%N_prc + N_prc)%N_prc,0,message_2.c_str(),msg_size);
 
    // create the receiving buffer
    openfpm::vector<char> v_one;
    v_one.resize(msg_size);
    openfpm::vector<char> v_two(msg_size);
    v_two.resize(msg_size);
 
    // Processor 0 receive from 1,2 ...
 
    v_cl.recv(((id3-1)%N_prc + N_prc)%N_prc,0,(void *)v_one.getPointer(),msg_size);
    v_cl.recv(((id3-2)%N_prc + N_prc)%N_prc,0,(void *)v_two.getPointer(),msg_size);
    v_cl.execute();
 
    // Processor 0 print the received message
    if (v_cl.getProcessUnitID() == 0)
    {
        for (size_t i = 0 ; i < msg_size ; i++)
            std::cout << v_one.get(i);
 
        for (size_t i = 0 ; i < msg_size ; i++)
            std::cout << v_two.get(i);
    }
 
 
 
    // Get the rank of the processor and put this rank in one variable
    id  = v_cl.getProcessUnitID();
    id2 = v_cl.getProcessUnitID();
    id3 = v_cl.getProcessUnitID();
    v.clear();
 
    // convert the string into a vector
    openfpm::vector<char> message_1_v(msg_size);
    openfpm::vector<char> message_2_v(msg_size);
 
    for (size_t i = 0 ; i < msg_size ; i++)
        message_1_v.get(i) = message_1[i];
 
    for (size_t i = 0 ; i < msg_size ; i++)
        message_2_v.get(i) = message_2[i];
 
    // Calculate the maximin across all the rank
    v_cl.max(id);
    // Calculate the sum across all the rank
    v_cl.sum(id2);
    // all processor send one number, all processor receive all numbers
    v_cl.allGather(id3,v);
 
    // in the case of vector we have special functions that avoid to specify the size
    v_cl.send(((id+1)%N_prc + N_prc)%N_prc,0,message_1_v);
    v_cl.send(((id+2)%N_prc + N_prc)%N_prc,0,message_2_v);
    v_cl.recv(((id-1)%N_prc + N_prc)%N_prc,0,v_one);
    v_cl.recv(((id-2)%N_prc + N_prc)%N_prc,0,v_two);
    v_cl.execute();
 
    // Only processor one print the received data
    if (v_cl.getProcessUnitID() == 1)
    {
        std::cout << "Maximum processor rank: " << id << "\n";
        std::cout << "Sum of all processors rank: " << id << "\n";
 
        std::cout << "Collected ids: ";
        for(size_t i = 0 ; i < v.size() ; i++)
            std::cout << " " << v.get(i) << " ";
 
        std::cout << "\n";
 
        for (size_t i = 0 ; i < msg_size ; i++)
            std::cout << v_one.get(i);
 
        for (size_t i = 0 ; i < msg_size ; i++)
            std::cout << v_two.get(i);
    }
 
 
 
    openfpm_finalize();
 
 
}