testEventsFired() — netty Function Reference

Architecture documentation for the testEventsFired() function in SslHandlerTest.java from the netty codebase.

Function java Buffer Allocators calls 1

Entity Profile

Buffer→ Allocators→ testEventsFired() — netty Function Reference

Dependency Diagram

graph TD
  02081a7b_d616_d8c4_04ff_d292c6b63efa["testEventsFired()"]
  adaf7dc7_94e2_152f_ffdb_453fdaa4f25e["SslHandlerTest"]
  02081a7b_d616_d8c4_04ff_d292c6b63efa -->|defined in| adaf7dc7_94e2_152f_ffdb_453fdaa4f25e
  0fd148d9_de21_9e3d_3bde_be07148f32de["userEventTriggered()"]
  02081a7b_d616_d8c4_04ff_d292c6b63efa -->|calls| 0fd148d9_de21_9e3d_3bde_be07148f32de
  style 02081a7b_d616_d8c4_04ff_d292c6b63efa fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

handler/src/test/java/io/netty/handler/ssl/SslHandlerTest.java lines 565–589

    @Test
    @Timeout(value = 5000, unit = TimeUnit.MILLISECONDS)
    public void testEventsFired() throws Exception {
        SSLEngine engine = newServerModeSSLEngine();
        final BlockingQueue<SslCompletionEvent> events = new LinkedBlockingQueue<SslCompletionEvent>();
        EmbeddedChannel channel = new EmbeddedChannel(new SslHandler(engine), new ChannelInboundHandlerAdapter() {
            @Override
            public void userEventTriggered(ChannelHandlerContext ctx, Object evt) throws Exception {
                if (evt instanceof SslCompletionEvent) {
                    events.add((SslCompletionEvent) evt);
                }
            }
        });
        assertTrue(events.isEmpty());
        assertTrue(channel.finishAndReleaseAll());

        SslCompletionEvent evt = events.take();
        assertTrue(evt instanceof SslHandshakeCompletionEvent);
        assertInstanceOf(ClosedChannelException.class, evt.cause());

        evt = events.take();
        assertTrue(evt instanceof SslCloseCompletionEvent);
        assertInstanceOf(ClosedChannelException.class, evt.cause());
        assertTrue(events.isEmpty());
    }