Searched refs:datanodeManager (Results 1 – 5 of 5) sorted by relevance
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/ |
H A D | TestDecommission.java | 659 final DatanodeManager datanodeManager = in testRecommission() local 1027 final DatanodeManager datanodeManager = in testBlocksPerInterval() local 1033 doDecomCheck(datanodeManager, decomManager, 3); in testBlocksPerInterval() 1036 doDecomCheck(datanodeManager, decomManager, 2); in testBlocksPerInterval() 1039 doDecomCheck(datanodeManager, decomManager, 1); in testBlocksPerInterval() 1042 doDecomCheck(datanodeManager, decomManager, 1); in testBlocksPerInterval() 1059 final DatanodeManager datanodeManager = in testNodesPerInterval() local 1067 doDecomCheck(datanodeManager, decomManager, 1); in testNodesPerInterval() 1071 private void doDecomCheck(DatanodeManager datanodeManager, in doDecomCheck() argument 1083 BlockManagerTestUtil.recheckDecommissionState(datanodeManager); in doDecomCheck() [all …]
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/datanode/ |
H A D | TestReadOnlySharedStorage.java | 79 private DatanodeManager datanodeManager; field in TestReadOnlySharedStorage 114 datanodeManager = blockManager.getDatanodeManager(); in setup() 122 datanodeManager.getDatanode(dataNode.getDatanodeId())), in setup() 138 …readOnlyDataNode = datanodeManager.getDatanode(cluster.getDataNodes().get(RO_NODE_INDEX).getDatano… in setup()
|
/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 | BlockManager.java | 111 private final DatanodeManager datanodeManager; field in BlockManager 281 conf, datanodeManager.getFSClusterStats(), in BlockManager() 282 datanodeManager.getNetworkTopology(), in BlockManager() 283 datanodeManager.getHost2DatanodeMap()); in BlockManager() 446 datanodeManager.activate(conf); in activate() 456 datanodeManager.close(); in close() 463 return datanodeManager; in getDatanodeManager() 484 datanodeManager.fetchDatanodes(live, dead, false); in metaSave() 1788 node = datanodeManager.getDatanode(nodeID); in processReport() 3120 delHintNode = datanodeManager.getDatanode(delHint); in addBlock() [all …]
|
H A D | BlockPlacementPolicyWithNodeGroup.java | 45 NetworkTopology clusterMap, DatanodeManager datanodeManager) { in BlockPlacementPolicyWithNodeGroup() argument
|
/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 | TestCacheDirectives.java | 1416 final DatanodeManager datanodeManager = 1420 datanodeManager.getDatanode(dn.getDatanodeId());
|