Author: umamahesh Date: Mon Nov 18 17:15:50 2013 New Revision: 1543087 URL: http://svn.apache.org/r1543087 Log: HDFS-5372. In FSNamesystem, hasReadLock() returns false if the current thread holds the write lock (Contributed by Vinay)
Modified: hadoop/common/branches/branch-2.2/hadoop-hdfs-project/hadoop-hdfs/CHANGES.txt hadoop/common/branches/branch-2.2/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/BlockManager.java hadoop/common/branches/branch-2.2/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/FSNamesystem.java hadoop/common/branches/branch-2.2/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/util/RwLock.java Modified: hadoop/common/branches/branch-2.2/hadoop-hdfs-project/hadoop-hdfs/CHANGES.txt URL: http://svn.apache.org/viewvc/hadoop/common/branches/branch-2.2/hadoop-hdfs-project/hadoop-hdfs/CHANGES.txt?rev=1543087&r1=1543086&r2=1543087&view=diff ============================================================================== --- hadoop/common/branches/branch-2.2/hadoop-hdfs-project/hadoop-hdfs/CHANGES.txt (original) +++ hadoop/common/branches/branch-2.2/hadoop-hdfs-project/hadoop-hdfs/CHANGES.txt Mon Nov 18 17:15:50 2013 @@ -98,6 +98,9 @@ Release 2.2.1 - UNRELEASED HDFS-5469. Add configuration property for the sub-directroy export path (brandonli) + HDFS-5372. In FSNamesystem, hasReadLock() returns false if the current + thread holds the write lock (Vinaykumar B via umamahesh) + Release 2.2.0 - 2013-10-13 INCOMPATIBLE CHANGES Modified: hadoop/common/branches/branch-2.2/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/BlockManager.java URL: http://svn.apache.org/viewvc/hadoop/common/branches/branch-2.2/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/BlockManager.java?rev=1543087&r1=1543086&r2=1543087&view=diff ============================================================================== --- hadoop/common/branches/branch-2.2/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/BlockManager.java (original) +++ hadoop/common/branches/branch-2.2/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/BlockManager.java Mon Nov 18 17:15:50 2013 @@ -809,7 +809,7 @@ public class BlockManager { final boolean isFileUnderConstruction, final long offset, final long length, final boolean needBlockToken, final boolean inSnapshot) throws IOException { - assert namesystem.hasReadOrWriteLock(); + assert namesystem.hasReadLock(); if (blocks == null) { return null; } else if (blocks.length == 0) { Modified: hadoop/common/branches/branch-2.2/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/FSNamesystem.java URL: http://svn.apache.org/viewvc/hadoop/common/branches/branch-2.2/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/FSNamesystem.java?rev=1543087&r1=1543086&r2=1543087&view=diff ============================================================================== --- hadoop/common/branches/branch-2.2/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/FSNamesystem.java (original) +++ hadoop/common/branches/branch-2.2/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/FSNamesystem.java Mon Nov 18 17:15:50 2013 @@ -1253,11 +1253,7 @@ public class FSNamesystem implements Nam } @Override public boolean hasReadLock() { - return this.fsLock.getReadHoldCount() > 0; - } - @Override - public boolean hasReadOrWriteLock() { - return hasReadLock() || hasWriteLock(); + return this.fsLock.getReadHoldCount() > 0 || hasWriteLock(); } NamespaceInfo getNamespaceInfo() { @@ -1990,7 +1986,7 @@ public class FSNamesystem implements Nam */ private void verifyParentDir(String src) throws FileNotFoundException, ParentNotDirectoryException, UnresolvedLinkException { - assert hasReadOrWriteLock(); + assert hasReadLock(); Path parent = new Path(src).getParent(); if (parent != null) { final INode parentNode = dir.getINode(parent.toString()); @@ -2588,7 +2584,7 @@ public class FSNamesystem implements Nam ExtendedBlock previous, LocatedBlock[] onRetryBlock) throws IOException { - assert hasReadOrWriteLock(); + assert hasReadLock(); checkBlock(previous); onRetryBlock[0] = null; @@ -2785,7 +2781,7 @@ public class FSNamesystem implements Nam private INodeFileUnderConstruction checkLease(String src, long fileId, String holder, INode inode) throws LeaseExpiredException, FileNotFoundException { - assert hasReadOrWriteLock(); + assert hasReadLock(); if (inode == null || !inode.isFile()) { Lease lease = leaseManager.getLease(holder); throw new LeaseExpiredException( Modified: hadoop/common/branches/branch-2.2/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/util/RwLock.java URL: http://svn.apache.org/viewvc/hadoop/common/branches/branch-2.2/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/util/RwLock.java?rev=1543087&r1=1543086&r2=1543087&view=diff ============================================================================== --- hadoop/common/branches/branch-2.2/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/util/RwLock.java (original) +++ hadoop/common/branches/branch-2.2/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/util/RwLock.java Mon Nov 18 17:15:50 2013 @@ -39,7 +39,4 @@ public interface RwLock { /** Check if the current thread holds write lock. */ public boolean hasWriteLock(); - - /** Check if the current thread holds read or write lock. */ - public boolean hasReadOrWriteLock(); }