Code:
/ 4.0 / 4.0 / untmp / DEVDIV_TFS / Dev10 / Releases / RTMRel / ndp / fx / src / Core / System / Linq / Parallel / QueryOperators / PartitionedStreamMerger.cs / 1305376 / PartitionedStreamMerger.cs
// ==++== // // Copyright (c) Microsoft Corporation. All rights reserved. // // ==--== // =+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+ // // PartitionedStreamMerger.cs // //[....] // // =-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=- using System.Threading.Tasks; using System.Diagnostics.Contracts; namespace System.Linq.Parallel { ////// Partitioned stream recipient that will merge the results. /// internal class PartitionedStreamMerger: IPartitionedStreamRecipient { private bool m_forEffectMerge; private ParallelMergeOptions m_mergeOptions; private bool m_isOrdered; private MergeExecutor m_mergeExecutor = null; private TaskScheduler m_taskScheduler; private int m_queryId; // ID of the current query execution private CancellationState m_cancellationState; #if DEBUG private bool m_received = false; #endif // Returns the merge executor which merges the received partitioned stream. internal MergeExecutor MergeExecutor { get { #if DEBUG Contract.Assert(m_received, "Cannot return the merge executor because Receive() has not been called yet."); #endif return m_mergeExecutor; } } internal PartitionedStreamMerger(bool forEffectMerge, ParallelMergeOptions mergeOptions, TaskScheduler taskScheduler, bool outputOrdered, CancellationState cancellationState, int queryId) { m_forEffectMerge = forEffectMerge; m_mergeOptions = mergeOptions; m_isOrdered = outputOrdered; m_taskScheduler = taskScheduler; m_cancellationState = cancellationState; m_queryId = queryId; } public void Receive (PartitionedStream partitionedStream) { #if DEBUG m_received = true; #endif m_mergeExecutor = MergeExecutor .Execute ( partitionedStream, m_forEffectMerge, m_mergeOptions, m_taskScheduler, m_isOrdered, m_cancellationState, m_queryId); TraceHelpers.TraceInfo("[timing]: {0}: finished opening - QueryOperator<>::GetEnumerator", DateTime.Now.Ticks); } } } // File provided for Reference Use Only by Microsoft Corporation (c) 2007.
Link Menu
This book is available now!
Buy at Amazon US or
Buy at Amazon UK
- XPathNode.cs
- GACMembershipCondition.cs
- MinimizableAttributeTypeConverter.cs
- PeerService.cs
- BreadCrumbTextConverter.cs
- AppDomainProtocolHandler.cs
- TreeNodeCollectionEditor.cs
- PermissionRequestEvidence.cs
- DefaultEventAttribute.cs
- SHA256.cs
- QuaternionAnimation.cs
- KnownBoxes.cs
- HttpCookie.cs
- ProjectionCamera.cs
- IncrementalHitTester.cs
- DefaultAssemblyResolver.cs
- WebPartTransformerAttribute.cs
- ProbeRequestResponseAsyncResult.cs
- EnvelopedPkcs7.cs
- WindowInteractionStateTracker.cs
- HtmlInputReset.cs
- SQLDouble.cs
- BooleanFunctions.cs
- SafeHandle.cs
- AnnouncementService.cs
- NumberFormatInfo.cs
- ObjectReaderCompiler.cs
- Stream.cs
- ToolStripStatusLabel.cs
- WebPartTransformer.cs
- TextEditorTables.cs
- WriterOutput.cs
- WebErrorHandler.cs
- ColumnCollection.cs
- CommandBindingCollection.cs
- IUnknownConstantAttribute.cs
- ReferenceService.cs
- GPPOINT.cs
- TypeListConverter.cs
- Compiler.cs
- StaticExtensionConverter.cs
- HttpCachePolicyElement.cs
- ToolStripPanelRow.cs
- DocumentationServerProtocol.cs
- IteratorFilter.cs
- DataGridToolTip.cs
- IdentityHolder.cs
- FormParameter.cs
- NetPeerTcpBindingCollectionElement.cs
- NgenServicingAttributes.cs
- SourceItem.cs
- SiteMapNodeItem.cs
- XmlProcessingInstruction.cs
- RelatedCurrencyManager.cs
- _FtpDataStream.cs
- WebControlParameterProxy.cs
- CodeTypeMemberCollection.cs
- CustomAttributeBuilder.cs
- NodeLabelEditEvent.cs
- AutoResizedEvent.cs
- TreeNodeCollection.cs
- ListBase.cs
- TdsParserSessionPool.cs
- RequestStatusBarUpdateEventArgs.cs
- MetadataItemSerializer.cs
- SinglePageViewer.cs
- StaticSiteMapProvider.cs
- Message.cs
- CloseSequence.cs
- DirectoryRootQuery.cs
- BackgroundWorker.cs
- SqlErrorCollection.cs
- ObjectQueryExecutionPlan.cs
- Hashtable.cs
- CSharpCodeProvider.cs
- DrawListViewSubItemEventArgs.cs
- TextRunCacheImp.cs
- MexServiceChannelBuilder.cs
- PageHandlerFactory.cs
- RSAOAEPKeyExchangeFormatter.cs
- TableSectionStyle.cs
- MetadataExchangeBindings.cs
- OptimalTextSource.cs
- fixedPageContentExtractor.cs
- UrlMappingsModule.cs
- StreamResourceInfo.cs
- safemediahandle.cs
- CodeExpressionStatement.cs
- ObjectPersistData.cs
- ComponentCommands.cs
- StrongNameUtility.cs
- DoubleLinkList.cs
- StringDictionary.cs
- VectorCollectionValueSerializer.cs
- ColumnMapVisitor.cs
- PersonalizationStateInfo.cs
- MessageLogger.cs
- SizeValueSerializer.cs
- FolderNameEditor.cs
- InternalConfigHost.cs