daemon/src/net/UDPConvergenceLayer.h

Go to the documentation of this file.

#ifndef UDPCONVERGENCELAYER_H_
#define UDPCONVERGENCELAYER_H_

#include "Component.h"
#include "net/ConvergenceLayer.h"
#include "ibrcommon/Exceptions.h"
#include "net/DiscoveryServiceProvider.h"
#include "ibrcommon/net/NetInterface.h"
#include "ibrcommon/net/udpsocket.h"

using namespace dtn::data;


namespace dtn
{
        namespace net
        {
                class UDPConvergenceLayer : public ConvergenceLayer, public dtn::daemon::IndependentComponent, public DiscoveryServiceProvider
                {
                public:
                        UDPConvergenceLayer(ibrcommon::NetInterface net, int port, bool broadcast = false, unsigned int mtu = 1280);

                        virtual ~UDPConvergenceLayer();

                        virtual void update(std::string &name, std::string &data);
                        virtual bool onInterface(const ibrcommon::NetInterface &net) const;

                        dtn::core::Node::Protocol getDiscoveryProtocol() const;

                        void queue(const dtn::core::Node &n, const ConvergenceLayer::Job &job);

                        UDPConvergenceLayer& operator>>(dtn::data::Bundle&);

                        virtual const std::string getName() const;

                protected:
                        virtual void componentUp();
                        virtual void componentRun();
                        virtual void componentDown();
                        bool __cancellation();

                private:
                        ibrcommon::udpsocket *_socket;

                        ibrcommon::NetInterface _net;
                        int _port;
                        int m_socket;

                        static const int DEFAULT_PORT;

                        unsigned int m_maxmsgsize;

                        ibrcommon::Mutex m_writelock;
                        ibrcommon::Mutex m_readlock;

                        bool _running;


                };
        }
}

#endif /*UDPCONVERGENCELAYER_H_*/