addressed code review comments
diff --git a/asterix-transactions/src/main/java/edu/uci/ics/asterix/transaction/management/service/logging/LogManager.java b/asterix-transactions/src/main/java/edu/uci/ics/asterix/transaction/management/service/logging/LogManager.java
index 040800c..07f89cb 100644
--- a/asterix-transactions/src/main/java/edu/uci/ics/asterix/transaction/management/service/logging/LogManager.java
+++ b/asterix-transactions/src/main/java/edu/uci/ics/asterix/transaction/management/service/logging/LogManager.java
@@ -591,14 +591,14 @@
readDiskLog(lsnValue, logicalLogLocator);
}
- public boolean isMemoryRead(long currentLSN) {
+ public boolean isMemoryRead(long readLSN) {
long flushLSN = lastFlushedLSN.get();
- if ((flushLSN + 1) == currentLSN) {
+ if ((flushLSN + 1) == readLSN) {
return false;
}
long logPageBeginOffset = flushLSN - (flushLSN % logPageSize);
long logPageEndOffset = logPageBeginOffset + logPageSize;
- if (currentLSN > flushLSN || (currentLSN >= logPageBeginOffset && currentLSN < logPageEndOffset)) {
+ if (readLSN > flushLSN || (readLSN >= logPageBeginOffset && readLSN < logPageEndOffset)) {
return true;
} else {
return false;