Upstream/Plan
1
0
Fork 0
mirror of https://github.com/plan-player-analytics/Plan.git synced 2024-11-01 00:10:12 +01:00
Code Issues Projects Releases Wiki Activity

Log connection waiting sites without dev mode

Browse Source
This commit is contained in:
Aurora Lahtela 2024-02-04 10:05:35 +02:00
parent 8ced48d815
commit bf3bdb599d
1 changed files with 10 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

30
Plan/common/src/main/java/com/djrapitops/plan/utilities/SemaphoreAccessCounter.java
View File

@ -17,15 +17,10 @@
package com.djrapitops.plan.utilities; package com.djrapitops.plan.utilities;
import com.djrapitops.plan.settings.config.PlanConfig; import com.djrapitops.plan.settings.config.PlanConfig;
import com.djrapitops.plan.settings.config.paths.PluginSettings;
import org.jetbrains.annotations.NotNull; import org.jetbrains.annotations.NotNull;
import java.util.ArrayList; import java.util.*;
import java.util.Collection;
import java.util.Collections;
import java.util.List;
import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.atomic.AtomicBoolean;
import java.util.concurrent.atomic.AtomicInteger; import java.util.concurrent.atomic.AtomicInteger;
import java.util.logging.Level; import java.util.logging.Level;
import java.util.logging.Logger; import java.util.logging.Logger;
@ -37,7 +32,6 @@ public class SemaphoreAccessCounter {
private final AtomicInteger accessCounter; private final AtomicInteger accessCounter;
private final Object lockObject; private final Object lockObject;
private final Collection<String> holds = Collections.newSetFromMap(new ConcurrentHashMap<>()); private final Collection<String> holds = Collections.newSetFromMap(new ConcurrentHashMap<>());
private AtomicBoolean logHolds = null;
public SemaphoreAccessCounter(PlanConfig config) { public SemaphoreAccessCounter(PlanConfig config) {
this.config = config; this.config = config;
@ -60,20 +54,18 @@ public class SemaphoreAccessCounter {
previousWasAccess = true; previousWasAccess = true;
} }
} }
if (accessors.isEmpty()) accessors.addAll(Arrays.asList(Thread.currentThread().getStackTrace()));
return accessors.toString(); return accessors.toString();
} }
public void enter() { public void enter() {
accessCounter.incrementAndGet(); accessCounter.incrementAndGet();
holds.add(getAccessingThing());
if (logHolds == null) logHolds = new AtomicBoolean(config.isTrue(PluginSettings.DEV_MODE));
if (logHolds.get()) holds.add(getAccessingThing());
} }
public void exit() { public void exit() {
synchronized (lockObject) { synchronized (lockObject) {
if (logHolds == null) logHolds = new AtomicBoolean(config.isTrue(PluginSettings.DEV_MODE)); holds.remove(getAccessingThing());
if (logHolds.get()) holds.remove(getAccessingThing());
int value = accessCounter.decrementAndGet(); int value = accessCounter.decrementAndGet();
if (value == 0) { if (value == 0) {
@ -96,15 +88,13 @@ public class SemaphoreAccessCounter {
} }
private void logAccess() { private void logAccess() {
if (logHolds != null && logHolds.get()) { Logger logger = Logger.getLogger("Plan");
Logger logger = Logger.getLogger("Plan"); if (logger == null) logger = Logger.getGlobal();
if (logger == null) logger = Logger.getGlobal();
if (logger.isLoggable(Level.INFO) && !holds.isEmpty()) { if (logger.isLoggable(Level.INFO) && !holds.isEmpty()) {
logger.log(Level.INFO, "DEBUG - Following call sites are holding connection:"); logger.log(Level.INFO, "Waiting for these connections to finish:");
for (String hold : holds) { for (String hold : holds) {
logger.log(Level.INFO, String.format("DEBUG - %s", hold)); logger.log(Level.INFO, hold);
}
} }
} }
} }