DistributedMultiThreadNetwork.h

Go to the documentation of this file.

#ifndef DISTRIBUTEDMULTITHREADNETWORK_H_
#define DISTRIBUTEDMULTITHREADNETWORK_H_

#include "DistributedNetwork.h"
#include "DistributedSimEngine.h"
#include "MultiThreadSimEngine.h"
#include "MTDistributedIncomingSpikeScheduler.h"
#include "DistributedSpikeScheduler.h"
#include "MultiThreadSpikeScheduler.h"
#include "GlobalMultiTargetDelayMap.h"
#include "TargetNodesMap.h"
#include "MPIInputBuffer.h"
#include "MPIOutputBuffer.h"
#include "MPIDefaultAllToAllCommunicator.h"

#ifndef __GCCXML__

#include "SingleThreadAnalogMsgDispatcher.h"
#include "MultiThreadAnalogMsgDispatcher.h"
#include "DistributedAnalogMessageDispatcher.h"
#include "MTDistributedCycledAnalogMsgDispatcher.h"
#include "STAnalogMessageCreator.h"
#include "MTAnalogMessageCreator.h"
#include "DistributedAnalogMessageCreator.h"

#endif



class DistributedMultiThreadNetwork : public DistributedNetwork {
    public:

        DistributedMultiThreadNetwork(int numThreads, SimParameter sp = SimParameter::Default );


        DistributedMultiThreadNetwork(int numThreads, MPI::Intracomm &mpiCommunicator, SimParameter sp = SimParameter::Default );

        virtual ~DistributedMultiThreadNetwork();



    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);
        
        virtual gl_engineid_t maxLocalEngineID(void) const;       

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

        int nThreads;

        MTDistributedIncomingSpikeScheduler *distIncomingSpikeScheduler;

        DistributedSpikeScheduler *spikeScheduler;


        GlobalMultiTargetDelayMap *globalDelayMap;


        TargetNodesMap *targetNodesMap;

        MPIAllToAllCommunicator *mpiAllToAllComm;


        MPIOutputBufferVector *mpiOutBuffers;


        MPIInputBufferVector *mpiInBuffers;

        MTSpikeRoutingTables *mtTables;

        ThreadPool thrPool;

        vector<PropagatedSpikeBuffer*> STBuffers;


        MultiThreadSpikeScheduler *localSpikeScheduler;


        // BEGIN ************* Analog Message Dispatchers, Message Creators and their supporting structures ***********
#ifndef __GCCXML__

        AnalogDelayObjectMap *analogDelayObjectsMap;

        vector<MultiThreadAnalogMsgDispatcher *> mTanalogMsgDispatchers;

        vector< DistributedAnalogMessageDispatcher *> distAnalogMsgDispatchers;

        MTDistributedCycledAnalogMsgDispatcher *mtDistCycledAnalogMsgDispatcher;

        vector< STAnalogMessageCreator * > stAnalogMsgCreators;

        MTAnalogMessageCreator * mtAnalogMsgCreator;

        vector< DistributedAnalogMessageCreator *> distAnalogMessageCreators;

        vector<vector< DistributedIncomingAnalogMsgDispatcher *> > incomingDispatchers;

        vector<DistIncomingAnalogSources2BufPosMap *> sources2BufPositionsMaps;

        vector< vector< DistributedOutgoingAnalogMsgDispatcher *> > outgoingDispatchers;

#endif
        // END ************* Analog Message Dispatchers, Message Creators and their supporting structures ***********


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

    private:
        friend class NoiseRandomEngineTest;
        virtual void noiseRandEngineOutput( vector<uint32> & r );

};

#endif /*DISTRIBUTEDMULTITHREADNETWORK_H_*/

---