This is an automated email from the ASF dual-hosted git repository. maedhroz pushed a commit to branch cep-15-accord in repository https://gitbox.apache.org/repos/asf/cassandra.git
commit 12d8af0ae5a8db85771c4879a83b74161d0ca7dd Author: David Capwell <[email protected]> AuthorDate: Mon Dec 12 15:50:59 2022 -0800 Ninja for CASSANDRA-17719: Add @Simulate(with = MONITORS) to MultiReadFuture to get simulator working --- src/java/org/apache/cassandra/service/accord/txn/TxnRead.java | 3 +++ 1 file changed, 3 insertions(+) diff --git a/src/java/org/apache/cassandra/service/accord/txn/TxnRead.java b/src/java/org/apache/cassandra/service/accord/txn/TxnRead.java index 9626d81220..94ad0693f1 100644 --- a/src/java/org/apache/cassandra/service/accord/txn/TxnRead.java +++ b/src/java/org/apache/cassandra/service/accord/txn/TxnRead.java @@ -39,6 +39,7 @@ import org.apache.cassandra.io.util.DataOutputPlus; import org.apache.cassandra.service.accord.api.PartitionKey; import org.apache.cassandra.service.accord.serializers.KeySerializers; import org.apache.cassandra.utils.ObjectSizes; +import org.apache.cassandra.utils.Simulate; import org.apache.cassandra.utils.concurrent.AsyncPromise; import org.apache.cassandra.utils.concurrent.Future; import org.apache.cassandra.utils.concurrent.ImmediateFuture; @@ -46,6 +47,7 @@ import org.apache.cassandra.utils.concurrent.ImmediateFuture; import static org.apache.cassandra.utils.ArraySerializers.deserializeArray; import static org.apache.cassandra.utils.ArraySerializers.serializeArray; import static org.apache.cassandra.utils.ArraySerializers.serializedArraySize; +import static org.apache.cassandra.utils.Simulate.With.MONITORS; public class TxnRead extends AbstractKeySorted<TxnNamedRead> implements Read { @@ -143,6 +145,7 @@ public class TxnRead extends AbstractKeySorted<TxnNamedRead> implements Read return new MultiReadFuture(futures); } + @Simulate(with = MONITORS) private static class MultiReadFuture extends AsyncPromise<Data> implements BiConsumer<Data, Throwable> { private Data result = null; --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
