This is an automated email from the ASF dual-hosted git repository.
aweisberg pushed a change to branch cep-15-accord
in repository https://gitbox.apache.org/repos/asf/cassandra.git
from c9211f0a05 Accord's ConfigService lock is held over large areas which
cause deadlocks and performance issues
add e6bd89ac36 Split accord migration into two phases
No new revisions were added by this update.
Summary of changes:
.../cassandra/cql3/statements/CQL3CasRequest.java | 2 +-
.../cassandra/db/virtual/AccordVirtualTables.java | 10 +-
.../org/apache/cassandra/dht/NormalizedRanges.java | 295 ++++++++++++++++
src/java/org/apache/cassandra/dht/Range.java | 223 +-----------
.../cassandra/repair/AbstractRepairTask.java | 5 +-
.../apache/cassandra/repair/RepairCoordinator.java | 17 +-
.../org/apache/cassandra/repair/RepairJob.java | 134 ++++---
.../org/apache/cassandra/repair/RepairSession.java | 23 +-
.../cassandra/repair/messages/RepairOption.java | 72 ++--
.../cassandra/service/ActiveRepairService.java | 21 +-
.../service/accord/AccordMessageSink.java | 21 +-
.../service/accord/AccordResponseVerbHandler.java | 2 +-
.../cassandra/service/accord/AccordService.java | 158 +--------
.../service/accord/AccordVerbHandler.java | 2 +-
.../cassandra/service/accord/IAccordService.java | 387 ++++++++++++++++++++-
.../cassandra/service/accord/api/AccordAgent.java | 5 -
.../cassandra/service/accord/txn/TxnQuery.java | 17 +-
.../service/consensus/TransactionalMode.java | 32 +-
.../migration/ConsensusKeyMigrationState.java | 3 +-
.../ConsensusMigrationMutationHelper.java | 7 +-
.../migration/ConsensusMigrationRepairResult.java | 22 +-
.../migration/ConsensusMigrationRepairType.java | 62 ++--
.../migration/ConsensusMigrationState.java | 17 +-
.../migration/ConsensusMigrationTarget.java | 8 +-
.../migration/ConsensusRequestRouter.java | 31 +-
.../migration/ConsensusTableMigration.java | 114 ++++--
.../consensus/migration/TableMigrationState.java | 199 +++++++----
.../org/apache/cassandra/service/paxos/Paxos.java | 37 +-
.../BeginConsensusMigrationForTableAndRange.java | 8 +-
...beFinishConsensusMigrationForTableAndRange.java | 44 ++-
.../tools/nodetool/ConsensusMigrationAdmin.java | 23 ++
.../apache/cassandra/tools/nodetool/Repair.java | 48 ++-
.../distributed/test/PaxosRepair2Test.java | 8 +-
.../distributed/test/PaxosRepairTest.java | 35 +-
.../distributed/test/accord/AccordCQLTestBase.java | 2 +-
.../test/accord/AccordIncrementalRepairTest.java | 131 ++++---
.../test/accord/AccordMigrationRaceTestBase.java | 24 +-
.../test/accord/AccordMigrationTest.java | 53 ++-
.../accord/AccordTimestampPreservationTest.java | 17 +-
.../simulator/cluster/OnInstanceRepair.java | 2 +-
.../unit/org/apache/cassandra/ServerTestUtils.java | 35 --
.../compaction/CompactionAccordIteratorsTest.java | 41 ++-
test/unit/org/apache/cassandra/dht/RangeTest.java | 95 ++---
.../org/apache/cassandra/repair/RepairJobTest.java | 6 +-
.../apache/cassandra/repair/RepairSessionTest.java | 2 +-
.../cassandra/tools/NodeToolCommandTest.java | 4 +-
46 files changed, 1531 insertions(+), 973 deletions(-)
create mode 100644 src/java/org/apache/cassandra/dht/NormalizedRanges.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
