daemon/src/net/LOWPANConvergenceLayer.h

Go to the documentation of this file.

#ifndef LOWPANCONVERGENCELAYER_H_
#define LOWPANCONVERGENCELAYER_H_

#include "Component.h"
#include "net/ConvergenceLayer.h"
#include "net/LOWPANConnection.h"
#include "net/DiscoveryAgent.h"
#include "net/DiscoveryServiceProvider.h"
#include <ibrcommon/net/vinterface.h>
#include <ibrcommon/net/lowpansocket.h>
#include <ibrcommon/net/lowpanstream.h>

#include <list>

using namespace dtn::data;

namespace dtn
{
        namespace net
        {
                class LOWPANConnection;
                class LOWPANConvergenceLayer : public DiscoveryAgent, public ConvergenceLayer, public dtn::daemon::IndependentComponent, public ibrcommon::lowpanstream_callback, public EventReceiver, public DiscoveryServiceProvider
                {
                public:
                        LOWPANConvergenceLayer(ibrcommon::vinterface net, int panid, unsigned int mtu = 115); //MTU is actually 127...

                        virtual ~LOWPANConvergenceLayer();

                        void update(const ibrcommon::vinterface &iface, std::string &name, std::string &data) throw(dtn::net::DiscoveryServiceProvider::NoServiceHereException);

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

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

                        virtual const std::string getName() const;

                        virtual void raiseEvent(const Event *evt);

                        virtual void send_cb(char *buf, int len, unsigned int address);

                        static const size_t BUFF_SIZE = 113;

                        void remove(const LOWPANConnection *conn);

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

                        virtual void sendAnnoucement(const u_int16_t &sn, std::list<dtn::net::DiscoveryService> &services);

                private:
                        ibrcommon::lowpansocket *_socket;

                        ibrcommon::vinterface _net;
                        int _panid;
                        char *_ipnd_buf;
                        int _ipnd_buf_len;

                        ibrcommon::Mutex _connection_lock;
                        std::list<LOWPANConnection*> ConnectionList;
                        LOWPANConnection* getConnection(unsigned short address);

                        unsigned int m_maxmsgsize;

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

                        bool _running;
                };
        }
}
#endif /*LOWPANCONVERGENCELAYER_H_*/