daemon/src/routing/NeighborDatabase.h

Go to the documentation of this file.

/*
 * NeighborDatabase.h
 *
 *  Created on: 23.07.2010
 *      Author: morgenro
 */

#ifndef NEIGHBORDATABASE_H_
#define NEIGHBORDATABASE_H_

#include <ibrdtn/data/EID.h>
#include <ibrdtn/data/BundleID.h>
#include <ibrcommon/data/BloomFilter.h>
#include <ibrcommon/Exceptions.h>
#include <map>

namespace dtn
{
        namespace routing
        {
                class NeighborDatabase
                {
                public:
                        class BloomfilterNotAvailableException : public ibrcommon::Exception
                        {
                        public:
                                BloomfilterNotAvailableException(const dtn::data::EID &host)
                                : ibrcommon::Exception("Bloom filter is not available for this node."), eid(host) { };

                                virtual ~BloomfilterNotAvailableException() throw () { };

                                const dtn::data::EID eid;
                        };

                        class NoMoreTransfersAvailable : public ibrcommon::Exception
                        {
                        public:
                                NoMoreTransfersAvailable() : ibrcommon::Exception("No more transfers allowed.") { };
                                virtual ~NoMoreTransfersAvailable() throw () { };
                        };

                        class NeighborEntry
                        {
                        public:
                                NeighborEntry();
                                NeighborEntry(const dtn::data::EID &eid);
                                ~NeighborEntry();

                                void updateLastSeen();
                                void updateBundles(const ibrcommon::BloomFilter &bf);

                                dtn::data::EID _eid;
                                ibrcommon::BloomFilter _filter;
                                size_t _filter_age;
                                size_t _lastseen;
                                size_t _lastupdate;
                                bool _available;

                                void acquireTransfer() throw (NoMoreTransfersAvailable);
                                void releaseTransfer();

                        private:
                                ibrcommon::Mutex _transfer_lock;
                                size_t _transfer_semaphore;
                                size_t _transfer_max;
                        };

                        NeighborDatabase();
                        virtual ~NeighborDatabase();

                        void updateBundles(const dtn::data::EID &eid, const ibrcommon::BloomFilter &bf);

                        bool knowBundle(const dtn::data::EID &eid, const dtn::data::BundleID &bundle) throw (BloomfilterNotAvailableException);

                        void setAvailable(const dtn::data::EID &eid);
                        void setUnavailable(const dtn::data::EID &eid);

                        const std::set<dtn::data::EID> getAvailable() const;

                        NeighborDatabase::NeighborEntry& get(const dtn::data::EID &eid);

                private:
                        std::map<dtn::data::EID, NeighborDatabase::NeighborEntry> _entries;
                };
        }
}

#endif /* NEIGHBORDATABASE_H_ */