| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/datanode/fsdataset/impl/ |
| H A D | LazyPersistTestCase.java | 126 LocatedBlocks locatedBlocks = in ensureFileReplicasOnStorageType() local
141 LocatedBlocks locatedBlocks) throws IOException, InterruptedException { in ensureLazyPersistBlocksAreSaved()
348 LocatedBlocks locatedBlocks) { in verifyBlockDeletedFromDir()
372 protected final boolean verifyDeletedBlocks(LocatedBlocks locatedBlocks) in verifyDeletedBlocks()
|
| H A D | TestLazyPersistFiles.java | 191 LocatedBlocks locatedBlocks = in testFallbackToDiskPartial() local
316 LocatedBlocks locatedBlocks = ensureFileReplicasOnStorageType(path, RAM_DISK); in testLazyPersistBlocksAreSaved() local
471 LocatedBlocks locatedBlocks = in testDeleteBeforePersist() local
497 LocatedBlocks locatedBlocks = ensureFileReplicasOnStorageType(path, RAM_DISK); in testDeleteAfterPersist() local
|
| /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 | TestBlockReplacement.java | 129 List<LocatedBlock> locatedBlocks = client.getNamenode(). in testBlockReplacement() local
224 LocatedBlocks locatedBlocks = dfs.getClient().getLocatedBlocks(file.toString(), 0); in testBlockMoveAcrossStorageInSameNode() local
389 List<LocatedBlock> locatedBlocks = client.getNamenode(). in testDeletedBlockWhenAddBlockIsInEdit() local
|
| H A D | TestBlockHasMultipleReplicasOnSameDN.java | 101 LocatedBlocks locatedBlocks = client.getLocatedBlocks( in testBlockHasMultipleReplicasOnSameDN() local
|
| H A D | TestDataNodeVolumeFailure.java | 362 List<LocatedBlock> locatedBlocks = in triggerFailure() local
459 List<LocatedBlock> locatedBlocks = in countNNBlocks() local
|
| H A D | TestReadOnlySharedStorage.java | 178 LocatedBlocks locatedBlocks = client.getLocatedBlocks(PATH.toString(), 0, BLOCK_SIZE); in getLocatedBlock() local
|
| /dports/devel/hadoop/hadoop-1.2.1/src/test/org/apache/hadoop/hdfs/server/datanode/ |
| H A D | TestDataNodeVolumeFailure.java | 196 List<LocatedBlock> locatedBlocks = nn.getBlockLocations(path, 0, size).getLocatedBlocks(); in triggerFailure() local
273 List<LocatedBlock> locatedBlocks = in countNNBlocks() local
|
| H A D | TestBlockReplacement.java | 112 List<LocatedBlock> locatedBlocks = client.namenode. in testBlockReplacement() local
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/ |
| H A D | TestLeaseRecovery2.java | 297 LocatedBlocks locatedBlocks; in testHardLeaseRecovery() local
509 LocatedBlocks locatedBlocks; in hardLeaseRecoveryRestartHelper() local
|
| H A D | TestGetBlocks.java | 209 List<LocatedBlock> locatedBlocks; in testGetBlocks() local
|
| H A D | TestClientReportBadBlock.java | 232 final LocatedBlocks locatedBlocks = dfs.dfs.getNamenode() in verifyFirstBlockCorrupted() local
|
| H A D | TestBlockReaderFactory.java | 466 final List<LocatedBlock> locatedBlocks = in testPurgingClosedReplicas() local
|
| H A D | TestEncryptedTransfer.java | 580 List<LocatedBlock> locatedBlocks = DFSTestUtil.getAllBlocks(in); in testEncryptedAppendRequiringBlockTransfer() local
|
| /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 | TestBlockUnderConstruction.java | 78 BlockLocation[] locatedBlocks; in writeFile() local
|
| /dports/devel/hadoop/hadoop-1.2.1/src/test/org/apache/hadoop/hdfs/ |
| H A D | TestGetBlocks.java | 160 List<LocatedBlock> locatedBlocks; in testGetBlocks() local
|
| /dports/devel/hadoop/hadoop-1.2.1/src/test/org/apache/hadoop/hdfs/server/namenode/ |
| H A D | TestBlockTokenWithDFS.java | 321 List<LocatedBlock> locatedBlocks = cluster.getNameNode().getBlockLocations( in testRead() local
|
| /dports/devel/hadoop/hadoop-1.2.1/src/test/org/apache/hadoop/hdfs/server/balancer/ |
| H A D | TestBalancer.java | 92 List<LocatedBlock> locatedBlocks = client. in generateBlocks() local
|
| /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 | TestBlockTokenWithDFS.java | 384 List<LocatedBlock> locatedBlocks = nnProto.getBlockLocations( in testRead() local
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/ |
| H A D | BlockStorageLocationUtil.java | 91 List<LocatedBlock> locatedBlocks = entry.getValue(); in createVolumeBlockLocationCallables() local
|
| H A D | DFSInputStream.java | 116 private LocatedBlocks locatedBlocks = null; field in DFSInputStream
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/balancer/ |
| H A D | TestBalancerWithMultipleNameNodes.java | 110 final List<LocatedBlock> locatedBlocks = s.clients[n].getBlockLocations( in generateBlocks() local
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/security/token/block/ |
| H A D | TestBlockToken.java | 399 LocatedBlocks locatedBlocks = cluster.getNameNodeRpc().getBlockLocations( in testBlockTokenInLastLocatedBlock() local
|
| /dports/devel/hadoop/hadoop-1.2.1/src/hdfs/org/apache/hadoop/hdfs/web/ |
| H A D | JsonUtil.java | 382 final List<LocatedBlock> locatedBlocks = toLocatedBlockList( in toLocatedBlocks() local
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/mover/ |
| H A D | Mover.java | 364 final LocatedBlocks locatedBlocks = status.getBlockLocations(); in processFile() local
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/web/ |
| H A D | JsonUtil.java | 516 final List<LocatedBlock> locatedBlocks = toLocatedBlockList( in toLocatedBlocks() local
|