From 3b078dfc960444ea45cb3efa4c9b5aa5f062f42c Mon Sep 17 00:00:00 2001 From: OneSizeFitQuorum Date: Mon, 18 Sep 2023 14:47:42 +0800 Subject: [PATCH] fix Signed-off-by: OneSizeFitQuorum --- .../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 2f2ca8f7dd..dc840b00c9 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 @@ private static class RequestMap { 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) {