This is an automated email from the ASF dual-hosted git repository.
bdeggleston pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/cassandra-accord.git
from b9025e5 CEP-15: (C*) Add git submodule for Accord (#29)
new 07e3514 add AsyncChain implementations and tests
new f607a05 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:
accord-core/build.gradle | 2 +-
accord-core/src/main/java/accord/api/Agent.java | 2 +-
accord-core/src/main/java/accord/api/Read.java | 49 +-
.../{Data.java => VisibleForImplementation.java} | 17 +-
accord-core/src/main/java/accord/api/Write.java | 4 +-
.../src/main/java/accord/coordinate/CheckOn.java | 27 +-
.../main/java/accord/coordinate/Coordinate.java | 14 +-
.../src/main/java/accord/coordinate/FetchData.java | 2 +-
.../java/accord/coordinate/InformHomeOfTxn.java | 8 +-
.../main/java/accord/coordinate/Invalidate.java | 14 +-
.../src/main/java/accord/coordinate/Persist.java | 4 +-
.../java/accord/coordinate/ReadCoordinator.java | 8 +-
.../src/main/java/accord/coordinate/Recover.java | 20 +-
.../java/accord/coordinate/RecoverWithHomeKey.java | 6 +-
.../coordinate/tracking/AbstractTracker.java | 6 +-
.../java/accord/impl/AbstractSafeCommandStore.java | 221 +++
.../src/main/java/accord/impl/CommandsForKey.java | 458 +++++-
.../src/main/java/accord/impl/InMemoryCommand.java | 342 ----
.../java/accord/impl/InMemoryCommandStore.java | 1098 ++++++++-----
.../java/accord/impl/InMemoryCommandStores.java | 31 +-
.../java/accord/impl/InMemoryCommandsForKey.java | 160 --
.../java/accord/impl/InMemorySafeCommand.java} | 43 +-
.../accord/impl/InMemorySafeCommandsForKey.java} | 44 +-
.../main/java/accord/impl/SafeCommandsForKey.java | 180 +++
.../ShardTracker.java => impl/SafeState.java} | 17 +-
.../main/java/accord/impl/SimpleProgressLog.java | 53 +-
.../main/java/accord/local/AsyncCommandStores.java | 92 --
.../src/main/java/accord/local/Command.java | 1643 +++++++++-----------
.../main/java/accord/local/CommandListener.java | 2 +-
.../src/main/java/accord/local/CommandStore.java | 27 +-
.../src/main/java/accord/local/CommandStores.java | 80 +-
.../src/main/java/accord/local/Commands.java | 1094 +++++++++++++
.../main/java/accord/local/CommonAttributes.java | 201 +++
.../src/main/java/accord/local/Listeners.java | 67 +
accord-core/src/main/java/accord/local/Node.java | 50 +-
.../src/main/java/accord/local/PreLoadContext.java | 17 +
.../src/main/java/accord/local/SafeCommand.java | 139 ++
.../main/java/accord/local/SafeCommandStore.java | 50 +-
accord-core/src/main/java/accord/local/Status.java | 4 +-
.../main/java/accord/local/SyncCommandStores.java | 114 --
.../src/main/java/accord/messages/Accept.java | 19 +-
.../src/main/java/accord/messages/Apply.java | 21 +-
.../java/accord/messages/BeginInvalidation.java | 8 +-
.../main/java/accord/messages/BeginRecovery.java | 17 +-
.../src/main/java/accord/messages/CheckStatus.java | 9 +-
.../src/main/java/accord/messages/Commit.java | 24 +-
.../src/main/java/accord/messages/Defer.java | 17 +-
.../main/java/accord/messages/InformDurable.java | 7 +-
.../java/accord/messages/InformHomeDurable.java | 11 +-
.../main/java/accord/messages/InformOfTxnId.java | 6 +-
.../src/main/java/accord/messages/PreAccept.java | 4 +-
.../src/main/java/accord/messages/ReadData.java | 39 +-
.../main/java/accord/messages/WaitOnCommit.java | 14 +-
.../src/main/java/accord/primitives/Timestamp.java | 2 +-
.../src/main/java/accord/primitives/Txn.java | 15 +-
.../src/main/java/accord/primitives/TxnId.java | 5 +
.../src/main/java/accord/primitives/Writes.java | 13 +-
.../main/java/accord/topology/TopologyManager.java | 21 +-
.../accord/utils/DeterministicIdentitySet.java | 16 +-
.../src/main/java/accord/utils/Invariants.java | 195 ++-
.../src/main/java/accord/utils/MapReduce.java | 19 +
.../src/main/java/accord/utils/ReducingFuture.java | 72 -
.../java/accord/utils/ThreadPoolScheduler.java | 3 +-
accord-core/src/main/java/accord/utils/Utils.java | 46 +
.../AsyncCallbacks.java} | 34 +-
.../main/java/accord/utils/async/AsyncChain.java | 81 +
.../accord/utils/async/AsyncChainCombiner.java | 168 ++
.../main/java/accord/utils/async/AsyncChains.java | 518 ++++++
.../main/java/accord/utils/async/AsyncResult.java | 96 ++
.../main/java/accord/utils/async/AsyncResults.java | 329 ++++
.../src/test/java/accord/burn/BurnTest.java | 3 +-
.../accord/burn/BurnTestConfigurationService.java | 20 +-
.../src/test/java/accord/burn/TopologyUpdates.java | 151 +-
.../java/accord/coordinate/CoordinateTest.java | 17 +-
.../test/java/accord/coordinate/RecoverTest.java | 2 +-
.../java/accord/coordinate/TopologyChangeTest.java | 40 +-
.../src/test/java/accord/impl/TestAgent.java | 2 +-
.../src/test/java/accord/impl/list/ListAgent.java | 2 +-
.../src/test/java/accord/impl/list/ListRead.java | 12 +-
.../src/test/java/accord/impl/list/ListWrite.java | 4 +-
.../src/test/java/accord/impl/mock/EpochSync.java | 34 +-
.../accord/impl/mock/MockConfigurationService.java | 4 -
.../src/test/java/accord/impl/mock/MockStore.java | 15 +-
...{CommandTest.java => ImmutableCommandTest.java} | 125 +-
.../test/java/accord/messages/PreAcceptTest.java | 26 +-
.../java/accord/topology/TopologyRandomizer.java | 18 +-
accord-core/src/test/java/accord/utils/Gens.java | 38 +-
.../src/test/java/accord/utils/MessageTask.java | 5 +-
.../src/test/java/accord/utils/Property.java | 14 +-
.../java/accord/utils/async/AsyncChainsTest.java | 303 ++++
accord-maelstrom/build.gradle | 2 +-
.../main/java/accord/maelstrom/MaelstromAgent.java | 2 +-
.../main/java/accord/maelstrom/MaelstromRead.java | 12 +-
.../main/java/accord/maelstrom/MaelstromWrite.java | 4 +-
.../java/accord/maelstrom/SimpleConfigService.java | 3 -
95 files changed, 6245 insertions(+), 2852 deletions(-)
copy accord-core/src/main/java/accord/api/{Data.java =>
VisibleForImplementation.java} (69%)
create mode 100644
accord-core/src/main/java/accord/impl/AbstractSafeCommandStore.java
delete mode 100644 accord-core/src/main/java/accord/impl/InMemoryCommand.java
delete mode 100644
accord-core/src/main/java/accord/impl/InMemoryCommandsForKey.java
copy accord-core/src/{test/java/accord/impl/TestAgent.java =>
main/java/accord/impl/InMemorySafeCommand.java} (51%)
copy accord-core/src/{test/java/accord/impl/list/ListData.java =>
main/java/accord/impl/InMemorySafeCommandsForKey.java} (56%)
create mode 100644
accord-core/src/main/java/accord/impl/SafeCommandsForKey.java
copy accord-core/src/main/java/accord/{coordinate/tracking/ShardTracker.java
=> impl/SafeState.java} (76%)
delete mode 100644
accord-core/src/main/java/accord/local/AsyncCommandStores.java
create mode 100644 accord-core/src/main/java/accord/local/Commands.java
create mode 100644 accord-core/src/main/java/accord/local/CommonAttributes.java
create mode 100644 accord-core/src/main/java/accord/local/SafeCommand.java
delete mode 100644
accord-core/src/main/java/accord/local/SyncCommandStores.java
delete mode 100644 accord-core/src/main/java/accord/utils/ReducingFuture.java
copy accord-core/src/main/java/accord/utils/{MapReduceConsume.java =>
async/AsyncCallbacks.java} (50%)
create mode 100644 accord-core/src/main/java/accord/utils/async/AsyncChain.java
create mode 100644
accord-core/src/main/java/accord/utils/async/AsyncChainCombiner.java
create mode 100644
accord-core/src/main/java/accord/utils/async/AsyncChains.java
create mode 100644
accord-core/src/main/java/accord/utils/async/AsyncResult.java
create mode 100644
accord-core/src/main/java/accord/utils/async/AsyncResults.java
rename accord-core/src/test/java/accord/local/{CommandTest.java =>
ImmutableCommandTest.java} (57%)
create mode 100644
accord-core/src/test/java/accord/utils/async/AsyncChainsTest.java
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@cassandra.apache.org
For additional commands, e-mail: commits-h...@cassandra.apache.org
