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 2021/01/25 01:15:57 UTC
[pulsar] branch master updated (60161ed -> 37d778b)

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 60161ed  Fix peek message metadata broker while enable broker entry metadata. (#9255)
     add 37d778b  [Transaction] Transaction timeout implementation. (#9229)

No new revisions were added by this update.

Summary of changes:
 .../org/apache/pulsar/broker/PulsarService.java    |   8 +-
 .../broker/TransactionMetadataStoreService.java    |  32 +++++-
 .../apache/pulsar/broker/service/ServerCnx.java    |   3 +-
 .../buffer/impl/TransactionBufferClientImpl.java   |   6 +-
 .../buffer/impl/TransactionBufferHandlerImpl.java  |  10 +-
 .../TransactionTimeoutTrackerFactoryImpl.java      |  50 +++++++++
 .../timeout/TransactionTimeoutTrackerImpl.java     | 122 +++++++++++++++++++++
 .../{buffer => timeout}/package-info.java          |   2 +-
 .../TransactionMetadataStoreServiceTest.java       | 114 ++++++++++++++++++-
 .../buffer/TransactionBufferClientTest.java        |   5 +-
 .../client/impl/TransactionEndToEndTest.java       |  57 +++++++---
 .../TransactionMetadataStoreProvider.java          |   4 +-
 .../coordinator/TransactionTimeoutTracker.java     |  62 +++++++++++
 ....java => TransactionTimeoutTrackerFactory.java} |  17 +--
 .../InMemTransactionMetadataStoreProvider.java     |   5 +-
 .../impl/MLTransactionMetadataStore.java           |  11 +-
 .../impl/MLTransactionMetadataStoreProvider.java   |   7 +-
 .../MLTransactionMetadataStoreTest.java            |  37 ++++++-
 .../TransactionMetadataStoreProviderTest.java      |   2 +-
 19 files changed, 499 insertions(+), 55 deletions(-)
 create mode 100644 pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/timeout/TransactionTimeoutTrackerFactoryImpl.java
 create mode 100644 pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/timeout/TransactionTimeoutTrackerImpl.java
 copy pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/{buffer => timeout}/package-info.java (94%)
 create mode 100644 pulsar-transaction/coordinator/src/main/java/org/apache/pulsar/transaction/coordinator/TransactionTimeoutTracker.java
 copy pulsar-transaction/coordinator/src/main/java/org/apache/pulsar/transaction/coordinator/{TransactionCoordinatorID.java => TransactionTimeoutTrackerFactory.java} (73%)