ARTEMIS-3850 Eliminate Page Soft Cache. Add Option to read messages based on sizing.
authorClebert Suconic <clebertsuconic@apache.org>
Wed, 1 Jun 2022 01:45:58 +0000 (21:45 -0400)
committerclebertsuconic <clebert.suconic@gmail.com>
Tue, 14 Jun 2022 18:53:14 +0000 (14:53 -0400)
commit342565d4c1475e974c5cf874ad419842f037e976
tree36873a9b726a3e0132ab9dd97e4108907f38213c
parent64de8f8f4edde44cdc6c044f3b4326c3eb97e84f
ARTEMIS-3850 Eliminate Page Soft Cache. Add Option to read messages based on sizing.
102 files changed:
artemis-cli/src/main/java/org/apache/activemq/artemis/cli/commands/tools/PrintData.java
artemis-cli/src/main/java/org/apache/activemq/artemis/cli/commands/tools/xml/XmlDataExporter.java
artemis-cli/src/main/resources/org/apache/activemq/artemis/cli/commands/etc/broker.xml
artemis-commons/src/main/java/org/apache/activemq/artemis/utils/ReferenceCounterUtil.java
artemis-commons/src/main/java/org/apache/activemq/artemis/utils/SizeAwareMetric.java
artemis-commons/src/main/java/org/apache/activemq/artemis/utils/collections/EmptyList.java [new file with mode: 0644]
artemis-commons/src/main/java/org/apache/activemq/artemis/utils/collections/LinkedList.java
artemis-commons/src/main/java/org/apache/activemq/artemis/utils/collections/LinkedListImpl.java
artemis-commons/src/test/java/org/apache/activemq/artemis/utils/Wait.java
artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/management/AddressControl.java
artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/CoreRemotingConnection.java
artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/PacketImpl.java
artemis-core-client/src/main/java/org/apache/activemq/artemis/utils/SoftValueLongObjectHashMap.java [deleted file]
artemis-core-client/src/main/resources/activemq-version.properties
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/broker/AMQPLargeMessage.java
artemis-server/src/main/java/org/apache/activemq/artemis/core/deployers/impl/FileConfigurationParser.java
artemis-server/src/main/java/org/apache/activemq/artemis/core/management/impl/AddressControlImpl.java
artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/PageTransactionInfo.java
artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/PagedMessage.java
artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/PagingStore.java
artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/PageCursorProvider.java
artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/PageIterator.java
artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/PagePosition.java
artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/PageSubscription.java
artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/PagedReference.java
artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/PagedReferenceImpl.java
artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/QueryPagedReferenceImpl.java [moved from artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/PageCache.java with 67% similarity]
artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/impl/LivePageCacheImpl.java [deleted file]
artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/impl/PageCacheImpl.java [deleted file]
artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/impl/PageCursorProviderImpl.java
artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/impl/PagePositionImpl.java
artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/impl/PageReader.java [deleted file]
artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/impl/PageSubscriptionCounterImpl.java
artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/impl/PageSubscriptionImpl.java
artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/impl/Page.java
artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/impl/PageCache.java [new file with mode: 0644]
artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/impl/PageReadWriter.java [new file with mode: 0644]
artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/impl/PageTransactionInfoImpl.java
artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/impl/PagedMessageImpl.java
artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/impl/PagingStoreImpl.java
artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/StorageManager.java
artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/journal/AbstractJournalStorageManager.java
artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/journal/DescribeJournal.java
artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/journal/JournalStorageManager.java
artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/journal/LargeBody.java
artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/journal/LargeServerMessageImpl.java
artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/journal/codec/CursorAckRecordEncoding.java
artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/nullpm/NullStorageLargeServerMessage.java
artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/nullpm/NullStorageManager.java
artemis-server/src/main/java/org/apache/activemq/artemis/core/protocol/ServerPacketDecoder.java
artemis-server/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/ReplicationPageEventMessage.java
artemis-server/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/ReplicationPageWriteMessage.java
artemis-server/src/main/java/org/apache/activemq/artemis/core/replication/ReplicationEndpoint.java
artemis-server/src/main/java/org/apache/activemq/artemis/core/replication/ReplicationManager.java
artemis-server/src/main/java/org/apache/activemq/artemis/core/server/ActiveMQServerLogger.java
artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/PostOfficeJournalLoader.java
artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueImpl.java
artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ServerConsumerImpl.java
artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/SharedNothingBackupActivation.java
artemis-server/src/main/java/org/apache/activemq/artemis/core/settings/impl/AddressSettings.java
artemis-server/src/main/resources/schema/artemis-configuration.xsd
artemis-server/src/test/java/org/apache/activemq/artemis/core/config/impl/FileConfigurationParserTest.java
artemis-server/src/test/java/org/apache/activemq/artemis/core/config/impl/FileConfigurationTest.java
artemis-server/src/test/java/org/apache/activemq/artemis/core/paging/cursor/impl/PageCursorProviderAccessor.java [new file with mode: 0644]
artemis-server/src/test/java/org/apache/activemq/artemis/core/paging/cursor/impl/PageCursorProviderImplTest.java [deleted file]
artemis-server/src/test/java/org/apache/activemq/artemis/core/paging/cursor/impl/PageReaderTest.java [deleted file]
artemis-server/src/test/java/org/apache/activemq/artemis/core/paging/impl/PagingManagerTestAccessor.java
artemis-server/src/test/java/org/apache/activemq/artemis/core/paging/impl/PagingStoreTestAccessor.java
artemis-server/src/test/java/org/apache/activemq/artemis/core/server/impl/QueueImplTest.java
artemis-server/src/test/java/org/apache/activemq/artemis/core/server/impl/QueueImplTestAccessor.java
artemis-server/src/test/java/org/apache/activemq/artemis/core/transaction/impl/TransactionImplTest.java
artemis-server/src/test/java/org/apache/activemq/artemis/tests/util/ActiveMQTestBase.java
docs/user-manual/en/address-settings.md
docs/user-manual/en/config-reload.md
docs/user-manual/en/configuration-index.md
docs/user-manual/en/paging.md
pom.xml
tests/compatibility-tests/pom.xml
tests/compatibility-tests/src/main/java/org/apache/activemq/artemis/tests/compatibility/GroovyRun.java
tests/compatibility-tests/src/main/resources/multiVersionReplica/backupServer.groovy [new file with mode: 0644]
tests/compatibility-tests/src/main/resources/multiVersionReplica/backupServerIsActive.groovy [new file with mode: 0644]
tests/compatibility-tests/src/main/resources/multiVersionReplica/backupServerStop.groovy [moved from artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/BulkPageCache.java with 79% similarity]
tests/compatibility-tests/src/main/resources/multiVersionReplica/mainServer.groovy [new file with mode: 0644]
tests/compatibility-tests/src/main/resources/multiVersionReplica/mainServerIsReplicated.groovy [new file with mode: 0644]
tests/compatibility-tests/src/main/resources/multiVersionReplica/mainServerStop.groovy [moved from artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/LivePageCache.java with 78% similarity]
tests/compatibility-tests/src/test/java/org/apache/activemq/artemis/tests/compatibility/MultiVersionReplicaTest.java [new file with mode: 0644]
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/connect/AMQPBridgeDisconnectTest.java
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/paging/AmqpPageReaderTest.java [deleted file]
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/paging/AmqpPagingTest.java
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/client/JMSPagingFileDeleteTest.java
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/client/LargeMessageTest.java
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/client/SendAckFailTest.java
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/management/AddressControlUsingCoreTest.java
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/paging/PagingTest.java
tests/performance-tests/src/test/java/org/apache/activemq/artemis/tests/performance/storage/PersistMultiThreadTest.java
tests/stress-tests/src/test/java/org/apache/activemq/artemis/tests/stress/paging/PageCursorStressTest.java
tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/core/paging/impl/PageTest.java
tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/core/paging/impl/PagingManagerImplTest.java
tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/core/paging/impl/PagingStoreImplTest.java
tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/util/EmptyListTest.java [new file with mode: 0644]
tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/util/LinkedListTest.java
tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/util/SoftValueMapTest.java [deleted file]