indexwritetable_v201_v301.h

Go to the documentation of this file.

 
#ifndef INDEX_WRITE_TABLE_V201_V301_CLASS_HEADER
#define INDEX_WRITE_TABLE_V201_V301_CLASS_HEADER
 
#include <ifhd/v201_v301/indexedfile_types_v201_v301.h>
 
#include <deque>
 
namespace ifhd
{
namespace v201_v301
{
 
class IndexWriteTable
{
    private:
        struct IndexTable
        {
            IndexTable():index_table_offset(0), index_count(0), last_index(0), index_offset(0) {}
            uint32_t index_table_offset;
            uint32_t index_count;
            //the timestamp of the last index entry
            timestamp_t last_index;
            //the chunk position of the last index entry
            uint64_t index_offset;
        };
 
        struct MasterIndexTable: public std::deque<ChunkRef>, public IndexTable
        {        
        };
 
        MasterIndexTable _master_index;
 
        struct StreamIndexTable: public std::deque<StreamRef>, public IndexTable
        {           
        };
 
        StreamIndexTable _stream_index_tables[max_indexed_streams + 1];
        timestamp_t _index_delay;
 
    public:
 
        void create(timestamp_t index_delay = 1000000);
 
        void free();
 
        uint16_t getMaxStreamId() const;
 
        size_t getItemCount(uint16_t stream_id) const;
 
        uint64_t getBufferSize(uint16_t stream_id) const;
 
        void copyToBuffer(uint16_t stream_id, void* buffer) const;
 
        void append(uint16_t stream_id,
                       uint64_t stream_index,
                       uint64_t chunk_index,
                       uint64_t file_pos,
                       uint32_t size,
                       timestamp_t time_stamp,
                       uint32_t flags,
                       bool& index_entry_appended);
 
        void remove(uint64_t chunk_index, uint16_t stream_id);
 
        uint64_t getIndexOffset(uint16_t stream_id) const;
 
        uint64_t getIndexTableOffset(uint16_t stream_id) const;
};
 
} // namspace v400
} // namespace
#endif // _INDEX_WRITE_TABLE_V201_V301_CLASS_HEADER_