minecraft/LuckPerms
1
0
Fork 0
mirror of https://github.com/lucko/LuckPerms.git synced 2025-08-22 06:02:49 +02:00
Code Issues Releases Wiki Activity

Only store ids of received messages for 1 hour to prevent high memory usage on instances with high uptime (#2807)

Browse Source
This commit is contained in:
Luck
2021-01-02 20:08:56 +00:00
parent c3581c00d3
commit a8b1dc8c07
1 changed files with 2 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
common/src/main/java/me/lucko/luckperms/common/messaging/LuckPermsMessagingService.java
View File

@@ -36,6 +36,7 @@ import me.lucko.luckperms.common.messaging.message.UpdateMessageImpl;
import me.lucko.luckperms.common.messaging.message.UserUpdateMessageImpl;
import me.lucko.luckperms.common.model.User;
import me.lucko.luckperms.common.plugin.LuckPermsPlugin;
import me.lucko.luckperms.common.util.ExpiringSet;
import me.lucko.luckperms.common.util.gson.GsonProvider;
import me.lucko.luckperms.common.util.gson.JObject;
@@ -51,8 +52,6 @@ import net.luckperms.api.messenger.message.type.UserUpdateMessage;
import org.checkerframework.checker.nullness.qual.NonNull;
import org.checkerframework.checker.nullness.qual.Nullable;
import java.util.Collections;
import java.util.HashSet;
import java.util.Objects;
import java.util.Set;
import java.util.UUID;
@@ -73,7 +72,7 @@ public class LuckPermsMessagingService implements InternalMessagingService, Inco
this.messenger = messengerProvider.obtain(this);
Objects.requireNonNull(this.messenger, "messenger");
this.receivedMessages = Collections.synchronizedSet(new HashSet<>());
this.receivedMessages = new ExpiringSet<>(1, TimeUnit.HOURS);
this.updateBuffer = new PushUpdateBuffer(plugin);
}