Repository: ignite Updated Branches: refs/heads/ignite-1537 8b09766b0 -> 53482a76a
ignite-1.5 Fixed hang on metadata update inside put in atomic cache when topology read lock is held. Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/53482a76 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/53482a76 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/53482a76 Branch: refs/heads/ignite-1537 Commit: 53482a76ad9814a99f0257cfbd55ca31d3faaf9d Parents: 8b09766 Author: sboikov <[email protected]> Authored: Wed Dec 23 13:54:11 2015 +0300 Committer: sboikov <[email protected]> Committed: Wed Dec 23 13:54:11 2015 +0300 ---------------------------------------------------------------------- .../distributed/IgniteBinaryMetadataUpdateNodeRestartTest.java | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/53482a76/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/IgniteBinaryMetadataUpdateNodeRestartTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/IgniteBinaryMetadataUpdateNodeRestartTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/IgniteBinaryMetadataUpdateNodeRestartTest.java index e88ae6f..814fb08 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/IgniteBinaryMetadataUpdateNodeRestartTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/IgniteBinaryMetadataUpdateNodeRestartTest.java @@ -150,12 +150,16 @@ public class IgniteBinaryMetadataUpdateNodeRestartTest extends GridCommonAbstrac IgniteInternalFuture<?> fut = GridTestUtils.runMultiThreadedAsync(new Callable<Object>() { @Override public Object call() throws Exception { - int node = idx.getAndIncrement() % (SRVS + CLIENTS); + int threadIdx = idx.getAndIncrement(); + + int node = threadIdx % (SRVS + CLIENTS); Ignite ignite = ignite(node); log.info("Started thread: " + ignite.name()); + Thread.currentThread().setName("update-thread-" + threadIdx + "-" + ignite.name()); + IgniteCache<Object, Object> cache1 = ignite.cache(ATOMIC_CACHE); IgniteCache<Object, Object> cache2 = ignite.cache(TX_CACHE);
