This is an automated email from the ASF dual-hosted git repository. bdeggleston pushed a change to branch cep-15-accord in repository https://gitbox.apache.org/repos/asf/cassandra.git
from 9cd6406a7e Add support for prepared statements for accord transactions new fa10af834e add AsyncChain implementations and tests new 3374d91c4a CEP-15/Accord Immutable State Refactor The 2 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: .build/build-accord.xml | 6 + .circleci/config.yml | 10923 ------------------- modules/accord | 2 +- .../cql3/statements/TransactionStatement.java | 3 +- .../cassandra/exceptions/ReadTimeoutException.java | 6 + .../cassandra/service/accord/AccordCommand.java | 824 -- .../service/accord/AccordCommandStore.java | 400 +- .../service/accord/AccordCommandStores.java | 7 +- .../service/accord/AccordCommandsForKey.java | 433 - .../service/accord/AccordConfigurationService.java | 21 +- .../cassandra/service/accord/AccordKeyspace.java | 638 +- .../service/accord/AccordLoadingState.java | 163 + .../service/accord/AccordObjectSizes.java | 162 +- .../service/accord/AccordPartialCommand.java | 209 - .../service/accord/AccordSafeCommand.java | 124 + .../service/accord/AccordSafeCommandStore.java | 260 + .../service/accord/AccordSafeCommandsForKey.java | 125 + .../cassandra/service/accord/AccordSafeState.java | 76 + .../cassandra/service/accord/AccordService.java | 36 +- .../cassandra/service/accord/AccordState.java | 105 - .../cassandra/service/accord/AccordStateCache.java | 522 +- .../cassandra/service/accord/ListenerProxy.java | 275 - .../cassandra/service/accord/ReadFuture.java | 292 - .../cassandra/service/accord/api/AccordAgent.java | 7 +- .../service/accord/async/AsyncContext.java | 116 - .../service/accord/async/AsyncLoader.java | 207 +- .../service/accord/async/AsyncOperation.java | 168 +- .../service/accord/async/AsyncWriter.java | 285 +- .../accord/exceptions/ReadPreemptedException.java} | 20 +- .../exceptions/WritePreemptedException.java} | 19 +- .../accord/serializers/AcceptSerializers.java | 1 - .../accord/serializers/ApplySerializers.java | 3 + .../serializers/CommandsForKeySerializer.java | 207 + .../accord/serializers/ListenerSerializers.java | 151 + .../service/accord/store/AbstractStoredField.java | 152 - .../service/accord/store/StoredBoolean.java | 85 - .../cassandra/service/accord/store/StoredLong.java | 86 - .../service/accord/store/StoredNavigableMap.java | 224 - .../cassandra/service/accord/store/StoredSet.java | 249 - .../service/accord/store/StoredValue.java | 128 - .../cassandra/service/accord/txn/TxnNamedRead.java | 7 +- .../cassandra/service/accord/txn/TxnRead.java | 57 +- .../cassandra/service/accord/txn/TxnWrite.java | 34 +- .../distributed/test/accord/AccordTestBase.java | 5 +- .../cassandra/simulator/paxos/PaxosSimulation.java | 21 +- .../service/accord/AccordCommandStoreTest.java | 113 +- .../service/accord/AccordCommandTest.java | 53 +- .../service/accord/AccordLoadingStateTest.java | 178 + .../service/accord/AccordStateCacheTest.java | 533 +- .../cassandra/service/accord/AccordTestUtils.java | 175 +- .../service/accord/async/AsyncLoaderTest.java | 203 +- .../service/accord/async/AsyncOperationTest.java | 447 +- .../service/accord/async/AsyncWriterTest.java | 241 - .../serializers/CommandsForKeySerializerTest.java | 95 + .../service/accord/store/StoredMapTest.java | 203 - .../service/accord/store/StoredSetTest.java | 202 - .../service/accord/store/StoredValueTest.java | 85 - .../apache/cassandra/utils/AccordGenerators.java | 84 + .../org/apache/cassandra/utils/AssertionUtils.java | 31 + 59 files changed, 3676 insertions(+), 16811 deletions(-) delete mode 100644 .circleci/config.yml delete mode 100644 src/java/org/apache/cassandra/service/accord/AccordCommand.java delete mode 100644 src/java/org/apache/cassandra/service/accord/AccordCommandsForKey.java create mode 100644 src/java/org/apache/cassandra/service/accord/AccordLoadingState.java delete mode 100644 src/java/org/apache/cassandra/service/accord/AccordPartialCommand.java create mode 100644 src/java/org/apache/cassandra/service/accord/AccordSafeCommand.java create mode 100644 src/java/org/apache/cassandra/service/accord/AccordSafeCommandStore.java create mode 100644 src/java/org/apache/cassandra/service/accord/AccordSafeCommandsForKey.java create mode 100644 src/java/org/apache/cassandra/service/accord/AccordSafeState.java delete mode 100644 src/java/org/apache/cassandra/service/accord/AccordState.java delete mode 100644 src/java/org/apache/cassandra/service/accord/ListenerProxy.java delete mode 100644 src/java/org/apache/cassandra/service/accord/ReadFuture.java delete mode 100644 src/java/org/apache/cassandra/service/accord/async/AsyncContext.java copy src/java/org/apache/cassandra/{exceptions/WriteTimeoutException.java => service/accord/exceptions/ReadPreemptedException.java} (57%) copy src/java/org/apache/cassandra/{exceptions/WriteTimeoutException.java => service/accord/exceptions/WritePreemptedException.java} (59%) create mode 100644 src/java/org/apache/cassandra/service/accord/serializers/CommandsForKeySerializer.java create mode 100644 src/java/org/apache/cassandra/service/accord/serializers/ListenerSerializers.java delete mode 100644 src/java/org/apache/cassandra/service/accord/store/AbstractStoredField.java delete mode 100644 src/java/org/apache/cassandra/service/accord/store/StoredBoolean.java delete mode 100644 src/java/org/apache/cassandra/service/accord/store/StoredLong.java delete mode 100644 src/java/org/apache/cassandra/service/accord/store/StoredNavigableMap.java delete mode 100644 src/java/org/apache/cassandra/service/accord/store/StoredSet.java delete mode 100644 src/java/org/apache/cassandra/service/accord/store/StoredValue.java create mode 100644 test/unit/org/apache/cassandra/service/accord/AccordLoadingStateTest.java delete mode 100644 test/unit/org/apache/cassandra/service/accord/async/AsyncWriterTest.java create mode 100644 test/unit/org/apache/cassandra/service/accord/serializers/CommandsForKeySerializerTest.java delete mode 100644 test/unit/org/apache/cassandra/service/accord/store/StoredMapTest.java delete mode 100644 test/unit/org/apache/cassandra/service/accord/store/StoredSetTest.java delete mode 100644 test/unit/org/apache/cassandra/service/accord/store/StoredValueTest.java create mode 100644 test/unit/org/apache/cassandra/utils/AccordGenerators.java --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@cassandra.apache.org For additional commands, e-mail: commits-h...@cassandra.apache.org