include/core/UDPConvergenceLayer.h

Go to the documentation of this file.

#ifndef UDPCONVERGENCELAYER_H_
#define UDPCONVERGENCELAYER_H_

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

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

namespace dtn
{
        namespace core
        {
                class UDPConvergenceLayer : public Service, public ConvergenceLayer
                {
                public:
                        UDPConvergenceLayer(string bind_addr, unsigned short port, bool broadcast = false, unsigned int mtu = 1280);

                        virtual ~UDPConvergenceLayer();

                        virtual TransmitReport transmit(const Bundle &b);

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

                        virtual void tick();

                private:
                        void receiveBundle();

                        int m_socket;

                        //static const int MAX_SIZE;
                        static const int DEFAULT_PORT;

                        unsigned int m_maxmsgsize;

                        string m_selfaddr;
                        unsigned int m_selfport;

                        Mutex m_writelock;

                        //int m_fakeloss;
                };
        }
}

#endif /*UDPCONVERGENCELAYER_H_*/

---