Skip to main content
summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
Diffstat (limited to 'plugins/org.eclipse.net4j/src/org/eclipse/net4j/signal/Signal.java')
-rw-r--r--plugins/org.eclipse.net4j/src/org/eclipse/net4j/signal/Signal.java19
1 files changed, 19 insertions, 0 deletions
diff --git a/plugins/org.eclipse.net4j/src/org/eclipse/net4j/signal/Signal.java b/plugins/org.eclipse.net4j/src/org/eclipse/net4j/signal/Signal.java
index d1b1c8c2da..52972750f2 100644
--- a/plugins/org.eclipse.net4j/src/org/eclipse/net4j/signal/Signal.java
+++ b/plugins/org.eclipse.net4j/src/org/eclipse/net4j/signal/Signal.java
@@ -13,6 +13,8 @@ package org.eclipse.net4j.signal;
import org.eclipse.net4j.buffer.BufferInputStream;
import org.eclipse.net4j.buffer.BufferOutputStream;
import org.eclipse.net4j.util.ReflectUtil;
+import org.eclipse.net4j.util.StringUtil;
+import org.eclipse.net4j.util.concurrent.RunnableWithName;
import org.eclipse.net4j.util.io.ExtendedDataInputStream;
import org.eclipse.net4j.util.io.ExtendedDataOutputStream;
import org.eclipse.net4j.util.io.IOTimeoutException;
@@ -270,6 +272,18 @@ public abstract class Signal implements Runnable
{
Exception exception = null;
+ String name = null;
+ String oldName = null;
+ Thread thread = null;
+
+ if (RunnableWithName.THREAD_NAMES)
+ {
+ thread = Thread.currentThread();
+ oldName = thread.getName();
+ name = StringUtil.isEmpty(oldName) ? toString() : oldName + " - " + toString();
+ thread.setName(name);
+ }
+
try
{
execute(bufferInputStream, bufferOutputStream);
@@ -286,6 +300,11 @@ public abstract class Signal implements Runnable
}
finally
{
+ if (thread != null)
+ {
+ thread.setName(oldName);
+ }
+
if (closeInputStreamAfterMe())
{
IOUtil.closeSilent(wrappedInputStream != null ? wrappedInputStream : bufferInputStream);

Back to the top