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
- TextElement.cs
- CalendarDayButton.cs
- PlaceHolder.cs
- ApplicationProxyInternal.cs
- UnionExpr.cs
- ExtractCollection.cs
- GridViewRowPresenter.cs
- ClientRuntimeConfig.cs
- WpfSharedXamlSchemaContext.cs
- SQLChars.cs
- ForeignKeyConstraint.cs
- EventMappingSettings.cs
- CompressionTracing.cs
- ConfigXmlDocument.cs
- RightsManagementPermission.cs
- DataGridViewCellParsingEventArgs.cs
- IIS7WorkerRequest.cs
- StylusPointDescription.cs
- PrintPageEvent.cs
- WebPartManager.cs
- FieldValue.cs
- CategoryState.cs
- ResourceReferenceKeyNotFoundException.cs
- FactoryId.cs
- PolyQuadraticBezierSegment.cs
- StringUtil.cs
- HttpModuleAction.cs
- WindowsClaimSet.cs
- TextSerializer.cs
- HttpInputStream.cs
- CryptoStream.cs
- BinaryFormatter.cs
- DynamicPhysicalDiscoSearcher.cs
- DecoderExceptionFallback.cs
- AspNetHostingPermission.cs
- StringCollectionEditor.cs
- AssemblySettingAttributes.cs
- XmlEncoding.cs
- SimpleHandlerBuildProvider.cs
- BaseTreeIterator.cs
- MetabaseServerConfig.cs
- PipelineModuleStepContainer.cs
- SafeThreadHandle.cs
- Wildcard.cs
- DefaultPrintController.cs
- NetMsmqSecurityElement.cs
- BitmapEffectState.cs
- CompilerErrorCollection.cs
- DynamicEndpointElement.cs
- CacheForPrimitiveTypes.cs
- Interfaces.cs
- ConnectionStringSettingsCollection.cs
- DataGridAutoFormat.cs
- Logging.cs
- Descriptor.cs
- AnimationStorage.cs
- CapabilitiesState.cs
- ParagraphVisual.cs
- MemberPath.cs
- InstancePersistenceContext.cs
- ToolBarDesigner.cs
- MemberCollection.cs
- ListViewItem.cs
- SiteMapNodeItemEventArgs.cs
- clipboard.cs
- LinqDataSourceSelectEventArgs.cs
- EntryPointNotFoundException.cs
- CapacityStreamGeometryContext.cs
- XNodeValidator.cs
- HostingEnvironmentWrapper.cs
- CommentEmitter.cs
- TransformDescriptor.cs
- WebHttpSecurity.cs
- BitmapEffectGeneralTransform.cs
- DependencyPropertyConverter.cs
- AnimatedTypeHelpers.cs
- ChangePassword.cs
- SqlInternalConnectionSmi.cs
- __FastResourceComparer.cs
- SqlConnectionManager.cs
- DispatcherHooks.cs
- ColumnResizeUndoUnit.cs
- BaseTemplateCodeDomTreeGenerator.cs
- OleStrCAMarshaler.cs
- WorkflowItemPresenter.cs
- TrackBarRenderer.cs
- SiteMapNode.cs
- StorageTypeMapping.cs
- CodeObject.cs
- SqlPersistenceWorkflowInstanceDescription.cs
- XmlImplementation.cs
- UpdatePanelTriggerCollection.cs
- InfiniteTimeSpanConverter.cs
- WmlFormAdapter.cs
- MailDefinition.cs
- BinaryNode.cs
- WsdlServiceChannelBuilder.cs
- SettingsBindableAttribute.cs
- UserControl.cs
- IODescriptionAttribute.cs