Deveel.Data.Index.IndexBlock Class Reference

Public Member Functions
	IndexBlock (IndexSetStore indexSetStore, int indexNum, int blockSize, long startOffset)
long[]	GetBlockPointers ()
IIndex	CreateIndex ()
void	AddReference ()
void	RemoveReference ()
void	MarkAsDeleted ()
void	AddDeletedArea (long pointer)

Properties
IndexBlock	Parent [get, set]
bool	IsFreed [get, private set]
bool	IsDeleted [get, private set]
int	BlockSize [get, private set]
long	StartOffset [get, private set]

Private Member Functions
IEnumerable< IMappedBlock >	CreateMappedBlocks ()
bool	DeleteBlockChain ()

Private Attributes
readonly IndexSetStore	indexSetStore
readonly int	indexNum
readonly long	blockEntries
List< int >	deletedAreas
int	refCount

Detailed Description

Definition at line 25 of file IndexBlock.cs.

Constructor & Destructor Documentation

Deveel.Data.Index.IndexBlock.IndexBlock ( IndexSetStore  indexSetStore, int  indexNum, int  blockSize, long  startOffset  )

inline

Definition at line 34 of file IndexBlock.cs.

                                                                                                      {
            this.indexSetStore = indexSetStore;
            this.indexNum = indexNum;
            BlockSize = blockSize;
            StartOffset = startOffset;

            // Read the index count
            var indexBlockArea = indexSetStore.Store.GetArea(startOffset);
            indexBlockArea.Position = 8;
            blockEntries = indexBlockArea.ReadInt8();

            refCount = 0;
        }

Member Function Documentation

void Deveel.Data.Index.IndexBlock.AddDeletedArea ( long  pointer )

inline

Definition at line 185 of file IndexBlock.cs.

                                                 {
            lock (this) {
                if (deletedAreas == null) {
                    deletedAreas = new List<int>();
                }

                deletedAreas.Add((int)pointer);
            }
        }

void Deveel.Data.Index.IndexBlock.AddReference ( )

inline

Definition at line 142 of file IndexBlock.cs.

                                   {
            lock (this) {
                if (IsFreed)
                    throw new Exception("Assertion failed: Block was freed.");

                ++refCount;
            }
        }

IIndex Deveel.Data.Index.IndexBlock.CreateIndex ( )

inline

Definition at line 109 of file IndexBlock.cs.

                                    {
            // Create the MappedListBlock objects for this view
            var blocks = CreateMappedBlocks().Cast<IIndexBlock<int>>();
            // And return the Index
            return new StoreIndex(indexSetStore, indexNum, BlockSize, blocks);
        }

IEnumerable<IMappedBlock> Deveel.Data.Index.IndexBlock.CreateMappedBlocks ( )

inlineprivate

Definition at line 81 of file IndexBlock.cs.

                                                               {
            // Create an area for the index block pointer
            var indexBlockArea = indexSetStore.Store.GetArea(StartOffset);

            // First create the list of block entries for this list      
            var blocks = new IMappedBlock[(int) blockEntries];
            if (blockEntries != 0) {
                indexBlockArea.Position = 16;
                for (int i = 0; i < blockEntries; ++i) {
                    // NOTE: We cast to 'int' here because of internal limitations.
                    var firstEntry = indexBlockArea.ReadInt8();
                    var lastEntry = indexBlockArea.ReadInt8();
                    var blockPointer = indexBlockArea.ReadInt8();
                    var typeSize = indexBlockArea.ReadInt4();

                    //TODO: check this...
                    // size is the first 24 bits (max size = 16MB)
                    int elementCount = typeSize & 0x0FFF;
                    byte type = (byte) (ByteBuffer.URShift(typeSize, 24) & 0x0F);

                    blocks[i] = StoreIndex.NewMappedBlock(indexSetStore, firstEntry, lastEntry, blockPointer, elementCount, type,
                        BlockSize);
                }
            }

            return blocks;
        }

bool Deveel.Data.Index.IndexBlock.DeleteBlockChain ( )

inlineprivate

