Repository: ignite Updated Branches: refs/heads/ignite-4648 a130f520f -> db5e7f59e
.NET: Update tests to check async within TransactionScope Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/db5e7f59 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/db5e7f59 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/db5e7f59 Branch: refs/heads/ignite-4648 Commit: db5e7f59e4fccc0fa8fa9aee010952890408c918 Parents: a130f52 Author: Pavel Tupitsyn <[email protected]> Authored: Thu Jul 13 17:28:40 2017 +0300 Committer: Pavel Tupitsyn <[email protected]> Committed: Thu Jul 13 17:28:40 2017 +0300 ---------------------------------------------------------------------- .../Cache/CacheAbstractTransactionalTest.cs | 26 ++++++++++---------- 1 file changed, 13 insertions(+), 13 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/db5e7f59/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Cache/CacheAbstractTransactionalTest.cs ---------------------------------------------------------------------- diff --git a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Cache/CacheAbstractTransactionalTest.cs b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Cache/CacheAbstractTransactionalTest.cs index 45d0b5f..2e0c0fc 100644 --- a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Cache/CacheAbstractTransactionalTest.cs +++ b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Cache/CacheAbstractTransactionalTest.cs @@ -773,10 +773,10 @@ namespace Apache.Ignite.Core.Tests.Cache for (var i = 0; i < 10; i++) { CheckTxOp((cache, key) => cache.Put(key, -5)); - CheckTxOp((cache, key) => cache.PutAsync(key, -5).Wait()); + CheckTxOp((cache, key) => cache.PutAsync(key, -5)); CheckTxOp((cache, key) => cache.PutAll(new Dictionary<int, int> {{key, -7}})); - CheckTxOp((cache, key) => cache.PutAllAsync(new Dictionary<int, int> {{key, -7}}).Wait()); + CheckTxOp((cache, key) => cache.PutAllAsync(new Dictionary<int, int> {{key, -7}})); CheckTxOp((cache, key) => { @@ -786,11 +786,11 @@ namespace Apache.Ignite.Core.Tests.Cache CheckTxOp((cache, key) => { cache.Remove(key); - cache.PutIfAbsentAsync(key, -10).Wait(); + cache.PutIfAbsentAsync(key, -10); }); CheckTxOp((cache, key) => cache.GetAndPut(key, -9)); - CheckTxOp((cache, key) => cache.GetAndPutAsync(key, -9).Wait()); + CheckTxOp((cache, key) => cache.GetAndPutAsync(key, -9)); CheckTxOp((cache, key) => { @@ -800,32 +800,32 @@ namespace Apache.Ignite.Core.Tests.Cache CheckTxOp((cache, key) => { cache.Remove(key); - cache.GetAndPutIfAbsentAsync(key, -10).Wait(); + cache.GetAndPutIfAbsentAsync(key, -10); }); CheckTxOp((cache, key) => cache.GetAndRemove(key)); - CheckTxOp((cache, key) => cache.GetAndRemoveAsync(key).Wait()); + CheckTxOp((cache, key) => cache.GetAndRemoveAsync(key)); CheckTxOp((cache, key) => cache.GetAndReplace(key, -11)); - CheckTxOp((cache, key) => cache.GetAndReplaceAsync(key, -11).Wait()); + CheckTxOp((cache, key) => cache.GetAndReplaceAsync(key, -11)); CheckTxOp((cache, key) => cache.Invoke(key, new AddProcessor(), 1)); - CheckTxOp((cache, key) => cache.InvokeAsync(key, new AddProcessor(), 1).Wait()); + CheckTxOp((cache, key) => cache.InvokeAsync(key, new AddProcessor(), 1)); CheckTxOp((cache, key) => cache.InvokeAll(new[] {key}, new AddProcessor(), 1)); - CheckTxOp((cache, key) => cache.InvokeAllAsync(new[] {key}, new AddProcessor(), 1).Wait()); + CheckTxOp((cache, key) => cache.InvokeAllAsync(new[] {key}, new AddProcessor(), 1)); CheckTxOp((cache, key) => cache.Remove(key)); - CheckTxOp((cache, key) => cache.RemoveAsync(key).Wait()); + CheckTxOp((cache, key) => cache.RemoveAsync(key)); CheckTxOp((cache, key) => cache.RemoveAll(new[] {key})); - CheckTxOp((cache, key) => cache.RemoveAllAsync(new[] {key}).Wait()); + CheckTxOp((cache, key) => cache.RemoveAllAsync(new[] {key})); CheckTxOp((cache, key) => cache.Replace(key, 100)); - CheckTxOp((cache, key) => cache.ReplaceAsync(key, 100).Wait()); + CheckTxOp((cache, key) => cache.ReplaceAsync(key, 100)); CheckTxOp((cache, key) => cache.Replace(key, cache[key], 100)); - CheckTxOp((cache, key) => cache.ReplaceAsync(key, cache[key], 100).Wait()); + CheckTxOp((cache, key) => cache.ReplaceAsync(key, cache[key], 100)); } }
