You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by sb...@apache.org on 2015/03/04 14:33:45 UTC
[01/11] incubator-ignite git commit: # IGNITE-344 Fixed cache clear
and cache load sizes + minor cleanup of Visor-console code.
Repository: incubator-ignite
Updated Branches:
refs/heads/ignite-349 83dabe67d -> 887b88e14
# IGNITE-344 Fixed cache clear and cache load sizes + minor cleanup of Visor-console code.
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/4348d9ca
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/4348d9ca
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/4348d9ca
Branch: refs/heads/ignite-349
Commit: 4348d9ca8a0e6e95817ec90b43bc4f39847e1d9e
Parents: 47539d8
Author: AKuznetsov <ak...@gridgain.com>
Authored: Fri Feb 27 10:07:51 2015 +0700
Committer: AKuznetsov <ak...@gridgain.com>
Committed: Fri Feb 27 10:07:51 2015 +0700
----------------------------------------------------------------------
.../visor/cache/VisorCacheClearTask.java | 3 +-
.../visor/cache/VisorCacheLoadTask.java | 3 +-
.../scala/org/apache/ignite/visor/Packet.scala | 38 ------
.../ignite/visor/commands/VisorConsole.scala | 2 -
.../ignite/visor/commands/ack/Packet.scala | 55 --------
.../visor/commands/ack/VisorAckCommand.scala | 2 +-
.../ignite/visor/commands/alert/Packet.scala | 108 ----------------
.../ignite/visor/commands/cache/Packet.scala | 127 -------------------
.../commands/cache/VisorCacheCommand.scala | 2 +-
.../ignite/visor/commands/config/Packet.scala | 55 --------
.../ignite/visor/commands/deploy/Packet.scala | 76 -----------
.../ignite/visor/commands/disco/Packet.scala | 72 -----------
.../ignite/visor/commands/events/Packet.scala | 97 --------------
.../ignite/visor/commands/gc/Packet.scala | 61 ---------
.../ignite/visor/commands/kill/Packet.scala | 78 ------------
.../visor/commands/kill/VisorKillCommand.scala | 2 +-
.../ignite/visor/commands/node/Packet.scala | 60 ---------
.../ignite/visor/commands/ping/Packet.scala | 50 --------
.../visor/commands/ping/VisorPingCommand.scala | 2 +-
.../ignite/visor/commands/start/Packet.scala | 90 -------------
.../ignite/visor/commands/tasks/Packet.scala | 116 -----------------
.../commands/tasks/VisorTasksCommand.scala | 26 +---
.../ignite/visor/commands/top/Packet.scala | 87 -------------
.../ignite/visor/commands/vvm/Packet.scala | 61 ---------
24 files changed, 15 insertions(+), 1258 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/4348d9ca/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorCacheClearTask.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorCacheClearTask.java b/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorCacheClearTask.java
index f425d75..f341a04 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorCacheClearTask.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorCacheClearTask.java
@@ -18,6 +18,7 @@
package org.apache.ignite.internal.visor.cache;
import org.apache.ignite.*;
+import org.apache.ignite.cache.*;
import org.apache.ignite.compute.*;
import org.apache.ignite.internal.processors.task.*;
import org.apache.ignite.internal.util.typedef.internal.*;
@@ -147,7 +148,7 @@ public class VisorCacheClearTask extends VisorOneNodeTask<String, IgniteBiTuple<
/** {@inheritDoc} */
@Override public Integer call() throws Exception {
- return cache.size();
+ return cache.size(CachePeekMode.PRIMARY);
}
}
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/4348d9ca/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorCacheLoadTask.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorCacheLoadTask.java b/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorCacheLoadTask.java
index 329772c..189a07d 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorCacheLoadTask.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorCacheLoadTask.java
@@ -18,6 +18,7 @@
package org.apache.ignite.internal.visor.cache;
import org.apache.ignite.*;
+import org.apache.ignite.cache.*;
import org.apache.ignite.internal.processors.task.*;
import org.apache.ignite.internal.util.lang.*;
import org.apache.ignite.internal.util.typedef.internal.*;
@@ -80,7 +81,7 @@ public class VisorCacheLoadTask extends
cache.loadCache(null, ldrArgs);
- res.put(cacheName, cache.size());
+ res.put(cacheName, cache.size(CachePeekMode.PRIMARY));
}
return res;
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/4348d9ca/modules/visor-console/src/main/scala/org/apache/ignite/visor/Packet.scala
----------------------------------------------------------------------
diff --git a/modules/visor-console/src/main/scala/org/apache/ignite/visor/Packet.scala b/modules/visor-console/src/main/scala/org/apache/ignite/visor/Packet.scala
deleted file mode 100644
index bee86ae..0000000
--- a/modules/visor-console/src/main/scala/org/apache/ignite/visor/Packet.scala
+++ /dev/null
@@ -1,38 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.ignite
-
-/**
- * {{{
- * ___ _________________________ ________
- * __ | / /____ _/__ ___/__ __ \___ __ \
- * __ | / / __ / _____ \ _ / / /__ /_/ /
- * __ |/ / __/ / ____/ / / /_/ / _ _, _/
- * _____/ /___/ /____/ \____/ /_/ |_|
- *
- * }}}
- *
- * ==Overview==
- * Visor console provides monitoring capabilities for Ignite.
- *
- * ==Usage==
- * Ignite ships with `IGNITE_HOME/bin/ignitevisorcmd.{sh|bat}` script that starts Visor console.
- *
- * Just type:<ex>help</ex> in Visor console to get help and get started.
- */
-package object visor
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/4348d9ca/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/VisorConsole.scala
----------------------------------------------------------------------
diff --git a/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/VisorConsole.scala b/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/VisorConsole.scala
index 62f590e..f8c5e19 100644
--- a/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/VisorConsole.scala
+++ b/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/VisorConsole.scala
@@ -304,8 +304,6 @@ private[commands] class VisorFileNameCompleter extends Completer {
if (files.size == 1) {
val candidate = files(0)
- if (candidate.isDirectory) separator else " "
-
candidates.add(candidate.getName + (if (candidate.isDirectory) separator else " "))
}
else
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/4348d9ca/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/ack/Packet.scala
----------------------------------------------------------------------
diff --git a/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/ack/Packet.scala b/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/ack/Packet.scala
deleted file mode 100644
index 1529d71..0000000
--- a/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/ack/Packet.scala
+++ /dev/null
@@ -1,55 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.ignite.visor.commands
-
-/**
- * ==Overview==
- * Visor 'ack' command implementation.
- *
- * ==Help==
- * {{{
- * +-------------------------------------------+
- * | ack | Acks arguments on all remote nodes. |
- * +-------------------------------------------+
- * }}}
- *
- * ====Specification====
- * {{{
- * ack {"s"}
- * ack ("s", f)
- * }}}
- *
- * ====Arguments====
- * {{{
- * s
- * Optional string to print on each remote node.
- * f
- * Optional Scala predicate on 'ScalarRichNodePimp' filtering nodes in the topology.
- * }}}
- *
- * ====Examples====
- * {{{
- * ack "Howdy!"
- * Prints 'Howdy!' on all nodes in the topology.
- * ack("Howdy!", _.id8.startsWith("123"))
- * Prints 'Howdy!' on all nodes satisfying this predicate.
- * ack
- * Prints local node ID on all nodes in the topology.
- * }}}
- */
-package object ack
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/4348d9ca/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/ack/VisorAckCommand.scala
----------------------------------------------------------------------
diff --git a/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/ack/VisorAckCommand.scala b/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/ack/VisorAckCommand.scala
index 760edde..25d4ad7 100644
--- a/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/ack/VisorAckCommand.scala
+++ b/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/ack/VisorAckCommand.scala
@@ -157,5 +157,5 @@ object VisorAckCommand {
*
* @param vs Visor tagging trait.
*/
- implicit def fromAck2Visor(vs: VisorTag) = cmd
+ implicit def fromAck2Visor(vs: VisorTag): VisorAckCommand = cmd
}
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/4348d9ca/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/alert/Packet.scala
----------------------------------------------------------------------
diff --git a/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/alert/Packet.scala b/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/alert/Packet.scala
deleted file mode 100644
index 8322228..0000000
--- a/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/alert/Packet.scala
+++ /dev/null
@@ -1,108 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.ignite.visor.commands
-
-/**
- * ==Overview==
- * Visor 'alert' command implementation.
- *
- * ==Help==
- * {{{
- * +---------------------------------------------------------------------+
- * | alert | Generates email alerts for user-defined events. |
- * | | Node events and grid-wide events are defined via mnemonics. |
- * +---------------------------------------------------------------------+
- * }}}
- *
- * ====Specification====
- * {{{
- * alert
- * alert "-u {-id=<alert-id>|-a}"
- * alert "-r {-t=<sec>} -c1=e1<num> -c2=e2<num> ... -ck=ek<num>"
- * }}}
- *
- * ====Arguments====
- * {{{
- * -u
- * Unregisters alert(s). Either '-a' flag or '-id' parameter is required.
- * Note that only one of the '-u' or '-r' is allowed.
- * If neither '-u' or '-r' provided - all alerts will be printed.
- * -a
- * When provided with '-u' - all alerts will be unregistered.
- * -id=<alert-id>
- * When provided with '-u' - alert with matching ID will be unregistered.
- * -r
- * Register new alert with mnemonic predicate(s).
- * Note that only one of the '-u' or '-r' is allowed.
- * If neither '-u' or '-r' provided - all alerts will be printed.
- * -t
- * Defines notification frequency in seconds. Default is 15 minutes.
- * This parameter can only appear with '-r'.
- * -ck=ek<num>
- * This defines a mnemonic for the metric that will be measured:
- * Grid-wide metrics (not node specific):
- * -cc Total number of available CPUs in the grid.
- * -nc Total number of nodes in the grid.
- * -hc Total number of physical hosts in the grid.
- * -cl Current average CPU load (in %) in the grid.
- *
- * Per-node current metrics:
- * -aj Active jobs on the node.
- * -cj Cancelled jobs on the node.
- * -tc Thread count on the node.
- * -it Idle time on the node.
- * Note: <num> can have 's', 'm', or 'h' suffix indicating
- * seconds, minutes, and hours. By default (no suffix provided)
- * value is assumed to be in milliseconds.
- * -ut Up time on the node.
- * Note: <num> can have 's', 'm', or 'h' suffix indicating
- * seconds, minutes, and hours. By default (no suffix provided)
- * value is assumed to be in milliseconds.
- * -je Job execute time on the node.
- * -jw Job wait time on the node.
- * -wj Waiting jobs count on the node.
- * -rj Rejected jobs count on the node.
- * -hu Heap memory used (in MB) on the node.
- * -cd Current CPU load on the node.
- * -hm Heap memory maximum (in MB) on the node.
- *
- * Comparison part of the mnemonic predicate:
- * =eq<num> Equal '=' to '<num>' number.
- * =neq<num> Not equal '!=' to '<num>' number.
- * =gt<num> Greater than '>' to '<num>' number.
- * =gte<num> Greater than or equal '>=' to '<num>' number.
- * =lt<num> Less than '<' to 'NN' number.
- * =lte<num> Less than or equal '<=' to '<num>' number.
- *
- * NOTE: Email notification will be sent for the alert only when all
- * provided mnemonic predicates evaluate to 'true'.
- * }}}
- *
- * ====Examples====
- * {{{
- * alert
- * Prints all currently registered alerts.
- * alert "-u -a"
- * Unregisters all currently registered alerts.
- * alert "-u -id=12345678"
- * Unregisters alert with provided ID.
- * alert "-r -t=900 -cc=gte4 -cl=gt50"
- * Notify every 15 min if grid has >= 4 CPUs and > 50% CPU load.
- * }}}
- */
-package object alert
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/4348d9ca/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/cache/Packet.scala
----------------------------------------------------------------------
diff --git a/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/cache/Packet.scala b/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/cache/Packet.scala
deleted file mode 100644
index 443c4ce..0000000
--- a/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/cache/Packet.scala
+++ /dev/null
@@ -1,127 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.ignite.visor.commands
-
-/**
- * ==Overview==
- * Visor 'cache' command implementation.
- *
- * ==Help==
- * {{{
- * +-----------------------------------------------------------------------------------------+
- * | cache | Prints statistics about caches from specified node on the entire grid. |
- * | | Output sorting can be specified in arguments. |
- * | | |
- * | | Output abbreviations: |
- * | | # Number of nodes. |
- * | | H/h Number of cache hits. |
- * | | M/m Number of cache misses. |
- * | | R/r Number of cache reads. |
- * | | W/w Number of cache writes. |
- * +-----------------------------------------------------------------------------------------+
- * | cache -compact | Compacts all entries in cache on all nodes. |
- * +-----------------------------------------------------------------------------------------+
- * | cache -clear | Clears all entries from cache on all nodes. |
- * +-----------------------------------------------------------------------------------------+
- * | cache -scan | List all entries in cache with specified name. |
- * +-----------------------------------------------------------------------------------------+
- * }}}
- *
- * ====Specification====
- * {{{
- * cache
- * cache -i
- * cache {-c=<cache-name>} {-id=<node-id>|id8=<node-id8>} {-s=lr|lw|hi|mi|re|wr} {-a} {-r}
- * cache -clear {-c=<cache-name>}
- * cache -compact {-c=<cache-name>}
- * cache -scan -c=<cache-name> {-id=<node-id>|id8=<node-id8>} {-p=<page size>}
- * }}}
- *
- * ====Arguments====
- * {{{
- * -id=<node-id>
- * Full ID of the node to get cache statistics from.
- * Either '-id8' or '-id' can be specified.
- * If neither is specified statistics will be gathered from all nodes.
- * -id8=<node-id>
- * ID8 of the node to get cache statistics from.
- * Either '-id8' or '-id' can be specified.
- * If neither is specified statistics will be gathered from all nodes.
- * -c=<cache-name>
- * Name of the cache.
- * -s=lr|lw|hi|mi|re|wr|cn
- * Defines sorting type. Sorted by:
- * lr Last read.
- * lw Last write.
- * hi Hits.
- * mi Misses.
- * rd Reads.
- * wr Writes.
- * If not specified - default sorting is 'lr'.
- * -i
- * Interactive mode.
- * User can interactively select node for cache statistics.
- * -r
- * Defines if sorting should be reversed.
- * Can be specified only with '-s' argument.
- * -a
- * Prints details statistics about each cache.
- * By default only aggregated summary is printed.
- * -compact
- * Compacts entries in cache.
- * -clear
- * Clears cache.
- * -scan
- * Prints list of all entries from cache.
- * -p=<page size>
- * Number of object to fetch from cache at once.
- * Valid range from 1 to 100.
- * By default page size is 25.
- * }}}
- *
- * ====Examples====
- * {{{
- * cache
- * Prints summary statistics about all caches.
- * cache -id8=12345678 -s=hi -r
- * Prints summary statistics about caches from node with specified id8
- * sorted by number of hits in reverse order.
- * cache -i
- * Prints cache statistics for interactively selected node.
- * cache -s=hi -r -a
- * Prints detailed statistics about all caches sorted by number of hits in reverse order.
- * cache -compact
- * Compacts entries in interactively selected cache.
- * cache -compact -c=cache
- * Compacts entries in cache with name 'cache'.
- * cache -clear
- * Clears interactively selected cache.
- * cache -clear -c=cache
- * Clears cache with name 'cache'.
- * cache -scan
- * Prints list entries from interactively selected cache.
- * cache -scan -c=cache
- * Prints list entries from cache with name 'cache' from all nodes with this cache.
- * cache -scan -c=@c0 -p=50
- * Prints list entries from cache with name taken from 'c0' memory variable
- * with page of 50 items from all nodes with this cache.
- * cache -scan -c=cache -id8=12345678
- * Prints list entries from cache with name 'cache' and node '12345678' ID8.
- * }}}
- */
-package object cache
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/4348d9ca/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/cache/VisorCacheCommand.scala
----------------------------------------------------------------------
diff --git a/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/cache/VisorCacheCommand.scala b/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/cache/VisorCacheCommand.scala
index 3c1aa01..dbbdbbc 100644
--- a/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/cache/VisorCacheCommand.scala
+++ b/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/cache/VisorCacheCommand.scala
@@ -581,7 +581,7 @@ class VisorCacheCommand {
val sumT = VisorTextTable()
- sumT #= ("#", "Name(@),", "Nodes", "Size")
+ sumT #= ("#", "Name(@)", "Nodes", "Size")
(0 until sortedAggrData.size) foreach (i => {
val ad = sortedAggrData(i)
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/4348d9ca/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/config/Packet.scala
----------------------------------------------------------------------
diff --git a/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/config/Packet.scala b/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/config/Packet.scala
deleted file mode 100644
index c99dd98..0000000
--- a/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/config/Packet.scala
+++ /dev/null
@@ -1,55 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.ignite.visor.commands
-
-/**
- * ==Overview==
- * Visor 'config' command implementation.
- *
- * ==Help==
- * {{{
- * +-------------------------------------+
- * | config | Prints node configuration. |
- * +-------------------------------------+
- * }}}
- *
- * ====Specification====
- * {{{
- * config
- * config "{-id=<node-id>|id8=<node-id8>}"
- * }}}
- *
- * ====Arguments====
- * {{{
- * -id=<node-id>
- * Full node ID. Either '-id8' or '-id' can be specified.
- * If neither is specified - command starts in interactive mode.
- * -id8=<node-id8>
- * Node ID8. Either '-id8' or '-id' can be specified.
- * If neither is specified - command starts in interactive mode.
- * }}}
- *
- * ====Examples====
- * {{{
- * config "-id8=12345678"
- * Prints configuration for node with '12345678' ID8.
- * config
- * Starts command in interactive mode.
- * }}}
- */
-package object config
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/4348d9ca/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/deploy/Packet.scala
----------------------------------------------------------------------
diff --git a/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/deploy/Packet.scala b/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/deploy/Packet.scala
deleted file mode 100644
index 5e5f285..0000000
--- a/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/deploy/Packet.scala
+++ /dev/null
@@ -1,76 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.ignite.visor.commands
-
-/**
- * ==Overview==
- * Visor 'deploy' command implementation.
- *
- * ==Help==
- * {{{
- * +---------------------------------------------------+
- * | deploy | Copies file or directory to remote host. |
- * | | Command relies on SFTP protocol. |
- * +---------------------------------------------------+
- * }}}
- *
- * ====Specification====
- * {{{
- * deploy "-h={<username>{:<password>}@}<host>{:<port>} {-u=<username>}
- * {-p=<password>} {-k=<path>} -s=<path> {-d<path>}"
- * }}}
- *
- * ====Arguments====
- * {{{
- * -h={<username>{:<password>}@}<host>{:<port>}
- * Host specification.
- *
- * <host> can be a hostname, IP or range of IPs.
- * Example of range is 192.168.1.100~150,
- * which means all IPs from 192.168.1.100 to 192.168.1.150 inclusively.
- *
- * Default port number is 22.
- *
- * This option can be provided multiple times.
- * -u=<username>
- * Default username.
- * Used if specification doesn't contain username.
- * If default is not provided as well, current local username will be used.
- * -p=<password>
- * Default password.
- * Used if specification doesn't contain password.
- * If default is not provided as well, it will be asked interactively.
- * -k=<path>
- * Path to private key file.
- * If provided, it will be used for all specifications that doesn't contain password.
- * -s=<path>
- * Source path.
- * -d=<path>
- * Destination path (relative to IGNITE_HOME).
- * If not provided, files will be copied to the root of IGNITE_HOME.
- * }}}
- *
- * ====Examples====
- * {{{
- * deploy "-h=uname:passwd@host -s=/local/path -d=/remote/path"
- * Copies file or directory to remote host (password authentication).
- * deploy "-h=uname@host -k=ssh-key.pem -s=/local/path -d=/remote/path"
- * Copies file or directory to remote host (private key authentication).
- * }}}
- */
-package object deploy
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/4348d9ca/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/disco/Packet.scala
----------------------------------------------------------------------
diff --git a/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/disco/Packet.scala b/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/disco/Packet.scala
deleted file mode 100644
index b6257d7..0000000
--- a/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/disco/Packet.scala
+++ /dev/null
@@ -1,72 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.ignite.visor.commands
-
-/**
- * ==Overview==
- * Visor 'disco' command implementation.
- *
- * ==Help==
- * {{{
- * +---------------------------------------------------------------------------------------+
- * | disco | Prints topology change log as seen from the oldest node. |
- * | | Timeframe for quering events can be specified in arguments. |
- * | | |
- * | | Note that this command depends on Ignite events. |
- * | | |
- * | | Ignite events can be individually enabled and disabled and disabled events |
- * | | can affect the results produced by this command. Note also that configuration |
- * | | of Event Storage SPI that is responsible for temporary storage of generated |
- * | | events on each node can also affect the functionality of this command. |
- * | | |
- * | | By default - all events are enabled and Ignite stores last 10,000 local |
- * | | events on each node. Both of these defaults can be changed in configuration. |
- * +---------------------------------------------------------------------------------------+
- * }}}
- *
- * ====Specification====
- * {{{
- * disco
- * disco "{-t=<num>s|m|h|d} {-r} {-c=<n>}"
- * }}}
- *
- * ====Arguments====
- * {{{
- * -t=<num>s|m|h|d
- * Defines timeframe for querying events:
- * =<num>s Events fired during last <num> seconds.
- * =<num>m Events fired during last <num> minutes.
- * =<num>h Events fired during last <num> hours.
- * =<num>d Events fired during last <num> days.
- * -r
- * Defines whether sorting should be reversed.
- * -c=<n>
- * Defines the maximum events count that can be shown.
- * }}}
- *
- * ====Examples====
- * {{{
- * disco
- * Prints all discovery events sorted chronologically (oldest first).
- * disco "-r"
- * Prints all discovery events sorted chronologically in reversed order (newest first).
- * disco "-t=2m"
- * Prints discovery events fired during last two minutes sorted chronologically.
- * }}}
- */
-package object disco
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/4348d9ca/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/events/Packet.scala
----------------------------------------------------------------------
diff --git a/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/events/Packet.scala b/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/events/Packet.scala
deleted file mode 100644
index b4f0546..0000000
--- a/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/events/Packet.scala
+++ /dev/null
@@ -1,97 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.ignite.visor.commands
-
-/**
- * ==Overview==
- * Visor 'events' commands implementation.
- *
- * ==Help==
- * {{{
- * +----------------------------------------------------------------------------------------+
- * | events | Print events from a node. |
- * | | |
- * | | Note that this command depends on Ignite events. |
- * | | |
- * | | Ignite events can be individually enabled and disabled and disabled events |
- * | | can affect the results produced by this command. Note also that configuration |
- * | | of Event Storage SPI that is responsible for temporary storage of generated |
- * | | events on each node can also affect the functionality of this command. |
- * | | |
- * | | By default - all events are enabled and Ignite stores last 10,000 local |
- * | | events on each node. Both of these defaults can be changed in configuration. |
- * +----------------------------------------------------------------------------------------+
- * }}}
- *
- * ====Specification====
- * {{{
- * events
- * events "{-id=<node-id>|-id8=<node-id8>} {-e=<ch,cp,de,di,jo,ta,cl,ca,sw>}
- * {-t=<num>s|m|h|d} {-s=e|t} {-r} {-c=<n>}"
- * }}}
- *
- * ====Arguments====
- * {{{
- * -id=<node-id>
- * Full node ID.
- * Either '-id' or '-id8' can be specified.
- * If called without the arguments - starts in interactive mode.
- * -id8
- * Node ID8.
- * Either '-id' or '-id8' can be specified.
- * If called without the arguments - starts in interactive mode.
- * -e=<ch,de,di,jo,ta,cl,ca,sw>
- * Comma separated list of event types that should be queried:
- * ch Checkpoint events.
- * de Deployment events.
- * di Discovery events.
- * jo Job execution events.
- * ta Task execution events.
- * ca Cache events.
- * cp Cache pre-loader events.
- * sw Swapspace events.
- * -t=<num>s|m|h|d
- * Defines time frame for querying events:
- * =<num>s Queries events fired during last <num> seconds.
- * =<num>m Queries events fired during last <num> minutes.
- * =<num>h Queries events fired during last <num> hours.
- * =<num>d Queries events fired during last <num> days.
- * -s=e|t
- * Defines sorting of queried events:
- * =e Sorted by event type.
- * =t Sorted chronologically.
- * Only one '=e' or '=t' can be specified.
- * -r
- * Defines if sorting should be reversed.
- * Can be specified only with -s argument.
- * -c=<n>
- * Defines the maximum events count that can be shown.
- * Values in summary tables are calculated over the whole list of events.
- * }}}
- *
- * ====Examples====
- * {{{
- * events "-id8=12345678"
- * Queries all events from node with '12345678' ID8.
- * events "-id8=12345678 -e=di,ca"
- * Queries discovery and cache events from node with '12345678' ID8.
- * events
- * Starts command in interactive mode.
- * }}}
- */
-package object events
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/4348d9ca/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/gc/Packet.scala
----------------------------------------------------------------------
diff --git a/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/gc/Packet.scala b/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/gc/Packet.scala
deleted file mode 100644
index 6bcfca8..0000000
--- a/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/gc/Packet.scala
+++ /dev/null
@@ -1,61 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.ignite.visor.commands
-
-/**
- * ==Overview==
- * Contains Visor command `gc` implementation.
- *
- * ==Help==
- * {{{
- * +---------------------------------------------------------------------------+
- * | gc | Runs garbage collector on remote nodes. |
- * | | If specific node is provided, garbage collector is run on that node. |
- * | | Otherwise, it will be run on all nodes in topology. |
- * +---------------------------------------------------------------------------+
- * }}}
- *
- * ====Specification====
- * {{{
- * gc
- * gc "{-id8=<node-id8>|-id=<node-id>} {-c}"
- * }}}
- *
- * ====Arguments====
- * {{{
- * -id8=<node-id8>
- * ID8 of the node.
- * Note that either '-id8' or '-id' can be specified.
- * -id=<node-id>
- * ID of the node.
- * Note that either '-id8' or '-id' can be specified.
- * -c
- * Run DGC procedure on all caches.
- * }}}
- *
- * ====Examples====
- * {{{
- * gc "-id8=12345678"
- * Runs garbage collector on specified node.
- * gc
- * Runs garbage collector on all nodes in topology.
- * gc "-id8=12345678 -c"
- * Runs garbage collector and DGC procedure on all caches.
- * }}}
- */
-package object gc
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/4348d9ca/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/kill/Packet.scala
----------------------------------------------------------------------
diff --git a/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/kill/Packet.scala b/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/kill/Packet.scala
deleted file mode 100644
index 7029a4b..0000000
--- a/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/kill/Packet.scala
+++ /dev/null
@@ -1,78 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.ignite.visor.commands
-
-/**
- * ==Overview==
- * Contains Visor command `kill` implementation.
- *
- * ==Help==
- * {{{
- * +--------------------------------+
- * | kill | Kills or restarts node. |
- * +--------------------------------+
- * }}}
- *
- * ====Specification====
- * {{{
- * kill
- * kill "-in|-ih"
- * kill "{-r|-k} {-id8=<node-id8>|-id=<node-id>}"
- * }}}
- *
- * ====Arguments====
- * {{{
- * -in
- * Run command in interactive mode with ability to
- * choose a node to kill or restart.
- * Note that either '-in' or '-ih' can be specified.
- *
- * This mode is used by default.
- * -ih
- * Run command in interactive mode with ability to
- * choose a host where to kill or restart nodes.
- * Note that either '-in' or '-ih' can be specified.
- * -r
- * Restart node mode.
- * Note that either '-r' or '-k' can be specified.
- * If no parameters provided - command starts in interactive mode.
- * -k
- * Kill (stop) node mode.
- * Note that either '-r' or '-k' can be specified.
- * If no parameters provided - command starts in interactive mode.
- * -id8=<node-id8>
- * ID8 of the node to kill or restart.
- * Note that either '-id8' or '-id' can be specified.
- * If no parameters provided - command starts in interactive mode.
- * -id=<node-id>
- * ID of the node to kill or restart.
- * Note that either '-id8' or '-id' can be specified.
- * If no parameters provided - command starts in interactive mode.
- * }}}
- *
- * ====Examples====
- * {{{
- * kill
- * Starts command in interactive mode.
- * kill "-id8=12345678 -r"
- * Restart node with '12345678' ID8.
- * kill "-k"
- * Kill (stop) all nodes.
- * }}}
- */
-package object kill
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/4348d9ca/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/kill/VisorKillCommand.scala
----------------------------------------------------------------------
diff --git a/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/kill/VisorKillCommand.scala b/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/kill/VisorKillCommand.scala
index 3c9b3d6..a8263e4 100644
--- a/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/kill/VisorKillCommand.scala
+++ b/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/kill/VisorKillCommand.scala
@@ -352,5 +352,5 @@ object VisorKillCommand {
*
* @param vs Visor tagging trait.
*/
- implicit def fromKill2Visor(vs: VisorTag) = cmd
+ implicit def fromKill2Visor(vs: VisorTag): VisorKillCommand = cmd
}
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/4348d9ca/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/node/Packet.scala
----------------------------------------------------------------------
diff --git a/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/node/Packet.scala b/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/node/Packet.scala
deleted file mode 100644
index e070322..0000000
--- a/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/node/Packet.scala
+++ /dev/null
@@ -1,60 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.ignite.visor.commands
-
-/**
- * ==Overview==
- * Contains Visor command `node` implementation.
- *
- * ==Help==
- * {{{
- * +--------------------------------+
- * | node | Prints node statistics. |
- * +--------------------------------+
- * }}}
- *
- * ====Specification====
- * {{{
- * node "{-id8=<node-id8>|-id=<node-id>} {-a}"
- * node
- * }}}
- *
- * ====Arguments====
- * {{{
- * -id8=<node-id8>
- * ID8 of node. Either '-id8' or '-id' can be specified.
- * If neither specified - command starts in interactive mode.
- * -id=<node-id>
- * Full ID of node. Either '-id8' or '-id' can be specified.
- * If neither specified - command starts in interactive mode.
- * -a
- * Print extended information.
- * By default - only abbreviated statistics is printed.
- * }}}
- *
- * ====Examples====
- * {{{
- * node
- * Starts command in interactive mode.
- * node "-id8=12345678"
- * Prints statistics for specified node.
- * node "-id8=12345678 -a"
- * Prints full statistics for specified node.
- * }}}
- */
-package object node
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/4348d9ca/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/ping/Packet.scala
----------------------------------------------------------------------
diff --git a/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/ping/Packet.scala b/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/ping/Packet.scala
deleted file mode 100644
index eb824e8..0000000
--- a/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/ping/Packet.scala
+++ /dev/null
@@ -1,50 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.ignite.visor.commands
-
-/**
- * ==Command==
- * Visor 'ping' command implementation.
- *
- * ==Help==
- * {{{
- * +--------------------+
- * | ping | Pings node. |
- * +--------------------+
- * }}}
- *
- * ====Specification====
- * {{{
- * ping {"id81 id82 ... id8k"}
- * }}}
- *
- * ====Arguments====
- * {{{
- * id8k
- * ID8 of the node to ping.
- * }}}
- *
- * ====Examples====
- * {{{
- * ping "12345678"
- * Pings node with '12345678' ID8.
- * ping
- * Pings all nodes in the topology.
- * }}}
- */
-package object ping
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/4348d9ca/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/ping/VisorPingCommand.scala
----------------------------------------------------------------------
diff --git a/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/ping/VisorPingCommand.scala b/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/ping/VisorPingCommand.scala
index e19dba2..7027354 100644
--- a/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/ping/VisorPingCommand.scala
+++ b/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/ping/VisorPingCommand.scala
@@ -224,5 +224,5 @@ object VisorPingCommand {
*
* @param vs Visor tagging trait.
*/
- implicit def fromPing2Visor(vs: VisorTag) = cmd
+ implicit def fromPing2Visor(vs: VisorTag): VisorPingCommand = cmd
}
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/4348d9ca/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/start/Packet.scala
----------------------------------------------------------------------
diff --git a/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/start/Packet.scala b/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/start/Packet.scala
deleted file mode 100644
index 55eb836..0000000
--- a/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/start/Packet.scala
+++ /dev/null
@@ -1,90 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.ignite.visor.commands
-
-/**
- * ==Overview==
- * Contains Visor command `start` implementation.
- *
- * ==Help==
- * {{{
- * +-----------------------------------------------------+
- * | start | Starts one or more nodes on remote host(s). |
- * | | Uses SSH protocol to execute commands. |
- * +-----------------------------------------------------+
- * }}}
- *
- * ====Specification====
- * {{{
- * start "-f=<path> {-m=<num>} {-r}"
- * start "-h=<hostname> {-p=<num>} {-u=<username>} {-pw=<password>} {-k=<path>}
- * {-n=<num>} {-g=<path>} {-c=<path>} {-s=<path>} {-m=<num>} {-r}"
- * }}}
- *
- * ====Arguments====
- * {{{
- * -f=<path>
- * Path to INI file that contains topology specification.
- * -h=<hostname>
- * Hostname where to start nodes.
- *
- * Can define several hosts if their IPs are sequential.
- * Example of range is 192.168.1.100~150,
- * which means all IPs from 192.168.1.100 to 192.168.1.150 inclusively.
- * -p=<num>
- * Port number (default is 22).
- * -u=<username>
- * Username (if not defined, current local username will be used).
- * -pw=<password>
- * Password (if not defined, private key file must be defined).
- * -k=<path>
- * Path to private key file. Define if key authentication is used.
- * -n=<num>
- * Expected number of nodes on the host.
- * If some nodes are started already, then only remaining nodes will be started.
- * If current count of nodes is equal to this number and '-r' flag is not set, then nothing will happen.
- * -g=<path>
- * Path to Ignite installation folder.
- * If not defined, IGNITE_HOME environment variable must be set on remote hosts.
- * -c=<path>
- * Path to configuration file (relative to Ignite home).
- * If not provided, default Ignite configuration is used.
- * -s=<path>
- * Path to start script (relative to Ignite home).
- * Default is "bin/ignite.sh" for Unix or
- * "bin\ignite.bat" for Windows.
- * -m=<num>
- * Defines maximum number of nodes that can be started in parallel on one host.
- * This actually means number of parallel SSH connections to each SSH server.
- * Default is 5.
- * -r
- * Indicates that existing nodes on the host will be restarted.
- * By default, if flag is not present, existing nodes will be left as is.
- * }}}
- *
- * ====Examples====
- * {{{
- * start "-h=10.1.1.10 -u=uname -pw=passwd -n=3"
- * Starts three nodes with default configuration (password authentication).
- * start "-h=192.168.1.100~104 -u=uname -k=/home/uname/.ssh/is_rsa -n=5"
- * Starts 25 nodes on 5 hosts (5 nodes per host) with default configuration (key-based authentication).
- * start "-f=start-nodes.ini -r"
- * Starts topology defined in 'start-nodes.ini' file. Existing nodes are stopped.
- * }}}
- */
-package object start
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/4348d9ca/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/tasks/Packet.scala
----------------------------------------------------------------------
diff --git a/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/tasks/Packet.scala b/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/tasks/Packet.scala
deleted file mode 100644
index ad35e06..0000000
--- a/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/tasks/Packet.scala
+++ /dev/null
@@ -1,116 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.ignite.visor.commands
-
-/**
- * ==Overview==
- * Visor 'tasks' command implementation.
- *
- * ==Help==
- * {{{
- * +---------------------------------------------------------------------------------------+
- * | tasks | Prints statistics about tasks and executions. |
- * | | |
- * | | Note that this command depends on Ignite events. |
- * | | |
- * | | Ignite events can be individually enabled and disabled and disabled events |
- * | | can affect the results produced by this command. Note also that configuration |
- * | | of Event Storage SPI that is responsible for temporary storage of generated |
- * | | events on each node can also affect the functionality of this command. |
- * | | |
- * | | By default - all events are enabled and Ignite stores last 10,000 local |
- * | | events on each node. Both of these defaults can be changed in configuration. |
- * +---------------------------------------------------------------------------------------+
- * }}}
- *
- * ====Specification====
- * {{{
- * tasks
- * tasks "-l {-t=<num>s|m|h|d} {-r}"
- * tasks "-s=<substring> {-t=<num>s|m|h|d} {-r}"
- * tasks "-g {-t=<num>s|m|h|d} {-r}"
- * tasks "-h {-t=<num>s|m|h|d} {-r}"
- * tasks "-n=<task-name> {-r}"
- * tasks "-e=<exec-id>"
- * }}}
- *
- * ====Arguments====
- * {{{
- * -l
- * List all tasks and executions for a given time period.
- * Executions sorted chronologically (see '-r'), and tasks alphabetically
- * See '-t=<num>s|m|h|d' on how to specify the time limit.
- * Default time period is one hour, i.e '-t=1h'
- *
- * This is a default mode when command is called without parameters.
- * -s=<substring>
- * List all tasks and executions for a given task name substring.
- * Executions sorted chronologically (see '-r'), and tasks alphabetically
- * See '-t=<num>s|m|h|d' on how to specify the time limit.
- * Default time period is one hour, i.e '-t=1h'
- * -g
- * List all tasks grouped by nodes for a given time period.
- * Tasks sorted alphabetically
- * See '-t=<num>s|m|h|d' on how to specify the time limit.
- * Default time period is one hour, i.e '-t=1h'
- * -h
- * List all tasks grouped by hosts for a given time period.
- * Tasks sorted alphabetically
- * See '-t=<num>s|m|h|d' on how to specify the time limit.
- * Default time period is one hour, i.e '-t=1h'
- * -t=<num>s|m|h|d
- * Defines time frame for '-l' parameter:
- * =<num>s Last <num> seconds.
- * =<num>m Last <num> minutes.
- * =<num>h Last <num> hours.
- * =<num>d Last <num> days.
- * -r
- * Reverse sorting of executions.
- * -n=<task-name>
- * Prints aggregated statistic for named task.
- * -e=<exec-id>
- * Prints aggregated statistic for given task execution.
- * }}}
- *
- * ====Examples====
- * {{{
- * tasks "-l"
- * Prints list of all tasks and executions for the last hour (default).
- * tasks
- * Prints list of all tasks and executions for the last hour (default).
- * tasks "-l -t=5m"
- * Prints list of tasks and executions that started during last 5 minutes.
- * tasks "-s=Task"
- * Prints list of all tasks and executions that have 'Task' in task name.
- * tasks "-g"
- * Prints list of tasks grouped by nodes.
- * tasks "-g -t=5m"
- * Prints list of tasks that started during last 5 minutes grouped by nodes.
- * tasks "-h"
- * Prints list of tasks grouped by hosts.
- * tasks "-h -t=5m"
- * Prints list of tasks that started during last 5 minutes grouped by hosts.
- * tasks "-n=GridTask"
- * Prints summary for task named 'GridTask'.
- * tasks "-e=7D5CB773-225C-4165-8162-3BB67337894B"
- * Traces task execution with ID '7D5CB773-225C-4165-8162-3BB67337894B'.
- * tasks "-e=@e1"
- * Traces task execution with ID taken from 'e1' memory variable.
- * }}}
- */
-package object tasks
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/4348d9ca/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/tasks/VisorTasksCommand.scala
----------------------------------------------------------------------
diff --git a/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/tasks/VisorTasksCommand.scala b/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/tasks/VisorTasksCommand.scala
index 4185d0c..723c135 100644
--- a/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/tasks/VisorTasksCommand.scala
+++ b/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/tasks/VisorTasksCommand.scala
@@ -638,14 +638,10 @@ class VisorTasksCommand {
execsT.maxCellWidth = 35
execsT #=(
- (
- "ID8(@ID), Start/End,",
- "State & Duration"
- ),
+ ("ID8(@ID), Start/End,", "State & Duration"),
"Task Name(@)",
"Nodes IP, ID8(@)",
- "Jobs"
- )
+ "Jobs")
var sortedExecs = if (!reverse) eLst.sortBy(_.startTs).reverse else eLst.sortBy(_.startTs)
@@ -900,14 +896,10 @@ class VisorTasksCommand {
execsT.maxCellWidth = 35
execsT #= (
- (
- "ID8(@ID), Start/End,",
- "State & Duration"
- ),
+ ("ID8(@ID), Start/End,", "State & Duration"),
"Task Name(@)",
"Nodes IP, ID8(@)",
- "Jobs"
- )
+ "Jobs")
var sorted = if (!reverse) eLst.sortBy(_.startTs).reverse else eLst.sortBy(_.startTs)
@@ -1025,14 +1017,10 @@ class VisorTasksCommand {
execT.maxCellWidth = 35
execT #= (
- (
- "ID8(@ID), Start/End,",
- "State & Duration"
- ),
+ ("ID8(@ID), Start/End,", "State & Duration"),
"Task Name(@)",
"Nodes IP, ID8(@)",
- "Jobs"
- )
+ "Jobs")
val e = eLst.head
@@ -1480,5 +1468,5 @@ object VisorTasksCommand {
*
* @param vs Visor tagging trait.
*/
- implicit def fromTrace2Visor(vs: VisorTag) = cmd
+ implicit def fromTrace2Visor(vs: VisorTag): VisorTasksCommand = cmd
}
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/4348d9ca/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/top/Packet.scala
----------------------------------------------------------------------
diff --git a/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/top/Packet.scala b/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/top/Packet.scala
deleted file mode 100644
index b34d4a9..0000000
--- a/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/top/Packet.scala
+++ /dev/null
@@ -1,87 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.ignite.visor.commands
-
-/**
- * ==Overview==
- * Contains Visor command `top` implementation.
- *
- * ==Help==
- * {{{
- * +--------------------------------+
- * | top | Prints current topology. |
- * +--------------------------------+
- * }}}
- *
- * ====Specification====
- * {{{
- * top "{-c1=e1<num> -c2=e2<num> ... -ck=ek<num>} {-h=<host1> ... -h=<hostk>} {-a}"
- * }}}
- *
- * ====Arguments====
- * {{{
- * -ck=ek<num>
- * This defines a mnemonic for node filter:
- * -cc Number of available CPUs on the node.
- * -cl Average CPU load (in %) on the node.
- * -aj Active jobs on the node.
- * -cj Cancelled jobs on the node.
- * -tc Thread count on the node.
- * -it Idle time on the node.
- * Note: <num> can have 's', 'm', or 'h' suffix indicating
- * seconds, minutes, and hours. By default (no suffix provided)
- * value is assumed to be in milliseconds.
- * -ut Up time on the node.
- * Note: <num> can have 's', 'm', or 'h' suffix indicating
- * seconds, minutes, and hours. By default (no suffix provided)
- * value is assumed to be in milliseconds.
- * -je Job execute time on the node.
- * -jw Job wait time on the node.
- * -wj Waiting jobs count on the node.
- * -rj Rejected jobs count on the node.
- * -hu Heap memory used (in MB) on the node.
- * -hm Heap memory maximum (in MB) on the node.
- *
- * Comparison part of the mnemonic predicate:
- * =eq<num> Equal '=' to '<num>' number.
- * =neq<num> Not equal '!=' to '<num>' number.
- * =gt<num> Greater than '>' to '<num>' number.
- * =gte<num> Greater than or equal '>=' to '<num>' number.
- * =lt<num> Less than '<' to '<num>' number.
- * =lte<num> Less than or equal '<=' to '<num>' number.
- * -h=<host>
- * This defines a host to show nodes from.
- * Multiple hosts can be provided.
- * -a
- * This defines whether to show a separate table of nodes
- * with detail per-node information.
- * }}}
- *
- * ====Examples====
- * {{{
- * top "-cc=eq2"
- * Prints topology for all nodes with two CPUs.
- * top "-cc=eq2 -a"
- * Prints full information for all nodes with two CPUs.
- * top "-h=10.34.2.122 -h=10.65.3.11"
- * Prints topology for provided hosts.
- * top
- * Prints full topology.
- * }}}
- */
-package object top
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/4348d9ca/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/vvm/Packet.scala
----------------------------------------------------------------------
diff --git a/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/vvm/Packet.scala b/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/vvm/Packet.scala
deleted file mode 100644
index b01fbcc..0000000
--- a/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/vvm/Packet.scala
+++ /dev/null
@@ -1,61 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.ignite.visor.commands
-
-/**
- * ==Overview==
- * Contains Visor command `vvm` implementation.
- *
- * ==Help==
- * {{{
- * +-----------------------+
- * | vvm | Opens VisualVM. |
- * +-----------------------+
- * }}}
- *
- * ====Specification====
- * {{{
- * vvm "{-home=dir} {-id8=<node-id8>} {-id=<node-id>}"
- * }}}
- *
- * ====Arguments====
- * {{{
- * -home=dir
- * VisualVM home directory.
- * If not specified, PATH and JAVA_HOME will be searched
- * -id8=<node-id8>
- * ID8 of node.
- * Either '-id8' or '-id' can be specified.
- * -id=<node-id>
- * Full ID of node.
- * Either '-id8' or '-id' can be specified.
- * }}}
- *
- * ====Examples====
- * {{{
- * vvm "-id8=12345678"
- * Opens VisualVM connected to JVM for node with '12345678' ID8.
- * vvm "-id=5B923966-85ED-4C90-A14C-96068470E94D"
- * Opens VisualVM connected to JVM for node with given full node ID.
- * vvm "-home=C:\VisualVM -id8=12345678"
- * Opens VisualVM installed in 'C:\VisualVM' directory for specified node.
- * vvm
- * Opens VisualVM connected to all nodes.
- * }}}
- */
-package object vvm
[04/11] incubator-ignite git commit: # sprint-2 - removing
gridgain.com.
Posted by sb...@apache.org.
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/c4030f92/modules/core/src/test/resources/log/ignite.log.tst
----------------------------------------------------------------------
diff --git a/modules/core/src/test/resources/log/ignite.log.tst b/modules/core/src/test/resources/log/ignite.log.tst
deleted file mode 100644
index ea74097..0000000
--- a/modules/core/src/test/resources/log/ignite.log.tst
+++ /dev/null
@@ -1,13706 +0,0 @@
-[14:14:22,515][INFO ][main][GridListenActorSelfTest]
-
->>> _____ _ _______ _
->>> / ___/____(_)___/ / ___/___ _(_)___
->>> / (_ // __/ // _ / (_ // _ `/ // _ \
->>> \___//_/ /_/ \_,_/\___/ \_,_/_//_//_/
->>>
->>> ---==++ IN-MEMORY BIG DATA ++==---
->>> ver. x.x.x-DDMMYYYY
->>> Copyright (C) 2012 GridGain Systems
-
-[14:14:22,515][INFO ][main][GridListenActorSelfTest] << Enterprise Edition >>
-[14:14:22,516][INFO ][main][GridListenActorSelfTest] Config URL: n/a
-[14:14:22,516][INFO ][main][GridListenActorSelfTest] Daemon mode: off
-[14:14:22,516][INFO ][main][GridListenActorSelfTest] Language runtime: Java Platform API Specification ver. 1.6
-[14:14:22,516][INFO ][main][GridListenActorSelfTest] JVM name: Java HotSpot(TM) 64-Bit Server VM
-[14:14:22,516][INFO ][main][GridListenActorSelfTest] Remote Management [restart: off, REST: on, JMX (remote: off)]
-[14:14:22,516][INFO ][main][GridListenActorSelfTest] GRIDGAIN_HOME=/usr/local/TeamCityAgent/work/d46fc9c3d71112c2
-[14:14:22,516][INFO ][main][GridListenActorSelfTest] VM arguments: [-ea, -XX:MaxPermSize=128m, -Xms512m, -Xmx1024m, -Duser.name=bamboo, -DGRIDGAIN_UPDATE_NOTIFIER=false, -DGRIDGAIN_DISABLED=true, -DGRIDGAIN_HOME=/usr/local/TeamCityAgent/work/d46fc9c3d71112c2, -DGRIDGAIN_STABLE_HOME=/usr/local/TeamCityAgent/work/d46fc9c3d71112c2, -DGRIDGAIN_ROUTER_PREFER_REMOTE=true, -DGRIDGAIN_NO_DISCO_ORDER=true, -DGRIDGAIN_QUIET=false, -DGG_TEST_HOME=/usr/local/TeamCityAgent/work/d46fc9c3d71112c2, -Dteamcity.build.id=34324, -Dteamcity.buildType.id=bt5, -Dagent.ownPort=9090, -Dteamcity.build.checkoutDir=/usr/local/TeamCityAgent/work/d46fc9c3d71112c2, -Dteamcity.build.workingDir=/usr/local/TeamCityAgent/work/d46fc9c3d71112c2, -Dagent.work.dir=/usr/local/TeamCityAgent/work, -Dagent.name=teamcity-4, -Dagent.home.dir=/usr/local/TeamCityAgent, -Dteamcity.runtime.props.file=/usr/local/TeamCityAgent/temp/agentTmp/ant2684847485530994862runtime]
-[14:14:22,517][WARN ][main][GridListenActorSelfTest] SMTP is not configured - email notifications are off.
-[14:14:22,517][WARN ][main][GridListenActorSelfTest] Cache is not configured - data grid is off.
-[14:14:22,521][INFO ][main][GridListenActorSelfTest] 3-rd party licenses can be found at: /usr/local/TeamCityAgent/work/d46fc9c3d71112c2/libs/licenses
-[14:14:22,522][INFO ][main][GridListenActorSelfTest] Non-loopback local IPs: fe80:0:0:0:ca60:ff:fe68:582c%2, 192.168.2.14
-[14:14:22,522][INFO ][main][GridListenActorSelfTest] Enabled local MACs: C8600068582C
-[14:14:23,112][INFO ][main][GridJdkLocalMetricsSpi] Hyperic Sigar 'CpuPerc.getCombined()' method will be used to detect average CPU load.
-[14:14:23,165][INFO ][main][GridTcpCommunicationSpi] Successfully bound to TCP port [port=45010, locHost=/192.168.2.14]
-[14:14:23,462][INFO ][main][GridListenActorSelfTest] Security status [authentication=on, secure-session=on]
-[14:14:23,504][WARN ][main][GridMulticastDiscoverySpi] Heartbeat frequency is too low (at least 2000 ms): 1000
-[14:14:23,505][INFO ][main][GridMulticastDiscoverySpi] Successfully bound to TCP port: 55010
-[14:14:23,507][INFO ][main][GridMulticastDiscoverySpi] Successfully bound to Multicast port: 50001
-[14:14:23,516][INFO ][main][GridMulticastDiscoverySpi] Local node: GridMulticastDiscoveryNode [id=353d63b5-a2f0-41d1-a30e-37016f357233, state=READY, lastHeartbeat=1353320063506, addrs=[192.168.2.14], addr=/192.168.2.14, tcpPort=55010, startTime=1353320063496]
-[14:14:23,526][INFO ][main][GridDiscoveryManager] Topology snapshot [nodes=1, CPUs=4, hash=0x8C20EE0]
-[14:14:23,529][INFO ][main][GridMulticastDiscoverySpi] Waiting for initial heartbeat timeout (1000 ms)
-[14:14:24,707][INFO ][main][GridJettyRestProtocol] Command protocol successfully started: Jetty REST
-[14:14:24,720][INFO ][main][GridTcpRestProtocol] Command protocol successfully started: TCP binary
-[14:14:24,721][INFO ][main][GridLicenseControllerImpl] Licensed to 'GridGain Systems, Internal Development Only' on Feb 3, 2011
-[14:14:24,721][INFO ][main][GridLicenseControllerImpl] License [ID=7D5CB773-225C-4165-8162-3BB67337894B, type=ENT]
-[14:14:24,721][INFO ][main][GridLicenseControllerImpl] License limits [expire-date: never]
-[14:14:24,740][INFO ][main][GridListenActorSelfTest]
-
->>> +--------------------------+
->>> GridGain ver. x.x.x-DDMMYYYY
->>> +--------------------------+
->>> OS name: Linux 2.6.32-38-generic amd64
->>> OS user: bamboo
->>> CPU(s): 4
->>> VM information: Java(TM) SE Runtime Environment 1.6.0_30-b12 Sun Microsystems Inc. Java HotSpot(TM) 64-Bit Server VM 20.5-b03
->>> VM name: 573@gg-teamcity-4
->>> Grid name: kernal.GridListenActorSelfTest
->>> Local node [ID=353D63B5-A2F0-41D1-A30E-37016F357233, order=1353320063496]
->>> Local node addresses: [192.168.2.14]
->>> Local ports: TCP:8080 TCP:11211 TCP:45010 UDP:50001 TCP:55010
->>> GridGain documentation: http://www.gridgain.com/product.html
-
-[14:14:24,740][INFO ][main][GridListenActorSelfTest] >>> Starting test: testListenByClosure <<<
-[14:14:26,895][INFO ][main][GridListenActorSelfTest] >>> Stopping test: testListenByClosure in 2155 ms <<<
-[14:14:26,902][INFO ][main][GridListenActorSelfTest] >>> Starting test: testBasicFlow <<<
-[14:14:28,919][INFO ][main][GridListenActorSelfTest] >>> Stopping test: testBasicFlow in 2016 ms <<<
-[14:14:28,925][INFO ][main][GridListenActorSelfTest] >>> Starting test: testImmediateStop <<<
-[14:14:30,930][INFO ][main][GridListenActorSelfTest] >>> Stopping test: testImmediateStop in 2005 ms <<<
-[14:14:30,938][INFO ][main][GridListenActorSelfTest] >>> Starting test: testReceiveAll <<<
-[14:14:32,948][INFO ][main][GridListenActorSelfTest] >>> Stopping test: testReceiveAll in 2010 ms <<<
-[14:14:32,956][INFO ][main][GridListenActorSelfTest] >>> Starting test: testRespondToRemote <<<
-[14:14:32,960][INFO ][test-runner][GridListenActorSelfTest1]
-
->>> _____ _ _______ _
->>> / ___/____(_)___/ / ___/___ _(_)___
->>> / (_ // __/ // _ / (_ // _ `/ // _ \
->>> \___//_/ /_/ \_,_/\___/ \_,_/_//_//_/
->>>
->>> ---==++ IN-MEMORY BIG DATA ++==---
->>> ver. x.x.x-DDMMYYYY
->>> Copyright (C) 2012 GridGain Systems
-
-[14:14:32,960][INFO ][test-runner][GridListenActorSelfTest1] << Enterprise Edition >>
-[14:14:32,960][INFO ][test-runner][GridListenActorSelfTest1] Config URL: n/a
-[14:14:32,960][INFO ][test-runner][GridListenActorSelfTest1] Daemon mode: off
-[14:14:32,961][INFO ][test-runner][GridListenActorSelfTest1] Language runtime: Java Platform API Specification ver. 1.6
-[14:14:32,961][INFO ][test-runner][GridListenActorSelfTest1] JVM name: Java HotSpot(TM) 64-Bit Server VM
-[14:14:32,961][INFO ][test-runner][GridListenActorSelfTest1] Remote Management [restart: off, REST: on, JMX (remote: off)]
-[14:14:32,961][INFO ][test-runner][GridListenActorSelfTest1] GRIDGAIN_HOME=/usr/local/TeamCityAgent/work/d46fc9c3d71112c2
-[14:14:32,961][INFO ][test-runner][GridListenActorSelfTest1] VM arguments: [-ea, -XX:MaxPermSize=128m, -Xms512m, -Xmx1024m, -Duser.name=bamboo, -DGRIDGAIN_UPDATE_NOTIFIER=false, -DGRIDGAIN_DISABLED=true, -DGRIDGAIN_HOME=/usr/local/TeamCityAgent/work/d46fc9c3d71112c2, -DGRIDGAIN_STABLE_HOME=/usr/local/TeamCityAgent/work/d46fc9c3d71112c2, -DGRIDGAIN_ROUTER_PREFER_REMOTE=true, -DGRIDGAIN_NO_DISCO_ORDER=true, -DGRIDGAIN_QUIET=false, -DGG_TEST_HOME=/usr/local/TeamCityAgent/work/d46fc9c3d71112c2, -Dteamcity.build.id=34324, -Dteamcity.buildType.id=bt5, -Dagent.ownPort=9090, -Dteamcity.build.checkoutDir=/usr/local/TeamCityAgent/work/d46fc9c3d71112c2, -Dteamcity.build.workingDir=/usr/local/TeamCityAgent/work/d46fc9c3d71112c2, -Dagent.work.dir=/usr/local/TeamCityAgent/work, -Dagent.name=teamcity-4, -Dagent.home.dir=/usr/local/TeamCityAgent, -Dteamcity.runtime.props.file=/usr/local/TeamCityAgent/temp/agentTmp/ant2684847485530994862runtime]
-[14:14:32,961][WARN ][test-runner][GridListenActorSelfTest1] SMTP is not configured - email notifications are off.
-[14:14:32,961][WARN ][test-runner][GridListenActorSelfTest1] Cache is not configured - data grid is off.
-[14:14:32,964][INFO ][test-runner][GridListenActorSelfTest1] 3-rd party licenses can be found at: /usr/local/TeamCityAgent/work/d46fc9c3d71112c2/libs/licenses
-[14:14:32,965][INFO ][test-runner][GridListenActorSelfTest1] Non-loopback local IPs: fe80:0:0:0:ca60:ff:fe68:582c%2, 192.168.2.14
-[14:14:32,966][INFO ][test-runner][GridListenActorSelfTest1] Enabled local MACs: C8600068582C
-[14:14:33,480][INFO ][test-runner][GridJdkLocalMetricsSpi] Hyperic Sigar 'CpuPerc.getCombined()' method will be used to detect average CPU load.
-[14:14:33,499][INFO ][test-runner][GridTcpCommunicationSpi] Successfully bound to TCP port [port=45011, locHost=/192.168.2.14]
-[14:14:33,559][INFO ][test-runner][GridListenActorSelfTest1] Security status [authentication=on, secure-session=on]
-[14:14:33,565][WARN ][test-runner][GridMulticastDiscoverySpi] Heartbeat frequency is too low (at least 2000 ms): 1000
-[14:14:33,566][INFO ][test-runner][GridMulticastDiscoverySpi] Successfully bound to TCP port: 55011
-[14:14:33,566][INFO ][test-runner][GridMulticastDiscoverySpi] Successfully bound to Multicast port: 50001
-[14:14:33,567][INFO ][test-runner][GridMulticastDiscoverySpi] Local node: GridMulticastDiscoveryNode [id=1f7e8040-8a17-4e14-a513-1709bebe265b, state=READY, lastHeartbeat=1353320073559, addrs=[192.168.2.14], addr=/192.168.2.14, tcpPort=55011, startTime=1353320073559]
-[14:14:33,568][INFO ][test-runner][GridDiscoveryManager] Topology snapshot [nodes=1, CPUs=4, hash=0xAB3F3CCB]
-[14:14:33,568][INFO ][test-runner][GridMulticastDiscoverySpi] Waiting for initial heartbeat timeout (1000 ms)
-[14:14:33,637][INFO ][disco-event-worker-#15%kernal.GridListenActorSelfTest%][GridDiscoveryManager] Added new node to topology: GridMulticastDiscoveryNode [id=1f7e8040-8a17-4e14-a513-1709bebe265b, state=READY, lastHeartbeat=1353320073570, addrs=[192.168.2.14], addr=/192.168.2.14, tcpPort=55011, startTime=1353320073559]
-[14:14:33,637][INFO ][disco-event-worker-#55%kernal.GridListenActorSelfTest1%][GridDiscoveryManager] Added new node to topology: GridMulticastDiscoveryNode [id=353d63b5-a2f0-41d1-a30e-37016f357233, state=READY, lastHeartbeat=1353320073600, addrs=[192.168.2.14], addr=/192.168.2.14, tcpPort=55010, startTime=1353320063496]
-[14:14:33,638][INFO ][disco-event-worker-#15%kernal.GridListenActorSelfTest%][GridDiscoveryManager] Topology snapshot [nodes=2, CPUs=4, hash=0x93B555F6]
-[14:14:34,571][INFO ][disco-event-worker-#55%kernal.GridListenActorSelfTest1%][GridDiscoveryManager] Topology snapshot [nodes=2, CPUs=4, hash=0x93B555F6]
-[14:14:35,650][WARN ][test-runner][GridJettyRestProtocol] Jetty failed to start (retrying every 3000 ms). Another node on this host?
-[14:14:35,651][WARN ][test-runner][GridTcpRestProtocol] TCP binary REST server failed to start (retrying every 3000 ms). Another node on this host?
-[14:14:35,652][INFO ][test-runner][GridLicenseControllerImpl] Licensed to 'GridGain Systems, Internal Development Only' on Feb 3, 2011
-[14:14:35,652][INFO ][test-runner][GridLicenseControllerImpl] License [ID=7D5CB773-225C-4165-8162-3BB67337894B, type=ENT]
-[14:14:35,652][INFO ][test-runner][GridLicenseControllerImpl] License limits [expire-date: never]
-[14:14:35,667][INFO ][test-runner][GridListenActorSelfTest1]
-
->>> +--------------------------+
->>> GridGain ver. x.x.x-DDMMYYYY
->>> +--------------------------+
->>> OS name: Linux 2.6.32-38-generic amd64
->>> OS user: bamboo
->>> CPU(s): 4
->>> VM information: Java(TM) SE Runtime Environment 1.6.0_30-b12 Sun Microsystems Inc. Java HotSpot(TM) 64-Bit Server VM 20.5-b03
->>> VM name: 573@gg-teamcity-4
->>> Grid name: kernal.GridListenActorSelfTest1
->>> Local node [ID=1F7E8040-8A17-4E14-A513-1709BEBE265B, order=1353320073559]
->>> Local node addresses: [192.168.2.14]
->>> Local ports: TCP:45011 UDP:50001 TCP:55011
->>> GridGain documentation: http://www.gridgain.com/product.html
-
-[14:14:36,672][INFO ][test-runner][GridListenActorSelfTest] >>> Stopping grid [name=kernal.GridListenActorSelfTest1, id=1f7e8040-8a17-4e14-a513-1709bebe265b]
-[14:14:36,674][INFO ][test-runner][GridJettyRestProtocol] Command protocol successfully stopped: Jetty REST
-[14:14:36,674][INFO ][test-runner][GridTcpRestProtocol] Command protocol successfully stopped: TCP binary
-[14:14:36,679][INFO ][disco-event-worker-#15%kernal.GridListenActorSelfTest%][GridDiscoveryManager] Node left topology: GridMulticastDiscoveryNode [id=1f7e8040-8a17-4e14-a513-1709bebe265b, state=LEFT, lastHeartbeat=1353320076673, addrs=[192.168.2.14], addr=/192.168.2.14, tcpPort=55011, startTime=1353320073559]
-[14:14:36,680][INFO ][disco-event-worker-#15%kernal.GridListenActorSelfTest%][GridDiscoveryManager] Topology snapshot [nodes=1, CPUs=4, hash=0x8C20EE0]
-[14:14:36,693][INFO ][test-runner][GridDeploymentLocalStore] Removed undeployed class: GridDeployment [ts=1353320075676, depMode=SHARED, clsLdr=sun.misc.Launcher$AppClassLoader@3326b249, clsLdrId=e4269281b31-1f7e8040-8a17-4e14-a513-1709bebe265b, userVer=0, loc=true, sampleCls=class java.lang.String, sampleClsName=java.lang.String, undeployed=true, pendingUndeploy=false, usage=0]
-[14:14:36,701][INFO ][test-runner][GridListenActorSelfTest1]
-
->>> +-------------------------------------+
->>> GridGain ver. x.x.x-DDMMYYYY stopped OK
->>> +-------------------------------------+
->>> Grid name: kernal.GridListenActorSelfTest1
->>> Grid uptime: 00:00:01:28
-
-
-[14:14:36,703][INFO ][main][GridListenActorSelfTest] >>> Stopping test: testRespondToRemote in 3747 ms <<<
-[14:14:36,712][INFO ][main][GridListenActorSelfTest] >>> Starting test: testPingPong <<<
-[14:14:36,726][INFO ][main][GridListenActorSelfTest] >>> Stopping test: testPingPong in 14 ms <<<
-[14:14:36,726][INFO ][main][GridListenActorSelfTest] >>> Stopping grid [name=kernal.GridListenActorSelfTest, id=353d63b5-a2f0-41d1-a30e-37016f357233]
-[14:14:37,780][INFO ][main][GridJettyRestProtocol] Command protocol successfully stopped: Jetty REST
-[14:14:37,781][INFO ][main][GridTcpRestProtocol] Command protocol successfully stopped: TCP binary
-[14:14:37,794][INFO ][main][GridDeploymentLocalStore] Removed undeployed class: GridDeployment [ts=1353320064744, depMode=SHARED, clsLdr=sun.misc.Launcher$AppClassLoader@3326b249, clsLdrId=a2269281b31-353d63b5-a2f0-41d1-a30e-37016f357233, userVer=0, loc=true, sampleCls=class org.gridgain.grid.kernal.GridListenActorSelfTest$1, sampleClsName=org.gridgain.grid.kernal.GridListenActorSelfTest$1, undeployed=true, pendingUndeploy=false, usage=0]
-[14:14:37,799][INFO ][main][GridListenActorSelfTest]
-
->>> +-------------------------------------+
->>> GridGain ver. x.x.x-DDMMYYYY stopped OK
->>> +-------------------------------------+
->>> Grid name: kernal.GridListenActorSelfTest
->>> Grid uptime: 00:00:13:57
-
-
-[14:14:37,814][INFO ][main][GridSessionCancelSiblingsFromFutureSelfTest]
-
->>> _____ _ _______ _
->>> / ___/____(_)___/ / ___/___ _(_)___
->>> / (_ // __/ // _ / (_ // _ `/ // _ \
->>> \___//_/ /_/ \_,_/\___/ \_,_/_//_//_/
->>>
->>> ---==++ IN-MEMORY BIG DATA ++==---
->>> ver. x.x.x-DDMMYYYY
->>> Copyright (C) 2012 GridGain Systems
-
-[14:14:37,814][INFO ][main][GridSessionCancelSiblingsFromFutureSelfTest] << Enterprise Edition >>
-[14:14:37,814][INFO ][main][GridSessionCancelSiblingsFromFutureSelfTest] Config URL: n/a
-[14:14:37,814][INFO ][main][GridSessionCancelSiblingsFromFutureSelfTest] Daemon mode: off
-[14:14:37,814][INFO ][main][GridSessionCancelSiblingsFromFutureSelfTest] Language runtime: Java Platform API Specification ver. 1.6
-[14:14:37,814][INFO ][main][GridSessionCancelSiblingsFromFutureSelfTest] JVM name: Java HotSpot(TM) 64-Bit Server VM
-[14:14:37,814][INFO ][main][GridSessionCancelSiblingsFromFutureSelfTest] Remote Management [restart: off, REST: on, JMX (remote: off)]
-[14:14:37,814][INFO ][main][GridSessionCancelSiblingsFromFutureSelfTest] GRIDGAIN_HOME=/usr/local/TeamCityAgent/work/d46fc9c3d71112c2
-[14:14:37,814][INFO ][main][GridSessionCancelSiblingsFromFutureSelfTest] VM arguments: [-ea, -XX:MaxPermSize=128m, -Xms512m, -Xmx1024m, -Duser.name=bamboo, -DGRIDGAIN_UPDATE_NOTIFIER=false, -DGRIDGAIN_DISABLED=true, -DGRIDGAIN_HOME=/usr/local/TeamCityAgent/work/d46fc9c3d71112c2, -DGRIDGAIN_STABLE_HOME=/usr/local/TeamCityAgent/work/d46fc9c3d71112c2, -DGRIDGAIN_ROUTER_PREFER_REMOTE=true, -DGRIDGAIN_NO_DISCO_ORDER=true, -DGRIDGAIN_QUIET=false, -DGG_TEST_HOME=/usr/local/TeamCityAgent/work/d46fc9c3d71112c2, -Dteamcity.build.id=34324, -Dteamcity.buildType.id=bt5, -Dagent.ownPort=9090, -Dteamcity.build.checkoutDir=/usr/local/TeamCityAgent/work/d46fc9c3d71112c2, -Dteamcity.build.workingDir=/usr/local/TeamCityAgent/work/d46fc9c3d71112c2, -Dagent.work.dir=/usr/local/TeamCityAgent/work, -Dagent.name=teamcity-4, -Dagent.home.dir=/usr/local/TeamCityAgent, -Dteamcity.runtime.props.file=/usr/local/TeamCityAgent/temp/agentTmp/ant2684847485530994862runtime]
-[14:14:37,814][WARN ][main][GridSessionCancelSiblingsFromFutureSelfTest] SMTP is not configured - email notifications are off.
-[14:14:37,815][WARN ][main][GridSessionCancelSiblingsFromFutureSelfTest] Cache is not configured - data grid is off.
-[14:14:37,815][INFO ][main][GridSessionCancelSiblingsFromFutureSelfTest] 3-rd party licenses can be found at: /usr/local/TeamCityAgent/work/d46fc9c3d71112c2/libs/licenses
-[14:14:37,815][INFO ][main][GridSessionCancelSiblingsFromFutureSelfTest] Non-loopback local IPs: fe80:0:0:0:ca60:ff:fe68:582c%2, 192.168.2.14
-[14:14:37,815][INFO ][main][GridSessionCancelSiblingsFromFutureSelfTest] Enabled local MACs: C8600068582C
-[14:14:38,322][INFO ][main][GridJdkLocalMetricsSpi] Hyperic Sigar 'CpuPerc.getCombined()' method will be used to detect average CPU load.
-[14:14:38,339][INFO ][main][GridTcpCommunicationSpi] Successfully bound to TCP port [port=45020, locHost=/192.168.2.14]
-[14:14:38,398][INFO ][main][GridSessionCancelSiblingsFromFutureSelfTest] Security status [authentication=on, secure-session=on]
-[14:14:38,403][WARN ][main][GridMulticastDiscoverySpi] Heartbeat frequency is too low (at least 2000 ms): 1000
-[14:14:38,404][INFO ][main][GridMulticastDiscoverySpi] Successfully bound to TCP port: 55020
-[14:14:38,404][INFO ][main][GridMulticastDiscoverySpi] Successfully bound to Multicast port: 50002
-[14:14:38,406][INFO ][main][GridMulticastDiscoverySpi] Local node: GridMulticastDiscoveryNode [id=741af89c-78c4-453d-83d5-86b9a66dca08, state=READY, lastHeartbeat=1353320078398, addrs=[192.168.2.14], addr=/192.168.2.14, tcpPort=55020, startTime=1353320078398]
-[14:14:38,407][INFO ][main][GridDiscoveryManager] Topology snapshot [nodes=1, CPUs=4, hash=0x52EFDFF2]
-[14:14:38,408][INFO ][main][GridMulticastDiscoverySpi] Waiting for initial heartbeat timeout (1000 ms)
-[14:14:39,443][INFO ][main][GridJettyRestProtocol] Command protocol successfully started: Jetty REST
-[14:14:39,448][INFO ][main][GridTcpRestProtocol] Command protocol successfully started: TCP binary
-[14:14:39,448][INFO ][main][GridLicenseControllerImpl] Licensed to 'GridGain Systems, Internal Development Only' on Feb 3, 2011
-[14:14:39,448][INFO ][main][GridLicenseControllerImpl] License [ID=7D5CB773-225C-4165-8162-3BB67337894B, type=ENT]
-[14:14:39,448][INFO ][main][GridLicenseControllerImpl] License limits [expire-date: never]
-[14:14:39,468][INFO ][main][GridSessionCancelSiblingsFromFutureSelfTest]
-
->>> +--------------------------+
->>> GridGain ver. x.x.x-DDMMYYYY
->>> +--------------------------+
->>> OS name: Linux 2.6.32-38-generic amd64
->>> OS user: bamboo
->>> CPU(s): 4
->>> VM information: Java(TM) SE Runtime Environment 1.6.0_30-b12 Sun Microsystems Inc. Java HotSpot(TM) 64-Bit Server VM 20.5-b03
->>> VM name: 573@gg-teamcity-4
->>> Grid name: session.GridSessionCancelSiblingsFromFutureSelfTest
->>> Local node [ID=741AF89C-78C4-453D-83D5-86B9A66DCA08, order=1353320078398]
->>> Local node addresses: [192.168.2.14]
->>> Local ports: TCP:8080 TCP:11211 TCP:45020 UDP:50002 TCP:55020
->>> GridGain documentation: http://www.gridgain.com/product.html
-
-[14:14:39,468][INFO ][main][GridSessionCancelSiblingsFromFutureSelfTest] >>> Starting test: testCancelSiblings <<<
-[14:14:39,478][INFO ][gridgain-#95%session.GridSessionCancelSiblingsFromFutureSelfTest%][GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask] Splitting jobs [task=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask@4b90725e, gridSize=1, arg=0]
-[14:14:39,484][INFO ][gridgain-#96%session.GridSessionCancelSiblingsFromFutureSelfTest%][GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask] Computing job [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask$1@54eeabe8, arg=5]
-[14:14:39,484][INFO ][gridgain-#97%session.GridSessionCancelSiblingsFromFutureSelfTest%][GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask] Computing job [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask$1@39b1ff47, arg=4]
-[14:14:39,485][INFO ][gridgain-#98%session.GridSessionCancelSiblingsFromFutureSelfTest%][GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask] Computing job [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask$1@1a0283e, arg=3]
-[14:14:39,486][INFO ][gridgain-#99%session.GridSessionCancelSiblingsFromFutureSelfTest%][GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask] Computing job [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask$1@31f9b804, arg=2]
-[14:14:39,486][INFO ][gridgain-#100%session.GridSessionCancelSiblingsFromFutureSelfTest%][GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask] Computing job [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask$1@3a8bd3bb, arg=1]
-[14:14:39,487][INFO ][gridgain-#96%session.GridSessionCancelSiblingsFromFutureSelfTest%][GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask] Job got interrupted [arg=5, e=java.lang.InterruptedException: sleep interrupted]
-[14:14:39,488][INFO ][gridgain-#98%session.GridSessionCancelSiblingsFromFutureSelfTest%][GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask] Job got interrupted [arg=3, e=java.lang.InterruptedException: sleep interrupted]
-[14:14:39,491][INFO ][gridgain-#100%session.GridSessionCancelSiblingsFromFutureSelfTest%][GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask] Job got interrupted [arg=1, e=java.lang.InterruptedException: sleep interrupted]
-[14:14:39,491][INFO ][gridgain-#99%session.GridSessionCancelSiblingsFromFutureSelfTest%][GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask] Job got interrupted [arg=2, e=java.lang.InterruptedException: sleep interrupted]
-[14:14:39,492][INFO ][gridgain-#97%session.GridSessionCancelSiblingsFromFutureSelfTest%][GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask] Job got interrupted [arg=4, e=java.lang.InterruptedException: sleep interrupted]
-[14:14:39,497][INFO ][gridgain-#106%session.GridSessionCancelSiblingsFromFutureSelfTest%][GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask] Received job result [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask@4b90725e, result=GridJobResultImpl [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask$1@54eeabe8, sib=GridJobSiblingImpl [sesId=c5269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, jobId=e5269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, taskTopic=TOPIC_TASK--5725799524765009754-5763191950221394699-1353320063582--8947096952782337528-8366272608718832957, jobTopic=TOPIC_JOB--5725799524765009754-5763191950221394699-1353320063582--8947096952782337528-8366272608718832957, nodeId=741af89c-78c4-453d-83d5-86b9a66dca08, isJobDone=false], jobCtx=GridJobContextImpl [jobId=e5269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, attrs={}], node=GridRichNodeImpl [node=GridMulticastDisco
veryNode [id=741af89c-78c4-453d-83d5-86b9a66dca08, state=READY, lastHeartbeat=1353320078398, addrs=[192.168.2.14], addr=/192.168.2.14, tcpPort=55020, startTime=1353320078398], p=GridNodePredicate [ids=[741af89c-78c4-453d-83d5-86b9a66dca08]], isLoc=true, hash=694612240, daemon=false], ex=null, hasRes=true, isCancelled=true, isOccupied=true]]
-[14:14:39,498][INFO ][gridgain-#106%session.GridSessionCancelSiblingsFromFutureSelfTest%][GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask] Received job result [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask@4b90725e, result=GridJobResultImpl [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask$1@1a0283e, sib=GridJobSiblingImpl [sesId=c5269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, jobId=26269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, taskTopic=TOPIC_TASK--5725799524765009754-5763191950221394699-1353320063586--8947096952782337528-8366272608718832957, jobTopic=TOPIC_JOB--5725799524765009754-5763191950221394699-1353320063586--8947096952782337528-8366272608718832957, nodeId=741af89c-78c4-453d-83d5-86b9a66dca08, isJobDone=false], jobCtx=GridJobContextImpl [jobId=26269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, attrs={}], node=GridRichNodeImpl [node=GridMulticastDiscov
eryNode [id=741af89c-78c4-453d-83d5-86b9a66dca08, state=READY, lastHeartbeat=1353320078398, addrs=[192.168.2.14], addr=/192.168.2.14, tcpPort=55020, startTime=1353320078398], p=GridNodePredicate [ids=[741af89c-78c4-453d-83d5-86b9a66dca08]], isLoc=true, hash=694612240, daemon=false], ex=null, hasRes=true, isCancelled=true, isOccupied=true]]
-[14:14:39,499][INFO ][gridgain-#106%session.GridSessionCancelSiblingsFromFutureSelfTest%][GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask] Received job result [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask@4b90725e, result=GridJobResultImpl [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask$1@31f9b804, sib=GridJobSiblingImpl [sesId=c5269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, jobId=46269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, taskTopic=TOPIC_TASK--5725799524765009754-5763191950221394699-1353320063588--8947096952782337528-8366272608718832957, jobTopic=TOPIC_JOB--5725799524765009754-5763191950221394699-1353320063588--8947096952782337528-8366272608718832957, nodeId=741af89c-78c4-453d-83d5-86b9a66dca08, isJobDone=false], jobCtx=GridJobContextImpl [jobId=46269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, attrs={}], node=GridRichNodeImpl [node=GridMulticastDisco
veryNode [id=741af89c-78c4-453d-83d5-86b9a66dca08, state=READY, lastHeartbeat=1353320078398, addrs=[192.168.2.14], addr=/192.168.2.14, tcpPort=55020, startTime=1353320078398], p=GridNodePredicate [ids=[741af89c-78c4-453d-83d5-86b9a66dca08]], isLoc=true, hash=694612240, daemon=false], ex=null, hasRes=true, isCancelled=true, isOccupied=true]]
-[14:14:39,500][INFO ][gridgain-#106%session.GridSessionCancelSiblingsFromFutureSelfTest%][GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask] Received job result [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask@4b90725e, result=GridJobResultImpl [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask$1@3a8bd3bb, sib=GridJobSiblingImpl [sesId=c5269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, jobId=66269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, taskTopic=TOPIC_TASK--5725799524765009754-5763191950221394699-1353320063590--8947096952782337528-8366272608718832957, jobTopic=TOPIC_JOB--5725799524765009754-5763191950221394699-1353320063590--8947096952782337528-8366272608718832957, nodeId=741af89c-78c4-453d-83d5-86b9a66dca08, isJobDone=false], jobCtx=GridJobContextImpl [jobId=66269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, attrs={}], node=GridRichNodeImpl [node=GridMulticastDisco
veryNode [id=741af89c-78c4-453d-83d5-86b9a66dca08, state=READY, lastHeartbeat=1353320078398, addrs=[192.168.2.14], addr=/192.168.2.14, tcpPort=55020, startTime=1353320078398], p=GridNodePredicate [ids=[741af89c-78c4-453d-83d5-86b9a66dca08]], isLoc=true, hash=694612240, daemon=false], ex=null, hasRes=true, isCancelled=true, isOccupied=true]]
-[14:14:39,500][INFO ][gridgain-#106%session.GridSessionCancelSiblingsFromFutureSelfTest%][GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask] Received job result [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask@4b90725e, result=GridJobResultImpl [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask$1@39b1ff47, sib=GridJobSiblingImpl [sesId=c5269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, jobId=06269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, taskTopic=TOPIC_TASK--5725799524765009754-5763191950221394699-1353320063584--8947096952782337528-8366272608718832957, jobTopic=TOPIC_JOB--5725799524765009754-5763191950221394699-1353320063584--8947096952782337528-8366272608718832957, nodeId=741af89c-78c4-453d-83d5-86b9a66dca08, isJobDone=false], jobCtx=GridJobContextImpl [jobId=06269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, attrs={}], node=GridRichNodeImpl [node=GridMulticastDisco
veryNode [id=741af89c-78c4-453d-83d5-86b9a66dca08, state=READY, lastHeartbeat=1353320078398, addrs=[192.168.2.14], addr=/192.168.2.14, tcpPort=55020, startTime=1353320078398], p=GridNodePredicate [ids=[741af89c-78c4-453d-83d5-86b9a66dca08]], isLoc=true, hash=694612240, daemon=false], ex=null, hasRes=true, isCancelled=true, isOccupied=true]]
-[14:14:39,502][INFO ][gridgain-#106%session.GridSessionCancelSiblingsFromFutureSelfTest%][GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask] Aggregating job [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask@4b90725e, results=[GridJobResultImpl [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask$1@54eeabe8, sib=GridJobSiblingImpl [sesId=c5269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, jobId=e5269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, taskTopic=TOPIC_TASK--5725799524765009754-5763191950221394699-1353320063582--8947096952782337528-8366272608718832957, jobTopic=TOPIC_JOB--5725799524765009754-5763191950221394699-1353320063582--8947096952782337528-8366272608718832957, nodeId=741af89c-78c4-453d-83d5-86b9a66dca08, isJobDone=true], jobCtx=GridJobContextImpl [jobId=e5269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, attrs={}], node=GridRichNodeImpl [node=GridMulticastDiscover
yNode [id=741af89c-78c4-453d-83d5-86b9a66dca08, state=READY, lastHeartbeat=1353320078398, addrs=[192.168.2.14], addr=/192.168.2.14, tcpPort=55020, startTime=1353320078398], p=GridNodePredicate [ids=[741af89c-78c4-453d-83d5-86b9a66dca08]], isLoc=true, hash=694612240, daemon=false], ex=null, hasRes=true, isCancelled=true, isOccupied=false], GridJobResultImpl [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask$1@39b1ff47, sib=GridJobSiblingImpl [sesId=c5269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, jobId=06269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, taskTopic=TOPIC_TASK--5725799524765009754-5763191950221394699-1353320063584--8947096952782337528-8366272608718832957, jobTopic=TOPIC_JOB--5725799524765009754-5763191950221394699-1353320063584--8947096952782337528-8366272608718832957, nodeId=741af89c-78c4-453d-83d5-86b9a66dca08, isJobDone=true], jobCtx=GridJobContextImpl [jobId=06269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, attrs={}], n
ode=GridRichNodeImpl [node=GridMulticastDiscoveryNode [id=741af89c-78c4-453d-83d5-86b9a66dca08, state=READY, lastHeartbeat=1353320078398, addrs=[192.168.2.14], addr=/192.168.2.14, tcpPort=55020, startTime=1353320078398], p=GridNodePredicate [ids=[741af89c-78c4-453d-83d5-86b9a66dca08]], isLoc=true, hash=694612240, daemon=false], ex=null, hasRes=true, isCancelled=true, isOccupied=true], GridJobResultImpl [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask$1@1a0283e, sib=GridJobSiblingImpl [sesId=c5269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, jobId=26269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, taskTopic=TOPIC_TASK--5725799524765009754-5763191950221394699-1353320063586--8947096952782337528-8366272608718832957, jobTopic=TOPIC_JOB--5725799524765009754-5763191950221394699-1353320063586--8947096952782337528-8366272608718832957, nodeId=741af89c-78c4-453d-83d5-86b9a66dca08, isJobDone=true], jobCtx=GridJobContextImpl [jobId=26269281b31-4ffa
f88b-4556-430b-b089-dfab3747f8a6, attrs={}], node=GridRichNodeImpl [node=GridMulticastDiscoveryNode [id=741af89c-78c4-453d-83d5-86b9a66dca08, state=READY, lastHeartbeat=1353320078398, addrs=[192.168.2.14], addr=/192.168.2.14, tcpPort=55020, startTime=1353320078398], p=GridNodePredicate [ids=[741af89c-78c4-453d-83d5-86b9a66dca08]], isLoc=true, hash=694612240, daemon=false], ex=null, hasRes=true, isCancelled=true, isOccupied=false], GridJobResultImpl [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask$1@31f9b804, sib=GridJobSiblingImpl [sesId=c5269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, jobId=46269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, taskTopic=TOPIC_TASK--5725799524765009754-5763191950221394699-1353320063588--8947096952782337528-8366272608718832957, jobTopic=TOPIC_JOB--5725799524765009754-5763191950221394699-1353320063588--8947096952782337528-8366272608718832957, nodeId=741af89c-78c4-453d-83d5-86b9a66dca08, isJobDone=true], j
obCtx=GridJobContextImpl [jobId=46269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, attrs={}], node=GridRichNodeImpl [node=GridMulticastDiscoveryNode [id=741af89c-78c4-453d-83d5-86b9a66dca08, state=READY, lastHeartbeat=1353320078398, addrs=[192.168.2.14], addr=/192.168.2.14, tcpPort=55020, startTime=1353320078398], p=GridNodePredicate [ids=[741af89c-78c4-453d-83d5-86b9a66dca08]], isLoc=true, hash=694612240, daemon=false], ex=null, hasRes=true, isCancelled=true, isOccupied=false], GridJobResultImpl [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask$1@3a8bd3bb, sib=GridJobSiblingImpl [sesId=c5269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, jobId=66269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, taskTopic=TOPIC_TASK--5725799524765009754-5763191950221394699-1353320063590--8947096952782337528-8366272608718832957, jobTopic=TOPIC_JOB--5725799524765009754-5763191950221394699-1353320063590--8947096952782337528-8366272608718832957, nodeId=741af89c
-78c4-453d-83d5-86b9a66dca08, isJobDone=true], jobCtx=GridJobContextImpl [jobId=66269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, attrs={}], node=GridRichNodeImpl [node=GridMulticastDiscoveryNode [id=741af89c-78c4-453d-83d5-86b9a66dca08, state=READY, lastHeartbeat=1353320078398, addrs=[192.168.2.14], addr=/192.168.2.14, tcpPort=55020, startTime=1353320078398], p=GridNodePredicate [ids=[741af89c-78c4-453d-83d5-86b9a66dca08]], isLoc=true, hash=694612240, daemon=false], ex=null, hasRes=true, isCancelled=true, isOccupied=false]]]
-[14:14:39,503][INFO ][gridgain-#111%session.GridSessionCancelSiblingsFromFutureSelfTest%][GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask] Splitting jobs [task=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask@4e0bd5df, gridSize=1, arg=1]
-[14:14:39,505][INFO ][gridgain-#112%session.GridSessionCancelSiblingsFromFutureSelfTest%][GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask] Computing job [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask$1@591bfcbe, arg=1]
-[14:14:39,506][INFO ][gridgain-#113%session.GridSessionCancelSiblingsFromFutureSelfTest%][GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask] Computing job [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask$1@3c6e4ba6, arg=2]
-[14:14:39,507][INFO ][gridgain-#114%session.GridSessionCancelSiblingsFromFutureSelfTest%][GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask] Computing job [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask$1@5afc0f5, arg=4]
-[14:14:39,507][INFO ][gridgain-#115%session.GridSessionCancelSiblingsFromFutureSelfTest%][GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask] Computing job [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask$1@55a517bd, arg=5]
-[14:14:39,508][INFO ][gridgain-#116%session.GridSessionCancelSiblingsFromFutureSelfTest%][GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask] Computing job [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask$1@6d289e48, arg=3]
-[14:14:39,508][INFO ][gridgain-#112%session.GridSessionCancelSiblingsFromFutureSelfTest%][GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask] Job got interrupted [arg=1, e=java.lang.InterruptedException: sleep interrupted]
-[14:14:39,509][INFO ][gridgain-#113%session.GridSessionCancelSiblingsFromFutureSelfTest%][GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask] Job got interrupted [arg=2, e=java.lang.InterruptedException: sleep interrupted]
-[14:14:39,511][INFO ][gridgain-#115%session.GridSessionCancelSiblingsFromFutureSelfTest%][GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask] Job got interrupted [arg=5, e=java.lang.InterruptedException: sleep interrupted]
-[14:14:39,511][INFO ][gridgain-#114%session.GridSessionCancelSiblingsFromFutureSelfTest%][GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask] Job got interrupted [arg=4, e=java.lang.InterruptedException: sleep interrupted]
-[14:14:39,511][INFO ][gridgain-#116%session.GridSessionCancelSiblingsFromFutureSelfTest%][GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask] Job got interrupted [arg=3, e=java.lang.InterruptedException: sleep interrupted]
-[14:14:39,512][INFO ][gridgain-#121%session.GridSessionCancelSiblingsFromFutureSelfTest%][GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask] Received job result [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask@4e0bd5df, result=GridJobResultImpl [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask$1@591bfcbe, sib=GridJobSiblingImpl [sesId=88269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, jobId=a8269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, taskTopic=TOPIC_TASK--5725799524765009754-5763191950221394699-1353320063626--8947096952782337528-8366272608718832957, jobTopic=TOPIC_JOB--5725799524765009754-5763191950221394699-1353320063626--8947096952782337528-8366272608718832957, nodeId=741af89c-78c4-453d-83d5-86b9a66dca08, isJobDone=false], jobCtx=GridJobContextImpl [jobId=a8269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, attrs={}], node=GridRichNodeImpl [node=GridMulticastDisco
veryNode [id=741af89c-78c4-453d-83d5-86b9a66dca08, state=READY, lastHeartbeat=1353320078398, addrs=[192.168.2.14], addr=/192.168.2.14, tcpPort=55020, startTime=1353320078398], p=GridNodePredicate [ids=[741af89c-78c4-453d-83d5-86b9a66dca08]], isLoc=true, hash=694612240, daemon=false], ex=null, hasRes=true, isCancelled=true, isOccupied=true]]
-[14:14:39,513][INFO ][gridgain-#121%session.GridSessionCancelSiblingsFromFutureSelfTest%][GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask] Received job result [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask@4e0bd5df, result=GridJobResultImpl [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask$1@5afc0f5, sib=GridJobSiblingImpl [sesId=88269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, jobId=e8269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, taskTopic=TOPIC_TASK--5725799524765009754-5763191950221394699-1353320063630--8947096952782337528-8366272608718832957, jobTopic=TOPIC_JOB--5725799524765009754-5763191950221394699-1353320063630--8947096952782337528-8366272608718832957, nodeId=741af89c-78c4-453d-83d5-86b9a66dca08, isJobDone=false], jobCtx=GridJobContextImpl [jobId=e8269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, attrs={}], node=GridRichNodeImpl [node=GridMulticastDiscov
eryNode [id=741af89c-78c4-453d-83d5-86b9a66dca08, state=READY, lastHeartbeat=1353320078398, addrs=[192.168.2.14], addr=/192.168.2.14, tcpPort=55020, startTime=1353320078398], p=GridNodePredicate [ids=[741af89c-78c4-453d-83d5-86b9a66dca08]], isLoc=true, hash=694612240, daemon=false], ex=null, hasRes=true, isCancelled=true, isOccupied=true]]
-[14:14:39,513][INFO ][gridgain-#121%session.GridSessionCancelSiblingsFromFutureSelfTest%][GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask] Received job result [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask@4e0bd5df, result=GridJobResultImpl [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask$1@6d289e48, sib=GridJobSiblingImpl [sesId=88269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, jobId=29269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, taskTopic=TOPIC_TASK--5725799524765009754-5763191950221394699-1353320063634--8947096952782337528-8366272608718832957, jobTopic=TOPIC_JOB--5725799524765009754-5763191950221394699-1353320063634--8947096952782337528-8366272608718832957, nodeId=741af89c-78c4-453d-83d5-86b9a66dca08, isJobDone=false], jobCtx=GridJobContextImpl [jobId=29269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, attrs={}], node=GridRichNodeImpl [node=GridMulticastDisco
veryNode [id=741af89c-78c4-453d-83d5-86b9a66dca08, state=READY, lastHeartbeat=1353320078398, addrs=[192.168.2.14], addr=/192.168.2.14, tcpPort=55020, startTime=1353320078398], p=GridNodePredicate [ids=[741af89c-78c4-453d-83d5-86b9a66dca08]], isLoc=true, hash=694612240, daemon=false], ex=null, hasRes=true, isCancelled=true, isOccupied=true]]
-[14:14:39,513][INFO ][gridgain-#121%session.GridSessionCancelSiblingsFromFutureSelfTest%][GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask] Received job result [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask@4e0bd5df, result=GridJobResultImpl [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask$1@55a517bd, sib=GridJobSiblingImpl [sesId=88269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, jobId=09269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, taskTopic=TOPIC_TASK--5725799524765009754-5763191950221394699-1353320063632--8947096952782337528-8366272608718832957, jobTopic=TOPIC_JOB--5725799524765009754-5763191950221394699-1353320063632--8947096952782337528-8366272608718832957, nodeId=741af89c-78c4-453d-83d5-86b9a66dca08, isJobDone=false], jobCtx=GridJobContextImpl [jobId=09269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, attrs={}], node=GridRichNodeImpl [node=GridMulticastDisco
veryNode [id=741af89c-78c4-453d-83d5-86b9a66dca08, state=READY, lastHeartbeat=1353320078398, addrs=[192.168.2.14], addr=/192.168.2.14, tcpPort=55020, startTime=1353320078398], p=GridNodePredicate [ids=[741af89c-78c4-453d-83d5-86b9a66dca08]], isLoc=true, hash=694612240, daemon=false], ex=null, hasRes=true, isCancelled=true, isOccupied=true]]
-[14:14:39,514][INFO ][gridgain-#121%session.GridSessionCancelSiblingsFromFutureSelfTest%][GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask] Received job result [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask@4e0bd5df, result=GridJobResultImpl [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask$1@3c6e4ba6, sib=GridJobSiblingImpl [sesId=88269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, jobId=c8269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, taskTopic=TOPIC_TASK--5725799524765009754-5763191950221394699-1353320063628--8947096952782337528-8366272608718832957, jobTopic=TOPIC_JOB--5725799524765009754-5763191950221394699-1353320063628--8947096952782337528-8366272608718832957, nodeId=741af89c-78c4-453d-83d5-86b9a66dca08, isJobDone=false], jobCtx=GridJobContextImpl [jobId=c8269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, attrs={}], node=GridRichNodeImpl [node=GridMulticastDisco
veryNode [id=741af89c-78c4-453d-83d5-86b9a66dca08, state=READY, lastHeartbeat=1353320078398, addrs=[192.168.2.14], addr=/192.168.2.14, tcpPort=55020, startTime=1353320078398], p=GridNodePredicate [ids=[741af89c-78c4-453d-83d5-86b9a66dca08]], isLoc=true, hash=694612240, daemon=false], ex=null, hasRes=true, isCancelled=true, isOccupied=true]]
-[14:14:39,515][INFO ][gridgain-#121%session.GridSessionCancelSiblingsFromFutureSelfTest%][GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask] Aggregating job [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask@4e0bd5df, results=[GridJobResultImpl [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask$1@591bfcbe, sib=GridJobSiblingImpl [sesId=88269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, jobId=a8269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, taskTopic=TOPIC_TASK--5725799524765009754-5763191950221394699-1353320063626--8947096952782337528-8366272608718832957, jobTopic=TOPIC_JOB--5725799524765009754-5763191950221394699-1353320063626--8947096952782337528-8366272608718832957, nodeId=741af89c-78c4-453d-83d5-86b9a66dca08, isJobDone=true], jobCtx=GridJobContextImpl [jobId=a8269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, attrs={}], node=GridRichNodeImpl [node=GridMulticastDiscover
yNode [id=741af89c-78c4-453d-83d5-86b9a66dca08, state=READY, lastHeartbeat=1353320078398, addrs=[192.168.2.14], addr=/192.168.2.14, tcpPort=55020, startTime=1353320078398], p=GridNodePredicate [ids=[741af89c-78c4-453d-83d5-86b9a66dca08]], isLoc=true, hash=694612240, daemon=false], ex=null, hasRes=true, isCancelled=true, isOccupied=false], GridJobResultImpl [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask$1@55a517bd, sib=GridJobSiblingImpl [sesId=88269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, jobId=09269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, taskTopic=TOPIC_TASK--5725799524765009754-5763191950221394699-1353320063632--8947096952782337528-8366272608718832957, jobTopic=TOPIC_JOB--5725799524765009754-5763191950221394699-1353320063632--8947096952782337528-8366272608718832957, nodeId=741af89c-78c4-453d-83d5-86b9a66dca08, isJobDone=true], jobCtx=GridJobContextImpl [jobId=09269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, attrs={}], n
ode=GridRichNodeImpl [node=GridMulticastDiscoveryNode [id=741af89c-78c4-453d-83d5-86b9a66dca08, state=READY, lastHeartbeat=1353320078398, addrs=[192.168.2.14], addr=/192.168.2.14, tcpPort=55020, startTime=1353320078398], p=GridNodePredicate [ids=[741af89c-78c4-453d-83d5-86b9a66dca08]], isLoc=true, hash=694612240, daemon=false], ex=null, hasRes=true, isCancelled=true, isOccupied=false], GridJobResultImpl [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask$1@5afc0f5, sib=GridJobSiblingImpl [sesId=88269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, jobId=e8269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, taskTopic=TOPIC_TASK--5725799524765009754-5763191950221394699-1353320063630--8947096952782337528-8366272608718832957, jobTopic=TOPIC_JOB--5725799524765009754-5763191950221394699-1353320063630--8947096952782337528-8366272608718832957, nodeId=741af89c-78c4-453d-83d5-86b9a66dca08, isJobDone=true], jobCtx=GridJobContextImpl [jobId=e8269281b31-4ff
af88b-4556-430b-b089-dfab3747f8a6, attrs={}], node=GridRichNodeImpl [node=GridMulticastDiscoveryNode [id=741af89c-78c4-453d-83d5-86b9a66dca08, state=READY, lastHeartbeat=1353320078398, addrs=[192.168.2.14], addr=/192.168.2.14, tcpPort=55020, startTime=1353320078398], p=GridNodePredicate [ids=[741af89c-78c4-453d-83d5-86b9a66dca08]], isLoc=true, hash=694612240, daemon=false], ex=null, hasRes=true, isCancelled=true, isOccupied=false], GridJobResultImpl [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask$1@6d289e48, sib=GridJobSiblingImpl [sesId=88269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, jobId=29269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, taskTopic=TOPIC_TASK--5725799524765009754-5763191950221394699-1353320063634--8947096952782337528-8366272608718832957, jobTopic=TOPIC_JOB--5725799524765009754-5763191950221394699-1353320063634--8947096952782337528-8366272608718832957, nodeId=741af89c-78c4-453d-83d5-86b9a66dca08, isJobDone=true],
jobCtx=GridJobContextImpl [jobId=29269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, attrs={}], node=GridRichNodeImpl [node=GridMulticastDiscoveryNode [id=741af89c-78c4-453d-83d5-86b9a66dca08, state=READY, lastHeartbeat=1353320078398, addrs=[192.168.2.14], addr=/192.168.2.14, tcpPort=55020, startTime=1353320078398], p=GridNodePredicate [ids=[741af89c-78c4-453d-83d5-86b9a66dca08]], isLoc=true, hash=694612240, daemon=false], ex=null, hasRes=true, isCancelled=true, isOccupied=false], GridJobResultImpl [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask$1@3c6e4ba6, sib=GridJobSiblingImpl [sesId=88269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, jobId=c8269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, taskTopic=TOPIC_TASK--5725799524765009754-5763191950221394699-1353320063628--8947096952782337528-8366272608718832957, jobTopic=TOPIC_JOB--5725799524765009754-5763191950221394699-1353320063628--8947096952782337528-8366272608718832957, nodeId=741af89
c-78c4-453d-83d5-86b9a66dca08, isJobDone=true], jobCtx=GridJobContextImpl [jobId=c8269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, attrs={}], node=GridRichNodeImpl [node=GridMulticastDiscoveryNode [id=741af89c-78c4-453d-83d5-86b9a66dca08, state=READY, lastHeartbeat=1353320078398, addrs=[192.168.2.14], addr=/192.168.2.14, tcpPort=55020, startTime=1353320078398], p=GridNodePredicate [ids=[741af89c-78c4-453d-83d5-86b9a66dca08]], isLoc=true, hash=694612240, daemon=false], ex=null, hasRes=true, isCancelled=true, isOccupied=true]]]
-[14:14:39,516][INFO ][gridgain-#127%session.GridSessionCancelSiblingsFromFutureSelfTest%][GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask] Splitting jobs [task=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask@28c4b5f, gridSize=1, arg=2]
-[14:14:39,518][INFO ][gridgain-#128%session.GridSessionCancelSiblingsFromFutureSelfTest%][GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask] Computing job [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask$1@637644c8, arg=5]
-[14:14:39,519][INFO ][gridgain-#129%session.GridSessionCancelSiblingsFromFutureSelfTest%][GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask] Computing job [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask$1@3fa9b4a4, arg=3]
-[14:14:39,519][INFO ][gridgain-#130%session.GridSessionCancelSiblingsFromFutureSelfTest%][GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask] Computing job [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask$1@1e929ba3, arg=4]
-[14:14:39,520][INFO ][gridgain-#131%session.GridSessionCancelSiblingsFromFutureSelfTest%][GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask] Computing job [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask$1@4fe2fe5d, arg=2]
-[14:14:39,521][INFO ][gridgain-#132%session.GridSessionCancelSiblingsFromFutureSelfTest%][GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask] Computing job [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask$1@6e659812, arg=1]
-[14:14:39,521][INFO ][gridgain-#128%session.GridSessionCancelSiblingsFromFutureSelfTest%][GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask] Job got interrupted [arg=5, e=java.lang.InterruptedException: sleep interrupted]
-[14:14:39,521][INFO ][gridgain-#130%session.GridSessionCancelSiblingsFromFutureSelfTest%][GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask] Job got interrupted [arg=4, e=java.lang.InterruptedException: sleep interrupted]
-[14:14:39,522][INFO ][gridgain-#129%session.GridSessionCancelSiblingsFromFutureSelfTest%][GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask] Job got interrupted [arg=3, e=java.lang.InterruptedException: sleep interrupted]
-[14:14:39,522][INFO ][gridgain-#131%session.GridSessionCancelSiblingsFromFutureSelfTest%][GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask] Job got interrupted [arg=2, e=java.lang.InterruptedException: sleep interrupted]
-[14:14:39,523][INFO ][gridgain-#132%session.GridSessionCancelSiblingsFromFutureSelfTest%][GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask] Job got interrupted [arg=1, e=java.lang.InterruptedException: sleep interrupted]
-[14:14:39,525][INFO ][gridgain-#138%session.GridSessionCancelSiblingsFromFutureSelfTest%][GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask] Received job result [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask@28c4b5f, result=GridJobResultImpl [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask$1@1e929ba3, sib=GridJobSiblingImpl [sesId=4b269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, jobId=ab269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, taskTopic=TOPIC_TASK--5725799524765009754-5763191950221394699-1353320063674--8947096952782337528-8366272608718832957, jobTopic=TOPIC_JOB--5725799524765009754-5763191950221394699-1353320063674--8947096952782337528-8366272608718832957, nodeId=741af89c-78c4-453d-83d5-86b9a66dca08, isJobDone=false], jobCtx=GridJobContextImpl [jobId=ab269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, attrs={}], node=GridRichNodeImpl [node=GridMulticastDiscov
eryNode [id=741af89c-78c4-453d-83d5-86b9a66dca08, state=READY, lastHeartbeat=1353320078398, addrs=[192.168.2.14], addr=/192.168.2.14, tcpPort=55020, startTime=1353320078398], p=GridNodePredicate [ids=[741af89c-78c4-453d-83d5-86b9a66dca08]], isLoc=true, hash=694612240, daemon=false], ex=null, hasRes=true, isCancelled=true, isOccupied=true]]
-[14:14:39,526][INFO ][gridgain-#138%session.GridSessionCancelSiblingsFromFutureSelfTest%][GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask] Received job result [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask@28c4b5f, result=GridJobResultImpl [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask$1@3fa9b4a4, sib=GridJobSiblingImpl [sesId=4b269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, jobId=8b269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, taskTopic=TOPIC_TASK--5725799524765009754-5763191950221394699-1353320063672--8947096952782337528-8366272608718832957, jobTopic=TOPIC_JOB--5725799524765009754-5763191950221394699-1353320063672--8947096952782337528-8366272608718832957, nodeId=741af89c-78c4-453d-83d5-86b9a66dca08, isJobDone=false], jobCtx=GridJobContextImpl [jobId=8b269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, attrs={}], node=GridRichNodeImpl [node=GridMulticastDiscov
eryNode [id=741af89c-78c4-453d-83d5-86b9a66dca08, state=READY, lastHeartbeat=1353320078398, addrs=[192.168.2.14], addr=/192.168.2.14, tcpPort=55020, startTime=1353320078398], p=GridNodePredicate [ids=[741af89c-78c4-453d-83d5-86b9a66dca08]], isLoc=true, hash=694612240, daemon=false], ex=null, hasRes=true, isCancelled=true, isOccupied=true]]
-[14:14:39,527][INFO ][gridgain-#138%session.GridSessionCancelSiblingsFromFutureSelfTest%][GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask] Received job result [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask@28c4b5f, result=GridJobResultImpl [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask$1@4fe2fe5d, sib=GridJobSiblingImpl [sesId=4b269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, jobId=cb269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, taskTopic=TOPIC_TASK--5725799524765009754-5763191950221394699-1353320063676--8947096952782337528-8366272608718832957, jobTopic=TOPIC_JOB--5725799524765009754-5763191950221394699-1353320063676--8947096952782337528-8366272608718832957, nodeId=741af89c-78c4-453d-83d5-86b9a66dca08, isJobDone=false], jobCtx=GridJobContextImpl [jobId=cb269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, attrs={}], node=GridRichNodeImpl [node=GridMulticastDiscov
eryNode [id=741af89c-78c4-453d-83d5-86b9a66dca08, state=READY, lastHeartbeat=1353320078398, addrs=[192.168.2.14], addr=/192.168.2.14, tcpPort=55020, startTime=1353320078398], p=GridNodePredicate [ids=[741af89c-78c4-453d-83d5-86b9a66dca08]], isLoc=true, hash=694612240, daemon=false], ex=null, hasRes=true, isCancelled=true, isOccupied=true]]
-[14:14:39,527][INFO ][gridgain-#138%session.GridSessionCancelSiblingsFromFutureSelfTest%][GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask] Received job result [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask@28c4b5f, result=GridJobResultImpl [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask$1@637644c8, sib=GridJobSiblingImpl [sesId=4b269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, jobId=6b269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, taskTopic=TOPIC_TASK--5725799524765009754-5763191950221394699-1353320063670--8947096952782337528-8366272608718832957, jobTopic=TOPIC_JOB--5725799524765009754-5763191950221394699-1353320063670--8947096952782337528-8366272608718832957, nodeId=741af89c-78c4-453d-83d5-86b9a66dca08, isJobDone=false], jobCtx=GridJobContextImpl [jobId=6b269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, attrs={}], node=GridRichNodeImpl [node=GridMulticastDiscov
eryNode [id=741af89c-78c4-453d-83d5-86b9a66dca08, state=READY, lastHeartbeat=1353320078398, addrs=[192.168.2.14], addr=/192.168.2.14, tcpPort=55020, startTime=1353320078398], p=GridNodePredicate [ids=[741af89c-78c4-453d-83d5-86b9a66dca08]], isLoc=true, hash=694612240, daemon=false], ex=null, hasRes=true, isCancelled=true, isOccupied=true]]
-[14:14:39,528][INFO ][gridgain-#142%session.GridSessionCancelSiblingsFromFutureSelfTest%][GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask] Received job result [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask@28c4b5f, result=GridJobResultImpl [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask$1@6e659812, sib=GridJobSiblingImpl [sesId=4b269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, jobId=eb269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, taskTopic=TOPIC_TASK--5725799524765009754-5763191950221394699-1353320063678--8947096952782337528-8366272608718832957, jobTopic=TOPIC_JOB--5725799524765009754-5763191950221394699-1353320063678--8947096952782337528-8366272608718832957, nodeId=741af89c-78c4-453d-83d5-86b9a66dca08, isJobDone=false], jobCtx=GridJobContextImpl [jobId=eb269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, attrs={}], node=GridRichNodeImpl [node=GridMulticastDiscov
eryNode [id=741af89c-78c4-453d-83d5-86b9a66dca08, state=READY, lastHeartbeat=1353320078398, addrs=[192.168.2.14], addr=/192.168.2.14, tcpPort=55020, startTime=1353320078398], p=GridNodePredicate [ids=[741af89c-78c4-453d-83d5-86b9a66dca08]], isLoc=true, hash=694612240, daemon=false], ex=null, hasRes=true, isCancelled=true, isOccupied=true]]
-[14:14:39,530][INFO ][gridgain-#142%session.GridSessionCancelSiblingsFromFutureSelfTest%][GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask] Aggregating job [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask@28c4b5f, results=[GridJobResultImpl [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask$1@1e929ba3, sib=GridJobSiblingImpl [sesId=4b269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, jobId=ab269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, taskTopic=TOPIC_TASK--5725799524765009754-5763191950221394699-1353320063674--8947096952782337528-8366272608718832957, jobTopic=TOPIC_JOB--5725799524765009754-5763191950221394699-1353320063674--8947096952782337528-8366272608718832957, nodeId=741af89c-78c4-453d-83d5-86b9a66dca08, isJobDone=true], jobCtx=GridJobContextImpl [jobId=ab269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, attrs={}], node=GridRichNodeImpl [node=GridMulticastDiscovery
Node [id=741af89c-78c4-453d-83d5-86b9a66dca08, state=READY, lastHeartbeat=1353320078398, addrs=[192.168.2.14], addr=/192.168.2.14, tcpPort=55020, startTime=1353320078398], p=GridNodePredicate [ids=[741af89c-78c4-453d-83d5-86b9a66dca08]], isLoc=true, hash=694612240, daemon=false], ex=null, hasRes=true, isCancelled=true, isOccupied=false], GridJobResultImpl [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask$1@3fa9b4a4, sib=GridJobSiblingImpl [sesId=4b269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, jobId=8b269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, taskTopic=TOPIC_TASK--5725799524765009754-5763191950221394699-1353320063672--8947096952782337528-8366272608718832957, jobTopic=TOPIC_JOB--5725799524765009754-5763191950221394699-1353320063672--8947096952782337528-8366272608718832957, nodeId=741af89c-78c4-453d-83d5-86b9a66dca08, isJobDone=true], jobCtx=GridJobContextImpl [jobId=8b269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, attrs={}], no
de=GridRichNodeImpl [node=GridMulticastDiscoveryNode [id=741af89c-78c4-453d-83d5-86b9a66dca08, state=READY, lastHeartbeat=1353320078398, addrs=[192.168.2.14], addr=/192.168.2.14, tcpPort=55020, startTime=1353320078398], p=GridNodePredicate [ids=[741af89c-78c4-453d-83d5-86b9a66dca08]], isLoc=true, hash=694612240, daemon=false], ex=null, hasRes=true, isCancelled=true, isOccupied=false], GridJobResultImpl [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask$1@637644c8, sib=GridJobSiblingImpl [sesId=4b269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, jobId=6b269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, taskTopic=TOPIC_TASK--5725799524765009754-5763191950221394699-1353320063670--8947096952782337528-8366272608718832957, jobTopic=TOPIC_JOB--5725799524765009754-5763191950221394699-1353320063670--8947096952782337528-8366272608718832957, nodeId=741af89c-78c4-453d-83d5-86b9a66dca08, isJobDone=true], jobCtx=GridJobContextImpl [jobId=6b269281b31-4ff
af88b-4556-430b-b089-dfab3747f8a6, attrs={}], node=GridRichNodeImpl [node=GridMulticastDiscoveryNode [id=741af89c-78c4-453d-83d5-86b9a66dca08, state=READY, lastHeartbeat=1353320078398, addrs=[192.168.2.14], addr=/192.168.2.14, tcpPort=55020, startTime=1353320078398], p=GridNodePredicate [ids=[741af89c-78c4-453d-83d5-86b9a66dca08]], isLoc=true, hash=694612240, daemon=false], ex=null, hasRes=true, isCancelled=true, isOccupied=false], GridJobResultImpl [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask$1@6e659812, sib=GridJobSiblingImpl [sesId=4b269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, jobId=eb269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, taskTopic=TOPIC_TASK--5725799524765009754-5763191950221394699-1353320063678--8947096952782337528-8366272608718832957, jobTopic=TOPIC_JOB--5725799524765009754-5763191950221394699-1353320063678--8947096952782337528-8366272608718832957, nodeId=741af89c-78c4-453d-83d5-86b9a66dca08, isJobDone=true],
jobCtx=GridJobContextImpl [jobId=eb269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, attrs={}], node=GridRichNodeImpl [node=GridMulticastDiscoveryNode [id=741af89c-78c4-453d-83d5-86b9a66dca08, state=READY, lastHeartbeat=1353320078398, addrs=[192.168.2.14], addr=/192.168.2.14, tcpPort=55020, startTime=1353320078398], p=GridNodePredicate [ids=[741af89c-78c4-453d-83d5-86b9a66dca08]], isLoc=true, hash=694612240, daemon=false], ex=null, hasRes=true, isCancelled=true, isOccupied=true], GridJobResultImpl [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask$1@4fe2fe5d, sib=GridJobSiblingImpl [sesId=4b269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, jobId=cb269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, taskTopic=TOPIC_TASK--5725799524765009754-5763191950221394699-1353320063676--8947096952782337528-8366272608718832957, jobTopic=TOPIC_JOB--5725799524765009754-5763191950221394699-1353320063676--8947096952782337528-8366272608718832957, nodeId=741af89c
-78c4-453d-83d5-86b9a66dca08, isJobDone=true], jobCtx=GridJobContextImpl [jobId=cb269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, attrs={}], node=GridRichNodeImpl [node=GridMulticastDiscoveryNode [id=741af89c-78c4-453d-83d5-86b9a66dca08, state=READY, lastHeartbeat=1353320078398, addrs=[192.168.2.14], addr=/192.168.2.14, tcpPort=55020, startTime=1353320078398], p=GridNodePredicate [ids=[741af89c-78c4-453d-83d5-86b9a66dca08]], isLoc=true, hash=694612240, daemon=false], ex=null, hasRes=true, isCancelled=true, isOccupied=false]]]
-[14:14:39,531][INFO ][gridgain-#143%session.GridSessionCancelSiblingsFromFutureSelfTest%][GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask] Splitting jobs [task=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask@f8b7298, gridSize=1, arg=3]
-[14:14:39,533][INFO ][gridgain-#144%session.GridSessionCancelSiblingsFromFutureSelfTest%][GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask] Computing job [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask$1@44ec366a, arg=5]
-[14:14:39,535][INFO ][gridgain-#145%session.GridSessionCancelSiblingsFromFutureSelfTest%][GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask] Computing job [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask$1@377e4cec, arg=4]
-[14:14:39,536][INFO ][gridgain-#146%session.GridSessionCancelSiblingsFromFutureSelfTest%][GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask] Computing job [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask$1@12d91987, arg=2]
-[14:14:39,537][INFO ][gridgain-#147%session.GridSessionCancelSiblingsFromFutureSelfTest%][GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask] Computing job [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask$1@6b1af7bb, arg=3]
-[14:14:39,537][INFO ][gridgain-#148%session.GridSessionCancelSiblingsFromFutureSelfTest%][GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask] Computing job [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask$1@54992725, arg=1]
-[14:14:39,538][INFO ][gridgain-#144%session.GridSessionCancelSiblingsFromFutureSelfTest%][GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask] Job got interrupted [arg=5, e=java.lang.InterruptedException: sleep interrupted]
-[14:14:39,538][INFO ][gridgain-#147%session.GridSessionCancelSiblingsFromFutureSelfTest%][GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask] Job got interrupted [arg=3, e=java.lang.InterruptedException: sleep interrupted]
-[14:14:39,539][INFO ][gridgain-#146%session.GridSessionCancelSiblingsFromFutureSelfTest%][GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask] Job got interrupted [arg=2, e=java.lang.InterruptedException: sleep interrupted]
-[14:14:39,539][INFO ][gridgain-#145%session.GridSessionCancelSiblingsFromFutureSelfTest%][GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask] Job got interrupted [arg=4, e=java.lang.InterruptedException: sleep interrupted]
-[14:14:39,541][INFO ][gridgain-#148%session.GridSessionCancelSiblingsFromFutureSelfTest%][GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask] Job got interrupted [arg=1, e=java.lang.InterruptedException: sleep interrupted]
-[14:14:39,543][INFO ][gridgain-#154%session.GridSessionCancelSiblingsFromFutureSelfTest%][GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask] Received job result [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask@f8b7298, result=GridJobResultImpl [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask$1@44ec366a, sib=GridJobSiblingImpl [sesId=0e269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, jobId=2e269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, taskTopic=TOPIC_TASK--5725799524765009754-5763191950221394699-1353320063714--8947096952782337528-8366272608718832957, jobTopic=TOPIC_JOB--5725799524765009754-5763191950221394699-1353320063714--8947096952782337528-8366272608718832957, nodeId=741af89c-78c4-453d-83d5-86b9a66dca08, isJobDone=false], jobCtx=GridJobContextImpl [jobId=2e269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, attrs={}], node=GridRichNodeImpl [node=GridMulticastDiscov
eryNode [id=741af89c-78c4-453d-83d5-86b9a66dca08, state=READY, lastHeartbeat=1353320078398, addrs=[192.168.2.14], addr=/192.168.2.14, tcpPort=55020, startTime=1353320078398], p=GridNodePredicate [ids=[741af89c-78c4-453d-83d5-86b9a66dca08]], isLoc=true, hash=694612240, daemon=false], ex=null, hasRes=true, isCancelled=true, isOccupied=true]]
-[14:14:39,543][INFO ][gridgain-#154%session.GridSessionCancelSiblingsFromFutureSelfTest%][GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask] Received job result [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask@f8b7298, result=GridJobResultImpl [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask$1@12d91987, sib=GridJobSiblingImpl [sesId=0e269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, jobId=6e269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, taskTopic=TOPIC_TASK--5725799524765009754-5763191950221394699-1353320063718--8947096952782337528-8366272608718832957, jobTopic=TOPIC_JOB--5725799524765009754-5763191950221394699-1353320063718--8947096952782337528-8366272608718832957, nodeId=741af89c-78c4-453d-83d5-86b9a66dca08, isJobDone=false], jobCtx=GridJobContextImpl [jobId=6e269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, attrs={}], node=GridRichNodeImpl [node=GridMulticastDiscov
eryNode [id=741af89c-78c4-453d-83d5-86b9a66dca08, state=READY, lastHeartbeat=1353320078398, addrs=[192.168.2.14], addr=/192.168.2.14, tcpPort=55020, startTime=1353320078398], p=GridNodePredicate [ids=[741af89c-78c4-453d-83d5-86b9a66dca08]], isLoc=true, hash=694612240, daemon=false], ex=null, hasRes=true, isCancelled=true, isOccupied=true]]
-[14:14:39,544][INFO ][gridgain-#154%session.GridSessionCancelSiblingsFromFutureSelfTest%][GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask] Received job result [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask@f8b7298, result=GridJobResultImpl [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask$1@6b1af7bb, sib=GridJobSiblingImpl [sesId=0e269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, jobId=8e269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, taskTopic=TOPIC_TASK--5725799524765009754-5763191950221394699-1353320063720--8947096952782337528-8366272608718832957, jobTopic=TOPIC_JOB--5725799524765009754-5763191950221394699-1353320063720--8947096952782337528-8366272608718832957, nodeId=741af89c-78c4-453d-83d5-86b9a66dca08, isJobDone=false], jobCtx=GridJobContextImpl [jobId=8e269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, attrs={}], node=GridRichNodeImpl [node=GridMulticastDiscov
eryNode [id=741af89c-78c4-453d-83d5-86b9a66dca08, state=READY, lastHeartbeat=1353320078398, addrs=[192.168.2.14], addr=/192.168.2.14, tcpPort=55020, startTime=1353320078398], p=GridNodePredicate [ids=[741af89c-78c4-453d-83d5-86b9a66dca08]], isLoc=true, hash=694612240, daemon=false], ex=null, hasRes=true, isCancelled=true, isOccupied=true]]
-[14:14:39,544][INFO ][gridgain-#154%session.GridSessionCancelSiblingsFromFutureSelfTest%][GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask] Received job result [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask@f8b7298, result=GridJobResultImpl [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask$1@54992725, sib=GridJobSiblingImpl [sesId=0e269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, jobId=ae269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, taskTopic=TOPIC_TASK--5725799524765009754-5763191950221394699-1353320063722--8947096952782337528-8366272608718832957, jobTopic=TOPIC_JOB--5725799524765009754-5763191950221394699-1353320063722--8947096952782337528-8366272608718832957, nodeId=741af89c-78c4-453d-83d5-86b9a66dca08, isJobDone=false], jobCtx=GridJobContextImpl [jobId=ae269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, attrs={}], node=GridRichNodeImpl [node=GridMulticastDiscov
eryNode [id=741af89c-78c4-453d-83d5-86b9a66dca08, state=READY, lastHeartbeat=1353320078398, addrs=[192.168.2.14], addr=/192.168.2.14, tcpPort=55020, startTime=1353320078398], p=GridNodePredicate [ids=[741af89c-78c4-453d-83d5-86b9a66dca08]], isLoc=true, hash=694612240, daemon=false], ex=null, hasRes=true, isCancelled=true, isOccupied=true]]
-[14:14:39,545][INFO ][gridgain-#154%session.GridSessionCancelSiblingsFromFutureSelfTest%][GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask] Received job result [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask@f8b7298, result=GridJobResultImpl [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask$1@377e4cec, sib=GridJobSiblingImpl [sesId=0e269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, jobId=4e269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, taskTopic=TOPIC_TASK--5725799524765009754-5763191950221394699-1353320063716--8947096952782337528-8366272608718832957, jobTopic=TOPIC_JOB--5725799524765009754-5763191950221394699-1353320063716--8947096952782337528-8366272608718832957, nodeId=741af89c-78c4-453d-83d5-86b9a66dca08, isJobDone=false], jobCtx=GridJobContextImpl [jobId=4e269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, attrs={}], node=GridRichNodeImpl [node=GridMulticastDiscov
eryNode [id=741af89c-78c4-453d-83d5-86b9a66dca08, state=READY, lastHeartbeat=1353320078398, addrs=[192.168.2.14], addr=/192.168.2.14, tcpPort=55020, startTime=1353320078398], p=GridNodePredicate [ids=[741af89c-78c4-453d-83d5-86b9a66dca08]], isLoc=true, hash=694612240, daemon=false], ex=null, hasRes=true, isCancelled=true, isOccupied=true]]
-[14:14:39,546][INFO ][gridgain-#154%session.GridSessionCancelSiblingsFromFutureSelfTest%][GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask] Aggregating job [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask@f8b7298, results=[GridJobResultImpl [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask$1@377e4cec, sib=GridJobSiblingImpl [sesId=0e269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, jobId=4e269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, taskTopic=TOPIC_TASK--5725799524765009754-5763191950221394699-1353320063716--8947096952782337528-8366272608718832957, jobTopic=TOPIC_JOB--5725799524765009754-5763191950221394699-1353320063716--8947096952782337528-8366272608718832957, nodeId=741af89c-78c4-453d-83d5-86b9a66dca08, isJobDone=true], jobCtx=GridJobContextImpl [jobId=4e269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, attrs={}], node=GridRichNodeImpl [node=GridMulticastDiscovery
Node [id=741af89c-78c4-453d-83d5-86b9a66dca08, state=READY, lastHeartbeat=1353320078398, addrs=[192.168.2.14], addr=/192.168.2.14, tcpPort=55020, startTime=1353320078398], p=GridNodePredicate [ids=[741af89c-78c4-453d-83d5-86b9a66dca08]], isLoc=true, hash=694612240, daemon=false], ex=null, hasRes=true, isCancelled=true, isOccupied=true], GridJobResultImpl [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask$1@12d91987, sib=GridJobSiblingImpl [sesId=0e269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, jobId=6e269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, taskTopic=TOPIC_TASK--5725799524765009754-5763191950221394699-1353320063718--8947096952782337528-8366272608718832957, jobTopic=TOPIC_JOB--5725799524765009754-5763191950221394699-1353320063718--8947096952782337528-8366272608718832957, nodeId=741af89c-78c4-453d-83d5-86b9a66dca08, isJobDone=true], jobCtx=GridJobContextImpl [jobId=6e269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, attrs={}], nod
e=GridRichNodeImpl [node=GridMulticastDiscoveryNode [id=741af89c-78c4-453d-83d5-86b9a66dca08, state=READY, lastHeartbeat=1353320078398, addrs=[192.168.2.14], addr=/192.168.2.14, tcpPort=55020, startTime=1353320078398], p=GridNodePredicate [ids=[741af89c-78c4-453d-83d5-86b9a66dca08]], isLoc=true, hash=694612240, daemon=false], ex=null, hasRes=true, isCancelled=true, isOccupied=false], GridJobResultImpl [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask$1@6b1af7bb, sib=GridJobSiblingImpl [sesId=0e269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, jobId=8e269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, taskTopic=TOPIC_TASK--5725799524765009754-5763191950221394699-1353320063720--8947096952782337528-8366272608718832957, jobTopic=TOPIC_JOB--5725799524765009754-5763191950221394699-1353320063720--8947096952782337528-8366272608718832957, nodeId=741af89c-78c4-453d-83d5-86b9a66dca08, isJobDone=true], jobCtx=GridJobContextImpl [jobId=8e269281b31-4ffa
f88b-4556-430b-b089-dfab3747f8a6, attrs={}], node=GridRichNodeImpl [node=GridMulticastDiscoveryNode [id=741af89c-78c4-453d-83d5-86b9a66dca08, state=READY, lastHeartbeat=1353320078398, addrs=[192.168.2.14], addr=/192.168.2.14, tcpPort=55020, startTime=1353320078398], p=GridNodePredicate [ids=[741af89c-78c4-453d-83d5-86b9a66dca08]], isLoc=true, hash=694612240, daemon=false], ex=null, hasRes=true, isCancelled=true, isOccupied=false], GridJobResultImpl [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask$1@54992725, sib=GridJobSiblingImpl [sesId=0e269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, jobId=ae269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, taskTopic=TOPIC_TASK--5725799524765009754-5763191950221394699-1353320063722--8947096952782337528-8366272608718832957, jobTopic=TOPIC_JOB--5725799524765009754-5763191950221394699-1353320063722--8947096952782337528-8366272608718832957, nodeId=741af89c-78c4-453d-83d5-86b9a66dca08, isJobDone=true], j
obCtx=GridJobContextImpl [jobId=ae269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, attrs={}], node=GridRichNodeImpl [node=GridMulticastDiscoveryNode [id=741af89c-78c4-453d-83d5-86b9a66dca08, state=READY, lastHeartbeat=1353320078398, addrs=[192.168.2.14], addr=/192.168.2.14, tcpPort=55020, startTime=1353320078398], p=GridNodePredicate [ids=[741af89c-78c4-453d-83d5-86b9a66dca08]], isLoc=true, hash=694612240, daemon=false], ex=null, hasRes=true, isCancelled=true, isOccupied=false], GridJobResultImpl [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask$1@44ec366a, sib=GridJobSiblingImpl [sesId=0e269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, jobId=2e269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, taskTopic=TOPIC_TASK--5725799524765009754-5763191950221394699-1353320063714--8947096952782337528-8366272608718832957, jobTopic=TOPIC_JOB--5725799524765009754-5763191950221394699-1353320063714--8947096952782337528-8366272608718832957, nodeId=741af89c
-78c4-453d-83d5-86b9a66dca08, isJobDone=true], jobCtx=GridJobContextImpl [jobId=2e269281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, attrs={}], node=GridRichNodeImpl [node=GridMulticastDiscoveryNode [id=741af89c-78c4-453d-83d5-86b9a66dca08, state=READY, lastHeartbeat=1353320078398, addrs=[192.168.2.14], addr=/192.168.2.14, tcpPort=55020, startTime=1353320078398], p=GridNodePredicate [ids=[741af89c-78c4-453d-83d5-86b9a66dca08]], isLoc=true, hash=694612240, daemon=false], ex=null, hasRes=true, isCancelled=true, isOccupied=false]]]
-[14:14:39,547][INFO ][gridgain-#159%session.GridSessionCancelSiblingsFromFutureSelfTest%][GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask] Splitting jobs [task=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask@1330b13c, gridSize=1, arg=4]
-[14:14:39,549][INFO ][gridgain-#160%session.GridSessionCancelSiblingsFromFutureSelfTest%][GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask] Computing job [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask$1@742136c6, arg=3]
-[14:14:39,550][INFO ][gridgain-#161%session.GridSessionCancelSiblingsFromFutureSelfTest%][GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask] Computing job [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask$1@5e8518d4, arg=2]
-[14:14:39,550][INFO ][gridgain-#162%session.GridSessionCancelSiblingsFromFutureSelfTest%][GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask] Computing job [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask$1@1277f040, arg=5]
-[14:14:39,551][INFO ][gridgain-#163%session.GridSessionCancelSiblingsFromFutureSelfTest%][GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask] Computing job [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask$1@30933cba, arg=4]
-[14:14:39,551][INFO ][gridgain-#164%session.GridSessionCancelSiblingsFromFutureSelfTest%][GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask] Computing job [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask$1@3bbe9a50, arg=1]
-[14:14:39,552][INFO ][gridgain-#161%session.GridSessionCancelSiblingsFromFutureSelfTest%][GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask] Job got interrupted [arg=2, e=java.lang.InterruptedException: sleep interrupted]
-[14:14:39,552][INFO ][gridgain-#162%session.GridSessionCancelSiblingsFromFutureSelfTest%][GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask] Job got interrupted [arg=5, e=java.lang.InterruptedException: sleep interrupted]
-[14:14:39,553][INFO ][gridgain-#160%session.GridSessionCancelSiblingsFromFutureSelfTest%][GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask] Job got interrupted [arg=3, e=java.lang.InterruptedException: sleep interrupted]
-[14:14:39,553][INFO ][gridgain-#163%session.GridSessionCancelSiblingsFromFutureSelfTest%][GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask] Job got interrupted [arg=4, e=java.lang.InterruptedException: sleep interrupted]
-[14:14:39,553][INFO ][gridgain-#164%session.GridSessionCancelSiblingsFromFutureSelfTest%][GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask] Job got interrupted [arg=1, e=java.lang.InterruptedException: sleep interrupted]
-[14:14:39,554][INFO ][gridgain-#103%session.GridSessionCancelSiblingsFromFutureSelfTest%][GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask] Received job result [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask@1330b13c, result=GridJobResultImpl [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask$1@5e8518d4, sib=GridJobSiblingImpl [sesId=c0369281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, jobId=01369281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, taskTopic=TOPIC_TASK--5725799524765009754-5763191950221394699-1353320063760--8947096952782337528-8366272608718832957, jobTopic=TOPIC_JOB--5725799524765009754-5763191950221394699-1353320063760--8947096952782337528-8366272608718832957, nodeId=741af89c-78c4-453d-83d5-86b9a66dca08, isJobDone=false], jobCtx=GridJobContextImpl [jobId=01369281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, attrs={}], node=GridRichNodeImpl [node=GridMulticastDisco
veryNode [id=741af89c-78c4-453d-83d5-86b9a66dca08, state=READY, lastHeartbeat=1353320078398, addrs=[192.168.2.14], addr=/192.168.2.14, tcpPort=55020, startTime=1353320078398], p=GridNodePredicate [ids=[741af89c-78c4-453d-83d5-86b9a66dca08]], isLoc=true, hash=694612240, daemon=false], ex=null, hasRes=true, isCancelled=true, isOccupied=true]]
-[14:14:39,554][INFO ][gridgain-#107%session.GridSessionCancelSiblingsFromFutureSelfTest%][GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask] Received job result [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask@1330b13c, result=GridJobResultImpl [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask$1@1277f040, sib=GridJobSiblingImpl [sesId=c0369281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, jobId=21369281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, taskTopic=TOPIC_TASK--5725799524765009754-5763191950221394699-1353320063762--8947096952782337528-8366272608718832957, jobTopic=TOPIC_JOB--5725799524765009754-5763191950221394699-1353320063762--8947096952782337528-8366272608718832957, nodeId=741af89c-78c4-453d-83d5-86b9a66dca08, isJobDone=false], jobCtx=GridJobContextImpl [jobId=21369281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, attrs={}], node=GridRichNodeImpl [node=GridMulticastDisco
veryNode [id=741af89c-78c4-453d-83d5-86b9a66dca08, state=READY, lastHeartbeat=1353320078398, addrs=[192.168.2.14], addr=/192.168.2.14, tcpPort=55020, startTime=1353320078398], p=GridNodePredicate [ids=[741af89c-78c4-453d-83d5-86b9a66dca08]], isLoc=true, hash=694612240, daemon=false], ex=null, hasRes=true, isCancelled=true, isOccupied=true]]
-[14:14:39,555][INFO ][gridgain-#107%session.GridSessionCancelSiblingsFromFutureSelfTest%][GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask] Received job result [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask@1330b13c, result=GridJobResultImpl [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask$1@742136c6, sib=GridJobSiblingImpl [sesId=c0369281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, jobId=e0369281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, taskTopic=TOPIC_TASK--5725799524765009754-5763191950221394699-1353320063758--8947096952782337528-8366272608718832957, jobTopic=TOPIC_JOB--5725799524765009754-5763191950221394699-1353320063758--8947096952782337528-8366272608718832957, nodeId=741af89c-78c4-453d-83d5-86b9a66dca08, isJobDone=false], jobCtx=GridJobContextImpl [jobId=e0369281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, attrs={}], node=GridRichNodeImpl [node=GridMulticastDisco
veryNode [id=741af89c-78c4-453d-83d5-86b9a66dca08, state=READY, lastHeartbeat=1353320078398, addrs=[192.168.2.14], addr=/192.168.2.14, tcpPort=55020, startTime=1353320078398], p=GridNodePredicate [ids=[741af89c-78c4-453d-83d5-86b9a66dca08]], isLoc=true, hash=694612240, daemon=false], ex=null, hasRes=true, isCancelled=true, isOccupied=true]]
-[14:14:39,555][INFO ][gridgain-#107%session.GridSessionCancelSiblingsFromFutureSelfTest%][GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask] Received job result [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask@1330b13c, result=GridJobResultImpl [job=org.gridgain.grid.session.GridSessionCancelSiblingsFromFutureSelfTest$GridTaskSessionTestTask$1@3bbe9a50, sib=GridJobSiblingImpl [sesId=c0369281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, jobId=61369281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, taskTopic=TOPIC_TASK--5725799524765009754-5763191950221394699-1353320063766--8947096952782337528-8366272608718832957, jobTopic=TOPIC_JOB--5725799524765009754-5763191950221394699-1353320063766--8947096952782337528-8366272608718832957, nodeId=741af89c-78c4-453d-83d5-86b9a66dca08, isJobDone=false], jobCtx=GridJobContextImpl [jobId=61369281b31-4ffaf88b-4556-430b-b089-dfab3747f8a6, attrs={}], node=GridRichNodeImpl [node=GridMulticastDisco
veryNode [id=741af89c-78c4-453d-83d5-86b9a66dca08, state=READY, lastHeartbeat=1353320078398, addrs=[192.168.2.14],
<TRUNCATED>
[02/11] incubator-ignite git commit: Merge branches 'ignite-344' and
'sprint-2' of https://git-wip-us.apache.org/repos/asf/incubator-ignite into
ignite-344
Posted by sb...@apache.org.
Merge branches 'ignite-344' and 'sprint-2' of https://git-wip-us.apache.org/repos/asf/incubator-ignite into ignite-344
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/5b0d7db7
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/5b0d7db7
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/5b0d7db7
Branch: refs/heads/ignite-349
Commit: 5b0d7db77cdbca9c2d33b3c64f567f61faec8a8f
Parents: 4348d9c b81c6a2
Author: AKuznetsov <ak...@gridgain.com>
Authored: Tue Mar 3 15:34:35 2015 +0700
Committer: AKuznetsov <ak...@gridgain.com>
Committed: Tue Mar 3 15:34:35 2015 +0700
----------------------------------------------------------------------
config/hadoop/default-config.xml | 12 +
config/ignite-log4j.xml | 2 +-
examples/pom-standalone.xml | 2 +-
.../datagrid/CacheContinuousQueryExample.java | 2 +-
.../store/CacheNodeWithStoreStartup.java | 6 +-
.../store/jdbc/CacheJdbcPersonStore.java | 115 +-
ipc/shmem/Makefile.am | 15 +
ipc/shmem/igniteshmem/Makefile.am | 15 +
ipc/shmem/include/Makefile.am | 15 +
modules/clients/src/test/keystore/generate.sh | 15 +-
.../src/main/java/org/apache/ignite/Ignite.java | 4 +-
.../java/org/apache/ignite/IgniteCluster.java | 8 +-
.../ignite/cache/CacheTypeFieldMetadata.java | 2 +-
.../apache/ignite/cache/CacheTypeMetadata.java | 18 +-
.../ignite/cache/query/ContinuousQuery.java | 18 +-
.../apache/ignite/cache/store/CacheStore.java | 4 +-
.../ignite/cache/store/CacheStoreAdapter.java | 2 +-
.../ignite/cache/store/CacheStoreSession.java | 17 +-
.../apache/ignite/cluster/ClusterMetrics.java | 2 +-
.../configuration/IgniteConfiguration.java | 5 +-
.../configuration/QueryConfiguration.java | 37 +-
.../java/org/apache/ignite/igfs/IgfsMode.java | 6 +-
.../ignite/internal/GridKernalContext.java | 10 +-
.../ignite/internal/GridKernalContextImpl.java | 14 +-
.../apache/ignite/internal/GridProperties.java | 78 -
.../ignite/internal/GridUpdateNotifier.java | 2 +-
.../apache/ignite/internal/IgniteKernal.java | 41 +-
.../ignite/internal/IgniteProperties.java | 79 +
.../ignite/internal/IgniteVersionUtils.java | 8 +-
.../org/apache/ignite/internal/IgnitionEx.java | 592 +++----
.../internal/events/DiscoveryCustomEvent.java | 3 +
.../affinity/GridAffinityAssignmentCache.java | 13 +-
.../processors/cache/CacheMetricsImpl.java | 4 +
.../processors/cache/GridCacheContext.java | 19 +
.../processors/cache/GridCacheMapEntry.java | 9 +
.../processors/cache/GridCacheProcessor.java | 15 +
.../processors/cache/GridCacheStoreManager.java | 18 +-
.../processors/cache/IgniteCacheProxy.java | 6 +-
.../GridDistributedCacheAdapter.java | 2 +
.../distributed/dht/GridDhtCacheEntry.java | 3 +
.../distributed/dht/GridDhtLocalPartition.java | 5 +
.../dht/atomic/GridDhtAtomicCache.java | 2 +-
.../dht/colocated/GridDhtColocatedCache.java | 2 +-
.../cache/transactions/IgniteTxManager.java | 7 +-
.../processors/cluster/ClusterProcessor.java | 46 +
.../dataload/IgniteDataLoaderImpl.java | 29 +-
.../plugin/IgnitePluginProcessor.java | 24 +
.../ignite/internal/util/IgniteUtils.java | 90 +-
.../ignite/internal/visor/cache/VisorCache.java | 190 +--
.../cache/VisorCacheAffinityConfiguration.java | 53 +-
.../visor/cache/VisorCacheConfiguration.java | 484 +-----
.../cache/VisorCacheDefaultConfiguration.java | 27 +-
.../cache/VisorCacheEvictionConfiguration.java | 81 +-
.../cache/VisorCacheNearConfiguration.java | 42 +-
.../cache/VisorCachePreloadConfiguration.java | 54 +-
.../cache/VisorCacheStoreConfiguration.java | 148 +-
.../VisorCacheWriteBehindConfiguration.java | 137 --
.../visor/node/VisorAtomicConfiguration.java | 27 +-
.../visor/node/VisorBasicConfiguration.java | 197 +--
.../node/VisorCacheQueryConfiguration.java | 45 +-
.../node/VisorExecutorServiceConfiguration.java | 54 +-
.../visor/node/VisorGridConfiguration.java | 177 +-
.../visor/node/VisorIgfsConfiguration.java | 244 +--
.../visor/node/VisorLifecycleConfiguration.java | 9 +-
.../visor/node/VisorMetricsConfiguration.java | 29 +-
.../node/VisorPeerToPeerConfiguration.java | 28 +-
.../visor/node/VisorQueryConfiguration.java | 65 +-
.../visor/node/VisorRestConfiguration.java | 80 +-
.../node/VisorSegmentationConfiguration.java | 45 +-
.../visor/node/VisorSpisConfiguration.java | 92 +-
.../node/VisorTransactionConfiguration.java | 62 +-
.../internal/visor/util/VisorTaskUtils.java | 4 +-
.../optimized-classnames.previous.properties | 15 +
.../optimized/optimized-classnames.properties | 1565 +-----------------
.../apache/ignite/plugin/PluginProvider.java | 5 +
.../spi/discovery/tcp/TcpDiscoverySpi.java | 137 +-
.../discovery/tcp/TcpDiscoverySpiAdapter.java | 116 ++
.../TcpDiscoveryCustomEventMessage.java | 3 +
.../core/src/main/resources/ignite.properties | 2 +-
.../core/src/test/config/store/jdbc/Ignite.xml | 63 +-
.../internal/GridUpdateNotifierSelfTest.java | 2 +-
.../GridCacheAbstractLocalStoreSelfTest.java | 440 +++++
.../cache/GridCacheAbstractMetricsSelfTest.java | 42 +
...acheAbstractUsersAffinityMapperSelfTest.java | 207 +++
...dCacheAtomicUsersAffinityMapperSelfTest.java | 45 +
.../GridCachePartitionedLocalStoreSelfTest.java | 51 +
...chePartitionedOffHeapLocalStoreSelfTest.java | 56 +
.../GridCacheReplicatedLocalStoreSelfTest.java | 51 +
...heReplicatedUsersAffinityMapperSelfTest.java | 45 +
...ridCacheTxPartitionedLocalStoreSelfTest.java | 51 +
.../GridCacheTxUsersAffinityMapperSelfTest.java | 45 +
.../GridCacheQueueCleanupSelfTest.java | 1 -
.../IgniteCacheExpiryPolicyAbstractTest.java | 38 +-
...ridCacheContinuousQueryAbstractSelfTest.java | 8 +-
.../config/GridTestProperties.java | 10 +-
.../junits/cache/TestCacheSession.java | 5 +
.../cache/TestThreadLocalCacheSession.java | 5 +
.../ignite/testsuites/IgniteCacheTestSuite.java | 4 +
modules/extdata/p2p/pom.xml | 6 -
.../client/hadoop/GridHadoopClientProtocol.java | 6 +-
.../hadoop/IgfsHadoopFileSystemWrapper.java | 412 +++++
.../igfs/hadoop/v1/IgfsHadoopFileSystem.java | 3 +-
.../igfs/hadoop/v2/IgfsHadoopFileSystem.java | 3 +-
.../igfs/hadoop/IgfsHadoopFSProperties.java | 10 +-
.../hadoop/IgfsHadoopFileSystemWrapper.java | 413 -----
.../internal/igfs/hadoop/IgfsHadoopReader.java | 2 +-
.../internal/igfs/hadoop/IgfsHadoopUtils.java | 4 +-
.../hadoop/GridHadoopClassLoader.java | 12 +-
.../processors/hadoop/GridHadoopSetup.java | 8 +-
.../processors/hadoop/GridHadoopUtils.java | 4 +-
.../collections/GridHadoopHashMultimapBase.java | 2 +-
.../GridHadoopExternalCommunication.java | 14 +-
.../hadoop/v1/GridHadoopV1MapTask.java | 6 +-
.../v2/GridHadoopV2JobResourceManager.java | 2 +-
.../GridHadoopClientProtocolSelfTest.java | 6 +-
.../apache/ignite/igfs/IgfsEventsTestSuite.java | 2 +-
.../IgfsHadoop20FileSystemAbstractSelfTest.java | 2 +-
.../igfs/IgfsHadoopDualAbstractSelfTest.java | 2 +-
.../IgfsHadoopFileSystemAbstractSelfTest.java | 1 +
...fsHadoopFileSystemSecondaryModeSelfTest.java | 2 +-
.../hadoop/GridHadoopGroupingTest.java | 4 +-
.../igfs/IgfsPerformanceBenchmark.java | 9 +-
modules/hibernate/pom.xml | 6 -
.../HibernateReadWriteAccessStrategy.java | 81 +-
modules/indexing/pom.xml | 6 -
modules/jta/pom.xml | 6 -
modules/scalar/pom.xml | 12 +-
.../ignite/schema/generator/PojoGenerator.java | 3 +-
.../schema/generator/SnippetGenerator.java | 138 ++
.../ignite/schema/generator/XmlGenerator.java | 8 +-
.../apache/ignite/schema/model/PojoField.java | 11 +-
.../apache/ignite/schema/ui/SchemaLoadApp.java | 2 +
.../apache/ignite/schema/load/model/Ignite.xml | 133 +-
modules/spring/pom.xml | 6 -
modules/visor-console/pom.xml | 7 -
.../commands/alert/VisorAlertCommand.scala | 8 +-
.../commands/cache/VisorCacheCommand.scala | 116 +-
.../commands/cache/VisorCacheScanCommand.scala | 7 +-
.../config/VisorConfigurationCommand.scala | 141 +-
.../commands/disco/VisorDiscoveryCommand.scala | 2 +-
.../visor/commands/node/VisorNodeCommand.scala | 6 +-
.../scala/org/apache/ignite/visor/visor.scala | 89 +-
.../commands/tasks/VisorTasksCommandSpec.scala | 2 +-
modules/web/pom.xml | 6 -
modules/winservice/IgniteService.sln | 2 +-
.../IgniteService/IgniteService.csproj | 2 +-
.../config/benchmark-atomic-win.properties | 15 +
.../config/benchmark-atomic.properties | 15 +
.../config/benchmark-compute-win.properties | 15 +
.../config/benchmark-compute.properties | 15 +
.../config/benchmark-multicast.properties | 15 +
.../config/benchmark-query-win.properties | 15 +
.../yardstick/config/benchmark-query.properties | 15 +
.../config/benchmark-tx-win.properties | 15 +
.../yardstick/config/benchmark-tx.properties | 15 +
.../yardstick/config/benchmark-win.properties | 15 +
modules/yardstick/config/benchmark.properties | 15 +
.../yardstick/config/ignite-store-config.xml | 15 +-
pom.xml | 152 +-
159 files changed, 3884 insertions(+), 5012 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/5b0d7db7/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/cache/VisorCacheCommand.scala
----------------------------------------------------------------------
[03/11] incubator-ignite git commit: # sprint-2 - removing
gridgain.com.
Posted by sb...@apache.org.
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/c4030f92/modules/hibernate/src/main/java/org/apache/ignite/cache/store/hibernate/CacheHibernateBlobStore.java
----------------------------------------------------------------------
diff --git a/modules/hibernate/src/main/java/org/apache/ignite/cache/store/hibernate/CacheHibernateBlobStore.java b/modules/hibernate/src/main/java/org/apache/ignite/cache/store/hibernate/CacheHibernateBlobStore.java
index b6a4155..9b9f2aa 100644
--- a/modules/hibernate/src/main/java/org/apache/ignite/cache/store/hibernate/CacheHibernateBlobStore.java
+++ b/modules/hibernate/src/main/java/org/apache/ignite/cache/store/hibernate/CacheHibernateBlobStore.java
@@ -140,7 +140,7 @@ import java.util.concurrent.atomic.*;
* ...
* </pre>
* <p>
- * <img src="http://www.gridgain.com/images/spring-small.png">
+ * <img src="http://ignite.incubator.apache.org/images/spring-small.png">
* <br>
* For information about Spring framework visit <a href="http://www.springframework.org/">www.springframework.org</a>
*/
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/c4030f92/modules/rest-http/src/main/java/org/apache/ignite/internal/processors/rest/protocols/http/jetty/rest.html
----------------------------------------------------------------------
diff --git a/modules/rest-http/src/main/java/org/apache/ignite/internal/processors/rest/protocols/http/jetty/rest.html b/modules/rest-http/src/main/java/org/apache/ignite/internal/processors/rest/protocols/http/jetty/rest.html
index 717c5df..b8ad9e0 100644
--- a/modules/rest-http/src/main/java/org/apache/ignite/internal/processors/rest/protocols/http/jetty/rest.html
+++ b/modules/rest-http/src/main/java/org/apache/ignite/internal/processors/rest/protocols/http/jetty/rest.html
@@ -56,7 +56,7 @@
<br>
<center>
<a class="img_link" href="https://incubator.apache.org/projects/ignite.html" title="Apache Software Foundation">
- <img src="http://gridgain.com/wp-content/uploads/2014/09/gridgain-red-logo-standard.png" alt="Ignite - In-Memory Data Fabric">
+ <img src="http://ignite.incubator.apache.org/images/logo3.png" alt="Ignite - In-Memory Data Fabric">
</a>
<p>
<div style="width: 650px; text-align: justify; padding-top: 20px">
@@ -74,23 +74,6 @@
different parameters, some of which may be mandatory and some optional. The commands parameters may be
passed either via HTTP GET or POST, whichever one is preferred.
</div>
- <br>
- <br>
- <a target=facebook class='img_link' href='http://www.facebook.com/profile.php?id=6458239494'>
- <img border=0 align=absmiddle src='http://www.gridgain.com/images/facebook_small.png'>
- </a>
-
- <a class='img_link' target=meetup href='http://www.meetup.com/GridGain-Bay-Area-Meetup-Group/'>
- <img border=0 align=absmiddle src='http://www.gridgain.com/images/meetup_logo_small.png' alt='Join Ignite Meetup'/>
- </a>
-
- <a class='img_link' target=twitter href='http://www.twitter.com/gridgain'>
- <img border=0 align=absmiddle src='http://www.gridgain.com/images/twitter.gif' alt='Follow Ignite on Twitter'/>
- </a>
-
- <a class='img_link' target=vimeo href='http://www.vimeo.com/gridgain'>
- <img border=0 align=absmiddle src='http://www.gridgain.com/images/vimeo.png' alt='Follow Ignite on Vimeo'/>
- </a>
</center>
</body>
</html>
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/c4030f92/modules/urideploy/src/main/java/org/apache/ignite/spi/deployment/uri/UriDeploymentSpi.java
----------------------------------------------------------------------
diff --git a/modules/urideploy/src/main/java/org/apache/ignite/spi/deployment/uri/UriDeploymentSpi.java b/modules/urideploy/src/main/java/org/apache/ignite/spi/deployment/uri/UriDeploymentSpi.java
index 32b3282..da9b42e 100644
--- a/modules/urideploy/src/main/java/org/apache/ignite/spi/deployment/uri/UriDeploymentSpi.java
+++ b/modules/urideploy/src/main/java/org/apache/ignite/spi/deployment/uri/UriDeploymentSpi.java
@@ -301,7 +301,7 @@ import java.util.Map.*;
* </bean>
* </pre>
* <p>
- * <img src="http://www.gridgain.com/images/spring-small.png">
+ * <img src="http://ignite.incubator.apache.org/images/spring-small.png">
* <br>
* For information about Spring framework visit <a href="http://www.springframework.org/">www.springframework.org</a>
* @see org.apache.ignite.spi.deployment.DeploymentSpi
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/c4030f92/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/VisorConsole.scala
----------------------------------------------------------------------
diff --git a/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/VisorConsole.scala b/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/VisorConsole.scala
index 62f590e..164b307 100644
--- a/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/VisorConsole.scala
+++ b/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/VisorConsole.scala
@@ -17,16 +17,16 @@
package org.apache.ignite.visor.commands
-import org.apache.ignite.internal.IgniteVersionUtils._
-import org.apache.ignite.internal.util.scala.impl
-import org.apache.ignite.internal.util.{IgniteUtils => U}
-import org.apache.ignite.startup.cmdline.AboutDialog
-
-import javax.swing.ImageIcon
import java.awt.Image
import java.io.File
import java.text.SimpleDateFormat
import java.util
+import javax.swing.ImageIcon
+
+import org.apache.ignite.internal.IgniteVersionUtils._
+import org.apache.ignite.internal.util.scala.impl
+import org.apache.ignite.internal.util.{IgniteUtils => U}
+import org.apache.ignite.startup.cmdline.AboutDialog
// Built-in commands.
// Note the importing of implicit conversions.
@@ -194,11 +194,11 @@ object VisorConsole extends App {
val osxApp = appCls.getDeclaredMethod("getApplication").invoke(null)
- val dockIco = new ImageIcon(urlIcon("ggcube_node_128x128.png"))
+ val dockIco = new ImageIcon(urlIcon("logo_ignite_128x128.png"))
appCls.getDeclaredMethod("setDockIconImage", classOf[Image]).invoke(osxApp, dockIco.getImage)
- val bannerIconUrl = urlIcon("ggcube_node_48x48.png")
+ val bannerIconUrl = urlIcon("logo_ignite_48x48.png")
val aboutHndProxy = java.lang.reflect.Proxy.newProxyInstance(
appCls.getClassLoader,
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/c4030f92/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/ggcube_128x128.png
----------------------------------------------------------------------
diff --git a/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/ggcube_128x128.png b/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/ggcube_128x128.png
deleted file mode 100644
index ba8f954..0000000
Binary files a/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/ggcube_128x128.png and /dev/null differ
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/c4030f92/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/ggcube_48x48.png
----------------------------------------------------------------------
diff --git a/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/ggcube_48x48.png b/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/ggcube_48x48.png
deleted file mode 100644
index ab3ede2..0000000
Binary files a/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/ggcube_48x48.png and /dev/null differ
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/c4030f92/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/logo_ignite_128x128.png
----------------------------------------------------------------------
diff --git a/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/logo_ignite_128x128.png b/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/logo_ignite_128x128.png
new file mode 100644
index 0000000..046e381
Binary files /dev/null and b/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/logo_ignite_128x128.png differ
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/c4030f92/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/logo_ignite_48x48.png
----------------------------------------------------------------------
diff --git a/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/logo_ignite_48x48.png b/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/logo_ignite_48x48.png
new file mode 100644
index 0000000..d4836ef
Binary files /dev/null and b/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/logo_ignite_48x48.png differ
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/c4030f92/pom.xml
----------------------------------------------------------------------
diff --git a/pom.xml b/pom.xml
index b0ebc44..b176b10 100644
--- a/pom.xml
+++ b/pom.xml
@@ -535,7 +535,6 @@
<exclude>src/main/java/org/pcollections/**</exclude><!--own license-->
<exclude>src/main/java/org/jdk8/backport/*.java</exclude><!--own license-->
<exclude>src/test/java/org/apache/ignite/p2p/p2p.properties</exclude><!--test depends on file content-->
- <exclude>src/test/resources/log/ignite.log.tst</exclude><!--test resource-->
<exclude>src/test/config/start-nodes.ini</exclude><!---->
<exclude>src/test/java/org/apache/ignite/spi/deployment/uri/META-INF/ignite.incorrefs</exclude><!--test resource-->
<exclude>src/test/java/org/apache/ignite/spi/deployment/uri/META-INF/ignite.empty</exclude><!--should be empty-->
[08/11] incubator-ignite git commit: Merge branches 'ignite-344' and
'sprint-2' of https://git-wip-us.apache.org/repos/asf/incubator-ignite into
sprint-2
Posted by sb...@apache.org.
Merge branches 'ignite-344' and 'sprint-2' of https://git-wip-us.apache.org/repos/asf/incubator-ignite into sprint-2
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/4dd565e2
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/4dd565e2
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/4dd565e2
Branch: refs/heads/ignite-349
Commit: 4dd565e22911b218234d0bd703495d845b11674c
Parents: 656ee47 5b0d7db
Author: AKuznetsov <ak...@gridgain.com>
Authored: Wed Mar 4 16:34:37 2015 +0700
Committer: AKuznetsov <ak...@gridgain.com>
Committed: Wed Mar 4 16:34:37 2015 +0700
----------------------------------------------------------------------
.../visor/cache/VisorCacheClearTask.java | 3 +-
.../visor/cache/VisorCacheLoadTask.java | 3 +-
.../scala/org/apache/ignite/visor/Packet.scala | 38 ------
.../ignite/visor/commands/VisorConsole.scala | 2 -
.../ignite/visor/commands/ack/Packet.scala | 55 --------
.../visor/commands/ack/VisorAckCommand.scala | 2 +-
.../ignite/visor/commands/alert/Packet.scala | 108 ----------------
.../ignite/visor/commands/cache/Packet.scala | 127 -------------------
.../commands/cache/VisorCacheCommand.scala | 2 +-
.../ignite/visor/commands/config/Packet.scala | 55 --------
.../ignite/visor/commands/deploy/Packet.scala | 76 -----------
.../ignite/visor/commands/disco/Packet.scala | 72 -----------
.../ignite/visor/commands/events/Packet.scala | 97 --------------
.../ignite/visor/commands/gc/Packet.scala | 61 ---------
.../ignite/visor/commands/kill/Packet.scala | 78 ------------
.../visor/commands/kill/VisorKillCommand.scala | 2 +-
.../ignite/visor/commands/node/Packet.scala | 60 ---------
.../ignite/visor/commands/ping/Packet.scala | 50 --------
.../visor/commands/ping/VisorPingCommand.scala | 2 +-
.../ignite/visor/commands/start/Packet.scala | 90 -------------
.../ignite/visor/commands/tasks/Packet.scala | 116 -----------------
.../commands/tasks/VisorTasksCommand.scala | 26 +---
.../ignite/visor/commands/top/Packet.scala | 87 -------------
.../ignite/visor/commands/vvm/Packet.scala | 61 ---------
24 files changed, 15 insertions(+), 1258 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/4dd565e2/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/VisorConsole.scala
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/4dd565e2/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/cache/VisorCacheCommand.scala
----------------------------------------------------------------------
[11/11] incubator-ignite git commit: Merge branch 'sprint-2' of
https://git-wip-us.apache.org/repos/asf/incubator-ignite into ignite-349
Posted by sb...@apache.org.
Merge branch 'sprint-2' of https://git-wip-us.apache.org/repos/asf/incubator-ignite into ignite-349
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/887b88e1
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/887b88e1
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/887b88e1
Branch: refs/heads/ignite-349
Commit: 887b88e14baf85d09aa2f977db05fc1b718c9f69
Parents: 66b00a1 5d2a7c6
Author: iveselovskiy <iv...@gridgain.com>
Authored: Wed Mar 4 16:32:56 2015 +0300
Committer: iveselovskiy <iv...@gridgain.com>
Committed: Wed Mar 4 16:32:56 2015 +0300
----------------------------------------------------------------------
.../spi/checkpoint/s3/S3CheckpointSpi.java | 2 +-
modules/clients/readme.md | 4 +-
modules/clients/readme.pdf | Bin 52230 -> 47887 bytes
.../integration/ClientAbstractSelfTest.java | 3 -
.../apache/ignite/cache/store/CacheStore.java | 49 -
.../cache/store/jdbc/CacheJdbcBlobStore.java | 2 +-
.../apache/ignite/internal/GridDiagnostic.java | 15 +-
.../ignite/internal/GridUpdateNotifier.java | 8 +-
.../apache/ignite/internal/IgniteKernal.java | 23 +-
.../visor/cache/VisorCacheClearTask.java | 3 +-
.../visor/cache/VisorCacheLoadTask.java | 3 +-
.../apache/ignite/marshaller/Marshaller.java | 2 +-
.../ignite/marshaller/jdk/JdkMarshaller.java | 2 +-
.../optimized/OptimizedMarshaller.java | 2 +-
.../SpringApplicationContextResource.java | 2 +-
.../checkpoint/cache/CacheCheckpointSpi.java | 2 +-
.../spi/checkpoint/jdbc/JdbcCheckpointSpi.java | 2 +-
.../sharedfs/SharedFsCheckpointSpi.java | 2 +-
.../jobstealing/JobStealingCollisionSpi.java | 4 +-
.../PriorityQueueCollisionSpi.java | 2 +-
.../communication/tcp/TcpCommunicationSpi.java | 16 +-
.../spi/discovery/tcp/TcpDiscoverySpi.java | 2 +-
.../memory/MemoryEventStorageSpi.java | 2 +-
.../spi/failover/always/AlwaysFailoverSpi.java | 2 +-
.../jobstealing/JobStealingFailoverSpi.java | 2 +-
.../spi/failover/never/NeverFailoverSpi.java | 2 +-
.../apache/ignite/spi/indexing/IndexingSpi.java | 2 +-
.../adaptive/AdaptiveLoadBalancingSpi.java | 2 +-
.../roundrobin/RoundRobinLoadBalancingSpi.java | 2 +-
.../WeightedRandomLoadBalancingSpi.java | 2 +-
.../spi/swapspace/file/FileSwapSpaceSpi.java | 2 +-
.../startup/cmdline/CommandLineStartup.java | 4 +-
.../startup/cmdline/ggcube_node_128x128.png | Bin 4679 -> 0 bytes
.../startup/cmdline/ggcube_node_48x48.png | Bin 2355 -> 0 bytes
.../startup/cmdline/logo_ignite_128x128.png | Bin 0 -> 18667 bytes
.../startup/cmdline/logo_ignite_48x48.png | Bin 0 -> 16572 bytes
.../internal/GridUpdateNotifierSelfTest.java | 2 +-
.../core/src/test/resources/log/ignite.log.tst | 13706 -----------------
.../hibernate/CacheHibernateBlobStore.java | 2 +-
.../rest/protocols/http/jetty/rest.html | 19 +-
.../spi/deployment/uri/UriDeploymentSpi.java | 2 +-
.../scala/org/apache/ignite/visor/Packet.scala | 38 -
.../ignite/visor/commands/VisorConsole.scala | 18 +-
.../ignite/visor/commands/ack/Packet.scala | 55 -
.../visor/commands/ack/VisorAckCommand.scala | 2 +-
.../ignite/visor/commands/alert/Packet.scala | 108 -
.../ignite/visor/commands/cache/Packet.scala | 127 -
.../commands/cache/VisorCacheCommand.scala | 12 +-
.../ignite/visor/commands/config/Packet.scala | 55 -
.../ignite/visor/commands/deploy/Packet.scala | 76 -
.../ignite/visor/commands/disco/Packet.scala | 72 -
.../ignite/visor/commands/events/Packet.scala | 97 -
.../ignite/visor/commands/gc/Packet.scala | 61 -
.../ignite/visor/commands/ggcube_128x128.png | Bin 11444 -> 0 bytes
.../ignite/visor/commands/ggcube_48x48.png | Bin 3365 -> 0 bytes
.../ignite/visor/commands/kill/Packet.scala | 78 -
.../visor/commands/kill/VisorKillCommand.scala | 2 +-
.../visor/commands/logo_ignite_128x128.png | Bin 0 -> 18667 bytes
.../ignite/visor/commands/logo_ignite_48x48.png | Bin 0 -> 16572 bytes
.../ignite/visor/commands/node/Packet.scala | 60 -
.../ignite/visor/commands/ping/Packet.scala | 50 -
.../visor/commands/ping/VisorPingCommand.scala | 2 +-
.../ignite/visor/commands/start/Packet.scala | 90 -
.../ignite/visor/commands/tasks/Packet.scala | 116 -
.../commands/tasks/VisorTasksCommand.scala | 26 +-
.../ignite/visor/commands/top/Packet.scala | 87 -
.../ignite/visor/commands/vvm/Packet.scala | 61 -
pom.xml | 50 +-
68 files changed, 83 insertions(+), 15163 deletions(-)
----------------------------------------------------------------------
[05/11] incubator-ignite git commit: # sprint-2 - removing
gridgain.com.
Posted by sb...@apache.org.
# sprint-2 - removing gridgain.com.
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/c4030f92
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/c4030f92
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/c4030f92
Branch: refs/heads/ignite-349
Commit: c4030f926a7339cfcae14e19cec22d9d37cd94dd
Parents: 6909cc4
Author: Dmitiry Setrakyan <ds...@gridgain.com>
Authored: Tue Mar 3 18:58:18 2015 -0800
Committer: Dmitiry Setrakyan <ds...@gridgain.com>
Committed: Tue Mar 3 18:58:18 2015 -0800
----------------------------------------------------------------------
.../spi/checkpoint/s3/S3CheckpointSpi.java | 2 +-
modules/clients/readme.md | 4 +-
modules/clients/readme.pdf | Bin 52230 -> 47887 bytes
.../integration/ClientAbstractSelfTest.java | 3 -
.../apache/ignite/cache/store/CacheStore.java | 49 -
.../cache/store/jdbc/CacheJdbcBlobStore.java | 2 +-
.../apache/ignite/internal/GridDiagnostic.java | 15 +-
.../ignite/internal/GridUpdateNotifier.java | 8 +-
.../apache/ignite/internal/IgniteKernal.java | 23 +-
.../apache/ignite/marshaller/Marshaller.java | 2 +-
.../ignite/marshaller/jdk/JdkMarshaller.java | 2 +-
.../optimized/OptimizedMarshaller.java | 2 +-
.../SpringApplicationContextResource.java | 2 +-
.../checkpoint/cache/CacheCheckpointSpi.java | 2 +-
.../spi/checkpoint/jdbc/JdbcCheckpointSpi.java | 2 +-
.../sharedfs/SharedFsCheckpointSpi.java | 2 +-
.../jobstealing/JobStealingCollisionSpi.java | 4 +-
.../PriorityQueueCollisionSpi.java | 2 +-
.../communication/tcp/TcpCommunicationSpi.java | 16 +-
.../spi/discovery/tcp/TcpDiscoverySpi.java | 2 +-
.../memory/MemoryEventStorageSpi.java | 2 +-
.../spi/failover/always/AlwaysFailoverSpi.java | 2 +-
.../jobstealing/JobStealingFailoverSpi.java | 2 +-
.../spi/failover/never/NeverFailoverSpi.java | 2 +-
.../apache/ignite/spi/indexing/IndexingSpi.java | 2 +-
.../adaptive/AdaptiveLoadBalancingSpi.java | 2 +-
.../roundrobin/RoundRobinLoadBalancingSpi.java | 2 +-
.../WeightedRandomLoadBalancingSpi.java | 2 +-
.../spi/swapspace/file/FileSwapSpaceSpi.java | 2 +-
.../startup/cmdline/CommandLineStartup.java | 4 +-
.../startup/cmdline/ggcube_node_128x128.png | Bin 4679 -> 0 bytes
.../startup/cmdline/ggcube_node_48x48.png | Bin 2355 -> 0 bytes
.../startup/cmdline/logo_ignite_128x128.png | Bin 0 -> 18667 bytes
.../startup/cmdline/logo_ignite_48x48.png | Bin 0 -> 16572 bytes
.../internal/GridUpdateNotifierSelfTest.java | 2 +-
.../core/src/test/resources/log/ignite.log.tst | 13706 -----------------
.../hibernate/CacheHibernateBlobStore.java | 2 +-
.../rest/protocols/http/jetty/rest.html | 19 +-
.../spi/deployment/uri/UriDeploymentSpi.java | 2 +-
.../ignite/visor/commands/VisorConsole.scala | 16 +-
.../ignite/visor/commands/ggcube_128x128.png | Bin 11444 -> 0 bytes
.../ignite/visor/commands/ggcube_48x48.png | Bin 3365 -> 0 bytes
.../visor/commands/logo_ignite_128x128.png | Bin 0 -> 18667 bytes
.../ignite/visor/commands/logo_ignite_48x48.png | Bin 0 -> 16572 bytes
pom.xml | 1 -
45 files changed, 57 insertions(+), 13857 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/c4030f92/modules/aws/src/main/java/org/apache/ignite/spi/checkpoint/s3/S3CheckpointSpi.java
----------------------------------------------------------------------
diff --git a/modules/aws/src/main/java/org/apache/ignite/spi/checkpoint/s3/S3CheckpointSpi.java b/modules/aws/src/main/java/org/apache/ignite/spi/checkpoint/s3/S3CheckpointSpi.java
index 9cfbca3..b5198f6 100644
--- a/modules/aws/src/main/java/org/apache/ignite/spi/checkpoint/s3/S3CheckpointSpi.java
+++ b/modules/aws/src/main/java/org/apache/ignite/spi/checkpoint/s3/S3CheckpointSpi.java
@@ -94,7 +94,7 @@ import java.util.*;
* Choose another implementation of {@link org.apache.ignite.spi.checkpoint.CheckpointSpi} for local or
* home network tests.
* <p>
- * <img src="http://www.gridgain.com/images/spring-small.png">
+ * <img src="http://ignite.incubator.apache.org/images/spring-small.png">
* <br>
* For information about Spring framework visit <a href="http://www.springframework.org/">www.springframework.org</a>
* @see org.apache.ignite.spi.checkpoint.CheckpointSpi
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/c4030f92/modules/clients/readme.md
----------------------------------------------------------------------
diff --git a/modules/clients/readme.md b/modules/clients/readme.md
index e64c123..0208c51 100644
--- a/modules/clients/readme.md
+++ b/modules/clients/readme.md
@@ -1,5 +1,5 @@
<center>
-
+
</center>
## Java Client README
@@ -13,5 +13,5 @@ could not (*or should not*) be started.
## Client vs Grid Node
Note that for performance and ease-of-use reasons, you should always prefer to start grid node in your cluster instead of remote client. Grid node will generally perform a lot faster and can easily exhibit client-only functionality by excluding it from task/job execution and from caching data.
-For example, you can prevent a grid node from participating in caching by setting `GridCacheConfiguration.setDistributionMode(...)` value to either `CLIENT_ONLY` or `NEAR_ONLY`.
+For example, you can prevent a grid node from participating in caching by setting `CacheConfiguration.setDistributionMode(...)` value to either `CLIENT_ONLY` or `NEAR_ONLY`.
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/c4030f92/modules/clients/readme.pdf
----------------------------------------------------------------------
diff --git a/modules/clients/readme.pdf b/modules/clients/readme.pdf
index 4334aaa..5ecb8d8 100644
Binary files a/modules/clients/readme.pdf and b/modules/clients/readme.pdf differ
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/c4030f92/modules/clients/src/test/java/org/apache/ignite/internal/client/integration/ClientAbstractSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/clients/src/test/java/org/apache/ignite/internal/client/integration/ClientAbstractSelfTest.java b/modules/clients/src/test/java/org/apache/ignite/internal/client/integration/ClientAbstractSelfTest.java
index 8011945..0173da6 100644
--- a/modules/clients/src/test/java/org/apache/ignite/internal/client/integration/ClientAbstractSelfTest.java
+++ b/modules/clients/src/test/java/org/apache/ignite/internal/client/integration/ClientAbstractSelfTest.java
@@ -74,9 +74,6 @@ public abstract class ClientAbstractSelfTest extends GridCommonAbstractTest {
/** */
private static final Map<String, HashMapStore> cacheStores = new HashMap<>();
- /** Path to test log. */
- private static final String TEST_LOG_PATH = "modules/core/src/test/resources/log/ignite.log.tst";
-
/** */
public static final String ROUTER_LOG_CFG = "modules/core/src/test/config/log4j-test.xml";
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/c4030f92/modules/core/src/main/java/org/apache/ignite/cache/store/CacheStore.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/cache/store/CacheStore.java b/modules/core/src/main/java/org/apache/ignite/cache/store/CacheStore.java
index eefcfb3..c0c95c7 100644
--- a/modules/core/src/main/java/org/apache/ignite/cache/store/CacheStore.java
+++ b/modules/core/src/main/java/org/apache/ignite/cache/store/CacheStore.java
@@ -23,9 +23,7 @@ import org.apache.ignite.transactions.*;
import org.jetbrains.annotations.*;
import javax.cache.integration.*;
-import java.sql.*;
import java.util.*;
-import java.util.Date;
import static javax.cache.Cache.*;
@@ -65,53 +63,6 @@ import static javax.cache.Cache.*;
* tx.addMeta("some.name", conn);
* }
* </pre>
- * <h1 class="header">Working With Portable Objects</h1>
- * When portables are enabled for cache by setting {@code org.apache.ignite.configuration.CacheConfiguration#isPortableEnabled()} to
- * {@code true}), all portable keys and values are converted to instances of {@code PortableObject}.
- * Therefore, all cache store methods will take parameters in portable format. To avoid class
- * cast exceptions, store must have signature compatible with portables. E.g., if you use {@link Integer}
- * as a key and {@code Value} class as a value (which will be converted to portable format), cache store
- * signature should be the following:
- * <pre name="code" class="java">
- * public class PortableCacheStore implements GridCacheStore<Integer, GridPortableObject> {
- * public void put(@Nullable GridCacheTx tx, Integer key, GridPortableObject val) throws IgniteCheckedException {
- * ...
- * }
- *
- * ...
- * }
- * </pre>
- * This behavior can be overridden by setting {@code org.apache.ignite.configuration.CacheConfiguration#setKeepPortableInStore(boolean)}
- * flag value to {@code false}. In this case, Ignite will deserialize keys and values stored in portable
- * format before they are passed to cache store, so that you can use the following cache store signature instead:
- * <pre name="code" class="java">
- * public class ObjectsCacheStore implements GridCacheStore<Integer, Person> {
- * public void put(@Nullable GridCacheTx tx, Integer key, Person val) throws GridException {
- * ...
- * }
- *
- * ...
- * }
- * </pre>
- * Note that while this can simplify store implementation in some cases, it will cause performance degradation
- * due to additional serializations and deserializations of portable objects. You will also need to have key
- * and value classes on all nodes since portables will be deserialized when store is invoked.
- * <p>
- * Note that only portable classes are converted to {@code PortableObject} format. Following
- * types are stored in cache without changes and therefore should not affect cache store signature:
- * <ul>
- * <li>All primitives (byte, int, ...) and there boxed versions (Byte, Integer, ...)</li>
- * <li>Arrays of primitives (byte[], int[], ...)</li>
- * <li>{@link String} and array of {@link String}s</li>
- * <li>{@link UUID} and array of {@link UUID}s</li>
- * <li>{@link Date} and array of {@link Date}s</li>
- * <li>{@link Timestamp} and array of {@link Timestamp}s</li>
- * <li>Enums and array of enums</li>
- * <li>
- * Maps, collections and array of objects (but objects inside
- * them will still be converted if they are portable)
- * </li>
- * </ul>
*
* @see CacheStoreSession
*/
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/c4030f92/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/CacheJdbcBlobStore.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/CacheJdbcBlobStore.java b/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/CacheJdbcBlobStore.java
index 90d62b7..08ad789 100644
--- a/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/CacheJdbcBlobStore.java
+++ b/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/CacheJdbcBlobStore.java
@@ -81,7 +81,7 @@ import java.util.concurrent.atomic.*;
* ...
* </pre>
* <p>
- * <img src="http://www.gridgain.com/images/spring-small.png">
+ * <img src="http://ignite.incubator.apache.org/images/spring-small.png">
* <br>
* For information about Spring framework visit <a href="http://www.springframework.org/">www.springframework.org</a>
*/
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/c4030f92/modules/core/src/main/java/org/apache/ignite/internal/GridDiagnostic.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/GridDiagnostic.java b/modules/core/src/main/java/org/apache/ignite/internal/GridDiagnostic.java
index 2ed3e14..f8b8d64 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/GridDiagnostic.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/GridDiagnostic.java
@@ -92,26 +92,13 @@ final class GridDiagnostic {
}
});
- exec.execute(new GridWorker(gridName, "grid-diagnostic-3", log) {
- @Override public void body() {
- String jdkStrLow = U.jdkString().toLowerCase();
-
- if (jdkStrLow.contains("jrockit") && jdkStrLow.contains("1.5.")) {
- U.warn(log, "BEA JRockit VM ver. 1.5.x has shown problems with NIO functionality in our " +
- "tests that were not reproducible in other VMs. We recommend using Sun VM. Should you " +
- "have further questions please contact us at support@gridgain.com",
- "BEA JRockit VM ver. 1.5.x is not supported.");
- }
- }
- });
-
exec.execute(new GridWorker(gridName, "grid-diagnostic-4", log) {
@Override public void body() {
// Sufficiently tested OS.
if (!U.isSufficientlyTestedOs()) {
U.warn(log, "This operating system has been tested less rigorously: " + U.osString() +
". Our team will appreciate the feedback if you experience any problems running " +
- "ignite in this environment. You can always send your feedback to support@gridgain.com",
+ "ignite in this environment.",
"This OS is tested less rigorously: " + U.osString());
}
}
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/c4030f92/modules/core/src/main/java/org/apache/ignite/internal/GridUpdateNotifier.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/GridUpdateNotifier.java b/modules/core/src/main/java/org/apache/ignite/internal/GridUpdateNotifier.java
index 830481f..3d491ec 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/GridUpdateNotifier.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/GridUpdateNotifier.java
@@ -33,9 +33,7 @@ import java.util.concurrent.*;
import static java.net.URLEncoder.*;
/**
- * This class is responsible for notification about new version availability. Note that this class
- * does not send any information and merely accesses the {@code www.gridgain.com} web site for the
- * latest version data.
+ * This class is responsible for notification about new version availability.
* <p>
* Note also that this connectivity is not necessary to successfully start the system as it will
* gracefully ignore any errors occurred during notification and verification process.
@@ -90,7 +88,7 @@ class GridUpdateNotifier {
* @param gw Kernal gateway.
* @throws IgniteCheckedException If failed.
*/
- GridUpdateNotifier(String gridName, String ver, String site, GridKernalGateway gw, boolean reportOnlyNew)
+ GridUpdateNotifier(String gridName, String ver, GridKernalGateway gw, boolean reportOnlyNew)
throws IgniteCheckedException {
try {
DocumentBuilderFactory factory = DocumentBuilderFactory.newInstance();
@@ -108,7 +106,7 @@ class GridUpdateNotifier {
this.ver = ver;
- url = "http://" + site + "/update_status.php";
+ url = "http://tiny.cc/updater/update_status.php";
this.gridName = gridName == null ? "null" : gridName;
this.reportOnlyNew = reportOnlyNew;
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/c4030f92/modules/core/src/main/java/org/apache/ignite/internal/IgniteKernal.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/IgniteKernal.java b/modules/core/src/main/java/org/apache/ignite/internal/IgniteKernal.java
index f46d071..cc4efa6 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/IgniteKernal.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/IgniteKernal.java
@@ -104,7 +104,7 @@ public class IgniteKernal implements IgniteEx, IgniteMXBean, Externalizable {
private static final String COMPATIBLE_VERS = IgniteProperties.get("ignite.compatible.vers");
/** Ignite site that is shown in log messages. */
- static final String SITE = "www.gridgain.com";
+ static final String SITE = "ignite.incubator.apache.org";
/** System line separator. */
private static final String NL = U.nl();
@@ -271,7 +271,7 @@ public class IgniteKernal implements IgniteEx, IgniteMXBean, Externalizable {
/** {@inheritDoc} */
@Override public final IgniteEvents events(ClusterGroup grp) {
- return ((ClusterGroupAdapter)grp).events();
+ return ((ClusterGroupAdapter) grp).events();
}
/** {@inheritDoc} */
@@ -452,8 +452,9 @@ public class IgniteKernal implements IgniteEx, IgniteMXBean, Externalizable {
@Override public Collection<String> getUserAttributesFormatted() {
assert cfg != null;
- return F.transform(cfg.getUserAttributes().entrySet(), new C1<Map.Entry<String,?>,String>() {
- @Override public String apply(Map.Entry<String,?> e) {
+ return F.transform(cfg.getUserAttributes().entrySet(), new C1<Map.Entry<String, ?>, String>() {
+ @Override
+ public String apply(Map.Entry<String, ?> e) {
return e.getKey() + ", " + e.getValue().toString();
}
});
@@ -628,7 +629,7 @@ public class IgniteKernal implements IgniteEx, IgniteMXBean, Externalizable {
if (notifyEnabled) {
try {
- verChecker = new GridUpdateNotifier(gridName, VER_STR, SITE, gw, false);
+ verChecker = new GridUpdateNotifier(gridName, VER_STR, gw, false);
verChecker.checkForNewVersion(execSvc, log);
}
@@ -997,8 +998,6 @@ public class IgniteKernal implements IgniteEx, IgniteMXBean, Externalizable {
ctx.performance().logSuggestions(log, gridName);
- ackBenchmarks();
-
U.quietAndInfo(log, "To start Console Management & Monitoring run ignitevisorcmd.{sh|bat}");
ackStart(rtBean);
@@ -1511,14 +1510,6 @@ public class IgniteKernal implements IgniteEx, IgniteMXBean, Externalizable {
}
/**
- * Acks benchmarking instructions.
- */
- private void ackBenchmarks() {
- if (!isDaemon())
- U.quietAndInfo(log, "If running benchmarks, see http://bit.ly/GridGain-Benchmarking");
- }
-
- /**
* Acks ASCII-logo. Thanks to http://patorjk.com/software/taag
*/
private void ackAsciiLogo() {
@@ -1608,7 +1599,7 @@ public class IgniteKernal implements IgniteEx, IgniteMXBean, Externalizable {
">>> Local node addresses: " + U.addressesAsString(locNode) + NL +
">>> Local ports: " + sb + NL;
- str += ">>> Ignite documentation: http://" + SITE + "/documentation" + NL;
+ str += ">>> Ignite documentation: http://" + SITE + NL;
log.info(str);
}
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/c4030f92/modules/core/src/main/java/org/apache/ignite/marshaller/Marshaller.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/marshaller/Marshaller.java b/modules/core/src/main/java/org/apache/ignite/marshaller/Marshaller.java
index e2956dd..1e6dc47 100644
--- a/modules/core/src/main/java/org/apache/ignite/marshaller/Marshaller.java
+++ b/modules/core/src/main/java/org/apache/ignite/marshaller/Marshaller.java
@@ -60,7 +60,7 @@ import java.io.*;
* </bean>
* </pre>
* <p>
- * <img src="http://www.gridgain.com/images/spring-small.png">
+ * <img src="http://ignite.incubator.apache.org/images/spring-small.png">
* <br>
* For information about Spring framework visit <a href="http://www.springframework.org/">www.springframework.org</a>
*/
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/c4030f92/modules/core/src/main/java/org/apache/ignite/marshaller/jdk/JdkMarshaller.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/marshaller/jdk/JdkMarshaller.java b/modules/core/src/main/java/org/apache/ignite/marshaller/jdk/JdkMarshaller.java
index f03a4f5..a76bb5f 100644
--- a/modules/core/src/main/java/org/apache/ignite/marshaller/jdk/JdkMarshaller.java
+++ b/modules/core/src/main/java/org/apache/ignite/marshaller/jdk/JdkMarshaller.java
@@ -55,7 +55,7 @@ import java.io.*;
* </bean>
* </pre>
* <p>
- * <img src="http://www.gridgain.com/images/spring-small.png">
+ * <img src="http://ignite.incubator.apache.org/images/spring-small.png">
* <br>
* For information about Spring framework visit <a href="http://www.springframework.org/">www.springframework.org</a>
*/
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/c4030f92/modules/core/src/main/java/org/apache/ignite/marshaller/optimized/OptimizedMarshaller.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/marshaller/optimized/OptimizedMarshaller.java b/modules/core/src/main/java/org/apache/ignite/marshaller/optimized/OptimizedMarshaller.java
index 57d0506..c18d545 100644
--- a/modules/core/src/main/java/org/apache/ignite/marshaller/optimized/OptimizedMarshaller.java
+++ b/modules/core/src/main/java/org/apache/ignite/marshaller/optimized/OptimizedMarshaller.java
@@ -72,7 +72,7 @@ import java.util.*;
* </bean>
* </pre>
* <p>
- * <img src="http://www.gridgain.com/images/spring-small.png">
+ * <img src="http://ignite.incubator.apache.org/images/spring-small.png">
* <br>
* For information about Spring framework visit <a href="http://www.springframework.org/">www.springframework.org</a>
*/
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/c4030f92/modules/core/src/main/java/org/apache/ignite/resources/SpringApplicationContextResource.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/resources/SpringApplicationContextResource.java b/modules/core/src/main/java/org/apache/ignite/resources/SpringApplicationContextResource.java
index 8b8f9b9..93c9a30 100644
--- a/modules/core/src/main/java/org/apache/ignite/resources/SpringApplicationContextResource.java
+++ b/modules/core/src/main/java/org/apache/ignite/resources/SpringApplicationContextResource.java
@@ -56,7 +56,7 @@ import java.lang.annotation.*;
* }
* </pre>
* <p>
- * <img src="http://www.gridgain.com/images/spring-small.png">
+ * <img src="http://ignite.incubator.apache.org/images/spring-small.png">
* <br>
* For information about Spring framework visit <a href="http://www.springframework.org/">www.springframework.org</a>
*/
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/c4030f92/modules/core/src/main/java/org/apache/ignite/spi/checkpoint/cache/CacheCheckpointSpi.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/spi/checkpoint/cache/CacheCheckpointSpi.java b/modules/core/src/main/java/org/apache/ignite/spi/checkpoint/cache/CacheCheckpointSpi.java
index 15908c6..5f76b33 100644
--- a/modules/core/src/main/java/org/apache/ignite/spi/checkpoint/cache/CacheCheckpointSpi.java
+++ b/modules/core/src/main/java/org/apache/ignite/spi/checkpoint/cache/CacheCheckpointSpi.java
@@ -88,7 +88,7 @@ import static org.apache.ignite.events.EventType.*;
* </bean>
* </pre>
* <p>
- * <img src="http://www.gridgain.com/images/spring-small.png">
+ * <img src="http://ignite.incubator.apache.org/images/spring-small.png">
* <br>
* For information about Spring framework visit <a href="http://www.springframework.org/">www.springframework.org</a>
* @see org.apache.ignite.spi.checkpoint.CheckpointSpi
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/c4030f92/modules/core/src/main/java/org/apache/ignite/spi/checkpoint/jdbc/JdbcCheckpointSpi.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/spi/checkpoint/jdbc/JdbcCheckpointSpi.java b/modules/core/src/main/java/org/apache/ignite/spi/checkpoint/jdbc/JdbcCheckpointSpi.java
index 6a77caa..158d530 100644
--- a/modules/core/src/main/java/org/apache/ignite/spi/checkpoint/jdbc/JdbcCheckpointSpi.java
+++ b/modules/core/src/main/java/org/apache/ignite/spi/checkpoint/jdbc/JdbcCheckpointSpi.java
@@ -97,7 +97,7 @@ import java.text.*;
* </bean>
* </pre>
* <p>
- * <img src="http://www.gridgain.com/images/spring-small.png">
+ * <img src="http://ignite.incubator.apache.org/images/spring-small.png">
* <br>
* For information about Spring framework visit <a href="http://www.springframework.org/">www.springframework.org</a>
*/
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/c4030f92/modules/core/src/main/java/org/apache/ignite/spi/checkpoint/sharedfs/SharedFsCheckpointSpi.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/spi/checkpoint/sharedfs/SharedFsCheckpointSpi.java b/modules/core/src/main/java/org/apache/ignite/spi/checkpoint/sharedfs/SharedFsCheckpointSpi.java
index 7ab8c1f..c244e49 100644
--- a/modules/core/src/main/java/org/apache/ignite/spi/checkpoint/sharedfs/SharedFsCheckpointSpi.java
+++ b/modules/core/src/main/java/org/apache/ignite/spi/checkpoint/sharedfs/SharedFsCheckpointSpi.java
@@ -93,7 +93,7 @@ import java.util.*;
* </bean>
* </pre>
* <p>
- * <img src="http://www.gridgain.com/images/spring-small.png">
+ * <img src="http://ignite.incubator.apache.org/images/spring-small.png">
* <br>
* For information about Spring framework visit <a href="http://www.springframework.org/">www.springframework.org</a>
* @see org.apache.ignite.spi.checkpoint.CheckpointSpi
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/c4030f92/modules/core/src/main/java/org/apache/ignite/spi/collision/jobstealing/JobStealingCollisionSpi.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/spi/collision/jobstealing/JobStealingCollisionSpi.java b/modules/core/src/main/java/org/apache/ignite/spi/collision/jobstealing/JobStealingCollisionSpi.java
index 7e31076..ddb73a6 100644
--- a/modules/core/src/main/java/org/apache/ignite/spi/collision/jobstealing/JobStealingCollisionSpi.java
+++ b/modules/core/src/main/java/org/apache/ignite/spi/collision/jobstealing/JobStealingCollisionSpi.java
@@ -58,7 +58,7 @@ import static org.apache.ignite.events.EventType.*;
* when Node<sub>3</sub> becomes free, it steals Job<sub>13</sub> and Job<sub>23</sub>
* from Node<sub>1</sub> and Node<sub>2</sub> respectively.
* <p>
- * <center><img src="http://www.gridgain.com/images/job_stealing_white.gif"></center>
+ * <center><img src="http://http://ignite.incubator.apache.org/images/job_stealing_white.gif"></center>
* <p>
* <i>
* Note that this SPI must always be used in conjunction with
@@ -156,7 +156,7 @@ import static org.apache.ignite.events.EventType.*;
* </property>
* </pre>
* <p>
- * <img src="http://www.gridgain.com/images/spring-small.png">
+ * <img src="http://ignite.incubator.apache.org/images/spring-small.png">
* <br>
* For information about Spring framework visit <a href="http://www.springframework.org/">www.springframework.org</a>
*/
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/c4030f92/modules/core/src/main/java/org/apache/ignite/spi/collision/priorityqueue/PriorityQueueCollisionSpi.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/spi/collision/priorityqueue/PriorityQueueCollisionSpi.java b/modules/core/src/main/java/org/apache/ignite/spi/collision/priorityqueue/PriorityQueueCollisionSpi.java
index e423665..4ad15fa 100644
--- a/modules/core/src/main/java/org/apache/ignite/spi/collision/priorityqueue/PriorityQueueCollisionSpi.java
+++ b/modules/core/src/main/java/org/apache/ignite/spi/collision/priorityqueue/PriorityQueueCollisionSpi.java
@@ -153,7 +153,7 @@ import java.util.*;
* }
* </pre>
* <p>
- * <img src="http://www.gridgain.com/images/spring-small.png">
+ * <img src="http://ignite.incubator.apache.org/images/spring-small.png">
* <br>
* For information about Spring framework visit <a href="http://www.springframework.org/">www.springframework.org</a>
*/
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/c4030f92/modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/TcpCommunicationSpi.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/TcpCommunicationSpi.java b/modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/TcpCommunicationSpi.java
index eacd742..19fe5c5 100644
--- a/modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/TcpCommunicationSpi.java
+++ b/modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/TcpCommunicationSpi.java
@@ -22,14 +22,8 @@ import org.apache.ignite.cluster.*;
import org.apache.ignite.configuration.*;
import org.apache.ignite.events.*;
import org.apache.ignite.internal.*;
-import org.apache.ignite.internal.util.*;
-import org.apache.ignite.lang.*;
-import org.apache.ignite.plugin.extensions.communication.*;
-import org.apache.ignite.resources.*;
-import org.apache.ignite.spi.*;
-import org.apache.ignite.spi.communication.*;
-import org.apache.ignite.thread.*;
import org.apache.ignite.internal.managers.eventstorage.*;
+import org.apache.ignite.internal.util.*;
import org.apache.ignite.internal.util.future.*;
import org.apache.ignite.internal.util.ipc.*;
import org.apache.ignite.internal.util.ipc.shmem.*;
@@ -38,6 +32,12 @@ import org.apache.ignite.internal.util.nio.*;
import org.apache.ignite.internal.util.typedef.*;
import org.apache.ignite.internal.util.typedef.internal.*;
import org.apache.ignite.internal.util.worker.*;
+import org.apache.ignite.lang.*;
+import org.apache.ignite.plugin.extensions.communication.*;
+import org.apache.ignite.resources.*;
+import org.apache.ignite.spi.*;
+import org.apache.ignite.spi.communication.*;
+import org.apache.ignite.thread.*;
import org.jdk8.backport.*;
import org.jetbrains.annotations.*;
@@ -136,7 +136,7 @@ import static org.apache.ignite.events.EventType.*;
* </bean>
* </pre>
* <p>
- * <img src="http://www.gridgain.com/images/spring-small.png">
+ * <img src="http://ignite.incubator.apache.org/images/spring-small.png">
* <br>
* For information about Spring framework visit <a href="http://www.springframework.org/">www.springframework.org</a>
* @see CommunicationSpi
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/c4030f92/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySpi.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySpi.java b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySpi.java
index df39d6b..e52fcaa 100644
--- a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySpi.java
+++ b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySpi.java
@@ -133,7 +133,7 @@ import static org.apache.ignite.spi.discovery.tcp.messages.TcpDiscoveryStatusChe
* </bean>
* </pre>
* <p>
- * <img src="http://www.gridgain.com/images/spring-small.png">
+ * <img src="http://ignite.incubator.apache.org/images/spring-small.png">
* <br>
* For information about Spring framework visit <a href="http://www.springframework.org/">www.springframework.org</a>
* @see org.apache.ignite.spi.discovery.DiscoverySpi
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/c4030f92/modules/core/src/main/java/org/apache/ignite/spi/eventstorage/memory/MemoryEventStorageSpi.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/spi/eventstorage/memory/MemoryEventStorageSpi.java b/modules/core/src/main/java/org/apache/ignite/spi/eventstorage/memory/MemoryEventStorageSpi.java
index c4ae597..da65036 100644
--- a/modules/core/src/main/java/org/apache/ignite/spi/eventstorage/memory/MemoryEventStorageSpi.java
+++ b/modules/core/src/main/java/org/apache/ignite/spi/eventstorage/memory/MemoryEventStorageSpi.java
@@ -84,7 +84,7 @@ import static org.apache.ignite.events.EventType.*;
* </bean>
* </pre>
* <p>
- * <img src="http://www.gridgain.com/images/spring-small.png">
+ * <img src="http://ignite.incubator.apache.org/images/spring-small.png">
* <br>
* For information about Spring framework visit <a href="http://www.springframework.org/">www.springframework.org</a>
* @see org.apache.ignite.spi.eventstorage.EventStorageSpi
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/c4030f92/modules/core/src/main/java/org/apache/ignite/spi/failover/always/AlwaysFailoverSpi.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/spi/failover/always/AlwaysFailoverSpi.java b/modules/core/src/main/java/org/apache/ignite/spi/failover/always/AlwaysFailoverSpi.java
index 0788b34..68f212e 100644
--- a/modules/core/src/main/java/org/apache/ignite/spi/failover/always/AlwaysFailoverSpi.java
+++ b/modules/core/src/main/java/org/apache/ignite/spi/failover/always/AlwaysFailoverSpi.java
@@ -74,7 +74,7 @@ import java.util.*;
* </property>
* </pre>
* <p>
- * <img src="http://www.gridgain.com/images/spring-small.png">
+ * <img src="http://ignite.incubator.apache.org/images/spring-small.png">
* <br>
* For information about Spring framework visit <a href="http://www.springframework.org/">www.springframework.org</a>
* @see org.apache.ignite.spi.failover.FailoverSpi
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/c4030f92/modules/core/src/main/java/org/apache/ignite/spi/failover/jobstealing/JobStealingFailoverSpi.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/spi/failover/jobstealing/JobStealingFailoverSpi.java b/modules/core/src/main/java/org/apache/ignite/spi/failover/jobstealing/JobStealingFailoverSpi.java
index f6121d8..6c7749f 100644
--- a/modules/core/src/main/java/org/apache/ignite/spi/failover/jobstealing/JobStealingFailoverSpi.java
+++ b/modules/core/src/main/java/org/apache/ignite/spi/failover/jobstealing/JobStealingFailoverSpi.java
@@ -80,7 +80,7 @@ import static org.apache.ignite.spi.collision.jobstealing.JobStealingCollisionSp
* </property>
* </pre>
* <p>
- * <img src="http://www.gridgain.com/images/spring-small.png">
+ * <img src="http://ignite.incubator.apache.org/images/spring-small.png">
* <br>
* For information about Spring framework visit <a href="http://www.springframework.org/">www.springframework.org</a>
* @see org.apache.ignite.spi.failover.FailoverSpi
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/c4030f92/modules/core/src/main/java/org/apache/ignite/spi/failover/never/NeverFailoverSpi.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/spi/failover/never/NeverFailoverSpi.java b/modules/core/src/main/java/org/apache/ignite/spi/failover/never/NeverFailoverSpi.java
index 132060b..ee31d64 100644
--- a/modules/core/src/main/java/org/apache/ignite/spi/failover/never/NeverFailoverSpi.java
+++ b/modules/core/src/main/java/org/apache/ignite/spi/failover/never/NeverFailoverSpi.java
@@ -55,7 +55,7 @@ import java.util.*;
* </property>
* </pre>
* <p>
- * <img src="http://www.gridgain.com/images/spring-small.png">
+ * <img src="http://ignite.incubator.apache.org/images/spring-small.png">
* <br>
* For information about Spring framework visit <a href="http://www.springframework.org/">www.springframework.org</a>
* @see org.apache.ignite.spi.failover.FailoverSpi
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/c4030f92/modules/core/src/main/java/org/apache/ignite/spi/indexing/IndexingSpi.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/spi/indexing/IndexingSpi.java b/modules/core/src/main/java/org/apache/ignite/spi/indexing/IndexingSpi.java
index 43ee43b..d148fbe 100644
--- a/modules/core/src/main/java/org/apache/ignite/spi/indexing/IndexingSpi.java
+++ b/modules/core/src/main/java/org/apache/ignite/spi/indexing/IndexingSpi.java
@@ -54,7 +54,7 @@ import java.util.*;
* </property>
* </pre>
* <p>
- * <img src="http://www.gridgain.com/images/spring-small.png">
+ * <img src="http://ignite.incubator.apache.org/images/spring-small.png">
* <br>
* For information about Spring framework visit <a href="http://www.springframework.org/">www.springframework.org</a>
*/
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/c4030f92/modules/core/src/main/java/org/apache/ignite/spi/loadbalancing/adaptive/AdaptiveLoadBalancingSpi.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/spi/loadbalancing/adaptive/AdaptiveLoadBalancingSpi.java b/modules/core/src/main/java/org/apache/ignite/spi/loadbalancing/adaptive/AdaptiveLoadBalancingSpi.java
index 3aec11a..3f4ad9d 100644
--- a/modules/core/src/main/java/org/apache/ignite/spi/loadbalancing/adaptive/AdaptiveLoadBalancingSpi.java
+++ b/modules/core/src/main/java/org/apache/ignite/spi/loadbalancing/adaptive/AdaptiveLoadBalancingSpi.java
@@ -224,7 +224,7 @@ import static org.apache.ignite.events.EventType.*;
* </property>
* </pre>
* <p>
- * <img src="http://www.gridgain.com/images/spring-small.png">
+ * <img src="http://ignite.incubator.apache.org/images/spring-small.png">
* <br>
* For information about Spring framework visit <a href="http://www.springframework.org/">www.springframework.org</a>
*/
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/c4030f92/modules/core/src/main/java/org/apache/ignite/spi/loadbalancing/roundrobin/RoundRobinLoadBalancingSpi.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/spi/loadbalancing/roundrobin/RoundRobinLoadBalancingSpi.java b/modules/core/src/main/java/org/apache/ignite/spi/loadbalancing/roundrobin/RoundRobinLoadBalancingSpi.java
index 74cd8fc..1dfed68 100644
--- a/modules/core/src/main/java/org/apache/ignite/spi/loadbalancing/roundrobin/RoundRobinLoadBalancingSpi.java
+++ b/modules/core/src/main/java/org/apache/ignite/spi/loadbalancing/roundrobin/RoundRobinLoadBalancingSpi.java
@@ -155,7 +155,7 @@ import static org.apache.ignite.events.EventType.*;
* </property>
* </pre>
* <p>
- * <img src="http://www.gridgain.com/images/spring-small.png">
+ * <img src="http://ignite.incubator.apache.org/images/spring-small.png">
* <br>
* For information about Spring framework visit <a href="http://www.springframework.org/">www.springframework.org</a>
*/
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/c4030f92/modules/core/src/main/java/org/apache/ignite/spi/loadbalancing/weightedrandom/WeightedRandomLoadBalancingSpi.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/spi/loadbalancing/weightedrandom/WeightedRandomLoadBalancingSpi.java b/modules/core/src/main/java/org/apache/ignite/spi/loadbalancing/weightedrandom/WeightedRandomLoadBalancingSpi.java
index 9fab9b0..4be2add 100644
--- a/modules/core/src/main/java/org/apache/ignite/spi/loadbalancing/weightedrandom/WeightedRandomLoadBalancingSpi.java
+++ b/modules/core/src/main/java/org/apache/ignite/spi/loadbalancing/weightedrandom/WeightedRandomLoadBalancingSpi.java
@@ -153,7 +153,7 @@ import static org.apache.ignite.events.EventType.*;
* </property>
* </pre>
* <p>
- * <img src="http://www.gridgain.com/images/spring-small.png">
+ * <img src="http://ignite.incubator.apache.org/images/spring-small.png">
* <br>
* For information about Spring framework visit <a href="http://www.springframework.org/">www.springframework.org</a>
*/
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/c4030f92/modules/core/src/main/java/org/apache/ignite/spi/swapspace/file/FileSwapSpaceSpi.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/spi/swapspace/file/FileSwapSpaceSpi.java b/modules/core/src/main/java/org/apache/ignite/spi/swapspace/file/FileSwapSpaceSpi.java
index 122d0ed..5eec025 100644
--- a/modules/core/src/main/java/org/apache/ignite/spi/swapspace/file/FileSwapSpaceSpi.java
+++ b/modules/core/src/main/java/org/apache/ignite/spi/swapspace/file/FileSwapSpaceSpi.java
@@ -94,7 +94,7 @@ import static org.apache.ignite.events.EventType.*;
* </bean>
* </pre>
* <p>
- * <img src="http://www.gridgain.com/images/spring-small.png">
+ * <img src="http://ignite.incubator.apache.org/images/spring-small.png">
* <br>
* For information about Spring framework visit <a href="http://www.springframework.org/">www.springframework.org</a>
* @see org.apache.ignite.spi.swapspace.SwapSpaceSpi
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/c4030f92/modules/core/src/main/java/org/apache/ignite/startup/cmdline/CommandLineStartup.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/startup/cmdline/CommandLineStartup.java b/modules/core/src/main/java/org/apache/ignite/startup/cmdline/CommandLineStartup.java
index 5189cfd..6a0709d 100644
--- a/modules/core/src/main/java/org/apache/ignite/startup/cmdline/CommandLineStartup.java
+++ b/modules/core/src/main/java/org/apache/ignite/startup/cmdline/CommandLineStartup.java
@@ -90,7 +90,7 @@ public final class CommandLineStartup {
Object osxApp = appCls.getDeclaredMethod("getApplication").invoke(null);
- String icoPath = "ggcube_node_128x128.png";
+ String icoPath = "logo_ignite_128x128.png";
URL url = CommandLineStartup.class.getResource(icoPath);
@@ -103,7 +103,7 @@ public final class CommandLineStartup {
// Setting Up about dialog
Class<?> aboutHndCls = Class.forName("com.apple.eawt.AboutHandler");
- final URL bannerUrl = CommandLineStartup.class.getResource("ggcube_node_48x48.png");
+ final URL bannerUrl = CommandLineStartup.class.getResource("logo_ignite_48x48.png");
Object aboutHndProxy = Proxy.newProxyInstance(
appCls.getClassLoader(),
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/c4030f92/modules/core/src/main/java/org/apache/ignite/startup/cmdline/ggcube_node_128x128.png
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/startup/cmdline/ggcube_node_128x128.png b/modules/core/src/main/java/org/apache/ignite/startup/cmdline/ggcube_node_128x128.png
deleted file mode 100644
index 88dcd60..0000000
Binary files a/modules/core/src/main/java/org/apache/ignite/startup/cmdline/ggcube_node_128x128.png and /dev/null differ
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/c4030f92/modules/core/src/main/java/org/apache/ignite/startup/cmdline/ggcube_node_48x48.png
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/startup/cmdline/ggcube_node_48x48.png b/modules/core/src/main/java/org/apache/ignite/startup/cmdline/ggcube_node_48x48.png
deleted file mode 100644
index 7f6c967..0000000
Binary files a/modules/core/src/main/java/org/apache/ignite/startup/cmdline/ggcube_node_48x48.png and /dev/null differ
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/c4030f92/modules/core/src/main/java/org/apache/ignite/startup/cmdline/logo_ignite_128x128.png
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/startup/cmdline/logo_ignite_128x128.png b/modules/core/src/main/java/org/apache/ignite/startup/cmdline/logo_ignite_128x128.png
new file mode 100644
index 0000000..046e381
Binary files /dev/null and b/modules/core/src/main/java/org/apache/ignite/startup/cmdline/logo_ignite_128x128.png differ
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/c4030f92/modules/core/src/main/java/org/apache/ignite/startup/cmdline/logo_ignite_48x48.png
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/startup/cmdline/logo_ignite_48x48.png b/modules/core/src/main/java/org/apache/ignite/startup/cmdline/logo_ignite_48x48.png
new file mode 100644
index 0000000..d4836ef
Binary files /dev/null and b/modules/core/src/main/java/org/apache/ignite/startup/cmdline/logo_ignite_48x48.png differ
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/c4030f92/modules/core/src/test/java/org/apache/ignite/internal/GridUpdateNotifierSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/GridUpdateNotifierSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/GridUpdateNotifierSelfTest.java
index 07bcf48..78a7a9c 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/GridUpdateNotifierSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/GridUpdateNotifierSelfTest.java
@@ -37,7 +37,7 @@ public class GridUpdateNotifierSelfTest extends GridCommonAbstractTest {
*/
public void testNotifier() throws Exception {
GridUpdateNotifier ntf = new GridUpdateNotifier(null, IgniteProperties.get("ignite.version"),
- IgniteKernal.SITE, TEST_GATEWAY, false);
+ TEST_GATEWAY, false);
ntf.checkForNewVersion(new SelfExecutor(), log);
[10/11] incubator-ignite git commit: [IGNITE-349]: unit test added.
Posted by sb...@apache.org.
[IGNITE-349]: unit test added.
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/66b00a1b
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/66b00a1b
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/66b00a1b
Branch: refs/heads/ignite-349
Commit: 66b00a1bc2f1d4775ab5c369a1df61d6d8922afb
Parents: 83dabe6
Author: iveselovskiy <iv...@gridgain.com>
Authored: Wed Mar 4 16:32:31 2015 +0300
Committer: iveselovskiy <iv...@gridgain.com>
Committed: Wed Mar 4 16:32:31 2015 +0300
----------------------------------------------------------------------
.../igfs/hadoop/v1/IgfsHadoopFileSystem.java | 8 +-
.../igfs/hadoop/v2/IgfsHadoopFileSystem.java | 8 +-
.../hadoop/SecondaryFileSystemProvider.java | 4 +-
.../SecondaryFileSystemConfigurationTest.java | 536 +++++++++++++++++++
4 files changed, 551 insertions(+), 5 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/66b00a1b/modules/hadoop/src/main/java/org/apache/ignite/igfs/hadoop/v1/IgfsHadoopFileSystem.java
----------------------------------------------------------------------
diff --git a/modules/hadoop/src/main/java/org/apache/ignite/igfs/hadoop/v1/IgfsHadoopFileSystem.java b/modules/hadoop/src/main/java/org/apache/ignite/igfs/hadoop/v1/IgfsHadoopFileSystem.java
index 2f5278e..280a28b 100644
--- a/modules/hadoop/src/main/java/org/apache/ignite/igfs/hadoop/v1/IgfsHadoopFileSystem.java
+++ b/modules/hadoop/src/main/java/org/apache/ignite/igfs/hadoop/v1/IgfsHadoopFileSystem.java
@@ -272,11 +272,15 @@ public class IgfsHadoopFileSystem extends FileSystem {
boolean initSecondary = paths.defaultMode() == PROXY;
- if (paths.pathModes() != null && !paths.pathModes().isEmpty()) {
+ if (!initSecondary && paths.pathModes() != null && !paths.pathModes().isEmpty()) {
for (T2<IgfsPath, IgfsMode> pathMode : paths.pathModes()) {
IgfsMode mode = pathMode.getValue();
- initSecondary |= mode == PROXY;
+ if (mode == PROXY) {
+ initSecondary = true;
+
+ break;
+ }
}
}
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/66b00a1b/modules/hadoop/src/main/java/org/apache/ignite/igfs/hadoop/v2/IgfsHadoopFileSystem.java
----------------------------------------------------------------------
diff --git a/modules/hadoop/src/main/java/org/apache/ignite/igfs/hadoop/v2/IgfsHadoopFileSystem.java b/modules/hadoop/src/main/java/org/apache/ignite/igfs/hadoop/v2/IgfsHadoopFileSystem.java
index 81585ff..340b22a 100644
--- a/modules/hadoop/src/main/java/org/apache/ignite/igfs/hadoop/v2/IgfsHadoopFileSystem.java
+++ b/modules/hadoop/src/main/java/org/apache/ignite/igfs/hadoop/v2/IgfsHadoopFileSystem.java
@@ -267,11 +267,15 @@ public class IgfsHadoopFileSystem extends AbstractFileSystem implements Closeabl
boolean initSecondary = paths.defaultMode() == PROXY;
- if (paths.pathModes() != null) {
+ if (!initSecondary && paths.pathModes() != null) {
for (T2<IgfsPath, IgfsMode> pathMode : paths.pathModes()) {
IgfsMode mode = pathMode.getValue();
- initSecondary |= mode == PROXY;
+ if (mode == PROXY) {
+ initSecondary = true;
+
+ break;
+ }
}
}
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/66b00a1b/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/SecondaryFileSystemProvider.java
----------------------------------------------------------------------
diff --git a/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/SecondaryFileSystemProvider.java b/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/SecondaryFileSystemProvider.java
index 722cc6c..5c9ec83 100644
--- a/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/SecondaryFileSystemProvider.java
+++ b/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/SecondaryFileSystemProvider.java
@@ -19,6 +19,7 @@ package org.apache.ignite.internal.processors.hadoop;
import org.apache.hadoop.conf.*;
import org.apache.hadoop.fs.*;
+import org.apache.ignite.internal.util.*;
import org.apache.ignite.internal.util.typedef.internal.*;
import org.jetbrains.annotations.*;
@@ -41,7 +42,8 @@ public class SecondaryFileSystemProvider {
*
* @param secUri the secondary Fs URI (optional). If not given explicitly, it must be specified as "fs.defaultFS"
* property in the provided configuration.
- * @param secConfPath the secondary Fs config URL (optional)
+ * @param secConfPath the secondary Fs path (file path on the local file system, optional).
+ * See {@link IgniteUtils#resolveIgniteUrl(String)} on how the path resolved.
* @throws IOException
*/
public SecondaryFileSystemProvider(final @Nullable String secUri,
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/66b00a1b/modules/hadoop/src/test/java/org/apache/ignite/igfs/SecondaryFileSystemConfigurationTest.java
----------------------------------------------------------------------
diff --git a/modules/hadoop/src/test/java/org/apache/ignite/igfs/SecondaryFileSystemConfigurationTest.java b/modules/hadoop/src/test/java/org/apache/ignite/igfs/SecondaryFileSystemConfigurationTest.java
new file mode 100644
index 0000000..f75ca2a
--- /dev/null
+++ b/modules/hadoop/src/test/java/org/apache/ignite/igfs/SecondaryFileSystemConfigurationTest.java
@@ -0,0 +1,536 @@
+package org.apache.ignite.igfs;
+
+import org.apache.hadoop.conf.*;
+import org.apache.hadoop.fs.*;
+import org.apache.hadoop.fs.permission.*;
+import org.apache.ignite.*;
+import org.apache.ignite.cache.*;
+import org.apache.ignite.configuration.*;
+import org.apache.ignite.igfs.hadoop.*;
+import org.apache.ignite.igfs.hadoop.v1.*;
+import org.apache.ignite.internal.igfs.hadoop.*;
+import org.apache.ignite.internal.processors.hadoop.*;
+import org.apache.ignite.internal.processors.igfs.*;
+import org.apache.ignite.internal.util.typedef.*;
+import org.apache.ignite.internal.util.typedef.internal.*;
+import org.apache.ignite.spi.communication.*;
+import org.apache.ignite.spi.communication.tcp.*;
+import org.apache.ignite.spi.discovery.tcp.*;
+import org.apache.ignite.spi.discovery.tcp.ipfinder.*;
+import org.apache.ignite.spi.discovery.tcp.ipfinder.vm.*;
+import org.apache.ignite.testframework.*;
+
+import java.io.*;
+import java.net.*;
+import java.util.*;
+import java.util.concurrent.*;
+
+import static org.apache.ignite.cache.CacheAtomicityMode.*;
+import static org.apache.ignite.cache.CacheMode.*;
+import static org.apache.ignite.events.EventType.*;
+import static org.apache.ignite.igfs.IgfsMode.*;
+import static org.apache.ignite.internal.util.ipc.shmem.IpcSharedMemoryServerEndpoint.*;
+
+/**
+ * Tests secondary file system configuration.
+ */
+public class SecondaryFileSystemConfigurationTest extends IgfsCommonAbstractTest {
+ /** IGFS scheme */
+ private static final String IGFS_SCHEME = "igfs";
+
+ /** Primary file system authority. */
+ private static final String PRIMARY_AUTHORITY = "igfs:grid0@";
+
+ /** Autogenerated secondary file system configuration path. */
+ private static final String PRIMARY_CFG_PATH = "/work/core-site-primary-test.xml";
+
+ /** Secondary file system authority. */
+ private static final String SECONDARY_AUTHORITY = "igfs_secondary:grid_secondary@127.0.0.1:11500";
+
+ /** Autogenerated secondary file system configuration path. */
+ private static final String SECONDARY_CFG_PATH = "/work/core-site-test.xml";
+
+ /** Secondary endpoint configuration. */
+ protected static final Map<String, String> SECONDARY_ENDPOINT_CFG = new HashMap<String, String>() {{
+ put("type", "tcp");
+ put("port", "11500");
+ }};
+
+ /** Group size. */
+ public static final int GRP_SIZE = 128;
+
+ /** IP finder. */
+ private static final TcpDiscoveryIpFinder IP_FINDER = new TcpDiscoveryVmIpFinder(true);
+
+ /** Primary file system URI. */
+ protected URI primaryFsUri;
+
+ /** Primary file system. */
+ private FileSystem primaryFs;
+
+ /** Full path of primary Fs configuration */
+ private String primaryConfFullPath;
+
+ /** Input primary Fs uri */
+ private String primaryFsUriStr;
+
+ /** Input URI scheme for configuration */
+ private String primaryCfgScheme;
+
+ /** Input URI authority for configuration */
+ private String primaryCfgAuthority;
+
+ /** if to pass configuration */
+ private boolean passPrimaryConfiguration;
+
+ /** Full path of s Fs configuration */
+ private String secondaryConfFullPath;
+
+ /** /Input URI scheme for configuration */
+ private String secondaryFsUriStr;
+
+ /** Input URI scheme for configuration */
+ private String secondaryCfgScheme;
+
+ /** Input URI authority for configuration */
+ private String secondaryCfgAuthority;
+
+ /** if to pass configuration */
+ private boolean passSecondaryConfiguration;
+
+ /** Default IGFS mode. */
+ protected final IgfsMode mode;
+
+ /** Skip embedded mode flag. */
+ private final boolean skipEmbed;
+
+ /** Skip local shmem flag. */
+ private final boolean skipLocShmem;
+
+ /**
+ * Constructor.
+ *
+ * @param mode Default IGFS mode.
+ * @param skipEmbed Whether to skip embedded mode.
+ * @param skipLocShmem Whether to skip local shmem mode.
+ */
+ protected SecondaryFileSystemConfigurationTest(IgfsMode mode, boolean skipEmbed, boolean skipLocShmem) {
+ this.mode = mode;
+ this.skipEmbed = skipEmbed;
+ this.skipLocShmem = skipLocShmem;
+ }
+
+ /**
+ * Default constructor.
+ */
+ public SecondaryFileSystemConfigurationTest() {
+ this(PROXY, true, false);
+ }
+
+ /**
+ * Executes before each test.
+ * @throws Exception
+ */
+ private void before() throws Exception {
+ initSecondary();
+
+ if (passPrimaryConfiguration) {
+ Configuration primaryFsCfg = configuration(primaryCfgScheme, primaryCfgAuthority, skipEmbed, skipLocShmem);
+
+ primaryConfFullPath = writeConfiguration(primaryFsCfg, PRIMARY_CFG_PATH);
+ } else
+ primaryConfFullPath = null;
+
+ SecondaryFileSystemProvider provider =
+ new SecondaryFileSystemProvider(primaryFsUriStr, primaryConfFullPath);
+
+ primaryFs = provider.createFileSystem();
+
+ primaryFsUri = provider.uri();
+ }
+
+ /**
+ * Executes after each test.
+ * @throws Exception
+ */
+ private void after() throws Exception {
+ if (primaryFs != null) {
+ try {
+ primaryFs.delete(new Path("/"), true);
+ }
+ catch (Exception ignore) {
+ // No-op.
+ }
+
+ U.closeQuiet(primaryFs);
+ }
+
+ G.stopAll(true);
+
+ delete(primaryConfFullPath);
+ delete(secondaryConfFullPath);
+ }
+
+ /**
+ * Utility method to delete file.
+ *
+ * @param file the file path to delete.
+ */
+ private static void delete(String file) {
+ if (file != null) {
+ new File(file).delete();
+
+ assertFalse(new File(file).exists());
+ }
+ }
+
+ /**
+ * Initialize underlying secondary filesystem.
+ *
+ * @throws Exception
+ */
+ private void initSecondary() throws Exception {
+ if (passSecondaryConfiguration) {
+ Configuration secondaryConf = configuration(secondaryCfgScheme, secondaryCfgAuthority, true, true);
+
+ secondaryConf.setInt("fs.igfs.block.size", 1024);
+
+ secondaryConfFullPath = writeConfiguration(secondaryConf, SECONDARY_CFG_PATH);
+ } else
+ secondaryConfFullPath = null;
+
+ startNodes();
+ }
+
+ /**
+ * Starts the nodes for this test.
+ *
+ * @throws Exception If failed.
+ */
+ private void startNodes() throws Exception {
+ if (mode != PRIMARY)
+ startSecondary();
+
+ startGrids(4);
+ }
+
+ /**
+ * Starts secondary IGFS
+ */
+ private void startSecondary() {
+ IgfsConfiguration igfsCfg = new IgfsConfiguration();
+
+ igfsCfg.setDataCacheName("partitioned");
+ igfsCfg.setMetaCacheName("replicated");
+ igfsCfg.setName("igfs_secondary");
+ igfsCfg.setIpcEndpointConfiguration(SECONDARY_ENDPOINT_CFG);
+ igfsCfg.setBlockSize(512 * 1024);
+ igfsCfg.setPrefetchBlocks(1);
+
+ CacheConfiguration cacheCfg = defaultCacheConfiguration();
+
+ cacheCfg.setName("partitioned");
+ cacheCfg.setCacheMode(PARTITIONED);
+ cacheCfg.setDistributionMode(CacheDistributionMode.PARTITIONED_ONLY);
+ cacheCfg.setWriteSynchronizationMode(CacheWriteSynchronizationMode.FULL_SYNC);
+ cacheCfg.setAffinityMapper(new IgfsGroupDataBlocksKeyMapper(GRP_SIZE));
+ cacheCfg.setBackups(0);
+ cacheCfg.setQueryIndexEnabled(false);
+ cacheCfg.setAtomicityMode(TRANSACTIONAL);
+
+ CacheConfiguration metaCacheCfg = defaultCacheConfiguration();
+
+ metaCacheCfg.setName("replicated");
+ metaCacheCfg.setCacheMode(REPLICATED);
+ metaCacheCfg.setWriteSynchronizationMode(CacheWriteSynchronizationMode.FULL_SYNC);
+ metaCacheCfg.setQueryIndexEnabled(false);
+ metaCacheCfg.setAtomicityMode(TRANSACTIONAL);
+
+ IgniteConfiguration cfg = new IgniteConfiguration();
+
+ cfg.setGridName("grid_secondary");
+
+ TcpDiscoverySpi discoSpi = new TcpDiscoverySpi();
+
+ discoSpi.setIpFinder(new TcpDiscoveryVmIpFinder(true));
+
+ cfg.setDiscoverySpi(discoSpi);
+ cfg.setCacheConfiguration(metaCacheCfg, cacheCfg);
+ cfg.setIgfsConfiguration(igfsCfg);
+ cfg.setIncludeEventTypes(EVT_TASK_FAILED, EVT_TASK_FINISHED, EVT_JOB_MAPPED);
+
+ cfg.setCommunicationSpi(communicationSpi());
+
+ G.start(cfg);
+ }
+
+ /**
+ * Get primary IPC endpoint configuration.
+ *
+ * @param gridName Grid name.
+ * @return IPC primary endpoint configuration.
+ */
+ protected Map<String, String> primaryIpcEndpointConfiguration(final String gridName) {
+ return new HashMap<String, String>() {{
+ put("type", "tcp");
+ put("port", String.valueOf(DFLT_IPC_PORT + getTestGridIndex(gridName)));
+ }};
+ }
+
+ /** {@inheritDoc} */
+ @Override public String getTestGridName() {
+ return "grid";
+ }
+
+ /** {@inheritDoc} */
+ @Override protected IgniteConfiguration getConfiguration(String gridName) throws Exception {
+ IgniteConfiguration cfg = super.getConfiguration(gridName);
+
+ TcpDiscoverySpi discoSpi = new TcpDiscoverySpi();
+
+ discoSpi.setIpFinder(IP_FINDER);
+
+ cfg.setDiscoverySpi(discoSpi);
+ cfg.setCacheConfiguration(cacheConfiguration());
+ cfg.setIgfsConfiguration(igfsConfiguration(gridName));
+ cfg.setIncludeEventTypes(EVT_TASK_FAILED, EVT_TASK_FINISHED, EVT_JOB_MAPPED);
+ cfg.setCommunicationSpi(communicationSpi());
+
+ return cfg;
+ }
+
+ /**
+ * Gets cache configuration.
+ *
+ * @return Cache configuration.
+ */
+ protected CacheConfiguration[] cacheConfiguration() {
+ CacheConfiguration cacheCfg = defaultCacheConfiguration();
+
+ cacheCfg.setName("partitioned");
+ cacheCfg.setCacheMode(PARTITIONED);
+ cacheCfg.setDistributionMode(CacheDistributionMode.PARTITIONED_ONLY);
+ cacheCfg.setWriteSynchronizationMode(CacheWriteSynchronizationMode.FULL_SYNC);
+ cacheCfg.setAffinityMapper(new IgfsGroupDataBlocksKeyMapper(GRP_SIZE));
+ cacheCfg.setBackups(0);
+ cacheCfg.setQueryIndexEnabled(false);
+ cacheCfg.setAtomicityMode(TRANSACTIONAL);
+
+ CacheConfiguration metaCacheCfg = defaultCacheConfiguration();
+
+ metaCacheCfg.setName("replicated");
+ metaCacheCfg.setCacheMode(REPLICATED);
+ metaCacheCfg.setWriteSynchronizationMode(CacheWriteSynchronizationMode.FULL_SYNC);
+ metaCacheCfg.setQueryIndexEnabled(false);
+ metaCacheCfg.setAtomicityMode(TRANSACTIONAL);
+
+ return new CacheConfiguration[] {metaCacheCfg, cacheCfg};
+ }
+
+ /**
+ * Gets IGFS configuration.
+ *
+ * @param gridName Grid name.
+ * @return IGFS configuration.
+ */
+ protected IgfsConfiguration igfsConfiguration(String gridName) throws IgniteCheckedException {
+ IgfsConfiguration cfg = new IgfsConfiguration();
+
+ cfg.setDataCacheName("partitioned");
+ cfg.setMetaCacheName("replicated");
+ cfg.setName("igfs");
+ cfg.setPrefetchBlocks(1);
+ cfg.setDefaultMode(mode);
+
+ if (mode != PRIMARY)
+ cfg.setSecondaryFileSystem(
+ new IgfsHadoopFileSystemWrapper(secondaryFsUriStr, secondaryConfFullPath));
+
+ cfg.setIpcEndpointConfiguration(primaryIpcEndpointConfiguration(gridName));
+
+ cfg.setManagementPort(-1);
+ cfg.setBlockSize(512 * 1024); // Together with group blocks mapper will yield 64M per node groups.
+
+ return cfg;
+ }
+
+ /** @return Communication SPI. */
+ private CommunicationSpi communicationSpi() {
+ TcpCommunicationSpi commSpi = new TcpCommunicationSpi();
+
+ commSpi.setSharedMemoryPort(-1);
+
+ return commSpi;
+ }
+
+ /** @throws Exception If failed. */
+ @SuppressWarnings("deprecation")
+ private void createBaseTestImpl() throws Exception {
+ Path fsHome = new Path(primaryFsUri);
+ Path dir = new Path(fsHome, "/someDir1/someDir2/someDir3");
+ Path file = new Path(dir, "someFile");
+
+ assertPathDoesNotExist(primaryFs, file);
+
+ FsPermission fsPerm = new FsPermission((short)644);
+
+ FSDataOutputStream os = primaryFs.create(file, fsPerm, false, 1, (short)1, 1L, null);
+
+ // Try to write something in file.
+ os.write("abc".getBytes());
+
+ os.close();
+
+ // Check file status.
+ FileStatus fileStatus = primaryFs.getFileStatus(file);
+
+ assertFalse(fileStatus.isDir());
+ assertEquals(file, fileStatus.getPath());
+ assertEquals(fsPerm, fileStatus.getPermission());
+ }
+
+ /**
+ * Case #SecondaryFileSystemProvider(null, path)
+ *
+ * @throws Exception On failure.
+ */
+ public void testFsConfigurationOnly() throws Exception {
+ primaryCfgScheme = IGFS_SCHEME;
+ primaryCfgAuthority = PRIMARY_AUTHORITY;
+ passPrimaryConfiguration = true;
+ primaryFsUriStr = null;
+
+ // wrong secondary URI in the configuration:
+ secondaryCfgScheme = IGFS_SCHEME;
+ secondaryCfgAuthority = SECONDARY_AUTHORITY;
+ passSecondaryConfiguration = true;
+ secondaryFsUriStr = null;
+
+ before();
+ try {
+ createBaseTestImpl();
+ } finally {
+ after();
+ }
+ }
+
+ /**
+ * Case #SecondaryFileSystemProvider(uri, path), when 'uri' parameter overrides
+ * the Fs uri set in the configuration.
+ *
+ * @throws Exception On failure.
+ */
+ public void testFsUriOverridesUriInConfiguration() throws Exception {
+ // wrong primary URI in the configuration:
+ primaryCfgScheme = "foo";
+ primaryCfgAuthority = "moo:zoo@bee";
+ passPrimaryConfiguration = true;
+ primaryFsUriStr = mkUri(IGFS_SCHEME, PRIMARY_AUTHORITY);
+
+ // wrong secondary URI in the configuration:
+ secondaryCfgScheme = "foo";
+ secondaryCfgAuthority = "moo:zoo@bee";
+ passSecondaryConfiguration = true;
+ secondaryFsUriStr = mkUri(IGFS_SCHEME, SECONDARY_AUTHORITY);
+
+ before();
+ try {
+ createBaseTestImpl();
+ } finally {
+ after();
+ }
+ }
+
+ /**
+ * Create configuration for test.
+ *
+ * @param skipEmbed Whether to skip embedded mode.
+ * @param skipLocShmem Whether to skip local shmem mode.
+ * @return Configuration.
+ */
+ private static Configuration configuration(String scheme, String authority, boolean skipEmbed, boolean skipLocShmem) {
+ final Configuration cfg = new Configuration();
+
+ if (scheme != null && authority != null)
+ cfg.set("fs.defaultFS", scheme + "://" + authority + "/");
+
+ setImplClasses(cfg);
+
+ if (authority != null) {
+ if (skipEmbed)
+ cfg.setBoolean(String.format(IgfsHadoopUtils.PARAM_IGFS_ENDPOINT_NO_EMBED, authority), true);
+
+ if (skipLocShmem)
+ cfg.setBoolean(String.format(IgfsHadoopUtils.PARAM_IGFS_ENDPOINT_NO_LOCAL_SHMEM, authority), true);
+ }
+
+ return cfg;
+ }
+
+ /**
+ * Sets Hadoop Fs implementation classes.
+ *
+ * @param cfg the configuration to set parameters into.
+ */
+ private static void setImplClasses(Configuration cfg) {
+ cfg.set("fs.igfs.impl", IgfsHadoopFileSystem.class.getName());
+
+ cfg.set("fs.AbstractFileSystem.igfs.impl",
+ org.apache.ignite.igfs.hadoop.v2.IgfsHadoopFileSystem.class.getName());
+ }
+
+ /**
+ * Check path does not exist in a given FileSystem.
+ *
+ * @param fs FileSystem to check.
+ * @param path Path to check.
+ */
+ private void assertPathDoesNotExist(final FileSystem fs, final Path path) {
+ GridTestUtils.assertThrows(log, new Callable<Object>() {
+ @Override public Object call() throws Exception {
+ return fs.getFileStatus(path);
+ }
+ }, FileNotFoundException.class, null);
+ }
+
+ /**
+ * Writes down the configuration to local disk and returns its path.
+ *
+ * @param cfg the configuration to write.
+ * @param pathFromIgniteHome path relatively to Ignite home.
+ * @return Full path of the written configuration.
+ */
+ private static String writeConfiguration(Configuration cfg, String pathFromIgniteHome) throws IOException {
+ if (!pathFromIgniteHome.startsWith("/"))
+ pathFromIgniteHome = "/" + pathFromIgniteHome;
+
+ final String path = U.getIgniteHome() + pathFromIgniteHome;
+
+ delete(path);
+
+ File file = new File(path);
+
+ try (FileOutputStream fos = new FileOutputStream(file)) {
+ cfg.writeXml(fos);
+ }
+
+ assertTrue(file.exists());
+ return path;
+ }
+
+ /** {@inheritDoc} */
+ @Override protected long getTestTimeout() {
+ return 3 * 60 * 1000;
+ }
+
+ /**
+ * Makes URI.
+ *
+ * @param scheme the scheme
+ * @param authority the authority
+ * @return URI String
+ */
+ private static String mkUri(String scheme, String authority) {
+ return scheme + "://" + authority + "/";
+ }
+}
[06/11] incubator-ignite git commit: # sprint-2 Fixed replace in
build script.
Posted by sb...@apache.org.
# sprint-2 Fixed replace in build script.
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/be3c24cd
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/be3c24cd
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/be3c24cd
Branch: refs/heads/ignite-349
Commit: be3c24cd3fd4a9aaf9a6922eac7bc56b5f85473c
Parents: c4030f9
Author: anovikov <an...@gridgain.com>
Authored: Wed Mar 4 14:34:50 2015 +0700
Committer: anovikov <an...@gridgain.com>
Committed: Wed Mar 4 14:34:50 2015 +0700
----------------------------------------------------------------------
pom.xml | 49 ++++---------------------------------------------
1 file changed, 4 insertions(+), 45 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/be3c24cd/pom.xml
----------------------------------------------------------------------
diff --git a/pom.xml b/pom.xml
index b176b10..b561aab 100644
--- a/pom.xml
+++ b/pom.xml
@@ -1121,38 +1121,6 @@
<configuration>
<target>
<replaceregexp byline="true">
- <regexp pattern='pushd "%~dp0"/\.\./\.\.(\s*&::.+)?'/>
- <substitution expression='pushd "%~dp0"/..'/>
- <fileset dir="${basedir}/target/release-package/bin">
- <include name="**/*.bat"/>
- </fileset>
- </replaceregexp>
-
- <replaceregexp byline="true">
- <regexp pattern='IGNITE_HOME_TMP="\$\(dirname "\$\{IGNITE_HOME_TMP\}"\)"(\s*#.*)?'/>
- <substitution expression=""/>
- <fileset dir="${basedir}/target/release-package/bin">
- <include name="**/*.sh"/>
- </fileset>
- </replaceregexp>
-
- <replaceregexp byline="true">
- <regexp pattern='set SCRIPTS_HOME=%IGNITE_HOME%\\os\\bin(\s*&::.*)?'/>
- <substitution expression='set SCRIPTS_HOME=%IGNITE_HOME%\\\\bin'/>
- <fileset dir="${basedir}/target/release-package/bin">
- <include name="**/*.bat"/>
- </fileset>
- </replaceregexp>
-
- <replaceregexp byline="true">
- <regexp pattern='SCRIPTS_HOME="\$\{IGNITE_HOME_TMP\}/os/bin"(\s*#.*)?'/>
- <substitution expression='SCRIPTS_HOME="$${IGNITE_HOME_TMP}/bin"'/>
- <fileset dir="${basedir}/target/release-package/bin">
- <include name="**/*.sh"/>
- </fileset>
- </replaceregexp>
-
- <replaceregexp byline="true">
<regexp pattern='\. "\$\{SCRIPTS_HOME\}"/include/target-classpath.sh(\s*#.*)?'/>
<substitution expression=""/>
<fileset dir="${basedir}/target/release-package/bin">
@@ -1184,23 +1152,14 @@
</fileset>
</replaceregexp>
- <replace token="@sh.file.version" value="${ignite.version}">
+ <replaceregexp byline="true">
+ <regexp pattern='-DIGNITE_UPDATE_NOTIFIER=false'/>
+ <substitution expression=""/>
<fileset dir="${basedir}/target/release-package/bin">
<include name="**/*.sh"/>
- </fileset>
- </replace>
-
- <replace token="@bat.file.version" value="${ignite.version}">
- <fileset dir="${basedir}/target/release-package/bin">
<include name="**/*.bat"/>
</fileset>
- </replace>
-
- <replace token="@xml.file.version" value="${ignite.version}">
- <fileset dir="${basedir}/target/release-package">
- <include name="**/*.xml"/>
- </fileset>
- </replace>
+ </replaceregexp>
<zip destfile="${basedir}/target/ignite-${ignite.edition}-${ignite.version}.zip"
encoding="UTF-8">
[09/11] incubator-ignite git commit: # sprint-2 Fixed typo.
Posted by sb...@apache.org.
# sprint-2 Fixed typo.
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/5d2a7c6c
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/5d2a7c6c
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/5d2a7c6c
Branch: refs/heads/ignite-349
Commit: 5d2a7c6ca6dac1d64d1efd4196e5130a117c6ca3
Parents: 4dd565e
Author: AKuznetsov <ak...@gridgain.com>
Authored: Wed Mar 4 17:16:01 2015 +0700
Committer: AKuznetsov <ak...@gridgain.com>
Committed: Wed Mar 4 17:16:01 2015 +0700
----------------------------------------------------------------------
.../apache/ignite/visor/commands/cache/VisorCacheCommand.scala | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/5d2a7c6c/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/cache/VisorCacheCommand.scala
----------------------------------------------------------------------
diff --git a/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/cache/VisorCacheCommand.scala b/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/cache/VisorCacheCommand.scala
index c39e946..8a2f6e0 100644
--- a/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/cache/VisorCacheCommand.scala
+++ b/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/cache/VisorCacheCommand.scala
@@ -842,8 +842,8 @@ object VisorCacheCommand {
cacheT += ("Cache Interceptor", safe(cfg.interceptor()))
cacheT += ("Store Enabled", bool2Str(storeCfg.enabled()))
- cacheT += ("Store Сlass", safe(storeCfg.store()))
- cacheT += ("Store Factory Сlass", storeCfg.storeFactory())
+ cacheT += ("Store Class", safe(storeCfg.store()))
+ cacheT += ("Store Factory Class", storeCfg.storeFactory())
cacheT += ("Store Read Through", bool2Str(storeCfg.readThrough()))
cacheT += ("Store Write Through", bool2Str(storeCfg.writeThrough()))
[07/11] incubator-ignite git commit: # IGNITE-298 Show "UNLIMITED" if
off-heap size configuration == 0.
Posted by sb...@apache.org.
# IGNITE-298 Show "UNLIMITED" if off-heap size configuration == 0.
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/656ee473
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/656ee473
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/656ee473
Branch: refs/heads/ignite-349
Commit: 656ee473e2299c16a0f59dc1aa37bbed04ee656e
Parents: be3c24c
Author: AKuznetsov <ak...@gridgain.com>
Authored: Wed Mar 4 16:31:49 2015 +0700
Committer: AKuznetsov <ak...@gridgain.com>
Committed: Wed Mar 4 16:31:49 2015 +0700
----------------------------------------------------------------------
.../apache/ignite/visor/commands/cache/VisorCacheCommand.scala | 6 +++++-
1 file changed, 5 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/656ee473/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/cache/VisorCacheCommand.scala
----------------------------------------------------------------------
diff --git a/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/cache/VisorCacheCommand.scala b/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/cache/VisorCacheCommand.scala
index 69da6f5..1c52676 100644
--- a/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/cache/VisorCacheCommand.scala
+++ b/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/cache/VisorCacheCommand.scala
@@ -856,7 +856,11 @@ object VisorCacheCommand {
cacheT += ("Concurrent Asynchronous Operations Number", cfg.maxConcurrentAsyncOperations())
cacheT += ("Memory Mode", cfg.memoryMode())
cacheT += ("Keep Values Bytes", cfg.valueBytes())
- cacheT += ("Off-Heap Size", if (cfg.offsetHeapMaxMemory() >= 0) cfg.offsetHeapMaxMemory() else NA)
+ cacheT += ("Off-Heap Size", cfg.offsetHeapMaxMemory() match {
+ case 0 => "UNLIMITED"
+ case size if size < 0 => NA
+ case size => size
+ })
cacheT += ("Loader Factory Class Name", safe(cfg.loaderFactory()))
cacheT += ("Writer Factory Class Name", safe(cfg.writerFactory()))