Limework/RedisBungee
2
0
Fork 0
mirror of https://github.com/proxiodev/RedisBungee.git synced 2024-11-23 04:28:01 +00:00
Code Releases Activity

invalidate clarifcation, remove unified jedis method from ProxyDataManager

Browse Source
This commit is contained in:
mohammed jasem alaajel 2024-05-18 16:46:35 +04:00
parent d6b3956a96
commit 3314c5e54b
Signed by: ham1255
GPG Key ID: EF343502046229F4
2 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
api/src/main/java/com/imaginarycode/minecraft/redisbungee/api/PlayerDataManager.java
View File

@ -52,7 +52,7 @@ public abstract class PlayerDataManager<P, LE, DE, PS extends IPubSubMessageEven
public PlayerDataManager(RedisBungeePlugin<P> plugin) { public PlayerDataManager(RedisBungeePlugin<P> plugin) {
this.plugin = plugin; this.plugin = plugin;
this.unifiedJedis = plugin.proxyDataManager().unifiedJedis(); this.unifiedJedis = plugin.getSummoner().obtainResource();
this.proxyId = plugin.proxyDataManager().proxyId(); this.proxyId = plugin.proxyDataManager().proxyId();
this.networkId = plugin.proxyDataManager().networkId(); this.networkId = plugin.proxyDataManager().networkId();
} }
@ -83,6 +83,8 @@ public abstract class PlayerDataManager<P, LE, DE, PS extends IPubSubMessageEven
} }
protected void handleNetworkPlayerQuit(IPlayerLeftNetworkEvent event) { protected void handleNetworkPlayerQuit(IPlayerLeftNetworkEvent event) {
// reason we don't set the data here because in-case of failure in redis etc,
// events won't reach the proxy so data would be incorrect.
this.proxyCache.invalidate(event.getUuid()); this.proxyCache.invalidate(event.getUuid());
this.serverCache.invalidate(event.getUuid()); this.serverCache.invalidate(event.getUuid());
this.ipCache.invalidate(event.getUuid()); this.ipCache.invalidate(event.getUuid());
@ -93,6 +95,8 @@ public abstract class PlayerDataManager<P, LE, DE, PS extends IPubSubMessageEven
} }
protected void handleNetworkPlayerJoin(IPlayerJoinedNetworkEvent event) { protected void handleNetworkPlayerJoin(IPlayerJoinedNetworkEvent event) {
// reason we don't set the data here because in-case of failure in redis etc,
// events won't reach the proxy so data would be incorrect.
this.proxyCache.invalidate(event.getUuid()); this.proxyCache.invalidate(event.getUuid());
this.serverCache.invalidate(event.getUuid()); this.serverCache.invalidate(event.getUuid());
this.ipCache.invalidate(event.getUuid()); this.ipCache.invalidate(event.getUuid());

4
api/src/main/java/com/imaginarycode/minecraft/redisbungee/api/ProxyDataManager.java
View File

@ -392,10 +392,6 @@ public abstract class ProxyDataManager implements Runnable {
return proxyId; return proxyId;
} }
public UnifiedJedis unifiedJedis() {
return unifiedJedis;
}
public String networkId() { public String networkId() {
return networkId; return networkId;
} }