diff options
author | Arne H Juul <arnej@yahooinc.com> | 2021-12-16 14:43:20 +0000 |
---|---|---|
committer | Arne H Juul <arnej@yahooinc.com> | 2021-12-16 14:43:44 +0000 |
commit | 7f825e71fb23b2ebb6047efe088746a7cbccc917 (patch) | |
tree | 09cd1eb651b9586bd8bb68fec1d2404f9e1b8721 /documentapi | |
parent | 9a4a247b44beed310a9bb2441ad1feb1610aaf06 (diff) |
most unit tests can run with just 1 network thread
Diffstat (limited to 'documentapi')
4 files changed, 5 insertions, 5 deletions
diff --git a/documentapi/src/test/java/com/yahoo/documentapi/messagebus/protocol/test/PolicyFactoryTestCase.java b/documentapi/src/test/java/com/yahoo/documentapi/messagebus/protocol/test/PolicyFactoryTestCase.java index 9ee58f746a5..473b9c9d5dd 100755 --- a/documentapi/src/test/java/com/yahoo/documentapi/messagebus/protocol/test/PolicyFactoryTestCase.java +++ b/documentapi/src/test/java/com/yahoo/documentapi/messagebus/protocol/test/PolicyFactoryTestCase.java @@ -42,7 +42,7 @@ public class PolicyFactoryTestCase { public void setUp() throws ListenFailedException { slobrok = new Slobrok(); srv = new TestServer(new MessageBusParams().addProtocol(new DocumentProtocol(new DocumentTypeManager())), - new RPCNetworkParams().setSlobrokConfigId(TestServer.getSlobrokConfig(slobrok))); + new RPCNetworkParams().setNumNetworkThreads(1).setSlobrokConfigId(TestServer.getSlobrokConfig(slobrok))); src = srv.mb.createSourceSession(new SourceSessionParams().setReplyHandler(new Receptor())); } diff --git a/documentapi/src/test/java/com/yahoo/documentapi/messagebus/protocol/test/PolicyTestFrame.java b/documentapi/src/test/java/com/yahoo/documentapi/messagebus/protocol/test/PolicyTestFrame.java index b2fce64f784..a067261ba1a 100755 --- a/documentapi/src/test/java/com/yahoo/documentapi/messagebus/protocol/test/PolicyTestFrame.java +++ b/documentapi/src/test/java/com/yahoo/documentapi/messagebus/protocol/test/PolicyTestFrame.java @@ -80,7 +80,7 @@ public class PolicyTestFrame { e.printStackTrace(); fail(e.getMessage()); } - net = new MyNetwork(new RPCNetworkParams() + net = new MyNetwork(new RPCNetworkParams().setNumNetworkThreads(1) .setIdentity(new Identity(identity)) .setSlobrokConfigId(TestServer.getSlobrokConfig(slobrok))); mbus = new MessageBus(net, new MessageBusParams() diff --git a/documentapi/src/test/java/com/yahoo/documentapi/messagebus/protocol/test/RoutableFactoryTestCase.java b/documentapi/src/test/java/com/yahoo/documentapi/messagebus/protocol/test/RoutableFactoryTestCase.java index cde6a7484ea..51728b67347 100755 --- a/documentapi/src/test/java/com/yahoo/documentapi/messagebus/protocol/test/RoutableFactoryTestCase.java +++ b/documentapi/src/test/java/com/yahoo/documentapi/messagebus/protocol/test/RoutableFactoryTestCase.java @@ -51,11 +51,11 @@ public class RoutableFactoryTestCase { DocumentTypeManager docMan = new DocumentTypeManager(); dstProtocol = new DocumentProtocol(docMan); dstServer = new TestServer(new MessageBusParams().addProtocol(dstProtocol), - new RPCNetworkParams().setIdentity(new Identity("dst")).setSlobrokConfigId(TestServer.getSlobrokConfig(slobrok))); + new RPCNetworkParams().setNumNetworkThreads(1).setIdentity(new Identity("dst")).setSlobrokConfigId(TestServer.getSlobrokConfig(slobrok))); dstSession = dstServer.mb.createDestinationSession(new DestinationSessionParams().setName("session").setMessageHandler(new Receptor())); srcProtocol = new DocumentProtocol(docMan); srcServer = new TestServer(new MessageBusParams().addProtocol(srcProtocol), - new RPCNetworkParams().setSlobrokConfigId(TestServer.getSlobrokConfig(slobrok))); + new RPCNetworkParams().setNumNetworkThreads(1).setSlobrokConfigId(TestServer.getSlobrokConfig(slobrok))); srcSession = srcServer.mb.createSourceSession(new SourceSessionParams().setReplyHandler(new Receptor())); assertTrue(srcServer.waitSlobrok("dst/session", 1)); } diff --git a/documentapi/src/test/java/com/yahoo/documentapi/messagebus/test/Destination.java b/documentapi/src/test/java/com/yahoo/documentapi/messagebus/test/Destination.java index 0670358f097..06f82168447 100644 --- a/documentapi/src/test/java/com/yahoo/documentapi/messagebus/test/Destination.java +++ b/documentapi/src/test/java/com/yahoo/documentapi/messagebus/test/Destination.java @@ -47,7 +47,7 @@ public class Destination implements MessageHandler { access = new LocalDocumentAccess(params); local = access.createSyncSession(new SyncParameters.Builder().build()); bus = new RPCMessageBus(Arrays.asList((Protocol)new DocumentProtocol(access.getDocumentTypeManager())), - new RPCNetworkParams() + new RPCNetworkParams().setNumNetworkThreads(1) .setIdentity(new Identity("test/destination")) .setSlobrokConfigId(slobrokConfigId), "file:src/test/cfg/messagebus.cfg"); |