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

Add clients to the "cleanup" list before actually setting their presence keys.

This commit is contained in:
Jon Chambers 2020-10-19 11:00:15 -04:00 committed by Jon Chambers
parent 23ca011ac1
commit 42ed6c3ded
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
service/src/main/java/org/whispersystems/textsecuregcm/push/ClientPresenceManager.java
View File

@ -38,6 +38,9 @@ import static com.codahale.metrics.MetricRegistry.name;
* The client presence manager keeps track of which clients are actively connected and "present" to receive messages. * The client presence manager keeps track of which clients are actively connected and "present" to receive messages.
* Only one client per account/device may be present at a time; if a second client for the same account/device declares * Only one client per account/device may be present at a time; if a second client for the same account/device declares
* its presence, the previous client is displaced. * its presence, the previous client is displaced.
* <p/>
* The client presence manager depends on Redis keyspace notifications and requires that the Redis instance support at
* least the following notification types: {@code K$z}.
*/ */
public class ClientPresenceManager extends RedisClusterPubSubAdapter<String, String> implements Managed { public class ClientPresenceManager extends RedisClusterPubSubAdapter<String, String> implements Managed {
@ -146,8 +149,8 @@ public class ClientPresenceManager extends RedisClusterPubSubAdapter<String, Str
presenceCluster.useCluster(connection -> { presenceCluster.useCluster(connection -> {
final RedisAdvancedClusterCommands<String, String> commands = connection.sync(); final RedisAdvancedClusterCommands<String, String> commands = connection.sync();
commands.set(presenceKey, managerId);
commands.sadd(connectedClientSetKey, presenceKey); commands.sadd(connectedClientSetKey, presenceKey);
commands.set(presenceKey, managerId);
}); });
subscribeForRemotePresenceChanges(presenceKey); subscribeForRemotePresenceChanges(presenceKey);