| /dports/devel/hadoop/hadoop-1.2.1/src/test/org/apache/hadoop/hdfs/server/namenode/ |
| H A D | TestReplicationPolicy.java | 129 assertFalse(cluster.isOnSameRack(targets[0], targets[1])); in testChooseTarget1()
135 assertFalse(cluster.isOnSameRack(targets[0], targets[1])); in testChooseTarget1()
136 assertTrue(cluster.isOnSameRack(targets[1], targets[2])); in testChooseTarget1()
142 assertTrue(cluster.isOnSameRack(targets[1], targets[2]) || in testChooseTarget1()
143 cluster.isOnSameRack(targets[2], targets[3])); in testChooseTarget1()
144 assertFalse(cluster.isOnSameRack(targets[0], targets[2])); in testChooseTarget1()
186 assertFalse(cluster.isOnSameRack(targets[0], targets[1])); in testChooseTarget2()
196 assertTrue(cluster.isOnSameRack(targets[1], targets[2])); in testChooseTarget2()
209 cluster.isOnSameRack(targets[2], targets[3])); in testChooseTarget2()
247 assertTrue(cluster.isOnSameRack(targets[1], targets[2])); in testChooseTarget3()
[all …]
|
| H A D | TestReplicationPolicyWithNodeGroup.java | 183 assertFalse(cluster.isOnSameRack(targets[0], targets[1])); in testChooseTarget1()
189 assertFalse(cluster.isOnSameRack(targets[0], targets[1])); in testChooseTarget1()
190 assertTrue(cluster.isOnSameRack(targets[1], targets[2])); in testChooseTarget1()
197 assertTrue(cluster.isOnSameRack(targets[1], targets[2]) || in testChooseTarget1()
198 cluster.isOnSameRack(targets[2], targets[3])); in testChooseTarget1()
199 assertFalse(cluster.isOnSameRack(targets[0], targets[2])); in testChooseTarget1()
243 cluster.isOnSameRack(targets[2], targets[3])); in testChooseTarget2()
282 assertTrue(cluster.isOnSameRack(targets[1], targets[2])); in testChooseTarget3()
292 cluster.isOnSameRack(targets[2], targets[3])); in testChooseTarget3()
341 cluster.isOnSameRack(targets[1], targets[2])); in testChooseTarget4()
[all …]
|
| /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 | 294 assertFalse(isOnSameRack(targets[0], targets[1])); in testChooseTarget1()
300 assertFalse(isOnSameRack(targets[0], targets[1])); in testChooseTarget1()
301 assertTrue(isOnSameRack(targets[1], targets[2])); in testChooseTarget1()
308 assertTrue(isOnSameRack(targets[1], targets[2]) || in testChooseTarget1()
309 isOnSameRack(targets[2], targets[3])); in testChooseTarget1()
354 isOnSameRack(targets[2], targets[3])); in testChooseTarget2()
403 assertTrue(isOnSameRack(targets[1], targets[2]));
412 isOnSameRack(targets[2], targets[3]));
457 isOnSameRack(targets[1], targets[2]));
484 assertTrue(isOnSameRack(targets[1], targets[2]));
[all …]
|
| H A D | TestReplicationPolicy.java | 231 assertFalse(isOnSameRack(targets[0], targets[1])); in testChooseTarget1()
236 assertFalse(isOnSameRack(targets[0], targets[1])); in testChooseTarget1()
237 assertTrue(isOnSameRack(targets[1], targets[2])); in testChooseTarget1()
242 assertTrue(isOnSameRack(targets[1], targets[2]) || in testChooseTarget1()
243 isOnSameRack(targets[2], targets[3])); in testChooseTarget1()
244 assertFalse(isOnSameRack(targets[0], targets[2])); in testChooseTarget1()
328 assertTrue(isOnSameRack(targets[1], targets[2])); in testChooseTarget2()
341 isOnSameRack(targets[2], targets[3])); in testChooseTarget2()
390 assertTrue(isOnSameRack(targets[1], targets[2]));
400 isOnSameRack(targets[2], targets[3]));
[all …]
|
| /dports/devel/hadoop/hadoop-1.2.1/src/test/org/apache/hadoop/net/ |
| H A D | TestNetworkTopologyWithNodeGroup.java | 61 assertTrue(cluster.isOnSameRack(dataNodes[0], dataNodes[1])); in testRacks()
62 assertTrue(cluster.isOnSameRack(dataNodes[1], dataNodes[2])); in testRacks()
63 assertFalse(cluster.isOnSameRack(dataNodes[2], dataNodes[3])); in testRacks()
64 assertTrue(cluster.isOnSameRack(dataNodes[3], dataNodes[4])); in testRacks()
65 assertTrue(cluster.isOnSameRack(dataNodes[4], dataNodes[5])); in testRacks()
66 assertFalse(cluster.isOnSameRack(dataNodes[5], dataNodes[6])); in testRacks()
67 assertTrue(cluster.isOnSameRack(dataNodes[6], dataNodes[7])); in testRacks()
|
| H A D | TestNetworkTopology.java | 82 assertTrue(cluster.isOnSameRack(dataNodes[0], dataNodes[1])); in testRacks()
83 assertFalse(cluster.isOnSameRack(dataNodes[1], dataNodes[2])); in testRacks()
84 assertTrue(cluster.isOnSameRack(dataNodes[2], dataNodes[3])); in testRacks()
85 assertTrue(cluster.isOnSameRack(dataNodes[3], dataNodes[4])); in testRacks()
86 assertFalse(cluster.isOnSameRack(dataNodes[4], dataNodes[5])); in testRacks()
87 assertTrue(cluster.isOnSameRack(dataNodes[5], dataNodes[6])); in testRacks()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/net/ |
| H A D | TestNetworkTopologyWithNodeGroup.java | 68 assertTrue(cluster.isOnSameRack(dataNodes[0], dataNodes[1])); in testRacks()
69 assertTrue(cluster.isOnSameRack(dataNodes[1], dataNodes[2])); in testRacks()
70 assertFalse(cluster.isOnSameRack(dataNodes[2], dataNodes[3])); in testRacks()
71 assertTrue(cluster.isOnSameRack(dataNodes[3], dataNodes[4])); in testRacks()
72 assertTrue(cluster.isOnSameRack(dataNodes[4], dataNodes[5])); in testRacks()
73 assertFalse(cluster.isOnSameRack(dataNodes[5], dataNodes[6])); in testRacks()
74 assertTrue(cluster.isOnSameRack(dataNodes[6], dataNodes[7])); in testRacks()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/net/ |
| H A D | TestNetworkTopology.java | 118 assertTrue(cluster.isOnSameRack(dataNodes[0], dataNodes[1])); in testRacks()
119 assertFalse(cluster.isOnSameRack(dataNodes[1], dataNodes[2])); in testRacks()
120 assertTrue(cluster.isOnSameRack(dataNodes[2], dataNodes[3])); in testRacks()
121 assertTrue(cluster.isOnSameRack(dataNodes[3], dataNodes[4])); in testRacks()
122 assertFalse(cluster.isOnSameRack(dataNodes[4], dataNodes[5])); in testRacks()
123 assertTrue(cluster.isOnSameRack(dataNodes[5], dataNodes[6])); in testRacks()
|
| /dports/devel/hadoop/hadoop-1.2.1/src/test/org/apache/hadoop/hdfs/ |
| H A D | TestReplication.java | 101 boolean isOnSameRack = true, isNotOnSameRack = true; in checkFile()
110 isOnSameRack = false; in checkFile()
122 isOnSameRack = true; in checkFile()
127 if (isOnSameRack && isNotOnSameRack) break; in checkFile()
129 if (!isOnSameRack || !isNotOnSameRack) break; in checkFile()
131 assertTrue(isOnSameRack); in checkFile()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/ |
| H A D | TestReplication.java | 115 boolean isOnSameRack = true, isNotOnSameRack = true; in checkFile()
124 isOnSameRack = false; in checkFile()
136 isOnSameRack = true; in checkFile()
141 if (isOnSameRack && isNotOnSameRack) break; in checkFile()
143 if (!isOnSameRack || !isNotOnSameRack) break; in checkFile()
145 assertTrue(isOnSameRack); in checkFile()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/balancer/ |
| H A D | Matcher.java | 45 return cluster.isOnSameRack(left, right);
|
| H A D | Dispatcher.java | 264 if (cluster.isOnSameRack(loc.getDatanodeInfo(), targetDN) && addTo(loc)) { in chooseProxySource()
1016 if (cluster.isOnSameRack(sourceDn, target.getDatanodeInfo())) { in reduceNumOfRacks()
1023 if (cluster.isOnSameRack(loc.getDatanodeInfo(), target.getDatanodeInfo())) { in reduceNumOfRacks()
1034 if (g != source && cluster.isOnSameRack(g.getDatanodeInfo(), sourceDn)) { in reduceNumOfRacks()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/net/ |
| H A D | NetworkTopologyWithNodeGroup.java | 116 public boolean isOnSameRack( Node node1, Node node2) { in isOnSameRack() method in NetworkTopologyWithNodeGroup
261 } else if (isOnSameRack(reader, node)) { in getWeight()
|
| H A D | NetworkTopology.java | 633 public boolean isOnSameRack( Node node1, Node node2) { in isOnSameRack() method in NetworkTopology
865 } else if (isOnSameRack(reader, node)) { in getWeight()
|
| /dports/devel/hadoop/hadoop-1.2.1/src/core/org/apache/hadoop/net/ |
| H A D | NetworkTopologyWithNodeGroup.java | 116 public boolean isOnSameRack( Node node1, Node node2) { in isOnSameRack() method in NetworkTopologyWithNodeGroup
306 } else if (localRackNode == -1 && isOnSameRack(reader, nodes[i])) { in pseudoSortByDistance()
|
| H A D | NetworkTopology.java | 580 public boolean isOnSameRack( Node node1, Node node2) { in isOnSameRack() method in NetworkTopology
812 } else if(localRackNode == -1 && isOnSameRack(reader, nodes[i])) { in pseudoSortByDistance()
|
| /dports/devel/hadoop/hadoop-1.2.1/src/hdfs/org/apache/hadoop/hdfs/server/balancer/ |
| H A D | Balancer.java | 306 if (cluster.isOnSameRack(loc.getDatanode(), target.getDatanode())) { in chooseProxySource()
1094 return cluster.isOnSameRack(left, right);
1376 if (cluster.isOnSameRack(source.getDatanode(), target.getDatanode())) { in isGoodBlockCandidate()
1383 if (cluster.isOnSameRack(loc.datanode, target.datanode)) { in isGoodBlockCandidate()
1396 cluster.isOnSameRack(loc.datanode, source.datanode)) { in isGoodBlockCandidate()
|
| /dports/devel/hadoop/hadoop-1.2.1/src/hdfs/org/apache/hadoop/hdfs/server/namenode/ |
| H A D | BlockPlacementPolicyDefault.java | 192 if (clusterMap.isOnSameRack(results.get(0), results.get(1))) { in chooseTarget()
|
| /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 | 355 if (clusterMap.isOnSameRack(dn0, dn1)) { in chooseTarget()
|