ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From akuznet...@apache.org
Subject [14/50] ignite git commit: Fixed test.
Date Wed, 09 Sep 2015 12:37:26 GMT
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-843
Commit: 45ced671788bc804ca01ce17872316152dfe6acd
Parents: 86f8037
Author: sboikov <sboikov@gridgain.com>
Authored: Tue Sep 8 13:31:56 2015 +0300
Committer: sboikov <sboikov@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));
             }


Mime
View raw message