You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by rx...@apache.org on 2020/11/11 06:54:21 UTC
[pulsar] branch master updated (c7694c8 -> dafa7e0)
This is an automated email from the ASF dual-hosted git repository.
rxl pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from c7694c8 Add 2.6.2 release blog (#8495)
add dafa7e0 [Transaction]Transaction pendingack server implement patch (#8426)
No new revisions were added by this update.
Summary of changes:
.../bookkeeper/mledger/impl/ManagedCursorImpl.java | 18 +
.../bookkeeper/mledger/impl/PositionImpl.java | 12 +
.../mledger/util/PositionAckSetUtil.java | 96 ++++++
.../mledger/util/PositionAckSetUtilTest.java | 113 ++++++
.../org/apache/pulsar/broker/service/Consumer.java | 165 +++++++--
.../service/persistent/PersistentSubscription.java | 381 +++------------------
.../transaction/pendingack/PendingAckHandle.java | 118 +++++++
.../pendingack/impl/PendingAckHandleImpl.java | 349 +++++++++++++++++++
.../persistent/PersistentSubscriptionTest.java | 101 +++---
.../pendingack/PendingAckInMemoryDeleteTest.java | 306 +++++++++++++++++
.../client/impl/ConsumerAckResponseTest.java | 2 +-
.../client/impl/TransactionEndToEndTest.java | 120 ++++++-
.../apache/pulsar/client/impl/ConsumerBase.java | 6 +-
.../apache/pulsar/client/impl/ConsumerImpl.java | 23 +-
.../client/impl/transaction/TransactionImpl.java | 90 +++--
15 files changed, 1450 insertions(+), 450 deletions(-)
create mode 100644 managed-ledger/src/main/java/org/apache/bookkeeper/mledger/util/PositionAckSetUtil.java
create mode 100644 managed-ledger/src/test/java/org/apache/bookkeeper/mledger/util/PositionAckSetUtilTest.java
create mode 100644 pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/pendingack/PendingAckHandle.java
create mode 100644 pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/pendingack/impl/PendingAckHandleImpl.java
create mode 100644 pulsar-broker/src/test/java/org/apache/pulsar/broker/transaction/pendingack/PendingAckInMemoryDeleteTest.java