Definition at line 116 of file IndexBlock.cs.

                                        {
            bool parentDeleted = true;
            if (Parent != null) {
                parentDeleted = Parent.DeleteBlockChain();
                if (parentDeleted) {
                    Parent = null;
                }
            }

            // If the parent is deleted,
            if (parentDeleted) {
                // Can we delete this block?
                if (refCount <= 0) {
                    if (IsDeleted && deletedAreas != null) {
                        indexSetStore.DeleteAreas(deletedAreas);
                    }
                    deletedAreas = null;
                } else {
                    // We can't delete this block so return false
                    return false;
                }
            }

            return parentDeleted;
        }

long [] Deveel.Data.Index.IndexBlock.GetBlockPointers ( )

inline

Definition at line 58 of file IndexBlock.cs.

                                         {
            // Create an area for the index block pointer
            var indexBlockArea = indexSetStore.Store.GetArea(StartOffset);

            // First create the list of block entries for this list      
            long[] blocks = new long[(int)blockEntries];
            if (blockEntries != 0) {
                indexBlockArea.Position = 16;

                for (int i = 0; i < blockEntries; ++i) {
                    // NOTE: We cast to 'int' here because of internal limitations.
                    indexBlockArea.ReadInt8();
                    indexBlockArea.ReadInt8();
                    long elementP = indexBlockArea.ReadInt8();
                    indexBlockArea.ReadInt4();

                    blocks[i] = elementP;
                }
            }

            return blocks;
        }

void Deveel.Data.Index.IndexBlock.MarkAsDeleted ( )

inline

Definition at line 179 of file IndexBlock.cs.

                                    {
            lock (this) {
                IsDeleted = true;
            }
        }

void Deveel.Data.Index.IndexBlock.RemoveReference ( )

inline

Definition at line 151 of file IndexBlock.cs.

                                      {
            bool pendingDelete = false;
            lock (this) {
                --refCount;
                if (refCount <= 0) {
                    if (IsFreed)
                        throw new Exception("Assertion failed: remove reference called too many times.");

                    if (!IsDeleted && deletedAreas != null)
                        throw new Exception("Assertion failed: not deleted and with deleted areas");

                    IsFreed = true;

                    if (IsDeleted) {
                        AddDeletedArea(StartOffset);
                        // Delete these areas
                        pendingDelete = true;
                    }
                }
            } // lock(this)

            if (pendingDelete) {
                lock (indexSetStore.Store) {
                    DeleteBlockChain();
                }
            }
        }

Member Data Documentation

readonly long Deveel.Data.Index.IndexBlock.blockEntries

private

Definition at line 28 of file IndexBlock.cs.

List<int> Deveel.Data.Index.IndexBlock.deletedAreas

private

Definition at line 30 of file IndexBlock.cs.

readonly int Deveel.Data.Index.IndexBlock.indexNum

private

Definition at line 27 of file IndexBlock.cs.

readonly IndexSetStore Deveel.Data.Index.IndexBlock.indexSetStore

private

Definition at line 26 of file IndexBlock.cs.

int Deveel.Data.Index.IndexBlock.refCount

private

Definition at line 32 of file IndexBlock.cs.

Property Documentation

int Deveel.Data.Index.IndexBlock.BlockSize

getprivate set

Definition at line 54 of file IndexBlock.cs.

bool Deveel.Data.Index.IndexBlock.IsDeleted

getprivate set

Definition at line 52 of file IndexBlock.cs.

bool Deveel.Data.Index.IndexBlock.IsFreed

getprivate set

Definition at line 50 of file IndexBlock.cs.

IndexBlock Deveel.Data.Index.IndexBlock.Parent

getset

Definition at line 48 of file IndexBlock.cs.

long Deveel.Data.Index.IndexBlock.StartOffset

getprivate set

Definition at line 56 of file IndexBlock.cs.

---

The documentation for this class was generated from the following file:

• /var/calculate/remote/distfiles/egit-src/deveeldb.git/src/deveeldb/Deveel.Data.Index/IndexBlock.cs