32 references to TraceInfo
System.Linq.Parallel (32)
System\Linq\Parallel\Channels\AsynchronousChannel.cs (6)
206
TraceHelpers.
TraceInfo
("tid {0}: AsynchronousChannel<T>::FlushBuffers() called",
220
TraceHelpers.
TraceInfo
("tid {0}: AsynchronousChannel<T>::SetDone() called",
314
TraceHelpers.
TraceInfo
("AsynchronousChannel::EnqueueChunk - producer waking consumer");
356
TraceHelpers.
TraceInfo
("AsynchronousChannel::EnqueueChunk - producer waiting, buffer full");
576
TraceHelpers.
TraceInfo
("AsynchronousChannel::DequeueChunk - consumer possibly waiting");
629
TraceHelpers.
TraceInfo
("BoundedSingleLockFreeChannel::DequeueChunk - consumer waking producer");
System\Linq\Parallel\Merging\AsynchronousChannelMergeEnumerator.cs (1)
268
TraceHelpers.
TraceInfo
("[timing]: {0}: Completed the merge", DateTime.Now.Ticks);
System\Linq\Parallel\Merging\DefaultMergeHelper.cs (1)
56
TraceHelpers.
TraceInfo
("DefaultMergeHelper::.ctor(..): creating a default merge helper");
System\Linq\Parallel\Merging\MergeExecutor.cs (2)
152
TraceHelpers.
TraceInfo
("MergeExecutor::MakeChannels: setting up {0} async channels in prep for pipeline", partitionCount);
190
TraceHelpers.
TraceInfo
("MergeExecutor::MakeChannels: setting up {0} channels in prep for stop-and-go", partitionCount);
System\Linq\Parallel\Merging\OrderPreservingMergeHelper.cs (1)
43
TraceHelpers.
TraceInfo
("KeyOrderPreservingMergeHelper::.ctor(..): creating an order preserving merge helper");
System\Linq\Parallel\Merging\OrderPreservingPipeliningMergeHelper.cs (1)
124
TraceHelpers.
TraceInfo
("KeyOrderPreservingMergeHelper::.ctor(..): creating an order preserving merge helper");
System\Linq\Parallel\Merging\SynchronousChannelMergeEnumerator.cs (1)
106
TraceHelpers.
TraceInfo
("[timing]: {0}: Completed the merge", DateTime.Now.Ticks);
System\Linq\Parallel\Partitioning\PartitionedDataSource.cs (2)
121
TraceHelpers.
TraceInfo
("ContiguousRangePartitionExchangeStream::MakePartitions - (array) #{0} {1}", i, maxChunkSize);
134
TraceHelpers.
TraceInfo
("ContiguousRangePartitionExchangeStream::MakePartitions - (list) #{0} {1})", i, maxChunkSize);
System\Linq\Parallel\QueryOperators\Binary\HashJoinQueryOperatorEnumerator.cs (1)
276
TraceHelpers.
TraceInfo
("HashLookupBuilder::BuildBaseHashLookup - built hash table [count = {0}, collisions = {1}]",
System\Linq\Parallel\QueryOperators\PartitionedStreamMerger.cs (1)
63
TraceHelpers.
TraceInfo
("[timing]: {0}: finished opening - QueryOperator<>::GetEnumerator", DateTime.Now.Ticks);
System\Linq\Parallel\QueryOperators\QueryOperator.cs (1)
175
TraceHelpers.
TraceInfo
("[timing]: {0}: starting execution - QueryOperator<>::GetQueryResults", DateTime.Now.Ticks);
System\Linq\Parallel\Scheduling\OrderPreservingSpoolingTask.cs (2)
95
TraceHelpers.
TraceInfo
("OrderPreservingSpoolingTask::Spool: Running partition[{0}] asynchronously", i);
102
TraceHelpers.
TraceInfo
("OrderPreservingSpoolingTask::Spool: Running partition[{0}] synchronously", maxToRunInParallel);
System\Linq\Parallel\Scheduling\QueryTask.cs (4)
63
TraceHelpers.
TraceInfo
("[timing]: {0}: Running work synchronously", DateTime.Now.Ticks, _taskIndex);
83
TraceHelpers.
TraceInfo
("[timing]: {0}: Queue work {1} to occur asynchronously", DateTime.Now.Ticks, _taskIndex);
95
TraceHelpers.
TraceInfo
("[timing]: {0}: Start work {1}", DateTime.Now.Ticks, _taskIndex);
108
TraceHelpers.
TraceInfo
("[timing]: {0}: End work {1}", DateTime.Now.Ticks, _taskIndex);
System\Linq\Parallel\Scheduling\Scheduling.cs (1)
92
TraceHelpers.
TraceInfo
("Scheduling::GetDefaultChunkSize({0}) -- returning {1}", typeof(T), chunkSize);
System\Linq\Parallel\Scheduling\SpoolingTask.cs (5)
50
TraceHelpers.
TraceInfo
("SpoolingTask::Spool: Running partition[{0}] asynchronously", i);
56
TraceHelpers.
TraceInfo
("SpoolingTask::Spool: Running partition[{0}] synchronously", maxToRunInParallel);
105
TraceHelpers.
TraceInfo
("SpoolingTask::Spool: Running partition[{0}] asynchronously", i);
148
TraceHelpers.
TraceInfo
("SpoolingTask::Spool: Running partition[{0}] asynchronously", i);
154
TraceHelpers.
TraceInfo
("SpoolingTask::Spool: Running partition[{0}] synchronously", maxToRunInParallel);
System\Linq\Parallel\Utils\ExchangeUtilities.cs (2)
93
TraceHelpers.
TraceInfo
("PartitionStream<..>.HashRepartitionStream(..):: creating **RE**partitioned stream for nested operator");
101
TraceHelpers.
TraceInfo
("PartitionStream<..>.HashRepartitionStream(..):: creating **RE**partitioned stream for nested operator");