32 references to TraceHelpers
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");