commit e1dad1984640517366a7e73e323c9de27b0676f7
author Murtadha Hubail <mhubail@uci.edu> Wed Oct 21 22:44:03 2015 -0700
committer Murtadha Hubail <hubailmor@gmail.com> Wed Oct 21 23:36:41 2015 -0700
tree df97effde812c5c01df0771ef0411df3e481d13e
parent 812f69cc4fd3c7c49313281d40654604e2fdec84

ASTERIXDB-1045: fix log file reading during recovery

Change-Id: Ic83ee1dd2d7ba88180c25f4ec6c7aa8d0a5a7162
Reviewed-on: https://asterix-gerrit.ics.uci.edu/465
Reviewed-by: Ian Maxon <imaxon@apache.org>
Tested-by: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

asterix-transactions/src/main/java/org/apache/asterix/transaction/management/service/logging/LogReader.java

diff --git a/asterix-transactions/src/main/java/org/apache/asterix/transaction/management/service/logging/LogReader.java b/asterix-transactions/src/main/java/org/apache/asterix/transaction/management/service/logging/LogReader.java
index 9900468..e0cddee 100644
--- a/asterix-transactions/src/main/java/org/apache/asterix/transaction/management/service/logging/LogReader.java
+++ b/asterix-transactions/src/main/java/org/apache/asterix/transaction/management/service/logging/LogReader.java
@@ -87,8 +87,8 @@
             return null;
         }
         if (readBuffer.position() == readBuffer.limit()) {
-            boolean eof = refillLogReadBuffer();
-            if (eof && isRecoveryMode && readLSN < flushLSN.get()) {
+            boolean hasRemaining = refillLogReadBuffer();
+            if (!hasRemaining && isRecoveryMode && readLSN < flushLSN.get()) {
                 LOGGER.severe("Transaction log ends before expected. Log files may be missing.");
                 return null;
             }