ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject [20/40] incubator-ignite git commit: Merge branch 'ignite-sprint-3-p1' into ignite-714
Date Wed, 15 Apr 2015 14:11:55 GMT
Merge branch 'ignite-sprint-3-p1' into ignite-714


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

Branch: refs/heads/ignite-743
Commit: 6c694962e06444cc12bfa06e8b0e255bbcdab63f
Parents: 49e358e 60a0249
Author: nikolay_tikhonov <ntikhonov@gridgain.com>
Authored: Tue Apr 14 18:12:30 2015 +0300
Committer: nikolay_tikhonov <ntikhonov@gridgain.com>
Committed: Tue Apr 14 18:12:30 2015 +0300

----------------------------------------------------------------------
 DEVNOTES.txt                                    |   4 +-
 RELEASE_NOTES.txt                               |  13 +
 assembly/dependencies-fabric.xml                |  50 ++++
 assembly/dependencies-hadoop.xml                |   1 -
 assembly/dependencies-optional-fabric.xml       |  82 ------
 assembly/dependencies-optional-hadoop.xml       |  83 ------
 assembly/release-base.xml                       |   5 -
 assembly/release-fabric.xml                     |   5 +
 assembly/release-hadoop.xml                     |   4 -
 bin/ignitevisorcmd.bat                          |  39 +--
 examples/pom.xml                                |   2 +-
 .../streaming/wordcount/CacheConfig.java        |   5 +
 .../streaming/wordcount/QueryWords.java         |   4 +-
 .../examples/MessagingExamplesSelfTest.java     |   2 +-
 .../java8/examples/BasicExamplesSelfTest.java   |   3 +
 .../java8/examples/CacheExamplesSelfTest.java   |   4 +
 .../examples/CheckpointExamplesSelfTest.java    |   3 +
 .../examples/ClusterGroupExampleSelfTest.java   |   3 +-
 .../examples/ContinuationExamplesSelfTest.java  |   3 +
 .../ContinuousMapperExamplesSelfTest.java       |   4 +-
 .../DeploymentExamplesMultiNodeSelfTest.java    |   2 +
 .../examples/DeploymentExamplesSelfTest.java    |   2 +
 .../HibernateL2CacheExampleSelfTest.java        |   3 +
 .../java8/examples/IgfsExamplesSelfTest.java    |   3 +
 .../examples/LifecycleExamplesSelfTest.java     |   3 +
 .../MemcacheRestExamplesMultiNodeSelfTest.java  |   2 +
 .../examples/MemcacheRestExamplesSelfTest.java  |   2 +
 .../examples/MessagingExamplesSelfTest.java     |   4 +-
 .../examples/MonteCarloExamplesSelfTest.java    |   3 +
 .../examples/SpringBeanExamplesSelfTest.java    |   3 +
 .../java8/examples/TaskExamplesSelfTest.java    |   2 +
 modules/aop/pom.xml                             |   2 +-
 modules/aws/pom.xml                             |   2 +-
 modules/clients/pom.xml                         |   2 +-
 .../client/ClientReconnectionSelfTest.java      |  69 ++---
 modules/codegen/pom.xml                         |  14 +-
 modules/core/pom.xml                            |   4 +-
 .../java/org/apache/ignite/IgniteCache.java     |  19 +-
 .../java/org/apache/ignite/IgniteState.java     |   2 +-
 .../apache/ignite/IgniteSystemProperties.java   |   7 +
 .../apache/ignite/cache/query/ScanQuery.java    |   2 +-
 .../ignite/cache/query/SqlFieldsQuery.java      |  55 +++-
 .../configuration/CacheConfiguration.java       |  76 +++--
 .../configuration/IgniteConfiguration.java      |  16 +-
 .../ignite/internal/ClusterMetricsSnapshot.java |   3 -
 .../internal/ComputeTaskInternalFuture.java     |   2 +-
 .../apache/ignite/internal/GridComponent.java   |   5 +-
 .../ignite/internal/GridJobExecuteRequest.java  |  10 +-
 .../ignite/internal/GridJobExecuteResponse.java |   4 +-
 .../ignite/internal/GridPluginComponent.java    |   5 +-
 .../apache/ignite/internal/GridTaskMessage.java |  30 --
 .../ignite/internal/GridTaskSessionRequest.java |   6 +-
 .../org/apache/ignite/internal/IgnitionEx.java  |   4 +-
 .../client/GridClientConfiguration.java         |  14 +-
 .../GridClientConnectionManagerAdapter.java     |   2 +-
 .../router/GridTcpRouterConfiguration.java      |   6 +-
 .../internal/cluster/ClusterGroupAdapter.java   | 150 ++++++++--
 .../internal/managers/GridManagerAdapter.java   |   8 +-
 .../discovery/GridDiscoveryManager.java         |  39 ++-
 .../eventstorage/GridEventStorageManager.java   |   4 +-
 .../processors/GridProcessorAdapter.java        |   5 +-
 .../processors/cache/CacheMetricsImpl.java      |   7 +-
 .../processors/cache/CacheMetricsSnapshot.java  | 223 ++++++++++++++-
 .../processors/cache/GridCacheAdapter.java      |  12 +-
 .../processors/cache/GridCacheContext.java      |   6 +-
 .../processors/cache/GridCacheProcessor.java    |   4 +-
 .../processors/cache/IgniteCacheProxy.java      |  26 ++
 .../dht/atomic/GridDhtAtomicCache.java          |   6 +-
 .../dht/colocated/GridDhtColocatedCache.java    |   3 +-
 .../GridDhtPartitionsExchangeFuture.java        |   3 +
 .../distributed/near/GridNearAtomicCache.java   |   2 +-
 .../near/GridNearTransactionalCache.java        |   2 +-
 .../cache/local/GridLocalLockFuture.java        |   2 +
 .../local/atomic/GridLocalAtomicCache.java      |   6 +-
 .../cache/query/GridCacheQueryAdapter.java      |   2 +-
 .../continuous/CacheContinuousQueryManager.java |   2 +-
 .../transactions/IgniteTxLocalAdapter.java      |   6 +-
 .../continuous/GridContinuousProcessor.java     |   4 +-
 .../internal/processors/igfs/IgfsAsyncImpl.java |   4 +-
 .../ignite/internal/processors/igfs/IgfsEx.java |   4 +-
 .../processors/igfs/IgfsFileWorker.java         | 180 ------------
 .../processors/igfs/IgfsFileWorkerBatch.java    | 225 ++++++---------
 .../processors/igfs/IgfsFileWorkerTask.java     |  32 ---
 .../internal/processors/igfs/IgfsImpl.java      | 150 ++++++----
 .../processors/igfs/IgfsInputStreamImpl.java    |   2 +-
 .../processors/igfs/IgfsOutputStreamImpl.java   |   6 +-
 .../internal/processors/igfs/IgfsProcessor.java |   2 +-
 .../plugin/IgnitePluginProcessor.java           |  13 +-
 .../query/GridQueryFieldMetadata.java           |   2 +-
 .../processors/query/GridQueryProcessor.java    |  89 +++---
 .../processors/rest/GridRestProcessor.java      |  33 +--
 .../security/GridSecurityProcessor.java         |  13 +-
 .../processors/security/SecurityContext.java    |   8 +-
 .../security/os/GridOsSecurityProcessor.java    |  11 +-
 .../processors/task/GridTaskProcessor.java      |   9 +-
 .../ignite/internal/util/GridJavaProcess.java   |  38 ++-
 .../visor/cache/VisorCacheClearTask.java        |   3 +
 .../visor/cache/VisorCacheConfiguration.java    |   2 +-
 .../internal/visor/cache/VisorCacheMetrics.java |   2 +-
 .../cache/VisorCacheQueryConfiguration.java     |   9 -
 .../internal/visor/log/VisorLogSearchTask.java  |  12 +-
 .../visor/node/VisorNodeDataCollectorTask.java  |   1 +
 .../node/VisorNodeEventsCollectorTask.java      |   3 +
 .../node/VisorSegmentationConfiguration.java    |   4 +-
 .../internal/visor/query/VisorQueryArg.java     |  82 ++++++
 .../visor/query/VisorQueryCleanupTask.java      |  10 +-
 .../internal/visor/query/VisorQueryCursor.java  |  96 +++++++
 .../internal/visor/query/VisorQueryField.java   |  66 ++++-
 .../internal/visor/query/VisorQueryJob.java     | 174 ++++++++++++
 .../visor/query/VisorQueryNextPageTask.java     |  75 +++--
 .../internal/visor/query/VisorQueryResult.java  |   6 +-
 .../visor/query/VisorQueryResultEx.java         |  16 +-
 .../internal/visor/query/VisorQueryTask.java    | 283 ++-----------------
 .../internal/visor/query/VisorQueryUtils.java   |  55 ++--
 .../internal/visor/util/VisorTaskUtils.java     |   3 +
 .../apache/ignite/plugin/PluginProvider.java    |   5 +-
 .../plugin/security/AuthenticationContext.java  |  12 +-
 .../security/GridSecurityCredentials.java       | 184 ------------
 .../GridSecurityCredentialsBasicProvider.java   |  44 ---
 .../GridSecurityCredentialsProvider.java        |  44 ---
 .../plugin/security/GridSecurityException.java  |  58 ----
 .../plugin/security/GridSecurityPermission.java |  69 -----
 .../security/GridSecurityPermissionSet.java     |  66 -----
 .../plugin/security/GridSecuritySubject.java    |  62 ----
 .../security/GridSecuritySubjectType.java       |  48 ----
 .../plugin/security/SecurityCredentials.java    | 191 +++++++++++++
 .../SecurityCredentialsBasicProvider.java       |  44 +++
 .../security/SecurityCredentialsProvider.java   |  44 +++
 .../plugin/security/SecurityException.java      |  61 ++++
 .../plugin/security/SecurityPermission.java     |  69 +++++
 .../plugin/security/SecurityPermissionSet.java  |  66 +++++
 .../ignite/plugin/security/SecuritySubject.java |  62 ++++
 .../plugin/security/SecuritySubjectType.java    |  48 ++++
 .../segmentation/GridSegmentationPolicy.java    |  47 ---
 .../segmentation/GridSegmentationResolver.java  |  64 -----
 .../plugin/segmentation/SegmentationPolicy.java |  49 ++++
 .../segmentation/SegmentationResolver.java      |  65 +++++
 .../org/apache/ignite/spi/IgniteSpiAdapter.java |   4 +-
 .../org/apache/ignite/spi/IgniteSpiContext.java |   4 +-
 .../spi/discovery/DiscoveryMetricsProvider.java |  10 +
 .../spi/discovery/DiscoverySpiDataExchange.java |   5 +-
 .../DiscoverySpiNodeAuthenticator.java          |   2 +-
 .../discovery/tcp/TcpClientDiscoverySpi.java    |  39 ++-
 .../spi/discovery/tcp/TcpDiscoverySpi.java      | 147 ++++++++--
 .../discovery/tcp/TcpDiscoverySpiAdapter.java   |  27 ++
 .../tcp/internal/TcpDiscoveryNode.java          |  82 +++++-
 .../TcpDiscoveryCustomEventMessage.java         |  23 +-
 .../messages/TcpDiscoveryHeartbeatMessage.java  |  65 +++++
 .../TcpDiscoveryJoinRequestMessage.java         |   6 +-
 .../messages/TcpDiscoveryNodeAddedMessage.java  |  16 +-
 .../ignite/startup/BasicWarmupClosure.java      |   9 +-
 .../startup/cmdline/CommandLineStartup.java     |   7 +-
 .../resources/META-INF/classnames.properties    |  36 ++-
 .../cache/IgniteWarmupClosureSelfTest.java      |  82 ++++++
 .../fair/GridFairAffinityFunctionSelfTest.java  |   2 -
 .../IgniteFairAffinityDynamicCacheSelfTest.java |  97 +++++++
 .../internal/GridLifecycleAwareSelfTest.java    |   2 +-
 .../ignite/internal/GridProjectionSelfTest.java |  82 ++++++
 .../ignite/internal/GridStartStopSelfTest.java  |   8 +-
 .../CacheMetricsForClusterGroupSelfTest.java    | 252 +++++++++++++++++
 ...CacheOffHeapMultiThreadedUpdateSelfTest.java |  47 +--
 .../GridCacheOffHeapTieredAbstractSelfTest.java |   4 +-
 .../cache/GridCacheReloadSelfTest.java          |   3 +-
 .../GridCacheReturnValueTransferSelfTest.java   |  15 +-
 .../IgniteTxMultiThreadedAbstractTest.java      |   5 +-
 ...GridCacheQueueMultiNodeAbstractSelfTest.java |   5 +-
 .../GridCacheSetAbstractSelfTest.java           |  10 +-
 .../GridCacheSetFailoverAbstractSelfTest.java   |   8 +-
 .../distributed/GridCacheEventAbstractTest.java |  16 +-
 .../GridCacheNodeFailureAbstractTest.java       |  15 +-
 ...licatedNearOnlyMultiNodeFullApiSelfTest.java |   2 +-
 .../continuous/GridEventConsumeSelfTest.java    |  10 +-
 .../processors/igfs/IgfsAbstractSelfTest.java   |  24 +-
 .../tostring/GridToStringBuilderSelfTest.java   |   5 +-
 .../GridP2PMissedResourceCacheSizeSelfTest.java |   2 +-
 .../discovery/AbstractDiscoverySelfTest.java    |   4 +-
 ...ClusterMetricsSnapshotSerializeSelfTest.java |  28 ++
 .../tcp/TcpClientDiscoverySelfTest.java         |   5 +-
 .../tcp/TcpDiscoverySpiStartStopSelfTest.java   |   5 +-
 .../testframework/GridSpiTestContext.java       |   4 +-
 .../testframework/junits/GridAbstractTest.java  |   2 +-
 .../junits/spi/GridSpiAbstractTest.java         |  76 +----
 .../IgniteCacheMetricsSelfTestSuite.java        |   4 +
 .../ignite/testsuites/IgniteCacheTestSuite.java |   6 +
 ...rrentLinkedHashMapMultiThreadedSelfTest.java |   4 +-
 modules/extdata/p2p/pom.xml                     |   2 +-
 .../p2p/startcache/CacheAllNodesFilter.java     |  31 ++
 .../CacheConfigurationP2PTestClient.java        | 118 ++++++++
 .../tests/p2p/startcache/Organization1.java     |  52 ++++
 .../tests/p2p/startcache/Organization2.java     |  52 ++++
 modules/extdata/uri/pom.xml                     |   2 +-
 modules/geospatial/pom.xml                      |   2 +-
 modules/hadoop/docs/hadoop_readme.pdf           | Bin 82297 -> 82219 bytes
 modules/hadoop/pom.xml                          |   2 +-
 .../HadoopDefaultMapReducePlannerSelfTest.java  |   2 +-
 modules/hibernate/pom.xml                       |   2 +-
 modules/indexing/pom.xml                        |   2 +-
 .../processors/query/h2/IgniteH2Indexing.java   |  19 +-
 .../query/h2/sql/GridSqlQuerySplitter.java      |  18 +-
 .../query/h2/twostep/GridMergeIndex.java        |  17 +-
 .../h2/twostep/GridReduceQueryExecutor.java     |   2 +-
 .../cache/CacheConfigurationP2PTest.java        | 179 ++++++++++++
 .../cache/CacheConfigurationP2PTestServer.java  |  49 ++++
 .../GridCacheAbstractFieldsQuerySelfTest.java   |  10 +-
 .../processors/cache/GridCacheSwapSelfTest.java |   5 +-
 .../IgniteCacheCollocatedQuerySelfTest.java     | 209 ++++++++++++++
 .../cache/IgniteCacheLargeResultSelfTest.java   | 104 +++++++
 .../IgniteCacheReplicatedQuerySelfTest.java     |  11 +-
 .../query/h2/sql/BaseH2CompareQueryTest.java    |  20 ++
 .../IgniteCacheQuerySelfTestSuite.java          |   2 +
 .../IgniteCacheWithIndexingTestSuite.java       |   2 +
 modules/jcl/pom.xml                             |   2 +-
 modules/jta/pom.xml                             |   2 +-
 .../processors/cache/GridCacheJtaSelfTest.java  |   6 +-
 modules/log4j/pom.xml                           |   2 +-
 modules/rest-http/pom.xml                       |   2 +-
 .../http/jetty/GridJettyRestHandler.java        |   2 +-
 modules/scalar/pom.xml                          |   2 +-
 modules/schedule/pom.xml                        |   2 +-
 modules/schema-import/pom.xml                   |   2 +-
 modules/slf4j/pom.xml                           |   2 +-
 modules/spring/pom.xml                          |   2 +-
 .../p2p/GridP2PUserVersionChangeSelfTest.java   |   8 +-
 modules/ssh/pom.xml                             |   2 +-
 modules/tools/pom.xml                           |   2 +-
 .../ignite/tools/classgen/ClassesGenerator.java |   2 +-
 modules/urideploy/pom.xml                       |   2 +-
 modules/visor-console/pom.xml                   |   2 +-
 .../ignite/visor/commands/VisorConsole.scala    |  19 ++
 .../commands/cache/VisorCacheScanCommand.scala  |  13 +-
 modules/visor-plugins/pom.xml                   |   2 +-
 modules/web/pom.xml                             |   2 +-
 modules/yardstick/pom.xml                       |   2 +-
 pom.xml                                         |  78 ++---
 234 files changed, 4432 insertions(+), 2314 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/6c694962/modules/core/src/main/java/org/apache/ignite/internal/managers/GridManagerAdapter.java
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/6c694962/modules/core/src/main/java/org/apache/ignite/internal/managers/discovery/GridDiscoveryManager.java
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/6c694962/modules/core/src/main/java/org/apache/ignite/spi/IgniteSpiAdapter.java
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/6c694962/modules/core/src/main/java/org/apache/ignite/spi/IgniteSpiContext.java
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/6c694962/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpClientDiscoverySpi.java
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/6c694962/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySpi.java
----------------------------------------------------------------------
diff --cc modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySpi.java
index 582e794,ed4be4e..b40bf75
--- 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
@@@ -1249,21 -1247,18 +1250,30 @@@ public class TcpDiscoverySpi extends Tc
  
      /** {@inheritDoc} */
      @Override public void sendCustomEvent(Serializable evt) {
-         msgWorker.addMessage(new TcpDiscoveryCustomEventMessage(getLocalNodeId(), evt));
+         try {
+             byte[] msgBytes;
+ 
+             msgBytes = marsh.marshal(evt);
+ 
+             msgWorker.addMessage(new TcpDiscoveryCustomEventMessage(getLocalNodeId(), evt,
msgBytes));
+         }
+         catch (IgniteCheckedException e) {
+             throw new IgniteSpiException("Failed to marshal custom event: " + evt, e);
+         }
      }
  
 +    /** {@inheritDoc} */
 +    @Override public void failNode(UUID nodeId) {
 +        ClusterNode node = ring.node(nodeId);
 +
 +        if (node != null) {
 +            TcpDiscoveryNodeFailedMessage msg = new TcpDiscoveryNodeFailedMessage(getLocalNodeId(),
 +                node.id(), node.order());
 +
 +            msgWorker.addMessage(msg);
 +        }
 +    }
 +
      /**
       * Tries to join this node to topology.
       *

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/6c694962/modules/core/src/test/java/org/apache/ignite/testframework/GridSpiTestContext.java
----------------------------------------------------------------------


Mime
View raw message