Deveel.Data.Transactions.TableCommitCallback Class Reference

Public Member Functions
void	AttachTo (ITransaction transaction)
void	DetachFrom (ITransaction transaction)

Protected Member Functions
	TableCommitCallback (ObjectName tableName)
abstract void	OnAction (IEnumerable< int > addedRows, IEnumerable< int > removedRows)

Package Functions
void	OnTransactionStarted ()
void	OnTransactionEnd ()

Properties
ObjectName	TableName [get, private set]
bool	IsInTransaction [get, private set]

Private Member Functions
void	Act ()
void	OnCommit (TableCommitInfo commitInfo)

Private Attributes
readonly List< int >	addedList
readonly List< int >	removedList

Detailed Description

Definition at line 24 of file TableCommitCallback.cs.

Constructor & Destructor Documentation

Deveel.Data.Transactions.TableCommitCallback.TableCommitCallback ( ObjectName  tableName )

inlineprotected

Definition at line 28 of file TableCommitCallback.cs.

                                                            {
            if (tableName == null)
                throw new ArgumentNullException("tableName");

            TableName = tableName;

            addedList = new List<int>();
            removedList = new List<int>();
        }

Member Function Documentation

void Deveel.Data.Transactions.TableCommitCallback.Act ( )

inlineprivate

Definition at line 66 of file TableCommitCallback.cs.

                           {
            IList<int> add, remove;
            lock (removedList) {
                add = new List<int>(addedList);
                remove = new List<int>(removedList);

                addedList.Clear();
                removedList.Clear();
            }

            OnAction(add, remove);
        }

void Deveel.Data.Transactions.TableCommitCallback.AttachTo ( ITransaction  transaction )

inline

Definition at line 52 of file TableCommitCallback.cs.

                                                       {
            transaction.RegisterOnCommit(OnCommit);

            if (transaction is ICallbackHandler)
                ((ICallbackHandler)transaction).OnCallbackAttached(this);
        }

void Deveel.Data.Transactions.TableCommitCallback.DetachFrom ( ITransaction  transaction )

inline

Definition at line 59 of file TableCommitCallback.cs.

                                                         {
            transaction.UnregisterOnCommit(OnCommit);

            if (transaction is ICallbackHandler)
                ((ICallbackHandler)transaction).OnCallbackDetached(this);
        }

abstract void Deveel.Data.Transactions.TableCommitCallback.OnAction ( IEnumerable< int >  addedRows, IEnumerable< int >  removedRows  )

protectedpure virtual

void Deveel.Data.Transactions.TableCommitCallback.OnCommit ( TableCommitInfo  commitInfo )

inlineprivate

Definition at line 79 of file TableCommitCallback.cs.

                                                          {
            if (TableName.Equals(commitInfo.TableName)) {
                addedList.AddRange(commitInfo.AddedRows);
                removedList.AddRange(commitInfo.RemovedRows);
            }
        }

void Deveel.Data.Transactions.TableCommitCallback.OnTransactionEnd ( )

inlinepackage

Definition at line 47 of file TableCommitCallback.cs.

                                         {
            IsInTransaction = false;
            Act();
        }

void Deveel.Data.Transactions.TableCommitCallback.OnTransactionStarted ( )

inlinepackage

Definition at line 42 of file TableCommitCallback.cs.

                                             {
            IsInTransaction = true;
            Act();
        }

Member Data Documentation

readonly List<int> Deveel.Data.Transactions.TableCommitCallback.addedList

private

Definition at line 25 of file TableCommitCallback.cs.

readonly List<int> Deveel.Data.Transactions.TableCommitCallback.removedList

private

Definition at line 26 of file TableCommitCallback.cs.

Property Documentation

bool Deveel.Data.Transactions.TableCommitCallback.IsInTransaction

getprivate setprotected

Definition at line 40 of file TableCommitCallback.cs.

ObjectName Deveel.Data.Transactions.TableCommitCallback.TableName

getprivate set

Definition at line 38 of file TableCommitCallback.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/TableCommitCallback.cs