run() — netty Function Reference

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

Function java Buffer Telemetry

Entity Profile

Buffer→ Telemetry→ run() — netty Function Reference

Dependency Diagram

graph TD
  a332caff_4f20_e293_c8ce_8c8f1590919c["run()"]
  379bebcd_d565_3dae_c6b9_313138d1f960["ByteEchoPeerBase"]
  a332caff_4f20_e293_c8ce_8c8f1590919c -->|defined in| 379bebcd_d565_3dae_c6b9_313138d1f960
  style a332caff_4f20_e293_c8ce_8c8f1590919c fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

example/src/main/java/io/netty/example/udt/echo/rendezvousBytes/ByteEchoPeerBase.java lines 54–75

    public void run() throws Exception {
        final ThreadFactory connectFactory = new DefaultThreadFactory("rendezvous");
        final EventLoopGroup connectGroup = new MultiThreadIoEventLoopGroup(1,
                connectFactory, NioIoHandler.newFactory(NioUdtProvider.BYTE_PROVIDER));
        try {
            final Bootstrap bootstrap = new Bootstrap();
            bootstrap.group(connectGroup)
                    .channelFactory(NioUdtProvider.BYTE_RENDEZVOUS)
                    .handler(new ChannelInitializer<UdtChannel>() {
                        @Override
                        protected void initChannel(UdtChannel ch) throws Exception {
                            ch.pipeline().addLast(
                                    new LoggingHandler(LogLevel.INFO),
                                    new ByteEchoPeerHandler(messageSize));
                        }
                    });
            final ChannelFuture future = bootstrap.connect(peerAddress, myAddress).sync();
            future.channel().closeFuture().sync();
        } finally {
            connectGroup.shutdownGracefully();
        }
    }