5 writes to _numberOfOutstandingOperations
System.Threading.Tasks.Dataflow (5)
13 references to _numberOfOutstandingOperations
System.Threading.Tasks.Dataflow (13)
Internal\TargetCore.cs (13)
153Debug.Assert(_numberOfOutstandingOperations > 0 || !storeExceptionEvenIfAlreadyCompleting,
168Debug.Assert(_numberOfOutstandingOperations > 0 && (!UsesAsyncCompletion || _numberOfOutstandingServiceTasks > 0),
259Debug.Assert(_numberOfOutstandingOperations > 0, "Operations may only be completed if any are outstanding.");
260if (_numberOfOutstandingOperations > 0) _numberOfOutstandingOperations--;
295Debug.Assert(_numberOfOutstandingOperations >= 0, "Number of outstanding operations should never be negative.");
297Debug.Assert(_numberOfOutstandingOperations >= _numberOfOutstandingServiceTasks, "Number of outstanding service tasks should never exceed the number of outstanding operations.");
302return (_numberOfOutstandingOperations - _numberOfOutstandingServiceTasks) < _dataflowBlockOptions.ActualMaxDegreeOfParallelism;
311Debug.Assert(_numberOfOutstandingOperations >= 0, "Number of outstanding operations should never be negative.");
313Debug.Assert(_numberOfOutstandingOperations >= _numberOfOutstandingServiceTasks, "Number of outstanding service tasks should never exceed the number of outstanding operations.");
495Debug.Assert(_numberOfOutstandingOperations > 0, "Expected a positive number of outstanding operations, since we're completing one here.");
733bool notCurrentlyProcessing = _numberOfOutstandingOperations == 0;
758lock (IncomingLock) Debug.Assert(_numberOfOutstandingOperations == 0, "Everything must be done by now.");
865internal int CurrentDegreeOfParallelism { get { return _target._numberOfOutstandingOperations - _target._numberOfOutstandingServiceTasks; } }