31 references to TraceHelpers
System.Core (31)
System\Linq\Parallel\Channels\AsynchronousChannel.cs (6)
207TraceHelpers.TraceInfo("tid {0}: AsynchronousChannel<T>::FlushBuffers() called", 221TraceHelpers.TraceInfo("tid {0}: AsynchronousChannel<T>::SetDone() called", 318TraceHelpers.TraceInfo("AsynchronousChannel::EnqueueChunk - producer waking consumer"); 359TraceHelpers.TraceInfo("AsynchronousChannel::EnqueueChunk - producer waiting, buffer full"); 581TraceHelpers.TraceInfo("AsynchronousChannel::DequeueChunk - consumer possibly waiting"); 636TraceHelpers.TraceInfo("BoundedSingleLockFreeChannel::DequeueChunk - consumer waking producer");
System\Linq\Parallel\Merging\AsynchronousChannelMergeEnumerator.cs (1)
269TraceHelpers.TraceInfo("[timing]: {0}: Completed the merge", DateTime.Now.Ticks);
System\Linq\Parallel\Merging\DefaultMergeHelper.cs (1)
60TraceHelpers.TraceInfo("DefaultMergeHelper::.ctor(..): creating a default merge helper");
System\Linq\Parallel\Merging\MergeExecutor.cs (2)
152TraceHelpers.TraceInfo("MergeExecutor::MakeChannels: setting up {0} async channels in prep for pipeline", partitionCount); 190TraceHelpers.TraceInfo("MergeExecutor::MakeChannels: setting up {0} channels in prep for stop-and-go", partitionCount);
System\Linq\Parallel\Merging\OrderPreservingMergeHelper.cs (1)
47TraceHelpers.TraceInfo("KeyOrderPreservingMergeHelper::.ctor(..): creating an order preserving merge helper");
System\Linq\Parallel\Merging\OrderPreservingPipeliningMergeHelper.cs (1)
124TraceHelpers.TraceInfo("KeyOrderPreservingMergeHelper::.ctor(..): creating an order preserving merge helper");
System\Linq\Parallel\Merging\SynchronousChannelMergeEnumerator.cs (1)
112TraceHelpers.TraceInfo("[timing]: {0}: Completed the merge", DateTime.Now.Ticks);
System\Linq\Parallel\Partitioning\PartitionedDataSource.cs (2)
128TraceHelpers.TraceInfo("ContigousRangePartitionExchangeStream::MakePartitions - (array) #{0} {1}", i, maxChunkSize); 141TraceHelpers.TraceInfo("ContigousRangePartitionExchangeStream::MakePartitions - (list) #{0} {1})", i, maxChunkSize);
System\Linq\Parallel\QueryOperators\PartitionedStreamMerger.cs (1)
67TraceHelpers.TraceInfo("[timing]: {0}: finished opening - QueryOperator<>::GetEnumerator", DateTime.Now.Ticks);
System\Linq\Parallel\QueryOperators\QueryOperator.cs (1)
183TraceHelpers.TraceInfo("[timing]: {0}: starting execution - QueryOperator<>::GetQueryResults", DateTime.Now.Ticks);
System\Linq\Parallel\Scheduling\OrderPreservingSpoolingTask.cs (2)
99TraceHelpers.TraceInfo("OrderPreservingSpoolingTask::Spool: Running partition[{0}] asynchronously", i); 106TraceHelpers.TraceInfo("OrderPreservingSpoolingTask::Spool: Running partition[{0}] synchronously", maxToRunInParallel);
System\Linq\Parallel\Scheduling\QueryTask.cs (4)
67TraceHelpers.TraceInfo("[timing]: {0}: Running work synchronously", DateTime.Now.Ticks, m_taskIndex); 86TraceHelpers.TraceInfo("[timing]: {0}: Queue work {1} to occur asynchronously", DateTime.Now.Ticks, m_taskIndex); 98TraceHelpers.TraceInfo("[timing]: {0}: Start work {1}", DateTime.Now.Ticks, m_taskIndex); 117TraceHelpers.TraceInfo("[timing]: {0}: End work {1}", DateTime.Now.Ticks, m_taskIndex);
System\Linq\Parallel\Scheduling\Scheduling.cs (1)
106TraceHelpers.TraceInfo("Scheduling::GetDefaultChunkSize({0}) -- returning {1}", typeof(T), chunkSize);
System\Linq\Parallel\Scheduling\SpoolingTask.cs (5)
55TraceHelpers.TraceInfo("SpoolingTask::Spool: Running partition[{0}] asynchronously", i); 61TraceHelpers.TraceInfo("SpoolingTask::Spool: Running partition[{0}] synchronously", maxToRunInParallel); 107TraceHelpers.TraceInfo("SpoolingTask::Spool: Running partition[{0}] asynchronously", i); 151TraceHelpers.TraceInfo("SpoolingTask::Spool: Running partition[{0}] asynchronously", i); 157TraceHelpers.TraceInfo("SpoolingTask::Spool: Running partition[{0}] synchronously", maxToRunInParallel);
System\Linq\Parallel\Utils\ExchangeUtilities.cs (2)
101TraceHelpers.TraceInfo("PartitionStream<..>.HashRepartitionStream(..):: creating **RE**partitioned stream for nested operator"); 109TraceHelpers.TraceInfo("PartitionStream<..>.HashRepartitionStream(..):: creating **RE**partitioned stream for nested operator");