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

Add eviction meter

This commit is contained in:
Moxie Marlinspike 2019-03-22 22:54:21 -07:00
parent d63309ae51
commit 7463652345
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/main/java/org/whispersystems/textsecuregcm/push/ApnFallbackManager.java
View File

@ -39,6 +39,7 @@ public class ApnFallbackManager implements Managed, Runnable {
private static final Meter delivered = metricRegistry.meter(name(ApnFallbackManager.class, "voip_delivered")); private static final Meter delivered = metricRegistry.meter(name(ApnFallbackManager.class, "voip_delivered"));
private static final Meter sent = metricRegistry.meter(name(ApnFallbackManager.class, "voip_sent" )); private static final Meter sent = metricRegistry.meter(name(ApnFallbackManager.class, "voip_sent" ));
private static final Meter retry = metricRegistry.meter(name(ApnFallbackManager.class, "voip_retry")); private static final Meter retry = metricRegistry.meter(name(ApnFallbackManager.class, "voip_retry"));
private static final Meter evicted = metricRegistry.meter(name(ApnFallbackManager.class, "voip_evicted"));
static { static {
metricRegistry.register(name(ApnFallbackManager.class, "voip_ratio"), new VoipRatioGauge(delivered, sent)); metricRegistry.register(name(ApnFallbackManager.class, "voip_ratio"), new VoipRatioGauge(delivered, sent));
@ -151,7 +152,7 @@ public class ApnFallbackManager implements Managed, Runnable {
long deviceLastSeen = device.get().getLastSeen(); long deviceLastSeen = device.get().getLastSeen();
if (deviceLastSeen < System.currentTimeMillis() - TimeUnit.DAYS.toMillis(90)) { if (deviceLastSeen < System.currentTimeMillis() - TimeUnit.DAYS.toMillis(90)) {
logger.info("Evicting retry after 90 days: " + account.get().getNumber() + ", " + device.get().getId()); evicted.mark();
removeOperation.remove(account.get(), device.get()); removeOperation.remove(account.get(), device.get());
continue; continue;
} }