daemon/src/net/ConnectionManager.h

Go to the documentation of this file.

/*
 * ConnectionManager.h
 *
 *  Created on: 18.09.2009
 *      Author: morgenro
 */

#ifndef CONNECTIONMANAGER_H_
#define CONNECTIONMANAGER_H_

#include "Component.h"
#include "net/ConvergenceLayer.h"
#include "net/BundleReceiver.h"
#include "core/EventReceiver.h"
#include <ibrdtn/data/EID.h>
#include "core/Node.h"
#include <ibrcommon/Exceptions.h>

#include <set>

namespace dtn
{
        namespace net
        {
                class NeighborNotAvailableException : public ibrcommon::Exception
                {
                public:
                        NeighborNotAvailableException(string what = "The requested connection is not available.") throw() : ibrcommon::Exception(what)
                        {
                        };
                };

                class ConnectionNotAvailableException : public ibrcommon::Exception
                {
                public:
                        ConnectionNotAvailableException(string what = "The requested connection is not available.") throw() : ibrcommon::Exception(what)
                        {
                        };
                };

                class ConnectionManager : public dtn::core::EventReceiver, public dtn::daemon::IntegratedComponent
                {
                public:
                        ConnectionManager();
                        virtual ~ConnectionManager();

                        void addConnection(const dtn::core::Node &n);
                        void removeConnection(const dtn::core::Node &n);

                        void addConvergenceLayer(ConvergenceLayer *cl);

                        void queue(const dtn::data::EID &eid, const dtn::data::BundleID &b);

                        void raiseEvent(const dtn::core::Event *evt);

                        class ShutdownException : public ibrcommon::Exception
                        {
                        public:
                                ShutdownException(string what = "System shutdown") throw() : ibrcommon::Exception(what)
                                {
                                };
                        };

                        void open(const dtn::core::Node &node);

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

                        const std::set<dtn::core::Node> getNeighbors();

                        bool isNeighbor(const dtn::core::Node&);

                        const dtn::core::Node getNeighbor(const dtn::data::EID &eid);

                        virtual const std::string getName() const;

                protected:
                        void discovered(const dtn::core::Node &node);

                        virtual void componentUp();
                        virtual void componentDown();

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

                        void check_unavailable();

                        void check_autoconnect();

                        dtn::core::Node& getNode(const dtn::data::EID &eid);

                        // if set to true, this module will shutdown
                        bool _shutdown;

                        // mutex for the list of convergence layers
                        ibrcommon::Mutex _cl_lock;

                        // contains all configured convergence layers
                        std::set<ConvergenceLayer*> _cl;

                        // mutex for the lists of nodes
                        ibrcommon::Mutex _node_lock;

                        // contains all nodes
                        std::list<dtn::core::Node> _nodes;

                        // next timestamp for autoconnect check
                        size_t _next_autoconnect;
                };
        }
}

#endif /* CONNECTIONMANAGER_H_ */