STDistributedIncomingSpikeScheduler.cpp

Go to the documentation of this file.

#include "STDistributedIncomingSpikeScheduler.h"

#include <iostream>

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

STDistributedIncomingSpikeScheduler::STDistributedIncomingSpikeScheduler(
    MPIInputBufferVector &inputBuffers,
    GlobalSingleTargetDelayMap &globalDelayMap,
    PropagatedSpikeBuffer &spikeBuffer,
    int cycleSteps) :
        spikeBuf(spikeBuffer), mpiInBuffers(inputBuffers), delayMap(globalDelayMap),
        _cycleSteps(cycleSteps)
{}

STDistributedIncomingSpikeScheduler::~STDistributedIncomingSpikeScheduler()
{}

void STDistributedIncomingSpikeScheduler::processMPIInputSpikeBuffers()
{
    MPIInputSpikeBuffer<>::const_iterator it;

    for (unsigned int i = 0 ; i < mpiInBuffers.size() ; i++) {
        if (mpiInBuffers[i].getContentType() != MPIMessageSpec::contentAnalog)
            if (mpiInBuffers[i].spikeBuf().hasNewContent())
                for (it = mpiInBuffers[i].spikeBuf().begin() ; it != mpiInBuffers[i].spikeBuf().end(); ++it) {
                    //cerr << "spike glengine=" << it->engine << " oid=" << it->oid << endl;
                    GlobalSingleTargetDelayMap::const_iterator delay_it;
                    if (delayMap.hasDelays(it->engine,it->oid))
                        for (delay_it = delayMap.beginDelays(it->engine, it->oid);
                                delay_it != delayMap.endDelays(it->engine, it->oid) ; ++delay_it) {
                            spikeBuf.scheduleSpikeTargetGroup(delay_it->second, delay_it->first + it->timestamp - _cycleSteps, 1.0 );
                        }
                }
    }
}

---