DistributionStrategy.cpp

Go to the documentation of this file.

#include "DistributionStrategy.h"
#include "DistributedNetwork.h"

#include <iostream>

using std::cerr;
using std::endl;

SimEngine::ID DistributionStrategy::ModuloOverGlobalEngines::operator()( DistributedNetwork* net )
{
    e = e % (net->maxGlobalEngineID() + 1);
    return net->getLocation( e++ );
}

SimEngine::ID DistributionStrategy::ModuloOverGlobalEngines::operator()( SimNetwork* net )
{
    e = e % (net->maxLocalEngineID() + 1);
    return SimEngine::ID( net->mpi_rank(), e );
}

SimEngine::ID DistributionStrategy::ModuloOverLocalEngines::operator()( DistributedNetwork* net )
{
    e = e % (net->maxLocalEngineID() + 1);
//    cerr << "ok!";
    return SimEngine::ID( net->mpi_rank() , e++ );
}

SimEngine::ID DistributionStrategy::ModuloOverLocalEngines::operator()( SimNetwork* net )
{
    e = e % (net->maxLocalEngineID() + 1);
//    cerr << "ok!";
    return SimEngine::ID( net->mpi_rank() , e++ );
}

SimEngine::ID DistributionStrategy::ModuloOverLocalEnginesOnOneNode::operator()( DistributedNetwork* net )
{
    e = e % (net->maxLocalEngineID() + 1);
    return SimEngine::ID( node , e++ );
}

SimEngine::ID DistributionStrategy::ModuloOverLocalEnginesOnOneNode::operator()( SimNetwork* net )
{
    e = e % (net->maxLocalEngineID() + 1);
    return SimEngine::ID( node , e++ );
}


SimEngine::ID DistributionStrategy::RandomOverGlobalEngines::operator()( DistributedNetwork* net )
{
    gl_engineid_t gEID = (gl_engineid_t)( (int)( (*(net->getMainConstructRNGEngine()))() * net->maxGlobalEngineID() + 0.5 ) );
    return net->getLocation( gEID );
}

/*SimEngine::ID DistributionStrategy::RandomOverGlobalEngines::operator()( SimNetwork* net )
{
    gl_engineid_t gEID = (gl_engineid_t)( (int)( (*uni)()*net->maxGlobalEngineID() + 0.5 ) );
    return net->getLocation( gEID );
}*/

SimEngine::ID DistributionStrategy::RandomOverLocalEngines::operator()( SimNetwork* net )
{
    engineid_t gEID = (engineid_t)( (int)( (*(net->getMainConstructRNGEngine()))() * net->maxLocalEngineID() + 0.5 ) );
    return SimEngine::ID( net->mpi_rank() , gEID );
}

SimEngine::ID DistributionStrategy::RandomOverLocalEngines::operator()( DistributedNetwork* net )
{
    engineid_t gEID = (engineid_t)( (int)( (*(net->getMainConstructRNGEngine()))() * net->maxLocalEngineID() + 0.5 ) );
    return SimEngine::ID( net->mpi_rank() , gEID );
}



SimEngine::ID DistributionStrategy::EngineListStrategy::operator()( SimNetwork* net )
{
    if(engine_list.empty()) {
        cerr << "engine_list empty!!!" << endl;
        engineid_t gEID = (engineid_t)( (int)( (*(net->getMainConstructRNGEngine()))() * net->maxLocalEngineID() + 0.5 ) );
        return SimEngine::ID( net->mpi_rank() , gEID );
    }

    engineid_t gEID = (engineid_t) engine_list.front();
    engine_list.pop_front();

    return SimEngine::ID( net->mpi_rank() , gEID );
}


SimEngine::ID DistributionStrategy::EngineListStrategy::operator()( DistributedNetwork* net )
{
    if(engine_list.empty()) {
        cerr << "engine_list empty!!!" << endl;
        gl_engineid_t gEID = (gl_engineid_t)( (int)( (*(net->getMainConstructRNGEngine()))() * net->maxGlobalEngineID() + 0.5 ) );
        return net->getLocation( gEID );
    }

    gl_engineid_t gEID = (gl_engineid_t) engine_list.front();
    engine_list.pop_front();

    return net->getLocation( gEID );
}



SimEngine::ID DistributionStrategy::RankListStrategy::operator()( SimNetwork* net )
{
    if(rank_list.empty()) {
        cerr << "rank_list empty!!!" << endl;
        engineid_t gEID = (engineid_t)( (int)( (*(net->getMainConstructRNGEngine()))() * net->maxLocalEngineID() + 0.5 ) );
        return SimEngine::ID( net->mpi_rank() , gEID );
    }

    e = e % (net->maxLocalEngineID() + 1);
    int rank = (int) rank_list.front();
    rank_list.pop_front();

    return SimEngine::ID( rank, e );
}



SimEngine::ID DistributionStrategy::RankListStrategy::operator()( DistributedNetwork* net )
{
    if(rank_list.empty()) {
        cerr << "rank_list empty!!!" << endl;
        gl_engineid_t gEID = (gl_engineid_t)( (int)( (*(net->getMainConstructRNGEngine()))() * net->maxGlobalEngineID() + 0.5 ) );
        return net->getLocation( gEID );
    }

    e = e % (net->maxLocalEngineID() + 1);
    int rank = (int) rank_list.front();
    rank_list.pop_front();

    return SimEngine::ID(rank, e++ );
}

---