netty Architecture Docs
Home / Class/ RxtxUnsafe Class — netty Architecture

RxtxUnsafe Class — netty Architecture

Architecture documentation for the RxtxUnsafe class in RxtxChannel.java from the netty codebase.

Class java

Entity Profile

Dependency Diagram

graph TD
  9f111b14_1674_16a9_19ce_6d3150be2298["RxtxUnsafe"]
  da4861a2_5b5d_56e1_8521_a9674728c5f5["RxtxChannel.java"]
  9f111b14_1674_16a9_19ce_6d3150be2298 -->|defined in| da4861a2_5b5d_56e1_8521_a9674728c5f5
  00581f20_0dcc_c5da_cef6_8b4ae5a2b485["connect()"]
  9f111b14_1674_16a9_19ce_6d3150be2298 -->|method| 00581f20_0dcc_c5da_cef6_8b4ae5a2b485

Relationship Graph

Source Code

transport-rxtx/src/main/java/io/netty/channel/rxtx/RxtxChannel.java lines 152–194

    private final class RxtxUnsafe extends AbstractUnsafe {
        @Override
        public void connect(
                final SocketAddress remoteAddress,
                final SocketAddress localAddress, final ChannelPromise promise) {
            if (!promise.setUncancellable() || !ensureOpen(promise)) {
                return;
            }

            try {
                final boolean wasActive = isActive();
                doConnect(remoteAddress, localAddress);

                int waitTime = config().getOption(WAIT_TIME);
                if (waitTime > 0) {
                    eventLoop().schedule(new Runnable() {
                        @Override
                        public void run() {
                            try {
                                doInit();
                                safeSetSuccess(promise);
                                if (!wasActive && isActive()) {
                                    pipeline().fireChannelActive();
                                }
                            } catch (Throwable t) {
                                safeSetFailure(promise, t);
                                closeIfClosed();
                            }
                        }
                   }, waitTime, TimeUnit.MILLISECONDS);
                } else {
                    doInit();
                    safeSetSuccess(promise);
                    if (!wasActive && isActive()) {
                        pipeline().fireChannelActive();
                    }
                }
            } catch (Throwable t) {
                safeSetFailure(promise, t);
                closeIfClosed();
            }
        }
    }

Defined In

Source

Frequently Asked Questions

What is the RxtxUnsafe class?
RxtxUnsafe is a class in the netty codebase, defined in transport-rxtx/src/main/java/io/netty/channel/rxtx/RxtxChannel.java.
Where is RxtxUnsafe defined?
RxtxUnsafe is defined in transport-rxtx/src/main/java/io/netty/channel/rxtx/RxtxChannel.java at line 152.

Analyze Your Own Codebase

Get architecture documentation, dependency graphs, and domain analysis for your codebase in minutes.

Try Supermodel Free