5 writes to _cancellationState
System.Threading.Tasks.Dataflow (5)
Base\DataflowBlock.cs (5)
425_cancellationState = CANCELLATION_STATE_REGISTERED; 574Interlocked.CompareExchange(ref source._cancellationState, CANCELLATION_STATE_COMPLETING, CANCELLATION_STATE_REGISTERED) == CANCELLATION_STATE_REGISTERED) 673Interlocked.CompareExchange(ref _cancellationState, CANCELLATION_STATE_COMPLETING, curState) == curState)) 700Interlocked.CompareExchange(ref _cancellationState, CANCELLATION_STATE_RESERVED, CANCELLATION_STATE_REGISTERED) == CANCELLATION_STATE_REGISTERED); 722if (Interlocked.CompareExchange(ref _cancellationState, CANCELLATION_STATE_REGISTERED, CANCELLATION_STATE_RESERVED) != CANCELLATION_STATE_RESERVED)
8 references to _cancellationState
System.Threading.Tasks.Dataflow (8)
Base\DataflowBlock.cs (8)
525if (_cancellationState != CANCELLATION_STATE_NONE) 567Debug.Assert(source._cancellationState != CANCELLATION_STATE_NONE, 573if (source._cancellationState == CANCELLATION_STATE_REGISTERED && // fast check to avoid the interlocked if we can 591bool consumeToAccept = _cancellationState != CANCELLATION_STATE_NONE; 608Debug.Assert(_cancellationState == CANCELLATION_STATE_COMPLETING, 662int curState = _cancellationState; 699(_cancellationState == CANCELLATION_STATE_NONE || // avoid synchronization when cancellation is not in play 720if (_cancellationState != CANCELLATION_STATE_NONE)