This is an automated email from the ASF dual-hosted git repository.
merlimat pushed a change to branch branch-4.18
in repository https://gitbox.apache.org/repos/asf/bookkeeper.git
from a692129bea Bump Jetty to 12.1.10 and fix binary license metadata
(#4871)
new f77d07c1b0 Pin a ledger's callbacks to a caller-chosen worker thread
via withOrderingKey (#4881)
new c9c25f2a89 Add SingleThreadExecutor.executeOrRun and issue reads
inline from the ledger's own thread (#4883)
new 1e8ae266de build(deps): bump org.apache.thrift:libthrift from 0.23.0
to 0.24.0 (#4874)
new 6ac8c4bcc4 build(deps): bump at.yawk.lz4:lz4-java from 1.10.2 to
1.11.1 (#4869)
new ed062f1407 build(deps): bump bytes in
/native-io/src/main/native-io-jni/rust (#4747)
The 5 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../bookkeeper/common/util/OrderedExecutor.java | 111 ++++++-----
.../common/util/SingleThreadExecutor.java | 46 ++++-
.../common/util/ThreadBoundExecutor.java | 46 +++++
.../common/util/TestOrderedExecutorDecorators.java | 26 +++
.../common/util/TestSingleThreadExecutor.java | 105 +++++++++++
.../src/main/resources/LICENSE-all.bin.txt | 8 +-
.../src/main/resources/LICENSE-bkctl.bin.txt | 8 +-
.../src/main/resources/LICENSE-server.bin.txt | 8 +-
.../apache/bookkeeper/client/BatchedReadOp.java | 6 +-
.../apache/bookkeeper/client/ForceLedgerOp.java | 2 +-
.../apache/bookkeeper/client/LedgerCreateOp.java | 32 +++-
.../org/apache/bookkeeper/client/LedgerHandle.java | 66 +++++--
.../apache/bookkeeper/client/LedgerHandleAdv.java | 10 +-
.../org/apache/bookkeeper/client/LedgerOpenOp.java | 101 ++++++----
.../apache/bookkeeper/client/LedgerRecoveryOp.java | 1 +
.../org/apache/bookkeeper/client/PendingAddOp.java | 2 +-
.../apache/bookkeeper/client/PendingReadLacOp.java | 2 +-
.../apache/bookkeeper/client/PendingReadOp.java | 5 +-
.../bookkeeper/client/PendingWriteLacOp.java | 2 +-
.../client/ReadLastConfirmedAndEntryOp.java | 4 +-
.../bookkeeper/client/ReadLastConfirmedOp.java | 22 ++-
.../bookkeeper/client/ReadOnlyLedgerHandle.java | 14 +-
.../org/apache/bookkeeper/client/ReadOpBase.java | 4 +-
.../bookkeeper/client/TryReadLastConfirmedOp.java | 2 +-
.../bookkeeper/client/api/CreateAdvBuilder.java | 14 ++
.../bookkeeper/client/api/CreateBuilder.java | 18 ++
.../apache/bookkeeper/client/api/OpenBuilder.java | 18 ++
.../bookkeeper/client/impl/OpenBuilderBase.java | 7 +
.../org/apache/bookkeeper/proto/AddCompletion.java | 12 +-
.../bookkeeper/proto/BatchedReadCompletion.java | 6 +-
.../org/apache/bookkeeper/proto/BookieClient.java | 117 +++++++++++-
.../apache/bookkeeper/proto/BookieClientImpl.java | 75 +++++---
.../apache/bookkeeper/proto/CompletionValue.java | 21 ++-
.../bookkeeper/proto/ForceLedgerCompletion.java | 6 +-
.../bookkeeper/proto/PerChannelBookieClient.java | 66 ++++---
.../apache/bookkeeper/proto/ReadCompletion.java | 6 +-
.../apache/bookkeeper/proto/ReadLacCompletion.java | 6 +-
.../bookkeeper/proto/WriteLacCompletion.java | 6 +-
.../client/LedgerHandleInlineReadTest.java | 148 +++++++++++++++
.../bookkeeper/client/MockBookKeeperTestCase.java | 20 +-
.../bookkeeper/client/MockClientContext.java | 8 +-
.../bookkeeper/client/PendingWriteLacOpTest.java | 3 +-
.../client/ReadLastConfirmedAndEntryOpTest.java | 4 +
.../api/BookKeeperBuildersOpenLedgerTest.java | 5 +-
.../bookkeeper/client/api/OrderingKeyTest.java | 209 +++++++++++++++++++++
.../apache/bookkeeper/proto/MockBookieClient.java | 36 ++--
.../proto/TestPerChannelBookieClient.java | 2 +-
.../apache/bookkeeper/test/BookieClientTest.java | 75 ++++++++
native-io/src/main/native-io-jni/rust/Cargo.lock | 6 +-
pom.xml | 4 +-
50 files changed, 1301 insertions(+), 230 deletions(-)
create mode 100644
bookkeeper-common/src/main/java/org/apache/bookkeeper/common/util/ThreadBoundExecutor.java
create mode 100644
bookkeeper-server/src/test/java/org/apache/bookkeeper/client/LedgerHandleInlineReadTest.java
create mode 100644
bookkeeper-server/src/test/java/org/apache/bookkeeper/client/api/OrderingKeyTest.java
