You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by iv...@apache.org on 2015/07/09 16:59:54 UTC
[26/28] incubator-ignite git commit: #ignite-964: change
cache-api-example.js
#ignite-964: change cache-api-example.js
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/242c21bb
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/242c21bb
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/242c21bb
Branch: refs/heads/ignite-964-1
Commit: 242c21bb10ee0578055adeda1014a536e73ef88f
Parents: 7763a37
Author: ivasilinets <iv...@gridgain.com>
Authored: Thu Jul 9 17:08:06 2015 +0300
Committer: ivasilinets <iv...@gridgain.com>
Committed: Thu Jul 9 17:08:06 2015 +0300
----------------------------------------------------------------------
examples/config/js/example-js-cache.xml | 3 +
.../examples/js/ExampleJsNodeStartup.java | 4 +-
examples/src/main/js/cache-api-example.js | 103 ++++++++++++-------
modules/nodejs/src/main/js/ignite.js | 4 +-
4 files changed, 74 insertions(+), 40 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/242c21bb/examples/config/js/example-js-cache.xml
----------------------------------------------------------------------
diff --git a/examples/config/js/example-js-cache.xml b/examples/config/js/example-js-cache.xml
index 2599e38..e8ffc8a 100644
--- a/examples/config/js/example-js-cache.xml
+++ b/examples/config/js/example-js-cache.xml
@@ -31,6 +31,9 @@
<bean id="ignite.cfg" class="org.apache.ignite.configuration.IgniteConfiguration">
<property name="gridName" value="ServerNode" />
+ <!-- Set to true to enable distributed class loading for examples, default is false. -->
+ <property name="peerClassLoadingEnabled" value="true"/>
+
<property name="connectorConfiguration">
<bean class="org.apache.ignite.configuration.ConnectorConfiguration">
<property name="jettyPath" value="examples/config/js/rest-jetty.xml"/>
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/242c21bb/examples/src/main/java/org/apache/ignite/examples/js/ExampleJsNodeStartup.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/js/ExampleJsNodeStartup.java b/examples/src/main/java/org/apache/ignite/examples/js/ExampleJsNodeStartup.java
index 6fa2e6c..0de6047 100644
--- a/examples/src/main/java/org/apache/ignite/examples/js/ExampleJsNodeStartup.java
+++ b/examples/src/main/java/org/apache/ignite/examples/js/ExampleJsNodeStartup.java
@@ -21,11 +21,11 @@ import org.apache.ignite.*;
import org.apache.ignite.spi.discovery.tcp.internal.*;
/**
- * Starts up an empty node with example compute configuration.
+ * Starts up an empty node with example node js configuration.
*/
public class ExampleJsNodeStartup {
/**
- * Start up an empty node with example compute configuration.
+ * Start up an empty node with example node js configuration.
*
* @param args Command line arguments, none required.
* @throws IgniteException If failed.
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/242c21bb/examples/src/main/js/cache-api-example.js
----------------------------------------------------------------------
diff --git a/examples/src/main/js/cache-api-example.js b/examples/src/main/js/cache-api-example.js
index 13368d5..d17276a 100644
--- a/examples/src/main/js/cache-api-example.js
+++ b/examples/src/main/js/cache-api-example.js
@@ -18,50 +18,81 @@
var apacheIgnite = require("apache-ignite");
var Ignition = apacheIgnite.Ignition;
-Ignition.start(['127.0.0.1:9095'], null, onConnect);
+/**
+ * This example demonstrates some of the cache rich API capabilities.
+ * <p>
+ * Remote nodes should always be started with special configuration file which
+ * enables P2P class loading: {@code 'ignite.{sh|bat} examples/config/js/example-js-cache.xml'}.
+ * <p>
+ * Alternatively you can run {@link ExampleJsNodeStartup} in another JVM which will
+ * start node with {@code examples/config/js/example-js-cache.xml} configuration.
+ */
+function main() {
+ /** Cache name. */
+ var cacheName = "ApiExampleCache";
+
+ /** Connect to node that started with {@code examples/config/js/example-js-cache.xml} configuration. */
+ Ignition.start(['127.0.0.1:9095'], null, onConnect);
+
+ function onConnect(err, ignite) {
+ console.log(">>> Cache API example started.");
+
+ // Create cache on server with cacheName.
+ ignite.getOrCreateCache(cacheName, function(err, cache) {
+ atomicMapOperations(ignite, cache);
+ });
+ }
-function onConnect(err, ignite) {
- console.log(">>> Cache API example started.");
+ /**
+ * Demonstrates cache operations similar to {@link ConcurrentMap} API. Note that
+ * cache API is a lot richer than the JDK {@link ConcurrentMap}.
+ */
+ atomicMapOperations = function(ignite, cache) {
+ console.log(">>> Cache atomic map operation examples.");
- ignite.getOrCreateCache("ApiExampleCache", function(err, cache) {
- atomicMapOperations(cache);
+ cache.removeAllFromCache(function(err) {
+ // Put and return previous value.
+ cache.getAndPut(1, "1", onGetAndPut)
});
-}
-/**
- * Demonstrates cache operations similar to {@link ConcurrentMap} API. Note that
- * cache API is a lot richer than the JDK {@link ConcurrentMap}.
- */
-atomicMapOperations = function(cache) {
- console.log(">>> Cache atomic map operation examples.");
+ onGetAndPut = function(err, entry) {
+ console.log(">>> Get and put finished [result=" + entry + "]");
- cache.removeAllFromCache(function(err) {
- cache.getAndPut(1, "1", onGetAndPut.bind(null, cache))
- });
-}
+ // Put and do not return previous value.
+ // Performs better when previous value is not needed.
+ cache.put(2, "2", onPut);
+ }
-function onGetAndPut(cache, err, entry) {
- cache.put(2, "2", onPut.bind(null, cache));
-}
+ onPut = function(err) {
+ console.log(">>> Put finished.");
-function onPut(cache, err) {
- cache.putIfAbsent(4, "44", onPutIfAbsent.bind(null, cache, true));
-}
+ // Put-if-absent.
+ cache.putIfAbsent(4, "44", onPutIfAbsent);
+ }
-function onPutIfAbsent(cache, expRes, err, res) {
- if (expRes) {
- cache.putIfAbsent(4, "44", onPutIfAbsent.bind(null, cache, false));
- }
- else {
- cache.replaceValue(4, "55", "44", onReplaceValue.bind(null, cache, true));
+ onPutIfAbsent = function(err, res) {
+ console.log(">>> Put if absent finished [result=" + res + "]");
+
+ // Replace.
+ cache.replaceValue(4, "55", "44", onReplaceValue);
+ }
+
+ onReplaceValue = function(err, res) {
+ console.log(">>> Replace value finished [result=" + res + "]");
+
+ // Replace not correct value.
+ cache.replaceValue(4, "555", "44", onEnd);
+ }
+
+ onEnd = function(err) {
+ console.log(">>> Replace finished.");
+
+ // Destroying cache.
+ ignite.destroyCache(cacheName, function(err) {
+ console.log(">>> End of Cache API example.");
+ });
+ }
}
}
-function onReplaceValue(cache, expRes, err, res) {
- if (expRes) {
- cache.replaceValue(4, "555", "44", onReplaceValue.bind(null, cache, false));
- }
- else {
- console.log("End of the example.")
- }
-}
\ No newline at end of file
+main();
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/242c21bb/modules/nodejs/src/main/js/ignite.js
----------------------------------------------------------------------
diff --git a/modules/nodejs/src/main/js/ignite.js b/modules/nodejs/src/main/js/ignite.js
index 5dfb15b..a4a1dd9 100644
--- a/modules/nodejs/src/main/js/ignite.js
+++ b/modules/nodejs/src/main/js/ignite.js
@@ -59,7 +59,7 @@ Ignite.prototype.cache = function(cacheName) {
* @param callback Callback with cache.
*/
Ignite.prototype.getOrCreateCache = function(cacheName, callback) {
- var onCreateCallback = function(err) {
+ var onCreateCallback = function(callback, err, res) {
if (err !== null) {
callback.call(null, err, null);
@@ -70,7 +70,7 @@ Ignite.prototype.getOrCreateCache = function(cacheName, callback) {
}
this._server.runCommand(new Command("getorcreatecache").addParam("cacheName", cacheName),
- onCreateCallback.bind(this));
+ onCreateCallback.bind(this, callback));
}
/**