DistributedSingleThreadNetwork.h

Go to the documentation of this file.

#ifndef DISTRIBUTEDSINGLETHREADNETWORK_H_
#define DISTRIBUTEDSINGLETHREADNETWORK_H_

#include "DistributedNetwork.h"
#include "DistributedSimEngine.h"
#include "SingleThreadSimEngine.h"
#include "STDistributedIncomingSpikeScheduler.h"
#include "DistributedSpikeScheduler.h"
#include "SingleThreadSpikeScheduler.h"
#include "GlobalSingleTargetDelayMap.h"
#include "TargetNodesMap.h"

#include "MPIDefaultAllToAllCommunicator.h"
#include "MPIInputBuffer.h"
#include "MPIOutputBuffer.h"
#include "AnalogMessageDispatcher.h"

#ifndef __GCCXML__
#include "DistributedAnalogMessageDispatcher.h"
#include "DistributedAnalogMessageCreator.h"
#include "AnalogDelayObjectMap.h"
#include "STAnalogMessageCreator.h"
#endif


class DistributedSingleThreadNetwork : public DistributedNetwork {
    public:

        DistributedSingleThreadNetwork( SimParameter sp = SimParameter::Default);



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



        virtual ~DistributedSingleThreadNetwork();




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

    public:
        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);


    protected:
        template<typename analogSrcType, typename analogDestType>
        void addGenericAnalogMessage(const SimObject::ID &sender, analogSrcType srcPortOrField, const SimObject::ID &receiver, analogDestType destPortOrField, delay_t delay);


    protected:


        virtual void _reset_();



        virtual void _advance_( int nSteps = 1 );

        virtual void _initialize_();


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

        // virtual local_objectid_t addObjectLocally( SimObject *o, engineid_t eng = 0 );

        STDistributedIncomingSpikeScheduler *distIncomingSpikeScheduler;

        DistributedSpikeScheduler *spikeScheduler;



        GlobalSingleTargetDelayMap *globalDelayMap;


        TargetNodesMap *targetNodesMap;

        MPIAllToAllCommunicator *mpiAllToAllComm;


        MPIOutputBufferVector *mpiOutBuffers;


        MPIInputBufferVector *mpiInBuffers;


        PropagatedSpikeBuffer *spikeBuffer;


        LocalDelayMap *localDelayMap;

        SingleThreadSpikeScheduler *localSpikeScheduler;



#ifndef __GCCXML__

        AnalogMessageDispatcher *localAnalogMsgDispatcher;

        AnalogDelayObjectMap * delayObjectMap;

        DistributedAnalogMessageDispatcher *distAnalogMsgDispatcher;

        STAnalogMessageCreator *localAnalogMsgCreator;

        DistributedAnalogMessageCreator *distAnalogMsgCreator;

        vector< DistributedIncomingAnalogMsgDispatcher *> incomingDispatchers;

        vector<DistIncomingAnalogSources2BufPosMap *> sources2BufPositionsMaps;

        vector< DistributedOutgoingAnalogMsgDispatcher *> outgoingDispatchers;

#endif



        SpikeTargetGroupPool *stgPool;



    private:

        void init();

    protected:

        virtual void _addSpikeMessage_(const SimObject::ID &sender, const port_t out, const spike_port_id_t sender_port, const SimObject::ID &receiver, const port_t port, const step_t delay);


};

#endif /*DISTRIBUTEDSINGLETHREADNETWORK_H_*/

---