Author: eli
Date: Sat Nov 19 02:34:25 2011
New Revision: 1203950
URL: http://svn.apache.org/viewvc?rev=1203950&view=rev
Log:
HDFS-2564. Cleanup unnecessary exceptions thrown and unnecessary casts. Contributed by Hari
Mankude
Modified:
hadoop/common/trunk/hadoop-hdfs-project/hadoop-hdfs/CHANGES.txt
hadoop/common/trunk/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/DFSInputStream.java
hadoop/common/trunk/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/DataNode.java
hadoop/common/trunk/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/FSDataset.java
hadoop/common/trunk/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/FSNamesystem.java
hadoop/common/trunk/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/NameNode.java
Modified: hadoop/common/trunk/hadoop-hdfs-project/hadoop-hdfs/CHANGES.txt
URL: http://svn.apache.org/viewvc/hadoop/common/trunk/hadoop-hdfs-project/hadoop-hdfs/CHANGES.txt?rev=1203950&r1=1203949&r2=1203950&view=diff
==============================================================================
--- hadoop/common/trunk/hadoop-hdfs-project/hadoop-hdfs/CHANGES.txt (original)
+++ hadoop/common/trunk/hadoop-hdfs-project/hadoop-hdfs/CHANGES.txt Sat Nov 19 02:34:25 2011
@@ -52,6 +52,8 @@ Trunk (unreleased changes)
HDFS-2334. Add Closeable to JournalManager. (Ivan Kelly via jitendra)
+ HDFS-2564. Cleanup unnecessary exceptions thrown and unnecessary casts.
+ (Hari Mankude via eli)
OPTIMIZATIONS
HDFS-2477. Optimize computing the diff between a block report and the
Modified: hadoop/common/trunk/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/DFSInputStream.java
URL: http://svn.apache.org/viewvc/hadoop/common/trunk/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/DFSInputStream.java?rev=1203950&r1=1203949&r2=1203950&view=diff
==============================================================================
--- hadoop/common/trunk/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/DFSInputStream.java
(original)
+++ hadoop/common/trunk/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/DFSInputStream.java
Sat Nov 19 02:34:25 2011
@@ -543,7 +543,7 @@ public class DFSInputStream extends FSIn
if (pos > blockEnd) {
currentNode = blockSeekTo(pos);
}
- int realLen = (int) Math.min((long) len, (blockEnd - pos + 1L));
+ int realLen = (int) Math.min(len, (blockEnd - pos + 1L));
int result = readBuffer(buf, off, realLen, corruptedBlockMap);
if (result >= 0) {
Modified: hadoop/common/trunk/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/DataNode.java
URL: http://svn.apache.org/viewvc/hadoop/common/trunk/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/DataNode.java?rev=1203950&r1=1203949&r2=1203950&view=diff
==============================================================================
--- hadoop/common/trunk/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/DataNode.java
(original)
+++ hadoop/common/trunk/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/DataNode.java
Sat Nov 19 02:34:25 2011
@@ -239,8 +239,7 @@ public class DataNode extends Configured
* Use {@link NetUtils#createSocketAddr(String)} instead.
*/
@Deprecated
- public static InetSocketAddress createSocketAddr(String target
- ) throws IOException {
+ public static InetSocketAddress createSocketAddr(String target) {
return NetUtils.createSocketAddr(target);
}
@@ -334,14 +333,14 @@ public class DataNode extends Configured
}
}
- void joinAll() throws InterruptedException {
+ void joinAll() {
for (BPOfferService bpos: this.getAllNamenodeThreads()) {
bpos.join();
}
}
void refreshNamenodes(Configuration conf)
- throws IOException, InterruptedException {
+ throws IOException {
LOG.info("Refresh request received for nameservices: "
+ conf.get(DFS_FEDERATION_NAMESERVICES));
List<InetSocketAddress> newAddresses =
@@ -859,8 +858,7 @@ public class DataNode extends Configured
private void connectToNNAndHandshake() throws IOException {
// get NN proxy
- bpNamenode =
- (DatanodeProtocol)RPC.waitForProxy(DatanodeProtocol.class,
+ bpNamenode = (DatanodeProtocol)RPC.waitForProxy(DatanodeProtocol.class,
DatanodeProtocol.versionID, nnAddr, dn.getConf());
// First phase of the handshake with NN - get the namespace
@@ -2120,7 +2118,7 @@ public class DataNode extends Configured
* entire target list, the block, and the data.
*/
DataTransfer(DatanodeInfo targets[], ExtendedBlock b, BlockConstructionStage stage,
- final String clientname) throws IOException {
+ final String clientname) {
if (DataTransferProtocol.LOG.isDebugEnabled()) {
DataTransferProtocol.LOG.debug(getClass().getSimpleName() + ": "
+ b + " (numBytes=" + b.getNumBytes() + ")"
@@ -2896,13 +2894,7 @@ public class DataNode extends Configured
}
public void refreshNamenodes(Configuration conf) throws IOException {
- try {
- blockPoolManager.refreshNamenodes(conf);
- } catch (InterruptedException ex) {
- IOException eio = new IOException();
- eio.initCause(ex);
- throw eio;
- }
+ blockPoolManager.refreshNamenodes(conf);
}
@Override //ClientDatanodeProtocol
Modified: hadoop/common/trunk/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/FSDataset.java
URL: http://svn.apache.org/viewvc/hadoop/common/trunk/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/FSDataset.java?rev=1203950&r1=1203949&r2=1203950&view=diff
==============================================================================
--- hadoop/common/trunk/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/FSDataset.java
(original)
+++ hadoop/common/trunk/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/FSDataset.java
Sat Nov 19 02:34:25 2011
@@ -459,7 +459,7 @@ public class FSDataset implements FSData
long metaFileLen = metaFile.length();
int crcHeaderLen = DataChecksum.getChecksumHeaderSize();
if (!blockFile.exists() || blockFileLen == 0 ||
- !metaFile.exists() || metaFileLen < (long)crcHeaderLen) {
+ !metaFile.exists() || metaFileLen < crcHeaderLen) {
return 0;
}
checksumIn = new DataInputStream(
@@ -578,7 +578,7 @@ public class FSDataset implements FSData
* reserved capacity.
* @return the unreserved number of bytes left in this filesystem. May be zero.
*/
- long getCapacity() throws IOException {
+ long getCapacity() {
long remaining = usage.getCapacity() - reserved;
return remaining > 0 ? remaining : 0;
}
@@ -818,7 +818,7 @@ public class FSDataset implements FSData
return dfsUsed;
}
- private long getCapacity() throws IOException {
+ private long getCapacity() {
long capacity = 0L;
for (FSVolume vol : volumes) {
capacity += vol.getCapacity();
@@ -1667,7 +1667,7 @@ public class FSDataset implements FSData
}
if (!oldmeta.renameTo(newmeta)) {
replicaInfo.setGenerationStamp(oldGS); // restore old GS
- throw new IOException("Block " + (Block)replicaInfo + " reopen failed. " +
+ throw new IOException("Block " + replicaInfo + " reopen failed. " +
" Unable to move meta file " + oldmeta +
" to " + newmeta);
}
@@ -2018,7 +2018,7 @@ public class FSDataset implements FSData
/**
* Find the file corresponding to the block and return it if it exists.
*/
- File validateBlockFile(String bpid, Block b) throws IOException {
+ File validateBlockFile(String bpid, Block b) {
//Should we check for metadata file too?
File f = getFile(bpid, b);
@@ -2327,7 +2327,7 @@ public class FSDataset implements FSData
if (datanode.blockScanner != null) {
datanode.blockScanner.addBlock(new ExtendedBlock(bpid, diskBlockInfo));
}
- DataNode.LOG.warn("Added missing block to memory " + (Block)diskBlockInfo);
+ DataNode.LOG.warn("Added missing block to memory " + diskBlockInfo);
return;
}
/*
@@ -2600,7 +2600,7 @@ public class FSDataset implements FSData
* get list of all bpids
* @return list of bpids
*/
- public String [] getBPIdlist() throws IOException {
+ public String [] getBPIdlist() {
return volumeMap.getBlockPoolList();
}
Modified: hadoop/common/trunk/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/FSNamesystem.java
URL: http://svn.apache.org/viewvc/hadoop/common/trunk/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/FSNamesystem.java?rev=1203950&r1=1203949&r2=1203950&view=diff
==============================================================================
--- hadoop/common/trunk/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/FSNamesystem.java
(original)
+++ hadoop/common/trunk/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/FSNamesystem.java
Sat Nov 19 02:34:25 2011
@@ -1421,7 +1421,7 @@ public class FSNamesystem implements Nam
try {
lb = startFileInternal(src, null, holder, clientMachine,
EnumSet.of(CreateFlag.APPEND),
- false, blockManager.maxReplication, (long)0);
+ false, blockManager.maxReplication, 0);
} finally {
writeUnlock();
}
@@ -1504,7 +1504,7 @@ public class FSNamesystem implements Nam
fileLength = pendingFile.computeContentSummary().getLength();
blockSize = pendingFile.getPreferredBlockSize();
clientNode = pendingFile.getClientNode();
- replication = (int)pendingFile.getReplication();
+ replication = pendingFile.getReplication();
} finally {
writeUnlock();
}
@@ -2214,6 +2214,7 @@ public class FSNamesystem implements Nam
// If the penultimate block is not COMPLETE, then it must be COMMITTED.
if(nrCompleteBlocks < nrBlocks - 2 ||
nrCompleteBlocks == nrBlocks - 2 &&
+ curBlock != null &&
curBlock.getBlockUCState() != BlockUCState.COMMITTED) {
final String message = "DIR* NameSystem.internalReleaseLease: "
+ "attempt to release a create lock on "
@@ -2299,7 +2300,7 @@ public class FSNamesystem implements Nam
}
Lease reassignLeaseInternal(Lease lease, String src, String newHolder,
- INodeFileUnderConstruction pendingFile) throws IOException {
+ INodeFileUnderConstruction pendingFile) {
assert hasWriteLock();
pendingFile.setClientName(newHolder);
return leaseManager.reassignLease(lease, src, newHolder);
@@ -2402,7 +2403,7 @@ public class FSNamesystem implements Nam
newtargets[i]);
}
}
- if (closeFile) {
+ if ((closeFile) && (descriptors != null)) {
// the file is getting closed. Insert block locations into blockManager.
// Otherwise fsck will report these blocks as MISSING, especially if the
// blocksReceived from Datanodes take a long time to arrive.
@@ -3088,7 +3089,7 @@ public class FSNamesystem implements Nam
this.blockTotal = total;
this.blockThreshold = (int) (blockTotal * threshold);
this.blockReplQueueThreshold =
- (int) (((double) blockTotal) * replQueueThreshold);
+ (int) (blockTotal * replQueueThreshold);
checkMode();
}
@@ -3098,7 +3099,7 @@ public class FSNamesystem implements Nam
* @param replication current replication
*/
private synchronized void incrementSafeBlockCount(short replication) {
- if ((int)replication == safeReplication)
+ if (replication == safeReplication)
this.blockSafe++;
checkMode();
}
@@ -3230,6 +3231,7 @@ public class FSNamesystem implements Nam
/**
* Checks consistency of the class state.
* This is costly and currently called only in assert.
+ * @throws IOException
*/
private boolean isConsistent() throws IOException {
if (blockTotal == -1 && blockSafe == -1) {
Modified: hadoop/common/trunk/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/NameNode.java
URL: http://svn.apache.org/viewvc/hadoop/common/trunk/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/NameNode.java?rev=1203950&r1=1203949&r2=1203950&view=diff
==============================================================================
--- hadoop/common/trunk/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/NameNode.java
(original)
+++ hadoop/common/trunk/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/NameNode.java
Sat Nov 19 02:34:25 2011
@@ -258,11 +258,12 @@ public class NameNode {
* If the service rpc is not configured returns null
*/
protected InetSocketAddress getServiceRpcServerAddress(Configuration conf)
- throws IOException {
+ throws IOException {
return NameNode.getServiceAddress(conf, false);
}
- protected InetSocketAddress getRpcServerAddress(Configuration conf) throws IOException
{
+ protected InetSocketAddress getRpcServerAddress(Configuration conf)
+ throws IOException {
return getAddress(conf);
}
|