include/emma/EmmaConvergenceLayer.h

Go to the documentation of this file.

#ifndef EMMACONVERGENCELAYER_H_
#define EMMACONVERGENCELAYER_H_

#include "core/ConvergenceLayer.h"
#include "core/UDPConvergenceLayer.h"
#include "core/BundleReceiver.h"
#include "data/BundleFactory.h"
#include "emma/DiscoverBlockFactory.h"
#include "emma/GPSProvider.h"
#include "core/BundleRouter.h"
#include "utils/Service.h"

#include "core/EventReceiver.h"

#include "utils/MutexLock.h"
#include "utils/Mutex.h"

#include <queue>

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

namespace emma
{
        class EmmaConvergenceLayer : public dtn::core::ConvergenceLayer, public BundleReceiver, public EventReceiver
        {
        public:
                EmmaConvergenceLayer(string eid, string bind_addr, unsigned short port, string broadcast, unsigned int mtu = 1280);

                virtual ~EmmaConvergenceLayer();

                virtual TransmitReport transmit(const Bundle &b);

                virtual TransmitReport transmit(const Bundle &b, const Node &node);

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

                void raiseEvent(const Event *evt);

                virtual void initialize();
                virtual void terminate();

        private:
                void yell();

                void yell(Node node);

                static const int MAX_SIZE;

                string m_eid;
                string m_bindaddr;
                unsigned int m_bindport;

                UDPConvergenceLayer *m_direct_cl;
                UDPConvergenceLayer *m_broadcast_cl;

                Mutex m_receivelock;

                pair<double,double> m_position;

                DiscoverBlockFactory *m_dfactory;
        };
}

#endif /*EMMACONVERGENCELAYER_H_*/

---