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:
This commit is contained in:
Rob Austin
2015-07-06 23:54:11 +01:00
parent 0686a1d594
commit 9b793bed6d
@@ -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);