13 references to TaskLaunchedReason
System.Threading.Tasks.Dataflow (13)
Blocks\BatchBlock.cs (1)
645
_owningBatch, _nonGreedyState.TaskForInputProcessing, DataflowEtwProvider.
TaskLaunchedReason
.ProcessingInputMessages,
Blocks\BroadcastBlock.cs (2)
261
this, _boundingState.TaskForInputProcessing, DataflowEtwProvider.
TaskLaunchedReason
.ProcessingInputMessages,
838
_owningSource, _taskForOutputProcessing, DataflowEtwProvider.
TaskLaunchedReason
.OfferingOutputMessages, _messages.Count);
Blocks\BufferBlock.cs (1)
262
this, _boundingState.TaskForInputProcessing, DataflowEtwProvider.
TaskLaunchedReason
.ProcessingInputMessages,
Blocks\JoinBlock.cs (1)
1274
_ownerJoin, _taskForInputProcessing, DataflowEtwProvider.
TaskLaunchedReason
.ProcessingInputMessages,
Blocks\WriteOnceBlock.cs (1)
127
this, taskForOutputProcessing, DataflowEtwProvider.
TaskLaunchedReason
.OfferingOutputMessages, _header.IsValid ? 1 : 0);
Internal\DataflowEtwProvider.cs (4)
92
IDataflowBlock block, Task task,
TaskLaunchedReason
reason, int availableMessages)
96
Debug.Assert(reason ==
TaskLaunchedReason
.ProcessingInputMessages || reason ==
TaskLaunchedReason
.OfferingOutputMessages,
109
private void TaskLaunchedForMessageHandling(int blockId,
TaskLaunchedReason
reason, int availableMessages, int taskId)
Internal\SourceCore.cs (1)
760
_owningSource, _taskForOutputProcessing, DataflowEtwProvider.
TaskLaunchedReason
.OfferingOutputMessages, _messages.Count);
Internal\SpscTargetCore.cs (1)
177
_owningTarget, newConsumer, DataflowEtwProvider.
TaskLaunchedReason
.ProcessingInputMessages, _messages.Count);
Internal\TargetCore.cs (1)
379
_owningTarget, taskForInputProcessing, DataflowEtwProvider.
TaskLaunchedReason
.ProcessingInputMessages,