From dda6fcbaa7cbeaf2c0abed470c790a49cb2b5189 Mon Sep 17 00:00:00 2001
From: leventov <leventov@ya.ru>
Date: Mon, 19 Jan 2015 07:10:07 +0700
Subject: [PATCH] Don't assume timestamp = 0 is impossible in
 ReplicatedChronicleMap

---
 .../openhft/chronicle/map/ReplicatedChronicleMap.java | 11 +++++------
 1 file changed, 5 insertions(+), 6 deletions(-)

diff --git a/src/main/java/net/openhft/chronicle/map/ReplicatedChronicleMap.java b/src/main/java/net/openhft/chronicle/map/ReplicatedChronicleMap.java
index 188c3f7a2..6113045a1 100644
--- a/src/main/java/net/openhft/chronicle/map/ReplicatedChronicleMap.java
+++ b/src/main/java/net/openhft/chronicle/map/ReplicatedChronicleMap.java
@@ -341,7 +341,7 @@ final class ReplicatedChronicleMap<K, KI, MKI extends MetaBytesInterop<K, ? supe
         byte newIdentifier;
 
         void initReplicationUpdate() {
-            if (newTimestamp != 0L)
+            if (newIdentifier != 0)
                 return;
             checkMapInit();
             initReplicationUpdate0();
@@ -357,7 +357,7 @@ final class ReplicatedChronicleMap<K, KI, MKI extends MetaBytesInterop<K, ? supe
         }
 
         void closeReplicationUpdate() {
-            if (newTimestamp == 0L)
+            if (newIdentifier == 0)
                 return;
             closeReplicationUpdate0();
         }
@@ -376,7 +376,6 @@ final class ReplicatedChronicleMap<K, KI, MKI extends MetaBytesInterop<K, ? supe
         void writeReplicationBytes() {
             entry.writeLong(replicationBytesOffset, newTimestamp);
             entry.writeByte(replicationBytesOffset + 8L, newIdentifier);
-
         }
 
         void writeDeleted() {
@@ -502,9 +501,9 @@ final class ReplicatedChronicleMap<K, KI, MKI extends MetaBytesInterop<K, ? supe
         }
 
         boolean shouldIgnore() {
-            if (timestamp == 0L || newTimestamp == 0L)
-                throw new IllegalStateException("Own entry replication state or " +
-                        "update replication state is not initialized");
+            assert identifier != 0 && newIdentifier != 0 :
+                    "Own entry replication state or " +
+                            "update replication state is not initialized";
             if (timestamp < newTimestamp)
                 return false;
             if (timestamp > newTimestamp)