run() — netty Function Reference

Architecture documentation for the run() function in UDTClientServerConnectionTest.java from the netty codebase.

Function java Buffer Telemetry calls 2 called by 1

Entity Profile

Buffer→ Telemetry→ run() — netty Function Reference

Dependency Diagram

graph TD
  96b8c4e6_d3c3_17d6_a8c3_a91250f3642c["run()"]
  04943c9a_8ea1_0974_cf09_4ca1510eeef0["Client"]
  96b8c4e6_d3c3_17d6_a8c3_a91250f3642c -->|defined in| 04943c9a_8ea1_0974_cf09_4ca1510eeef0
  15c7489b_6c9b_a2f1_adb8_b6985fa97a5b["run()"]
  15c7489b_6c9b_a2f1_adb8_b6985fa97a5b -->|calls| 96b8c4e6_d3c3_17d6_a8c3_a91250f3642c
  15c7489b_6c9b_a2f1_adb8_b6985fa97a5b["run()"]
  96b8c4e6_d3c3_17d6_a8c3_a91250f3642c -->|calls| 15c7489b_6c9b_a2f1_adb8_b6985fa97a5b
  632a767d_e337_a2b4_e179_e0d936c7c46f["waitForRunning()"]
  96b8c4e6_d3c3_17d6_a8c3_a91250f3642c -->|calls| 632a767d_e337_a2b4_e179_e0d936c7c46f
  style 96b8c4e6_d3c3_17d6_a8c3_a91250f3642c fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

testsuite/src/main/java/io/netty/testsuite/transport/udt/UDTClientServerConnectionTest.java lines 73–111

        @Override
        public void run() {
            final Bootstrap boot = new Bootstrap();
            final ThreadFactory clientFactory = new DefaultThreadFactory("client");
            final EventLoopGroup connectGroup = new MultiThreadIoEventLoopGroup(1,
                    clientFactory, NioIoHandler.newFactory(NioUdtProvider.BYTE_PROVIDER));
            try {
                boot.group(connectGroup)
                        .channelFactory(NioUdtProvider.BYTE_CONNECTOR)
                        .handler(new ChannelInitializer<UdtChannel>() {

                            @Override
                            protected void initChannel(final UdtChannel ch)
                                    throws Exception {
                                final ChannelPipeline pipeline = ch.pipeline();
                                pipeline.addLast("framer",
                                        new DelimiterBasedFrameDecoder(8192,
                                                Delimiters.lineDelimiter()));
                                pipeline.addLast("decoder", new StringDecoder(
                                        CharsetUtil.UTF_8));
                                pipeline.addLast("encoder", new StringEncoder(
                                        CharsetUtil.UTF_8));
                                pipeline.addLast("handler", new ClientHandler());
                            }
                        });
                channel = boot.connect(address).sync().channel();
                isRunning = true;
                log.info("Client ready.");
                waitForRunning(false);
                log.info("Client closing...");
                channel.close().sync();
                isShutdown = true;
                log.info("Client is done.");
            } catch (final Throwable e) {
                log.error("Client failed.", e);
            } finally {
                connectGroup.shutdownGracefully().syncUninterruptibly();
            }
        }