This is an automated email from the ASF dual-hosted git repository.
xyz pushed a change to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/pulsar-client-cpp.git
from f70aa89 Fixed the release artifacts package file name (#113)
new 3c97495 [flaky tests] Fix flaky ShutdownTest::testDestructor (#62)
new 382e3a3 [refactor] Apply forward declaration as much as possible (#64)
new e557cca Stick clang-format version to 11 and add back
docker-format.sh (#45)
new edbed81 Fix macOS build (#67)
new 252e62a [fix][doc] explicitly instruct clone the repo (#69)
new a4494d5 Add windows release artifacts (#72)
new 02a2adf Fix ci install deps failed. (#96)
new cdc26e9 Support linking static dependencies when building with MSVC
(#73)
new 80c8ab2 [refactor] Remove useless config file. (#76)
The 9 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:
.clang-format | 2 +-
.github/workflows/ci-build-binary-artifacts.yaml | 117 +++++++++++++++-
.github/workflows/ci-pr-validation.yaml | 56 +++++---
CMakeLists.txt | 78 +++++++++--
README.md | 97 +++++++------
.../Dockerfile.format | 22 +--
.../{copy-deps-versionfile.sh => docker-format.sh} | 17 ++-
cmake_modules/FindClangTools.cmake | 4 +-
docker/alpine/Dockerfile | 99 -------------
docker/alpine/Dockerfile-alpine-3.8 | 99 -------------
docker/alpine/build-alpine-image.sh | 33 -----
docker/alpine/build-wheel-file-within-docker.sh | 38 -----
docker/alpine/build-wheel.sh | 34 -----
docker/build-client-lib-within-docker.sh | 34 -----
docker/build-client-lib.sh | 49 -------
docker/centos-7/Dockerfile | 47 -------
docker/push-images.sh | 46 ------
examples/SampleAsyncProducer.cc | 6 +-
examples/SampleConsumer.cc | 6 +-
examples/SampleConsumerListener.cc | 6 +-
examples/SampleProducer.cc | 6 +-
include/pulsar/Authentication.h | 9 +-
include/pulsar/BatchReceivePolicy.h | 1 +
include/pulsar/BrokerConsumerStats.h | 8 +-
include/pulsar/Client.h | 13 +-
include/pulsar/ClientConfiguration.h | 2 +-
include/pulsar/Consumer.h | 5 +-
include/pulsar/ConsumerConfiguration.h | 18 +--
include/pulsar/CryptoKeyReader.h | 4 +-
include/pulsar/DeprecatedException.h | 3 +-
include/pulsar/EncryptionKeyInfo.h | 5 +-
include/pulsar/KeySharedPolicy.h | 1 -
include/pulsar/Logger.h | 3 +-
include/pulsar/Message.h | 6 +-
include/pulsar/MessageBatch.h | 6 +-
include/pulsar/MessageBuilder.h | 6 +-
include/pulsar/MessageId.h | 5 +-
include/pulsar/MessageRoutingPolicy.h | 3 +-
include/pulsar/Producer.h | 5 +-
include/pulsar/ProducerConfiguration.h | 10 +-
include/pulsar/ProtobufNativeSchema.h | 2 +-
include/pulsar/Reader.h | 2 +-
include/pulsar/ReaderConfiguration.h | 13 +-
include/pulsar/Result.h | 3 +-
include/pulsar/Schema.h | 4 +-
include/pulsar/c/client.h | 8 +-
include/pulsar/c/consumer.h | 3 +-
include/pulsar/c/consumer_configuration.h | 1 +
include/pulsar/c/message.h | 2 +-
include/pulsar/c/message_id.h | 2 +-
include/pulsar/c/message_router.h | 2 +-
include/pulsar/c/producer.h | 5 +-
include/pulsar/c/producer_configuration.h | 5 +-
include/pulsar/c/reader.h | 4 +-
include/pulsar/c/reader_configuration.h | 2 +-
lib/AckGroupingTracker.cc | 22 +--
lib/AckGroupingTracker.h | 13 +-
lib/AckGroupingTrackerDisabled.cc | 8 +-
lib/AckGroupingTrackerDisabled.h | 4 +-
lib/AckGroupingTrackerEnabled.cc | 11 +-
lib/AckGroupingTrackerEnabled.h | 18 ++-
lib/Authentication.cc | 23 ++-
lib/Backoff.cc | 6 +-
lib/Backoff.h | 5 +-
lib/BatchAcknowledgementTracker.cc | 15 +-
lib/BatchAcknowledgementTracker.h | 18 +--
lib/BatchMessageContainer.cc | 9 +-
lib/BatchMessageContainerBase.cc | 32 ++++-
lib/BatchMessageContainerBase.h | 35 +----
lib/BatchMessageKeyBasedContainer.cc | 8 +-
lib/BatchReceivePolicy.cc | 1 +
lib/BinaryProtoLookupService.cc | 10 +-
lib/BinaryProtoLookupService.h | 14 +-
lib/BlockingQueue.h | 5 +-
lib/BoostHash.h | 5 +-
lib/BrokerConsumerStats.cc | 5 +-
lib/BrokerConsumerStatsImpl.cc | 3 +-
lib/BrokerConsumerStatsImpl.h | 12 +-
lib/BrokerConsumerStatsImplBase.h | 1 -
lib/CMakeLists.txt | 8 +-
lib/Client.cc | 7 +-
lib/ClientConfiguration.cc | 2 +-
lib/ClientConnection.cc | 121 ++++++++--------
lib/ClientConnection.h | 54 +++----
lib/ClientImpl.cc | 32 ++---
lib/ClientImpl.h | 30 ++--
lib/Commands.cc | 81 +++++++----
lib/Commands.h | 28 ++--
lib/CompressionCodec.cc | 37 +----
lib/CompressionCodec.h | 9 +-
lib/CompressionCodecLZ4.cc | 3 +-
lib/CompressionCodecSnappy.cc | 2 +-
lib/CompressionCodecZLib.cc | 4 +-
lib/CompressionCodecZLib.h | 2 -
lib/ConnectionPool.cc | 9 +-
lib/ConnectionPool.h | 14 +-
lib/ConsoleLoggerFactory.cc | 3 +-
lib/ConsoleLoggerFactoryImpl.h | 3 +-
lib/Consumer.cc | 6 +-
lib/ConsumerConfiguration.cc | 5 +-
lib/ConsumerImpl.cc | 76 +++++-----
lib/ConsumerImpl.h | 61 ++++----
lib/ConsumerImplBase.cc | 13 +-
lib/ConsumerImplBase.h | 11 +-
lib/CryptoKeyReader.cc | 9 +-
lib/DeprecatedException.cc | 2 +-
lib/EncryptionKeyInfoImpl.h | 5 +-
lib/ExecutorService.cc | 6 +-
lib/ExecutorService.h | 15 +-
lib/FileLoggerFactory.cc | 3 +-
lib/FileLoggerFactoryImpl.h | 5 +-
lib/Future.h | 9 +-
lib/GetLastMessageIdResponse.h | 1 +
lib/HTTPLookupService.cc | 9 +-
lib/HTTPLookupService.h | 13 +-
lib/HandlerBase.cc | 7 +-
lib/HandlerBase.h | 20 ++-
lib/JavaStringHash.cc | 1 +
lib/JavaStringHash.h | 3 +-
lib/KeySharedPolicy.cc | 4 +-
lib/Latch.h | 5 +-
lib/Log4CxxLogger.h | 2 +-
lib/Log4cxxLogger.cc | 5 +-
lib/LogUtils.cc | 3 +-
lib/LogUtils.h | 10 +-
lib/LookupDataResult.h | 7 +-
lib/LookupService.h | 18 +--
lib/MemoryLimitController.h | 2 +-
lib/Message.cc | 7 +-
lib/MessageAndCallbackBatch.cc | 1 +
lib/MessageAndCallbackBatch.h | 5 +-
lib/MessageBuilder.cc | 5 +-
lib/MessageCrypto.cc | 20 +--
lib/MessageCrypto.h | 33 +++--
lib/MessageId.cc | 11 +-
lib/MessageIdImpl.h | 1 +
lib/MessageIdUtil.h | 6 -
lib/MessageImpl.h | 3 +-
lib/MessageRouterBase.cc | 2 +-
lib/MessageRouterBase.h | 7 +-
lib/MessagesImpl.cc | 3 +-
lib/MessagesImpl.h | 3 +-
lib/MultiTopicsBrokerConsumerStatsImpl.cc | 5 +-
lib/MultiTopicsBrokerConsumerStatsImpl.h | 9 +-
lib/MultiTopicsConsumerImpl.cc | 25 +++-
lib/MultiTopicsConsumerImpl.h | 46 +++---
lib/Murmur3_32Hash.h | 3 +-
lib/NamespaceName.cc | 10 +-
lib/NamespaceName.h | 3 +-
lib/NegativeAcksTracker.cc | 7 +-
lib/NegativeAcksTracker.h | 16 ++-
lib/ObjectPool.h | 3 +-
lib/OpSendMsg.h | 4 +-
lib/PartitionedProducerImpl.cc | 14 +-
lib/PartitionedProducerImpl.h | 30 +++-
lib/PatternMultiTopicsConsumerImpl.cc | 5 +
lib/PatternMultiTopicsConsumerImpl.h | 16 ++-
lib/PeriodicTask.cc | 3 +-
lib/PeriodicTask.h | 4 +-
lib/Producer.cc | 5 +-
lib/ProducerConfiguration.cc | 4 +-
lib/ProducerConfigurationImpl.h | 1 +
lib/ProducerImpl.cc | 27 ++--
lib/ProducerImpl.h | 42 +++---
lib/ProducerImplBase.h | 2 +
lib/ProtoApiEnums.h | 156 +++++++++++++++++++++
lib/ProtobufNativeSchema.cc | 6 +-
lib/Reader.cc | 2 +-
lib/ReaderConfiguration.cc | 2 +-
lib/ReaderImpl.cc | 6 +-
lib/ReaderImpl.h | 23 ++-
lib/Result.cc | 2 +-
lib/RetryableLookupService.h | 13 +-
lib/RoundRobinMessageRouter.cc | 5 +-
lib/RoundRobinMessageRouter.h | 8 +-
lib/Schema.cc | 2 +-
lib/Semaphore.h | 2 +-
lib/ServiceNameResolver.h | 2 +
lib/ServiceURI.cc | 1 +
lib/ServiceURI.h | 1 +
lib/SharedBuffer.h | 4 +-
lib/SimpleLogger.h | 6 +-
lib/SinglePartitionMessageRouter.cc | 2 +
lib/SinglePartitionMessageRouter.h | 6 +-
lib/SynchronizedHashMap.h | 1 +
lib/TimeUtils.h | 6 +-
lib/TopicMetadataImpl.cc | 2 +-
lib/TopicMetadataImpl.h | 1 -
lib/TopicName.cc | 20 +--
lib/TopicName.h | 13 +-
lib/UnAckedMessageTrackerDisabled.h | 2 +-
lib/UnAckedMessageTrackerEnabled.cc | 5 +
lib/UnAckedMessageTrackerEnabled.h | 20 ++-
lib/UnAckedMessageTrackerInterface.h | 14 +-
lib/UnboundedBlockingQueue.h | 4 +-
lib/Url.cc | 1 -
lib/Url.h | 3 +-
lib/UtilAllocator.h | 1 +
lib/Utils.h | 6 +-
lib/auth/AuthAthenz.cc | 10 +-
lib/auth/AuthAthenz.h | 4 +-
lib/auth/AuthBasic.cc | 7 +-
lib/auth/AuthBasic.h | 2 -
lib/auth/AuthOauth2.cc | 9 +-
lib/auth/AuthOauth2.h | 2 +-
lib/auth/AuthTls.cc | 2 +-
lib/auth/AuthTls.h | 1 -
lib/auth/AuthToken.cc | 6 +-
lib/auth/AuthToken.h | 2 -
lib/auth/athenz/ZTSClient.cc | 16 +--
lib/auth/athenz/ZTSClient.h | 6 +-
lib/c/cStringMap.cc | 2 +-
lib/c/c_Authentication.cc | 5 +-
lib/c/c_Message.cc | 1 +
lib/c/c_MessageId.cc | 4 +-
lib/c/c_ProducerConfiguration.cc | 2 +-
lib/c/c_Reader.cc | 2 +-
lib/c/c_ReaderConfiguration.cc | 8 +-
lib/c/c_Result.cc | 2 +-
lib/c/c_structs.h | 4 +-
lib/checksum/ChecksumProvider.h | 2 +-
lib/checksum/crc32c_arm.cc | 1 +
lib/checksum/crc32c_sse42.cc | 3 +-
lib/checksum/crc32c_sw.cc | 1 +
lib/lz4/lz4.h | 2 +-
lib/stats/ConsumerStatsBase.h | 6 +-
lib/stats/ConsumerStatsDisabled.h | 4 +-
lib/stats/ConsumerStatsImpl.cc | 15 +-
lib/stats/ConsumerStatsImpl.h | 25 ++--
lib/stats/ProducerStatsBase.h | 1 +
lib/stats/ProducerStatsDisabled.h | 2 +-
lib/stats/ProducerStatsImpl.cc | 8 +-
lib/stats/ProducerStatsImpl.h | 20 +--
perf/PerfConsumer.cc | 15 +-
perf/PerfProducer.cc | 19 +--
perf/RateLimiter.h | 2 +-
tests/AuthBasicTest.cc | 3 +-
tests/AuthPluginTest.cc | 11 +-
tests/AuthTokenTest.cc | 11 +-
tests/BackoffTest.cc | 6 +-
tests/BasicEndToEndTest.cc | 57 ++++----
tests/BatchMessageTest.cc | 34 +++--
tests/BlockingQueueTest.cc | 5 +-
tests/ClientDeduplicationTest.cc | 7 +-
tests/ClientTest.cc | 10 +-
tests/CompressionCodecSnappyTest.cc | 2 +-
tests/ConsumerConfigurationTest.cc | 3 +-
tests/ConsumerStatsTest.cc | 17 +--
tests/ConsumerTest.cc | 21 +--
tests/ConsumerTest.h | 3 +-
tests/CustomLoggerTest.cc | 6 +-
tests/CustomRoutingPolicy.h | 5 +-
tests/HashTest.cc | 11 +-
tests/KeyBasedBatchingTest.cc | 7 +-
tests/KeySharedConsumerTest.cc | 10 +-
tests/KeySharedPolicyTest.cc | 12 +-
tests/LatchTest.cc | 6 +-
tests/LoggerTest.cc | 3 +-
tests/LookupServiceTest.cc | 22 +--
tests/MapCacheTest.cc | 3 +-
tests/MemoryLimitControllerTest.cc | 7 +-
tests/MemoryLimitTest.cc | 14 +-
tests/MessageChunkingTest.cc | 7 +-
tests/MessageIdTest.cc | 8 +-
tests/MessageTest.cc | 8 +-
tests/MessagesImplTest.cc | 5 +-
tests/NamespaceNameTest.cc | 4 +-
tests/PartitionsUpdateTest.cc | 6 +-
tests/PeriodicTaskTest.cc | 2 +
tests/ProducerConfigurationTest.cc | 1 +
tests/ProducerTest.cc | 6 +-
tests/PromiseTest.cc | 4 +-
tests/ProtobufNativeSchemaTest.cc | 4 +-
tests/PulsarFriend.h | 8 +-
tests/ReaderConfigurationTest.cc | 3 +-
tests/ReaderTest.cc | 16 +--
tests/RoundRobinMessageRouterTest.cc | 7 +-
tests/SemaphoreTest.cc | 5 +-
tests/ServiceURITest.cc | 1 +
tests/ShutdownTest.cc | 11 +-
tests/SinglePartitionMessageRouterTest.cc | 12 +-
tests/SynchronizedHashMapTest.cc | 2 +
tests/TopicMetadataImplTest.cc | 4 +-
tests/TopicNameTest.cc | 4 +-
tests/UnboundedBlockingQueueTest.cc | 5 +-
tests/UrlTest.cc | 3 +-
tests/VersionTest.cc | 2 +-
lib/PendingFailures.h => tests/WaitUtils.h | 34 +++--
tests/ZLibCompressionTest.cc | 3 +-
tests/ZTSClientTest.cc | 3 +-
tests/ZeroQueueSizeTest.cc | 7 +-
tests/c/c_BasicEndToEndTest.cc | 6 +-
tests/c/c_ConsumerConfigurationTest.cc | 2 +-
tests/c/c_ProducerConfigurationTest.cc | 2 +-
tests/main.cc | 1 -
win-examples/CMakeLists.txt | 49 +++++++
tests/PaddingDemo.proto => win-examples/example.cc | 12 +-
wireshark/pulsarDissector.cc | 6 +-
298 files changed, 1929 insertions(+), 1727 deletions(-)
copy pkg/apk/docker-build-apk-x86_64.sh => build-support/Dockerfile.format
(69%)
mode change 100755 => 100644
copy build-support/{copy-deps-versionfile.sh => docker-format.sh} (71%)
delete mode 100644 docker/alpine/Dockerfile
delete mode 100644 docker/alpine/Dockerfile-alpine-3.8
delete mode 100755 docker/alpine/build-alpine-image.sh
delete mode 100755 docker/alpine/build-wheel-file-within-docker.sh
delete mode 100755 docker/alpine/build-wheel.sh
delete mode 100755 docker/build-client-lib-within-docker.sh
delete mode 100755 docker/build-client-lib.sh
delete mode 100644 docker/centos-7/Dockerfile
delete mode 100755 docker/push-images.sh
create mode 100644 lib/ProtoApiEnums.h
copy lib/PendingFailures.h => tests/WaitUtils.h (55%)
create mode 100644 win-examples/CMakeLists.txt
copy tests/PaddingDemo.proto => win-examples/example.cc (84%)
