You are viewing a plain text version of this content. The canonical link for it is here.
Posted to hdfs-commits@hadoop.apache.org by to...@apache.org on 2012/02/02 23:10:59 UTC
svn commit: r1239878 - in /hadoop/common/branches/branch-0.22/hdfs:
CHANGES.txt src/java/org/apache/hadoop/hdfs/server/common/Storage.java
Author: todd
Date: Thu Feb 2 22:10:59 2012
New Revision: 1239878
URL: http://svn.apache.org/viewvc?rev=1239878&view=rev
Log:
HDFS-2877. If locking of a storage dir fails, it will remove the other NN's lock file on exit. Contributed by Todd Lipcon.
Modified:
hadoop/common/branches/branch-0.22/hdfs/CHANGES.txt
hadoop/common/branches/branch-0.22/hdfs/src/java/org/apache/hadoop/hdfs/server/common/Storage.java
Modified: hadoop/common/branches/branch-0.22/hdfs/CHANGES.txt
URL: http://svn.apache.org/viewvc/hadoop/common/branches/branch-0.22/hdfs/CHANGES.txt?rev=1239878&r1=1239877&r2=1239878&view=diff
==============================================================================
--- hadoop/common/branches/branch-0.22/hdfs/CHANGES.txt (original)
+++ hadoop/common/branches/branch-0.22/hdfs/CHANGES.txt Thu Feb 2 22:10:59 2012
@@ -19,6 +19,9 @@ Release 0.22.1 - Unreleased
HDFS-2698. BackupNode is downloading image from NameNode for every
checkpoint. (shv)
+ HDFS-2877. If locking of a storage dir fails, it will remove the other
+ NN's lock file on exit. (todd)
+
Release 0.22.0 - 2011-11-29
INCOMPATIBLE CHANGES
Modified: hadoop/common/branches/branch-0.22/hdfs/src/java/org/apache/hadoop/hdfs/server/common/Storage.java
URL: http://svn.apache.org/viewvc/hadoop/common/branches/branch-0.22/hdfs/src/java/org/apache/hadoop/hdfs/server/common/Storage.java?rev=1239878&r1=1239877&r2=1239878&view=diff
==============================================================================
--- hadoop/common/branches/branch-0.22/hdfs/src/java/org/apache/hadoop/hdfs/server/common/Storage.java (original)
+++ hadoop/common/branches/branch-0.22/hdfs/src/java/org/apache/hadoop/hdfs/server/common/Storage.java Thu Feb 2 22:10:59 2012
@@ -626,8 +626,12 @@ public abstract class Storage extends St
* @throws IOException if locking fails.
*/
FileLock tryLock() throws IOException {
+ boolean deletionHookAdded = false;
File lockF = new File(root, STORAGE_FILE_LOCK);
- lockF.deleteOnExit();
+ if (!lockF.exists()) {
+ lockF.deleteOnExit();
+ deletionHookAdded = true;
+ }
RandomAccessFile file = new RandomAccessFile(lockF, "rws");
FileLock res = null;
try {
@@ -640,6 +644,12 @@ public abstract class Storage extends St
file.close();
throw e;
}
+ if (res != null && !deletionHookAdded) {
+ // If the file existed prior to our startup, we didn't
+ // call deleteOnExit above. But since we successfully locked
+ // the dir, we can take care of cleaning it up.
+ lockF.deleteOnExit();
+ }
return res;
}