This is an automated email from the ASF dual-hosted git repository.
aweisberg pushed a change to branch cep-45-mutation-tracking
in repository https://gitbox.apache.org/repos/asf/cassandra.git
from 29ec0f0453 ninja - fix missing import
add f3231bc6be SERIAL read/write support for Witnesses and Mutation
Tracking
No new revisions were added by this update.
Summary of changes:
.../org/apache/cassandra/concurrent/Stage.java | 3 +-
.../config/CassandraRelevantProperties.java | 1 +
src/java/org/apache/cassandra/config/Config.java | 1 +
.../cassandra/config/DatabaseDescriptor.java | 12 +
.../constraints/ConstraintViolationException.java | 7 +
.../InvalidConstraintDefinitionException.java | 7 +
.../cassandra/cql3/statements/BatchStatement.java | 12 +-
.../cql3/statements/BatchUpdatesCollector.java | 12 +-
.../cassandra/cql3/statements/CQL3CasRequest.java | 458 +++++---
.../cql3/statements/ModificationStatement.java | 49 +-
...SingleTableSinglePartitionUpdatesCollector.java | 9 +-
.../statements/SingleTableUpdatesCollector.java | 11 +-
.../cql3/statements/TransactionStatement.java | 7 +-
.../cql3/statements/UpdatesCollector.java | 17 +-
.../db/EmbeddableSinglePartitionReadCommand.java | 120 +++
.../org/apache/cassandra/db/IReadResponse.java | 104 ++
.../cassandra/db/KeyspaceNotDefinedException.java | 7 +
src/java/org/apache/cassandra/db/Mutation.java | 17 +-
.../db/MutationExceededMaxSizeException.java | 35 +
src/java/org/apache/cassandra/db/ReadKind.java | 83 ++
src/java/org/apache/cassandra/db/ReadResponse.java | 9 +-
.../cassandra/db/SinglePartitionReadCommand.java | 12 +-
.../org/apache/cassandra/db/SystemKeyspace.java | 29 +-
src/java/org/apache/cassandra/db/WriteType.java | 73 +-
.../db/guardrails/GuardrailViolatedException.java | 14 +-
.../cassandra/db/partitions/PartitionUpdate.java | 9 +-
.../exceptions/AlreadyExistsException.java | 31 +
.../exceptions/AuthenticationException.java | 6 +
.../cassandra/exceptions/CDCWriteException.java | 6 +
.../exceptions/CasWriteTimeoutException.java | 35 +-
.../exceptions/CasWriteUnknownResultException.java | 35 +
.../cassandra/exceptions/CassandraException.java | 183 +++-
.../exceptions/CassandraExceptionCode.java | 96 ++
.../exceptions/ConfigurationException.java | 6 +
.../cassandra/exceptions/ExceptionSerializer.java | 2 +-
.../exceptions/FunctionExecutionException.java | 43 +
.../exceptions/InvalidRequestException.java | 6 +
.../exceptions/InvalidRoutingException.java | 8 +-
.../exceptions/IsBootstrappingException.java | 6 +
.../exceptions/OperationExecutionException.java | 20 +
.../cassandra/exceptions/OverloadedException.java | 6 +
.../exceptions/OversizedCQLMessageException.java | 6 +
.../exceptions/PreparedQueryNotFoundException.java | 31 +
...ueryReferencesTooManyIndexesAbortException.java | 38 +
.../cassandra/exceptions/ReadFailureException.java | 89 ++
.../exceptions/ReadSizeAbortException.java | 14 +
.../cassandra/exceptions/ReadTimeoutException.java | 38 +
.../exceptions/RequestFailureException.java | 2 +-
.../exceptions/RequestTimeoutException.java | 2 +-
.../cassandra/exceptions/SyntaxException.java | 6 +
.../exceptions/TombstoneAbortException.java | 38 +
.../cassandra/exceptions/TruncateException.java | 6 +
.../exceptions/UnauthorizedException.java | 6 +
.../cassandra/exceptions/UnavailableException.java | 35 +
.../exceptions/WriteFailureException.java | 57 +
.../exceptions/WriteTimeoutException.java | 38 +
.../io/AsymmetricUnversionedSerializer.java | 4 +
.../io/IVersionedAsymmetricSerializer.java | 4 +
.../apache/cassandra/io/IVersionedSerializer.java | 4 +
.../apache/cassandra/io/UnversionedSerializer.java | 5 +
.../cassandra/locator/EndpointsForToken.java | 46 +-
.../org/apache/cassandra/locator/ReplicaPlans.java | 2 -
src/java/org/apache/cassandra/net/Message.java | 15 +
src/java/org/apache/cassandra/net/Verb.java | 27 +-
.../apache/cassandra/replication/MutationId.java | 23 +
.../cassandra/replication/TrackedWriteRequest.java | 3 +
.../org/apache/cassandra/service/CASRequest.java | 60 --
.../org/apache/cassandra/service/ClientState.java | 22 +
.../org/apache/cassandra/service/StorageProxy.java | 668 +++++++++++-
.../service/TrackedWriteResponseHandler.java | 14 +-
.../exceptions/AccordReadExhaustedException.java | 37 +
.../exceptions/AccordReadPreemptedException.java | 37 +
.../exceptions/AccordWriteExhaustedException.java | 34 +
.../exceptions/AccordWritePreemptedException.java | 34 +
.../service/accord/txn/TxnReferenceOperation.java | 3 +
.../service/accord/txn/TxnReferenceOperations.java | 65 +-
.../cassandra/service/accord/txn/TxnWrite.java | 90 +-
.../cassandra/service/paxos/CasForwardHandler.java | 124 +++
.../cassandra/service/paxos/CasForwardRequest.java | 140 +++
.../service/paxos/CasForwardResponse.java | 182 ++++
.../org/apache/cassandra/service/paxos/Commit.java | 226 +++-
.../service/paxos/ConsensusReadForwardHandler.java | 122 +++
.../service/paxos/ConsensusReadForwardRequest.java | 77 ++
.../org/apache/cassandra/service/paxos/Paxos.java | 75 +-
.../service/paxos/Paxos2CommitForwardHandler.java | 132 +++
.../service/paxos/Paxos2CommitForwardRequest.java | 124 +++
.../cassandra/service/paxos/PaxosCommit.java | 350 ++++++-
.../service/paxos/PaxosCommitAndPrepare.java | 74 +-
.../service/paxos/PaxosCommitForwardHandler.java | 89 ++
.../service/paxos/PaxosCommitForwardRequest.java | 88 ++
.../cassandra/service/paxos/PaxosPrepare.java | 311 ++++--
.../service/paxos/PaxosPrepareRefresh.java | 201 +++-
.../cassandra/service/paxos/PaxosPropose.java | 15 +-
.../cassandra/service/paxos/PaxosRepair.java | 4 +-
.../service/paxos/PaxosRequestCallback.java | 63 +-
.../apache/cassandra/service/paxos/PaxosState.java | 50 +-
.../paxos/PrepareRefreshForwardHandler.java | 184 ++++
.../paxos/PrepareRefreshForwardRequest.java | 90 ++
.../paxos/PrepareRefreshForwardResponse.java | 72 ++
.../cassandra/service/paxos/PrepareResponse.java | 4 +-
.../service/paxos/uncommitted/PaxosRows.java | 23 +-
.../service/paxos/v1/AbstractPaxosVerbHandler.java | 8 +-
.../service/reads/tracked/TrackedDataResponse.java | 10 +-
.../service/reads/tracked/TrackedRead.java | 53 +-
.../reads/tracked/TrackedSummaryResponse.java | 12 +-
.../triggers/TriggerDisabledException.java | 7 +
.../cassandra/utils/CollectionSerializers.java | 24 +
.../distributed/test/PaxosRepair2Test.java | 2 +-
...nTest.java => ShortReadProtectionTestBase.java} | 25 +-
...TrackedReplicationShortReadProtectionTest.java} | 13 +-
.../test/TransientRangeMovement2Test.java | 3 +
.../test/TransientRangeMovementTest.java | 5 +-
...trackedReplicationShortReadProtectionTest.java} | 15 +-
.../test/log/MetadataChangeSimulationTest.java | 1 +
.../distributed/test/log/NTSSimulationTest.java | 1 +
.../test/log/OperationalEquivalenceTest.java | 1 +
.../test/log/SimpleStrategySimulationTest.java | 1 +
.../MutationTrackingCasForwardingTest.java | 273 +++++
.../MutationTrackingCommitAndPrepareTest.java | 298 ++++++
.../test/tracking/MutationTrackingTest.java | 72 +-
.../cassandra/harry/model/TokenPlacementModel.java | 7 +-
.../cassandra/simulator/ClusterSimulation.java | 26 +
.../cassandra/simulator/SimulationRunner.java | 13 +
.../apache/cassandra/simulator/SimulatorUtils.java | 34 +-
.../simulator/cluster/KeyspaceActions.java | 12 +-
.../simulator/cluster/ReplicationConfig.java | 154 +++
.../AbstractPairOfSequencesPaxosSimulation.java | 8 +-
.../simulator/paxos/AccordClusterSimulation.java | 2 +-
.../simulator/paxos/AccordSimulationRunner.java | 19 +-
.../apache/cassandra/simulator/paxos/Ballots.java | 4 +-
.../paxos/PairOfSequencesAccordSimulation.java | 7 +-
.../paxos/PairOfSequencesPaxosSimulation.java | 7 +-
.../simulator/paxos/PaxosClusterSimulation.java | 2 +-
.../simulator/paxos/PaxosSimulationRunner.java | 21 +-
.../cassandra/simulator/systems/SimulatedTime.java | 2 +-
.../simulator/test/ShortAccordSimulationTest.java | 11 +-
...hortPaxosMigrationFromAccordSimulationTest.java | 22 +-
.../ShortPaxosMigrationToAccordSimulationTest.java | 16 +-
.../simulator/test/ShortPaxosSimulationTest.java | 22 +-
....java => ShortPaxosTrackingSimulationTest.java} | 77 +-
...java => ShortPaxosWitnessesSimulationTest.java} | 77 +-
.../CQL3CasRequestSerializationTest.java | 523 ++++++++++
.../apache/cassandra/db/CleanupTransientTest.java | 11 +-
.../cassandra/db/IReadResponseSerializerTest.java | 358 +++++++
.../ColumnTypeSpecificValueThresholdTester.java | 20 +-
.../GuardrailColumnBlobValueSizeTest.java | 20 +-
.../guardrails/GuardrailColumnValueSizeTest.java | 20 +-
.../CassandraExceptionSerializationTest.java | 1094 ++++++++++++++++++++
.../cassandra/service/paxos/CasForwardingTest.java | 196 ++++
.../service/paxos/ConsensusReadForwardingTest.java | 56 +
.../cassandra/service/paxos/PaxosStateTest.java | 2 +-
.../service/paxos/uncommitted/PaxosRowsTest.java | 4 +-
.../paxos/uncommitted/PaxosStateTrackerTest.java | 2 +-
153 files changed, 8944 insertions(+), 759 deletions(-)
create mode 100644
src/java/org/apache/cassandra/db/EmbeddableSinglePartitionReadCommand.java
create mode 100644 src/java/org/apache/cassandra/db/IReadResponse.java
create mode 100644 src/java/org/apache/cassandra/db/ReadKind.java
create mode 100644
src/java/org/apache/cassandra/exceptions/CassandraExceptionCode.java
delete mode 100644 src/java/org/apache/cassandra/service/CASRequest.java
create mode 100644
src/java/org/apache/cassandra/service/paxos/CasForwardHandler.java
create mode 100644
src/java/org/apache/cassandra/service/paxos/CasForwardRequest.java
create mode 100644
src/java/org/apache/cassandra/service/paxos/CasForwardResponse.java
create mode 100644
src/java/org/apache/cassandra/service/paxos/ConsensusReadForwardHandler.java
create mode 100644
src/java/org/apache/cassandra/service/paxos/ConsensusReadForwardRequest.java
create mode 100644
src/java/org/apache/cassandra/service/paxos/Paxos2CommitForwardHandler.java
create mode 100644
src/java/org/apache/cassandra/service/paxos/Paxos2CommitForwardRequest.java
create mode 100644
src/java/org/apache/cassandra/service/paxos/PaxosCommitForwardHandler.java
create mode 100644
src/java/org/apache/cassandra/service/paxos/PaxosCommitForwardRequest.java
create mode 100644
src/java/org/apache/cassandra/service/paxos/PrepareRefreshForwardHandler.java
create mode 100644
src/java/org/apache/cassandra/service/paxos/PrepareRefreshForwardRequest.java
create mode 100644
src/java/org/apache/cassandra/service/paxos/PrepareRefreshForwardResponse.java
rename
test/distributed/org/apache/cassandra/distributed/test/{ShortReadProtectionTest.java
=> ShortReadProtectionTestBase.java} (97%)
copy
test/distributed/org/apache/cassandra/distributed/test/{ReadRepairTrackedTest.java
=> TrackedReplicationShortReadProtectionTest.java} (75%)
copy
test/distributed/org/apache/cassandra/distributed/test/{ReadRepairTrackedTest.java
=> UntrackedReplicationShortReadProtectionTest.java} (72%)
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/tracking/MutationTrackingCasForwardingTest.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/tracking/MutationTrackingCommitAndPrepareTest.java
create mode 100644
test/simulator/main/org/apache/cassandra/simulator/cluster/ReplicationConfig.java
copy
test/simulator/test/org/apache/cassandra/simulator/test/{ShortPaxosSimulationTest.java
=> ShortPaxosTrackingSimulationTest.java} (67%)
copy
test/simulator/test/org/apache/cassandra/simulator/test/{ShortPaxosSimulationTest.java
=> ShortPaxosWitnessesSimulationTest.java} (67%)
create mode 100644
test/unit/org/apache/cassandra/cql3/statements/CQL3CasRequestSerializationTest.java
create mode 100644
test/unit/org/apache/cassandra/db/IReadResponseSerializerTest.java
create mode 100644
test/unit/org/apache/cassandra/exceptions/CassandraExceptionSerializationTest.java
create mode 100644
test/unit/org/apache/cassandra/service/paxos/CasForwardingTest.java
create mode 100644
test/unit/org/apache/cassandra/service/paxos/ConsensusReadForwardingTest.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
