writeAndVerifyReceived() — netty Function Reference

Architecture documentation for the writeAndVerifyReceived() function in SSLEngineTest.java from the netty codebase.

Function java Buffer Allocators called by 1

Entity Profile

Buffer→ Allocators→ writeAndVerifyReceived() — netty Function Reference

Dependency Diagram

graph TD
  2f05b04e_8d41_a94c_69db_94145cf59172["writeAndVerifyReceived()"]
  9150c92a_2afc_b83a_c3bf_86dfac6e9d9b["SSLEngineTest"]
  2f05b04e_8d41_a94c_69db_94145cf59172 -->|defined in| 9150c92a_2afc_b83a_c3bf_86dfac6e9d9b
  cae059a1_758b_6d13_c2a1_9c18dc21631d["runTest()"]
  cae059a1_758b_6d13_c2a1_9c18dc21631d -->|calls| 2f05b04e_8d41_a94c_69db_94145cf59172
  style 2f05b04e_8d41_a94c_69db_94145cf59172 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

handler/src/test/java/io/netty/handler/ssl/SSLEngineTest.java lines 1332–1350

    private static void writeAndVerifyReceived(ByteBuf message, Channel sendChannel, CountDownLatch receiverLatch,
                                               MessageReceiver receiver) throws Exception {
        List<ByteBuf> dataCapture = null;
        try {
            assertTrue(sendChannel.writeAndFlush(message).await(10, TimeUnit.SECONDS));
            receiverLatch.await(5, TimeUnit.SECONDS);
            message.resetReaderIndex();
            assertFalse(receiver.messages.isEmpty());
            dataCapture = new ArrayList<ByteBuf>();
            receiver.messages.drainTo(dataCapture);
            assertEquals(message, dataCapture.get(0));
        } finally {
            if (dataCapture != null) {
                for (ByteBuf data : dataCapture) {
                    data.release();
                }
            }
        }
    }