fix infinity loop during reading from backup

infobip · Sep 25, 2019 · afb78ef · afb78ef
1 parent e17871e
commit afb78ef
Show file tree

Hide file tree

Showing 5 changed files with 11 additions and 4 deletions.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -13,6 +13,12 @@ and this project adheres to [Semantic Versioning](http://semver.org/spec/v2.0.0.
 - Add batch write/read (using FileChannel) with customizable batch size;
 - Add concurrent access to queue (methods with `synchronized` keyword or based on locks).
 
+## [2.1.1](https://github.com/infobip/popout/releases/tag/2.1.1) - 2019-09-25
+
+### Fixed
+
+- `SyncedFileQueue` don't fall in infinity loop during restoring from backup.
+
 ## [2.1.0](https://github.com/infobip/popout/releases/tag/2.1.0) - 2019-04-28
 
 ### Added

diff --git a/benchmarks/pom.xml b/benchmarks/pom.xml
@@ -25,7 +25,7 @@ limitations under the License.
   <parent>
     <groupId>org.infobip.lib</groupId>
     <artifactId>parent</artifactId>
-    <version>2.1.0</version>
+    <version>2.1.1</version>
   </parent>
 
   <artifactId>benchmarks</artifactId>

diff --git a/pom.xml b/pom.xml
@@ -24,7 +24,7 @@ limitations under the License.
 
   <groupId>org.infobip.lib</groupId>
   <artifactId>parent</artifactId>
-  <version>2.1.0</version>
+  <version>2.1.1</version>
   <packaging>pom</packaging>
 
   <modules>
@@ -71,7 +71,7 @@ limitations under the License.
     <url>https://github.com/infobip/popout</url>
     <connection>scm:git:https://github.com/infobip/popout.git</connection>
     <developerConnection>scm:git:https://github.com/infobip/popout.git</developerConnection>
-    <tag>2.1.0</tag>
+    <tag>2.1.1</tag>
   </scm>
 
   <distributionManagement>

diff --git a/popout/pom.xml b/popout/pom.xml
@@ -25,7 +25,7 @@ limitations under the License.
   <parent>
     <groupId>org.infobip.lib</groupId>
     <artifactId>parent</artifactId>
-    <version>2.1.0</version>
+    <version>2.1.1</version>
   </parent>
 
   <artifactId>popout</artifactId>

diff --git a/popout/src/main/java/org/infobip/lib/popout/synced/SyncedFileQueue.java b/popout/src/main/java/org/infobip/lib/popout/synced/SyncedFileQueue.java
@@ -67,6 +67,7 @@ class SyncedFileQueue<T> extends FileQueue<T> {
     size = new LongAdder();
     val iterator = backend.iterator();
     while (iterator.hasNext()) {
+      iterator.next();
       size.increment();
     }
   }