SingleThreadNetwork.h

Go to the documentation of this file.

#ifndef SINGLETHREADNETWORK_H_
#define SINGLETHREADNETWORK_H_

//PropagatedSpikeBuffer
//TargetDelayMap

#include "SimObject.h"
#include "SimParameter.h"
#include "SimNetwork.h"
#include "PCSIMException.h"
#include "SimObjectPool.h"
#include "SingleThreadSpikeScheduler.h"
#include "SingleThreadSimEngine.h"
#include "SingleThreadAnalogMsgDispatcher.h"
#include "AnalogDelayObjectMap.h"
#include "AnalogDelayObject.h"
#include "STAnalogMessageCreator.h"

class LocalDelayMap;
class SpikeTargetGroupPool;


class SingleThreadNetwork : public SimNetwork
{

public:

    SingleThreadNetwork( SimParameter sp = SimParameter::Default );
    SingleThreadNetwork( MPI::Intracomm &mpiCommunicator, SimParameter sp = SimParameter::Default );

    virtual ~SingleThreadNetwork();

    //


  protected:

    virtual void _addObject_( const SimObjectFactory &objFactory, const SimEngine::ID &loc, SimObject::ID &oid );

  public:
    virtual void setDistributionStrategy( const DistributionStrategy::DistributionFunction &df )
    {
        /* NOTHING TO DO HERE */
    };

  protected:
    virtual void _addObject_( const SimObjectFactory &objFactory, SimObject::ID &gid );


    //



    virtual void _addSpikeMessage_(const SimObject::ID &sender, const port_t out, const SimObject::ID &receiver, const port_t in, const Time &delay);

    virtual void _addAnalogMessage_(const SimObject::ID &sender, int sender_port, const SimObject::ID &receiver, int recv_port, const Time &delay);

    virtual void _addAnalogMessage_(const SimObject::ID &sender, int sender_port, const SimObject::ID &receiver, string destfield, const Time &delay);

    virtual void _addAnalogMessage_(const SimObject::ID &sender, string srcfield, const SimObject::ID &receiver, int recv_port, const Time &delay);

    virtual void _addAnalogMessage_(const SimObject::ID &sender, string srcfield, const SimObject::ID &receiver, string destfield, const Time &delay);

    virtual SimObject *_getObject_(const SimObject::ID &id);


    //


    // virtual gl_engineid_t maxGlobalEngineID(void) const;

    virtual gl_engineid_t maxLocalEngineID(void) const { return 0; };


protected:

    friend class MultiThreadNetwork;
    friend class DistributedSingleThreadNetwork;
    friend class DistributedMultiThreadNetwork;

    virtual void _initialize_();

    virtual void _reset_();

    virtual void _advance_( int nSteps = 1 );

    virtual void _insert_( const SimObjectFactory &objFactory, const SimObject::ID &container, SimObject::ID &gid );

    virtual void _mount_( const SimObjectFactory &objFactory, const SimObject::ID &mountpoint, SimObject::ID &gid );

    /* The type of connection (spike or analog) is determined (guessed) automatically.
     * If delay < 0 then the value returned by the destination objects getManagedDelay() method is used.
     * If a positive value is specified this value overwrites the dstobj.getManagedDelay() value.
     * */
    virtual void _connect_( SimObject::ID const& src, port_t out, const SimObject::ID &dst, port_t in, int delay );

    static void addLocalSpikeMessage(
        LocalDelayMap *arg_delayMap, SpikeTargetGroupPool *arg_stgPool, SimEngine *arg_simEng,
        const spike_port_id_t sender_port, const SimObject::ID &receiver, port_t in_port, step_t delay
    );

    virtual void seed_noise_rng( uint32 noiseRNGseed );
    
    // void addIntraEngineSpikeMessage( spike_port_id_t sender_port, object_type_t rec_type, local_objectid_t rec_oid, port_t in_port, delay_t delay );

private:

    void init();

    PropagatedSpikeBuffer *spikeBuffer;
    LocalDelayMap *delayMap;
    SingleThreadSpikeScheduler *spikeScheduler;

    SingleThreadAnalogMsgDispatcher *analogMsgDispatcher;
    AnalogDelayObjectMap *analogDelayObjectsMap;

    SingleThreadSimEngine *simEngine;
    SpikeTargetGroupPool *stgPool;

    DistributionStrategy::LocalRoundRobin localRoundRobin;

    STAnalogMessageCreator * analogMsgCreator;

};

#endif /*SINGLETHREADNETWORK_H_*/

---