SimpleBundleStorage.h

Go to the documentation of this file.

/*
 * SimpleBundleStorage.h
 *
 * Copyright (C) 2011 IBR, TU Braunschweig
 *
 * Written-by: Johannes Morgenroth <morgenroth@ibr.cs.tu-bs.de>
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 *
 */

#ifndef SIMPLEBUNDLESTORAGE_H_
#define SIMPLEBUNDLESTORAGE_H_

#include "Component.h"
#include "core/BundleCore.h"
#include "storage/BundleStorage.h"
#include "core/Node.h"
#include "core/EventReceiver.h"

#include "storage/DataStorage.h"
#include "storage/MetaStorage.h"

#include <ibrcommon/thread/Conditional.h>
#include <ibrcommon/thread/AtomicCounter.h>
#include <ibrcommon/thread/RWMutex.h>

#include <ibrcommon/data/File.h>
#include <ibrdtn/data/Bundle.h>
#include <ibrdtn/data/BundleList.h>
#include <ibrcommon/thread/Queue.h>

#include <set>
#include <map>

namespace dtn
{
        namespace storage
        {
                class SimpleBundleStorage : public DataStorage::Callback, public BundleStorage, public dtn::core::EventReceiver, public dtn::daemon::IntegratedComponent, public dtn::data::BundleList::Listener
                {
                        static const std::string TAG;

                public:
                        SimpleBundleStorage(const ibrcommon::File &workdir, const dtn::data::Length maxsize = 0, const unsigned int buffer_limit = 0);

                        virtual ~SimpleBundleStorage();

                        virtual void store(const dtn::data::Bundle &bundle);

                        virtual dtn::data::Bundle get(const dtn::data::BundleID &id);

                        virtual void get(const BundleSelector &cb, BundleResult &result) throw (NoBundleFoundException, BundleSelectorException);

                        virtual const eid_set getDistinctDestinations();

                        void remove(const dtn::data::BundleID &id);

                        dtn::data::MetaBundle remove(const ibrcommon::BloomFilter &filter);

                        void clear();

                        bool empty();

                        dtn::data::Size count();

                        void releaseCustody(const dtn::data::EID &custodian, const dtn::data::BundleID &id);

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

                        virtual const std::string getName() const;

                        virtual void eventDataStorageStored(const dtn::storage::DataStorage::Hash &hash);
                        virtual void eventDataStorageStoreFailed(const dtn::storage::DataStorage::Hash &hash, const ibrcommon::Exception&);
                        virtual void eventDataStorageRemoved(const dtn::storage::DataStorage::Hash &hash);
                        virtual void eventDataStorageRemoveFailed(const dtn::storage::DataStorage::Hash &hash, const ibrcommon::Exception&);
                        virtual void iterateDataStorage(const dtn::storage::DataStorage::Hash &hash, dtn::storage::DataStorage::istream &stream);

                        /*** BEGIN: methods for unit-testing ***/

                        virtual void wait();

                        virtual void setFaulty(bool mode);

                        /*** END: methods for unit-testing ***/

                protected:
                        virtual void componentUp() throw ();
                        virtual void componentDown() throw ();
                        virtual void eventBundleExpired(const dtn::data::MetaBundle &b) throw ();

                private:
                        class BundleContainer : public DataStorage::Container
                        {
                        public:
                                BundleContainer(const dtn::data::Bundle &b);
                                virtual ~BundleContainer();

                                std::string getKey() const;
                                std::ostream& serialize(std::ostream &stream);

                        private:
                                const dtn::data::Bundle _bundle;
                        };

                        void __remove(const dtn::data::MetaBundle &meta);
                        void __store(const dtn::data::Bundle &bundle, const dtn::data::Length &bundle_size);

                        typedef std::map<DataStorage::Hash, dtn::data::Bundle> pending_map;
                        ibrcommon::RWMutex _pending_lock;
                        pending_map _pending_bundles;

                        // This object manages data stored on disk
                        DataStorage _datastore;

                        // stores all the meta data in memory
                        ibrcommon::RWMutex _meta_lock;
                        MetaStorage _metastore;
                };
        }
}

#endif /*SIMPLEBUNDLESTORAGE_H_*/