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 <[email protected]>
Authored: Wed Sep 9 12:20:38 2015 +0300
Committer: ptupitsyn <[email protected]>
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>;

Reply via email to