Deveel.Data.Transactions.TransactionCollection Class Reference

Inheritance diagram for Deveel.Data.Transactions.TransactionCollection:

Public Member Functions
	TransactionCollection ()
void	AddTransaction (ITransaction transaction)
void	RemoveTransaction (ITransaction transaction)
long	MinimumCommitId (ITransaction transaction)
IEnumerator< ITransaction >	GetEnumerator ()
ITransaction	FindById (int commitId)

Properties
int	Count [get]

Private Member Functions
IEnumerator IEnumerable.	GetEnumerator ()

Private Attributes
readonly List< ITransaction >	transactions
long	minCommitId
long	maxCommitId

Detailed Description

Definition at line 23 of file TransactionCollection.cs.

Constructor & Destructor Documentation

Deveel.Data.Transactions.TransactionCollection.TransactionCollection ( )

inline

Definition at line 28 of file TransactionCollection.cs.

                                       {
            transactions = new List<ITransaction>();
            minCommitId = Int64.MaxValue;
            maxCommitId = 0;
        }

Member Function Documentation

void Deveel.Data.Transactions.TransactionCollection.AddTransaction ( ITransaction  transaction )

inline

Definition at line 42 of file TransactionCollection.cs.

                                                             {
            lock (this) {
                long currentCommitId = transaction.CommitId;
                if (currentCommitId < maxCommitId)
                    throw new InvalidOperationException("Added a transaction with a lower than maximum commit id");
                
                transactions.Add(transaction);
                //TODO: SystemContext.Stats.Increment(StatsDefaultKeys.OpenTransactionsCount);
                maxCommitId = currentCommitId;
            }
        }

ITransaction Deveel.Data.Transactions.TransactionCollection.FindById ( int  commitId )

inline

Definition at line 108 of file TransactionCollection.cs.

                                                   {
            lock (this) {
                return transactions.FirstOrDefault(x => x.CommitId == commitId);
            }
        }

IEnumerator<ITransaction> Deveel.Data.Transactions.TransactionCollection.GetEnumerator ( )

inline

Definition at line 98 of file TransactionCollection.cs.

                                                         {
            lock (this) {
                return transactions.GetEnumerator();
            }
        }

IEnumerator IEnumerable. Deveel.Data.Transactions.TransactionCollection.GetEnumerator ( )

inlineprivate

Definition at line 104 of file TransactionCollection.cs.

                                                {
            return GetEnumerator();
        }

long Deveel.Data.Transactions.TransactionCollection.MinimumCommitId ( ITransaction  transaction )

inline

Definition at line 79 of file TransactionCollection.cs.

                                                              {
            lock (this) {
                long commitId = Int64.MaxValue;
                if (transactions.Count > 0) {
                    // If the bottom transaction is this transaction, then go to the
                    // next up from the bottom (we don't count this transaction as the
                    // minimum commit_id).
                    var testTransaction = transactions[0];
                    if (testTransaction != transaction) {
                        commitId = testTransaction.CommitId;
                    } else if (transactions.Count > 1) {
                        commitId = transactions[1].CommitId;
                    }
                }

                return commitId;
            }
        }

void Deveel.Data.Transactions.TransactionCollection.RemoveTransaction ( ITransaction  transaction )

inline

Definition at line 54 of file TransactionCollection.cs.

                                                                {
            lock (this) {
                int size = transactions.Count;
                int i = transactions.IndexOf(transaction);
                if (i == 0) {
                    // First in list.
                    if (i == size - 1) {
                        // And last.
                        minCommitId = Int32.MaxValue;
                        maxCommitId = 0;
                    } else {
                        minCommitId = transactions[i + 1].CommitId;
                    }
                } else if (i == transactions.Count - 1) {
                    // Last in list.
                    maxCommitId = transactions[i - 1].CommitId;
                } else if (i == -1) {
                    throw new InvalidOperationException("Unable to find transaction in the list.");
                }

                transactions.RemoveAt(i);
                //TODO: SystemContext.Stats.Decrement(StatsDefaultKeys.OpenTransactionsCount);
            }
        }

Member Data Documentation

long Deveel.Data.Transactions.TransactionCollection.maxCommitId

private

Definition at line 26 of file TransactionCollection.cs.

long Deveel.Data.Transactions.TransactionCollection.minCommitId

private

Definition at line 25 of file TransactionCollection.cs.

readonly List<ITransaction> Deveel.Data.Transactions.TransactionCollection.transactions

private

Definition at line 24 of file TransactionCollection.cs.

Property Documentation

int Deveel.Data.Transactions.TransactionCollection.Count

get

Definition at line 34 of file TransactionCollection.cs.

---

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

• /var/calculate/remote/distfiles/egit-src/deveeldb.git/src/deveeldb/Deveel.Data.Transactions/TransactionCollection.cs