From 9b793bed6d8c09a57e4cc76da70f77ea336bc9e9 Mon Sep 17 00:00:00 2001
From: Rob Austin <rob.austin@boundedbuffer.co.uk>
Date: Mon, 6 Jul 2015 23:54:11 +0100
Subject: [PATCH] added fix to this java.lang.AssertionError: Invalid address 1
                  	at
 net.openhft.lang.io.NativeBytes.setStartPositionAddress(NativeBytes.java:77) 
                 	at
 net.openhft.lang.io.NativeBytes.<init>(NativeBytes.java:67)                  
 at net.openhft.lang.io.NativeBytes.wrap(NativeBytes.java:83)                 
 	at
 net.openhft.chronicle.map.ReplicatedChronicleMap$1$1.onEntry(ReplicatedChronicleMap.java:474)
                  	at
 net.openhft.chronicle.map.ReplicatedChronicleMap$ModificationIterator.nextEntry(ReplicatedChronicleMap.java:1759)
                  	at
 net.openhft.chronicle.map.ReplicatedChronicleMap$1.nextEntry(ReplicatedChronicleMap.java:460)
                  	at
 net.openhft.chronicle.engine.map.CMap2EngineReplicator$1.nextEntry(CMap2EngineReplicator.java:132)
                  	at
 net.openhft.chronicle.engine.map.CMap2EngineReplicator$1.forEach(CMap2EngineReplicator.java:120)
                  	at
 net.openhft.chronicle.engine.server.internal.ReplicationHandler$1$1.action(ReplicationHandler.java:124)
                  	at
 net.openhft.chronicle.threads.VanillaEventLoop.runOneTenthLowHandler(VanillaEventLoop.java:154)
                  	at
 net.openhft.chronicle.threads.VanillaEventLoop.run(VanillaEventLoop.java:108)
                  	at
 java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)      
            	at java.util.concurrent.FutureTask.run(FutureTask.java:266)   
               	at
 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
                  	at
 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
                  	at java.lang.Thread.run(Thread.java:745)              
    sends:

---
 .../java/net/openhft/chronicle/map/ReplicatedChronicleMap.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/main/java/net/openhft/chronicle/map/ReplicatedChronicleMap.java b/src/main/java/net/openhft/chronicle/map/ReplicatedChronicleMap.java
index a8cbaad59..4feab8ea4 100644
--- a/src/main/java/net/openhft/chronicle/map/ReplicatedChronicleMap.java
+++ b/src/main/java/net/openhft/chronicle/map/ReplicatedChronicleMap.java
@@ -471,7 +471,7 @@ final class ReplicatedChronicleMap<K, KI, MKI extends MetaBytesInterop<K, ? supe
                         final boolean isDeleted = entry.readBoolean();
 
                         if (isDeleted)
-                            return callback.onEntry(wrap(keyPosition, keySize), null, timestamp, identifier,
+                            return callback.onEntry(wrap(entry.address() + keyPosition, keySize), null, timestamp, identifier,
                                     true,
                                     bootStrapTimeStamp);