From b1805d4bf16674f1c9a23b5f75289f715d0ae5af Mon Sep 17 00:00:00 2001 From: Jon Chambers Date: Tue, 22 Apr 2025 16:36:08 -0400 Subject: [PATCH] Add a "persisted bytes" counter --- .../whispersystems/textsecuregcm/storage/MessagePersister.java | 3 +++ 1 file changed, 3 insertions(+) diff --git a/service/src/main/java/org/whispersystems/textsecuregcm/storage/MessagePersister.java b/service/src/main/java/org/whispersystems/textsecuregcm/storage/MessagePersister.java index a4c748ad7..e2f6589eb 100644 --- a/service/src/main/java/org/whispersystems/textsecuregcm/storage/MessagePersister.java +++ b/service/src/main/java/org/whispersystems/textsecuregcm/storage/MessagePersister.java @@ -48,6 +48,7 @@ public class MessagePersister implements Managed { private static final String OVERSIZED_QUEUE_COUNTER_NAME = name(MessagePersister.class, "persistQueueOversized"); private static final String PERSISTED_MESSAGE_COUNTER_NAME = name(MessagePersister.class, "persistMessage"); + private static final String PERSISTED_BYTES_COUNTER_NAME = name(MessagePersister.class, "persistBytes"); private static final Timer GET_QUEUES_TIMER = Metrics.timer(name(MessagePersister.class, "getQueues")); private static final Timer PERSIST_QUEUE_TIMER = Metrics.timer(name(MessagePersister.class, "persistQueue")); @@ -217,6 +218,8 @@ public class MessagePersister implements Managed { Metrics.counter(PERSISTED_MESSAGE_COUNTER_NAME, tags.and("urgent", "true")).increment(urgentMessageCount); Metrics.counter(PERSISTED_MESSAGE_COUNTER_NAME, tags.and("urgent", "false")).increment(nonUrgentMessageCount); + Metrics.counter(PERSISTED_BYTES_COUNTER_NAME, tags) + .increment(messages.stream().mapToInt(MessageProtos.Envelope::getSerializedSize).sum()); int messagesRemovedFromCache = messagesManager.persistMessages(accountUuid, device, messages); messageCount += messages.size();