Add ephemeral tag to MRM error retrieval counter

signalapp · Nov 12, 2024 · 0ca9e97 · 0ca9e97
1 parent ee5df0e
commit 0ca9e97
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/service/src/main/java/org/whispersystems/textsecuregcm/storage/MessagesCache.java b/service/src/main/java/org/whispersystems/textsecuregcm/storage/MessagesCache.java
@@ -137,7 +137,8 @@ public class MessagesCache {
   private final Counter staleEphemeralMessagesCounter = Metrics.counter(
       name(MessagesCache.class, "staleEphemeralMessages"));
   private final Counter mrmContentRetrievedCounter = Metrics.counter(name(MessagesCache.class, "mrmViewRetrieved"));
-  private final Counter mrmRetrievalErrorCounter = Metrics.counter(name(MessagesCache.class, "mrmRetrievalError"));
+  private final String MRM_RETRIEVAL_ERROR_COUNTER_NAME = "mrmRetrievalError";
+  private final String EPHEMERAL_TAG_NAME = "ephemeral";
   private final Counter mrmPhaseTwoMissingContentCounter = Metrics.counter(
       name(MessagesCache.class, "mrmPhaseTwoMissingContent"));
   private final Counter skippedStaleEphemeralMrmCounter = Metrics.counter(
@@ -436,7 +437,10 @@ private Mono<MessageProtos.Envelope> getMessageWithSharedMrmData(final MessagePr
         })
         .onErrorResume(throwable -> {
           logger.warn("Failed to retrieve shared mrm data", throwable);
-          mrmRetrievalErrorCounter.increment();
+          Metrics.counter(MRM_RETRIEVAL_ERROR_COUNTER_NAME,
+                  EPHEMERAL_TAG_NAME, String.valueOf(mrmMessage.getEphemeral()))
+              .increment();
+
           return Mono.empty();
         })
         .share();