Code:
/ 4.0 / 4.0 / untmp / DEVDIV_TFS / Dev10 / Releases / RTMRel / ndp / fx / src / Core / System / Linq / Parallel / QueryOperators / Options / OrderingQueryOperator.cs / 1305376 / OrderingQueryOperator.cs
// ==++== // // Copyright (c) Microsoft Corporation. All rights reserved. // // ==--== // =+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+ // // OrderingQueryOperator.cs // //[....] // // =-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=- using System.Collections.Generic; using System.Threading; namespace System.Linq.Parallel { ////// Represents operators AsOrdered and AsUnordered. In the current implementation, it /// simply turns on preservation globally in the query. /// ///internal sealed class OrderingQueryOperator : QueryOperator { // Turns on order (AsOrdered) or turns off order (AsUnordered) private bool m_orderOn; private QueryOperator m_child; private OrdinalIndexState m_ordinalIndexState; public OrderingQueryOperator(QueryOperator child, bool orderOn) : base(orderOn, child.SpecifiedQuerySettings) { m_child = child; m_ordinalIndexState = m_child.OrdinalIndexState; m_orderOn = orderOn; } internal override QueryResults Open(QuerySettings settings, bool preferStriping) { return m_child.Open(settings, preferStriping); } internal override IEnumerator GetEnumerator(ParallelMergeOptions? mergeOptions, bool suppressOrderPreservation) { ScanQueryOperator childAsScan = m_child as ScanQueryOperator ; if (childAsScan != null) { return childAsScan.Data.GetEnumerator(); } return base.GetEnumerator(mergeOptions, suppressOrderPreservation); } //---------------------------------------------------------------------------------------- // Returns an enumerable that represents the query executing sequentially. // internal override IEnumerable AsSequentialQuery(CancellationToken token) { return m_child.AsSequentialQuery(token); } //--------------------------------------------------------------------------------------- // Whether this operator performs a premature merge. // internal override bool LimitsParallelism { get { return m_child.LimitsParallelism; } } internal override OrdinalIndexState OrdinalIndexState { get { return m_ordinalIndexState; } } } } // 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
- GeometryModel3D.cs
- TextCharacters.cs
- TypeDescriptionProvider.cs
- StylusPointPropertyInfo.cs
- WarningException.cs
- ToolStripMenuItem.cs
- NonVisualControlAttribute.cs
- VisualStyleRenderer.cs
- NetworkInterface.cs
- ConfigXmlDocument.cs
- ImmutablePropertyDescriptorGridEntry.cs
- IDispatchConstantAttribute.cs
- ConfigXmlReader.cs
- HttpSessionStateWrapper.cs
- XhtmlBasicValidatorAdapter.cs
- PeerNameRecordCollection.cs
- OperationCanceledException.cs
- HttpPostedFileWrapper.cs
- mediapermission.cs
- KeyValueConfigurationElement.cs
- WebPartZoneCollection.cs
- XmlNamespaceMapping.cs
- StorageRoot.cs
- X509ChainPolicy.cs
- JobStaple.cs
- OperationAbortedException.cs
- ToolStripSeparator.cs
- VectorAnimationBase.cs
- SmiTypedGetterSetter.cs
- ContainerFilterService.cs
- SRGSCompiler.cs
- ImageBrush.cs
- PseudoWebRequest.cs
- NestPullup.cs
- WindowsSlider.cs
- CodeTypeParameterCollection.cs
- ListenerTraceUtility.cs
- InheritanceContextHelper.cs
- TriggerAction.cs
- ZoomPercentageConverter.cs
- ListViewDeletedEventArgs.cs
- XmlAnyElementAttributes.cs
- RemotingException.cs
- HotSpotCollection.cs
- BookmarkResumptionRecord.cs
- AsyncDataRequest.cs
- AssertFilter.cs
- ExceptionUtil.cs
- XamlSerializationHelper.cs
- IDispatchConstantAttribute.cs
- AnimationException.cs
- WebEventCodes.cs
- LostFocusEventManager.cs
- HtmlTableRowCollection.cs
- XComponentModel.cs
- ConnectionManagementSection.cs
- CodeIterationStatement.cs
- CapabilitiesState.cs
- SafeNativeMethods.cs
- EmbeddedMailObjectsCollection.cs
- Visual3D.cs
- BoundingRectTracker.cs
- SequenceDesigner.cs
- PeerFlooder.cs
- PerformanceCounterManager.cs
- ConfigurationElementCollection.cs
- TypeInfo.cs
- XPathNavigator.cs
- AutomationElementIdentifiers.cs
- MiniMapControl.xaml.cs
- DbProviderServices.cs
- SamlDelegatingWriter.cs
- cookieexception.cs
- COM2EnumConverter.cs
- FlowDocumentReaderAutomationPeer.cs
- DataSpaceManager.cs
- BrowserCapabilitiesFactoryBase.cs
- TableItemPattern.cs
- SymLanguageVendor.cs
- XmlSchemaSimpleTypeList.cs
- NonClientArea.cs
- ImageSourceValueSerializer.cs
- SystemDropShadowChrome.cs
- ConsoleCancelEventArgs.cs
- DataGridViewToolTip.cs
- ErrorWrapper.cs
- WizardStepBase.cs
- ProxyManager.cs
- AnchorEditor.cs
- SerializationFieldInfo.cs
- VolatileEnlistmentState.cs
- QuotedPrintableStream.cs
- SystemInformation.cs
- EastAsianLunisolarCalendar.cs
- TextCompositionEventArgs.cs
- NetworkInformationPermission.cs
- Attribute.cs
- FormParameter.cs
- ListViewItem.cs
- ErrorsHelper.cs