From ff2783d43441341d516d5169c63638c262d83698 Mon Sep 17 00:00:00 2001 From: Jon Chambers Date: Thu, 2 Jul 2020 11:07:18 -0400 Subject: [PATCH] Fixed a goof where we were mirroring a write to the wrong key in the new cache cluster. --- .../textsecuregcm/storage/AccountDatabaseCrawlerCache.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/service/src/main/java/org/whispersystems/textsecuregcm/storage/AccountDatabaseCrawlerCache.java b/service/src/main/java/org/whispersystems/textsecuregcm/storage/AccountDatabaseCrawlerCache.java index ce29dbf27..70f77f4fa 100644 --- a/service/src/main/java/org/whispersystems/textsecuregcm/storage/AccountDatabaseCrawlerCache.java +++ b/service/src/main/java/org/whispersystems/textsecuregcm/storage/AccountDatabaseCrawlerCache.java @@ -81,7 +81,7 @@ public class AccountDatabaseCrawlerCache { if (claimed) { // TODO Restore the NX flag when making the cluster the primary data store - cacheCluster.useWriteCluster(connection -> connection.sync().set(ACCELERATE_KEY, workerId, SetArgs.Builder.px(ttlMs))); + cacheCluster.useWriteCluster(connection -> connection.sync().set(ACTIVE_WORKER_KEY, workerId, SetArgs.Builder.px(ttlMs))); } return claimed;