daemon/src/core/SQLiteBundleStorage.h

Go to the documentation of this file.

/*
 * SQLiteBundleStorage.h
 *
 *  Created on: 09.01.2010
 *      Author: Myrtus
 *
 *      Potentielle Erweiterungen:
 *              1) Zweite Tabelle für die Fragmente
 *              2)
 */

#ifndef SQLITEBUNDLESTORAGE_H_
#define SQLITEBUNDLESTORAGE_H_

#include "BundleStorage.h"
#include <sqlite3.h>
#include <string>
#include "EventReceiver.h"
#include "ibrcommon/thread/Thread.h"
#include "ibrcommon/data/File.h"
#include <set>
#include <vector>


namespace dtn {
namespace core {

class SQLiteBundleStorage: public BundleStorage, public EventReceiver, public ibrcommon::JoinableThread{
public:

        SQLiteBundleStorage(ibrcommon::File dbPath ,string dbFile , int size);

        virtual ~SQLiteBundleStorage();

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

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

        dtn::data::Bundle get(const dtn::data::EID &eid);

        void unblock(const dtn::data::EID &eid);

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

        void clear();

        bool empty();

        unsigned int count();

        void getVector(vector<dtn::data::Bundle> &bundles);

        //int availableSpace();

        void raiseEvent(const Event *evt);

        void run(void);

private:
        void storeFragment(const dtn::data::Bundle &bundle);

        sqlite3_stmt* prepareStatement(string sqlquery);

        void deleteexpired();

        bool getBundle(const dtn::data::EID &eid, dtn::data::Bundle &bundle);

        //Tablename
        const std::string _BundleTable;
        const std::string _FragmentTable;

        bool global_shutdown;
        ibrcommon::File dbPath;
        string dbFile;
        int dbSize;
        sqlite3 *database;
        ibrcommon::Conditional dbMutex, timeeventConditional;

        /*
         * This set contains unblock requests for threads blocked by get(EID)
         */
        set<data::EID> unblockEID;

        sqlite3_stmt *getTTL;
        sqlite3_stmt *getBundleByDestination;
        sqlite3_stmt *getBundleByID;
        sqlite3_stmt *getFragements;
        sqlite3_stmt *store_Bundle;
        sqlite3_stmt *store_Fragment;
        sqlite3_stmt *clearStorage;
        sqlite3_stmt *countEntries;
        sqlite3_stmt *vacuum;
        sqlite3_stmt *getROWID;
        sqlite3_stmt *removeBundle;
        sqlite3_stmt *removeFragments;

};

}
}

#endif /* SQLITEBUNDLESTORAGE_H_ */

---