ASF Git Repos - activemq-artemis.git/commit

projects / activemq-artemis.git / commit

author	Clebert Suconic <clebertsuconic@apache.org>
	Wed, 1 Jun 2022 01:45:58 +0000 (21:45 -0400)
committer	clebertsuconic <clebert.suconic@gmail.com>
	Tue, 14 Jun 2022 18:53:14 +0000 (14:53 -0400)
commit	342565d4c1475e974c5cf874ad419842f037e976
tree	36873a9b726a3e0132ab9dd97e4108907f38213c	tree \| snapshot
parent	64de8f8f4edde44cdc6c044f3b4326c3eb97e84f	commit \| diff

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		diff \| blob \| history
artemis-cli/src/main/java/org/apache/activemq/artemis/cli/commands/tools/xml/XmlDataExporter.java		diff \| blob \| history
artemis-cli/src/main/resources/org/apache/activemq/artemis/cli/commands/etc/broker.xml		diff \| blob \| history
artemis-commons/src/main/java/org/apache/activemq/artemis/utils/ReferenceCounterUtil.java		diff \| blob \| history
artemis-commons/src/main/java/org/apache/activemq/artemis/utils/SizeAwareMetric.java		diff \| blob \| history
artemis-commons/src/main/java/org/apache/activemq/artemis/utils/collections/EmptyList.java	[new file with mode: 0644]	blob
artemis-commons/src/main/java/org/apache/activemq/artemis/utils/collections/LinkedList.java		diff \| blob \| history
artemis-commons/src/main/java/org/apache/activemq/artemis/utils/collections/LinkedListImpl.java		diff \| blob \| history
artemis-commons/src/test/java/org/apache/activemq/artemis/utils/Wait.java		diff \| blob \| history
artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/management/AddressControl.java		diff \| blob \| history
artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/CoreRemotingConnection.java		diff \| blob \| history
artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/PacketImpl.java		diff \| blob \| history
artemis-core-client/src/main/java/org/apache/activemq/artemis/utils/SoftValueLongObjectHashMap.java	[deleted file]	blob \| history
artemis-core-client/src/main/resources/activemq-version.properties		diff \| blob \| history
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/broker/AMQPLargeMessage.java		diff \| blob \| history
artemis-server/src/main/java/org/apache/activemq/artemis/core/deployers/impl/FileConfigurationParser.java		diff \| blob \| history
artemis-server/src/main/java/org/apache/activemq/artemis/core/management/impl/AddressControlImpl.java		diff \| blob \| history
artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/PageTransactionInfo.java		diff \| blob \| history
artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/PagedMessage.java		diff \| blob \| history
artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/PagingStore.java		diff \| blob \| history
artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/PageCursorProvider.java		diff \| blob \| history
artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/PageIterator.java		diff \| blob \| history
artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/PagePosition.java		diff \| blob \| history
artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/PageSubscription.java		diff \| blob \| history
artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/PagedReference.java		diff \| blob \| history
artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/PagedReferenceImpl.java		diff \| blob \| history
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]	diff \| blob \| history
artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/impl/LivePageCacheImpl.java	[deleted file]	blob \| history
artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/impl/PageCacheImpl.java	[deleted file]	blob \| history
artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/impl/PageCursorProviderImpl.java		diff \| blob \| history
artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/impl/PagePositionImpl.java		diff \| blob \| history
artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/impl/PageReader.java	[deleted file]	blob \| history
artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/impl/PageSubscriptionCounterImpl.java		diff \| blob \| history
artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/impl/PageSubscriptionImpl.java		diff \| blob \| history
artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/impl/Page.java		diff \| blob \| history
artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/impl/PageCache.java	[new file with mode: 0644]	blob
artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/impl/PageReadWriter.java	[new file with mode: 0644]	blob
artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/impl/PageTransactionInfoImpl.java		diff \| blob \| history
artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/impl/PagedMessageImpl.java		diff \| blob \| history
artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/impl/PagingStoreImpl.java		diff \| blob \| history
artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/StorageManager.java		diff \| blob \| history
artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/journal/AbstractJournalStorageManager.java		diff \| blob \| history
artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/journal/DescribeJournal.java		diff \| blob \| history
artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/journal/JournalStorageManager.java		diff \| blob \| history
artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/journal/LargeBody.java		diff \| blob \| history
artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/journal/LargeServerMessageImpl.java		diff \| blob \| history
artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/journal/codec/CursorAckRecordEncoding.java		diff \| blob \| history
artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/nullpm/NullStorageLargeServerMessage.java		diff \| blob \| history
artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/nullpm/NullStorageManager.java		diff \| blob \| history
artemis-server/src/main/java/org/apache/activemq/artemis/core/protocol/ServerPacketDecoder.java		diff \| blob \| history
artemis-server/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/ReplicationPageEventMessage.java		diff \| blob \| history
artemis-server/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/ReplicationPageWriteMessage.java		diff \| blob \| history
artemis-server/src/main/java/org/apache/activemq/artemis/core/replication/ReplicationEndpoint.java		diff \| blob \| history
artemis-server/src/main/java/org/apache/activemq/artemis/core/replication/ReplicationManager.java		diff \| blob \| history
artemis-server/src/main/java/org/apache/activemq/artemis/core/server/ActiveMQServerLogger.java		diff \| blob \| history
artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/PostOfficeJournalLoader.java		diff \| blob \| history
artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueImpl.java		diff \| blob \| history
artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ServerConsumerImpl.java		diff \| blob \| history
artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/SharedNothingBackupActivation.java		diff \| blob \| history
artemis-server/src/main/java/org/apache/activemq/artemis/core/settings/impl/AddressSettings.java		diff \| blob \| history
artemis-server/src/main/resources/schema/artemis-configuration.xsd		diff \| blob \| history
artemis-server/src/test/java/org/apache/activemq/artemis/core/config/impl/FileConfigurationParserTest.java		diff \| blob \| history
artemis-server/src/test/java/org/apache/activemq/artemis/core/config/impl/FileConfigurationTest.java		diff \| blob \| history
artemis-server/src/test/java/org/apache/activemq/artemis/core/paging/cursor/impl/PageCursorProviderAccessor.java	[new file with mode: 0644]	blob
artemis-server/src/test/java/org/apache/activemq/artemis/core/paging/cursor/impl/PageCursorProviderImplTest.java	[deleted file]	blob \| history
artemis-server/src/test/java/org/apache/activemq/artemis/core/paging/cursor/impl/PageReaderTest.java	[deleted file]	blob \| history
artemis-server/src/test/java/org/apache/activemq/artemis/core/paging/impl/PagingManagerTestAccessor.java		diff \| blob \| history
artemis-server/src/test/java/org/apache/activemq/artemis/core/paging/impl/PagingStoreTestAccessor.java		diff \| blob \| history
artemis-server/src/test/java/org/apache/activemq/artemis/core/server/impl/QueueImplTest.java		diff \| blob \| history
artemis-server/src/test/java/org/apache/activemq/artemis/core/server/impl/QueueImplTestAccessor.java		diff \| blob \| history
artemis-server/src/test/java/org/apache/activemq/artemis/core/transaction/impl/TransactionImplTest.java		diff \| blob \| history
artemis-server/src/test/java/org/apache/activemq/artemis/tests/util/ActiveMQTestBase.java		diff \| blob \| history
docs/user-manual/en/address-settings.md		diff \| blob \| history
docs/user-manual/en/config-reload.md		diff \| blob \| history
docs/user-manual/en/configuration-index.md		diff \| blob \| history
docs/user-manual/en/paging.md		diff \| blob \| history
pom.xml		diff \| blob \| history
tests/compatibility-tests/pom.xml		diff \| blob \| history
tests/compatibility-tests/src/main/java/org/apache/activemq/artemis/tests/compatibility/GroovyRun.java		diff \| blob \| history
tests/compatibility-tests/src/main/resources/multiVersionReplica/backupServer.groovy	[new file with mode: 0644]	blob
tests/compatibility-tests/src/main/resources/multiVersionReplica/backupServerIsActive.groovy	[new file with mode: 0644]	blob
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]	diff \| blob \| history
tests/compatibility-tests/src/main/resources/multiVersionReplica/mainServer.groovy	[new file with mode: 0644]	blob
tests/compatibility-tests/src/main/resources/multiVersionReplica/mainServerIsReplicated.groovy	[new file with mode: 0644]	blob
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]	diff \| blob \| history
tests/compatibility-tests/src/test/java/org/apache/activemq/artemis/tests/compatibility/MultiVersionReplicaTest.java	[new file with mode: 0644]	blob
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/connect/AMQPBridgeDisconnectTest.java		diff \| blob \| history
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/paging/AmqpPageReaderTest.java	[deleted file]	blob \| history
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/paging/AmqpPagingTest.java		diff \| blob \| history
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/client/JMSPagingFileDeleteTest.java		diff \| blob \| history
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/client/LargeMessageTest.java		diff \| blob \| history
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/client/SendAckFailTest.java		diff \| blob \| history
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/management/AddressControlUsingCoreTest.java		diff \| blob \| history
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/paging/PagingTest.java		diff \| blob \| history
tests/performance-tests/src/test/java/org/apache/activemq/artemis/tests/performance/storage/PersistMultiThreadTest.java		diff \| blob \| history
tests/stress-tests/src/test/java/org/apache/activemq/artemis/tests/stress/paging/PageCursorStressTest.java		diff \| blob \| history
tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/core/paging/impl/PageTest.java		diff \| blob \| history
tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/core/paging/impl/PagingManagerImplTest.java		diff \| blob \| history
tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/core/paging/impl/PagingStoreImplTest.java		diff \| blob \| history
tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/util/EmptyListTest.java	[new file with mode: 0644]	blob
tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/util/LinkedListTest.java		diff \| blob \| history
tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/util/SoftValueMapTest.java	[deleted file]	blob \| history

Mirror of Apache ActiveMQ Artemis

RSS Atom