This is an automated email from the ASF dual-hosted git repository.
clebertsuconic pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/activemq-artemis.git
from 996d5da515 NO-JIRA Removing RetryRule
new e7dbe8d68e ARTEMIS-5303 -1 should mean NULL on AddressSettings
new 24d1bbe603 ARTEMIS-5305 Improving performance of paging with multiple
producers
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:
.../artemis/cli/commands/tools/DBOption.java | 4 +-
.../artemis/cli/commands/tools/PrintData.java | 2 +-
.../activemq/artemis/core/paging/PagingStore.java | 30 +-
.../cursor/impl/PageCounterRebuildManager.java | 4 +-
.../paging/cursor/impl/PageCursorProviderImpl.java | 12 +-
.../activemq/artemis/core/paging/impl/Page.java | 4 +-
.../artemis/core/paging/impl/PageSyncTimer.java | 98 ----
.../artemis/core/paging/impl/PageTimedWriter.java | 200 +++++++
.../paging/impl/PagingStoreFactoryDatabase.java | 8 +-
.../core/paging/impl/PagingStoreFactoryNIO.java | 8 +-
.../artemis/core/paging/impl/PagingStoreImpl.java | 580 ++++++++++++---------
.../artemis/core/persistence/StorageManager.java | 12 +-
.../journal/AbstractJournalStorageManager.java | 11 +-
.../impl/journal/JournalStorageManager.java | 41 +-
.../impl/nullpm/NullStorageManager.java | 14 +-
.../core/replication/ReplicationManager.java | 4 +-
.../core/server/impl/ActiveMQServerImpl.java | 4 +-
.../core/server/impl/RoutingContextImpl.java | 2 +-
.../core/settings/impl/AddressSettings.java | 6 +-
.../core/config/impl/ConfigurationImplTest.java | 21 +-
.../core/paging/cursor/impl/ConcurrentAckTest.java | 2 +-
.../core/server/files/FileMoveManagerTest.java | 7 +-
.../artemis/core/settings/AddressSettingsTest.java | 7 +
.../core/transaction/impl/TransactionImplTest.java | 4 +-
.../impl/PageCursorProviderTestAccessor.java | 17 +-
.../artemis/tests/util/ActiveMQTestBase.java | 55 +-
.../artemis/tests/db/paging/PageSizeTest.java | 3 +-
.../artemis/tests/db/paging/PagingTest.java | 133 ++---
.../db/paging/RealServerDatabasePagingTest.java | 3 +-
.../amqp/paging/AmqpFilterChangePageTest.java | 2 +-
.../tests/integration/client/SendAckFailTest.java | 6 +-
.../cluster/failover/BackupSyncJournalTest.java | 6 +-
.../failover/NettyReplicatedFailoverTest.java | 2 +-
.../failover/PrimaryCrashOnBackupSyncTest.java | 4 +-
.../failover/ReplicatedPagedFailoverTest.java | 2 +-
...kManagerPageCleanupWhileReplicaCatchupTest.java | 34 --
.../jms/cluster/TopicClusterPageStoreSizeTest.java | 37 +-
.../paging/GlobalJournalPagingTest.java | 2 +-
.../integration/paging/JournalPagingTest.java | 8 +-
.../paging/MessagesExpiredPagingTest.java | 4 +-
.../integration/paging/PagingReceiveTest.java | 2 +-
.../paging/TestDeadlockOnPurgePagingTest.java | 2 +-
.../integration/replication/ReplicationTest.java | 13 +-
.../SharedNothingReplicationFlowControlTest.java | 4 +-
.../artemis/tests/leak/FilteredPagingLeakTest.java | 2 +-
.../artemis/tests/leak/PagingLeakTest.java | 4 +-
.../storage/PersistMultiThreadTest.java | 31 +-
.../multipleProducersPagingSoak}/broker.xml | 15 +-
.../paging/MultipleProducersPagingSoakTest.java | 190 +++++++
.../journal/JournalStorageManagerAccessor.java | 14 +-
.../tests/unit/core/paging/impl/AmqpPageTest.java | 4 +-
.../tests/unit/core/paging/impl/PageTest.java | 4 +-
.../core/paging/impl/PageTimedWriterUnitTest.java | 532 +++++++++++++++++++
.../core/paging/impl/PagingManagerImplTest.java | 27 +-
.../unit/core/paging/impl/PagingStoreImplTest.java | 392 ++++----------
55 files changed, 1705 insertions(+), 934 deletions(-)
delete mode 100644
artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/impl/PageSyncTimer.java
create mode 100644
artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/impl/PageTimedWriter.java
delete mode 100644
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/cluster/failover/lockmanager/LockManagerPageCleanupWhileReplicaCatchupTest.java
copy tests/{smoke-tests/src/main/resources/servers/paging =>
soak-tests/src/main/resources/servers/multipleProducersPagingSoak}/broker.xml
(94%)
create mode 100644
tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/paging/MultipleProducersPagingSoakTest.java
copy
artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/journal/codec/RefEncoding.java
=>
tests/unit-tests/src/test/java/org/apache/activemq/artemis/core/persistence/impl/journal/JournalStorageManagerAccessor.java
(73%)
create mode 100644
tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/core/paging/impl/PageTimedWriterUnitTest.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
For further information, visit: https://activemq.apache.org/contact
