LOWPANConnection.h

Go to the documentation of this file.

/*
 * LOWPANConnection.h
 *
 * Copyright (C) 2011 IBR, TU Braunschweig
 *
 * Written-by: Johannes Morgenroth <morgenroth@ibr.cs.tu-bs.de>
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 *
 */

#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 dtn::net::BundleTransfer &job);
                                void run() throw ();
                                void __cancellation() throw ();

                        private:
                                ibrcommon::lowpanstream &_stream;
                                ibrcommon::Queue<dtn::net::BundleTransfer> _queue;
                };

                class LOWPANConvergenceLayer;
                class LOWPANConnection : public ibrcommon::DetachedThread
                {
                public:
                        LOWPANConnection(const ibrcommon::vaddress &_address, LOWPANConvergenceLayer &cl);

                        virtual ~LOWPANConnection();

                        const ibrcommon::vaddress _address;

                        ibrcommon::lowpanstream& getStream();

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

                        LOWPANConnectionSender _sender;

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