Add missing addRequestStats

apache · Jun 28, 2023 · d222a80 · d222a80
1 parent 147b5bf
commit d222a80
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/WriteEntryProcessor.java b/bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/WriteEntryProcessor.java
@@ -128,6 +128,13 @@ public void writeComplete(int rc, long ledgerId, long entryId,
         requestHandler.prepareSendResponseV2(rc, request);
         requestProcessor.onAddRequestFinish();
 
+        if (BookieProtocol.EOK == rc) {
+            requestProcessor.getRequestStats().getAddRequestStats().registerSuccessfulEvent(
+                    MathUtils.elapsedNanos(enqueueNanos), TimeUnit.NANOSECONDS);
+        } else {
+            requestProcessor.getRequestStats().getAddRequestStats().registerFailedEvent(
+                    MathUtils.elapsedNanos(enqueueNanos), TimeUnit.NANOSECONDS);
+        }
         request.recycle();
         recycle();
     }