svn commit: r1068590 - in /hbase/trunk: CHANGES.txt src/main/java/org/apache/hadoop/hbase/regionserver/wal/HLog.java

[jd...@apache.org]

Author: jdcryans
Date: Tue Feb  8 21:34:34 2011
New Revision: 1068590

URL: http://svn.apache.org/viewvc?rev=1068590&view=rev
Log:
   HBASE-3515  [replication] ReplicationSource can miss a log after RS comes
               out of GC

Modified:
    hbase/trunk/CHANGES.txt
    hbase/trunk/src/main/java/org/apache/hadoop/hbase/regionserver/wal/HLog.java

Modified: hbase/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/hbase/trunk/CHANGES.txt?rev=1068590&r1=1068589&r2=1068590&view=diff
==============================================================================
--- hbase/trunk/CHANGES.txt (original)
+++ hbase/trunk/CHANGES.txt Tue Feb  8 21:34:34 2011
@@ -109,6 +109,8 @@ Release 0.90.1 - Unreleased
    HBASE-3509  Add metric for flush queue length
    HBASE-3419  If re-transition to OPENING during log replay fails, server
                aborts. Instead, should just cancel region open.
+   HBASE-3515  [replication] ReplicationSource can miss a log after RS comes
+               out of GC
 
 Release 0.90.0 - January 19th, 2011
   INCOMPATIBLE CHANGES

Modified: hbase/trunk/src/main/java/org/apache/hadoop/hbase/regionserver/wal/HLog.java
URL: http://svn.apache.org/viewvc/hbase/trunk/src/main/java/org/apache/hadoop/hbase/regionserver/wal/HLog.java?rev=1068590&r1=1068589&r2=1068590&view=diff
==============================================================================
--- hbase/trunk/src/main/java/org/apache/hadoop/hbase/regionserver/wal/HLog.java (original)
+++ hbase/trunk/src/main/java/org/apache/hadoop/hbase/regionserver/wal/HLog.java Tue Feb  8 21:34:34 2011
@@ -504,6 +504,9 @@ public class HLog implements Syncable {
       }
 
       synchronized (updateLock) {
+        if (closed) {
+          return regionsToFlush;
+        }
         // Clean up current writer.
         Path oldFile = cleanupCurrentWriter(currentFilenum);
         this.writer = nextWriter;