svn commit: r1068589 - in /hbase/branches/0.90: CHANGES.txt src/main/java/org/apache/hadoop/hbase/regionserver/wal/HLog.java

[jdcryans]

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

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

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

Modified: hbase/branches/0.90/CHANGES.txt
URL: 
http://svn.apache.org/viewvc/hbase/branches/0.90/CHANGES.txt?rev=1068589&r1=1068588&r2=1068589&view=diff
==============================================================================
--- hbase/branches/0.90/CHANGES.txt (original)
+++ hbase/branches/0.90/CHANGES.txt Tue Feb  8 21:34:06 2011
@@ -29,6 +29,8 @@ Release 0.90.1 - Unreleased
    HBASE-3500  Documentation update for replicatio
    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
 
 
   IMPROVEMENTS

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