/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 | 152 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 D | TestBlockTokenWithDFS.java | 350 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 D | LocatedBlock.java | 86 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 D | LocatedBlock.java | 122 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 D | TestFailoverWithBlockTokensEnabled.java | 134 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 D | BlockReaderTestUtil.java | 186 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 D | TestPBHelper.java | 465 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 D | TestBlockToken.java | 298 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 D | TestDataNodeVolumeFailure.java | 413 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 D | BlockReaderFactory.java | 202 public BlockReaderFactory setBlockToken(Token<BlockTokenIdentifier> token) { in setBlockToken() method in BlockReaderFactory
|
H A D | DFSInputStream.java | 663 setBlockToken(accessToken). in blockSeekTo() 1163 setBlockToken(blockToken).
|
/dports/devel/hadoop/hadoop-1.2.1/src/hdfs/org/apache/hadoop/hdfs/web/ |
H A D | JsonUtil.java | 321 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 D | DataNode.java | 2119 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 D | BlockManager.java | 816 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 D | JsonUtil.java | 453 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 D | NamenodeFsck.java | 734 setBlockToken(lblock.getBlockToken()). in copyBlock()
|
H A D | FSNamesystem.java | 3304 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 D | FSNamesystem.java | 1194 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 D | PBHelper.java | 796 .setBlockToken(PBHelper.convert(b.getBlockToken())) in convert() 832 lb.setBlockToken(PBHelper.convert(proto.getBlockToken())); in convert()
|