Path	Lines of Code
cassandra/src/test/bootstrap/automated/cleaner.py	30
cassandra/src/test/bootstrap/automated/common.py	58
cassandra/src/test/bootstrap/automated/common_exceptions.py	2
cassandra/src/test/bootstrap/automated/configuration.py	121
cassandra/src/test/bootstrap/automated/java_properties.py	29
cassandra/src/test/bootstrap/automated/load_test.py	117
cassandra/src/test/bootstrap/automated/node_type.py	23
cassandra/src/test/bootstrap/automated/preparation.py	230
cassandra/src/test/bootstrap/automated/ssh_client.py	164
cassandra/src/test/bootstrap/automated/starters.py	207
cassandra/src/test/bootstrap/automated/util.py	49
cassandra/src/test/java/org/apache/ignite/activestore/BaseCacheStoreTest.java	133
cassandra/src/test/java/org/apache/ignite/activestore/cli/ACSShell.java	90
cassandra/src/test/java/org/apache/ignite/activestore/cli/CommandServiceCLIAware.java	55
cassandra/src/test/java/org/apache/ignite/activestore/cluster/DefaultOneProcessClusterManager.java	19
cassandra/src/test/java/org/apache/ignite/activestore/cluster/IgniteClusterManager.java	7
cassandra/src/test/java/org/apache/ignite/activestore/cluster/IgniteConfigHelper.java	20
cassandra/src/test/java/org/apache/ignite/activestore/cluster/OneProcessClusterManager.java	13
cassandra/src/test/java/org/apache/ignite/activestore/cluster/SeparateProcessesClusterManager.java	73
cassandra/src/test/java/org/apache/ignite/activestore/cluster/XmlOneProcessClusterManager.java	13
cassandra/src/test/java/org/apache/ignite/activestore/complex/ConcurrentOperationsTest.java	364
cassandra/src/test/java/org/apache/ignite/activestore/complex/EvictionPolicyTest.java	118
cassandra/src/test/java/org/apache/ignite/activestore/complex/ExpiryPolicyTest.java	133
cassandra/src/test/java/org/apache/ignite/activestore/complex/TransactionIsolationTest.java	225
cassandra/src/test/java/org/apache/ignite/activestore/config/InMemoryActiveStoreConfiguration.java	35
cassandra/src/test/java/org/apache/ignite/activestore/config/SingletonDataSourceFactory.java	9
cassandra/src/test/java/org/apache/ignite/activestore/impl/InMemoryIdSequencer.java	9
cassandra/src/test/java/org/apache/ignite/activestore/impl/InMemoryKeyValueProvider.java	100
cassandra/src/test/java/org/apache/ignite/activestore/impl/InMemoryStorage.java	38
cassandra/src/test/java/org/apache/ignite/activestore/impl/noop/NoOpKeyValueProvider.java	38
cassandra/src/test/java/org/apache/ignite/activestore/impl/noop/NoOpStoreConfiguration.java	34
cassandra/src/test/java/org/apache/ignite/activestore/impl/quasi/FakeKafkaProducer.java	38
cassandra/src/test/java/org/apache/ignite/activestore/impl/quasi/Function.java	4
cassandra/src/test/java/org/apache/ignite/activestore/impl/quasi/KafkaProducerFactory.java	14
cassandra/src/test/java/org/apache/ignite/activestore/impl/quasi/QuasiKafkaKeyValueProvider.java	126
cassandra/src/test/java/org/apache/ignite/activestore/impl/quasi/QuasiKafkaStoreConfiguration.java	51
cassandra/src/test/java/org/apache/ignite/activestore/impl/quasi/SleepFuture.java	40
cassandra/src/test/java/org/apache/ignite/activestore/impl/subscriber/lead/LeadPlannerTest.java	240
cassandra/src/test/java/org/apache/ignite/activestore/investigation/replication/TxInfo.java	17
cassandra/src/test/java/org/apache/ignite/activestore/investigation/replication/TxInfoGenerator.java	41
cassandra/src/test/java/org/apache/ignite/activestore/load/ClusterStopper.java	29
cassandra/src/test/java/org/apache/ignite/activestore/load/Generator.java	4
cassandra/src/test/java/org/apache/ignite/activestore/load/IgniteStarter.java	7
cassandra/src/test/java/org/apache/ignite/activestore/load/LoadTestConfig.java	136
cassandra/src/test/java/org/apache/ignite/activestore/load/LoadTestDriver.java	242
cassandra/src/test/java/org/apache/ignite/activestore/load/LoadTestDriversCoordinator.java	57
cassandra/src/test/java/org/apache/ignite/activestore/load/LoadTestsCassandraCleaner.java	15
cassandra/src/test/java/org/apache/ignite/activestore/load/ServerSideEntryProcessor.java	38
cassandra/src/test/java/org/apache/ignite/activestore/load/TestsHelper.java	124
cassandra/src/test/java/org/apache/ignite/activestore/load/Worker.java	228
cassandra/src/test/java/org/apache/ignite/activestore/load/WorkerEntryProcessor.java	5
cassandra/src/test/java/org/apache/ignite/activestore/load/generators/LongGenerator.java	7
cassandra/src/test/java/org/apache/ignite/activestore/load/generators/StringGenerator.java	7
cassandra/src/test/java/org/apache/ignite/activestore/load/simulation/Account.java	24
cassandra/src/test/java/org/apache/ignite/activestore/load/simulation/AccountKey.java	30
cassandra/src/test/java/org/apache/ignite/activestore/load/simulation/AccountTransaction.java	28
cassandra/src/test/java/org/apache/ignite/activestore/load/simulation/AccountTransactionKey.java	32
cassandra/src/test/java/org/apache/ignite/activestore/load/simulation/SimulationLoadTest.java	29
cassandra/src/test/java/org/apache/ignite/activestore/load/simulation/SimulationLoadTestDriver.java	51
cassandra/src/test/java/org/apache/ignite/activestore/load/simulation/SimulationUtil.java	216
cassandra/src/test/java/org/apache/ignite/activestore/load/simulation/SimulationWorker.java	34
cassandra/src/test/java/org/apache/ignite/activestore/load/simulation/TransactionData.java	30
cassandra/src/test/java/org/apache/ignite/activestore/load/simulation/TransactionDataGenerator.java	43
cassandra/src/test/java/org/apache/ignite/activestore/load/statistics/HumanReadableCsvReporter.java	201
cassandra/src/test/java/org/apache/ignite/activestore/load/statistics/IgniteNodeOverloadReporter.java	129
cassandra/src/test/java/org/apache/ignite/activestore/load/statistics/LoadTestsStatisticsDriver.java	24
cassandra/src/test/java/org/apache/ignite/activestore/load/statistics/Statistics.java	141
cassandra/src/test/java/org/apache/ignite/activestore/load/statistics/StatisticsCollector.java	61
cassandra/src/test/java/org/apache/ignite/activestore/load/statistics/StatisticsCollectorBuilder.java	67
cassandra/src/test/java/org/apache/ignite/activestore/load/workers/BulkReadWorker.java	31
cassandra/src/test/java/org/apache/ignite/activestore/load/workers/BulkWriteWorker.java	31
cassandra/src/test/java/org/apache/ignite/activestore/load/workers/ReadWorker.java	33
cassandra/src/test/java/org/apache/ignite/activestore/load/workers/WriteWorker.java	33
cassandra/src/test/java/org/apache/ignite/activestore/rules/CassandraRule.java	56
cassandra/src/test/java/org/apache/ignite/activestore/rules/EmbeddedKafkaRule.java	73
cassandra/src/test/java/org/apache/ignite/activestore/rules/MeteredResource.java	16
cassandra/src/test/java/org/apache/ignite/activestore/rules/TestResourceFactory.java	7
cassandra/src/test/java/org/apache/ignite/activestore/rules/TestResources.java	196
cassandra/src/test/java/org/apache/ignite/activestore/simple/ActiveCacheStoreTest.java	171
cassandra/src/test/java/org/apache/ignite/activestore/simple/AtomicACSTest.java	78
cassandra/src/test/java/org/apache/ignite/activestore/simple/AtomicPartitionedACSTest.java	11
cassandra/src/test/java/org/apache/ignite/activestore/simple/AtomicPartitionedWriteBehindACSTest.java	13
cassandra/src/test/java/org/apache/ignite/activestore/simple/AtomicReplicatedACSTest.java	11
cassandra/src/test/java/org/apache/ignite/activestore/simple/AtomicReplicatedWriteBehindACSTest.java	13
cassandra/src/test/java/org/apache/ignite/activestore/simple/AtomicWriteBehindACSTest.java	46
cassandra/src/test/java/org/apache/ignite/activestore/simple/CommandServiceOperationsTest.java	12
cassandra/src/test/java/org/apache/ignite/activestore/simple/ExportTest.java	349
cassandra/src/test/java/org/apache/ignite/activestore/simple/MergeTest.java	99
cassandra/src/test/java/org/apache/ignite/activestore/simple/RollbackTest.java	138
cassandra/src/test/java/org/apache/ignite/activestore/simple/TransactionalACSTest.java	78
cassandra/src/test/java/org/apache/ignite/activestore/simple/TransactionalPartitionedACSTest.java	11
cassandra/src/test/java/org/apache/ignite/activestore/simple/TransactionalPartitionedWriteBehindACSTest.java	11
cassandra/src/test/java/org/apache/ignite/activestore/simple/TransactionalReplicatedACSTest.java	11
cassandra/src/test/java/org/apache/ignite/activestore/simple/TransactionalReplicatedWriteBehindACSTest.java	13
cassandra/src/test/java/org/apache/ignite/activestore/simple/TransactionalWriteBehindACSTest.java	46
cassandra/src/test/java/org/apache/ignite/activestore/simple/WriteBehindACSTest.java	115
cassandra/src/test/java/org/apache/ignite/activestore/suites/ActiveCacheStoreCassandraTestSuite.java	39
cassandra/src/test/java/org/apache/ignite/activestore/suites/ActiveCacheStoreInMemoryTestSuite.java	8
cassandra/src/test/java/org/apache/ignite/activestore/suites/ActiveCacheStoreXmlConfigCassandraTestSuite.java	25
cassandra/src/test/java/org/apache/ignite/activestore/suites/ActiveCacheStoreXmlConfigInMemoryTestSuite.java	12
cassandra/src/test/java/org/apache/ignite/activestore/suites/ActiveCacheStoreXmlConfigKafkaSuite.java	17
cassandra/src/test/java/org/apache/ignite/activestore/suites/BasicTestSuite.java	38
cassandra/src/test/java/org/apache/ignite/activestore/utils/CassandraAdminCredentials.java	11
cassandra/src/test/java/org/apache/ignite/activestore/utils/CassandraHelper.java	268
cassandra/src/test/java/org/apache/ignite/activestore/utils/CassandraLifeCycleBean.java	82
cassandra/src/test/java/org/apache/ignite/activestore/utils/CassandraRegularCredentials.java	11
cassandra/src/test/resources/ignite-sample-cassandra-config.xml	64
cassandra/src/test/resources/ignite-sample-inmemory-config.xml	49
cassandra/src/test/resources/ignite-sample-kafka-config.xml	66
cassandra/src/test/resources/ignite-sample-kafka-dr-config.xml	86
cassandra/src/test/resources/load-test-config.xml	61
cassandra/src/test/resources/org/apache/ignite/activestore/tests/cassandra/connection-settings.xml	30
cassandra/src/test/resources/org/apache/ignite/activestore/tests/cassandra/embedded-cassandra.yaml	98
cassandra/src/test/resources/shell-ignite.xml	23
cassandra/src/test/scripts/acs-shell.bat	21
cassandra/src/test/scripts/acs-shell.sh	4
cassandra/src/test/scripts/drop-test-keyspace.bat	31
cassandra/src/test/scripts/drop-test-keyspace.sh	18
cassandra/src/test/scripts/ignite-load-tests.bat	33
cassandra/src/test/scripts/ignite-load-tests.sh	18
cassandra/src/test/scripts/jvm-opt.sh	3
cassandra/src/test/scripts/jvm-opts.bat	21
cassandra/src/test/scripts/simulation-load-test.bat	34
cassandra/src/test/scripts/simulation-load-test.sh	17
cassandra/src/test/scripts/start-ignite.bat	34
cassandra/src/test/scripts/start-ignite.sh	17
cassandra/src/test/scripts/start-statistics-driver.bat	32
cassandra/src/test/scripts/start-statistics-driver.sh	16
cassandra/src/test/scripts/stop-cluster.bat	33
cassandra/src/test/scripts/stop-cluster.sh	16
core/src/test/bootstrap/automated/cleaner.py	30
core/src/test/bootstrap/automated/common.py	58
core/src/test/bootstrap/automated/common_exceptions.py	2
core/src/test/bootstrap/automated/configuration.py	121
core/src/test/bootstrap/automated/java_properties.py	29
core/src/test/bootstrap/automated/load_test.py	117
core/src/test/bootstrap/automated/node_type.py	23
core/src/test/bootstrap/automated/preparation.py	230
core/src/test/bootstrap/automated/ssh_client.py	164
core/src/test/bootstrap/automated/starters.py	207
core/src/test/bootstrap/automated/util.py	49
core/src/test/java/org/apache/ignite/activestore/BaseReplicationIntegrationTest.java	18
core/src/test/java/org/apache/ignite/activestore/cluster/DefaultOneProcessClusterManager.java	19
core/src/test/java/org/apache/ignite/activestore/cluster/IgniteClusterManager.java	6
core/src/test/java/org/apache/ignite/activestore/cluster/IgniteConfigHelper.java	20
core/src/test/java/org/apache/ignite/activestore/cluster/XmlOneProcessClusterManager.java	12
core/src/test/java/org/apache/ignite/activestore/commons/InMemoryReference.java	21
core/src/test/java/org/apache/ignite/activestore/commons/injection/InjectionForTests.java	7
core/src/test/java/org/apache/ignite/activestore/commons/tasks/SchedulerUnitTest.java	32
core/src/test/java/org/apache/ignite/activestore/impl/TestDCBConfiguration.java	62
core/src/test/java/org/apache/ignite/activestore/impl/publisher/LastTransactionListener.java	31
core/src/test/java/org/apache/ignite/activestore/impl/subscriber/KafkaFactoryForTests.java	31
core/src/test/java/org/apache/ignite/activestore/impl/subscriber/ReceivedTransactionsListener.java	7
core/src/test/java/org/apache/ignite/activestore/impl/subscriber/ReceivedTransactionsListenerImpl.java	56
core/src/test/java/org/apache/ignite/activestore/impl/subscriber/consumer/AbstractIgniteCommitterUnitTest.java	172
core/src/test/java/org/apache/ignite/activestore/impl/subscriber/consumer/ConsumerAdapter.java	91
core/src/test/java/org/apache/ignite/activestore/impl/subscriber/consumer/ConsumerForTests.java	123
core/src/test/java/org/apache/ignite/activestore/impl/subscriber/consumer/IgniteCommitterUnitTest.java	9
core/src/test/java/org/apache/ignite/activestore/impl/subscriber/consumer/OffsetCalculatorUnitTest.java	72
core/src/test/java/org/apache/ignite/activestore/impl/subscriber/consumer/ParallelIgniteCommitterUnitTest.java	11
core/src/test/java/org/apache/ignite/activestore/impl/subscriber/lead/DoubleLeadService.java	55
core/src/test/java/org/apache/ignite/activestore/impl/subscriber/lead/FastConsumerPingCheckStrategy.java	7
core/src/test/java/org/apache/ignite/activestore/impl/subscriber/lead/LeadContextLoaderUnitTest.java	51
core/src/test/java/org/apache/ignite/activestore/impl/subscriber/lead/LeadPlannerUnitTest.java	379
core/src/test/java/org/apache/ignite/activestore/impl/subscriber/lead/LeadServiceAdapter.java	50
core/src/test/java/org/apache/ignite/activestore/impl/subscriber/lead/LeadServiceForTests.java	14
core/src/test/java/org/apache/ignite/activestore/impl/subscriber/lead/MergeHelperUnitTest.java	106
core/src/test/java/org/apache/ignite/activestore/mocked/mocks/InputProducer.java	33
core/src/test/java/org/apache/ignite/activestore/mocked/mocks/KafkaMockFactory.java	105
core/src/test/java/org/apache/ignite/activestore/mocked/mocks/MockRPCManager.java	23
core/src/test/java/org/apache/ignite/activestore/mocked/mocks/MockRPCService.java	67
core/src/test/java/org/apache/ignite/activestore/mocked/mocks/ProxyMockConsumer.java	41
core/src/test/java/org/apache/ignite/activestore/mocked/tests/BaseFunctionalTest.java	66
core/src/test/java/org/apache/ignite/activestore/mocked/tests/BufferOverflowFunctionalTest.java	25
core/src/test/java/org/apache/ignite/activestore/mocked/tests/CrashFunctionalTest.java	76
core/src/test/java/org/apache/ignite/activestore/mocked/tests/DRClusterFunctionalTest.java	62
core/src/test/java/org/apache/ignite/activestore/mocked/tests/LeadAndKafkaOutOfOrderFunctionalTest.java	40
core/src/test/java/org/apache/ignite/activestore/mocked/tests/LeadAndMainOutOfOrderFunctionalTest.java	119
core/src/test/java/org/apache/ignite/activestore/replication/BasicSynchronousReplicationIntegrationTest.java	96
core/src/test/java/org/apache/ignite/activestore/replication/ConsumerOutOfOrderIntegrationTest.java	167
core/src/test/java/org/apache/ignite/activestore/replication/IdSequencerIntegrationTest.java	93
core/src/test/java/org/apache/ignite/activestore/replication/LeadAndKafkaOutOfOrderIntegrationTest.java	103
core/src/test/java/org/apache/ignite/activestore/replication/LeadOutOfOrderIntegrationTest.java	185
core/src/test/java/org/apache/ignite/activestore/replication/SynchronousReplicationIntegrationTest.java	52
core/src/test/java/org/apache/ignite/activestore/rules/EmbeddedKafkaRule.java	139
core/src/test/java/org/apache/ignite/activestore/rules/FullClusterTestResourcesFactory.java	51
core/src/test/java/org/apache/ignite/activestore/rules/IgniteClusterCleanupRule.java	61
core/src/test/java/org/apache/ignite/activestore/rules/MeteredResource.java	26
core/src/test/java/org/apache/ignite/activestore/rules/SingleClusterResource.java	30
core/src/test/java/org/apache/ignite/activestore/rules/SuperClusterResource.java	17
core/src/test/java/org/apache/ignite/activestore/rules/TestResources.java	30
core/src/test/java/org/apache/ignite/activestore/suites/ActiveCacheStoreReplicationIntegrationTestSuite.java	23
core/src/test/java/org/apache/ignite/activestore/suites/FunctionalTestSuite.java	21
core/src/test/java/org/apache/ignite/activestore/suites/UnitTestSuite.java	22
core/src/test/java/org/apache/ignite/load/ClusterStopper.java	33
core/src/test/java/org/apache/ignite/load/EntriesProcessingTask.java	36
core/src/test/java/org/apache/ignite/load/Generator.java	4
core/src/test/java/org/apache/ignite/load/IgniteStarter.java	6
core/src/test/java/org/apache/ignite/load/LoadGeneratingClient.java	17
core/src/test/java/org/apache/ignite/load/LoadTestConfig.java	120
core/src/test/java/org/apache/ignite/load/LoadTestDCBConfiguration.java	59
core/src/test/java/org/apache/ignite/load/LoadTestDriver.java	163
core/src/test/java/org/apache/ignite/load/LoadTestDriversCoordinator.java	64
core/src/test/java/org/apache/ignite/load/LoadTestsStatisticsDriver.java	19
core/src/test/java/org/apache/ignite/load/LongGenerator.java	7
core/src/test/java/org/apache/ignite/load/PropertiesParser.java	33
core/src/test/java/org/apache/ignite/load/ServerSideEntryProcessor.java	19
core/src/test/java/org/apache/ignite/load/TestsHelper.java	69
core/src/test/java/org/apache/ignite/load/Worker.java	232
core/src/test/java/org/apache/ignite/load/WorkerEntryProcessor.java	5
core/src/test/java/org/apache/ignite/load/WorkerThread.java	45
core/src/test/java/org/apache/ignite/load/simulation/Account.java	24
core/src/test/java/org/apache/ignite/load/simulation/AccountKey.java	30
core/src/test/java/org/apache/ignite/load/simulation/AccountTransaction.java	27
core/src/test/java/org/apache/ignite/load/simulation/AccountTransactionKey.java	32
core/src/test/java/org/apache/ignite/load/simulation/SimulationEntryProcessor.java	22
core/src/test/java/org/apache/ignite/load/simulation/SimulationLoadTestDriver.java	31
core/src/test/java/org/apache/ignite/load/simulation/SimulationTxProcessor.java	82
core/src/test/java/org/apache/ignite/load/simulation/SimulationUtil.java	148
core/src/test/java/org/apache/ignite/load/simulation/TransactionData.java	31
core/src/test/java/org/apache/ignite/load/simulation/TransactionDataGenerator.java	43
core/src/test/java/org/apache/ignite/load/simulation/dr/KafkaWritingEntryProcessor.java	101
core/src/test/java/org/apache/ignite/load/simulation/dr/SingleCommitNotificationSniffingLeadService.java	23
core/src/test/java/org/apache/ignite/load/simulation/main/MainLoadTestDriver.java	26
core/src/test/java/org/apache/ignite/load/statistics/ExecutorManager.java	32
core/src/test/java/org/apache/ignite/load/statistics/LocalStatisticsUpdater.java	22
core/src/test/java/org/apache/ignite/load/statistics/OperationBoundTime.java	21
core/src/test/java/org/apache/ignite/load/statistics/OperationBoundType.java	4
core/src/test/java/org/apache/ignite/load/statistics/RemoteStatisticsUpdater.java	24
core/src/test/java/org/apache/ignite/load/statistics/RemoteStatisticsUpdaterManager.java	35
core/src/test/java/org/apache/ignite/load/statistics/RemoteStatisticsUpdaterStartTask.java	26
core/src/test/java/org/apache/ignite/load/statistics/Statistics.java	29
core/src/test/java/org/apache/ignite/load/statistics/StatisticsCollector.java	78
core/src/test/java/org/apache/ignite/load/statistics/StatisticsConfig.java	97
core/src/test/java/org/apache/ignite/load/statistics/StatisticsConfigHelper.java	51
core/src/test/java/org/apache/ignite/load/statistics/StatisticsDriver.java	71
core/src/test/java/org/apache/ignite/load/statistics/StatisticsModule.java	54
core/src/test/java/org/apache/ignite/load/statistics/StatisticsUpdater.java	40
core/src/test/java/org/apache/ignite/load/statistics/UpdateStatisticsTask.java	30
core/src/test/java/org/apache/ignite/load/statistics/reporters/AdvancedReporter.java	41
core/src/test/java/org/apache/ignite/load/statistics/reporters/DebugReporterProvider.java	22
core/src/test/java/org/apache/ignite/load/statistics/reporters/GangliaReporterProvider.java	35
core/src/test/java/org/apache/ignite/load/statistics/reporters/HumanReadableCsvReporter.java	130
core/src/test/java/org/apache/ignite/load/statistics/reporters/HumanReadableCsvReporterProvider.java	25
core/src/test/java/org/apache/ignite/load/statistics/reporters/IgniteNodeOverloadReporter.java	74
core/src/test/java/org/apache/ignite/load/statistics/reporters/IgniteNodeOverloadReporterProvider.java	29
core/src/test/java/org/apache/ignite/load/statistics/reporters/ReporterProvider.java	5
core/src/test/java/org/apache/ignite/load/statistics/reporters/ReportersManager.java	34
core/src/test/java/org/apache/ignite/load/subscriber/BaseLeadLoadTest.java	68
core/src/test/java/org/apache/ignite/load/subscriber/DependentPairsTxGenerator.java	14
core/src/test/java/org/apache/ignite/load/subscriber/ImmediateCommitResponseProcessor.java	19
core/src/test/java/org/apache/ignite/load/subscriber/IndependentTxGenerator.java	8
core/src/test/java/org/apache/ignite/load/subscriber/LeadLoadTest.java	50
core/src/test/java/org/apache/ignite/load/subscriber/LeadLoadTestConfiguration.java	85
core/src/test/java/org/apache/ignite/load/subscriber/LeadLoadWorker.java	96
core/src/test/java/org/apache/ignite/load/subscriber/LeadResponseProcessor.java	6
core/src/test/java/org/apache/ignite/load/subscriber/ListOfProviders.java	25
core/src/test/java/org/apache/ignite/load/subscriber/NoOpListener.java	11
core/src/test/java/org/apache/ignite/load/subscriber/TotalDependentTxGenerator.java	9
core/src/test/java/org/apache/ignite/load/subscriber/TxIdGenerator.java	21
core/src/test/java/org/apache/ignite/load/subscriber/TxMetadataGenerator.java	15
core/src/test/java/org/apache/ignite/load/subscriber/WorkerProvider.java	40
core/src/test/java/org/apache/ignite/load/subscriber/WorkersScheduler.java	33
core/src/test/resources/functional/single-dr-cluster-mocked-kafka.xml	78
core/src/test/resources/load/base-cluster-config.xml	60
core/src/test/resources/load/dr-cluster-config.xml	40
core/src/test/resources/load/lead-load-test-config.xml	60
core/src/test/resources/load/main-cluster-config.xml	33
core/src/test/resources/replication/ignite-base-cluster-config.xml	49
core/src/test/resources/replication/ignite-dr-cluster-config.xml	69
core/src/test/resources/replication/ignite-main-cluster-config.xml	52
core/src/test/scripts/jvm-opt.sh	3
core/src/test/scripts/jvm-opts.bat	21
core/src/test/scripts/simulation-load-test.bat	34
core/src/test/scripts/simulation-load-test.sh	17
core/src/test/scripts/start-ignite.bat	34
core/src/test/scripts/start-ignite.sh	17
core/src/test/scripts/start-statistics-driver.bat	32
core/src/test/scripts/start-statistics-driver.sh	16
core/src/test/scripts/stop-cluster.bat	33
core/src/test/scripts/stop-cluster.sh	16
lagerta-core/src/test/java/com/epam/lagerta/BaseFunctionalTest.java	64
lagerta-core/src/test/java/com/epam/lagerta/BaseIntegrationTest.java	58
lagerta-core/src/test/java/com/epam/lagerta/BaseMultiJVMIntegrationTest.java	32
lagerta-core/src/test/java/com/epam/lagerta/BaseSingleJVMIntegrationTest.java	16
lagerta-core/src/test/java/com/epam/lagerta/IgniteConfigurer.java	18
lagerta-core/src/test/java/com/epam/lagerta/ServiceFilterPredicate.java	11
lagerta-core/src/test/java/com/epam/lagerta/base/jdbc/DataProviders.java	96
lagerta-core/src/test/java/com/epam/lagerta/base/jdbc/EntityDescriptors.java	23
lagerta-core/src/test/java/com/epam/lagerta/base/jdbc/JDBCUtil.java	105
lagerta-core/src/test/java/com/epam/lagerta/base/jdbc/committer/JDBCBaseFunctionalTest.java	45
lagerta-core/src/test/java/com/epam/lagerta/base/jdbc/committer/JDBCCommitterFunctionalTest.java	56
lagerta-core/src/test/java/com/epam/lagerta/base/jdbc/committer/SQLSupplier.java	5
lagerta-core/src/test/java/com/epam/lagerta/base/jdbc/common/KeyValueAndMetadata.java	61
lagerta-core/src/test/java/com/epam/lagerta/base/jdbc/common/OtherTypesHolder.java	134
lagerta-core/src/test/java/com/epam/lagerta/base/jdbc/common/PrimitiveWrappersHolder.java	133
lagerta-core/src/test/java/com/epam/lagerta/base/jdbc/common/PrimitivesFieldConstants.java	41
lagerta-core/src/test/java/com/epam/lagerta/base/jdbc/common/PrimitivesHolder.java	134
lagerta-core/src/test/java/com/epam/lagerta/capturer/DataCaptureBusUnitTest.java	64
lagerta-core/src/test/java/com/epam/lagerta/capturer/JDBCDataCapturerLoaderFunctionalTest.java	100
lagerta-core/src/test/java/com/epam/lagerta/capturer/JDBCDataCapturerLoaderIntegrationTest.java	75
lagerta-core/src/test/java/com/epam/lagerta/capturer/NopeDataCapturerLoader.java	14
lagerta-core/src/test/java/com/epam/lagerta/cluster/AppContextOneProcessClusterManager.java	22
lagerta-core/src/test/java/com/epam/lagerta/cluster/BaseIgniteClusterManager.java	39
lagerta-core/src/test/java/com/epam/lagerta/cluster/DefaultOneProcessClusterManager.java	40
lagerta-core/src/test/java/com/epam/lagerta/cluster/DifferentJVMClusterManager.java	99
lagerta-core/src/test/java/com/epam/lagerta/cluster/IgniteStarter.java	13
lagerta-core/src/test/java/com/epam/lagerta/cluster/IgniteStopper.java	45
lagerta-core/src/test/java/com/epam/lagerta/cluster/SimpleOneProcessClusterManager.java	18
lagerta-core/src/test/java/com/epam/lagerta/cluster/XmlOneProcessClusterManager.java	15
lagerta-core/src/test/java/com/epam/lagerta/common/PeriodicRuleUnitTest.java	16
lagerta-core/src/test/java/com/epam/lagerta/common/SchedulerUnitTest.java	30
lagerta-core/src/test/java/com/epam/lagerta/kafka/KafkaFactoryForTests.java	119
lagerta-core/src/test/java/com/epam/lagerta/mocks/InMemoryIdSequencer.java	10
lagerta-core/src/test/java/com/epam/lagerta/mocks/InputProducer.java	46
lagerta-core/src/test/java/com/epam/lagerta/mocks/KafkaMockFactory.java	116
lagerta-core/src/test/java/com/epam/lagerta/mocks/LeadStateAssistantMock.java	13
lagerta-core/src/test/java/com/epam/lagerta/mocks/ProxyMockConsumer.java	46
lagerta-core/src/test/java/com/epam/lagerta/mocks/ProxyReconciler.java	29
lagerta-core/src/test/java/com/epam/lagerta/resources/DBResourceFactory.java	18
lagerta-core/src/test/java/com/epam/lagerta/resources/FullClusterResource.java	52
lagerta-core/src/test/java/com/epam/lagerta/subscriber/CommittedOffsetUnitTest.java	41
lagerta-core/src/test/java/com/epam/lagerta/subscriber/InCacheCommitter.java	24
lagerta-core/src/test/java/com/epam/lagerta/subscriber/InCacheKafkaLogCommitter.java	20
lagerta-core/src/test/java/com/epam/lagerta/subscriber/ParallelCommitStrategyUnitTest.java	93
lagerta-core/src/test/java/com/epam/lagerta/subscriber/ReaderFunctionalTest.java	42
lagerta-core/src/test/java/com/epam/lagerta/subscriber/SequentialCommitStrategyUnitTest.java	126
lagerta-core/src/test/java/com/epam/lagerta/subscriber/StatefulCommitter.java	28
lagerta-core/src/test/java/com/epam/lagerta/subscriber/SubscriberFunctionalTest.java	46
lagerta-core/src/test/java/com/epam/lagerta/subscriber/SubscriberIntegrationTest.java	107
lagerta-core/src/test/java/com/epam/lagerta/subscriber/TestReaderConfig.java	38
lagerta-core/src/test/java/com/epam/lagerta/subscriber/lead/CommittedTransactionsUnitTest.java	58
lagerta-core/src/test/java/com/epam/lagerta/subscriber/lead/LeadImplFatUnitTest.java	183
lagerta-core/src/test/java/com/epam/lagerta/subscriber/lead/LeadReinitionIntegrationTest.java	88
lagerta-core/src/test/java/com/epam/lagerta/subscriber/lead/ReadTransactionsUnitTest.java	281
lagerta-core/src/test/java/com/epam/lagerta/subscriber/util/MergeUtilUnitTest.java	59
lagerta-core/src/test/java/com/epam/lagerta/subscriber/util/PlannerUtilUnitTest.java	212
lagerta-core/src/test/java/com/epam/lagerta/util/DataProviderUtil.java	55
lagerta-core/src/test/java/com/epam/lagerta/util/JDBCKeyValueMapperUnitTest.java	187
lagerta-core/src/test/resources/com/epam/lagerta/base/jdbc/committer/create_tables.sql	30
lagerta-core/src/test/resources/com/epam/lagerta/base/jdbc/committer/drop_tables.sql	3
lagerta-core/src/test/resources/com/epam/lagerta/functional/config.xml	134
lagerta-core/src/test/resources/com/epam/lagerta/integration/base-config.xml	174
lagerta-core/src/test/resources/com/epam/lagerta/integration/client-config.xml	19
lagerta-core/src/test/resources/com/epam/lagerta/integration/server-config.xml	18
lagerta-core/src/test/resources/logback-test.xml	24
lagerta-core/src/test/resources/test-suites/different-jvm-integration-tests.xml	8
lagerta-core/src/test/resources/test-suites/functional-tests.xml	12
lagerta-core/src/test/resources/test-suites/integration-tests.xml	8
lagerta-core/src/test/resources/test-suites/master-suite.xml	8
lagerta-core/src/test/resources/test-suites/single-jvm-integration-tests.xml	10
lagerta-core/src/test/resources/test-suites/unit-tests.xml	20
lagerta-jepsen/test/jepsen/lagerta/core_test.clj	6