fix(s3stream/wal): record metrics on WAL full (#1968)

Signed-off-by: Ning Yu <[email protected]>
AutoMQ · Aug 30, 2024 · 98b23b4 · 98b23b4
1 parent 6259864
commit 98b23b4
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/s3stream/src/main/java/com/automq/stream/s3/wal/impl/block/BlockWALService.java b/s3stream/src/main/java/com/automq/stream/s3/wal/impl/block/BlockWALService.java
@@ -417,11 +417,15 @@ public WALMetadata metadata() {
     public AppendResult append(TraceContext context, ByteBuf buf, int crc) throws OverCapacityException {
         // get current method name
         TraceContext.Scope scope = TraceUtils.createAndStartSpan(context, "BlockWALService::append");
+        final long startTime = System.nanoTime();
         try {
             AppendResult result = append0(buf, crc);
             result.future().whenComplete((nil, ex) -> TraceUtils.endSpan(scope, ex));
             return result;
         } catch (Throwable t) {
+            if (t instanceof OverCapacityException) {
+                StorageOperationStats.getInstance().appendWALFullStats.record(TimerUtil.timeElapsedSince(startTime, TimeUnit.NANOSECONDS));
+            }
             buf.release();
             TraceUtils.endSpan(scope, t);
             throw t;