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

Log max concurrency when starting/finishing experiments

This commit is contained in:
Jon Chambers 2024-07-30 17:53:10 -04:00 committed by Jon Chambers
parent 7e62dc64dc
commit f1c153f39f
2 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
service/src/main/java/org/whispersystems/textsecuregcm/workers/FinishPushNotificationExperimentCommand.java
View File

@ -70,6 +70,8 @@ public class FinishPushNotificationExperimentCommand<T> extends AbstractCommandW
final int maxConcurrency = namespace.getInt(MAX_CONCURRENCY_ARGUMENT); final int maxConcurrency = namespace.getInt(MAX_CONCURRENCY_ARGUMENT);
log.info("Finishing \"{}\" with max concurrency: {}", experiment.getExperimentName(), maxConcurrency);
final AccountsManager accountsManager = commandDependencies.accountsManager(); final AccountsManager accountsManager = commandDependencies.accountsManager();
final PushNotificationExperimentSamples pushNotificationExperimentSamples = commandDependencies.pushNotificationExperimentSamples(); final PushNotificationExperimentSamples pushNotificationExperimentSamples = commandDependencies.pushNotificationExperimentSamples();

2
service/src/main/java/org/whispersystems/textsecuregcm/workers/StartPushNotificationExperimentCommand.java
View File

@ -83,6 +83,8 @@ public class StartPushNotificationExperimentCommand<T> extends AbstractSinglePas
final PushNotificationExperimentSamples pushNotificationExperimentSamples = final PushNotificationExperimentSamples pushNotificationExperimentSamples =
getCommandDependencies().pushNotificationExperimentSamples(); getCommandDependencies().pushNotificationExperimentSamples();
log.info("Starting \"{}\" with max concurrency: {}", experiment.getExperimentName(), maxConcurrency);
accounts accounts
.flatMap(account -> Flux.fromIterable(account.getDevices()).map(device -> Tuples.of(account, device))) .flatMap(account -> Flux.fromIterable(account.getDevices()).map(device -> Tuples.of(account, device)))
.doOnNext(ignored -> DEVICE_INSPECTED_COUNTER.increment()) .doOnNext(ignored -> DEVICE_INSPECTED_COUNTER.increment())