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

Record the number of non-success responses from clients when sending messages via websockets.

This commit is contained in:
Jon Chambers 2020-10-29 10:34:30 -04:00 committed by Jon Chambers
parent 6c78d7544f
commit 103b49ec45
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
service/src/main/java/org/whispersystems/textsecuregcm/websocket/WebSocketConnection.java
View File

@ -57,6 +57,7 @@ public class WebSocketConnection implements MessageAvailabilityListener, Displac
private static final Meter messagesPersistedMeter = metricRegistry.meter(name(WebSocketConnection.class, "messagesPersisted")); private static final Meter messagesPersistedMeter = metricRegistry.meter(name(WebSocketConnection.class, "messagesPersisted"));
private static final Meter bytesSentMeter = metricRegistry.meter(name(WebSocketConnection.class, "bytes_sent")); private static final Meter bytesSentMeter = metricRegistry.meter(name(WebSocketConnection.class, "bytes_sent"));
private static final Meter sendFailuresMeter = metricRegistry.meter(name(WebSocketConnection.class, "send_failures")); private static final Meter sendFailuresMeter = metricRegistry.meter(name(WebSocketConnection.class, "send_failures"));
private static final Meter clientNonSuccessResponseMeter = metricRegistry.meter(name(WebSocketConnection.class, "clientNonSuccessResponse"));
private static final String DISPLACEMENT_COUNTER_NAME = name(WebSocketConnection.class, "displacement"); private static final String DISPLACEMENT_COUNTER_NAME = name(WebSocketConnection.class, "displacement");
private static final String DISPLACEMENT_PLATFORM_TAG_NAME = "platform"; private static final String DISPLACEMENT_PLATFORM_TAG_NAME = "platform";
@ -128,6 +129,8 @@ public class WebSocketConnection implements MessageAvailabilityListener, Displac
messageTime.update(System.currentTimeMillis() - message.getTimestamp()); messageTime.update(System.currentTimeMillis() - message.getTimestamp());
sendDeliveryReceiptFor(message); sendDeliveryReceiptFor(message);
} }
} else {
clientNonSuccessResponseMeter.mark();
} }
} else { } else {
sendFailuresMeter.mark(); sendFailuresMeter.mark();