You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@omid.apache.org by ik...@apache.org on 2016/04/21 02:03:02 UTC
[45/52] [abbrv] incubator-omid git commit: Merge pull request #90
from yahoo/PR-yahoo-apache
Merge pull request #90 from yahoo/PR-yahoo-apache
Move com.yahoo -> org.apache
Project: http://git-wip-us.apache.org/repos/asf/incubator-omid/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-omid/commit/fd8ca18b
Tree: http://git-wip-us.apache.org/repos/asf/incubator-omid/tree/fd8ca18b
Diff: http://git-wip-us.apache.org/repos/asf/incubator-omid/diff/fd8ca18b
Branch: refs/heads/master
Commit: fd8ca18b3bc95883feeb1011c9d8a280265f613c
Parents: 5734cac 9cd856c
Author: Francisco Pérez-Sorrosal <fp...@gmail.com>
Authored: Fri Apr 15 16:10:42 2016 -0700
Committer: Francisco Pérez-Sorrosal <fp...@gmail.com>
Committed: Fri Apr 15 16:10:42 2016 -0700
----------------------------------------------------------------------
.gitignore | 2 +-
benchmarks/bin/benchmarks.sh | 2 +-
benchmarks/pom.xml | 10 +-
.../hbase/HBaseCommitTableTester.java | 137 --
.../yahoo/omid/benchmarks/tso/RawTxRunner.java | 301 ----
.../omid/benchmarks/tso/TSOServerBenchmark.java | 138 --
.../tso/TSOServerBenchmarkConfig.java | 160 ---
.../yahoo/omid/benchmarks/utils/Generator.java | 36 -
.../omid/benchmarks/utils/IntegerGenerator.java | 71 -
.../utils/ScrambledZipfianGenerator.java | 153 ---
.../omid/benchmarks/utils/UniformGenerator.java | 36 -
.../omid/benchmarks/utils/ZipfianGenerator.java | 298 ----
.../hbase/HBaseCommitTableTester.java | 137 ++
.../apache/omid/benchmarks/tso/RawTxRunner.java | 301 ++++
.../omid/benchmarks/tso/TSOServerBenchmark.java | 138 ++
.../tso/TSOServerBenchmarkConfig.java | 160 +++
.../apache/omid/benchmarks/utils/Generator.java | 30 +
.../omid/benchmarks/utils/IntegerGenerator.java | 65 +
.../utils/ScrambledZipfianGenerator.java | 147 ++
.../omid/benchmarks/utils/UniformGenerator.java | 36 +
.../omid/benchmarks/utils/ZipfianGenerator.java | 292 ++++
.../default-tso-server-benchmark-config.yml | 20 +-
codahale-metrics/pom.xml | 4 +-
.../omid/metrics/CodahaleMetricsConfig.java | 100 --
.../omid/metrics/CodahaleMetricsProvider.java | 346 -----
.../omid/metrics/CodahaleMetricsConfig.java | 100 ++
.../omid/metrics/CodahaleMetricsProvider.java | 346 +++++
commit-table/pom.xml | 2 +-
.../com/yahoo/omid/committable/CommitTable.java | 113 --
.../omid/committable/InMemoryCommitTable.java | 143 --
.../yahoo/omid/committable/NullCommitTable.java | 91 --
.../apache/omid/committable/CommitTable.java | 113 ++
.../omid/committable/InMemoryCommitTable.java | 143 ++
.../omid/committable/NullCommitTable.java | 91 ++
.../omid/committable/NullCommitTableTest.java | 70 -
.../omid/committable/NullCommitTableTest.java | 70 +
common/pom.xml | 2 +-
.../src/main/java/com/yahoo/omid/YAMLUtils.java | 81 --
.../main/java/com/yahoo/omid/zk/ZKUtils.java | 57 -
.../main/java/org/apache/omid/YAMLUtils.java | 81 ++
.../main/java/org/apache/omid/zk/ZKUtils.java | 57 +
common/src/main/proto/TSOProto.proto | 2 +-
.../test/java/com/yahoo/omid/YAMLUtilsTest.java | 50 -
.../java/org/apache/omid/YAMLUtilsTest.java | 50 +
examples/pom.xml | 10 +-
examples/run.sh | 6 +-
.../com/yahoo/omid/examples/BasicExample.java | 112 --
.../omid/examples/ConfigurationExample.java | 131 --
.../omid/examples/SnapshotIsolationExample.java | 174 ---
.../org/apache/omid/examples/BasicExample.java | 112 ++
.../omid/examples/ConfigurationExample.java | 131 ++
.../omid/examples/SnapshotIsolationExample.java | 174 +++
.../main/resources/hbase-omid-client-config.yml | 10 +-
examples/src/main/resources/log4j.properties | 3 +-
hbase-client/pom.xml | 18 +-
.../yahoo/omid/transaction/ColumnWrapper.java | 64 -
.../transaction/HBaseAsyncPostCommitter.java | 67 -
.../com/yahoo/omid/transaction/HBaseCellId.java | 80 --
.../HBaseOmidClientConfiguration.java | 170 ---
.../transaction/HBaseSyncPostCommitter.java | 125 --
.../omid/transaction/HBaseTransaction.java | 79 --
.../transaction/HBaseTransactionClient.java | 24 -
.../transaction/HBaseTransactionManager.java | 292 ----
.../java/com/yahoo/omid/transaction/TTable.java | 770 -----------
.../transaction/TTableCellGetterAdapter.java | 38 -
.../apache/omid/transaction/ColumnWrapper.java | 64 +
.../transaction/HBaseAsyncPostCommitter.java | 67 +
.../apache/omid/transaction/HBaseCellId.java | 80 ++
.../HBaseOmidClientConfiguration.java | 170 +++
.../transaction/HBaseSyncPostCommitter.java | 125 ++
.../omid/transaction/HBaseTransaction.java | 79 ++
.../transaction/HBaseTransactionClient.java | 24 +
.../transaction/HBaseTransactionManager.java | 292 ++++
.../org/apache/omid/transaction/TTable.java | 770 +++++++++++
.../transaction/TTableCellGetterAdapter.java | 38 +
.../default-hbase-omid-client-config.yml | 4 +-
.../yahoo/omid/transaction/OmidTestBase.java | 257 ----
.../TestAsynchronousPostCommitter.java | 323 -----
.../yahoo/omid/transaction/TestAutoFlush.java | 62 -
.../omid/transaction/TestBasicTransaction.java | 440 ------
.../yahoo/omid/transaction/TestCellUtils.java | 230 ----
.../omid/transaction/TestColumnIterator.java | 96 --
.../yahoo/omid/transaction/TestDeletion.java | 299 ----
.../TestEndToEndScenariosWithHA.java | 412 ------
.../com/yahoo/omid/transaction/TestFilters.java | 191 ---
.../TestHALeaseManagementModule.java | 75 -
.../TestHBaseOmidClientConfiguration.java | 43 -
.../transaction/TestHBaseTransactionClient.java | 465 -------
.../TestHBaseTransactionManager.java | 102 --
.../yahoo/omid/transaction/TestMultiplePut.java | 134 --
.../yahoo/omid/transaction/TestReadPath.java | 105 --
.../yahoo/omid/transaction/TestShadowCells.java | 508 -------
.../transaction/TestSingleColumnFamily.java | 108 --
.../yahoo/omid/transaction/TestTSOModule.java | 98 --
.../omid/transaction/TestTTableBehaviour.java | 155 ---
.../transaction/TestTransactionCleanup.java | 119 --
.../transaction/TestTransactionConflict.java | 308 -----
.../omid/transaction/TestTxMgrFailover.java | 353 -----
.../yahoo/omid/transaction/TestUpdateScan.java | 218 ---
.../apache/omid/transaction/OmidTestBase.java | 257 ++++
.../TestAsynchronousPostCommitter.java | 323 +++++
.../apache/omid/transaction/TestAutoFlush.java | 62 +
.../omid/transaction/TestBasicTransaction.java | 440 ++++++
.../apache/omid/transaction/TestCellUtils.java | 230 ++++
.../omid/transaction/TestColumnIterator.java | 96 ++
.../apache/omid/transaction/TestDeletion.java | 299 ++++
.../TestEndToEndScenariosWithHA.java | 412 ++++++
.../apache/omid/transaction/TestFilters.java | 191 +++
.../TestHALeaseManagementModule.java | 75 +
.../TestHBaseOmidClientConfiguration.java | 43 +
.../transaction/TestHBaseTransactionClient.java | 465 +++++++
.../TestHBaseTransactionManager.java | 102 ++
.../omid/transaction/TestMultiplePut.java | 134 ++
.../apache/omid/transaction/TestReadPath.java | 105 ++
.../omid/transaction/TestShadowCells.java | 508 +++++++
.../transaction/TestSingleColumnFamily.java | 108 ++
.../apache/omid/transaction/TestTSOModule.java | 98 ++
.../omid/transaction/TestTTableBehaviour.java | 155 +++
.../transaction/TestTransactionCleanup.java | 119 ++
.../transaction/TestTransactionConflict.java | 308 +++++
.../omid/transaction/TestTxMgrFailover.java | 353 +++++
.../apache/omid/transaction/TestUpdateScan.java | 218 +++
.../src/test/resources/log4j.properties | 13 +-
.../resources/test-hbase-omid-client-config.yml | 18 +-
hbase-commit-table/pom.xml | 12 +-
.../DefaultHBaseCommitTableStorageModule.java | 89 --
.../committable/hbase/HBaseCommitTable.java | 422 ------
.../hbase/HBaseCommitTableConfig.java | 82 --
.../hbase/HBaseCommitTableStorageModule.java | 37 -
.../DefaultHBaseCommitTableStorageModule.java | 89 ++
.../committable/hbase/HBaseCommitTable.java | 422 ++++++
.../hbase/HBaseCommitTableConfig.java | 82 ++
.../hbase/HBaseCommitTableStorageModule.java | 37 +
.../committable/hbase/TestHBaseCommitTable.java | 298 ----
.../committable/hbase/TestHBaseCommitTable.java | 298 ++++
hbase-common/pom.xml | 6 +-
.../java/com/yahoo/omid/HBaseConfigModule.java | 83 --
.../omid/committable/hbase/KeyGenerator.java | 29 -
.../hbase/KeyGeneratorImplementations.java | 160 ---
.../omid/committable/hbase/RegionSplitter.java | 259 ----
.../com/yahoo/omid/tools/hbase/HBaseLogin.java | 38 -
.../omid/tools/hbase/SecureHBaseConfig.java | 55 -
.../com/yahoo/omid/transaction/CellInfo.java | 59 -
.../com/yahoo/omid/transaction/CellUtils.java | 406 ------
.../java/org/apache/omid/HBaseConfigModule.java | 83 ++
.../omid/committable/hbase/KeyGenerator.java | 29 +
.../hbase/KeyGeneratorImplementations.java | 160 +++
.../omid/committable/hbase/RegionSplitter.java | 258 ++++
.../org/apache/omid/tools/hbase/HBaseLogin.java | 38 +
.../omid/tools/hbase/SecureHBaseConfig.java | 55 +
.../org/apache/omid/transaction/CellInfo.java | 59 +
.../org/apache/omid/transaction/CellUtils.java | 406 ++++++
.../hbase/TestHBaseCommitTableKey.java | 53 -
.../hbase/TestHBaseCommitTableKey.java | 53 +
hbase-coprocessor/pom.xml | 16 +-
.../yahoo/omid/transaction/CompactorUtil.java | 107 --
.../transaction/HRegionCellGetterAdapter.java | 39 -
.../yahoo/omid/transaction/OmidCompactor.java | 140 --
.../hbase/regionserver/CompactorScanner.java | 14 +-
.../apache/omid/transaction/CompactorUtil.java | 107 ++
.../transaction/HRegionCellGetterAdapter.java | 39 +
.../apache/omid/transaction/OmidCompactor.java | 140 ++
.../TSOForHBaseCompactorTestModule.java | 120 --
.../yahoo/omid/transaction/TestCompaction.java | 1299 ------------------
.../omid/transaction/TestCompactorScanner.java | 106 --
.../TSOForHBaseCompactorTestModule.java | 120 ++
.../apache/omid/transaction/TestCompaction.java | 1299 ++++++++++++++++++
.../omid/transaction/TestCompactorScanner.java | 106 ++
hbase-coprocessor/src/test/resources/log4j.xml | 4 +-
hbase-shims/hbase-0/pom.xml | 2 +-
.../main/java/com/yahoo/omid/HBaseShims.java | 59 -
.../main/java/org/apache/omid/HBaseShims.java | 59 +
hbase-shims/hbase-1/pom.xml | 2 +-
.../main/java/com/yahoo/omid/HBaseShims.java | 58 -
.../main/java/org/apache/omid/HBaseShims.java | 58 +
hbase-shims/pom.xml | 2 +-
hbase-tools/pom.xml | 10 +-
.../omid/tools/hbase/OmidTableManager.java | 203 ---
.../omid/tools/hbase/OmidTableManager.java | 203 +++
.../omid/tools/hbase/TestOmidTableManager.java | 119 --
.../omid/tools/hbase/TestOmidTableManager.java | 119 ++
metrics/pom.xml | 2 +-
.../omid/metrics/AbstractMetricsConfig.java | 43 -
.../java/com/yahoo/omid/metrics/Counter.java | 46 -
.../main/java/com/yahoo/omid/metrics/Gauge.java | 28 -
.../java/com/yahoo/omid/metrics/Histogram.java | 36 -
.../main/java/com/yahoo/omid/metrics/Meter.java | 34 -
.../java/com/yahoo/omid/metrics/Metric.java | 25 -
.../com/yahoo/omid/metrics/MetricsProvider.java | 41 -
.../com/yahoo/omid/metrics/MetricsRegistry.java | 61 -
.../yahoo/omid/metrics/MetricsRegistryMap.java | 105 --
.../com/yahoo/omid/metrics/MetricsUtils.java | 47 -
.../yahoo/omid/metrics/NullMetricsProvider.java | 135 --
.../main/java/com/yahoo/omid/metrics/Timer.java | 28 -
.../omid/metrics/AbstractMetricsConfig.java | 43 +
.../java/org/apache/omid/metrics/Counter.java | 46 +
.../java/org/apache/omid/metrics/Gauge.java | 28 +
.../java/org/apache/omid/metrics/Histogram.java | 36 +
.../java/org/apache/omid/metrics/Meter.java | 34 +
.../java/org/apache/omid/metrics/Metric.java | 25 +
.../apache/omid/metrics/MetricsProvider.java | 41 +
.../apache/omid/metrics/MetricsRegistry.java | 61 +
.../apache/omid/metrics/MetricsRegistryMap.java | 105 ++
.../org/apache/omid/metrics/MetricsUtils.java | 47 +
.../omid/metrics/NullMetricsProvider.java | 135 ++
.../java/org/apache/omid/metrics/Timer.java | 28 +
pom.xml | 25 +-
statemachine/pom.xml | 2 +-
.../com/yahoo/statemachine/StateMachine.java | 256 ----
.../statemachine/StateMachineLogParser.java | 163 ---
.../org/apache/statemachine/StateMachine.java | 256 ++++
.../statemachine/StateMachineLogParser.java | 163 +++
.../yahoo/statemachine/TestStateMachine.java | 100 --
.../apache/statemachine/TestStateMachine.java | 100 ++
timestamp-storage/pom.xml | 10 +-
.../DefaultHBaseTimestampStorageModule.java | 81 --
.../DefaultZKTimestampStorageModule.java | 57 -
.../storage/HBaseTimestampStorage.java | 89 --
.../storage/HBaseTimestampStorageConfig.java | 60 -
.../storage/HBaseTimestampStorageModule.java | 36 -
.../timestamp/storage/TimestampStorage.java | 28 -
.../yahoo/omid/timestamp/storage/ZKModule.java | 49 -
.../timestamp/storage/ZKTimestampPaths.java | 28 -
.../timestamp/storage/ZKTimestampStorage.java | 90 --
.../storage/ZKTimestampStorageModule.java | 37 -
.../DefaultHBaseTimestampStorageModule.java | 81 ++
.../DefaultZKTimestampStorageModule.java | 57 +
.../storage/HBaseTimestampStorage.java | 89 ++
.../storage/HBaseTimestampStorageConfig.java | 60 +
.../storage/HBaseTimestampStorageModule.java | 36 +
.../timestamp/storage/TimestampStorage.java | 28 +
.../apache/omid/timestamp/storage/ZKModule.java | 49 +
.../timestamp/storage/ZKTimestampPaths.java | 28 +
.../timestamp/storage/ZKTimestampStorage.java | 90 ++
.../storage/ZKTimestampStorageModule.java | 37 +
.../storage/TestHBaseTimestampStorage.java | 136 --
.../storage/TestZKTimestampStorage.java | 241 ----
.../storage/TestHBaseTimestampStorage.java | 136 ++
.../storage/TestZKTimestampStorage.java | 241 ++++
.../src/test/resources/log4j.properties | 15 +-
transaction-client/pom.xml | 12 +-
.../omid/transaction/AbstractTransaction.java | 217 ---
.../transaction/AbstractTransactionManager.java | 502 -------
.../transaction/CommitTimestampLocator.java | 38 -
.../omid/transaction/PostCommitActions.java | 41 -
.../omid/transaction/RollbackException.java | 35 -
.../com/yahoo/omid/transaction/Transaction.java | 76 -
.../omid/transaction/TransactionException.java | 31 -
.../omid/transaction/TransactionManager.java | 66 -
.../TransactionManagerException.java | 32 -
.../yahoo/omid/tso/client/AbortException.java | 27 -
.../java/com/yahoo/omid/tso/client/CellId.java | 24 -
.../yahoo/omid/tso/client/ClosingException.java | 28 -
.../omid/tso/client/ConnectionException.java | 30 -
.../omid/tso/client/ForwardingTSOFuture.java | 64 -
.../tso/client/HandshakeFailedException.java | 28 -
.../yahoo/omid/tso/client/MockTSOClient.java | 102 --
.../yahoo/omid/tso/client/NewTSOException.java | 27 -
.../tso/client/OmidClientConfiguration.java | 177 ---
.../tso/client/ServiceUnavailableException.java | 32 -
.../com/yahoo/omid/tso/client/TSOClient.java | 933 -------------
.../com/yahoo/omid/tso/client/TSOFuture.java | 25 -
.../com/yahoo/omid/tso/client/TSOProtocol.java | 56 -
.../yahoo/omid/tso/util/DummyCellIdImpl.java | 35 -
.../omid/transaction/AbstractTransaction.java | 217 +++
.../transaction/AbstractTransactionManager.java | 502 +++++++
.../transaction/CommitTimestampLocator.java | 38 +
.../omid/transaction/PostCommitActions.java | 41 +
.../omid/transaction/RollbackException.java | 35 +
.../apache/omid/transaction/Transaction.java | 76 +
.../omid/transaction/TransactionException.java | 31 +
.../omid/transaction/TransactionManager.java | 66 +
.../TransactionManagerException.java | 32 +
.../apache/omid/tso/client/AbortException.java | 27 +
.../java/org/apache/omid/tso/client/CellId.java | 24 +
.../omid/tso/client/ClosingException.java | 28 +
.../omid/tso/client/ConnectionException.java | 30 +
.../omid/tso/client/ForwardingTSOFuture.java | 64 +
.../tso/client/HandshakeFailedException.java | 28 +
.../apache/omid/tso/client/MockTSOClient.java | 102 ++
.../apache/omid/tso/client/NewTSOException.java | 27 +
.../tso/client/OmidClientConfiguration.java | 177 +++
.../tso/client/ServiceUnavailableException.java | 32 +
.../org/apache/omid/tso/client/TSOClient.java | 933 +++++++++++++
.../org/apache/omid/tso/client/TSOFuture.java | 25 +
.../org/apache/omid/tso/client/TSOProtocol.java | 56 +
.../apache/omid/tso/util/DummyCellIdImpl.java | 35 +
.../src/main/resources/omid-client-config.yml | 6 +-
.../omid/tso/client/TestMockTSOClient.java | 72 -
.../tso/client/TestOmidClientConfiguration.java | 32 -
.../omid/tso/client/TestMockTSOClient.java | 72 +
.../tso/client/TestOmidClientConfiguration.java | 32 +
tso-server/bin/omid.sh | 6 +-
tso-server/maven/assembly/bin.xml | 6 +-
tso-server/pom.xml | 20 +-
.../src/main/java/com/yahoo/omid/tso/Cache.java | 32 -
.../com/yahoo/omid/tso/CacheEvaluation.java | 105 --
.../java/com/yahoo/omid/tso/CommitHashMap.java | 81 --
.../com/yahoo/omid/tso/DisruptorModule.java | 36 -
.../yahoo/omid/tso/FatalExceptionHandler.java | 51 -
.../yahoo/omid/tso/HALeaseManagementModule.java | 81 --
.../tso/InMemoryCommitTableStorageModule.java | 35 -
.../tso/InMemoryTimestampStorageModule.java | 35 -
.../com/yahoo/omid/tso/LeaseManagement.java | 52 -
.../java/com/yahoo/omid/tso/LeaseManager.java | 310 -----
.../main/java/com/yahoo/omid/tso/LongCache.java | 85 --
.../java/com/yahoo/omid/tso/MockPanicker.java | 30 -
.../com/yahoo/omid/tso/MonitoringContext.java | 77 --
.../yahoo/omid/tso/NetworkInterfaceUtils.java | 126 --
.../main/java/com/yahoo/omid/tso/Panicker.java | 22 -
.../yahoo/omid/tso/PausableTimestampOracle.java | 70 -
.../yahoo/omid/tso/PersistenceProcessor.java | 30 -
.../omid/tso/PersistenceProcessorImpl.java | 431 ------
.../java/com/yahoo/omid/tso/ReplyProcessor.java | 43 -
.../com/yahoo/omid/tso/ReplyProcessorImpl.java | 236 ----
.../com/yahoo/omid/tso/RequestProcessor.java | 31 -
.../yahoo/omid/tso/RequestProcessorImpl.java | 309 -----
.../java/com/yahoo/omid/tso/RetryProcessor.java | 24 -
.../com/yahoo/omid/tso/RetryProcessorImpl.java | 185 ---
.../com/yahoo/omid/tso/SystemExitPanicker.java | 32 -
.../com/yahoo/omid/tso/TSOChannelHandler.java | 285 ----
.../main/java/com/yahoo/omid/tso/TSOModule.java | 67 -
.../main/java/com/yahoo/omid/tso/TSOServer.java | 131 --
.../com/yahoo/omid/tso/TSOServerConfig.java | 176 ---
.../com/yahoo/omid/tso/TSOStateManager.java | 95 --
.../com/yahoo/omid/tso/TSOStateManagerImpl.java | 78 --
.../com/yahoo/omid/tso/TimestampOracle.java | 34 -
.../com/yahoo/omid/tso/TimestampOracleImpl.java | 169 ---
.../com/yahoo/omid/tso/TsoServerDaemon.java | 60 -
.../omid/tso/VoidLeaseManagementModule.java | 92 --
.../com/yahoo/omid/tso/VoidLeaseManager.java | 53 -
.../main/java/org/apache/omid/tso/Cache.java | 32 +
.../org/apache/omid/tso/CacheEvaluation.java | 105 ++
.../java/org/apache/omid/tso/CommitHashMap.java | 81 ++
.../org/apache/omid/tso/DisruptorModule.java | 36 +
.../apache/omid/tso/FatalExceptionHandler.java | 51 +
.../omid/tso/HALeaseManagementModule.java | 81 ++
.../tso/InMemoryCommitTableStorageModule.java | 35 +
.../tso/InMemoryTimestampStorageModule.java | 35 +
.../org/apache/omid/tso/LeaseManagement.java | 52 +
.../java/org/apache/omid/tso/LeaseManager.java | 310 +++++
.../java/org/apache/omid/tso/LongCache.java | 85 ++
.../java/org/apache/omid/tso/MockPanicker.java | 30 +
.../org/apache/omid/tso/MonitoringContext.java | 77 ++
.../apache/omid/tso/NetworkInterfaceUtils.java | 126 ++
.../main/java/org/apache/omid/tso/Panicker.java | 22 +
.../omid/tso/PausableTimestampOracle.java | 70 +
.../apache/omid/tso/PersistenceProcessor.java | 30 +
.../omid/tso/PersistenceProcessorImpl.java | 431 ++++++
.../org/apache/omid/tso/ReplyProcessor.java | 43 +
.../org/apache/omid/tso/ReplyProcessorImpl.java | 236 ++++
.../org/apache/omid/tso/RequestProcessor.java | 31 +
.../apache/omid/tso/RequestProcessorImpl.java | 309 +++++
.../org/apache/omid/tso/RetryProcessor.java | 24 +
.../org/apache/omid/tso/RetryProcessorImpl.java | 185 +++
.../org/apache/omid/tso/SystemExitPanicker.java | 32 +
.../org/apache/omid/tso/TSOChannelHandler.java | 285 ++++
.../java/org/apache/omid/tso/TSOModule.java | 67 +
.../java/org/apache/omid/tso/TSOServer.java | 131 ++
.../org/apache/omid/tso/TSOServerConfig.java | 176 +++
.../org/apache/omid/tso/TSOStateManager.java | 95 ++
.../apache/omid/tso/TSOStateManagerImpl.java | 78 ++
.../org/apache/omid/tso/TimestampOracle.java | 34 +
.../apache/omid/tso/TimestampOracleImpl.java | 169 +++
.../org/apache/omid/tso/TsoServerDaemon.java | 60 +
.../omid/tso/VoidLeaseManagementModule.java | 92 ++
.../org/apache/omid/tso/VoidLeaseManager.java | 53 +
tso-server/src/main/resources/default-omid.yml | 74 +-
tso-server/src/main/resources/log4j.properties | 13 +-
.../src/test/java/com/yahoo/omid/TestUtils.java | 114 --
.../yahoo/omid/tso/PausableLeaseManager.java | 117 --
.../yahoo/omid/tso/ProgrammableTSOServer.java | 287 ----
.../java/com/yahoo/omid/tso/TSOMockModule.java | 76 -
.../com/yahoo/omid/tso/TSOServerConfigTest.java | 29 -
.../test/java/com/yahoo/omid/tso/TestBatch.java | 158 ---
.../com/yahoo/omid/tso/TestLeaseManager.java | 418 ------
.../java/com/yahoo/omid/tso/TestLongCache.java | 122 --
.../java/com/yahoo/omid/tso/TestPanicker.java | 163 ---
.../omid/tso/TestPersistenceProcessor.java | 221 ---
.../yahoo/omid/tso/TestRequestProcessor.java | 186 ---
.../com/yahoo/omid/tso/TestRetryProcessor.java | 126 --
.../omid/tso/TestTSOChannelHandlerNetty.java | 321 -----
.../com/yahoo/omid/tso/TestTSOStateManager.java | 121 --
.../com/yahoo/omid/tso/TestTimestampOracle.java | 117 --
.../omid/tso/client/TSOClientAccessor.java | 29 -
.../yahoo/omid/tso/client/TSOClientOneShot.java | 63 -
.../com/yahoo/omid/tso/client/TSOClientRaw.java | 150 --
...tionOfTSOClientServerBasicFunctionality.java | 233 ----
.../client/TestTSOClientConnectionToTSO.java | 284 ----
...stTSOClientRequestAndResponseBehaviours.java | 423 ------
.../client/TestTSOClientResponseHandling.java | 111 --
.../tso/client/TestUnconnectedTSOClient.java | 83 --
.../test/java/org/apache/omid/TestUtils.java | 114 ++
.../apache/omid/tso/PausableLeaseManager.java | 117 ++
.../apache/omid/tso/ProgrammableTSOServer.java | 287 ++++
.../java/org/apache/omid/tso/TSOMockModule.java | 76 +
.../apache/omid/tso/TSOServerConfigTest.java | 29 +
.../java/org/apache/omid/tso/TestBatch.java | 158 +++
.../org/apache/omid/tso/TestLeaseManager.java | 418 ++++++
.../java/org/apache/omid/tso/TestLongCache.java | 122 ++
.../java/org/apache/omid/tso/TestPanicker.java | 163 +++
.../omid/tso/TestPersistenceProcessor.java | 221 +++
.../apache/omid/tso/TestRequestProcessor.java | 186 +++
.../org/apache/omid/tso/TestRetryProcessor.java | 126 ++
.../omid/tso/TestTSOChannelHandlerNetty.java | 321 +++++
.../apache/omid/tso/TestTSOStateManager.java | 121 ++
.../apache/omid/tso/TestTimestampOracle.java | 117 ++
.../omid/tso/client/TSOClientAccessor.java | 29 +
.../omid/tso/client/TSOClientOneShot.java | 63 +
.../apache/omid/tso/client/TSOClientRaw.java | 150 ++
...tionOfTSOClientServerBasicFunctionality.java | 233 ++++
.../client/TestTSOClientConnectionToTSO.java | 284 ++++
...stTSOClientRequestAndResponseBehaviours.java | 423 ++++++
.../client/TestTSOClientResponseHandling.java | 111 ++
.../tso/client/TestUnconnectedTSOClient.java | 83 ++
tso-server/src/test/resources/log4j.properties | 15 +-
tso-server/src/test/resources/test-omid.yml | 8 +-
417 files changed, 26656 insertions(+), 26685 deletions(-)
----------------------------------------------------------------------