Test multi-threaded Netty server support #94
Merged
Conversation
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Codecov ReportAll modified and coverable lines are covered by tests ✅
Additional details and impacted files@@ Coverage Diff @@
## master #94 +/- ##
============================================
- Coverage 93.16% 93.14% -0.03%
+ Complexity 2009 2007 -2
============================================
Files 133 133
Lines 4549 4549
Branches 616 616
============================================
- Hits 4238 4237 -1
Misses 170 170
- Partials 141 142 +1 ☔ View full report in Codecov by Sentry. |
akolosov-n
force-pushed
the
alko/test-multiple-servers
branch
from
61df578
to
0acc9d5
Compare
akolosov-n
force-pushed
the
alko/test-multiple-servers
branch
from
0acc9d5
to
12a91be
Compare
szysas
reviewed
Aug 27, 2024
Comment on lines
234
to
286
| @Test | ||
| @EnabledOnOs(OS.LINUX) | ||
| void multi_thread_server() throws Exception { | ||
| int threads = 4; | ||
| EventLoopGroup epollGroup = new EpollEventLoopGroup(threads, new DefaultThreadFactory("srv", true)); | ||
| Bootstrap bootstrap = new Bootstrap() | ||
| .group(epollGroup) | ||
| .localAddress(new Random().nextInt(32000) + 32000) | ||
| .channel(EpollDatagramChannel.class) | ||
| .option(EpollChannelOption.SO_REUSEPORT, true) | ||
| .handler(new ChannelInitializer<DatagramChannel>() { | ||
| @Override | ||
| protected void initChannel(DatagramChannel ch) { | ||
| ch.pipeline().addFirst("DTLS", new DtlsChannelHandler(serverConf)); | ||
| } | ||
| }); | ||
| CoapServerBuilder serverBuilder = CoapServer.builder() | ||
| .executor(eventLoopGroup) | ||
| .route(RouterService.builder() | ||
| .get("/test", __ -> ok("OK").toFuture()) | ||
| .post("/echo", req -> CompletableFuture.supplyAsync(() -> ok(req.getPayload()).build())) | ||
| ); | ||
| List<CoapServer> servers = new ArrayList<>(); | ||
| for (int i = 0; i < threads; i++) { | ||
| servers.add( | ||
| serverBuilder | ||
| .transport(new NettyCoapTransport(bootstrap, EMPTY_RESOLVER)) | ||
| .build() | ||
| .start() | ||
| ); | ||
| } | ||
|
|
||
| List<CoapClient> clients = new ArrayList<>(); | ||
| InetSocketAddress srvAddr = localhost(servers.get(0).getLocalSocketAddress().getPort()); | ||
| CoapServerBuilder clientBuilder = CoapServer.builder().executor(eventLoopGroup); | ||
| for (int i = 0; i < 100; i++) { | ||
| clients.add( | ||
| clientBuilder | ||
| .transport(new NettyCoapTransport(createClientBootstrap(srvAddr), EMPTY_RESOLVER)) | ||
| .buildClient(srvAddr) | ||
| ); | ||
| } | ||
|
|
||
| for (CoapClient client : clients) { | ||
| assertEquals(ok("paska"), client.sendSync(post("/echo").payload("paska"))); | ||
| client.close(); | ||
| } | ||
|
|
||
| for (CoapServer srv : servers) { | ||
| srv.stop(); | ||
| } | ||
| epollGroup.shutdownGracefully(0, 0, TimeUnit.SECONDS); | ||
| } |
There was a problem hiding this comment.
Lets have it on separate file, anyway this does not share anything from other tests,
szysas
approved these changes
Aug 27, 2024
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
No description provided.