Home
last modified time | relevance | path

Searched refs:setBlockToken (Results 1 – 19 of 19) sorted by relevance

/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/blockmanagement/
H A DTestBlockTokenWithDFS.java152 setBlockToken(lblock.getBlockToken()). in tryRead()
413 lblock.setBlockToken(sm.generateToken(lblock.getBlock(), in testRead()
420 lblock.setBlockToken(sm.generateToken(wrongBlock, in testRead()
425 lblock.setBlockToken(sm.generateToken(lblock.getBlock(), in testRead()
/dports/devel/hadoop/hadoop-1.2.1/src/test/org/apache/hadoop/hdfs/server/namenode/
H A DTestBlockTokenWithDFS.java350 lblock.setBlockToken(cluster.getNameNode().getNamesystem() in testRead()
357 lblock.setBlockToken(cluster.getNameNode().getNamesystem() in testRead()
363 lblock.setBlockToken(cluster.getNameNode().getNamesystem() in testRead()
/dports/devel/hadoop/hadoop-1.2.1/src/hdfs/org/apache/hadoop/hdfs/protocol/
H A DLocatedBlock.java86 public void setBlockToken(Token<BlockTokenIdentifier> token) { in setBlockToken() method in LocatedBlock
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/protocol/
H A DLocatedBlock.java122 public void setBlockToken(Token<BlockTokenIdentifier> token) { in setBlockToken() method in LocatedBlock
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/namenode/ha/
H A DTestFailoverWithBlockTokensEnabled.java134 lb.setBlockToken(newToken); in ensureInvalidBlockTokensAreRejected()
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/
H A DBlockReaderTestUtil.java186 setBlockToken(testBlock.getBlockToken()). in getBlockReader()
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/protocolPB/
H A DTestPBHelper.java465 lb.setBlockToken(new Token<BlockTokenIdentifier>( in createLocatedBlock()
482 lb.setBlockToken(new Token<BlockTokenIdentifier>( in createLocatedBlockNoStorageMedia()
/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 DTestBlockToken.java298 fakeBlock.setBlockToken(token); in testBlockTokenRpcLeak()
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/datanode/
H A DTestDataNodeVolumeFailure.java413 setBlockToken(lblock.getBlockToken()). in accessBlock()
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/
H A DBlockReaderFactory.java202 public BlockReaderFactory setBlockToken(Token<BlockTokenIdentifier> token) { in setBlockToken() method in BlockReaderFactory
H A DDFSInputStream.java663 setBlockToken(accessToken). in blockSeekTo()
1163 setBlockToken(blockToken).
/dports/devel/hadoop/hadoop-1.2.1/src/hdfs/org/apache/hadoop/hdfs/web/
H A DJsonUtil.java321 locatedblock.setBlockToken(toBlockToken((Map<?, ?>)m.get("blockToken"))); in toLocatedBlock()
/dports/devel/hadoop/hadoop-1.2.1/src/hdfs/org/apache/hadoop/hdfs/server/datanode/
H A DDataNode.java2119 b.setBlockToken(blockTokenSecretManager.generateToken(null, b.getBlock(),
2154 b.setBlockToken(blockTokenSecretManager.generateToken(null, b.getBlock(),
/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.java816 setBlockToken(lb, mode); in createLocatedBlock()
917 public void setBlockToken(final LocatedBlock b, in setBlockToken() method in BlockManager
921 b.setBlockToken(blockTokenSecretManager.generateToken( in setBlockToken()
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/web/
H A DJsonUtil.java453 locatedblock.setBlockToken(toBlockToken((Map<?, ?>)m.get("blockToken"))); in toLocatedBlock()
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/
H A DNamenodeFsck.java734 setBlockToken(lblock.getBlockToken()). in copyBlock()
H A DFSNamesystem.java3304 getBlockManager().setBlockToken( in makeLocatedBlock()
3367 blockManager.setBlockToken(lb, AccessMode.COPY); in getAdditionalDatanode()
6309 blockManager.setBlockToken(locatedBlock, AccessMode.WRITE); in updateBlockForPipeline()
/dports/devel/hadoop/hadoop-1.2.1/src/hdfs/org/apache/hadoop/hdfs/server/namenode/
H A DFSNamesystem.java1194 b.setBlockToken(accessTokenHandler.generateToken(b.getBlock(), in getBlockLocationsInternal()
1820 lb.setBlockToken(accessTokenHandler.generateToken(lb.getBlock(), in appendFile()
1956 b.setBlockToken(accessTokenHandler.generateToken(b.getBlock(), in getAdditionalBlock()
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/protocolPB/
H A DPBHelper.java796 .setBlockToken(PBHelper.convert(b.getBlockToken())) in convert()
832 lb.setBlockToken(PBHelper.convert(proto.getBlockToken())); in convert()