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);

    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;

    bool requiresIndex(uint16_t stream_id, timestamp_t time_stamp, uint32_t flags, uint64_t file_pos) const;
};
 
} // namespace v201_v301
} // namespace ifhd
#endif // _INDEX_WRITE_TABLE_V201_V301_CLASS_HEADER_