| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/ |
| H A D | BlockPlacementPolicyDefault.java | 116 int numOfReplicas, in chooseTarget() argument
143 numOfReplicas = maxNodesAndReplicas[0]; in chooseTarget()
161 if (results.size() < numOfReplicas) { in chooseTarget()
163 numOfReplicas -= results.size(); in chooseTarget()
202 numOfReplicas = result[0]; in chooseTarget()
296 private Node chooseTarget(int numOfReplicas, in chooseTarget() argument
341 if (--numOfReplicas == 0) { in chooseTarget()
349 if (--numOfReplicas == 0) { in chooseTarget()
365 if (--numOfReplicas == 0) { in chooseTarget()
655 numOfReplicas--; in chooseRandom()
[all …]
|
| H A D | BlockPlacementPolicy.java | 72 int numOfReplicas, in chooseTarget() argument
88 int numOfReplicas, Node writer, in chooseTarget() argument
97 return chooseTarget(src, numOfReplicas, writer, in chooseTarget()
98 new ArrayList<DatanodeStorageInfo>(numOfReplicas), false, in chooseTarget()
113 int numOfReplicas); in verifyBlockPlacement() argument
|
| H A D | BlockPlacementPolicyWithNodeGroup.java | 171 protected void chooseRemoteRack(int numOfReplicas, in chooseRemoteRack() argument
182 chooseRandom(numOfReplicas, "~" + rackLocation, excludedNodes, blocksize, in chooseRemoteRack()
186 chooseRandom(numOfReplicas - (results.size() - oldNumOfReplicas), in chooseRemoteRack()
|
| H A D | BlockManager.java | 1535 final int numOfReplicas, final Node client, in chooseTarget4NewBlock() argument
1544 numOfReplicas, client, excludedNodes, blocksize, in chooseTarget4NewBlock()
2107 int numOfReplicas = blockUC.getNumExpectedLocations(); in processFirstBlockReport() local
2108 namesystem.incrementSafeBlockCount(numOfReplicas); in processFirstBlockReport()
|
| /dports/devel/hadoop/hadoop-1.2.1/src/hdfs/org/apache/hadoop/hdfs/server/namenode/ |
| H A D | BlockPlacementPolicyDefault.java | 77 int numOfReplicas, in chooseTarget() argument
86 int numOfReplicas, in chooseTarget() argument
98 int numOfReplicas, in chooseTarget() argument
108 DatanodeDescriptor[] chooseTarget(int numOfReplicas, in chooseTarget() argument
180 if (--numOfReplicas == 0) { in chooseTarget()
187 if (--numOfReplicas == 0) { in chooseTarget()
202 if (--numOfReplicas == 0) { in chooseTarget()
329 protected void chooseRemoteRack(int numOfReplicas, in chooseRemoteRack() argument
386 protected void chooseRandom(int numOfReplicas, in chooseRandom() argument
406 numOfReplicas--; in chooseRandom()
[all …]
|
| H A D | BlockPlacementPolicy.java | 59 int numOfReplicas, in chooseTarget() argument
79 int numOfReplicas, in chooseTarget() argument
102 int numOfReplicas, in chooseTarget() argument
106 return chooseTarget(srcInode.getFullPathName(), numOfReplicas, writer, in chooseTarget()
188 int numOfReplicas, in chooseTarget() argument
191 return chooseTarget(srcPath, numOfReplicas, writer, in chooseTarget()
210 int numOfReplicas, in chooseTarget() argument
214 return chooseTarget(srcPath, numOfReplicas, writer, in chooseTarget()
|
| H A D | BlockPlacementPolicyWithNodeGroup.java | 167 protected void chooseRemoteRack(int numOfReplicas, in chooseRemoteRack() argument
175 numOfReplicas, in chooseRemoteRack()
180 chooseRandom(numOfReplicas - (results.size() - oldNumOfReplicas), in chooseRemoteRack()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/blockmanagement/ |
| H A D | TestReplicationPolicyWithNodeGroup.java | 236 private DatanodeStorageInfo[] chooseTarget(int numOfReplicas) { in chooseTarget() argument
237 return chooseTarget(numOfReplicas, dataNodes[0]); in chooseTarget()
240 private DatanodeStorageInfo[] chooseTarget(int numOfReplicas, in chooseTarget() argument
242 return chooseTarget(numOfReplicas, writer, in chooseTarget()
246 private DatanodeStorageInfo[] chooseTarget(int numOfReplicas, in chooseTarget() argument
248 return chooseTarget(numOfReplicas, dataNodes[0], chosenNodes); in chooseTarget()
251 private DatanodeStorageInfo[] chooseTarget(int numOfReplicas, in chooseTarget() argument
253 return chooseTarget(numOfReplicas, writer, chosenNodes, null); in chooseTarget()
257 int numOfReplicas, in chooseTarget() argument
261 return replicator.chooseTarget(filename, numOfReplicas, writer, chosenNodes, in chooseTarget()
|
| H A D | TestReplicationPolicy.java | 251 private static DatanodeStorageInfo[] chooseTarget(int numOfReplicas) { in chooseTarget() argument
252 return chooseTarget(numOfReplicas, dataNodes[0]); in chooseTarget()
255 private static DatanodeStorageInfo[] chooseTarget(int numOfReplicas, in chooseTarget() argument
257 return chooseTarget(numOfReplicas, writer, in chooseTarget()
261 private static DatanodeStorageInfo[] chooseTarget(int numOfReplicas, in chooseTarget() argument
263 return chooseTarget(numOfReplicas, dataNodes[0], chosenNodes); in chooseTarget()
266 private static DatanodeStorageInfo[] chooseTarget(int numOfReplicas, in chooseTarget() argument
268 return chooseTarget(numOfReplicas, writer, chosenNodes, null); in chooseTarget()
271 private static DatanodeStorageInfo[] chooseTarget(int numOfReplicas, in chooseTarget() argument
277 int numOfReplicas, in chooseTarget() argument
[all …]
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/namenode/ |
| H A D | TestDeleteRace.java | 120 int numOfReplicas, in chooseTarget() argument
128 numOfReplicas, writer, chosenNodes, returnChosenNodes, excludedNodes, in chooseTarget()
|
| /dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/storage/ndb/src/kernel/blocks/dbdih/ |
| H A D | Dbdih.hpp | 2762 Uint32 numOfReplicas,
|
| H A D | DbdihMain.cpp | 25637 Uint32 numOfReplicas, in getFragmentCount() argument
25643 return numOfNodeGroups * numOfReplicas * numOfLDMs; in getFragmentCount()
25647 return numOfNodeGroups * numOfReplicas; in getFragmentCount()
|