aboutsummaryrefslogtreecommitdiffstats
path: root/messagebus
diff options
context:
space:
mode:
authorgjoranv <gv@verizonmedia.com>2020-04-24 13:12:46 +0200
committergjoranv <gv@verizonmedia.com>2020-04-25 02:22:55 +0200
commit25f832e613bb6087327c293b527d5445babb4319 (patch)
tree8197a5b331e845bfe91f006d9cfe8bec9a28170f /messagebus
parent4e6825b47270804a36e7d76b873ca6c2fe360eac (diff)
LogLevel.DEBUG -> Level.FINE
Diffstat (limited to 'messagebus')
-rw-r--r--messagebus/src/main/java/com/yahoo/messagebus/DynamicThrottlePolicy.java4
-rw-r--r--messagebus/src/main/java/com/yahoo/messagebus/SendProxy.java2
-rwxr-xr-xmessagebus/src/main/java/com/yahoo/messagebus/network/rpc/RPCTarget.java8
3 files changed, 7 insertions, 7 deletions
diff --git a/messagebus/src/main/java/com/yahoo/messagebus/DynamicThrottlePolicy.java b/messagebus/src/main/java/com/yahoo/messagebus/DynamicThrottlePolicy.java
index d2e3c84baab..db464c1cd99 100644
--- a/messagebus/src/main/java/com/yahoo/messagebus/DynamicThrottlePolicy.java
+++ b/messagebus/src/main/java/com/yahoo/messagebus/DynamicThrottlePolicy.java
@@ -101,7 +101,7 @@ public class DynamicThrottlePolicy extends StaticThrottlePolicy {
localMaxThroughput = throughput;
windowSize += weight*windowSizeIncrement;
if (log.isLoggable(LogLevel.DEBUG)) {
- log.log(LogLevel.DEBUG, "windowSize " + windowSize + " throughput " + throughput + " local max " + localMaxThroughput);
+ log.log(Level.FINE, "windowSize " + windowSize + " throughput " + throughput + " local max " + localMaxThroughput);
}
} else {
// scale up/down throughput for comparing to window size
@@ -120,7 +120,7 @@ public class DynamicThrottlePolicy extends StaticThrottlePolicy {
windowSize += weight*windowSizeIncrement;
}
if (log.isLoggable(LogLevel.DEBUG)) {
- log.log(LogLevel.DEBUG, "windowSize " + windowSize + " throughput " + throughput + " local max " + localMaxThroughput + " efficiency " + efficiency);
+ log.log(Level.FINE, "windowSize " + windowSize + " throughput " + throughput + " local max " + localMaxThroughput + " efficiency " + efficiency);
}
}
windowSize = Math.max(minWindowSize, windowSize);
diff --git a/messagebus/src/main/java/com/yahoo/messagebus/SendProxy.java b/messagebus/src/main/java/com/yahoo/messagebus/SendProxy.java
index da143877083..77bbd662cc4 100644
--- a/messagebus/src/main/java/com/yahoo/messagebus/SendProxy.java
+++ b/messagebus/src/main/java/com/yahoo/messagebus/SendProxy.java
@@ -59,7 +59,7 @@ public class SendProxy implements MessageHandler, ReplyHandler {
Trace trace = msg.getTrace();
if (logTrace) {
if (reply.hasErrors()) {
- log.log(LogLevel.DEBUG, "Trace for reply with error(s):\n" + reply.getTrace());
+ log.log(Level.FINE, "Trace for reply with error(s):\n" + reply.getTrace());
} else if (log.isLoggable(LogLevel.SPAM)) {
log.log(LogLevel.SPAM, "Trace for reply:\n" + reply.getTrace());
}
diff --git a/messagebus/src/main/java/com/yahoo/messagebus/network/rpc/RPCTarget.java b/messagebus/src/main/java/com/yahoo/messagebus/network/rpc/RPCTarget.java
index 9cab213b628..b8faafe54bb 100755
--- a/messagebus/src/main/java/com/yahoo/messagebus/network/rpc/RPCTarget.java
+++ b/messagebus/src/main/java/com/yahoo/messagebus/network/rpc/RPCTarget.java
@@ -102,12 +102,12 @@ public class RPCTarget implements RequestWaiter {
synchronized (this) {
if (version != null) {
if (shouldLog) {
- log.log(LogLevel.DEBUG, "Version already available for target '" + name + "' (version " + version + ").");
+ log.log(Level.FINE, "Version already available for target '" + name + "' (version " + version + ").");
}
hasVersion = true;
} else {
if (shouldLog) {
- log.log(LogLevel.DEBUG, "Registering version handler '" + handler + "' for target '" + name + "'.");
+ log.log(Level.FINE, "Registering version handler '" + handler + "' for target '" + name + "'.");
}
versionHandlers.add(handler);
if (!targetInvoked) {
@@ -120,7 +120,7 @@ public class RPCTarget implements RequestWaiter {
handler.handleVersion(version);
} else if (shouldInvoke) {
if (shouldLog) {
- log.log(LogLevel.DEBUG, "Invoking mbus.getVersion() on target '" + name + "'");
+ log.log(Level.FINE, "Invoking mbus.getVersion() on target '" + name + "'");
}
Request req = new Request("mbus.getVersion");
target.invokeAsync(req, timeout, this);
@@ -138,7 +138,7 @@ public class RPCTarget implements RequestWaiter {
try {
version = new Version(str);
if (shouldLog) {
- log.log(LogLevel.DEBUG, "Target '" + name + "' has version " + version + ".");
+ log.log(Level.FINE, "Target '" + name + "' has version " + version + ".");
}
} catch (IllegalArgumentException e) {
log.log(LogLevel.WARNING, "Failed to parse '" + str + "' as version for target '" + name + "'.", e);