You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by sb...@apache.org on 2015/09/09 15:41:43 UTC
[36/50] ignite git commit: IGNITE-1394 Platform .Net: cache.Invoke
tests fail
IGNITE-1394 Platform .Net: cache.Invoke tests fail
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/7fcc14c3
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/7fcc14c3
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/7fcc14c3
Branch: refs/heads/ignite-1093-2
Commit: 7fcc14c3c29452b6bfbf79f069b825838e7c1e19
Parents: fba01d6
Author: ptupitsyn <pt...@gridgain.com>
Authored: Wed Sep 9 12:20:38 2015 +0300
Committer: ptupitsyn <pt...@gridgain.com>
Committed: Wed Sep 9 12:20:38 2015 +0300
----------------------------------------------------------------------
.../dotnet/Apache.Ignite.Core/Impl/Cache/CacheImpl.cs | 10 +++++++++-
1 file changed, 9 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/7fcc14c3/modules/platform/src/main/dotnet/Apache.Ignite.Core/Impl/Cache/CacheImpl.cs
----------------------------------------------------------------------
diff --git a/modules/platform/src/main/dotnet/Apache.Ignite.Core/Impl/Cache/CacheImpl.cs b/modules/platform/src/main/dotnet/Apache.Ignite.Core/Impl/Cache/CacheImpl.cs
index 0301352..cdc9bcd 100644
--- a/modules/platform/src/main/dotnet/Apache.Ignite.Core/Impl/Cache/CacheImpl.cs
+++ b/modules/platform/src/main/dotnet/Apache.Ignite.Core/Impl/Cache/CacheImpl.cs
@@ -921,7 +921,15 @@ namespace Apache.Ignite.Core.Impl.Cache
return reader => (TResult)ReadGetAllDictionary(reader);
if (lastAsyncOpId == (int)CacheOp.Invoke)
- return reader => { throw ReadException(reader.Stream); };
+ return reader =>
+ {
+ var hasError = reader.ReadBoolean();
+
+ if (hasError)
+ throw ReadException(reader.Stream);
+
+ return reader.ReadObject<TResult>();
+ };
if (lastAsyncOpId == (int) CacheOp.InvokeAll)
return _invokeAllConverter.Value as Func<PortableReaderImpl, TResult>;