DistributedSpikeScheduler.cpp

Go to the documentation of this file.

#include "DistributedSpikeScheduler.h"

#include <iostream>

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

DistributedSpikeScheduler::DistributedSpikeScheduler(SpikeScheduler &localScheduler,
        TargetNodesMap & targetNodesMap,
        MPIOutputBufferVector &mpiOutputBuffers,
        int numLocalEngines) :
        _localScheduler(localScheduler), _mpiOutputBuffers(mpiOutputBuffers),
        nodesMap(targetNodesMap), nLocalEngines(numLocalEngines)
{
    engineClocks.resize(nLocalEngines, int(0));
}

DistributedSpikeScheduler::~DistributedSpikeScheduler()
{}

void DistributedSpikeScheduler::scheduleSpike(local_objectid_t senderid, float offsetFraction, engineid_t engine)
{

    TargetNodesMap::const_iterator node_it;
    if ( nodesMap.hasNodes(senderid, engine) )
        for ( node_it = nodesMap.begin(senderid, engine) ; node_it != nodesMap.end(senderid, engine) ; ++node_it)  {            
            _mpiOutputBuffers[*node_it].spikeBuf().appendSpike(senderid, engineClocks[engine], engine);
        }

    _localScheduler.scheduleSpike(senderid, offsetFraction, engine);
}

void DistributedSpikeScheduler::deliverSpikes(SpikeReceiverList &listActiveSynapses, engineid_t engine, double time, int stepOffset)
{
    _localScheduler.deliverSpikes(listActiveSynapses, engine, time, stepOffset);
}

void DistributedSpikeScheduler::reset()
{
    _localScheduler.reset();
    for (int i = 0; i < nLocalEngines; ++i) {
        engineClocks[i] = 0;
    }
}

void DistributedSpikeScheduler::advance(engineid_t engine)
{
    _localScheduler.advance(engine);
    engineClocks[engine]++;
}

void DistributedSpikeScheduler::nextCycle()
{
    _localScheduler.nextCycle();
    for (int i = 0 ; i < nLocalEngines ; ++i) {
        engineClocks[i] = 0;
    }
}

---