Deveel.Data.Transactions.TransactionRegistry Class Reference

Inheritance diagram for Deveel.Data.Transactions.TransactionRegistry:

Public Member Functions
	TransactionRegistry (ITransaction transaction)
void	RegisterEvent (ITransactionEvent e)
IEnumerable< ITransactionEvent >	GetEvents ()
void	Dispose ()

Properties
ITransaction	Transaction [get, private set]
IEnumerable< ObjectName >	ObjectsCreated [get]
IEnumerable< ObjectName >	ObjectsDropped [get]
IEnumerable< int >	TouchedTables [get]
IEnumerable< int >	TablesCreated [get]
IEnumerable< int >	TablesDropped [get]
IEnumerable< int >	TablesConstraintAltered [get]

Private Member Functions
	~TransactionRegistry ()
void	RegisterObjectDropped (ObjectName objName)
void	RegisterObjectCreated (ObjectName objName)
void	TouchTable (int tableId)
void	Dispose (bool disposing)

Private Attributes
List< ITransactionEvent >	events
List< ObjectName >	objectsCreated
List< ObjectName >	objectsDropped
List< int >	touchedTables

Detailed Description

Definition at line 25 of file TransactionRegistry.cs.

Constructor & Destructor Documentation

Deveel.Data.Transactions.TransactionRegistry.TransactionRegistry ( ITransaction  transaction )

inline

Definition at line 31 of file TransactionRegistry.cs.

                                                             {
            Transaction = transaction;

            events = new List<ITransactionEvent>();
        }

Deveel.Data.Transactions.TransactionRegistry.~TransactionRegistry ( )

inlineprivate

Definition at line 37 of file TransactionRegistry.cs.

                               {
            Dispose(false);
        }

Member Function Documentation

void Deveel.Data.Transactions.TransactionRegistry.Dispose ( )

inline

Definition at line 185 of file TransactionRegistry.cs.

                              {
            Dispose(true);
            GC.SuppressFinalize(this);
        }

void Deveel.Data.Transactions.TransactionRegistry.Dispose ( bool  disposing )

inlineprivate

Definition at line 190 of file TransactionRegistry.cs.

                                             {
            if (disposing) {
                if (objectsCreated != null)
                    objectsCreated.Clear();

                if (objectsDropped != null)
                    objectsDropped.Clear();

                events.Clear();
            }

            objectsDropped = null;
            objectsCreated = null;
            events = null;
        }

IEnumerable<ITransactionEvent> Deveel.Data.Transactions.TransactionRegistry.GetEvents ( )

inline

Definition at line 179 of file TransactionRegistry.cs.

                                                          {
            lock (this) {
                return events.ToArray();
            }
        }

void Deveel.Data.Transactions.TransactionRegistry.RegisterEvent ( ITransactionEvent  e )

inline

Definition at line 137 of file TransactionRegistry.cs.

                                                       {
            lock (this) {
                if (e == null)
                    throw new ArgumentNullException("e");

                //if (Transaction.ReadOnly())
                //  throw new InvalidOperationException("Transaction is read-only.");

                if (e is ObjectCreatedEvent) {
                    var createdEvent = (ObjectCreatedEvent) e;
                    RegisterObjectCreated(createdEvent.ObjectName);
                } else if (e is ObjectDroppedEvent) {
                    var droppedEvent = (ObjectDroppedEvent) e;
                    RegisterObjectDropped(droppedEvent.ObjectName);
                }

                if (e is ITableEvent) {
                    var tableEvent = (ITableEvent) e;
                    TouchTable(tableEvent.TableId);
                }

                events.Add(e);
            }
        }

void Deveel.Data.Transactions.TransactionRegistry.RegisterObjectCreated ( ObjectName  objName )

inlineprivate

Definition at line 121 of file TransactionRegistry.cs.

                                                               {
            // If this table name was dropped, then remove from the drop list
            bool dropped = false;
            if (objectsDropped != null)
                dropped = objectsDropped.Remove(objName);

            // If the above operation didn't remove a table name then add to the
            // created database objects list.
            if (!dropped) {
                if (objectsCreated == null)
                    objectsCreated = new List<ObjectName>();

                objectsCreated.Add(objName);
            }
        }

void Deveel.Data.Transactions.TransactionRegistry.RegisterObjectDropped ( ObjectName  objName )

inlineprivate

Definition at line 105 of file TransactionRegistry.cs.

                                                               {
            bool created = false;

            if (objectsCreated != null)
                created = objectsCreated.Remove(objName);

            // If the above operation didn't remove a table name then add to the
            // dropped database objects list.
            if (!created) {
                if (objectsDropped == null)
                    objectsDropped = new List<ObjectName>();

                objectsDropped.Add(objName);
            }
        }

void Deveel.Data.Transactions.TransactionRegistry.TouchTable ( int  tableId )

inlineprivate

Definition at line 162 of file TransactionRegistry.cs.

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

                var index = touchedTables.LastIndexOf(tableId);
                if (index > 0 && touchedTables[index] == tableId)
                    return;

                if (index < 0) {
                    touchedTables.Add(tableId);
                } else {
                    touchedTables.Insert(index, tableId);
                }
            }
        }

Member Data Documentation

List<ITransactionEvent> Deveel.Data.Transactions.TransactionRegistry.events

private

Definition at line 26 of file TransactionRegistry.cs.

List<ObjectName> Deveel.Data.Transactions.TransactionRegistry.objectsCreated

private

Definition at line 27 of file TransactionRegistry.cs.

List<ObjectName> Deveel.Data.Transactions.TransactionRegistry.objectsDropped

private

Definition at line 28 of file TransactionRegistry.cs.

List<int> Deveel.Data.Transactions.TransactionRegistry.touchedTables

private

Definition at line 29 of file TransactionRegistry.cs.

Property Documentation

IEnumerable<ObjectName> Deveel.Data.Transactions.TransactionRegistry.ObjectsCreated

get

Definition at line 43 of file TransactionRegistry.cs.

IEnumerable<ObjectName> Deveel.Data.Transactions.TransactionRegistry.ObjectsDropped

get

Definition at line 51 of file TransactionRegistry.cs.

IEnumerable<int> Deveel.Data.Transactions.TransactionRegistry.TablesConstraintAltered

get

Definition at line 97 of file TransactionRegistry.cs.

IEnumerable<int> Deveel.Data.Transactions.TransactionRegistry.TablesCreated

get

Definition at line 67 of file TransactionRegistry.cs.

IEnumerable<int> Deveel.Data.Transactions.TransactionRegistry.TablesDropped

get

Definition at line 89 of file TransactionRegistry.cs.

IEnumerable<int> Deveel.Data.Transactions.TransactionRegistry.TouchedTables

get

Definition at line 59 of file TransactionRegistry.cs.

ITransaction Deveel.Data.Transactions.TransactionRegistry.Transaction

getprivate set

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