Fixed conflict version passed to events for ATOMIC cache. This closes
@@ -1881,7 +1881,7 @@ public abstract class GridCacheMapEntry extends GridMetadataAwareAdapter impleme
key,
evtNodeId,
null,
- newVer,
+ updateVer,
EVT_CACHE_OBJECT_READ,
evtOld, evtOld != null,
evtOld, evtOld != null,
@@ -1908,7 +1908,7 @@ public abstract class GridCacheMapEntry extends GridMetadataAwareAdapter impleme
key,
evtNodeId,
null,
- newVer,
+ updateVer,
EVT_CACHE_OBJECT_PUT,
updateVal,
true,
@@ -1925,7 +1925,7 @@ public abstract class GridCacheMapEntry extends GridMetadataAwareAdapter impleme
clearReaders();
- drReplicate(drType, null, newVer, topVer);
+ drReplicate(drType, null, updateVer, topVer);
recordNodeId(affNodeId, topVer);
@@ -1936,7 +1936,8 @@ public abstract class GridCacheMapEntry extends GridMetadataAwareAdapter impleme
cctx.events().addEvent(partition(),
key,
evtNodeId,
- null, newVer,
+ null,
+ updateVer,
EVT_CACHE_OBJECT_REMOVED,
null, false,
evtOld, evtOld != null,
