include/core/BundleCore.h

Go to the documentation of this file.

#ifndef BUNDLECORE_H_
#define BUNDLECORE_H_

#include "core/AbstractBundleStorage.h"
#include "core/ConvergenceLayer.h"
#include "data/BundleFactory.h"
#include "core/BundleRouter.h"
#include "core/CustodyTimer.h"
#include "core/BundleReceiver.h"
#include "core/EventReceiver.h"
#include "core/CustodyManager.h"
#include "core/Event.h"

#include "data/CustodySignalBlock.h"
#include "data/StatusReportBlock.h"
#include <vector>
#include <list>
#include "utils/MutexLock.h"
#include "utils/Mutex.h"
#include "utils/Service.h"


using namespace dtn::data;
using namespace dtn::utils;

namespace dtn
{
        namespace core
        {
                class AbstractWorker;

                class BundleCore : public Service, public BundleReceiver, public EventReceiver
                {
                public:
                        static BundleCore& getInstance(string eid);
                        static BundleCore& getInstance();

                        void setConvergenceLayer(ConvergenceLayer *cl);

                        ConvergenceLayer* getConvergenceLayer();

                        CustodyManager& getCustodyManager();

                        void registerSubNode(string eid, AbstractWorker *node);
                        void unregisterSubNode(string eid);

                        virtual void received(const ConvergenceLayer &cl, const Bundle &b);

                        string getLocalURI() const;

                        void raiseEvent(const Event *evt);

                        void transmit(const Node &n, const Bundle &b);

                        void deliver(const Bundle &b);

                protected:
                        void tick();

                private:
                        BundleCore();

                        virtual ~BundleCore();

                        void transmit(const Bundle &b);

                        BundleCore operator=(const BundleCore &k) {};

                        void setLocalEID(string eid);

                        void transmitCustody(bool accept, const Bundle &b);

                        Bundle createStatusReport(const Bundle &b, StatusReportType type, StatusReportReasonCode reason = NO_ADDITIONAL_INFORMATION);
                        Bundle createCustodySignal(const Bundle &b, bool accepted);

                        ConvergenceLayer *m_clayer;
                        map<string, AbstractWorker*> m_worker;
                        string m_localeid;
                        CustodyManager m_cm;
                        unsigned int m_dtntime;
                };
        }
}

#endif /*BUNDLECORE_H_*/

---