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

Add counter for failed account updates to RemoveExpiredLinkedDevicesCommand

This commit is contained in:
Chris Eager 2023-12-20 12:23:33 -06:00 committed by Chris Eager
parent d90dff95b1
commit 06c391cbf6
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
service/src/main/java/org/whispersystems/textsecuregcm/workers/RemoveExpiredLinkedDevicesCommand.java
View File

@ -30,6 +30,9 @@ public class RemoveExpiredLinkedDevicesCommand extends AbstractSinglePassCrawlAc
"removedDevices"); "removedDevices");
private static final String UPDATED_ACCOUNTS_COUNTER_NAME = name(RemoveExpiredLinkedDevicesCommand.class, private static final String UPDATED_ACCOUNTS_COUNTER_NAME = name(RemoveExpiredLinkedDevicesCommand.class,
"updatedAccounts"); "updatedAccounts");
private static final String FAILED_ACCOUNT_UPDATES_COUNTER_NAME = name(RemoveExpiredLinkedDevicesCommand.class,
"failedAccountUpdates");
private static final Logger logger = LoggerFactory.getLogger(RemoveExpiredLinkedDevicesCommand.class); private static final Logger logger = LoggerFactory.getLogger(RemoveExpiredLinkedDevicesCommand.class);
public RemoveExpiredLinkedDevicesCommand() { public RemoveExpiredLinkedDevicesCommand() {
@ -65,8 +68,8 @@ public class RemoveExpiredLinkedDevicesCommand extends AbstractSinglePassCrawlAc
return accountUpdate.thenReturn(expiredDevices.size()) return accountUpdate.thenReturn(expiredDevices.size())
.onErrorResume(t -> { .onErrorResume(t -> {
logger.warn("Failed to remove expired linked devices {}", account.getUuid(), logger.warn("Failed to remove expired linked devices {}", account.getUuid(), t);
t); Metrics.counter(FAILED_ACCOUNT_UPDATES_COUNTER_NAME).increment();
return Mono.empty(); return Mono.empty();
}); });