5 writes to _cancellationState
System.Threading.Tasks.Dataflow (5)
Base\DataflowBlock.cs (5)
401_cancellationState = CANCELLATION_STATE_REGISTERED; 550Interlocked.CompareExchange(ref source._cancellationState, CANCELLATION_STATE_COMPLETING, CANCELLATION_STATE_REGISTERED) == CANCELLATION_STATE_REGISTERED) 649Interlocked.CompareExchange(ref _cancellationState, CANCELLATION_STATE_COMPLETING, curState) == curState)) 676Interlocked.CompareExchange(ref _cancellationState, CANCELLATION_STATE_RESERVED, CANCELLATION_STATE_REGISTERED) == CANCELLATION_STATE_REGISTERED); 698if (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)
501if (_cancellationState != CANCELLATION_STATE_NONE) 543Debug.Assert(source._cancellationState != CANCELLATION_STATE_NONE, 549if (source._cancellationState == CANCELLATION_STATE_REGISTERED && // fast check to avoid the interlocked if we can 567bool consumeToAccept = _cancellationState != CANCELLATION_STATE_NONE; 584Debug.Assert(_cancellationState == CANCELLATION_STATE_COMPLETING, 638int curState = _cancellationState; 675(_cancellationState == CANCELLATION_STATE_NONE || // avoid synchronization when cancellation is not in play 696if (_cancellationState != CANCELLATION_STATE_NONE)