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/10/30 01:21:38 UTC
[pulsar] branch master updated (9d74007 -> 9173174)
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 9d74007 fix: intermittent test failure due to invalid cache (#8405)
add 9173174 [Transaction] TransactionBuffer Refactor (#8347)
No new revisions were added by this update.
Summary of changes:
.../bookkeeper/mledger/impl/ManagedCursorImpl.java | 8 -
.../apache/pulsar/broker/ServiceConfiguration.java | 2 +-
.../org/apache/pulsar/broker/PulsarService.java | 1 -
.../broker/TransactionMetadataStoreService.java | 28 +-
.../broker/service/AbstractBaseDispatcher.java | 69 +-
.../org/apache/pulsar/broker/service/Consumer.java | 4 -
.../apache/pulsar/broker/service/Dispatcher.java | 1 +
.../org/apache/pulsar/broker/service/Producer.java | 2 +-
.../apache/pulsar/broker/service/ServerCnx.java | 22 +-
.../org/apache/pulsar/broker/service/Topic.java | 7 +-
.../NonPersistentDispatcherMultipleConsumers.java | 2 +-
...onPersistentDispatcherSingleActiveConsumer.java | 2 +-
...istentStickyKeyDispatcherMultipleConsumers.java | 2 +-
.../service/nonpersistent/NonPersistentTopic.java | 5 +-
.../PersistentDispatcherMultipleConsumers.java | 16 +-
.../PersistentDispatcherSingleActiveConsumer.java | 44 +-
...istentStickyKeyDispatcherMultipleConsumers.java | 2 +-
.../service/persistent/PersistentSubscription.java | 2 +-
.../broker/service/persistent/PersistentTopic.java | 11 +-
.../service/persistent/TransactionReader.java | 197 ------
.../transaction/buffer/TransactionBuffer.java | 8 +-
.../buffer/impl/InMemTransactionBuffer.java | 6 +-
.../buffer/impl/PersistentTransactionBuffer.java | 344 ---------
.../impl/PersistentTransactionBufferProvider.java | 85 ---
.../impl/PersistentTransactionBufferReader.java | 142 ----
.../buffer/impl/TopicTransactionBuffer.java | 132 ++++
...er.java => TopicTransactionBufferProvider.java} | 17 +-
.../buffer/impl/TransactionBufferClientImpl.java | 11 +-
.../buffer/impl/TransactionBufferHandlerImpl.java | 16 +-
.../buffer/impl/TransactionCursorImpl.java | 126 ----
.../buffer/impl/TransactionEntryImpl.java | 10 +-
.../buffer/impl/TransactionMetaImpl.java | 187 -----
.../service/TransactionMarkerDeleteTest.java | 4 +-
.../broker/transaction/TransactionConsumeTest.java | 114 ++-
.../broker/transaction/TransactionProduceTest.java | 179 +----
.../buffer/PersistentTransactionBufferTest.java | 783 ---------------------
.../buffer/TransactionBufferClientTest.java | 7 +-
.../transaction/buffer/TransactionBufferTest.java | 21 +-
.../buffer/TransactionEntryImplTest.java | 12 +-
.../TransactionCoordinatorClientTest.java | 10 +-
.../client/impl/TransactionEndToEndTest.java | 117 +--
.../api/transaction/TransactionBufferClient.java | 8 +-
.../transaction/TransactionCoordinatorClient.java | 9 +-
.../apache/pulsar/client/impl/ConsumerImpl.java | 21 +-
.../client/impl/TransactionMetaStoreHandler.java | 29 +-
.../impl/transaction/TransactionBufferHandler.java | 4 +-
.../TransactionCoordinatorClientImpl.java | 17 +-
.../client/impl/transaction/TransactionImpl.java | 87 ++-
.../apache/pulsar/common/api/proto/PulsarApi.java | 318 +++++++++
.../pulsar/common/api/proto/PulsarMarkers.java | 181 +++--
.../apache/pulsar/common/protocol/Commands.java | 31 +-
.../org/apache/pulsar/common/protocol/Markers.java | 44 +-
pulsar-common/src/main/proto/PulsarApi.proto | 2 +
pulsar-common/src/main/proto/PulsarMarkers.proto | 2 +-
.../apache/pulsar/common/protocol/MarkersTest.java | 36 +-
55 files changed, 1179 insertions(+), 2368 deletions(-)
delete mode 100644 pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/TransactionReader.java
delete mode 100644 pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/impl/PersistentTransactionBuffer.java
delete mode 100644 pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/impl/PersistentTransactionBufferProvider.java
delete mode 100644 pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/impl/PersistentTransactionBufferReader.java
create mode 100644 pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/impl/TopicTransactionBuffer.java
copy pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/impl/{InMemTransactionBufferProvider.java => TopicTransactionBufferProvider.java} (67%)
delete mode 100644 pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/impl/TransactionCursorImpl.java
delete mode 100644 pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/impl/TransactionMetaImpl.java
delete mode 100644 pulsar-broker/src/test/java/org/apache/pulsar/broker/transaction/buffer/PersistentTransactionBufferTest.java