This is an automated email from the ASF dual-hosted git repository. williamsong pushed a commit to branch snapshot-branch2 in repository https://gitbox.apache.org/repos/asf/ratis.git
commit a4398bf591965ffe4daad7ac3555ed6bbc05f0b0 Author: szywilliam <[email protected]> AuthorDate: Sat Sep 9 19:26:24 2023 +0800 change metrics lambda --- .../src/main/java/org/apache/ratis/server/impl/PendingRequests.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/ratis-server/src/main/java/org/apache/ratis/server/impl/PendingRequests.java b/ratis-server/src/main/java/org/apache/ratis/server/impl/PendingRequests.java index 2f2ca8f7d..dc840b00c 100644 --- a/ratis-server/src/main/java/org/apache/ratis/server/impl/PendingRequests.java +++ b/ratis-server/src/main/java/org/apache/ratis/server/impl/PendingRequests.java @@ -112,8 +112,8 @@ class PendingRequests { this.resource = new RequestLimits(elementLimit, megabyteLimit); this.raftServerMetrics = raftServerMetrics; - raftServerMetrics.addNumPendingRequestsGauge(resource::getElementCount); - raftServerMetrics.addNumPendingRequestsMegaByteSize(resource::getMegaByteSize); + raftServerMetrics.addNumPendingRequestsGauge(() -> resource.getElementCount()); + raftServerMetrics.addNumPendingRequestsMegaByteSize(() -> resource.getMegaByteSize()); } Permit tryAcquire(Message message) {
