This is an automated email from the ASF dual-hosted git repository.
aweisberg pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/cassandra-accord.git
from bed79d2c Ninja for CASSANDRA-18874: When using Elle make sure to set
-Djava.awt.headless=true so rhizome does not try to spin up a GUI. Make the
build timeout after 20m as a successful build takes around 10m (the default
timeout)
add 99062824 Accord support for live migration
new 6c687227 Support for interoperability between Accord and non-Accord
managed data
The 1 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:
accord-core/build.gradle | 1 +
accord-core/src/main/java/accord/api/Agent.java | 12 +
.../BarrierType.java} | 50 ++--
accord-core/src/main/java/accord/api/Data.java | 12 +
accord-core/src/main/java/accord/api/Query.java | 11 +-
accord-core/src/main/java/accord/api/Read.java | 8 +-
.../src/main/java/accord/coordinate/Barrier.java | 306 +++++++++++++++++++++
.../main/java/accord/coordinate/BlockOnDeps.java | 135 +++++++++
.../accord/coordinate/CoordinateShardDurable.java | 13 +-
.../accord/coordinate/CoordinateSyncPoint.java | 101 ++++---
.../src/main/java/accord/coordinate/Execute.java | 134 ++-------
.../src/main/java/accord/coordinate/Persist.java | 74 +++--
.../src/main/java/accord/coordinate/Propose.java | 4 +-
.../java/accord/coordinate/ProposeSyncPoint.java | 84 ++++++
.../coordinate/{Execute.java => TxnExecute.java} | 42 +--
.../TxnPersist.java} | 57 ++--
.../accord/coordinate/tracking/AppliedTracker.java | 2 +-
.../accord/coordinate/tracking/QuorumTracker.java | 2 +-
.../{ShardTracker.java => ResponseTracker.java} | 12 +-
.../java/accord/impl/AbstractFetchCoordinator.java | 14 +-
.../main/java/accord/impl/CommandTimeseries.java | 15 +-
.../src/main/java/accord/impl/CommandsForKey.java | 12 +-
.../impl/CoordinateDurabilityScheduling.java | 2 +-
.../main/java/accord/impl/ErasedSafeCommand.java | 9 +-
.../java/accord/impl/InMemoryCommandStore.java | 58 ++--
.../main/java/accord/impl/InMemorySafeCommand.java | 4 +-
.../main/java/accord/impl/SimpleProgressLog.java | 16 +-
.../src/main/java/accord/local/Bootstrap.java | 7 +-
.../src/main/java/accord/local/Command.java | 2 +-
.../src/main/java/accord/local/CommandStore.java | 4 +-
.../src/main/java/accord/local/CommandStores.java | 17 ++
.../src/main/java/accord/local/Listeners.java | 14 +-
accord-core/src/main/java/accord/local/Node.java | 56 +++-
.../src/main/java/accord/local/PreLoadContext.java | 4 +-
.../src/main/java/accord/local/SafeCommand.java | 11 +-
.../main/java/accord/local/SafeCommandStore.java | 28 +-
.../main/java/accord/local/SerializerSupport.java | 68 +++--
.../{ReadTxnData.java => AbstractExecute.java} | 139 ++++++----
.../src/main/java/accord/messages/Apply.java | 34 ++-
.../accord/messages/ApplyThenWaitUntilApplied.java | 124 +++++++++
.../main/java/accord/messages/BeginRecovery.java | 8 +-
.../src/main/java/accord/messages/Commit.java | 61 +++-
.../java/accord/messages/InformHomeDurable.java | 4 +-
.../src/main/java/accord/messages/MessageType.java | 120 +++++---
.../src/main/java/accord/messages/PreAccept.java | 8 +-
.../src/main/java/accord/messages/ReadData.java | 57 +++-
.../src/main/java/accord/messages/ReadTxnData.java | 232 +---------------
.../main/java/accord/messages/SetShardDurable.java | 5 +-
.../src/main/java/accord/messages/TxnRequest.java | 30 +-
.../java/accord/messages/WaitUntilApplied.java | 17 +-
.../src/main/java/accord/primitives/Keys.java | 15 +-
.../main/java/accord/primitives/RoutingKeys.java | 11 +
.../src/main/java/accord/primitives/Seekables.java | 6 +
.../src/main/java/accord/primitives/SyncPoint.java | 25 +-
.../src/main/java/accord/primitives/Timestamp.java | 3 +-
.../src/main/java/accord/primitives/Txn.java | 18 +-
.../src/main/java/accord/primitives/Writes.java | 14 +-
.../src/main/java/accord/topology/Topology.java | 29 +-
.../main/java/accord/utils/DeterministicSet.java | 23 ++
.../src/main/java/accord/utils/Invariants.java | 13 +-
.../java/accord/utils/async/AsyncCallbacks.java | 15 +-
.../main/java/accord/utils/async/AsyncChain.java | 9 +-
.../main/java/accord/utils/async/AsyncChains.java | 52 ++--
.../main/java/accord/utils/async/AsyncResult.java | 13 -
.../main/java/accord/utils/async/AsyncResults.java | 26 +-
accord-core/src/test/java/accord/Utils.java | 24 +-
.../src/test/java/accord/burn/BurnTest.java | 9 +-
.../coordinate/CoordinateTransactionTest.java | 254 +++++++++++++++--
.../src/test/java/accord/impl/TestAgent.java | 32 ++-
.../src/test/java/accord/impl/basic/Cluster.java | 11 +-
.../src/test/java/accord/impl/list/ListQuery.java | 10 +-
.../src/test/java/accord/impl/list/ListRead.java | 13 +-
.../test/java/accord/impl/mock/MockCluster.java | 6 +
.../src/test/java/accord/impl/mock/MockStore.java | 13 +-
.../java/accord/local/ImmutableCommandTest.java | 11 +-
.../test/java/accord/messages/PreAcceptTest.java | 49 +++-
.../test/java/accord/messages/ReadDataTest.java | 4 +-
.../src/main/java/accord/maelstrom/Cluster.java | 6 +-
.../main/java/accord/maelstrom/MaelstromQuery.java | 12 +-
.../main/java/accord/maelstrom/MaelstromRead.java | 12 +-
.../src/main/java/accord/maelstrom/Main.java | 6 +-
81 files changed, 2067 insertions(+), 917 deletions(-)
copy accord-core/src/main/java/accord/{impl/InMemorySafeCommandsForKey.java =>
api/BarrierType.java} (54%)
create mode 100644 accord-core/src/main/java/accord/coordinate/Barrier.java
create mode 100644 accord-core/src/main/java/accord/coordinate/BlockOnDeps.java
create mode 100644
accord-core/src/main/java/accord/coordinate/ProposeSyncPoint.java
copy accord-core/src/main/java/accord/coordinate/{Execute.java =>
TxnExecute.java} (72%)
copy accord-core/src/main/java/accord/{api/EventsListener.java =>
coordinate/TxnPersist.java} (53%)
copy accord-core/src/main/java/accord/coordinate/tracking/{ShardTracker.java
=> ResponseTracker.java} (83%)
copy accord-core/src/main/java/accord/messages/{ReadTxnData.java =>
AbstractExecute.java} (70%)
create mode 100644
accord-core/src/main/java/accord/messages/ApplyThenWaitUntilApplied.java
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@cassandra.apache.org
For additional commands, e-mail: commits-h...@cassandra.apache.org
