summaryrefslogtreecommitdiffstats
path: root/logserver
diff options
context:
space:
mode:
authorgjoranv <gjoranv@gmail.com>2018-05-02 12:23:17 +0200
committerGitHub <noreply@github.com>2018-05-02 12:23:17 +0200
commit8e80aede65732210a72dbdfe6e7863ff502bd5ac (patch)
treef8b7d0da3fc9e28a7cfed66c6154ee603ba7c60f /logserver
parentbbb5bcd8fa10bde6d3275e68c54b0a83c2ab94ad (diff)
Revert "Revert "Gjoranv/java9 prep 05""
Diffstat (limited to 'logserver')
-rw-r--r--logserver/src/main/java/com/yahoo/logserver/AbstractPluginLoader.java5
-rw-r--r--logserver/src/main/java/com/yahoo/logserver/Server.java7
-rw-r--r--logserver/src/test/java/com/yahoo/logserver/handlers/logmetrics/test/LogMetricsTestCase.java37
3 files changed, 28 insertions, 21 deletions
diff --git a/logserver/src/main/java/com/yahoo/logserver/AbstractPluginLoader.java b/logserver/src/main/java/com/yahoo/logserver/AbstractPluginLoader.java
index 619643a32b6..db2ed6b0b83 100644
--- a/logserver/src/main/java/com/yahoo/logserver/AbstractPluginLoader.java
+++ b/logserver/src/main/java/com/yahoo/logserver/AbstractPluginLoader.java
@@ -5,6 +5,7 @@ import com.yahoo.log.LogLevel;
import com.yahoo.plugin.Plugin;
import com.yahoo.plugin.SystemPropertyConfig;
+import java.lang.reflect.InvocationTargetException;
import java.util.logging.Logger;
/**
@@ -20,8 +21,8 @@ public abstract class AbstractPluginLoader implements PluginLoader {
protected void loadFromClass(Class<? extends Plugin> pluginClass) {
Plugin plugin;
try {
- plugin = (Plugin) pluginClass.newInstance();
- } catch (InstantiationException | IllegalAccessException e) {
+ plugin = pluginClass.getDeclaredConstructor().newInstance();
+ } catch (InstantiationException | IllegalAccessException | NoSuchMethodException | InvocationTargetException e) {
log.log(LogLevel.ERROR, pluginClass.getName() + ": load failed: " + e);
throw new RuntimeException(e);
}
diff --git a/logserver/src/main/java/com/yahoo/logserver/Server.java b/logserver/src/main/java/com/yahoo/logserver/Server.java
index f87c66ecd92..36b1c3e31a0 100644
--- a/logserver/src/main/java/com/yahoo/logserver/Server.java
+++ b/logserver/src/main/java/com/yahoo/logserver/Server.java
@@ -50,9 +50,6 @@ public class Server implements Runnable {
private final boolean isInitialized;
- /**
- * Server constructor
- */
private Server() {
dispatch = new LogDispatcher();
dispatch.setBatchedMode(true);
@@ -75,7 +72,7 @@ public class Server implements Runnable {
return ht;
}
- public void registerPluginLoader(PluginLoader loader) {
+ private void registerPluginLoader(PluginLoader loader) {
loader.loadPlugins();
}
@@ -90,7 +87,7 @@ public class Server implements Runnable {
unregisterLogHandler(lh, threadName);
}
- public void unregisterLogHandler(LogHandler lh, String threadName) {
+ private void unregisterLogHandler(LogHandler lh, String threadName) {
HandlerThread ht = getHandlerThread(threadName);
ht.unregisterHandler(lh);
threadNameForHandler.remove(lh);
diff --git a/logserver/src/test/java/com/yahoo/logserver/handlers/logmetrics/test/LogMetricsTestCase.java b/logserver/src/test/java/com/yahoo/logserver/handlers/logmetrics/test/LogMetricsTestCase.java
index 2e0b3d67c49..434131878c0 100644
--- a/logserver/src/test/java/com/yahoo/logserver/handlers/logmetrics/test/LogMetricsTestCase.java
+++ b/logserver/src/test/java/com/yahoo/logserver/handlers/logmetrics/test/LogMetricsTestCase.java
@@ -83,20 +83,29 @@ public class LogMetricsTestCase {
assertEquals(levelCount.entrySet().size(), 5);
for (Map.Entry<String, Long> entry : levelCount.entrySet()) {
String key = entry.getKey();
- if (key.equals("config")) {
- assertEquals(entry.getValue(), new Long(1));
- } else if (key.equals("info")) {
- assertEquals(entry.getValue(), new Long(4));
- } else if (key.equals("warning")) {
- assertEquals(entry.getValue(), new Long(1));
- } else if (key.equals("severe")) {
- assertEquals(entry.getValue(), new Long(0));
- } else if (key.equals("error")) {
- assertEquals(entry.getValue(), new Long(1));
- } else if (key.equals("fatal")) {
- assertEquals(entry.getValue(), new Long(1));
- } else if (key.equals("debug")) {
- assertEquals(entry.getValue(), new Long(0)); // always 0
+ switch (key) {
+ case "config":
+ assertEquals(entry.getValue(), Long.valueOf(1));
+ break;
+ case "info":
+ assertEquals(entry.getValue(), Long.valueOf(4));
+ break;
+ case "warning":
+ assertEquals(entry.getValue(), Long.valueOf(1));
+ break;
+ case "severe":
+ assertEquals(entry.getValue(), Long.valueOf(0));
+ break;
+ case "error":
+ assertEquals(entry.getValue(), Long.valueOf(1));
+ break;
+ case "fatal":
+ assertEquals(entry.getValue(), Long.valueOf(1));
+ break;
+ case "debug":
+ assertEquals(entry.getValue(), Long.valueOf(0)); // always 0
+
+ break;
}
}
a.close();