You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@reef.apache.org by mo...@apache.org on 2017/03/21 19:45:45 UTC
reef git commit: [REEF-1661] RejectedExecutionException thrown when
closing the acceptor in NettyMessageTransport
Repository: reef
Updated Branches:
refs/heads/master e851c4614 -> 3cca11846
[REEF-1661] RejectedExecutionException thrown when closing the acceptor in NettyMessageTransport
Project: http://git-wip-us.apache.org/repos/asf/reef/repo
Commit: http://git-wip-us.apache.org/repos/asf/reef/commit/3cca1184
Tree: http://git-wip-us.apache.org/repos/asf/reef/tree/3cca1184
Diff: http://git-wip-us.apache.org/repos/asf/reef/diff/3cca1184
Branch: refs/heads/master
Commit: 3cca118468d0974c623ecccc920395edc0580a3f
Parents: e851c46
Author: taegeonum <ta...@gmail.com>
Authored: Fri Mar 17 15:42:19 2017 +0900
Committer: Sergiy Matusevych <mo...@apache.org>
Committed: Tue Mar 21 12:45:18 2017 -0700
----------------------------------------------------------------------
.../reef/io/network/util/NetworkMessagingTestService.java | 7 -------
1 file changed, 7 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/reef/blob/3cca1184/lang/java/reef-io/src/test/java/org/apache/reef/io/network/util/NetworkMessagingTestService.java
----------------------------------------------------------------------
diff --git a/lang/java/reef-io/src/test/java/org/apache/reef/io/network/util/NetworkMessagingTestService.java b/lang/java/reef-io/src/test/java/org/apache/reef/io/network/util/NetworkMessagingTestService.java
index 92e4980..59fd0c8 100644
--- a/lang/java/reef-io/src/test/java/org/apache/reef/io/network/util/NetworkMessagingTestService.java
+++ b/lang/java/reef-io/src/test/java/org/apache/reef/io/network/util/NetworkMessagingTestService.java
@@ -23,7 +23,6 @@ import org.apache.reef.io.network.Connection;
import org.apache.reef.io.network.Message;
import org.apache.reef.io.network.NetworkConnectionService;
import org.apache.reef.io.network.impl.config.NetworkConnectionServiceIdFactory;
-import org.apache.reef.io.network.naming.NameResolver;
import org.apache.reef.io.network.naming.NameResolverConfiguration;
import org.apache.reef.io.network.naming.NameServer;
import org.apache.reef.tang.Configuration;
@@ -51,8 +50,6 @@ public final class NetworkMessagingTestService implements AutoCloseable {
private final NetworkConnectionService receiverNetworkConnService;
private final NetworkConnectionService senderNetworkConnService;
private final NameServer nameServer;
- private final NameResolver receiverResolver;
- private final NameResolver senderResolver;
public NetworkMessagingTestService(final String localAddress) throws InjectionException {
// name server
@@ -67,14 +64,12 @@ public final class NetworkMessagingTestService implements AutoCloseable {
// network service for receiver
final Injector injectorReceiver = injector.forkInjector(netConf);
this.receiverNetworkConnService = injectorReceiver.getInstance(NetworkConnectionService.class);
- this.receiverResolver = injectorReceiver.getInstance(NameResolver.class);
this.factory = injectorReceiver.getNamedInstance(NetworkConnectionServiceIdFactory.class);
// network service for sender
LOG.log(Level.FINEST, "=== Test network connection service sender start");
final Injector injectorSender = injector.forkInjector(netConf);
senderNetworkConnService = injectorSender.getInstance(NetworkConnectionService.class);
- this.senderResolver = injectorSender.getInstance(NameResolver.class);
}
public <T> void registerTestConnectionFactory(final Identifier connFactoryId,
@@ -101,8 +96,6 @@ public final class NetworkMessagingTestService implements AutoCloseable {
senderNetworkConnService.close();
receiverNetworkConnService.close();
nameServer.close();
- receiverResolver.close();
- senderResolver.close();
}
public static final class MessageHandler<T> implements EventHandler<Message<T>> {