From dcd80e11f4db613e1faa4b5eb4863b7ffa4f001b Mon Sep 17 00:00:00 2001 From: Jon Chambers Date: Wed, 12 Mar 2025 12:07:12 -0400 Subject: [PATCH] Measure persisted message bytes --- .../textsecuregcm/storage/MessagesManager.java | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/service/src/main/java/org/whispersystems/textsecuregcm/storage/MessagesManager.java b/service/src/main/java/org/whispersystems/textsecuregcm/storage/MessagesManager.java index 2b36a56e6..92a3426d7 100644 --- a/service/src/main/java/org/whispersystems/textsecuregcm/storage/MessagesManager.java +++ b/service/src/main/java/org/whispersystems/textsecuregcm/storage/MessagesManager.java @@ -48,6 +48,9 @@ public class MessagesManager { private static final Counter PERSIST_MESSAGE_COUNTER = Metrics.counter( name(MessagesManager.class, "persistMessage")); + private static final Counter PERSIST_MESSAGE_BYTES_COUNTER = Metrics.counter( + name(MessagesManager.class, "persistMessageBytes")); + private static final String MAY_HAVE_MESSAGES_COUNTER_NAME = MetricsUtil.name(MessagesManager.class, "mayHaveMessages"); @@ -276,6 +279,9 @@ public class MessagesManager { messagesRemovedFromCache = messagesCache.remove(destinationUuid, destinationDevice.getId(), messageGuids) .get(30, TimeUnit.SECONDS).size(); PERSIST_MESSAGE_COUNTER.increment(messages.size()); + PERSIST_MESSAGE_BYTES_COUNTER.increment(messages.stream() + .mapToInt(Envelope::getSerializedSize) + .sum()); } catch (InterruptedException | ExecutionException | TimeoutException e) { logger.warn("Failed to remove messages from cache", e);