This is an automated email from the ASF dual-hosted git repository.
technoboy pushed a change to branch branch-2.11
in repository https://gitbox.apache.org/repos/asf/pulsar.git
from 2e85be99747 [improve][client] Refactor SchemaHash to reduce call of
hashFunction in SchemaHash (#17948)
new 44d45af6d21 Apply modernizer-maven-plugin to managed-ledger module.
(#16363)
new df33f59cb4f [enh][broker] Add metrics for entry cache insertion,
eviction (#17248)
new 55a0cb4841e [managed-ledger] Do not send duplicate reads to
BK/offloaders (#17241)
new 1fc4ccf8240 [bug][broker] fix memory leak in case of error conditions
in PendingReadsManager (#17995)
The 4 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:
managed-ledger/pom.xml | 18 +
.../bookkeeper/mledger/ManagedLedgerConfig.java | 6 +-
.../mledger/ManagedLedgerFactoryMXBean.java | 15 +
.../mledger/impl/LedgerMetadataUtils.java | 11 +-
.../mledger/impl/ManagedCursorContainer.java | 7 +-
.../bookkeeper/mledger/impl/ManagedCursorImpl.java | 34 +-
.../mledger/impl/ManagedLedgerFactoryImpl.java | 5 +-
.../impl/ManagedLedgerFactoryMBeanImpl.java | 27 ++
.../bookkeeper/mledger/impl/ManagedLedgerImpl.java | 24 +-
.../bookkeeper/mledger/impl/OpReadEntry.java | 4 +-
.../bookkeeper/mledger/impl/RangeSetWrapper.java | 4 +-
.../cache/EntryCacheDefaultEvictionPolicy.java | 4 +-
.../mledger/impl/cache/EntryCacheDisabled.java | 7 +-
.../mledger/impl/cache/PendingReadsManager.java | 452 ++++++++++++++++++++
.../mledger/impl/cache/RangeEntryCacheImpl.java | 125 +++---
.../impl/cache/RangeEntryCacheManagerImpl.java | 8 +-
.../bookkeeper/mledger/offload/OffloadUtils.java | 8 +-
.../apache/bookkeeper/mledger/util/RangeCache.java | 16 +-
.../bookkeeper/mledger/SimpleBookKeeperTest.java | 4 +-
.../mledger/impl/EntryCacheManagerTest.java | 18 +
.../bookkeeper/mledger/impl/EntryCacheTest.java | 4 +-
.../mledger/impl/ManagedCursorConcurrencyTest.java | 10 +-
.../mledger/impl/ManagedCursorContainerTest.java | 4 +-
...ManagedCursorIndividualDeletedMessagesTest.java | 6 +-
.../mledger/impl/ManagedCursorListAckTest.java | 4 +-
.../bookkeeper/mledger/impl/ManagedCursorTest.java | 13 +-
.../mledger/impl/ManagedLedgerBkTest.java | 17 +-
.../ManagedLedgerFactoryChangeLedgerPathTest.java | 9 +-
.../impl/ManagedLedgerSingleBookieTest.java | 4 +-
.../bookkeeper/mledger/impl/ManagedLedgerTest.java | 13 +-
.../mledger/impl/NonDurableCursorTest.java | 11 +-
.../mledger/impl/OffloadPrefixReadTest.java | 10 +-
.../bookkeeper/mledger/impl/OffloadPrefixTest.java | 19 +-
.../mledger/impl/RangeSetWrapperTest.java | 5 +-
.../impl/cache/PendingReadsManagerTest.java | 462 +++++++++++++++++++++
.../bookkeeper/mledger/util/RangeCacheTest.java | 5 +-
.../stats/metrics/ManagedLedgerCacheMetrics.java | 3 +
.../client/api/MessageDispatchThrottlingTest.java | 8 +
site2/docs/reference-metrics.md | 3 +
39 files changed, 1225 insertions(+), 182 deletions(-)
create mode 100644
managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/cache/PendingReadsManager.java
create mode 100644
managed-ledger/src/test/java/org/apache/bookkeeper/mledger/impl/cache/PendingReadsManagerTest.java
