OrderingQueryOperator.cs source code in C# .NET

Source code for the .NET framework in C#

                        
Code:

                         / 4.0 / 4.0 / 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.
// ==++== 
//
//   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

Network programming in C#, Network Programming in VB.NET, Network Programming in .NET
This book is available now!
Buy at Amazon US or
Buy at Amazon UK