This is an automated email from the ASF dual-hosted git repository.
benedict pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/cassandra.git.
from a3bbcbf Merge branch 'cassandra-3.11' into trunk
add 860de83 Enable nodetool/JMX resizing of processing stage executor pool
No new revisions were added by this update.
Summary of changes:
CHANGES.txt | 1 +
.../cassandra/concurrent/ImmediateExecutor.java | 10 +-
.../JMXConfigurableThreadPoolExecutor.java | 36 -----
.../concurrent/JMXEnabledSingleThreadExecutor.java | 8 +-
.../concurrent/JMXEnabledThreadPoolExecutor.java | 15 +-
.../JMXEnabledThreadPoolExecutorMBean.java | 11 +-
.../concurrent/LocalAwareExecutorService.java | 17 ++-
...ExecutorMBean.java => ResizableThreadPool.java} | 25 +++-
.../apache/cassandra/concurrent/SEPExecutor.java | 105 ++++++++++---
.../SEPExecutorMBean.java} | 5 +-
.../org/apache/cassandra/concurrent/SEPWorker.java | 16 +-
.../cassandra/concurrent/SharedExecutorPool.java | 7 +-
.../org/apache/cassandra/concurrent/Stage.java | 165 +++++++++++++++++----
.../cassandra/config/DatabaseDescriptor.java | 41 +++++
src/java/org/apache/cassandra/db/Keyspace.java | 4 +-
.../cassandra/db/SinglePartitionReadCommand.java | 2 +-
.../cassandra/db/commitlog/CommitLogReplayer.java | 2 +-
src/java/org/apache/cassandra/gms/Gossiper.java | 6 +-
.../cassandra/net/InboundMessageHandler.java | 2 +-
.../org/apache/cassandra/net/MessagingService.java | 4 +-
.../org/apache/cassandra/net/RequestCallbacks.java | 2 +-
.../apache/cassandra/repair/RepairRunnable.java | 15 +-
.../org/apache/cassandra/repair/Validator.java | 4 +-
.../apache/cassandra/schema/MigrationManager.java | 6 +-
.../cassandra/schema/SchemaPushVerbHandler.java | 4 +-
.../org/apache/cassandra/service/CacheService.java | 4 +-
.../org/apache/cassandra/service/StorageProxy.java | 18 +--
.../apache/cassandra/service/StorageService.java | 24 ++-
.../cassandra/service/StorageServiceMBean.java | 19 +++
.../service/reads/AbstractReadExecutor.java | 2 +-
.../reads/ShortReadPartitionsProtection.java | 2 +-
.../service/reads/repair/AbstractReadRepair.java | 2 +-
src/java/org/apache/cassandra/tools/NodeProbe.java | 11 ++
src/java/org/apache/cassandra/tools/NodeTool.java | 3 +
.../nodetool/{Refresh.java => GetConcurrency.java} | 29 ++--
.../{GetTimeout.java => SetConcurrency.java} | 35 +++--
.../apache/cassandra/tracing/TraceStateImpl.java | 2 +-
.../org/apache/cassandra/tracing/TracingImpl.java | 2 +-
.../org/apache/cassandra/transport/Message.java | 1 +
.../cassandra/distributed/impl/Instance.java | 2 +-
.../org/apache/cassandra/cql3/ViewLongTest.java | 4 +-
.../cassandra/concurrent/SEPExecutorTest.java | 109 ++++++++++++++
.../org/apache/cassandra/cql3/ViewComplexTest.java | 4 +-
.../apache/cassandra/cql3/ViewFilteringTest.java | 4 +-
.../org/apache/cassandra/cql3/ViewSchemaTest.java | 4 +-
test/unit/org/apache/cassandra/cql3/ViewTest.java | 6 +-
.../org/apache/cassandra/net/MatcherResponse.java | 2 +-
47 files changed, 610 insertions(+), 192 deletions(-)
delete mode 100644
src/java/org/apache/cassandra/concurrent/JMXConfigurableThreadPoolExecutor.java
rename
src/java/org/apache/cassandra/concurrent/{JMXConfigurableThreadPoolExecutorMBean.java
=> ResizableThreadPool.java} (62%)
copy src/java/org/apache/cassandra/{cache/CacheProvider.java =>
concurrent/SEPExecutorMBean.java} (88%)
copy src/java/org/apache/cassandra/tools/nodetool/{Refresh.java =>
GetConcurrency.java} (60%)
copy src/java/org/apache/cassandra/tools/nodetool/{GetTimeout.java =>
SetConcurrency.java} (50%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
