TryEnterWriteLockCore()

bool System.Threading.ReaderWriterLockSlim.TryEnterWriteLockCore ( TimeoutTracker timeout )

inlineprivate

Definition at line 595 of file ReaderWriterLockSlim.cs.

    {
        if (_fDisposed)
        {
            throw new ObjectDisposedException(null);
        }
        int currentManagedThreadId = Environment.CurrentManagedThreadId;
        bool flag = false;
        ReaderWriterCount threadRWCount;
        if (!_fIsReentrant)
        {
            if (currentManagedThreadId == _writeLockOwnerId)
            {
                throw new LockRecursionException(SR.LockRecursionException_RecursiveWriteNotAllowed);
            }
            EnterSpinLockReason reason;
            if (currentManagedThreadId == _upgradeLockOwnerId)
            {
                flag = true;
                reason = EnterSpinLockReason.UpgradeToWrite;
            }
            else
            {
                reason = EnterSpinLockReason.EnterWrite;
            }
            _spinLock.Enter(reason);
            threadRWCount = GetThreadRWCount(dontAllocate: true);
            if (threadRWCount != null && threadRWCount.readercount > 0)
            {
                _spinLock.Exit();
                throw new LockRecursionException(SR.LockRecursionException_WriteAfterReadNotAllowed);
            }
        }
        else
        {
            EnterSpinLockReason reason2 = ((currentManagedThreadId == _writeLockOwnerId) ? EnterSpinLockReason.EnterRecursiveWrite : ((currentManagedThreadId != _upgradeLockOwnerId) ? EnterSpinLockReason.EnterWrite : EnterSpinLockReason.UpgradeToWrite));
            _spinLock.Enter(reason2);
            threadRWCount = GetThreadRWCount(dontAllocate: false);
            if (currentManagedThreadId == _writeLockOwnerId)
            {
                threadRWCount.writercount++;
                _spinLock.Exit();
                return true;
            }
            if (currentManagedThreadId == _upgradeLockOwnerId)
            {
                flag = true;
            }
            else if (threadRWCount.readercount > 0)
            {
                _spinLock.Exit();
                throw new LockRecursionException(SR.LockRecursionException_WriteAfterReadNotAllowed);
            }
        }
        bool flag2 = true;
        int num = 0;
        while (true)
        {
            if (IsWriterAcquired())
            {
                SetWriterAcquired();
                break;
            }
            if (flag)
            {
                uint numReaders = GetNumReaders();
                if (numReaders == 1)
                {
                    SetWriterAcquired();
                    break;
                }
                if (numReaders == 2 && threadRWCount != null)
                {
                    if (IsRwHashEntryChanged(threadRWCount))
                    {
                        threadRWCount = GetThreadRWCount(dontAllocate: false);
                    }
                    if (threadRWCount.readercount > 0)
                    {
                        SetWriterAcquired();
                        break;
                    }
                }
            }
            if (timeout.IsExpired)
            {
                _spinLock.Exit();
                return false;
            }
            if (num < 20 && ShouldSpinForEnterAnyWrite(flag))
            {
                _spinLock.Exit();
                num++;
                SpinWait(num);
                _spinLock.Enter(flag ? EnterSpinLockReason.UpgradeToWrite : EnterSpinLockReason.EnterWrite);
            }
            else if (flag)
            {
                if (_waitUpgradeEvent == null)
                {
                    LazyCreateEvent(ref _waitUpgradeEvent, EnterLockType.UpgradeToWrite);
                }
                else if (!WaitOnEvent(_waitUpgradeEvent, ref _numWriteUpgradeWaiters, timeout, EnterLockType.UpgradeToWrite))
                {
                    return false;
                }
            }
            else if (_writeEvent == null)
            {
                LazyCreateEvent(ref _writeEvent, EnterLockType.Write);
            }
            else if (!WaitOnEvent(_writeEvent, ref _numWriteWaiters, timeout, EnterLockType.Write))
            {
                return false;
            }
        }
        if (_fIsReentrant)
        {
            if (IsRwHashEntryChanged(threadRWCount))
            {
                threadRWCount = GetThreadRWCount(dontAllocate: false);
            }
            threadRWCount.writercount++;
        }
        _spinLock.Exit();
        _writeLockOwnerId = currentManagedThreadId;
        return true;
    }

References System.Threading.ReaderWriterLockSlim._fDisposed, System.Threading.ReaderWriterLockSlim._fIsReentrant, System.Threading.ReaderWriterLockSlim._numWriteUpgradeWaiters, System.Threading.ReaderWriterLockSlim._numWriteWaiters, System.Threading.ReaderWriterLockSlim._spinLock, System.Threading.ReaderWriterLockSlim._upgradeLockOwnerId, System.Threading.ReaderWriterLockSlim._waitUpgradeEvent, System.Threading.ReaderWriterLockSlim._writeEvent, System.Threading.ReaderWriterLockSlim._writeLockOwnerId, System.Environment.CurrentManagedThreadId, System.Threading.ReaderWriterLockSlim.SpinLock.Enter(), System.Threading.ReaderWriterLockSlim.SpinLock.Exit(), System.Threading.ReaderWriterLockSlim.GetNumReaders(), System.Threading.ReaderWriterLockSlim.GetThreadRWCount(), System.Threading.ReaderWriterLockSlim.IsRwHashEntryChanged(), System.Threading.ReaderWriterLockSlim.IsWriterAcquired(), System.Threading.ReaderWriterLockSlim.LazyCreateEvent(), System.SR.LockRecursionException_RecursiveWriteNotAllowed, System.SR.LockRecursionException_WriteAfterReadNotAllowed, System.Threading.ReaderWriterCount.readercount, System.Threading.ReaderWriterLockSlim.SetWriterAcquired(), System.Threading.ReaderWriterLockSlim.ShouldSpinForEnterAnyWrite(), System.Threading.ReaderWriterLockSlim.SpinWait(), System.timeout, System.Threading.ReaderWriterLockSlim.WaitOnEvent(), and System.Threading.ReaderWriterCount.writercount.

Referenced by System.Threading.ReaderWriterLockSlim.TryEnterWriteLock().