Repository: reef Updated Branches: refs/heads/master 8657733fd -> 10678052c
[REEF-1762] Fix the expected number of messages in NetworkServiceTest.testMultithreadedSharedConnMessagingNetworkServiceRate JIRA: [REEF-1762](https://issues.apache.org/jira/browse/REEF-1762) Pull request: This closes #1281 Project: http://git-wip-us.apache.org/repos/asf/reef/repo Commit: http://git-wip-us.apache.org/repos/asf/reef/commit/10678052 Tree: http://git-wip-us.apache.org/repos/asf/reef/tree/10678052 Diff: http://git-wip-us.apache.org/repos/asf/reef/diff/10678052 Branch: refs/heads/master Commit: 10678052ca227b23e3b5c15f8613aed0dd3d59b2 Parents: 8657733 Author: taegeonum <[email protected]> Authored: Fri Mar 31 16:29:36 2017 +0900 Committer: Sergiy Matusevych <[email protected]> Committed: Fri Mar 31 10:10:17 2017 -0700 ---------------------------------------------------------------------- .../test/java/org/apache/reef/io/network/NetworkServiceTest.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/reef/blob/10678052/lang/java/reef-io/src/test/java/org/apache/reef/io/network/NetworkServiceTest.java ---------------------------------------------------------------------- diff --git a/lang/java/reef-io/src/test/java/org/apache/reef/io/network/NetworkServiceTest.java b/lang/java/reef-io/src/test/java/org/apache/reef/io/network/NetworkServiceTest.java index 373fd31..86acc86 100644 --- a/lang/java/reef-io/src/test/java/org/apache/reef/io/network/NetworkServiceTest.java +++ b/lang/java/reef-io/src/test/java/org/apache/reef/io/network/NetworkServiceTest.java @@ -386,7 +386,7 @@ public class NetworkServiceTest { final Injector injectorNs2 = injector2.forkInjector(); injectorNs2.bindVolatileParameter(NetworkServiceParameters.NetworkServiceHandler.class, - new MessageHandler<String>(name2, monitor, numMessages)); + new MessageHandler<String>(name2, monitor, totalNumMessages)); final NetworkService<String> ns2 = injectorNs2.getInstance(NetworkService.class); final Injector injectorNs1 = injector2.forkInjector();
