MirrorMirror
/
Signal-Server
mirror of https://github.com/signalapp/Signal-Server.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Measure persisted message bytes

This commit is contained in:
Jon Chambers 2025-03-12 12:07:12 -04:00 committed by Jon Chambers
parent e1b1c7db8d
commit dcd80e11f4
1 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
service/src/main/java/org/whispersystems/textsecuregcm/storage/MessagesManager.java
View File

@ -48,6 +48,9 @@ public class MessagesManager {
private static final Counter PERSIST_MESSAGE_COUNTER = Metrics.counter( private static final Counter PERSIST_MESSAGE_COUNTER = Metrics.counter(
name(MessagesManager.class, "persistMessage")); 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 = private static final String MAY_HAVE_MESSAGES_COUNTER_NAME =
MetricsUtil.name(MessagesManager.class, "mayHaveMessages"); MetricsUtil.name(MessagesManager.class, "mayHaveMessages");
@ -276,6 +279,9 @@ public class MessagesManager {
messagesRemovedFromCache = messagesCache.remove(destinationUuid, destinationDevice.getId(), messageGuids) messagesRemovedFromCache = messagesCache.remove(destinationUuid, destinationDevice.getId(), messageGuids)
.get(30, TimeUnit.SECONDS).size(); .get(30, TimeUnit.SECONDS).size();
PERSIST_MESSAGE_COUNTER.increment(messages.size()); PERSIST_MESSAGE_COUNTER.increment(messages.size());
PERSIST_MESSAGE_BYTES_COUNTER.increment(messages.stream()
.mapToInt(Envelope::getSerializedSize)
.sum());
} catch (InterruptedException | ExecutionException | TimeoutException e) { } catch (InterruptedException | ExecutionException | TimeoutException e) {
logger.warn("Failed to remove messages from cache", e); logger.warn("Failed to remove messages from cache", e);