Author: umamahesh Date: Mon Nov 18 04:18:44 2013 New Revision: 1542887 URL: http://svn.apache.org/r1542887 Log: HDFS-5372. In FSNamesystem, hasReadLock() returns false if the current thread holds the write lock (Contributed by Vinay)
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/server/blockmanagement/BlockManager.java hadoop/common/trunk/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/CacheManager.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/util/RwLock.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=1542887&r1=1542886&r2=1542887&view=diff ============================================================================== --- hadoop/common/trunk/hadoop-hdfs-project/hadoop-hdfs/CHANGES.txt (original) +++ hadoop/common/trunk/hadoop-hdfs-project/hadoop-hdfs/CHANGES.txt Mon Nov 18 04:18:44 2013 @@ -666,6 +666,9 @@ Release 2.2.1 - UNRELEASED HDFS-5519. COMMIT handler should update the commit status after sync (brandonli) + HDFS-5372. In FSNamesystem, hasReadLock() returns false if the current thread + holds the write lock (VinayaKumar B via umamahesh) + Release 2.2.0 - 2013-10-13 INCOMPATIBLE CHANGES Modified: hadoop/common/trunk/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/BlockManager.java URL: http://svn.apache.org/viewvc/hadoop/common/trunk/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/BlockManager.java?rev=1542887&r1=1542886&r2=1542887&view=diff ============================================================================== --- hadoop/common/trunk/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/BlockManager.java (original) +++ hadoop/common/trunk/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/BlockManager.java Mon Nov 18 04:18:44 2013 @@ -817,7 +817,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/trunk/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/CacheManager.java URL: http://svn.apache.org/viewvc/hadoop/common/trunk/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/CacheManager.java?rev=1542887&r1=1542886&r2=1542887&view=diff ============================================================================== --- hadoop/common/trunk/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/CacheManager.java (original) +++ hadoop/common/trunk/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/CacheManager.java Mon Nov 18 04:18:44 2013 @@ -237,13 +237,13 @@ public final class CacheManager { } public TreeMap<Long, PathBasedCacheEntry> getEntriesById() { - assert namesystem.hasReadOrWriteLock(); + assert namesystem.hasReadLock(); return entriesById; } @VisibleForTesting public GSet<CachedBlock, CachedBlock> getCachedBlocks() { - assert namesystem.hasReadOrWriteLock(); + assert namesystem.hasReadLock(); return cachedBlocks; } @@ -450,7 +450,7 @@ public final class CacheManager { listPathBasedCacheDirectives(long prevId, PathBasedCacheDirective filter, FSPermissionChecker pc) throws IOException { - assert namesystem.hasReadOrWriteLock(); + assert namesystem.hasReadLock(); final int NUM_PRE_ALLOCATED_ENTRIES = 16; String filterPath = null; if (filter.getId() != null) { @@ -607,7 +607,7 @@ public final class CacheManager { public BatchedListEntries<CachePoolInfo> listCachePools(FSPermissionChecker pc, String prevKey) { - assert namesystem.hasReadOrWriteLock(); + assert namesystem.hasReadLock(); final int NUM_PRE_ALLOCATED_ENTRIES = 16; ArrayList<CachePoolInfo> results = new ArrayList<CachePoolInfo>(NUM_PRE_ALLOCATED_ENTRIES); 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=1542887&r1=1542886&r2=1542887&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 Mon Nov 18 04:18:44 2013 @@ -1295,11 +1295,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(); } public int getReadHoldCount() { @@ -2043,7 +2039,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()); @@ -2651,7 +2647,7 @@ public class FSNamesystem implements Nam ExtendedBlock previous, LocatedBlock[] onRetryBlock) throws IOException { - assert hasReadOrWriteLock(); + assert hasReadLock(); checkBlock(previous); onRetryBlock[0] = null; @@ -2848,7 +2844,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( @@ -3807,7 +3803,7 @@ public class FSNamesystem implements Nam @Override public boolean isInSnapshot(BlockInfoUnderConstruction blockUC) { - assert hasReadOrWriteLock(); + assert hasReadLock(); final BlockCollection bc = blockUC.getBlockCollection(); if (bc == null || !(bc instanceof INodeFileUnderConstruction)) { return false; Modified: hadoop/common/trunk/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/util/RwLock.java URL: http://svn.apache.org/viewvc/hadoop/common/trunk/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/util/RwLock.java?rev=1542887&r1=1542886&r2=1542887&view=diff ============================================================================== --- hadoop/common/trunk/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/util/RwLock.java (original) +++ hadoop/common/trunk/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/util/RwLock.java Mon Nov 18 04:18:44 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(); }