DistributedSpikeScheduler.h

Go to the documentation of this file.

#ifndef DISTRIBUTEDSPIKESCHEDULER_H_
#define DISTRIBUTEDSPIKESCHEDULER_H_

#include <vector>

#include "globaldefinitions.h"
#include "SpikeScheduler.h"
#include "MPIOutputBuffer.h"
#include "TargetNodesMap.h"

using std::vector;


class DistributedSpikeScheduler : public SpikeScheduler
{
public:


    DistributedSpikeScheduler(SpikeScheduler &localScheduler,
                              TargetNodesMap &targetNodesMap,
                              MPIOutputBufferVector &mpiOutputBuffers,
                              int numLocalEngines = 1);

    virtual ~DistributedSpikeScheduler();

    /*
     * It is invoked by the SingleThreadSimEngine when some advancing spiking object generates a spike.
     * 
     * \param senderid Identifier of the sim object that emits the spike.
     * \param offsetFraction The exact moment in time when the spike occured is given by  t + offsetFraction * dt
     * \param engine engineid of the local engine where sender object belongs (used in multi-threaded case, otherwise 0).
     */
    virtual void scheduleSpike(local_objectid_t senderid, float offsetFraction, engineid_t engine = 0);


    virtual void deliverSpikes(SpikeReceiverList &listActiveSynapses, engineid_t engine, double time, int stepOffset = 0);

    virtual void reset();


    virtual void advance(engineid_t engine = 0);

    /*
     *  Used to update the state of the propagated spike buffers etc.
     */
    virtual void nextCycle();


protected:

    SpikeScheduler &_localScheduler;

    MPIOutputBufferVector &_mpiOutputBuffers;

    TargetNodesMap & nodesMap;


    vector<int> engineClocks;


    int nLocalEngines;

};

#endif /*DISTRIBUTEDSPIKESCHEDULER_H_*/

---