BundleSet.h

Go to the documentation of this file.

/*
 * BundleSet.h
 *
 *  Created on: 18.12.2012
 *      Author: morgenro
 */

#ifndef BUNDLESET_H_
#define BUNDLESET_H_

#include "ibrdtn/data/Number.h"
#include "ibrdtn/data/MetaBundle.h"
#include <ibrcommon/data/BloomFilter.h>
#include <set>

namespace dtn
{
        namespace data
        {
                class BundleSet
                {
                public:
                        class Listener {
                        public:
                                virtual ~Listener() = 0;
                                virtual void eventBundleExpired(const dtn::data::MetaBundle&) throw () = 0;
                        };

                        BundleSet(Listener *listener = NULL, Length bf_size = 1024);
                        virtual ~BundleSet();

                        virtual void add(const dtn::data::MetaBundle &bundle) throw ();
                        virtual void clear() throw ();
                        virtual bool has(const dtn::data::BundleID &bundle) const throw ();

                        virtual void expire(const Timestamp timestamp) throw ();

                        virtual Size size() const throw ();

                        Length getLength() const throw ();

                        const ibrcommon::BloomFilter& getBloomFilter() const throw ();

                        std::set<dtn::data::MetaBundle> getNotIn(ibrcommon::BloomFilter &filter) const throw ();

                        friend std::ostream &operator<<(std::ostream &stream, const BundleSet &obj);
                        friend std::istream &operator>>(std::istream &stream, BundleSet &obj);

                private:
                        class ExpiringBundle
                        {
                        public:
                                ExpiringBundle(const MetaBundle &b);
                                virtual ~ExpiringBundle();

                                bool operator!=(const ExpiringBundle& other) const;
                                bool operator==(const ExpiringBundle& other) const;
                                bool operator<(const ExpiringBundle& other) const;
                                bool operator>(const ExpiringBundle& other) const;

                                const dtn::data::MetaBundle &bundle;
                        };

                        std::set<dtn::data::MetaBundle> _bundles;
                        std::set<ExpiringBundle> _expire;

                        ibrcommon::BloomFilter _bf;

                        Listener *_listener;

                        bool _consistent;
                };
        } /* namespace data */
} /* namespace dtn */
#endif /* BUNDLESET_H_ */