daemon/src/net/LOWPANConnection.h

Go to the documentation of this file.

#ifndef LOWPANCONNECTION_H_
#define LOWPANCONNECTION_H_

#include "net/LOWPANConvergenceLayer.h"

#include <ibrcommon/thread/Queue.h>
#include <ibrcommon/net/lowpanstream.h>

using namespace dtn::data;

namespace dtn
{
        namespace net
        {
                class LOWPANConnectionSender : public ibrcommon::JoinableThread
                {
                        public:
                                LOWPANConnectionSender(ibrcommon::lowpanstream &_stream);
                                virtual ~LOWPANConnectionSender();

                                void queue(const ConvergenceLayer::Job &job);
                                void run();
                                void __cancellation();

                        private:
                                ibrcommon::lowpanstream &_stream;
                                ibrcommon::Queue<ConvergenceLayer::Job> _queue;
                };

                class LOWPANConvergenceLayer;
                class LOWPANConnection : public ibrcommon::DetachedThread
                {
                public:
                        LOWPANConnection(unsigned short _address, LOWPANConvergenceLayer &cl);

                        virtual ~LOWPANConnection();

                        unsigned short _address;

                        ibrcommon::lowpanstream& getStream();

                        void run();
                        void setup();
                        void finally();
                        void __cancellation();

                        LOWPANConnectionSender _sender;

                private:
                        bool _running;
                        ibrcommon::lowpanstream _stream;
                        LOWPANConvergenceLayer &_cl;
                };
        }
}
#endif /*LOWPANCONNECTION_H_*/