#ignite-743: Implement IgniteCacheProxyLockFree.
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/a9bd0178 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/a9bd0178 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/a9bd0178 Branch: refs/heads/ignite-485 Commit: a9bd0178772fbe785da496ea791bfc984b56b9a5 Parents: 56ef269 Author: ivasilinets <ivasilin...@gridgain.com> Authored: Tue Apr 14 16:18:37 2015 +0300 Committer: ivasilinets <ivasilin...@gridgain.com> Committed: Tue Apr 14 16:18:37 2015 +0300 ---------------------------------------------------------------------- .../ignite/internal/processors/cache/IgniteCacheProxy.java | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/a9bd0178/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheProxy.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheProxy.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheProxy.java index dcdf0be..d6f4e85 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheProxy.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheProxy.java @@ -96,7 +96,7 @@ public class IgniteCacheProxy<K, V> extends AsyncSupportAdapter<IgniteCache<K, V /** * @return Lock free instance. */ - public IgniteCacheProxyLockFree<K,V> lockFree() { + public IgniteCacheProxyLockFree<K, V> lockFree() { return delegate; } @@ -885,8 +885,6 @@ public class IgniteCacheProxy<K, V> extends AsyncSupportAdapter<IgniteCache<K, V /** {@inheritDoc} */ @Override public void writeExternal(ObjectOutput out) throws IOException { out.writeObject(delegate); - - out.writeObject(prj); } /** {@inheritDoc} */ @@ -894,7 +892,7 @@ public class IgniteCacheProxy<K, V> extends AsyncSupportAdapter<IgniteCache<K, V @Override public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException { delegate = (IgniteCacheProxyLockFree<K, V>)in.readObject(); - prj = (GridCacheProjectionImpl<K, V>)in.readObject(); + prj = (GridCacheProjectionImpl<K, V>)delegate.delegate(); gate = delegate.context().gate(); }
