You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@logging.apache.org by rp...@apache.org on 2016/09/04 07:22:37 UTC
[49/50] logging-log4j2 git commit: Better thread names.
Better thread names.
Project: http://git-wip-us.apache.org/repos/asf/logging-log4j2/repo
Commit: http://git-wip-us.apache.org/repos/asf/logging-log4j2/commit/dbbeb5cf
Tree: http://git-wip-us.apache.org/repos/asf/logging-log4j2/tree/dbbeb5cf
Diff: http://git-wip-us.apache.org/repos/asf/logging-log4j2/diff/dbbeb5cf
Branch: refs/heads/LOG4J2-1349-gcfree-threadcontext
Commit: dbbeb5cf505ae4adbbcd8f10d5396f5d674e7468
Parents: 21cc981
Author: ggregory <gg...@apache.org>
Authored: Sun Sep 4 02:43:38 2016 -0400
Committer: ggregory <gg...@apache.org>
Committed: Sun Sep 4 02:43:38 2016 -0400
----------------------------------------------------------------------
.../java/org/apache/logging/log4j/core/appender/AsyncAppender.java | 2 +-
.../main/java/org/apache/logging/log4j/core/util/CachedClock.java | 2 +-
.../java/org/apache/logging/log4j/core/util/CoarseCachedClock.java | 2 +-
.../logging/log4j/flume/appender/FlumePersistentManager.java | 1 +
4 files changed, 4 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/logging-log4j2/blob/dbbeb5cf/log4j-core/src/main/java/org/apache/logging/log4j/core/appender/AsyncAppender.java
----------------------------------------------------------------------
diff --git a/log4j-core/src/main/java/org/apache/logging/log4j/core/appender/AsyncAppender.java b/log4j-core/src/main/java/org/apache/logging/log4j/core/appender/AsyncAppender.java
index 7b6e985..11ac79d 100644
--- a/log4j-core/src/main/java/org/apache/logging/log4j/core/appender/AsyncAppender.java
+++ b/log4j-core/src/main/java/org/apache/logging/log4j/core/appender/AsyncAppender.java
@@ -269,10 +269,10 @@ public final class AsyncAppender extends AbstractAppender {
private final BlockingQueue<LogEvent> queue;
public AsyncThread(final List<AppenderControl> appenders, final BlockingQueue<LogEvent> queue) {
+ super("AsyncAppender-" + THREAD_SEQUENCE.getAndIncrement());
this.appenders = appenders;
this.queue = queue;
setDaemon(true);
- setName("AsyncAppenderThread" + THREAD_SEQUENCE.getAndIncrement());
}
@Override
http://git-wip-us.apache.org/repos/asf/logging-log4j2/blob/dbbeb5cf/log4j-core/src/main/java/org/apache/logging/log4j/core/util/CachedClock.java
----------------------------------------------------------------------
diff --git a/log4j-core/src/main/java/org/apache/logging/log4j/core/util/CachedClock.java b/log4j-core/src/main/java/org/apache/logging/log4j/core/util/CachedClock.java
index d53b2c0..f6d51ab 100644
--- a/log4j-core/src/main/java/org/apache/logging/log4j/core/util/CachedClock.java
+++ b/log4j-core/src/main/java/org/apache/logging/log4j/core/util/CachedClock.java
@@ -45,7 +45,7 @@ public final class CachedClock implements Clock {
LockSupport.parkNanos(1000 * 1000);
}
}
- }, "Clock Updater Thread");
+ }, "CachedClock Updater Thread");
updater.setDaemon(true);
updater.start();
}
http://git-wip-us.apache.org/repos/asf/logging-log4j2/blob/dbbeb5cf/log4j-core/src/main/java/org/apache/logging/log4j/core/util/CoarseCachedClock.java
----------------------------------------------------------------------
diff --git a/log4j-core/src/main/java/org/apache/logging/log4j/core/util/CoarseCachedClock.java b/log4j-core/src/main/java/org/apache/logging/log4j/core/util/CoarseCachedClock.java
index 769db08..144f470 100644
--- a/log4j-core/src/main/java/org/apache/logging/log4j/core/util/CoarseCachedClock.java
+++ b/log4j-core/src/main/java/org/apache/logging/log4j/core/util/CoarseCachedClock.java
@@ -28,7 +28,7 @@ public final class CoarseCachedClock implements Clock {
// ignore IDE complaints; volatile long is fine
private volatile long millis = System.currentTimeMillis();
- private final Thread updater = new Log4jThread("Clock Updater Thread") {
+ private final Thread updater = new Log4jThread("CoarseCachedClock Updater Thread") {
@Override
public void run() {
while (true) {
http://git-wip-us.apache.org/repos/asf/logging-log4j2/blob/dbbeb5cf/log4j-flume-ng/src/main/java/org/apache/logging/log4j/flume/appender/FlumePersistentManager.java
----------------------------------------------------------------------
diff --git a/log4j-flume-ng/src/main/java/org/apache/logging/log4j/flume/appender/FlumePersistentManager.java b/log4j-flume-ng/src/main/java/org/apache/logging/log4j/flume/appender/FlumePersistentManager.java
index 9442abe..bc591c2 100644
--- a/log4j-flume-ng/src/main/java/org/apache/logging/log4j/flume/appender/FlumePersistentManager.java
+++ b/log4j-flume-ng/src/main/java/org/apache/logging/log4j/flume/appender/FlumePersistentManager.java
@@ -490,6 +490,7 @@ public class FlumePersistentManager extends FlumeAvroManager {
public WriterThread(final Database database, final Environment environment,
final FlumePersistentManager manager, final Gate gate, final int batchsize,
final SecretKey secretKey, final AtomicLong dbCount, final int lockTimeoutRetryCount) {
+ super("FlumePersistentManager-Writer");
this.database = database;
this.environment = environment;
this.manager = manager;