This is an automated email from the ASF dual-hosted git repository.
av pushed a change to branch ignite-ducktape
in repository https://gitbox.apache.org/repos/asf/ignite.git.
from 879fa1f Fail fast (#8147)
add ec94d35 IGNITE-13208 : Simplify IgniteSpiOperationTimeoutHelper
(#7988)
add e7b874d IGNITE-13302 Fixed partition divergence in the system cache
that may occur due to java thin client connecting. Fixes #8096
add 5dad37d IGNITE-13309: Extended cpp build documentation
add ee7d136 IGNITE-13292 Remove unnecessary zk pinger. - Fixes #8081.
add b9e1f98 IGNITE-13098 TcpCommunicationSpi split to independent classes
- Fixes #8057
add 4b8ddd9 IGNITE-13102 IgniteCache#isClosed() returns false on server
node even if the cache had been closed before - Fixes #8087.
add 43992aa IGNITE-13347: InitialSize, MaxSize added to data region
metrics (#8138)
add 1f6641d IGNITE-13210 Fix generated names of parameterized tests -
Fixes #7989.
add 674841e IGNITE-12363 Migrate Camel module to ignite-extensions -
Fixes #8132.
new 27239fe Merge remote-tracking branch 'remotes/origin/master' into
ignite-ducktape
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
assembly/libs/README.txt | 1 -
modules/camel/README.txt | 34 -
modules/camel/licenses/apache-2.0.txt | 202 -
modules/camel/pom.xml | 116 -
.../apache/ignite/stream/camel/CamelStreamer.java | 237 -
.../apache/ignite/stream/camel/package-info.java | 22 -
.../stream/camel/IgniteCamelStreamerTest.java | 432 --
.../apache/ignite/stream/camel/package-info.java | 22 -
.../camel/src/test/resources/camel.test.properties | 18 -
.../internal/managers/GridManagerAdapter.java | 51 +-
.../processors/cache/GridCacheMapEntry.java | 4 +-
.../processors/cache/IgniteCacheProxyImpl.java | 2 +-
.../cache/persistence/DataRegionMetricsImpl.java | 6 +
.../util/function/ThrowableBiFunction.java} | 16 +-
.../internal/util/function/ThrowableSupplier.java} | 18 +-
.../org/apache/ignite/spi/IgniteSpiAdapter.java | 2 +-
.../spi/IgniteSpiOperationTimeoutHelper.java | 23 +-
.../spi/communication/tcp/AttributeNames.java | 123 +
.../tcp/TcpCommunicationMetricsListener.java | 6 +-
.../spi/communication/tcp/TcpCommunicationSpi.java | 5895 +++-----------------
.../tcp/internal/ClusterStateProvider.java | 208 +
.../CommunicationDiscoveryEventListener.java | 88 +
.../tcp/internal/CommunicationTcpUtils.java | 165 +
.../tcp/internal/CommunicationWorker.java | 413 ++
.../communication/tcp/internal/ConnectFuture.java} | 13 +-
.../communication/tcp/internal/ConnectGateway.java | 109 +
.../tcp/internal/ConnectionClientPool.java | 802 +++
.../tcp/internal/ConnectionPolicy.java} | 16 +-
.../tcp/internal/DisconnectedSessionInfo.java | 61 +
.../tcp/internal/FirstConnectionPolicy.java} | 15 +-
.../tcp/internal/GridNioServerWrapper.java | 1488 +++++
.../tcp/internal/HandshakeTimeoutObject.java | 89 +
.../tcp/internal/InboundConnectionHandler.java | 978 ++++
.../tcp/internal/RoundRobinConnectionPolicy.java} | 25 +-
.../TcpCommunicationConfigInitializer.java | 931 ++++
.../internal/TcpCommunicationConfiguration.java | 596 ++
.../tcp/internal/TcpCommunicationSpiMBeanImpl.java | 217 +
.../tcp/internal/shmem/SHMemHandshakeClosure.java | 134 +
.../tcp/internal/shmem/ShmemAcceptWorker.java | 154 +
.../tcp/internal/shmem/ShmemWorker.java | 159 +
.../main/resources/META-INF/classnames.properties | 1 +
.../org/apache/ignite/internal/GridMBeansTest.java | 2 +-
...teConnectionConcurrentReserveAndRemoveTest.java | 3 +-
.../IgniteSlowClientDetectionSelfTest.java | 3 +-
.../IgniteCommunicationBalanceTest.java | 5 +-
.../internal/metric/AbstractExporterSpiTest.java | 4 +-
.../ignite/internal/metric/JmxExporterSpiTest.java | 6 +
.../cache/CacheStopAndDestroySelfTest.java | 22 +
.../IgniteCacheClusterReadOnlyModeSelfTest.java | 5 -
.../SysCacheInconsistencyInternalKeyTest.java | 89 +
.../IgniteCacheMessageRecoveryAbstractTest.java | 3 +-
.../cache/persistence/db/RebalanceBlockingSPI.java | 102 +
.../ClientReconnectContinuousQueryTest.java | 3 +-
.../AbstractTransactionIntergrityTest.java | 2 +
.../ServiceDeploymentProcessIdSelfTest.java | 24 +-
.../GridAbstractCommunicationSelfTest.java | 3 +-
.../tcp/GridTcpCommunicationSpiAbstractTest.java | 4 +-
...pCommunicationSpiConcurrentConnectSelfTest.java | 9 +-
.../tcp/GridTcpCommunicationSpiLogTest.java | 235 +
...idTcpCommunicationSpiMultithreadedSelfTest.java | 88 +-
...GridTcpCommunicationSpiRecoveryAckSelfTest.java | 11 +-
.../GridTcpCommunicationSpiRecoverySelfTest.java | 72 +-
...TcpCommunicationRecoveryAckClosureSelfTest.java | 11 +-
.../tcp/TcpCommunicationSpiFaultyClientTest.java | 27 +-
.../tcp/TcpCommunicationSpiFreezingClientTest.java | 8 +-
...cpCommunicationSpiHalfOpenedConnectionTest.java | 12 +-
.../TooManyOpenFilesTcpCommunicationSpiTest.java | 40 +-
.../testframework/junits/GridAbstractTest.java | 3 +
.../junits/spi/GridSpiAbstractTest.java | 10 +-
.../ignite/testsuites/IgniteCacheTestSuite6.java | 3 +
.../cache/metric/SqlViewExporterSpiTest.java | 15 +-
modules/platforms/cpp/DEVNOTES.txt | 15 +-
modules/platforms/cpp/README.txt | 2 +
.../ignite/spi/discovery/zk/internal/ZkPinger.java | 88 -
.../spi/discovery/zk/internal/ZookeeperClient.java | 29 -
.../zk/internal/ZookeeperDiscoveryImpl.java | 13 -
pom.xml | 1 -
77 files changed, 8273 insertions(+), 6591 deletions(-)
delete mode 100644 modules/camel/README.txt
delete mode 100644 modules/camel/licenses/apache-2.0.txt
delete mode 100644 modules/camel/pom.xml
delete mode 100644
modules/camel/src/main/java/org/apache/ignite/stream/camel/CamelStreamer.java
delete mode 100644
modules/camel/src/main/java/org/apache/ignite/stream/camel/package-info.java
delete mode 100644
modules/camel/src/test/java/org/apache/ignite/stream/camel/IgniteCamelStreamerTest.java
delete mode 100644
modules/camel/src/test/java/org/apache/ignite/stream/camel/package-info.java
delete mode 100644 modules/camel/src/test/resources/camel.test.properties
copy
modules/{camel/src/test/java/org/apache/ignite/stream/camel/IgniteCamelStreamerTestSuite.java
=>
core/src/main/java/org/apache/ignite/internal/util/function/ThrowableBiFunction.java}
(72%)
copy
modules/{camel/src/test/java/org/apache/ignite/stream/camel/IgniteCamelStreamerTestSuite.java
=>
core/src/main/java/org/apache/ignite/internal/util/function/ThrowableSupplier.java}
(71%)
create mode 100644
modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/AttributeNames.java
create mode 100644
modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/internal/ClusterStateProvider.java
create mode 100644
modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/internal/CommunicationDiscoveryEventListener.java
create mode 100644
modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/internal/CommunicationTcpUtils.java
create mode 100644
modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/internal/CommunicationWorker.java
copy
modules/{camel/src/test/java/org/apache/ignite/stream/camel/IgniteCamelStreamerTestSuite.java
=>
core/src/main/java/org/apache/ignite/spi/communication/tcp/internal/ConnectFuture.java}
(68%)
create mode 100644
modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/internal/ConnectGateway.java
create mode 100644
modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/internal/ConnectionClientPool.java
copy
modules/{camel/src/test/java/org/apache/ignite/stream/camel/IgniteCamelStreamerTestSuite.java
=>
core/src/main/java/org/apache/ignite/spi/communication/tcp/internal/ConnectionPolicy.java}
(69%)
create mode 100644
modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/internal/DisconnectedSessionInfo.java
copy
modules/{camel/src/test/java/org/apache/ignite/stream/camel/IgniteCamelStreamerTestSuite.java
=>
core/src/main/java/org/apache/ignite/spi/communication/tcp/internal/FirstConnectionPolicy.java}
(73%)
create mode 100644
modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/internal/GridNioServerWrapper.java
create mode 100644
modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/internal/HandshakeTimeoutObject.java
create mode 100644
modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/internal/InboundConnectionHandler.java
rename
modules/{camel/src/test/java/org/apache/ignite/stream/camel/IgniteCamelStreamerTestSuite.java
=>
core/src/main/java/org/apache/ignite/spi/communication/tcp/internal/RoundRobinConnectionPolicy.java}
(57%)
create mode 100644
modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/internal/TcpCommunicationConfigInitializer.java
create mode 100644
modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/internal/TcpCommunicationConfiguration.java
create mode 100644
modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/internal/TcpCommunicationSpiMBeanImpl.java
create mode 100644
modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/internal/shmem/SHMemHandshakeClosure.java
create mode 100644
modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/internal/shmem/ShmemAcceptWorker.java
create mode 100644
modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/internal/shmem/ShmemWorker.java
create mode 100644
modules/core/src/test/java/org/apache/ignite/internal/processors/cache/SysCacheInconsistencyInternalKeyTest.java
create mode 100644
modules/core/src/test/java/org/apache/ignite/internal/processors/cache/persistence/db/RebalanceBlockingSPI.java
create mode 100644
modules/core/src/test/java/org/apache/ignite/spi/communication/tcp/GridTcpCommunicationSpiLogTest.java
delete mode 100644
modules/zookeeper/src/main/java/org/apache/ignite/spi/discovery/zk/internal/ZkPinger.java
