# 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 <[email protected]> Authored: Wed Feb 4 15:31:39 2015 +0300 Committer: sboikov <[email protected]> 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() + ']'); }
