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
- SoapProtocolReflector.cs
- ResponseStream.cs
- Button.cs
- TextTreePropertyUndoUnit.cs
- IgnoreFileBuildProvider.cs
- ConstantProjectedSlot.cs
- SvcMapFile.cs
- DesignerTransactionCloseEvent.cs
- MsmqVerifier.cs
- DropShadowBitmapEffect.cs
- AlternateView.cs
- RemoteWebConfigurationHostStream.cs
- FileLogRecord.cs
- ArrayWithOffset.cs
- BlobPersonalizationState.cs
- TextTrailingWordEllipsis.cs
- UIPropertyMetadata.cs
- AlignmentYValidation.cs
- ObjectDataSourceSelectingEventArgs.cs
- RtType.cs
- AsyncDataRequest.cs
- KnownIds.cs
- SiteOfOriginContainer.cs
- CryptoApi.cs
- OdbcEnvironment.cs
- GPStream.cs
- BinaryWriter.cs
- initElementDictionary.cs
- SendMailErrorEventArgs.cs
- HostingPreferredMapPath.cs
- CharEnumerator.cs
- DataGridViewBindingCompleteEventArgs.cs
- AlphaSortedEnumConverter.cs
- RowToFieldTransformer.cs
- MessageSecurityOverHttpElement.cs
- GeometryValueSerializer.cs
- ToolboxComponentsCreatingEventArgs.cs
- DataGridViewRowsAddedEventArgs.cs
- XmlObjectSerializerReadContextComplexJson.cs
- HttpRuntimeSection.cs
- DataGridPageChangedEventArgs.cs
- UnionExpr.cs
- Point4D.cs
- EncodingTable.cs
- smtpconnection.cs
- querybuilder.cs
- InputScopeConverter.cs
- sqlstateclientmanager.cs
- IconBitmapDecoder.cs
- DataSetViewSchema.cs
- FileSystemInfo.cs
- MarkedHighlightComponent.cs
- ObjectDataSource.cs
- LZCodec.cs
- GridItem.cs
- BaseParser.cs
- SyndicationPerson.cs
- PartialTrustHelpers.cs
- SQLSingle.cs
- IntSecurity.cs
- ImportCatalogPart.cs
- AudienceUriMode.cs
- PropertySourceInfo.cs
- Hashtable.cs
- IPAddressCollection.cs
- ResourceDefaultValueAttribute.cs
- oledbmetadatacollectionnames.cs
- XPathException.cs
- GroupItem.cs
- EditorZone.cs
- XmlHierarchyData.cs
- MSAANativeProvider.cs
- PropagatorResult.cs
- AssemblyNameProxy.cs
- StringBuilder.cs
- LayoutUtils.cs
- DLinqColumnProvider.cs
- BufferedReadStream.cs
- RegisteredArrayDeclaration.cs
- HtmlWindow.cs
- DataServiceProviderWrapper.cs
- SyndicationSerializer.cs
- XmlSchemaImport.cs
- ResolveDuplex11AsyncResult.cs
- SafeArrayRankMismatchException.cs
- PersonalizationAdministration.cs
- CaseStatement.cs
- UInt32.cs
- HttpCookieCollection.cs
- AttributeProviderAttribute.cs
- Int32KeyFrameCollection.cs
- DrawingImage.cs
- Crc32.cs
- DataGridViewCellToolTipTextNeededEventArgs.cs
- DynamicRenderer.cs
- TypedElement.cs
- MessagePartSpecification.cs
- FixedSOMElement.cs
- HtmlInputControl.cs
- CommandBinding.cs