/dports/lang/mono/mono-5.10.1.57/mcs/class/referencesource/System.Core/System/Linq/Parallel/Partitioning/ |
H A D | HashRepartitionStream.cs | 40 …private readonly IEqualityComparer<THashKey> m_keyComparer; // The optional key comparison routine. field in System.Linq.Parallel.HashRepartitionStream 55 m_keyComparer = hashKeyComparer; in HashRepartitionStream() 58 Contract.Assert(m_keyComparer == null || m_elementComparer == null); in HashRepartitionStream() 105 (m_keyComparer == null ? in GetHashCode() 107 m_keyComparer.GetHashCode(key))) % m_distributionMod; in GetHashCode()
|
H A D | PartitionedStream.cs | 39 private readonly IComparer<TKey> m_keyComparer; // Comparer for order keys. field in System.Linq.Parallel.PartitionedStream 46 m_keyComparer = keyComparer; in PartitionedStream() 93 get { return m_keyComparer; }
|
/dports/lang/mono/mono-5.10.1.57/mcs/class/referencesource/System.Core/System/Linq/Parallel/QueryOperators/Binary/ |
H A D | JoinQueryOperator.cs | 52 … private readonly IEqualityComparer<TKey> m_keyComparer; // An optional key comparison object. field in System.Linq.Parallel.JoinQueryOperator 73 m_keyComparer = keyComparer; in JoinQueryOperator() 88 …changeUtilities.HashRepartitionOrdered(leftStream, m_leftKeySelector, m_keyComparer, null, setting… in WrapPartitionedStream() 94 …ExchangeUtilities.HashRepartition(leftStream, m_leftKeySelector, m_keyComparer, null, settings.Can… in WrapPartitionedStream() 110 rightPartitionedStream, m_rightKeySelector, m_keyComparer, null, cancellationToken); in WrapPartitionedStreamHelper() 118 … leftHashStream[i], rightHashStream[i], m_resultSelector, null, m_keyComparer, cancellationToken); in WrapPartitionedStreamHelper() 142 … wrappedRightChild, m_leftKeySelector, m_rightKeySelector, m_resultSelector, m_keyComparer); in AsSequentialQuery()
|
H A D | GroupJoinQueryOperator.cs | 36 … private readonly IEqualityComparer<TKey> m_keyComparer; // An optional key comparison object. field in System.Linq.Parallel.GroupJoinQueryOperator 57 m_keyComparer = keyComparer; in GroupJoinQueryOperator() 86 …changeUtilities.HashRepartitionOrdered(leftStream, m_leftKeySelector, m_keyComparer, null, setting… in WrapPartitionedStream() 92 …ExchangeUtilities.HashRepartition(leftStream, m_leftKeySelector, m_keyComparer, null, settings.Can… in WrapPartitionedStream() 107 rightPartitionedStream, m_rightKeySelector, m_keyComparer, null, cancellationToken); in WrapPartitionedStreamHelper() 115 … leftHashStream[i], rightHashStream[i], null, m_resultSelector, m_keyComparer, cancellationToken); in WrapPartitionedStreamHelper() 132 … wrappedRightChild, m_leftKeySelector, m_rightKeySelector, m_resultSelector, m_keyComparer); in AsSequentialQuery()
|
H A D | HashJoinQueryOperatorEnumerator.cs | 46 … private readonly IEqualityComparer<THashKey> m_keyComparer; // An optional key comparison object. field in System.Linq.Parallel.HashJoinQueryOperatorEnumerator 80 m_keyComparer = keyComparer; in HashJoinQueryOperatorEnumerator() 111 …ghtHashLookup = new HashLookup<THashKey, Pair<TRightInput, ListChunk<TRightInput>>>(m_keyComparer); in MoveNext()
|
H A D | UnionQueryOperator.cs | 312 …private IComparer<ConcatKey<TLeftKey, TRightKey>> m_keyComparer; // Comparer for compound order ke… field in System.Linq.Parallel.UnionQueryOperator.OrderedUnionQueryOperatorEnumerator 334 m_keyComparer = keyComparer; in OrderedUnionQueryOperatorEnumerator() 377 …if (!union.TryGetValue(wrappedElem, out oldEntry) || m_keyComparer.Compare(key, oldEntry.Second) <… in MoveNext() 394 …if (!union.TryGetValue(wrappedElem, out oldEntry) || m_keyComparer.Compare(key, oldEntry.Second) <… in MoveNext()
|
/dports/lang/mono/mono-5.10.1.57/mcs/class/referencesource/System.Core/System/Linq/Parallel/QueryOperators/Unary/ |
H A D | GroupByQueryOperator.cs | 38 … private readonly IEqualityComparer<TGroupKey> m_keyComparer; // An optional key comparison object. field in System.Linq.Parallel.GroupByQueryOperator 67 m_keyComparer = keyComparer; in GroupByQueryOperator() 121 hashStream[i], m_keyComparer, cancellationToken); in WrapPartitionedStreamHelper() 129 hashStream[i], m_keyComparer, m_elementSelector, cancellationToken); in WrapPartitionedStreamHelper() 169 … hashStream[i], m_keySelector, m_elementSelector, m_keyComparer, orderComparer, in WrapPartitionedStreamHelperOrdered() 203 return wrappedChild.GroupBy(m_keySelector, m_elementSelector, m_keyComparer); in AsSequentialQuery() 232 protected readonly IEqualityComparer<TGroupKey> m_keyComparer; // A key comparer. field in System.Linq.Parallel.GroupByQueryOperatorEnumerator 253 m_keyComparer = keyComparer; in GroupByQueryOperatorEnumerator() 462 m_keyComparer = keyComparer; in OrderedGroupByQueryOperatorEnumerator() 564 new WrapperEqualityComparer<TGroupKey>(m_keyComparer)); in BuildHashLookup() [all …]
|
H A D | TakeOrSkipWhileQueryOperator.cs | 215 private readonly IComparer<TKey> m_keyComparer; // Comparer for the order keys. field in System.Linq.Parallel.TakeOrSkipWhileQueryOperator.TakeOrSkipWhileQueryOperatorEnumerator 249 m_keyComparer = keyComparer; in TakeOrSkipWhileQueryOperatorEnumerator() 294 … if (m_updatesSeen > 0 && m_keyComparer.Compare(key, m_currentLowKey) > 0) in MoveNext() 317 …if (m_operatorState.m_updatesDone == 0 || m_keyComparer.Compare(m_operatorState.m_currentLowKey, k… in MoveNext() 359 …return m_operatorState.m_updatesDone == 0 || m_keyComparer.Compare(m_operatorState.m_currentLowKey… in MoveNext() 378 …if (m_keyComparer.Compare(m_buffer[m_bufferIndex.Value].Second, m_operatorState.m_currentLowKey) >… in MoveNext() 390 … Contract.Assert(m_keyComparer.Compare(currentKey, m_operatorState.m_currentLowKey) > 0, in MoveNext()
|
H A D | TakeOrSkipQueryOperator.cs | 157 private readonly IComparer<TKey> m_keyComparer; // Comparer for the order keys. field in System.Linq.Parallel.TakeOrSkipQueryOperator.TakeOrSkipQueryOperatorEnumerator 187 m_keyComparer = keyComparer; in TakeOrSkipQueryOperatorEnumerator() 258 … || m_keyComparer.Compare(m_buffer[m_bufferIndex.Value].Second, m_sharedIndices.MaxValue) <= 0; in MoveNext() 284 … if (m_keyComparer.Compare(m_buffer[m_bufferIndex.Value].Second, minKey) > 0) in MoveNext() 297 … Contract.Assert(m_count <= 0 || m_keyComparer.Compare(currentKey, minKey) > 0, in MoveNext()
|
H A D | FirstQueryOperator.cs | 134 private IComparer<TKey> m_keyComparer; // Comparer for the order keys field in System.Linq.Parallel.FirstQueryOperator.FirstQueryOperatorEnumerator 155 m_keyComparer = keyComparer; in FirstQueryOperatorEnumerator() 194 …if (m_operatorState.m_partitionId == -1 || m_keyComparer.Compare(candidateKey, m_operatorState.m_k… in MoveNext()
|
H A D | LastQueryOperator.cs | 130 private IComparer<TKey> m_keyComparer; // Comparer for the order keys field in System.Linq.Parallel.LastQueryOperator.LastQueryOperatorEnumerator 151 m_keyComparer = keyComparer; in LastQueryOperatorEnumerator() 199 …if (m_operatorState.m_partitionId == -1 || m_keyComparer.Compare(candidateKey, m_operatorState.m_k… in MoveNext()
|
H A D | SortQueryOperator.cs | 207 … private readonly IComparer<TSortKey> m_keyComparer; // Key comparison logic to use during sorting. field in System.Linq.Parallel.SortQueryOperatorEnumerator 222 m_keyComparer = keyComparer; in SortQueryOperatorEnumerator() 230 get { return m_keyComparer; }
|
H A D | DistinctQueryOperator.cs | 202 private IComparer<TKey> m_keyComparer; // Comparer to decide the key order. field in System.Linq.Parallel.DistinctQueryOperator.OrderedDistinctQueryOperatorEnumerator 217 m_keyComparer = keyComparer; in OrderedDistinctQueryOperatorEnumerator() 252 …if (!m_hashLookup.TryGetValue(wrappedElem, out oldEntry) || m_keyComparer.Compare(orderKey, oldEnt… in MoveNext()
|
/dports/lang/mono/mono-5.10.1.57/mcs/class/referencesource/System.Core/System/Linq/Parallel/Utils/ |
H A D | Sorting.cs | 53 private IComparer<TKey> m_keyComparer; // Comparer for the order keys field in System.Linq.Parallel.SortHelper 89 m_keyComparer = keyComparer; in SortHelper() 450 m_keyComparer.Compare(myKeysArr[myIndices[j0]], in MergeSortCooperatively() 523 m_keyComparer.Compare(leftKeys[leftIndices[j0]], in MergeSortCooperatively() 606 while (m_keyComparer.Compare(keys[indices[i]], pivotKey) < 0) i++; in QuickSort() 607 while (m_keyComparer.Compare(keys[indices[j]], pivotKey) > 0) j--; in QuickSort()
|