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 <[email protected]> Authored: Fri Mar 17 15:42:19 2017 +0900 Committer: Sergiy Matusevych <[email protected]> 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>> {
