Deveel.Data.Sql.Tables.TableSourceGC Class Reference

Public Member Functions
	TableSourceGC (TableSource tableSource)
void	DeleteRow (int rowIndex)
void	Collect (bool force)

Private Attributes
readonly TableSource	tableSource
BlockIndex< int >	deletedRows
bool	fullSweep

Detailed Description

Definition at line 23 of file TableSourceGC.cs.

Constructor & Destructor Documentation

Deveel.Data.Sql.Tables.TableSourceGC.TableSourceGC ( TableSource  tableSource )

inline

Definition at line 32 of file TableSourceGC.cs.

                                                      {
            this.tableSource = tableSource;
            deletedRows = new BlockIndex<int>();

            // lastSuccess = DateTime.UtcNow;
            // lastTry = null;
        }

Member Function Documentation

void Deveel.Data.Sql.Tables.TableSourceGC.Collect ( bool  force )

inline

Definition at line 47 of file TableSourceGC.cs.

                                        {
            try {
                int checkCount = 0;
                int deleteCount = 0;

                // Synchronize over the master data table source so no other threads
                // can interfere when we collect this information.
                lock (tableSource) {
                    if (tableSource.IsClosed)
                        return;

                    // If root is locked, or has transaction changes pending, then we
                    // can't delete any rows marked as deleted because they could be
                    // referenced by transactions or result sets.
                    if (force ||
                        (!tableSource.IsRootLocked &&
                         !tableSource.HasChangesPending)) {

                        // lastSuccess = DateTime.Now;
                        // lastTry = null;

                        // Are we due a full sweep?
                        if (fullSweep) {
                            int rawRowCount = tableSource.RawRowCount;
                            for (int i = 0; i < rawRowCount; ++i) {
                                // Synchronized in dataSource.
                                if (tableSource.HardCheckAndReclaimRow(i))
                                    ++deleteCount;

                                ++checkCount;
                            }

                            fullSweep = false;
                        } else {
                            // Are there any rows marked as deleted?
                            int size = deletedRows.Count;
                            if (size > 0) {
                                // Go remove all rows marked as deleted.
                                foreach (int rowIndex in deletedRows) {
                                    // Synchronized in dataSource.
                                    tableSource.HardRemoveRow(rowIndex);
                                    ++deleteCount;
                                    ++checkCount;
                                }
                            }

                            deletedRows = new BlockIndex<int>();
                        }

                        if (checkCount > 0) {
                            // TODO: Emit the information to the system
                        }

                    } // if not roots locked and not transactions pending

                } // lock
            } catch (IOException) {
                // TODO: Log the error to the system
            }
        }

void Deveel.Data.Sql.Tables.TableSourceGC.DeleteRow ( int  rowIndex )

inline

Definition at line 40 of file TableSourceGC.cs.

                                            {
            if (!fullSweep) {
                if (!deletedRows.UniqueInsertSort(rowIndex))
                    throw new InvalidOperationException("Row marked twice for deletion.");
            }
        }

Member Data Documentation

BlockIndex<int> Deveel.Data.Sql.Tables.TableSourceGC.deletedRows

private

Definition at line 25 of file TableSourceGC.cs.

bool Deveel.Data.Sql.Tables.TableSourceGC.fullSweep

private

Definition at line 30 of file TableSourceGC.cs.

readonly TableSource Deveel.Data.Sql.Tables.TableSourceGC.tableSource

private

Definition at line 24 of file TableSourceGC.cs.

---

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

• /var/calculate/remote/distfiles/egit-src/deveeldb.git/src/deveeldb/Deveel.Data.Sql.Tables/TableSourceGC.cs