This is an automated email from the ASF dual-hosted git repository.
penghui pushed a change to branch branch-2.8
in repository https://gitbox.apache.org/repos/asf/pulsar.git
from 25d0edc9345 fix LICENSE for branch-2.8 (#15261)
new 58d074d907c [LoadBalance] Optimize find nics process. (#14340)
new 241320fd891 Support shrink in ConcurrentLongHashMap (#14497)
new 2cbf9f4f0dd Optimize memory usage: support to shrink for pendingAcks
map (#14515)
new 7ca9bf818de support shrink for map or set (#14663)
new 7c29b1d5fa1 Reduce unnecessary expansions for ConcurrentLong map and
set (#14562)
new c8858e18da0 [fix][security] Remove log4j for CVE-2022-23307 (#15109)
new e690b4c8a21 Skip unnecessary DNS resolution when creating
AuthenticationDataHttp instance (#15221)
new 3d8101f7ef4 Improve skipping of DNS resolution when creating
AuthenticationDataHttp instance (#15228)
new 324ce900c4c Fix topic closed normally but still call
`closeFencedTopicForcefully`. (#15196) (#15202)
new 55323cac872 [Functions] Check executor null when closing the
FileSource (#15247)
new 02e02d182f6 [Fix][Broker] Fix race condition in `OpAddEntry` (#15233)
new fbe4ddcb828 [fix] [broker] Fix problem at RateLimiter#tryAcquire
(#15306)
new c0c67db2ab4 [C++] Wait until event loop terminates when closing the
Client (#15316)
new b4762d1ec44 [improve][broker] Use shrink map for message redelivery.
(#15342)
new 9e8c3242f70 [improve][broker] Support shrink for
ConcurrentSortedLongPairSet (#15354)
The 15 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:
.../bookkeeper/mledger/impl/ManagedLedgerImpl.java | 10 +-
.../mledger/impl/ManagedLedgerOfflineBacklog.java | 3 +-
pom.xml | 13 -
.../apache/pulsar/broker/ServiceConfiguration.java | 8 +
.../authentication/AuthenticationDataHttp.java | 2 +-
.../loadbalance/impl/LinuxBrokerHostUsageImpl.java | 34 +-
.../broker/loadbalance/impl/LoadManagerShared.java | 20 +-
.../loadbalance/impl/ModularLoadManagerImpl.java | 18 +-
.../loadbalance/impl/SimpleLoadManagerImpl.java | 18 +-
.../pulsar/broker/namespace/NamespaceService.java | 13 +-
.../pulsar/broker/service/BrokerService.java | 39 +-
.../org/apache/pulsar/broker/service/Consumer.java | 11 +-
.../apache/pulsar/broker/service/ServerCnx.java | 10 +-
.../service/nonpersistent/NonPersistentTopic.java | 13 +-
.../service/persistent/MessageDeduplication.java | 12 +-
.../persistent/MessageRedeliveryController.java | 11 +-
.../broker/service/persistent/PersistentTopic.java | 33 +-
.../broker/stats/ClusterReplicationMetrics.java | 3 +-
.../AntiAffinityNamespaceGroupTest.java | 15 +-
.../loadbalance/impl/LoadManagerSharedTest.java | 13 +-
.../pulsar/broker/service/PersistentTopicTest.java | 46 +-
.../MessageRedeliveryControllerTest.java | 2 +-
pulsar-client-cpp/lib/ClientImpl.cc | 37 +-
pulsar-client-cpp/lib/ExecutorService.cc | 33 +-
pulsar-client-cpp/lib/ExecutorService.h | 11 +-
pulsar-client-cpp/lib/TimeUtils.h | 48 ++
pulsar-client-cpp/tests/CustomLoggerTest.cc | 26 +-
.../org/apache/pulsar/client/impl/ClientCnx.java | 23 +-
.../apache/pulsar/client/impl/ConsumerBase.java | 3 +-
.../apache/pulsar/client/impl/ConsumerImpl.java | 3 +-
.../apache/pulsar/client/impl/ProducerBase.java | 3 +-
.../client/impl/TransactionMetaStoreHandler.java | 5 +-
.../TransactionCoordinatorClientImpl.java | 6 +-
.../impl/AcknowledgementsGroupingTrackerTest.java | 3 +-
.../org/apache/pulsar/common/util/RateLimiter.java | 3 +-
.../util/collections/ConcurrentLongHashMap.java | 149 ++++-
.../collections/ConcurrentLongLongPairHashMap.java | 673 +++++++++++++++++++++
.../util/collections/ConcurrentLongPairSet.java | 174 +++++-
.../util/collections/ConcurrentOpenHashMap.java | 159 ++++-
.../util/collections/ConcurrentOpenHashSet.java | 158 ++++-
.../collections/ConcurrentSortedLongPairSet.java | 32 +-
.../common/util/collections/LongPairSet.java | 7 +
.../apache/pulsar/common/util/RateLimiterTest.java | 20 +-
.../collections/ConcurrentLongHashMapTest.java | 141 ++++-
.../ConcurrentLongLongPairHashMapTest.java | 427 +++++++++++++
.../collections/ConcurrentLongPairSetTest.java | 130 +++-
.../collections/ConcurrentOpenHashMapTest.java | 144 ++++-
.../collections/ConcurrentOpenHashSetTest.java | 93 ++-
.../ConcurrentSortedLongPairSetTest.java | 43 ++
.../java/org/apache/pulsar/io/file/FileSource.java | 12 +-
.../apache/pulsar/websocket/WebSocketService.java | 23 +-
.../apache/pulsar/websocket/stats/ProxyStats.java | 4 +-
52 files changed, 2670 insertions(+), 270 deletions(-)
create mode 100644
pulsar-common/src/main/java/org/apache/pulsar/common/util/collections/ConcurrentLongLongPairHashMap.java
create mode 100644
pulsar-common/src/test/java/org/apache/pulsar/common/util/collections/ConcurrentLongLongPairHashMapTest.java
