DeliveryPredictabilityMap.h

Go to the documentation of this file.

/*
 * DeliveryPredictabilityMap.h
 *
 *  Created on: 08.01.2013
 *      Author: morgenro
 */

#ifndef DELIVERYPREDICTABILITYMAP_H_
#define DELIVERYPREDICTABILITYMAP_H_

#include "routing/NeighborDataset.h"
#include "routing/NodeHandshake.h"
#include <ibrdtn/data/EID.h>
#include <ibrcommon/thread/Mutex.h>
#include <map>

namespace dtn
{
        namespace routing
        {
                class DeliveryPredictabilityMap : public NeighborDataSetImpl, public NodeHandshakeItem, public ibrcommon::Mutex {
                public:
                        static const dtn::data::Number identifier;

                        DeliveryPredictabilityMap();
                        DeliveryPredictabilityMap(const size_t &time_unit, const float &beta, const float &gamma);
                        virtual ~DeliveryPredictabilityMap();

                        virtual const dtn::data::Number& getIdentifier() const; 
                        virtual dtn::data::Length getLength() const; 
                        virtual std::ostream& serialize(std::ostream& stream) const; 
                        virtual std::istream& deserialize(std::istream& stream); 

                        class ValueNotFoundException : public ibrcommon::Exception
                        {
                        public:
                                ValueNotFoundException()
                                : ibrcommon::Exception("The requested value is not available.") { };

                                virtual ~ValueNotFoundException() throw () { };
                        };

                        float get(const dtn::data::EID &neighbor) const throw (ValueNotFoundException);
                        void set(const dtn::data::EID &neighbor, float value);
                        void clear();
                        size_t size() const;

                        void update(const dtn::data::EID &origin, const DeliveryPredictabilityMap &dpm, const float &p_encounter_first);

                        void age(const float &p_first_threshold);

                        void toString(std::ostream &stream) const;

                        friend std::ostream& operator<<(std::ostream& stream, const DeliveryPredictabilityMap& map);

                        void store(std::ostream &output) const;

                        void restore(std::istream &input);

                private:
                        typedef std::map<dtn::data::EID, float> predictmap;
                        predictmap _predictmap;

                        float _beta; 
                        float _gamma; 

                        dtn::data::Timestamp _lastAgingTime; 
                        size_t _time_unit; 

                };
        } /* namespace routing */
} /* namespace dtn */
#endif /* DELIVERYPREDICTABILITYMAP_H_ */