Home
last modified time | relevance | path

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 DTestDecommission.java659 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 DTestReadOnlySharedStorage.java79 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 DBlockManager.java111 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 DBlockPlacementPolicyWithNodeGroup.java45 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 DTestCacheDirectives.java1416 final DatanodeManager datanodeManager =
1420 datanodeManager.getDatanode(dn.getDatanodeId());