This is an automated email from the ASF dual-hosted git repository.
houxiaoyu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/master by this push:
new fe47d2d7ea2 [cleanup][broker] Cleanup unused method: isSlowestReader
(#18306)
fe47d2d7ea2 is described below
commit fe47d2d7ea2c61b32ee1f95898de8f30e98c9e17
Author: LinChen <[email protected]>
AuthorDate: Thu Nov 3 20:53:11 2022 +0800
[cleanup][broker] Cleanup unused method: isSlowestReader (#18306)
Co-authored-by: lordcheng10 <[email protected]>
Co-authored-by: Jiwe Guo <[email protected]>
---
.../src/main/java/org/apache/bookkeeper/mledger/impl/OpReadEntry.java | 4 ----
1 file changed, 4 deletions(-)
diff --git
a/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/OpReadEntry.java
b/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/OpReadEntry.java
index 47c4029974d..7fc2eec6626 100644
---
a/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/OpReadEntry.java
+++
b/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/OpReadEntry.java
@@ -168,10 +168,6 @@ class OpReadEntry implements ReadEntriesCallback {
return count - entries.size();
}
- public boolean isSlowestReader() {
- return cursor.ledger.getSlowestConsumer() == cursor;
- }
-
private final Handle<OpReadEntry> recyclerHandle;
private OpReadEntry(Handle<OpReadEntry> recyclerHandle) {