Unsafe() — netty Function Reference

Architecture documentation for the Unsafe() function in EmbeddedQuicStreamChannel.java from the netty codebase.

Function java Buffer Allocators

Entity Profile

Buffer→ Allocators→ Unsafe() — netty Function Reference

Dependency Diagram

graph TD
  28f7683a_c31e_544c_6199_357920f9836b["Unsafe()"]
  2d34325c_8fee_a954_938b_a19a27c3e0a4["EmbeddedQuicStreamChannel"]
  28f7683a_c31e_544c_6199_357920f9836b -->|defined in| 2d34325c_8fee_a954_938b_a19a27c3e0a4
  style 28f7683a_c31e_544c_6199_357920f9836b fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

codec-http3/src/test/java/io/netty/handler/codec/http3/EmbeddedQuicStreamChannel.java lines 213–299

    @Override
    public Unsafe unsafe() {
        if (unsafe == null) {
            Unsafe superUnsafe = super.unsafe();
            unsafe = new Unsafe() {
                @Override
                public RecvByteBufAllocator.Handle recvBufAllocHandle() {
                    return superUnsafe.recvBufAllocHandle();
                }

                @Override
                public SocketAddress localAddress() {
                    return superUnsafe.localAddress();
                }

                @Override
                public SocketAddress remoteAddress() {
                    return superUnsafe.remoteAddress();
                }

                @Override
                public void register(EventLoop eventLoop, ChannelPromise promise) {
                    superUnsafe.register(eventLoop, promise);
                }

                @Override
                public void bind(SocketAddress localAddress, ChannelPromise promise) {
                    superUnsafe.bind(localAddress, promise);
                }

                @Override
                public void connect(SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise promise) {
                    superUnsafe.connect(remoteAddress, localAddress, promise);
                }

                @Override
                public void disconnect(ChannelPromise promise) {
                    superUnsafe.disconnect(promise);
                }

                @Override
                public void close(ChannelPromise promise) {
                    superUnsafe.close(promise);
                }

                @Override
                public void closeForcibly() {
                    superUnsafe.closeForcibly();
                }

                @Override
                public void deregister(ChannelPromise promise) {
                    superUnsafe.deregister(promise);
                }

                @Override
                public void beginRead() {
                    superUnsafe.beginRead();
                }

                @Override
                public void write(Object msg, ChannelPromise promise) {
                    if (msg instanceof QuicStreamFrame && ((QuicStreamFrame) msg).hasFin()) {
                        // Mimic the API.
                        promise = promise.unvoid().addListener(f -> outputShutdown = 0);
                    }
                    superUnsafe.write(msg, promise);
                }

                @Override
                public void flush() {
                    superUnsafe.flush();
                }

                @Override
                public ChannelPromise voidPromise() {
                    return superUnsafe.voidPromise();
                }

                @Override
                public ChannelOutboundBuffer outboundBuffer() {