| /dports/lang/mono/mono-5.10.1.57/mcs/class/referencesource/System.Core/System/Linq/Parallel/Partitioning/ |
| H A D | OrderedHashRepartitionStream.cs | 24 … : base(inputStream.PartitionCount, inputStream.KeyComparer, hashKeyComparer, elementComparer) in OrderedHashRepartitionStream()
27 …ew OrderedHashRepartitionEnumerator<TInputOutput, THashKey, TOrderKey>[inputStream.PartitionCount]; in OrderedHashRepartitionStream()
31 CountdownEvent barrier = new CountdownEvent(inputStream.PartitionCount); in OrderedHashRepartitionStream()
33 …ew ListChunk<Pair<TInputOutput, THashKey>>[inputStream.PartitionCount, inputStream.PartitionCount]; in OrderedHashRepartitionStream()
34 …yExchangeMatrix = new ListChunk<TOrderKey>[inputStream.PartitionCount, inputStream.PartitionCount]; in OrderedHashRepartitionStream()
37 for (int i = 0; i < inputStream.PartitionCount; i++) in OrderedHashRepartitionStream()
40 inputStream[i], inputStream.PartitionCount, i, hashKeySelector, this, barrier, in OrderedHashRepartitionStream()
|
| H A D | UnorderedHashRepartitionStream.cs | 30 … : base(inputStream.PartitionCount, Util.GetDefaultComparer<int>(), keyComparer, elementComparer) in UnorderedHashRepartitionStream()
33 …ns = new HashRepartitionEnumerator<TInputOutput, THashKey, TIgnoreKey>[inputStream.PartitionCount]; in UnorderedHashRepartitionStream()
37 CountdownEvent barrier = new CountdownEvent(inputStream.PartitionCount); in UnorderedHashRepartitionStream()
39 …ew ListChunk<Pair<TInputOutput, THashKey>>[inputStream.PartitionCount, inputStream.PartitionCount]; in UnorderedHashRepartitionStream()
42 for (int i = 0; i < inputStream.PartitionCount; i++) in UnorderedHashRepartitionStream()
45 inputStream[i], inputStream.PartitionCount, i, keySelector, this, in UnorderedHashRepartitionStream()
|
| /dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Linq.Parallel/src/System/Linq/Parallel/Partitioning/ |
| H A D | OrderedHashRepartitionStream.cs | 21 … : base(inputStream.PartitionCount, inputStream.KeyComparer, hashKeyComparer, elementComparer) in OrderedHashRepartitionStream()
24 …ew OrderedHashRepartitionEnumerator<TInputOutput, THashKey, TOrderKey>[inputStream.PartitionCount]; in OrderedHashRepartitionStream()
28 CountdownEvent barrier = new CountdownEvent(inputStream.PartitionCount); in OrderedHashRepartitionStream()
30 …nk<Pair<TInputOutput, THashKey>>>.Allocate(inputStream.PartitionCount, inputStream.PartitionCount); in OrderedHashRepartitionStream()
32 …JaggedArray<ListChunk<TOrderKey>>.Allocate(inputStream.PartitionCount, inputStream.PartitionCount); in OrderedHashRepartitionStream()
35 for (int i = 0; i < inputStream.PartitionCount; i++) in OrderedHashRepartitionStream()
38 inputStream[i], inputStream.PartitionCount, i, hashKeySelector, this, barrier, in OrderedHashRepartitionStream()
|
| H A D | UnorderedHashRepartitionStream.cs | 26 … : base(inputStream.PartitionCount, Util.GetDefaultComparer<int>(), keyComparer, elementComparer) in UnorderedHashRepartitionStream()
29 …ns = new HashRepartitionEnumerator<TInputOutput, THashKey, TIgnoreKey>[inputStream.PartitionCount]; in UnorderedHashRepartitionStream()
33 CountdownEvent barrier = new CountdownEvent(inputStream.PartitionCount); in UnorderedHashRepartitionStream()
35 …nk<Pair<TInputOutput, THashKey>>>.Allocate(inputStream.PartitionCount, inputStream.PartitionCount); in UnorderedHashRepartitionStream()
38 for (int i = 0; i < inputStream.PartitionCount; i++) in UnorderedHashRepartitionStream()
41 inputStream[i], inputStream.PartitionCount, i, keySelector, this, in UnorderedHashRepartitionStream()
|
| /dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/mysql-test/suite/ndb/t/ |
| H A D | ndb_fk_addnode.test | 13 --replace_regex /FragmentCount:/FragmentCount/ /PartitionCount:/PartitionCount/ /HashMap:/HashMap/ …
15 --replace_regex /FragmentCount:/FragmentCount/ /PartitionCount:/PartitionCount/ /HashMap:/HashMap/ …
33 --replace_regex /FragmentCount:/FragmentCount/ /PartitionCount:/PartitionCount/ /HashMap:/HashMap/ …
35 --replace_regex /FragmentCount:/FragmentCount/ /PartitionCount:/PartitionCount/ /HashMap:/HashMap/ …
|
| /dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/mysql-test/suite/ndb/r/ |
| H A D | ndb_addnode.result | 41 PartitionCount: 8
44 PartitionCount: 8
47 PartitionCount: 8
50 PartitionCount: 8
53 PartitionCount: 8
56 PartitionCount: 8
97 PartitionCount: 16
100 PartitionCount: 16
103 PartitionCount: 16
106 PartitionCount: 16
[all …]
|
| H A D | ndb_addnode_withbinlog.result | 67 PartitionCount: 8
70 PartitionCount: 8
73 PartitionCount: 8
76 PartitionCount: 8
79 PartitionCount: 8
82 PartitionCount: 8
122 PartitionCount: 16
125 PartitionCount: 16
140 PartitionCount: 8
143 PartitionCount: 8
[all …]
|
| /dports/lang/mono/mono-5.10.1.57/mcs/class/referencesource/System.Core/System/Linq/Parallel/Merging/ |
| H A D | DefaultMergeHelper.cs | 69 if (partitions.PartitionCount > 1) in DefaultMergeHelper()
72 …MergeExecutor<TInputOutput>.MakeAsynchronousChannels(partitions.PartitionCount, options, consumerE… in DefaultMergeHelper()
85 … MergeExecutor<TInputOutput>.MakeSynchronousChannels(partitions.PartitionCount); in DefaultMergeHelper()
89 … Contract.Assert(m_asyncChannels == null || m_asyncChannels.Length == partitions.PartitionCount); in DefaultMergeHelper()
90 … Contract.Assert(m_syncChannels == null || m_syncChannels.Length == partitions.PartitionCount); in DefaultMergeHelper()
120 Contract.Assert(m_partitions.PartitionCount == 1); in Execute()
|
| /dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Linq.Parallel/src/System/Linq/Parallel/Merging/ |
| H A D | DefaultMergeHelper.cs | 66 if (partitions.PartitionCount > 1) in DefaultMergeHelper()
69 …MergeExecutor<TInputOutput>.MakeAsynchronousChannels(partitions.PartitionCount, options, consumerE… in DefaultMergeHelper()
82 … MergeExecutor<TInputOutput>.MakeSynchronousChannels(partitions.PartitionCount); in DefaultMergeHelper()
86 … Debug.Assert(_asyncChannels == null || _asyncChannels.Length == partitions.PartitionCount); in DefaultMergeHelper()
87 … Debug.Assert(_syncChannels == null || _syncChannels.Length == partitions.PartitionCount); in DefaultMergeHelper()
117 Debug.Assert(_partitions.PartitionCount == 1); in Execute()
|
| /dports/www/grafana8/grafana-8.3.6/vendor/cloud.google.com/go/pubsublite/ |
| H A D | config.go | 51 PartitionCount int member
77 Count: int64(tc.PartitionCount),
100 PartitionCount: int(partitionCfg.GetCount()),
126 PartitionCount int member
150 Count: int64(tc.PartitionCount),
164 if tc.PartitionCount > 0 {
|
| /dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/workhorse/vendor/cloud.google.com/go/pubsublite/ |
| H A D | config.go | 51 PartitionCount int member
77 Count: int64(tc.PartitionCount),
100 PartitionCount: int(partitionCfg.GetCount()),
126 PartitionCount int member
150 Count: int64(tc.PartitionCount),
164 if tc.PartitionCount > 0 {
|
| /dports/net/drive/drive-0.4.0/vendor/cloud.google.com/go/pubsublite/ |
| H A D | config.go | 51 PartitionCount int member
77 Count: int64(tc.PartitionCount),
100 PartitionCount: int(partitionCfg.GetCount()),
126 PartitionCount int member
150 Count: int64(tc.PartitionCount),
164 if tc.PartitionCount > 0 {
|
| /dports/net/rclone/rclone-1.57.0/vendor/cloud.google.com/go/pubsublite/ |
| H A D | config.go | 51 PartitionCount int member
77 Count: int64(tc.PartitionCount),
100 PartitionCount: int(partitionCfg.GetCount()),
126 PartitionCount int member
150 Count: int64(tc.PartitionCount),
164 if tc.PartitionCount > 0 {
|
| /dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/cloud.google.com/go/pubsublite/ |
| H A D | config.go | 51 PartitionCount int member
77 Count: int64(tc.PartitionCount),
100 PartitionCount: int(partitionCfg.GetCount()),
126 PartitionCount int member
150 Count: int64(tc.PartitionCount),
164 if tc.PartitionCount > 0 {
|
| /dports/www/gitlab-pages/gitlab-pages-f8512edbec4ec83b426c8ca2dda467de424685e4/vendor/cloud.google.com/go/pubsublite/ |
| H A D | config.go | 51 PartitionCount int member
77 Count: int64(tc.PartitionCount),
100 PartitionCount: int(partitionCfg.GetCount()),
126 PartitionCount int member
150 Count: int64(tc.PartitionCount),
164 if tc.PartitionCount > 0 {
|
| /dports/devel/gitlab-shell/gitlab-shell-65b8ec55bebd0aea64ac52b9878bafcc2ad992d3/vendor/cloud.google.com/go/pubsublite/ |
| H A D | config.go | 51 PartitionCount int member
77 Count: int64(tc.PartitionCount),
100 PartitionCount: int(partitionCfg.GetCount()),
126 PartitionCount int member
150 Count: int64(tc.PartitionCount),
164 if tc.PartitionCount > 0 {
|
| /dports/sysutils/restic/restic-0.12.1/vendor/cloud.google.com/go/pubsublite/ |
| H A D | config.go | 51 PartitionCount int member
77 Count: int64(tc.PartitionCount),
100 PartitionCount: int(partitionCfg.GetCount()),
126 PartitionCount int member
150 Count: int64(tc.PartitionCount),
164 if tc.PartitionCount > 0 {
|
| /dports/sysutils/restic/google-cloud-go-storage-v1.16.0/pubsublite/ |
| H A D | config.go | 51 PartitionCount int member
77 Count: int64(tc.PartitionCount),
100 PartitionCount: int(partitionCfg.GetCount()),
126 PartitionCount int member
150 Count: int64(tc.PartitionCount),
164 if tc.PartitionCount > 0 {
|
| /dports/databases/litestream/litestream-0.3.6/vendor/cloud.google.com/go/pubsublite/ |
| H A D | config.go | 51 PartitionCount int
77 Count: int64(tc.PartitionCount),
100 PartitionCount: int(partitionCfg.GetCount()),
126 PartitionCount int
150 Count: int64(tc.PartitionCount),
164 if tc.PartitionCount > 0 {
|
| /dports/databases/litestream/google-cloud-go-storage-v1.15.0/pubsublite/ |
| H A D | config.go | 51 PartitionCount int
77 Count: int64(tc.PartitionCount),
100 PartitionCount: int(partitionCfg.GetCount()),
126 PartitionCount int
150 Count: int64(tc.PartitionCount),
164 if tc.PartitionCount > 0 {
|
| /dports/www/grafana8/google-cloud-go-storage-v1.14.0/pubsublite/ |
| H A D | config.go | 51 PartitionCount int member
77 Count: int64(tc.PartitionCount),
100 PartitionCount: int(partitionCfg.GetCount()),
125 PartitionCount int member
146 Count: int64(tc.PartitionCount),
160 if tc.PartitionCount > 0 {
|
| /dports/sysutils/terraform/terraform-1.0.11/vendor/cloud.google.com/go/pubsublite/ |
| H A D | config.go | 51 PartitionCount int member
77 Count: int64(tc.PartitionCount),
100 PartitionCount: int(partitionCfg.GetCount()),
126 PartitionCount int member
150 Count: int64(tc.PartitionCount),
164 if tc.PartitionCount > 0 {
|
| /dports/www/gohugo/hugo-0.91.2/vendor/cloud.google.com/go/pubsublite/ |
| H A D | config.go | 51 PartitionCount int member
82 Count: int64(tc.PartitionCount),
110 PartitionCount: int(partitionCfg.GetCount()),
137 PartitionCount int member
166 Count: int64(tc.PartitionCount),
180 if tc.PartitionCount > 0 {
|
| /dports/www/tusd/tusd-1.8.0/vendor/cloud.google.com/go/pubsublite/ |
| H A D | config.go | 51 PartitionCount int member
82 Count: int64(tc.PartitionCount),
110 PartitionCount: int(partitionCfg.GetCount()),
137 PartitionCount int member
166 Count: int64(tc.PartitionCount),
180 if tc.PartitionCount > 0 {
|
| /dports/www/tusd/google-cloud-go-storage-v1.18.2/pubsublite/ |
| H A D | config.go | 51 PartitionCount int member
82 Count: int64(tc.PartitionCount),
110 PartitionCount: int(partitionCfg.GetCount()),
137 PartitionCount int member
166 Count: int64(tc.PartitionCount),
180 if tc.PartitionCount > 0 {
|