Deveel.Data.Transactions.Lock Class Reference

Package Functions
	Lock (LockingQueue queue, LockingMode mode, AccessType accessType)
void	Acquire ()
void	Release ()
void	CheckAccess (AccessType accessType)

Properties
LockingQueue	Queue [get, set]
AccessType	AccessType [get, private set]
LockingMode	Mode [get, private set]
bool	WasChecked [get, set]
ILockable	Lockable [get]

Private Member Functions
void	StartMode ()
void	EndMode ()

Private Attributes
bool	exclusiveMode
int	sharedAccess

Detailed Description

Definition at line 21 of file Lock.cs.

Constructor & Destructor Documentation

Deveel.Data.Transactions.Lock.Lock ( LockingQueue  queue, LockingMode  mode, AccessType  accessType  )

inlinepackage

Definition at line 25 of file Lock.cs.

                                                                                   {
            Queue = queue;
            AccessType = accessType;
            Mode = mode;
            Queue.Acquire(this);
        }

Member Function Documentation

void Deveel.Data.Transactions.Lock.Acquire ( )

inlinepackage

Definition at line 90 of file Lock.cs.

                                {
            StartMode();
        }

void Deveel.Data.Transactions.Lock.CheckAccess ( AccessType  accessType )

inlinepackage

Definition at line 101 of file Lock.cs.

                                                         {
            if (AccessType == AccessType.Write && 
                accessType != AccessType.Write)
                throw new InvalidOperationException("Access error on Lock: Tried to Write to a non Write Lock.");

            if (!WasChecked) {
                Queue.CheckAccess(this);
                WasChecked = true;
            }
        }

void Deveel.Data.Transactions.Lock.EndMode ( )

inlineprivate

Definition at line 70 of file Lock.cs.

                               {
            lock (this) {
                if (Mode == LockingMode.Exclusive) {
                    exclusiveMode = false;
                    Monitor.PulseAll(this);
                } else if (Mode == LockingMode.Shared) {
                    --sharedAccess;
                    if (sharedAccess == 0 && exclusiveMode) {
                        Monitor.PulseAll(this);
                    } else if (sharedAccess < 0) {
                        sharedAccess = 0;
                        Monitor.PulseAll(this);
                        throw new Exception("Too many 'Sahred Locks Release' calls");
                    }
                } else {
                    throw new InvalidOperationException("Invalid mode");
                }
            }
        }

void Deveel.Data.Transactions.Lock.Release ( )

inlinepackage

Definition at line 94 of file Lock.cs.

                                {
            EndMode();
            Queue.Release(this);

            // TODO: if the lock was not check, silently report the error to the system
        }

void Deveel.Data.Transactions.Lock.StartMode ( )

inlineprivate

Definition at line 44 of file Lock.cs.

                                 {
            lock (this) {
                // If currently in exclusive mode, block until not.

                while (exclusiveMode) {
                    Monitor.Wait(this);
                }

                if (Mode == LockingMode.Exclusive) {
                    // Set this thread to exclusive mode, and wait until all shared modes
                    // have completed.

                    exclusiveMode = true;
                    while (sharedAccess > 0) {
                        Monitor.Wait(this);
                    }
                } else if (Mode == LockingMode.Shared) {
                    // Increase the threads counter that are in shared mode.

                    ++sharedAccess;
                } else {
                    throw new InvalidOperationException("Invalid mode");
                }
            }
        }

Member Data Documentation

bool Deveel.Data.Transactions.Lock.exclusiveMode

private

Definition at line 22 of file Lock.cs.

int Deveel.Data.Transactions.Lock.sharedAccess

private

Definition at line 23 of file Lock.cs.

Property Documentation

AccessType Deveel.Data.Transactions.Lock.AccessType

getprivate set

Definition at line 34 of file Lock.cs.

ILockable Deveel.Data.Transactions.Lock.Lockable

getpackage

Definition at line 40 of file Lock.cs.

LockingMode Deveel.Data.Transactions.Lock.Mode

getprivate set

Definition at line 36 of file Lock.cs.

LockingQueue Deveel.Data.Transactions.Lock.Queue

getsetprivate

Definition at line 32 of file Lock.cs.

bool Deveel.Data.Transactions.Lock.WasChecked

getsetprivate

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