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

Make write operations in `AccountDatabaseCrawlerCache` synchronous.

This commit is contained in:
Jon Chambers 2020-06-17 09:57:30 -04:00 committed by Jon Chambers
parent c2e72c7641
commit 38f9b8f3dd
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
service/src/main/java/org/whispersystems/textsecuregcm/storage/AccountDatabaseCrawlerCache.java
View File

@ -62,7 +62,7 @@ public class AccountDatabaseCrawlerCache {
public void clearAccelerate() { public void clearAccelerate() {
try (Jedis jedis = jedisPool.getWriteResource()) { try (Jedis jedis = jedisPool.getWriteResource()) {
jedis.del(ACCELERATE_KEY); jedis.del(ACCELERATE_KEY);
cacheCluster.useWriteCluster(connection -> connection.async().del(ACCELERATE_KEY)); cacheCluster.useWriteCluster(connection -> connection.sync().del(ACCELERATE_KEY));
} }
} }
@ -81,7 +81,7 @@ public class AccountDatabaseCrawlerCache {
if (claimed) { if (claimed) {
// TODO Restore the NX flag when making the cluster the primary data store // TODO Restore the NX flag when making the cluster the primary data store
cacheCluster.useWriteCluster(connection -> connection.async().set(ACCELERATE_KEY, workerId, SetArgs.Builder.px(ttlMs))); cacheCluster.useWriteCluster(connection -> connection.sync().set(ACCELERATE_KEY, workerId, SetArgs.Builder.px(ttlMs)));
} }
return claimed; return claimed;
@ -114,10 +114,10 @@ public class AccountDatabaseCrawlerCache {
try (Jedis jedis = jedisPool.getWriteResource()) { try (Jedis jedis = jedisPool.getWriteResource()) {
if (lastUuid.isPresent()) { if (lastUuid.isPresent()) {
jedis.psetex(LAST_UUID_KEY, LAST_NUMBER_TTL_MS, lastUuid.get().toString()); jedis.psetex(LAST_UUID_KEY, LAST_NUMBER_TTL_MS, lastUuid.get().toString());
cacheCluster.useWriteCluster(connection -> connection.async().psetex(LAST_UUID_KEY, LAST_NUMBER_TTL_MS, lastUuid.get().toString())); cacheCluster.useWriteCluster(connection -> connection.sync().psetex(LAST_UUID_KEY, LAST_NUMBER_TTL_MS, lastUuid.get().toString()));
} else { } else {
jedis.del(LAST_UUID_KEY); jedis.del(LAST_UUID_KEY);
cacheCluster.useWriteCluster(connection -> connection.async().del(LAST_UUID_KEY)); cacheCluster.useWriteCluster(connection -> connection.sync().del(LAST_UUID_KEY));
} }
} }
} }