add delta wire test and fixes

OpenHFT · Aug 19, 2016 · f7933f5 · f7933f5
1 parent 19cdb4e
commit f7933f5
Showing 1 changed file with 8 additions and 2 deletions.
diff --git a/src/main/java/net/openhft/chronicle/queue/impl/single/SingleChronicleQueueExcerpts.java b/src/main/java/net/openhft/chronicle/queue/impl/single/SingleChronicleQueueExcerpts.java
@@ -1114,8 +1114,13 @@ ScanResult moveToIndexResult(long index) {
                     return ScanResult.NOT_REACHED;
             }
 
+            ScanResult scanResult = FOUND;
+
+
             index(index);
-            ScanResult scanResult = this.store.moveToIndexForRead(this, sequenceNumber);
+
+            scanResult = this.store.moveToIndexForRead(this, sequenceNumber);
+
             Bytes<?> bytes = wire().bytes();
             if (scanResult == FOUND) {
                 state = FOUND_CYCLE;
@@ -1155,6 +1160,7 @@ public final ExcerptTailer toStart() {
          *
          * @return the last index at the time this method was called.
          */
+
         private long approximateLastIndex() throws EOFException {
 
             RollCycle rollCycle = queue.rollCycle();
@@ -1295,7 +1301,7 @@ private void incrementIndex() {
                 }
             }
 
-            this.index(rollCycle.toIndex(cycle, seq));
+            this.index = rollCycle.toIndex(cycle, seq);
         }
 
         // DON'T INLINE THIS METHOD, as it's used by enterprise chronicle queue