include/core/SimpleBundleStorage.h

Go to the documentation of this file.

#ifndef SIMPLEBUNDLESTORAGE_H_
#define SIMPLEBUNDLESTORAGE_H_

#include "core/BundleCore.h"
#include "core/AbstractBundleStorage.h"
#include "core/Node.h"
#include "data/Bundle.h"
#include "utils/Service.h"
#include "utils/MutexLock.h"
#include "utils/Mutex.h"
#include "utils/Conditional.h"
#include <list>
#include <map>

using namespace dtn::data;
using namespace dtn::utils;

namespace dtn
{
        namespace core
        {
                class SimpleBundleStorage : public Service, public AbstractBundleStorage
                {
                public:
                        SimpleBundleStorage(unsigned int size = 1024 * 1024, unsigned int bundle_maxsize = 1024);

                        virtual ~SimpleBundleStorage();

                        void store(const BundleSchedule &schedule);

                        Bundle* storeFragment(const Bundle &bundle);

                        BundleSchedule getSchedule(unsigned int dtntime);

                        BundleSchedule getSchedule(string destination);

                        void clear();

                        bool isEmpty();

                        unsigned int getCount();

                protected:
                        virtual void tick();

                        void terminate();

                        void eventNodeAvailable(const Node &node);
                        void eventNodeUnavailable(const Node &node);

                private:
                        list<BundleSchedule> m_schedules;
                        list<list<Bundle> > m_fragments;

                        void deleteDeprecated();

                        unsigned int m_nextdeprecation;

                        time_t m_last_compress;

                        unsigned int m_size;
                        unsigned int m_bundle_maxsize;

                        unsigned int m_currentsize;

                        bool m_nocleanup;

                        Mutex m_readlock;
                        Mutex m_fragmentslock;

                        map<string,Node> m_neighbours;
                };
        }
}

#endif /*SIMPLEBUNDLESTORAGE_H_*/

---