diff --git a/engine/src/networking/com/jme3/network/base/ConnectorAdapter.java b/engine/src/networking/com/jme3/network/base/ConnectorAdapter.java index b5ca1b507..2903e77b9 100644 --- a/engine/src/networking/com/jme3/network/base/ConnectorAdapter.java +++ b/engine/src/networking/com/jme3/network/base/ConnectorAdapter.java @@ -82,7 +82,7 @@ public class ConnectorAdapter extends Thread this.reliable = reliable; setDaemon(true); writer = Executors.newFixedThreadPool(1, - new NamedThreadFactory(String.valueOf(connector) + "-writer")); + new NamedThreadFactory(String.valueOf(connector) + "-writer", true)); } public void close() diff --git a/engine/src/networking/com/jme3/network/base/KernelAdapter.java b/engine/src/networking/com/jme3/network/base/KernelAdapter.java index 3a0961648..2ef9f3909 100644 --- a/engine/src/networking/com/jme3/network/base/KernelAdapter.java +++ b/engine/src/networking/com/jme3/network/base/KernelAdapter.java @@ -143,7 +143,11 @@ public class KernelAdapter extends Thread try { HostedConnection source = getConnection(p); if( source == null ) { - log.log( Level.WARNING, "Recieved message from unconnected endpoint:" + p + " message:" + m ); + if( reliable ) { + // If it's a reliable connection then it's slightly more + // concerning but this can happen all the time for a UDP endpoint. + log.log( Level.WARNING, "Recieved message from unconnected endpoint:" + p + " message:" + m ); + } return; } messageDispatcher.messageReceived( source, m ); diff --git a/engine/src/networking/com/jme3/network/kernel/NamedThreadFactory.java b/engine/src/networking/com/jme3/network/kernel/NamedThreadFactory.java index 05cbe52ce..46e0f762f 100644 --- a/engine/src/networking/com/jme3/network/kernel/NamedThreadFactory.java +++ b/engine/src/networking/com/jme3/network/kernel/NamedThreadFactory.java @@ -46,6 +46,7 @@ import java.util.concurrent.ThreadFactory; public class NamedThreadFactory implements ThreadFactory { private String name; + private boolean daemon; private ThreadFactory delegate; public NamedThreadFactory( String name ) @@ -53,9 +54,20 @@ public class NamedThreadFactory implements ThreadFactory this( name, Executors.defaultThreadFactory() ); } + public NamedThreadFactory( String name, boolean daemon ) + { + this( name, daemon, Executors.defaultThreadFactory() ); + } + public NamedThreadFactory( String name, ThreadFactory delegate ) + { + this( name, false, delegate ); + } + + public NamedThreadFactory( String name, boolean daemon, ThreadFactory delegate ) { this.name = name; + this.daemon = daemon; this.delegate = delegate; } @@ -64,6 +76,7 @@ public class NamedThreadFactory implements ThreadFactory Thread result = delegate.newThread(r); String s = result.getName(); result.setName( name + "[" + s + "]" ); + result.setDaemon(daemon); return result; } }