ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sevdoki...@apache.org
Subject [10/50] [abbrv] incubator-ignite git commit: # ignite-6
Date Thu, 05 Feb 2015 14:05:10 GMT
# ignite-6


Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/3ac6c2c8
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/3ac6c2c8
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/3ac6c2c8

Branch: refs/heads/ignite-54-55
Commit: 3ac6c2c8b47b90d5747d9dff84d0c68babb8bff4
Parents: 8a76806
Author: sboikov <sboikov@gridgain.com>
Authored: Wed Feb 4 15:31:39 2015 +0300
Committer: sboikov <sboikov@gridgain.com>
Committed: Wed Feb 4 15:31:39 2015 +0300

----------------------------------------------------------------------
 .../datagrid/datastructures/IgniteAtomicLongExample.java       | 4 ++--
 .../datagrid/datastructures/IgniteAtomicReferenceExample.java  | 2 +-
 .../datagrid/datastructures/IgniteAtomicSequenceExample.java   | 4 ++--
 .../datagrid/datastructures/IgniteAtomicStampedExample.java    | 6 +++---
 .../examples/datagrid/datastructures/IgniteQueueExample.java   | 2 +-
 5 files changed, 9 insertions(+), 9 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/3ac6c2c8/examples/src/main/java/org/apache/ignite/examples/datagrid/datastructures/IgniteAtomicLongExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/datagrid/datastructures/IgniteAtomicLongExample.java
b/examples/src/main/java/org/apache/ignite/examples/datagrid/datastructures/IgniteAtomicLongExample.java
index 969de3e..ed01289 100644
--- a/examples/src/main/java/org/apache/ignite/examples/datagrid/datastructures/IgniteAtomicLongExample.java
+++ b/examples/src/main/java/org/apache/ignite/examples/datagrid/datastructures/IgniteAtomicLongExample.java
@@ -56,8 +56,8 @@ public final class IgniteAtomicLongExample {
             System.out.println();
             System.out.println("Atomic long initial value : " + atomicLong.get() + '.');
 
-            // Try increment atomic long from all grid nodes.
-            // Note that this node is also part of the grid.
+            // Try increment atomic long from all nodes.
+            // Note that this node is also part of the ignite cluster.
             ignite.compute().broadcast(new IgniteCallable<Object>() {
                 @Override public Object call() {
                     for (int i = 0; i < RETRIES; i++)

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/3ac6c2c8/examples/src/main/java/org/apache/ignite/examples/datagrid/datastructures/IgniteAtomicReferenceExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/datagrid/datastructures/IgniteAtomicReferenceExample.java
b/examples/src/main/java/org/apache/ignite/examples/datagrid/datastructures/IgniteAtomicReferenceExample.java
index cfd9873..f2dc2b6 100644
--- a/examples/src/main/java/org/apache/ignite/examples/datagrid/datastructures/IgniteAtomicReferenceExample.java
+++ b/examples/src/main/java/org/apache/ignite/examples/datagrid/datastructures/IgniteAtomicReferenceExample.java
@@ -55,7 +55,7 @@ public final class IgniteAtomicReferenceExample {
 
             System.out.println("Atomic reference initial value : " + ref.get() + '.');
 
-            // Make closure for checking atomic reference value on grid.
+            // Make closure for checking atomic reference value on cluster.
             Runnable c = new ReferenceClosure(refName);
 
             // Check atomic reference on all cluster nodes.

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/3ac6c2c8/examples/src/main/java/org/apache/ignite/examples/datagrid/datastructures/IgniteAtomicSequenceExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/datagrid/datastructures/IgniteAtomicSequenceExample.java
b/examples/src/main/java/org/apache/ignite/examples/datagrid/datastructures/IgniteAtomicSequenceExample.java
index 9172733..cec267b 100644
--- a/examples/src/main/java/org/apache/ignite/examples/datagrid/datastructures/IgniteAtomicSequenceExample.java
+++ b/examples/src/main/java/org/apache/ignite/examples/datagrid/datastructures/IgniteAtomicSequenceExample.java
@@ -58,8 +58,8 @@ public final class IgniteAtomicSequenceExample {
 
             System.out.println("Sequence initial value: " + firstVal);
 
-            // Try increment atomic sequence on all grid nodes. Note that this node is also
part of the grid.
-            ignite.compute().run(new SequenceClosure(seqName));
+            // Try increment atomic sequence on all cluster nodes. Note that this node is
also part of the cluster.
+            ignite.compute().broadcast(new SequenceClosure(seqName));
 
             System.out.println("Sequence after incrementing [expected=" + (firstVal + RETRIES)
+ ", actual=" +
                 seq.get() + ']');

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/3ac6c2c8/examples/src/main/java/org/apache/ignite/examples/datagrid/datastructures/IgniteAtomicStampedExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/datagrid/datastructures/IgniteAtomicStampedExample.java
b/examples/src/main/java/org/apache/ignite/examples/datagrid/datastructures/IgniteAtomicStampedExample.java
index ea083e1..30a2f66 100644
--- a/examples/src/main/java/org/apache/ignite/examples/datagrid/datastructures/IgniteAtomicStampedExample.java
+++ b/examples/src/main/java/org/apache/ignite/examples/datagrid/datastructures/IgniteAtomicStampedExample.java
@@ -53,16 +53,16 @@ public final class IgniteAtomicStampedExample {
             // Make stamp of atomic stamped.
             String stamp = UUID.randomUUID().toString();
 
-            // Initialize atomic stamped in cache.
+            // Initialize atomic stamped.
             IgniteAtomicStamped<String, String> stamped = ignite.atomicStamped(stampedName,
val, stamp, true);
 
             System.out.println("Atomic stamped initial [value=" + stamped.value() + ", stamp="
+ stamped.stamp() + ']');
 
-            // Make closure for checking atomic stamped on grid.
+            // Make closure for checking atomic stamped.
             Runnable c = new StampedUpdateClosure(stampedName);
 
             // Check atomic stamped on all cluster nodes.
-            ignite.compute().run(c);
+            ignite.compute().broadcast(c);
 
             // Make new value of atomic stamped.
             String newVal = UUID.randomUUID().toString();

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/3ac6c2c8/examples/src/main/java/org/apache/ignite/examples/datagrid/datastructures/IgniteQueueExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/datagrid/datastructures/IgniteQueueExample.java
b/examples/src/main/java/org/apache/ignite/examples/datagrid/datastructures/IgniteQueueExample.java
index bcae84d..bb54d773 100644
--- a/examples/src/main/java/org/apache/ignite/examples/datagrid/datastructures/IgniteQueueExample.java
+++ b/examples/src/main/java/org/apache/ignite/examples/datagrid/datastructures/IgniteQueueExample.java
@@ -106,7 +106,7 @@ public class IgniteQueueExample {
         final String queueName = queue.name();
 
         // Read queue items on each node.
-        ignite.compute().run(new QueueClosure(queueName, false));
+        ignite.compute().broadcast(new QueueClosure(queueName, false));
 
         System.out.println("Queue size after reading [expected=0, actual=" + queue.size()
+ ']');
     }


Mime
View raw message