This is an automated email from the ASF dual-hosted git repository.
ifesdjeen pushed a change to branch cassandra-5.0
in repository https://gitbox.apache.org/repos/asf/cassandra.git
from fbfa77e70f Merge branch 'cassandra-4.1' into cassandra-5.0
add 9ebe0aa08a Replace getStderr calls with getCleanedStderr calls in
tests checking for emptiness
add dc17c29724 Add native transport deadline, an ultimate deadline for all
tasks related to a specific request
add 617a75843c Merge branch 'cassandra-4.1' into cassandra-5.0
No new revisions were added by this update.
Summary of changes:
CHANGES.txt | 2 +-
.../cassandra/auth/CIDRGroupsMappingManager.java | 5 +-
.../cassandra/auth/CIDRPermissionsManager.java | 4 +-
.../apache/cassandra/auth/CassandraAuthorizer.java | 7 +-
.../cassandra/auth/CassandraNetworkAuthorizer.java | 4 +-
.../cassandra/auth/CassandraRoleManager.java | 4 +-
.../cassandra/auth/PasswordAuthenticator.java | 4 +-
.../apache/cassandra/batchlog/BatchlogManager.java | 8 +-
.../cassandra/concurrent/DebuggableTask.java | 9 +
.../apache/cassandra/concurrent/FutureTask.java | 28 ++
.../cassandra/concurrent/ResizableThreadPool.java | 5 +
.../apache/cassandra/concurrent/SEPExecutor.java | 15 +
src/java/org/apache/cassandra/config/Config.java | 20 ++
.../cassandra/config/DatabaseDescriptor.java | 103 ++++++
.../org/apache/cassandra/cql3/CQLStatement.java | 5 +-
.../cql3/CustomPayloadMirroringQueryHandler.java | 16 +-
.../org/apache/cassandra/cql3/QueryHandler.java | 7 +-
.../org/apache/cassandra/cql3/QueryProcessor.java | 42 +--
.../apache/cassandra/cql3/UntypedResultSet.java | 5 +-
.../cql3/statements/AuthenticationStatement.java | 5 +-
.../cql3/statements/AuthorizationStatement.java | 4 +-
.../cassandra/cql3/statements/BatchStatement.java | 34 +-
.../cql3/statements/DescribeStatement.java | 3 +-
.../cql3/statements/ModificationStatement.java | 50 +--
.../cassandra/cql3/statements/SelectStatement.java | 30 +-
.../cql3/statements/TruncateStatement.java | 4 +-
.../cassandra/cql3/statements/UseStatement.java | 7 +-
.../statements/schema/AlterSchemaStatement.java | 4 +-
.../cassandra/db/CounterMutationVerbHandler.java | 6 +-
.../apache/cassandra/db/MutationVerbHandler.java | 9 +
.../cassandra/db/PartitionRangeReadCommand.java | 7 +-
src/java/org/apache/cassandra/db/ReadCommand.java | 20 +-
src/java/org/apache/cassandra/db/ReadQuery.java | 6 +-
.../cassandra/db/SinglePartitionReadCommand.java | 17 +-
.../org/apache/cassandra/db/view/TableViews.java | 5 +-
.../apache/cassandra/db/view/ViewBuilderTask.java | 4 +-
.../db/virtual/CIDRFilteringMetricsTable.java | 4 +-
.../locator/AbstractReplicationStrategy.java | 15 +-
.../apache/cassandra/metrics/ClientMetrics.java | 44 ++-
.../cassandra/metrics/ThreadPoolMetrics.java | 7 +
.../cassandra/net/InboundMessageHandler.java | 12 +-
src/java/org/apache/cassandra/net/Message.java | 31 +-
.../apache/cassandra/repair/RepairCoordinator.java | 3 +-
.../service/AbstractWriteResponseHandler.java | 41 ++-
.../cassandra/service/BatchlogResponseHandler.java | 5 +-
.../apache/cassandra/service/CassandraDaemon.java | 16 +-
.../DatacenterSyncWriteResponseHandler.java | 5 +-
.../service/DatacenterWriteResponseHandler.java | 5 +-
.../cassandra/service/NativeTransportService.java | 7 +-
.../org/apache/cassandra/service/StorageProxy.java | 348 +++++++++++----------
.../apache/cassandra/service/StorageService.java | 71 ++++-
.../cassandra/service/StorageServiceMBean.java | 21 +-
.../cassandra/service/WriteResponseHandler.java | 9 +-
.../service/pager/AbstractQueryPager.java | 5 +-
.../service/pager/AggregationQueryPager.java | 41 ++-
.../service/pager/MultiPartitionPager.java | 19 +-
.../apache/cassandra/service/pager/QueryPager.java | 5 +-
.../org/apache/cassandra/service/paxos/Paxos.java | 18 +-
.../service/paxos/v1/AbstractPaxosCallback.java | 16 +-
.../service/paxos/v1/PrepareCallback.java | 5 +-
.../service/paxos/v1/ProposeCallback.java | 5 +-
.../service/reads/AbstractReadExecutor.java | 73 +++--
.../cassandra/service/reads/DataResolver.java | 13 +-
.../cassandra/service/reads/DigestResolver.java | 7 +-
.../cassandra/service/reads/ReadCallback.java | 40 ++-
.../service/reads/ReplicaFilteringProtection.java | 15 +-
.../cassandra/service/reads/ResponseResolver.java | 7 +-
.../reads/ShortReadPartitionsProtection.java | 15 +-
.../service/reads/ShortReadProtection.java | 5 +-
.../service/reads/range/RangeCommandIterator.java | 26 +-
.../service/reads/range/RangeCommands.java | 11 +-
.../reads/range/ScanAllRangesCommandIterator.java | 11 +-
.../service/reads/repair/AbstractReadRepair.java | 20 +-
.../service/reads/repair/BlockingReadRepair.java | 9 +-
.../service/reads/repair/ReadOnlyReadRepair.java | 5 +-
.../cassandra/service/reads/repair/ReadRepair.java | 7 +-
.../service/reads/repair/ReadRepairStrategy.java | 9 +-
src/java/org/apache/cassandra/tools/NodeProbe.java | 4 +-
.../cassandra/tools/nodetool/DisableBinary.java | 7 +-
.../apache/cassandra/tracing/TraceStateImpl.java | 4 +-
.../cassandra/transport/CQLMessageHandler.java | 194 ++++++++----
.../cassandra/transport/ClientResourceLimits.java | 2 +-
.../org/apache/cassandra/transport/Connection.java | 1 +
.../org/apache/cassandra/transport/Dispatcher.java | 289 +++++++++++++++--
.../transport/InitialConnectionHandler.java | 4 +-
.../org/apache/cassandra/transport/Message.java | 20 +-
.../cassandra/transport/PipelineConfigurator.java | 33 +-
.../apache/cassandra/transport/PreV5Handlers.java | 58 ++--
.../cassandra/transport/QueueBackpressure.java | 146 +++++++++
.../org/apache/cassandra/transport/Server.java | 42 ++-
.../apache/cassandra/transport/SimpleClient.java | 22 +-
.../cassandra/transport/messages/AuthResponse.java | 2 +-
.../cassandra/transport/messages/BatchMessage.java | 5 +-
.../transport/messages/ExecuteMessage.java | 6 +-
.../transport/messages/OptionsMessage.java | 3 +-
.../transport/messages/PrepareMessage.java | 3 +-
.../cassandra/transport/messages/QueryMessage.java | 5 +-
.../transport/messages/RegisterMessage.java | 2 +-
.../transport/messages/StartupMessage.java | 2 +-
.../apache/cassandra/transport/DriverBurnTest.java | 8 +-
.../cassandra/transport/SimpleClientBurnTest.java | 3 +-
.../cassandra/transport/SimpleClientPerfTest.java | 3 +-
.../cassandra/distributed/impl/Coordinator.java | 73 +----
.../distributed/impl/CoordinatorHelper.java | 106 +++++++
.../apache/cassandra/distributed/impl/Query.java | 7 +-
.../distributed/test/ByteBuddyExamplesTest.java | 3 +-
.../distributed/test/DisableBinaryTest.java | 209 +++++++++++++
.../test/FailingResponseDoesNotLogTest.java | 7 +-
.../distributed/test/FailureLoggingTest.java | 5 +-
.../distributed/test/LargeColumnTest.java | 2 +
.../distributed/test/MessageTimestampTest.java | 111 +++++++
.../test/NodeToolEnableDisableBinaryTest.java | 119 +++----
.../cassandra/distributed/test/OverloadTest.java | 247 +++++++++++++++
.../cassandra/distributed/test/ReadRepairTest.java | 4 +-
.../distributed/test/ReadSpeculationTest.java | 209 +++++++++++++
.../test/UnableToParseClientMessageTest.java | 3 +-
.../test/metrics/RequestTimeoutTest.java | 24 +-
.../test/ring/ReadsDuringBootstrapTest.java | 1 +
.../test/microbench/BatchStatementBench.java | 5 +-
.../config/DatabaseDescriptorRefTest.java | 1 +
.../cassandra/cql3/CustomNowInSecondsTest.java | 8 +-
.../cassandra/cql3/PstmtPersistenceTest.java | 7 +-
.../cql3/statements/AddIdentityStatementTest.java | 19 +-
.../cql3/statements/DropIdentityStatementTest.java | 15 +-
.../cassandra/db/guardrails/GuardrailTester.java | 4 +-
.../index/sai/cql/VectorInvalidQueryTest.java | 3 +-
.../org/apache/cassandra/net/ConnectionTest.java | 2 +-
.../service/WriteResponseHandlerTest.java | 9 +-
.../cassandra/service/reads/DataResolverTest.java | 70 ++---
.../service/reads/DigestResolverTest.java | 16 +-
.../cassandra/service/reads/ReadExecutorTest.java | 14 +-
.../reads/range/RangeCommandIteratorTest.java | 12 +-
.../service/reads/range/RangeCommandsTest.java | 8 +-
.../reads/repair/AbstractReadRepairTest.java | 5 +-
.../reads/repair/BlockingReadRepairTest.java | 9 +-
.../repair/DiagEventsBlockingReadRepairTest.java | 10 +-
.../reads/repair/ReadOnlyReadRepairTest.java | 9 +-
.../cassandra/transport/CQLConnectionTest.java | 20 +-
.../cassandra/transport/MessageDispatcherTest.java | 30 +-
.../cassandra/transport/MessagePayloadTest.java | 14 +-
.../cassandra/transport/QueueBackpressureTest.java | 60 ++++
141 files changed, 2923 insertions(+), 964 deletions(-)
create mode 100644
src/java/org/apache/cassandra/transport/QueueBackpressure.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/impl/CoordinatorHelper.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/DisableBinaryTest.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/MessageTimestampTest.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/OverloadTest.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/ReadSpeculationTest.java
create mode 100644
test/unit/org/apache/cassandra/transport/QueueBackpressureTest.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
