ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From akuznet...@apache.org
Subject [05/18] incubator-ignite git commit: sprint-2: minor
Date Wed, 18 Feb 2015 03:26:22 GMT
sprint-2: minor


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

Branch: refs/heads/ignite-275
Commit: 69e2a7d97d6c04a1244cdbfbd0b3855ee6216759
Parents: a4101a5
Author: Yakov Zhdanov <yzhdanov@gridgain.com>
Authored: Tue Feb 17 15:09:29 2015 +0300
Committer: Yakov Zhdanov <yzhdanov@gridgain.com>
Committed: Tue Feb 17 15:09:29 2015 +0300

----------------------------------------------------------------------
 .../IgniteAtomicSequenceExample.java            | 23 ++++++++++----------
 1 file changed, 12 insertions(+), 11 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/69e2a7d9/examples/src/main/java/org/apache/ignite/examples/datastructures/IgniteAtomicSequenceExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/datastructures/IgniteAtomicSequenceExample.java
b/examples/src/main/java/org/apache/ignite/examples/datastructures/IgniteAtomicSequenceExample.java
index ac2aec5..ad6ecdd 100644
--- a/examples/src/main/java/org/apache/ignite/examples/datastructures/IgniteAtomicSequenceExample.java
+++ b/examples/src/main/java/org/apache/ignite/examples/datastructures/IgniteAtomicSequenceExample.java
@@ -53,21 +53,13 @@ public final class IgniteAtomicSequenceExample {
             // Initialize atomic sequence.
             IgniteAtomicSequence seq = ignite.atomicSequence(seqName, 0, true);
 
-            // First value of atomic sequence on this node.
-            long firstVal = seq.get();
-
-            System.out.println("Sequence initial value: " + firstVal);
-
             // 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() + ']');
+            System.out.println();
+            System.out.println("Finished atomic sequence example...");
+            System.out.println("Check all nodes for output (this node is also part of the
cluster).");
         }
-
-        System.out.println();
-        System.out.println("Finished atomic sequence example...");
-        System.out.println("Check all nodes for output (this node is also part of the cluster).");
     }
 
     /**
@@ -88,9 +80,18 @@ public final class IgniteAtomicSequenceExample {
         @Override public void run() {
             IgniteAtomicSequence seq = Ignition.ignite().atomicSequence(seqName, 0, true);
 
+            // First value of atomic sequence on this node.
+            long firstVal = seq.get();
+
+            System.out.println("Sequence initial value on local node: " + firstVal);
+
             for (int i = 0; i < RETRIES; i++)
                 System.out.println("Sequence [currentValue=" + seq.get() + ", afterIncrement="
+
                     seq.incrementAndGet() + ']');
+
+
+            System.out.println("Sequence after incrementing [expected=" + (firstVal + RETRIES)
+ ", actual=" +
+                seq.get() + ']');
         }
     }
 }


Mime
View raw message