You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by pe...@apache.org on 2020/06/05 12:34:40 UTC
[pulsar] branch master updated (6826040 -> 9e4f854)

This is an automated email from the ASF dual-hosted git repository.

penghui pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git.


    from 6826040  Refactor zookeeper session timeout handling into an interface (#6347)
     add 9e4f854  [Issue 6000][pulsar-client] C++ client ACK grouping feature. (#6534)

No new revisions were added by this update.

Summary of changes:
 .../include/pulsar/ConsumerConfiguration.h         |  32 ++
 .../include/pulsar/c/consumer_configuration.h      |  40 ++
 pulsar-client-cpp/lib/AckGroupingTracker.cc        |  73 ++++
 pulsar-client-cpp/lib/AckGroupingTracker.h         | 108 ++++++
 ...StringHash.cc => AckGroupingTrackerDisabled.cc} |  28 +-
 pulsar-client-cpp/lib/AckGroupingTrackerDisabled.h |  58 +++
 pulsar-client-cpp/lib/AckGroupingTrackerEnabled.cc | 154 ++++++++
 pulsar-client-cpp/lib/AckGroupingTrackerEnabled.h  |  94 +++++
 pulsar-client-cpp/lib/Commands.cc                  |  27 +-
 pulsar-client-cpp/lib/Commands.h                   |   7 +
 pulsar-client-cpp/lib/ConsumerConfiguration.cc     |  12 +
 pulsar-client-cpp/lib/ConsumerConfigurationImpl.h  |   4 +
 pulsar-client-cpp/lib/ConsumerImpl.cc              |  79 ++--
 pulsar-client-cpp/lib/ConsumerImpl.h               |  20 +-
 pulsar-client-cpp/lib/TopicName.cc                 |  16 +-
 pulsar-client-cpp/lib/TopicName.h                  |   9 +-
 pulsar-client-cpp/lib/c/c_ConsumerConfiguration.cc |  18 +
 pulsar-client-cpp/tests/BasicEndToEndTest.cc       | 422 ++++++++++++++++++++-
 pulsar-client-cpp/tests/CMakeLists.txt             |   2 +-
 pulsar-client-cpp/tests/PulsarFriend.h             |   3 +
 20 files changed, 1141 insertions(+), 65 deletions(-)
 create mode 100644 pulsar-client-cpp/lib/AckGroupingTracker.cc
 create mode 100644 pulsar-client-cpp/lib/AckGroupingTracker.h
 copy pulsar-client-cpp/lib/{JavaStringHash.cc => AckGroupingTrackerDisabled.cc} (53%)
 create mode 100644 pulsar-client-cpp/lib/AckGroupingTrackerDisabled.h
 create mode 100644 pulsar-client-cpp/lib/AckGroupingTrackerEnabled.cc
 create mode 100644 pulsar-client-cpp/lib/AckGroupingTrackerEnabled.h