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:17 UTC
[10/50] ignite git commit: Fixed test.
Fixed test.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/45ced671
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/45ced671
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/45ced671
Branch: refs/heads/ignite-1093-2
Commit: 45ced671788bc804ca01ce17872316152dfe6acd
Parents: 86f8037
Author: sboikov <sb...@gridgain.com>
Authored: Tue Sep 8 13:31:56 2015 +0300
Committer: sboikov <sb...@gridgain.com>
Committed: Tue Sep 8 13:31:56 2015 +0300
----------------------------------------------------------------------
...GridCacheQueueMultiNodeAbstractSelfTest.java | 34 ++++++++++----------
1 file changed, 17 insertions(+), 17 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/45ced671/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/GridCacheQueueMultiNodeAbstractSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/GridCacheQueueMultiNodeAbstractSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/GridCacheQueueMultiNodeAbstractSelfTest.java
index 1dca379..097181c 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/GridCacheQueueMultiNodeAbstractSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/GridCacheQueueMultiNodeAbstractSelfTest.java
@@ -466,8 +466,6 @@ public abstract class GridCacheQueueMultiNodeAbstractSelfTest extends IgniteColl
* @throws Exception If failed.
*/
public void testIterator() throws Exception {
- fail("https://issues.apache.org/jira/browse/IGNITE-583");
-
final String queueName = UUID.randomUUID().toString();
info("Queue name: " + queueName);
@@ -475,35 +473,37 @@ public abstract class GridCacheQueueMultiNodeAbstractSelfTest extends IgniteColl
try (IgniteQueue<Integer> queue = grid(0).queue(queueName, QUEUE_CAPACITY, config(false))) {
assertTrue(queue.isEmpty());
- grid(0).compute().call(new AddAllJob(queueName, RETRIES));
+ grid(0).compute().broadcast(new AddAllJob(queueName, RETRIES));
assertEquals(GRID_CNT * RETRIES, queue.size());
Collection<ClusterNode> nodes = grid(0).cluster().nodes();
for (ClusterNode node : nodes) {
- Collection<Integer> queueElements = compute(grid(0).cluster().forNode(node)).call(new IgniteCallable<Collection<Integer>>() {
- @IgniteInstanceResource
- private Ignite grid;
+ Collection<Integer> queueElements = compute(grid(0).cluster().forNode(node)).call(
+ new IgniteCallable<Collection<Integer>>() {
+ @IgniteInstanceResource
+ private Ignite grid;
- /** {@inheritDoc} */
- @Override public Collection<Integer> call() throws Exception {
- Collection<Integer> values = new ArrayList<>();
+ /** {@inheritDoc} */
+ @Override public Collection<Integer> call() throws Exception {
+ Collection<Integer> values = new ArrayList<>();
- grid.log().info("Running job [node=" + grid.cluster().localNode().id() + ", job=" + this + "]");
+ grid.log().info("Running job [node=" + grid.cluster().localNode().id() + "]");
- IgniteQueue<Integer> locQueue = grid.queue(queueName, 0, null);
+ IgniteQueue<Integer> locQueue = grid.queue(queueName, 0, null);
- grid.log().info("Queue size " + locQueue.size());
+ grid.log().info("Queue size " + locQueue.size());
- for (Integer element : locQueue)
- values.add(element);
+ for (Integer element : locQueue)
+ values.add(element);
- grid.log().info("Returning: " + values);
+ grid.log().info("Returning: " + values);
- return values;
+ return values;
+ }
}
- });
+ );
assertTrue(F.eqOrdered(queue, queueElements));
}