This is an automated email from the ASF dual-hosted git repository. yong pushed a commit to branch branch-4.15 in repository https://gitbox.apache.org/repos/asf/bookkeeper.git
commit 2eb1c361cdadd2892aa8136850b21507b676a665 Author: houxiaoyu <[email protected]> AuthorDate: Mon Feb 27 12:02:38 2023 +0800 Fix ReadEntryProcessor v2 SchedulingDelayStats (#3758) Descriptions of the changes in this PR: ### Motivation We registered `ReadEntrySchedulingDelayStats` of `ReadEntryProcessor` as `WriteThreadQueuedLatency` mistakenly, so we need fix it. ### Changes Register `ReadEntrySchedulingDelayStats` if `ReadEntryProcessor` (cherry picked from commit 08ef6491a61cc3fbc3d055eb56b75eb221f986ec) --- .../java/org/apache/bookkeeper/proto/PacketProcessorBase.java | 11 +++++++++-- 1 file changed, 9 insertions(+), 2 deletions(-) diff --git a/bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/PacketProcessorBase.java b/bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/PacketProcessorBase.java index 5bee27b0fb..0490c2ca20 100644 --- a/bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/PacketProcessorBase.java +++ b/bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/PacketProcessorBase.java @@ -167,8 +167,15 @@ abstract class PacketProcessorBase<T extends Request> extends SafeRunnable { @Override public void safeRun() { - requestProcessor.getRequestStats().getWriteThreadQueuedLatency() - .registerSuccessfulEvent(MathUtils.elapsedNanos(enqueueNanos), TimeUnit.NANOSECONDS); + if (request instanceof BookieProtocol.ReadRequest) { + requestProcessor.getRequestStats().getReadEntrySchedulingDelayStats() + .registerSuccessfulEvent(MathUtils.elapsedNanos(enqueueNanos), TimeUnit.NANOSECONDS); + } + if (request instanceof BookieProtocol.ParsedAddRequest) { + requestProcessor.getRequestStats().getWriteThreadQueuedLatency() + .registerSuccessfulEvent(MathUtils.elapsedNanos(enqueueNanos), TimeUnit.NANOSECONDS); + } + if (!isVersionCompatible()) { sendResponse(BookieProtocol.EBADVERSION, ResponseBuilder.buildErrorResponse(BookieProtocol.EBADVERSION, request),
